# Place your local configuration in /etc/mosquitto/conf.d/
#
# A full description of the configuration file is at
# /usr/share/doc/mosquitto/examples/mosquitto.conf.example

pid_file /var/run/mosquitto.pid

persistence false
#persistence_location /var/lib/mosquitto/

log_dest none

include_dir /home/pi/components/PlantGlue/cloudmqtt_conf.d

listener 1883
listener 1884
protocol websockets

'use strict'

var mqtt = require('mqtt')
var net = require('net');

//var HOST = '192.168.1.3';
var HOST = process.argv[2] || 'localhost';
var PORT = process.argv[3] || 8888;

var JsonSocket = require('json-socket');
var tcpclient = new JsonSocket(new net.Socket());

var clientId = 'mqttjs_' + Math.random().toString(16).substr(2, 8)

var host = 'mqtt://m20.cloudmqtt.com'

var options = {
  port: 17203,
  keepalive: 10,
  clientId: clientId,
  protocolId: 'MQTT',
  protocolVersion: 4,
  clean: true,
  reconnectPeriod: 1000,
  connectTimeout: 30 * 1000,
  will: {
    topic: 'WillMsg',
    payload: 'Connection Closed abnormally..!',
    qos: 0,
    retain: false
  },
  username: 'publisher',
  password: 'publisher',
  rejectUnauthorized: false
}

var client = mqtt.connect(host, options)

client.on('connect', function () {
  client.subscribe('Pan')
  client.subscribe('Tilt')
  client.subscribe('Zoom')
  client.subscribe('AttA')
  client.subscribe('AttB')
  client.subscribe('AttC')
  client.subscribe('AttD')
})

client.on('message', function (topic, message) {
  // message is Buffer
  var mymessage="{\"Command\": \""+topic+"\", \"Value\": "+message.toString()+"}";  
  console.log(mymessage);
  // Write a message to the socket as soon as the client is connected, the server will
  // receive it as message from the client 
  tcpclient.sendMessage({Command: topic, Value: parseFloat(message.toString())});
})

tcpclient.connect(PORT, HOST, function() {

    console.log('CONNECTED TO: ' + HOST + ':' + PORT);
});

var net = require('net');

var HOST = 'localhost';
var PORT = 8888;

net.createServer(function(sock) {

    // We have a connection - a socket object is assigned to the connection automatically
    console.log('CONNECTED: ' + sock.remoteAddress +':'+ sock.remotePort);

    // Add a 'data' event handler to this instance of socket
    sock.on('data', function(data) {

        console.log('DATA ' + sock.remoteAddress + ': ' + data);        
    });

    // Add a 'close' event handler to this instance of socket
    sock.on('close', function(data) {
        console.log('CLOSED: ' + sock.remoteAddress +' '+ sock.remotePort);
    });

}).listen(PORT, HOST);

console.log('Server listening on ' + HOST +':'+ PORT);

node ServerForTest.js

node GmdGateway.js