73 lines
3.4 KiB
JavaScript
73 lines
3.4 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
const logger = require("./log");
|
|
const MqttDispatcher_1 = require("./MqttDispatcher");
|
|
const AItem_1 = require("./AItem");
|
|
const Export_1 = require("./Export");
|
|
class RelayBoxThing extends AItem_1.AItem {
|
|
constructor(floor, room, item, deviceCommandTopic, deviceStatusTopic, itemNames) {
|
|
super(floor, room, item, '');
|
|
this.itemNames = itemNames;
|
|
this.deviceCommandTopic = deviceCommandTopic;
|
|
this.deviceStatusTopic = deviceStatusTopic;
|
|
this.stateTopicPre = `${this.topicFirstPart}/state`;
|
|
this.feedbackTopicPre = `${this.topicFirstPart}/feedback`;
|
|
this.conflictTopicPre = `${this.topicFirstPart}/conflict`;
|
|
this.subscribeTopics = [
|
|
`${this.deviceStatusTopic}`,
|
|
`${this.stateTopicPre}/#`
|
|
];
|
|
this.oldSwitchStates = '';
|
|
}
|
|
exportItem() {
|
|
return Export_1.RelayBoxExport(this.itemId, this.stateTopicPre, this.feedbackTopicPre, this.conflictTopicPre, this.itemNames);
|
|
}
|
|
processMessage(topic, payload) {
|
|
// logger.info(`RT: ${topic}, ${payload}`)
|
|
if (topic == this.deviceStatusTopic) {
|
|
// logger.info(`RT: status received`)
|
|
this.status = JSON.parse(payload);
|
|
let statusParsed = JSON.stringify(this.status);
|
|
this.switchStates = JSON.stringify(this.status.data.switchStates);
|
|
if (this.switchStates != this.oldSwitchStates) {
|
|
this.oldSwitchStates = this.switchStates;
|
|
logger.info(`RT: status parsed: ${statusParsed}`);
|
|
logger.info(`RT: device: ${this.status.metadata.device}`);
|
|
logger.info(`RT: uptime: ${this.status.data.uptime}`);
|
|
for (let i = 0; i < this.itemNames.length; i++) {
|
|
if (this.status.data.switchStates[i].feedbackState == '0') {
|
|
MqttDispatcher_1.mqttHandler.send(`${this.feedbackTopicPre}/${i}`, 'OFF');
|
|
}
|
|
else {
|
|
MqttDispatcher_1.mqttHandler.send(`${this.feedbackTopicPre}/${i}`, 'ON');
|
|
}
|
|
if (this.status.data.switchStates[i].stateConflict == '0') {
|
|
MqttDispatcher_1.mqttHandler.send(`${this.conflictTopicPre}/${i}`, 'CLEAR');
|
|
}
|
|
else {
|
|
MqttDispatcher_1.mqttHandler.send(`${this.conflictTopicPre}/${i}`, 'CONFLICT');
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
logger.info(`RT: ${topic}, ${payload}`);
|
|
let thingRelatedPart = topic.substring(this.stateTopicPre.length + 1);
|
|
let itemIdx = parseInt(thingRelatedPart);
|
|
logger.info(`RT: pre: ${this.stateTopicPre}, thingRelatedPart: ${thingRelatedPart}, itemIdx: ${itemIdx}`);
|
|
if (itemIdx >= 0 && itemIdx < this.itemNames.length) {
|
|
if (payload == 'ON') {
|
|
MqttDispatcher_1.mqttHandler.send(this.deviceCommandTopic, `switch ${itemIdx} on`);
|
|
}
|
|
else {
|
|
MqttDispatcher_1.mqttHandler.send(this.deviceCommandTopic, `switch ${itemIdx} off`);
|
|
}
|
|
}
|
|
else {
|
|
logger.warn(`RT: no handling available for ${topic}`);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
exports.RelayBoxThing = RelayBoxThing;
|
|
//# sourceMappingURL=RelayBox.js.map
|