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

feat(all): send messages as parts

Browse Source
This commit is contained in:
Pierre CLEMENT
2018-03-23 23:08:53 +01:00
parent 1828e35a4d
commit df64a9521c
5 changed files with 38 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
dist/devices/gateway/Magnet.js vendored
View File

@@ -21,7 +21,7 @@ class Magnet extends GatewaySubdevice_1.GatewaySubdevice {
super.handleMessage(msg);
if (msg.isReadAck() || msg.isReport()) {
let data = msg.data;
// mintime
// TODO: mintime
if (this.status !== data.status) {
this.status = data.status;
this.emit('values-updated', this.sid);

22
dist/nodes/gateway-subdevices/All.js vendored
View File

@@ -1,6 +1,7 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const constants_1 = require("../constants");
const uniqid = require("uniqid");
exports.default = (RED) => {
class All {
static getOnlyModelsValue(input) {
@@ -12,28 +13,35 @@ exports.default = (RED) => {
}
constructor(props) {
RED.nodes.createNode(this, props);
this.gateway = RED.nodes.getNode(props.gateway);
this.gatewayConf = RED.nodes.getNode(props.gateway);
this.onlyModels = All.getOnlyModelsValue(props.onlyModels || []);
this.excludedSids = props.excludedSids;
this.setMessageListener();
}
setMessageListener() {
this.on('input', (msg) => {
if (this.gateway) {
if (this.gatewayConf) {
// Filter input
if (msg.payload && msg.payload.model && msg.payload.sid) {
if (!this.isDeviceValid(msg.payload)) {
if (!this.isDeviceValid(msg.payload.sid)) {
msg = null;
}
this.send(msg);
}
else {
Object.keys(this.gateway.deviceList || {})
let partsId = uniqid();
Object.keys(this.gatewayConf.deviceList || {})
.filter((sid) => this.isDeviceValid(sid))
.forEach((sid) => {
.forEach((sid, i, subSids) => {
let curMsg = Object.assign({}, msg);
delete curMsg._msgid;
curMsg.parts = {
id: partsId,
index: i,
count: subSids.length,
};
curMsg.sid = sid;
curMsg.gateway = this.gateway;
curMsg.gateway = this.gatewayConf;
this.send(curMsg);
});
}
@@ -44,7 +52,7 @@ exports.default = (RED) => {
if ((!this.onlyModels || this.onlyModels.length == 0) && (!this.excludedSids || this.excludedSids.length == 0)) {
return true;
}
let device = this.gateway.deviceList[sid];
let device = this.gatewayConf.deviceList[sid];
// Is excluded
if ((this.excludedSids && this.excludedSids.length != 0) && this.excludedSids.indexOf(sid) >= 0) {
return false;

1
package.json
View File

@@ -47,6 +47,7 @@
"dependencies": {
"cryptojs": "^2.5.3",
"miio": "^0.15.4",
"uniqid": "^4.1.1",
"yeelight-wifi": "^2.3.0"
},
"engines": {

3
src/devices/gateway/Magnet.ts
View File

@@ -29,7 +29,8 @@ export class Magnet extends GatewaySubdevice {
super.handleMessage(msg);
if (msg.isReadAck() || msg.isReport()) {
let data = <GatewayMessageReadAckMagnetData> msg.data;
// mintime
// TODO: mintime
if (this.status !== data.status) {
this.status = data.status;
this.emit('values-updated', this.sid);

27
src/nodes/gateway-subdevices/All.ts
View File

@@ -1,9 +1,10 @@
import {Red, NodeProperties} from "node-red";
import {Constants} from "../constants";
import * as uniqid from 'uniqid';
export default (RED: Red) => {
class All {
protected gateway: any;
protected gatewayConf: any;
protected onlyModels: string[];
protected excludedSids: string[];
@@ -17,7 +18,7 @@ export default (RED: Red) => {
constructor(props: NodeProperties) {
RED.nodes.createNode(<any> this, props);
this.gateway = RED.nodes.getNode((<any> props).gateway);
this.gatewayConf = RED.nodes.getNode((<any> props).gateway);
this.onlyModels = All.getOnlyModelsValue((<any> props).onlyModels || []);
this.excludedSids = (<any> props).excludedSids;
@@ -26,22 +27,31 @@ export default (RED: Red) => {
protected setMessageListener() {
(<any> this).on('input', (msg) => {
if (this.gateway) {
if (this.gatewayConf) {
// Filter input
if (msg.payload && msg.payload.model && msg.payload.sid) {
if (!this.isDeviceValid(msg.payload)) {
if (!this.isDeviceValid(msg.payload.sid)) {
msg = null;
}
(<any> this).send(msg);
}
// Prepare for request
else {
Object.keys(this.gateway.deviceList || {})
let partsId = uniqid();
Object.keys(this.gatewayConf.deviceList || {})
.filter((sid) => this.isDeviceValid(sid))
.forEach((sid) => {
.forEach((sid, i, subSids) => {
let curMsg = Object.assign({}, msg);
delete curMsg._msgid;
curMsg.parts = {
id: partsId,
index: i,
count: subSids.length,
};
curMsg.sid = sid;
curMsg.gateway = this.gateway;
curMsg.gateway = this.gatewayConf;
(<any> this).send(curMsg);
});
}
@@ -53,7 +63,8 @@ export default (RED: Red) => {
if ((!this.onlyModels || this.onlyModels.length == 0) && (!this.excludedSids || this.excludedSids.length == 0)) {
return true;
}
let device = this.gateway.deviceList[sid];
let device = this.gatewayConf.deviceList[sid];
// Is excluded
if ((this.excludedSids && this.excludedSids.length != 0) && this.excludedSids.indexOf(sid) >= 0) {
return false;