Files
dispatcher_ng/dist/MySwitchThing.js
Wolfgang Hottgenroth 50b0b85f4f nothing
2018-05-16 10:26:36 +02:00

52 lines
1.9 KiB
JavaScript

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const logger = require("./log");
const MqttDispatcher_1 = require("./MqttDispatcher");
const AItem_1 = require("./AItem");
class MySwitchSingleItem {
constructor(actionTopic) {
this.actionTopic = actionTopic;
}
processMessage(topic, payload) {
switch (payload) {
case 'PRESS_SHORT':
MqttDispatcher_1.mqttHandler.send(this.actionTopic, 'SHORT', true);
break;
case 'PRESS_LONG_START':
case 'PRESS_LONG_CONT':
MqttDispatcher_1.mqttHandler.send(this.actionTopic, 'LONG_HOLD', true);
break;
case 'PRESS_LONG_END':
MqttDispatcher_1.mqttHandler.send(this.actionTopic, 'LONG_END', true);
break;
default:
logger.warn(`HM4BSI: no handling available for ${topic}`);
break;
}
}
}
exports.MySwitchSingleItem = MySwitchSingleItem;
class MySwitchThing extends AItem_1.AItem {
constructor(floor, room, item, itemObjs) {
super(floor, room, item, '');
this.itemObjs = itemObjs;
if (this.itemObjs.length != 3) {
throw new Error('itemObjs for MySwitchThing must have three elements');
}
this.subscribeTopics = [
`${this.topicFirstPart}/#`
];
}
processMessage(topic, payload) {
logger.info(`MyT: ${topic}, ${payload}`);
let buttonIdx = parseInt(topic.substring(this.topicFirstPart.length + 1));
if (buttonIdx >= 1 && buttonIdx <= 3) {
this.itemObjs[buttonIdx - 1].processMessage('', payload);
}
else {
logger.warn(`MyT: no handling available for ${topic}, ${buttonIdx}`);
}
}
}
exports.MySwitchThing = MySwitchThing;
//# sourceMappingURL=MySwitchThing.js.map