wn/dispatcher_ng
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

still status handling

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2018-03-27 21:03:07 +02:00
parent 0977223736
commit 3179c84684
2 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
dist/RelayBox.js vendored
View File

@ -16,14 +16,22 @@ class RelayBoxThing extends AItem_1.AItem {
]; ];
} }
processMessage(topic, payload) { processMessage(topic, payload) {
logger.info(`RT: ${topic}, ${payload}`); // logger.info(`RT: ${topic}, ${payload}`)
if (topic == this.deviceStatusTopic) { if (topic == this.deviceStatusTopic) {
logger.info(`RT: status received`); logger.info(`RT: status received`);
let status = JSON.parse(payload); let status = JSON.parse(payload);
let statusParsed = JSON.stringify(status); let statusParsed = JSON.stringify(status);
logger.info(`RT: status parsed: ${statusParsed}`); logger.info(`RT: status parsed: ${statusParsed}`);
logger.info(`RT: device: ${status.metadata.device}`);
logger.info(`RT: uptime: ${status.data.uptime}`);
for (let i = 0; i < this.itemNames.length; i++) {
logger.info(`RT: state: ${status.data.switchstatus[i].state}`);
logger.info(`RT: feedb: ${status.data.switchstatus[i].feedbackState}`);
logger.info(`RT: confl: ${status.data.switchstatus[i].stateConflict}`);
}
} }
else { else {
logger.info(`RT: ${topic}, ${payload}`);
let thingRelatedPart = topic.substring(this.stateTopicPre.length + 1); let thingRelatedPart = topic.substring(this.stateTopicPre.length + 1);
let itemIdx = parseInt(thingRelatedPart); let itemIdx = parseInt(thingRelatedPart);
logger.info(`RT: pre: ${this.stateTopicPre}, thingRelatedPart: ${thingRelatedPart}, itemIdx: ${itemIdx}`); logger.info(`RT: pre: ${this.stateTopicPre}, thingRelatedPart: ${thingRelatedPart}, itemIdx: ${itemIdx}`);

5
src/RelayBox.ts
View File

@ -32,6 +32,11 @@ export class RelayBoxThing extends AItem {
logger.info(`RT: status parsed: ${statusParsed}`) logger.info(`RT: status parsed: ${statusParsed}`)
logger.info(`RT: device: ${status.metadata.device}`) logger.info(`RT: device: ${status.metadata.device}`)
logger.info(`RT: uptime: ${status.data.uptime}`) logger.info(`RT: uptime: ${status.data.uptime}`)
for (let i : number = 0; i < this.itemNames.length; i ++) {
logger.info(`RT: state: ${status.data.switchstatus[i].state}`)
logger.info(`RT: feedb: ${status.data.switchstatus[i].feedbackState}`)
logger.info(`RT: confl: ${status.data.switchstatus[i].stateConflict}`)
}
} else { } else {
logger.info(`RT: ${topic}, ${payload}`) logger.info(`RT: ${topic}, ${payload}`)
let thingRelatedPart = topic.substring(this.stateTopicPre.length+1) let thingRelatedPart = topic.substring(this.stateTopicPre.length+1)