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

var tls_opts = {
  host: 'mqtt.flespi.io',
  port: 8883,
  rejectUnauthorized: false,
  isServer: false,
  cert: fs.readFileSync('client.crt'),
  key: fs.readFileSync('client.key'),
}

var tlsSocket = tls.connect(tls_opts);

var mqtt_opts = {
  socket: tlsSocket,
  clientId: 'iotjs-tls-test',
  username: 'A9FdGsACZzsWRjWSe1LI1PMYPVaHQE6gDzi9SIBH5RsK1et534BSIeHlXFSD9MHC',
  keepalive: 10,
}

var mqttClient = mqtt.getClient(mqtt_opts);

var mqtt_sub_opts = {
  topic: 'iotjs-test',
}

var mqtt_pub_opts = {
  topic: 'iotjs-test',
  message: 'hello-iotjs',
}

tlsSocket.on('secureConnect', function () {
  mqttClient.on('suback', function () {
    mqttClient.publish(mqtt_pub_opts);
  });

  mqttClient.connect(function () {
    mqttClient.subscribe(mqtt_sub_opts);
  });
});

mqttClient.on('message', function(mes) {
  console.log('MESSAGE RECEIVED: ');
  console.log(mes.message.toString());
  mqttClient.disconnect();
});