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

c

Browse Source
This commit is contained in:
Evgenii Abramov
2021-05-12 22:17:01 +03:00
parent 3cdddcfae1
commit 0f08320411
1 changed files with 39 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
app.js
View File

@@ -112,17 +112,21 @@ global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
ldevice.updateState(`${message}`, instance); ldevice.updateState(`${message}`, instance);
/* */ /* */
Promise.all(config.notification.map(el => {
const [skill_id, oauth_token, user_id] = el;
return new Promise((resolve, reject) => {
const req = https.request({ const req = https.request({
hostname: 'dialogs.yandex.net', hostname: 'dialogs.yandex.net',
port: 443, port: 443,
path: `/api/v1/skills/${config.notification.skill_id}/callback/state`, path: `/api/v1/skills/${skill_id}/callback/state`,
method: 'POST', method: 'POST',
headers: { headers: {
'Content-Type': `application/json`, 'Content-Type': `application/json`,
'Authorization': `OAuth ${config.notification.oauth_token}` 'Authorization': `OAuth ${oauth_token}`
} }
}, res => { }, res => {
console.log(`statusCode: ${res.statusCode}`) console.log(`statusCode: ${res.statusCode}`);
res.on('data', d => { res.on('data', d => {
console.log(d); console.log(d);
@@ -137,12 +141,19 @@ global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
req.write(JSON.stringify({ req.write(JSON.stringify({
"ts": Math.floor(Date.now() / 1000), "ts": Math.floor(Date.now() / 1000),
"payload": { "payload": {
"user_id": '1', "user_id": `${user_id}`,
"devices": [ldevice.getState()], "devices": [ldevice.getState()],
} }
})); }));
req.end(); req.end();
resolve(true);
});
}));
/* */
}); });
module.exports = app; module.exports = app;