Practical Internet of Things with JavaScript

Updating the API engine

Now, we will add the required code to the MQTT client running on the API engine to handle the data from the device. Update api-engine/server/mqtt/index.js, as follows:

var Data = require('../api/data/data.model'); var mqtt = require('mqtt'); var config = require('../config/environment'); var client = mqtt.connect({ port: config.mqtt.port, protocol: 'mqtts', host: config.mqtt.host, clientId: config.mqtt.clientId, reconnectPeriod: 1000, username: config.mqtt.clientId, password: config.mqtt.clientId, keepalive: 300, rejectUnauthorized: false }); client.on('connect', function() { console.log('Connected to Mosca at ' + config.mqtt.host + ' on port ' + config.mqtt.port); client.subscribe('api-engine'); client.subscribe('dht11'); ...