let client = null;
let connected = false;
let connectionAttempt = 1;

const clientId = "vFwKg";

const REMOTE = false;
let hostname = "192.168.1.186"

const port = 8080;
let path = "";

const mainTopic = "train_control";
const user = "1731445474889";
const pass = "5180YRZIQbdSfeca<,.>";

const keepAlive = 60;
const timeout = 30;
const tls = REMOTE;
const cleanSession = true;
const lastWillTopic = `Test/LastWills/${clientId}`;
const lastWillQos = 0;
const lastWillRetain = true;
const lastWillMessageVal = `${clientId}:closed`;
let connectOptions;

var messageElement;

document.addEventListener("DOMContentLoaded", (event) => {
  messageElement = document.getElementById('message');
  // body...
  client = new Paho.MQTT.Client(hostname, Number(port), path, clientId);
  logMessage(`INFO    Connecting to Server: [Host: ${hostname}, Port: ${port}, Path: ${client.path}, ID: ${clientId}]`);

  // set callback handlers
  client.onConnectionLost = onConnectionLost;
  client.onMessageArrived = onMessageArrived;
  client.onConnected = onConnected;

  let lastWillMessage = new Paho.MQTT.Message(lastWillMessageVal);
  lastWillMessage.destinationName = lastWillTopic;
  lastWillMessage.qos = lastWillQos;
  lastWillMessage.retained = lastWillRetain;

  connectOptions = {
    invocationContext: {
      host: hostname,
      port: port,
      path: client.path,
      clientId: clientId
    },
    timeout: timeout,
    keepAliveInterval: keepAlive,
    cleanSession: cleanSession,
    useSSL: tls,
    onSuccess: onConnect,
    onFailure: onFail,
    userName: user,
    password: pass,
    willMessage: lastWillMessage
  };

  // connect the client
  client.connect(connectOptions);
});

client.subscribe('*{mainTopic}/#', { qos: Number(0) });

client.subscribe(mainTopic);