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

test

Browse Source
This commit is contained in:
Evgenii Abramov
2021-03-29 21:47:40 +03:00
parent b81480e0d4
commit b504261d34
1 changed files with 26 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
app.js
View File

@@ -94,24 +94,6 @@ global.devices.forEach(device => {
}); });
}); });
/* */
var noticeRequest;
const yc = config.yandex;
if (yc != undefined) {
noticeRequest = https.request({
hostname: 'dialogs.yandex.net',
port: 443,
path: `/api/v1/skills/${yc.skillId}/callback/state`,
method: 'POST',
headers: {
'Authorization': yc.token,
'Content-Type': 'application/json'
}
}, res => {
});
};
/* Create MQTT client (variable) in global */ /* Create MQTT client (variable) in global */
global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, { global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
port: config.mqtt.port, port: config.mqtt.port,
@@ -130,19 +112,19 @@ global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
ldevice.updateState(`${message}`, instance); ldevice.updateState(`${message}`, instance);
/* */ /* */
// if ((yc = config.yandex) != undefined) { if ((yc = config.yandex) != undefined) {
// const noticeRequest = https.request({ const noticeRequest = https.request({
// hostname: 'dialogs.yandex.net', hostname: 'dialogs.yandex.net',
// port: 443, port: 443,
// path: `/api/v1/skills/${yc.skillId}/callback/state`, path: `/api/v1/skills/${yc.skillId}/callback/state`,
// method: 'POST', method: 'POST',
// headers: { headers: {
// 'Authorization': yc.token, 'Authorization': yc.token,
// 'Content-Type': 'application/json' 'Content-Type': 'application/json'
// } }
// }, res => { }, res => {
// }); });
const st = ldevice.getState(); const st = ldevice.getState();
noticeRequest.write(JSON.stringify({ noticeRequest.write(JSON.stringify({
ts: Math.floor(Date.now() / 1000), ts: Math.floor(Date.now() / 1000),
@@ -156,7 +138,7 @@ global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
} }
})); }));
noticeRequest.end(); noticeRequest.end();
// } }
/* */ /* */
}); });