Public/node-red-contrib-mi-devices
2
0
Fork 0
Code Pull Requests Activity

refactor(socket): move on/off to dedicated actions

Browse Source
This commit is contained in:
Pierre CLEMENT
2018-01-03 13:05:01 +01:00
parent a33d616516
commit 8a40a6ad54
11 changed files with 715 additions and 66 deletions
Download Patch File Download Diff File Expand all files Collapse all files

66
node-red-contrib-xiaomi-socket/xiaomi-socket.js
View File

@@ -5,70 +5,28 @@ module.exports = (RED) => {
RED.nodes.createNode(this, config);
this.gateway = RED.nodes.getNode(config.gateway);
this.sid = config.sid;
this.key = this.gateway.key;
var currentToken = "";
var state = "";
this.status({fill:"yellow", shape:"ring", text:"waiting for key"});
this.status({fill:"grey", shape:"ring", text:"status"});
if (this.gateway && this.key != "") {
this.on('input', (msg) => {
var payload = msg.payload;
if (payload.cmd == "heartbeat" && payload.model == "gateway") {
var token = payload.token;
if (token) {
var cipher = crypto.createCipheriv('aes128', node.key, (new Buffer("17996d093d28ddb3ba695a2e6f58562e", "hex")));
var encoded_string = cipher.update(token, 'utf8', 'hex');
encoded_string += cipher.final('hex');
currentToken = encoded_string.substring(0,32);
if (state == "") {
node.status({fill:"yellow", shape:"dot", text:"unknown state"});
if(payload.sid) {
if (payload.sid == this.sid) {
if (data.status && data.status == "on") {
this.status({fill:"green", shape:"dot", text:"on"});
} else if (data.status && data.status == "off") {
this.status({fill:"red", shape:"dot", text:"off"});
}
this.send(msg);
}
}
if (payload == 'on') {
var cmd =
{ "cmd":"write",
"sid": node.sid,
"model": "plug",
"data": JSON.stringify({"status":"on", "key": currentToken })
}
msg.payload = JSON.stringify(cmd);
node.send([[],[msg]]);
} else if (payload == "off") {
var cmd =
{ "cmd":"write",
"sid": node.sid,
"model": "plug",
"data": JSON.stringify({"status":"off", "key": currentToken })
}
msg.payload = JSON.stringify(cmd);
node.send([[],[msg]]);
} else if (payload.sid == node.sid && payload.model == "plug") {
var data = JSON.parse(payload.data)
if (currentToken == "") {
node.status({fill:"yellow", shape:"ring", text:"waiting for key"});
} else if (data.status && data.status == "on") {
node.status({fill:"green", shape:"dot", text:"on"});
state = "on";
} else if (data.status && data.status == "off") {
node.status({fill:"red", shape:"dot", text:"off"});
state = "off";
}
msg.payload = payload;
node.send([msg]);
// Prepare for request
else {
miDevicesUtils.prepareForGatewayRequest(this, msg);
this.send(msg);
}
});
} else if (this.key == "") {
node.status({fill:"red", shape:"dot", text:"no key configured"});
}
}