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

var host = process.argv[2];

var client = mqtt.connect({
  host: host,
  port: 1883
});

// sample use
// node randy.js 10.129.242.21 V1/#

// Topic to subscribe too
var topic = process.argv[3];

client.on('connect', function () {
  console.log('connected');
  client.subscribe(topic);
});

client.on('message', function (topic, message) {
  var time = new Date().toUTCString();
  var data = message.toString();
  var log = ["Topic: ", topic, ", Message: ", data].join('');
  console.log(log);
});