03__Cybus_TimeSeriesPublisher_Machine_Demo.js

var Thread = Java.type("java.lang.Thread");
var Instant = Java.type("java.time.Instant");

var topic = "cybus/machine/1CY816L0ⓥ3/lastMovement";

function execute(action) {
  out("Test Script: " + action.getName());
  for (var i = 0; i < 1000; i++) {
    randomTimeSeriesPing();
    Thread.sleep(2000);
  }
  action.setExitCode(0);
  action.setResultText("done.");
  out("Test Script: Done");
  return action;
}

function randomTimeSeriesPing() {
  var time = Instant.now().toString();
  out("time published: " + time);

  var randomTemp = Math.random()*100;
  var randomX = Math.random()*100;
  var randomY = Math.random()*100;
  var randomZ = Math.random()*100;

  var message = { 
    machineId: "1CY816L0ⓥ3", 
    eventTimestamp: time,
    temperature: randomTemp,
    position: {
      X: randomX,
      Y: randomY, 
      Z: randomZ
    }, 
    status: "operational" 
  };

  mqttManager.publish(topic, JSON.stringify(message));
}

function out(message){
  output.print(message);
}