19 lines
616 B
JavaScript
19 lines
616 B
JavaScript
var mqtt = require('mqtt');
|
|
var client = mqtt.connect('mqtt://localhost',{
|
|
username: process.env.TOKEN
|
|
});
|
|
|
|
client.on('connect', function () {
|
|
console.log('connected');
|
|
client.subscribe('v1/devices/me/rpc/request/+')
|
|
client.subscribe('v1/devices/me/attributes')
|
|
});
|
|
|
|
client.on('message', function (topic, message) {
|
|
console.log('request.topic: ' + topic);
|
|
console.log('request.body: ' + message.toString());
|
|
var requestId = topic.slice('v1/devices/me/rpc/request/'.length);
|
|
//client acts as an echo service
|
|
client.publish('v1/devices/me/rpc/response/' + requestId, message);
|
|
});
|