sails-hook-mqtt

There are no updates planned for this hook for Sails v1.0 and beyond.

Feel free to continue to use this hook in existing projects, as-is, as long as it's doing the job for you. Just note that it's no longer the approach the Sails core team uses for new apps. Instead, we are now recommending the approach for publish & subscribe mqtt to topics that is bundled as part of sails new in Sails v1.

To try that out, run sails new foo --caviar using Sails >= v1.0 and Node <= v7.9.

If you're unsure or need advice, visit https://sailsjs.com/support.

Email hook for Sails JS, using MQTT.js

Note: This requires Sails v0.10.6+.

Installation

npm install sails-hook-mqtt After installation it create,

1. config/mqtt.js, Mqtt Configuration
2. mqtt/hander.js, Event hander for mqtt client

Usage

sails.hooks.mqtt.publish(topic, message, cb)

Parameter	Type	Details
topic	((string))	Topic is the topic to publish to
message	((string))	Data to use to replace template tokens
cb	((function))	Callback to be run after publish message (or if an error occurs).

sails.hooks.mqtt.subscribe(topic, cb)

Parameter	Type	Details
topic	((string))	Topic is the topic to publish to
cb	((function))	Callback to be run after subscribe message (or if an error occurs).

Configuration

By default, configuration lives in sails.config.mqtt or config/mqtt.js. The configuration key (mqtt) can be changed by setting sails.config.hooks['sails-hook-mqtt'].configKey.

broker

Broker URL

Parameter	Type	Details
brocker	((string))	brocker url, example mqtt://127.0.0.1

connect

connection perameters

Parameter	Type	Details
host	((string))	any hostname or ip
port	((string))	proker port no.
clientId	((string))	Uniqe ID for mqtt client
username	((string))	the username required by your broker, if any
password	((string))	the password required by your broker, if any
resubscribe	((string))	if connection is broken and reconnects, subscribed topics are automatically subscribed again (default true)
reconnectPeriod	((string))	1000 milliseconds, interval between two reconnections
connectTimeout	((string))	30 * 1000 milliseconds, time to wait before a CONNACK is received
queueQoSZero	((string))	if connection is broken, queue outgoing QoS zero messages (default true)
clean	((string))	true, set to false to receive QoS 1 and 2 messages while offline
will	((string))	a message that will sent by the broker automatically when the client disconnect badly, format in example.
key	((string))	absolute path to key
cert	((string))	absolute path to cert
ca	((string))	absolute path to ca
handler	((object))	handler to manage the events.

publishOptions

option on publish message

Parameter	Type	Details
qos	((string))	QoS level, Number, default 0
retain	((string))	retain flag, Boolean, default false
dup	((string))	mark as duplicate flag, Boolean, default false

subscribeOptions

option on subscribe topic

Parameter	Type	Details
qos	((string))	QoS level, Number, default 0

topics

Array of default topics (string)

Example

// [your-sails-app]/config/mqtt.js
 
module.exports.mqtt = {
  _hookTimeout: 20000,
  broker : 'mqtt://127.0.0.1',                        // broker url
  connect:{                                           // connection config
    host : '127.0.0.1',                         // host name <optional></optional>
    port : 8883 ,                                   // port no.
    clientId : 'sails_hook_mqtt_client',            // client id
     protocolId: 'MQTT',                            // protocol id (optional)
    username:'test_client',                         // mqtt basic auth (optional)
    password:'public',                              // mqtt basic auth (optional)      
    resubscribe: true,                              // (optional)
    reconnectPeriod:1000,                           // (optional)
    connectTimeout:30*1000,                         // (optional)
    queueQoSZero:true,  //if connection is broken, queue outgoing QoS zero messages (default true)(optional)
    will:{                                          // a message that will sent by the broker automatically when the client disconnect badly (optional)
      topic:"server/disconnect",
      payload:JSON.stringify({msg:'i am off-line'}),
      qos:1,
      clean:false
    },
    key : 'path_to/server.key',                    // Absolute path to key (optional)
    cert :'path_to/server.crt',                   // Absolute path to cert (optional)
    ca :  'path_to/ca.crt',                        // Absolute path to ca (optional)
    clean: false,                                   // (optional)
  },
  publishOption:{                                   // default option to subcribe topics
    qos:1,                                          // QoS level, Number, default 0 (optional)
    retain : true,                                  //retain flag, Boolean, default false (optional)
    dup : false                                     // mark as duplicate flag, Boolean, default false (optional)
  },
    subscribeOption:{                                   // default option to subcribe topics (optional)
    qos:1                                         // QoS level, Number, default 0 (optional)
  },
  topics : [                                          // default topics to subcriblbe
    "topic/#"
  ],
  handler : require('../mqtt/handler.js')             // handler object
}

Example

executing the following command (after configuring for your mqtt service and turning off test mode) :

// PUBLISH MESSAGE TO TOPIC OR TOPICS(`array of topics`)

sails.hooks.mqtt.publish('topic/any',"Hi, I am published message",function(err){
  if(err){
    sails.log.error(new Error(err));
  }
  sails.log.debug('Message published successfully');
});

//SUBSCRIBE TOPIC OR TOPICS(`array of topics`)
sails.hooks.mqtt.subscribe('topic/#',function(err, granted){
  if(err){
    sails.log.error(new Error(err));
  }
  sails.log.debug('Topic subscribe successfully');
});