MQTT /get flow

[andreareginato]

After the Redis configuration the /get definition is not working. Most probably the /get channel with Mosca (or Ascoltatori) is defined as a Buffer(hex).

We need to understand how to fix this problem to make things correctly work as right now we "hack" this problem by defining a MQTT

// NORMAL FLOW (using Ascoltatori)
publish(req, '/get/')
var publish = function(req, mode) {
  payload = { message: req.body };
  payload.message = new Buffer(payload.message, 'hex');
  var topic = 'devices/' + req.params.id + mode;
  debug('[API REQ] Publishing topic', topic, req.body, payload.toString());

  ascoltatore.publish(topic, req.body, function() {
    console.log('[API REQ] Message published to the topic', topic, req.body);
  });
}

// HACK
var client = mqtt.createClient(port, host, { username: req.params.id, password: req.get('X-Physical-Secret') });
client.on('connect', function() {
   client.publish('devices/' + req.params.id + '/get', JSON.stringify(req.body));
   client.end();
})

One further note (obvious) is that the MQTT client (pass through Mosca) works just fine. If I pass through Ascoltatori it doesn't set properly the payload. We need to understand how Mosca uses ascoltatori to store the Redis messages.