Imported-Repos/yandex2mqtt
1
0
Fork 0
mirror of https://github.com/lasthead0/yandex2mqtt.git synced 2025-08-08 09:01:00 +03:00
Code Issues Packages Projects Releases Wiki Activity

test version notification api

Browse Source
This commit is contained in:
Evgenii Abramov
2021-05-13 00:53:02 +03:00
parent 23fab5fde9
commit 2808c2c2a3
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app.js
View File

@@ -129,16 +129,16 @@ global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
console.log(`statusCode: ${res.statusCode}`); console.log(`statusCode: ${res.statusCode}`);
res.on('data', d => { res.on('data', d => {
process.stdout.write(d); // process.stdout.write(d);
}); });
}); });
req.on('error', error => { req.on('error', error => {
console.error(error) // console.error(error)
}); });
let {id, capabilities, properties} = ldevice.getState(); let {id, capabilities, properties} = ldevice.getState();
const a = { req.write(JSON.stringify({
"ts": Math.floor(Date.now() / 1000), "ts": Math.floor(Date.now() / 1000),
"payload": { "payload": {
"user_id": `${user_id}`, "user_id": `${user_id}`,
@@ -148,9 +148,7 @@ global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
properties: properties.filter(p => p.state.instance == instance) properties: properties.filter(p => p.state.instance == instance)
}], }],
} }
}; }));
console.dir(a, {depth: 10});
req.write(JSON.stringify(a));
req.end(); req.end();