27 lines
864 B
JavaScript
27 lines
864 B
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
const log = require("./log");
|
|
const config = require("./config");
|
|
const Mqtt = require("mqtt");
|
|
const fs = require("fs");
|
|
log.info("SmallSender starting");
|
|
config.readConfig();
|
|
let mqttOptions = {
|
|
username: config.dict.brokerUser,
|
|
password: config.dict.brokerPass,
|
|
ca: fs.readFileSync(config.dict.brokerCa, 'ascii'),
|
|
rejectUnauthorized: true
|
|
};
|
|
let mqttClient = Mqtt.connect(config.dict.brokerUrl, mqttOptions);
|
|
mqttClient.on('error', log.error);
|
|
mqttClient.on('connect', () => {
|
|
log.info("connected to mqtt broker");
|
|
});
|
|
let cnt = 0;
|
|
let timer = setInterval(() => {
|
|
log.info(`Publishing a message ${cnt}`);
|
|
mqttClient.publish("IoT/DeviceInfo", `OrangePi ${cnt}`);
|
|
cnt += 1;
|
|
}, 10 * 1000);
|
|
log.info("SmallSender running");
|
|
//# sourceMappingURL=main.js.map
|