test_subscriber.js

// This file creates an MQTT client and connects to the HiveMQ Cloud Broker
// Example of subscribing to a topic and receiving messages

const mqtt = require('mqtt');

/*
const options = {
  // Clean session
  clean: true,
  connectTimeout: 4000,
  // Auth
  clientId: 'emqx_test',
  username: 'emqx_test',
  password: 'emqx_test',
}
*/

var client  = mqtt.connect('mqtt://broker.hivemq.com');

// connect to broker
client.on('connect', function () {
  client.subscribe("cameronhowley888");
  console.log("Client has subscribed successfully");
});
  /* parse string message
  client.on('message', function (topic, message) {
    if (topic === 'cameronhowley888') {
      console.log(message.toString());
    }
    
  });
  */ 
  // parse json file - message is json, packet contains data about transmission
  client.on('message', function (topic, message, packet) {
    // ensure message from correct topic
    if (topic === 'cameronhowley888') {
      const obj = JSON.parse(message.toString())
      
      // store data in database
      let data = obj.Data
      let meterNum = obj.MeterNum
      console.log(obj)

    }
    
  })