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-16 02:54:41 +03:00
parent 0f79098f44
commit 5184680a6f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
app.js
View File

@@ -29,8 +29,8 @@ global.logger = createLogger({
format: combine( format: combine(
label(), label(),
timestamp(), timestamp(),
printf(({level, message, label, timestamp}) => { printf(({level, message, timestamp}) => {
return `${timestamp} [${label}] ${level}: ${message}`; return `${timestamp} ${level}: ${message}`;
}) })
), ),
transports: [ transports: [
@@ -148,13 +148,13 @@ global.mqttClient = mqtt.connect(`mqtt://${config.mqtt.host}`, {
} }
}, res => { }, res => {
res.on('data', d => { res.on('data', d => {
global.logger.log('info', {message: `${d}`, label: 'notification'}); global.logger.log('info', {message: `${d}`});
// process.stdout.write(d); // process.stdout.write(d);
}); });
}); });
req.on('error', error => { req.on('error', error => {
global.logger.log('error', 'notification', {message: `${error}`}); global.logger.log('error', {message: `${error}`});
}); });
let {id, capabilities, properties} = ldevice.getState(); let {id, capabilities, properties} = ldevice.getState();