Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
MQTT-Octoblu connector
const util = require('util');
var S = require('string');
var mqtt = require('mqtt');
var meshblu = require('meshblu');
var meshbluJSON = require("./meshblu.json");
// Specifies how you want your message payload to be passed
// from Octoblu to your device
var MESSAGE_SCHEMA = {
type: 'object',
properties: {
topic: {
type: 'string',
required: true
},
message: {
type: 'string',
required: true
}
}
};
connectionTimer = setTimeout(function() {
console.log("Timeout setting up connections, exiting.");
process.exit(1);
}, 120000);
// Not specifying a UUID/Token auto-registers a new device
var conn = meshblu.createConnection({
"uuid": meshbluJSON.uuid,
"token": meshbluJSON.token,
"server": "meshblu.octoblu.com",
"port": 80
});
conn.on('notReady', function(data){
console.log('Octoblu UUID FAILED AUTHENTICATION!');
console.log(data);
client.publish("Log/ops", "Octoblu connection failed: " + util.format(data));
});
var client = mqtt.connect('mqtt://localhost', {protocolId: 'MQIsdp', protocolVersion: 3});
client.on('connect', function () {
console.log("Connected to MQTT");
client.subscribe('Octoblu/#');
});
client.on('message', function (topic, message) {
console.log("MQTT RX t=" + topic + " m=" + message.toString());
var p = S(topic).splitLeft("/", 1);
if (p.length > 1) {
client.publish("Log/octoblu/outbound/" + topic, message.toString());
conn.message({
"devices": "*",
"topic": topic,
"message": message.toString()
});
}
});
conn.on('ready', function(rdata){
console.log('UUID AUTHENTICATED!');
console.log(rdata);
clearTimeout(connectionTimer);
connectionTimer = undefined;
conn.update({
"uuid": meshbluJSON.uuid,
"token": meshbluJSON.token,
"messageSchema": MESSAGE_SCHEMA,
});
conn.on('message', function(data){
console.log('Octoblu message received');
console.log(data);
if (('topic' in data) && ('message' in data)) {
client.publish(data.topic, data.message);
client.publish("Log/octoblu/inbound/" + data.topic, data.message);
}
});
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment