Вопросы по написанию скриптов

instalator

Хочу заставить бота слать информацию об обновлении, подписываюсь на драйвер, а он либо undefined присылает, либо вообще молчит.
on({id: 'admin.0.info.updatesList', change: 'any'}, function (obj) {
    if (getState('admin.0.info.updatesNumber').val > 0){
        sendTo('telegram', obj.val);
        log(obj.val);
    }
});

```` `  

on({id: 'admin.0.info.updatesNumber', change: 'any'}, function (obj) {
    if (obj.newState.val > 0){
        sendTo('telegram', (obj.newState.val).toString());
        log(obj.newState.val);
    }
});

А если так?

spectrekr

Сейчас поставил по-первому способу, если не пойдет, буду пробовать вторым способом. Осталось дождаться какого нибудь обновления :-)

Bluefox

~~@spectrekr:~~

Сейчас поставил по-первому способу, если не пойдет, буду пробовать вторым способом. Осталось дождаться какого нибудь обновления :-) `
Как instalator написал: obj.newState.val правильно

Также работает obj.state.val

spectrekr

Блин, уже мозг взрывается. Пытаюсь выполнить команду через exec

var cmd = "'/usr/src/git/git_upd.sh "+ obn + ' ' + date_obn + "'";
        log(cmd);
        child = exec (cmd,
            function (error, stdout, stderr){
                if (error !== null) {
                    log(error);
                }

В логе получаю

! 11:14:16.421 [info] javascript.0 script.js.Скрипт1: '/usr/src/git/git_upd.sh sayit 2016.5.16'
! 11:14:16.422 [info] javascript.0 script.js.Скрипт1: Error: Command failed: /bin/sh -c '/usr/src/git/git_upd.sh sayit 2016.5.16' /bin/sh: 1: /usr/src/git/git_upd.sh sayit 2016.5.16: not found
В консоле от этого же юзера, под которым работает сервер, эта команда без проблем выполняется.

! cubie@Cubian:/usr/src/git$ /bin/sh -c '/usr/src/git/git_upd.sh sayit 2016.5.12'
! GermanBluefox, Sat May 14 15:39:12 2016 +0200 : ### 1.0.0 (2016-05-14) * (bluefox) Make the type of mp3 as file

upd: Разобрался, сделал обходным путем.

spectrekr

делаю функцию.

! ````
var get_ver_upd = function (drv){
var path_upd = 'iobroker\node_modules\iobroker.js-controller\conf\sources-dist.json';
if (fs.existsSync(path_upd)) {
fs.readFile(path_upd, function (error, data) {
if (!error) {
var result;
try {
result = JSON.parse(data);
} catch (err) {
log("Не парсится!");
result = null;
}
// log(result[drv].meta);
request(result[drv].meta, function (error, response, body) {
if (!error && response.statusCode == 200) {
var result_ver;
try {
result_ver = JSON.parse(body)
} catch (err) {
log("Не парсится!");
result_ver = null;
}
// log(result_ver.common.version);
return result_ver.common.version;
}
});
}
});
}
}

и пытаюсь вернуть в основную программу

ver_n = get_ver_upd(obn);
log(ver_n);

ver_n объявлена глобально.

instalator

~~@spectrekr:~~

делаю функцию.

! ````
var get_ver_upd = function (drv){
var path_upd = 'iobroker\node_modules\iobroker.js-controller\conf\sources-dist.json';
if (fs.existsSync(path_upd)) {
fs.readFile(path_upd, function (error, data) {
if (!error) {
var result;
try {
result = JSON.parse(data);
} catch (err) {
log("Не парсится!");
result = null;
}
// log(result[drv].meta);
request(result[drv].meta, function (error, response, body) {
if (!error && response.statusCode == 200) {
var result_ver;
try {
result_ver = JSON.parse(body)
} catch (err) {
log("Не парсится!");
result_ver = null;
}
// log(result_ver.common.version);
return result_ver.common.version;
}
});
}
});
}
}
и пытаюсь вернуть в основную программу
ver_n = get_ver_upd(obn);
log(ver_n);
ver_n объявлена глобально. `  

! ````
function get_ver_upd (drv){
var path_upd = 'iobroker\node_modules\iobroker.js-controller\conf\sources-dist.json';
if (fs.existsSync(path_upd)) {
fs.readFile(path_upd, function (error, data) {
if (!error) {
var result;
try {
result = JSON.parse(data);
} catch (err) {
log("Не парсится!");
result = null;
}
// log(result[drv].meta);
request(result[drv].meta, function (error, response, body) {
if (!error && response.statusCode == 200) {
var result_ver;
try {
result_ver = JSON.parse(body)
} catch (err) {
log("Не парсится!");
result_ver = null;
}
// log(result_ver.common.version);
return result_ver.common.version;
}
});
}
});
}
}

instalator

! function get_ver_upd (drv, callback){ var path_upd = 'iobroker\\node_modules\\iobroker.js-controller\\conf\\sources-dist.json'; if (fs.existsSync(path_upd)) { fs.readFile(path_upd, function (error, data) { if (!error) { var result; try { result = JSON.parse(data); } catch (err) { log("Не парсится!"); result = null; } // log(result[drv].meta); request(result[drv].meta, function (error, response, body) { if (!error && response.statusCode == 200) { var result_ver; try { result_ver = JSON.parse(body) } catch (err) { log("Не парсится!"); result_ver = null; } // log(result_ver.common.version); callback (result_ver.common.version); } }); } }); } } ! get_ver_upd(obn, function(n){ log(n); }); !

spectrekr

Возник другой вопрос, а как заставить цикл ждать отработки всех функций внутри цикла?

! ```
for (var i = 0; i < obn.length; i++) { get_info(obn[i], function(readme, ver_c){ log(readme); log(ver_c); }); get_ver_upd(obn[i], function(ver_n){ log(ver_n); });
а выводит как попало
! >! ~~[spoiler]~~16:35:56.441 [info] javascript.0 script.js.update: https://github.com/ioBroker/ioBroker.mq ... /README.md
! 16:35:56.442 [info] javascript.0 script.js.update: 1.0.3
! 16:35:56.442 [info] javascript.0 script.js.update: https://github.com/iobroker/ioBroker.ja ... /README.md
! 16:35:56.442 [info] javascript.0 script.js.update: 2.0.6
! 16:35:56.705 [info] javascript.0 script.js.update: 2.1.0
! 16:35:56.713 [info] javascript.0 script.js.update: 1.0.3[/spoiler]
И еще попутно, почему не присваивает значение?
~~[code]~~get_ver_upd(obn, function(n){ ver_n = n; }); [/code][/i][/i]

Bluefox

`var ready = 0;
for (var i = 0; i < obn.length; i++) {
            ready++;
            get_info(obn[i], function(readme, ver_c){
                log(readme);
                log(ver_c);
                if (!--ready) {
                     log('finished');
                }
            });
            ready++;
            get_ver_upd(obn[i], function(ver_n){
                log(ver_n);
                if (!--ready) {
                     log('finished');
                }
            });
}`[/i][/i]

spectrekr

Странно отрабатывает, да еще и 1 раз только finished пишет.

! 17:35:17.349 [info] javascript.0 script.js.update: https://github.com/ioBroker/ioBroker.mq … /README.md
! 17:35:17.349 [info] javascript.0 script.js.update: 1.0.3
! 17:35:17.349 [info] javascript.0 script.js.update: https://github.com/iobroker/ioBroker.ja … /README.md
! 17:35:17.349 [info] javascript.0 script.js.update: 2.0.6
! 17:35:17.612 [info] javascript.0 script.js.update: 2.1.0
! 17:35:17.613 [info] javascript.0 script.js.update: 1.0.3
! 17:35:17.613 [info] javascript.0 script.js.update: finished
А по поводу передать значение не подскажешь?

Bluefox

Давай весь скрипт. Хватит кусками выдавать. :)

Там функции get_ver_upd и get_info надо менять

spectrekr

~~@Bluefox:~~

Давай весь скрипт. Хватит кусками выдавать. :)

Там функции get_ver_upd и get_info надо менять `

! ```
`var request = require('request');
var fs = require('fs');
var path, obn, readme, ver_c, ver_n;
! function get_info(obn){
path = 'iobroker\node_modules\iobroker.' + obn;
if (fs.existsSync(path)) {
fs.readFile(path + "\io-package.json", function (error, data) {
if (!error) {
var result;
try {
result = JSON.parse(data);
} catch (err) {
log("Не парсится!");
result = null;
}
return result.common.readme, result.common.version;
}
});
}
}
! function get_ver_upd (drv){
var path_upd = 'iobroker\node_modules\iobroker.js-controller\conf\sources-dist.json';
if (fs.existsSync(path_upd)) {
fs.readFile(path_upd, function (error, data) {
if (!error) {
var result;
try {
result = JSON.parse(data);
} catch (err) {
log("Не парсится!");
result = null;
}
request(result[drv].meta, function (error, response, body) {
if (!error && response.statusCode == 200) {
var result_ver;
try {
result_ver = JSON.parse(body);
} catch (err) {
log("Не парсится!");
result_ver = null;
}
return result_ver.common.version;
}
});
}
});
}
}
! function get_chang(readme, ver_c, ver_n, callback){
log(readme);
log(ver_c);
log(ver_n);

}

! on({id: 'admin.0.info.updatesList', change: 'any'}, function (obj) {
var str = 'Доступно обновления для:\n';
if (getState('admin.0.info.updatesNumber').val > 1){
obn = obj.state.val.split(',');
/* for (var i = 0; i < obn.length; i++) {
get_info(obn[i], function(readme, ver_c){
log(readme);
log(ver_c);
});
get_ver_upd(obn[i], function(ver_n){
log(ver_n);
});
*/
var ready = 0;
for (var i = 0; i < obn.length; i++) {
ready++;
get_info(obn[i], function(r, v){
// log(r);
readme = r;
// log(v);
ver_c = v;
if (!--ready) {
log('finished');
}
});
ready++;
get_ver_upd(obn[i], function(v){
log(ver_n);
ver_n = v;
if (!--ready) {
log('finished');
}
});
}
}
if (getState('admin.0.info.updatesNumber').val == 1){
obn = obj.state.val;
get_info(obn, function(r, v){
// log(r);
readme = r;
// log(v);
ver_c = v;
});
get_ver_upd(obn, function(v){
// log(v);
ver_n = v;
});
get_chang(readme, ver_c, ver_n);
}
});`
Это то что на данный момент. Соответственно в function get_chang будет дальнейшая обработка.[/i][/i][/i][/i]

Bluefox

Не жалей букв на названия ;)

! ```
`var request = require('request');
var fs = require('fs');
var path, obn, readme, ver_c, ver_n;
! function get_info(obn, cb){
path = 'iobroker/node_modules/iobroker.' + obn;

if (fs.existsSync(path)) {
	fs.readFile(path + "/io-package.json", function (error, data) {
		if (!error) {
			var result;
			try {
				result = JSON.parse(data);
			} catch (err) {
				console.error("Не парсится!");
				return cb(obn);
			}
			cb(obn, result.common.readme, result.common.version);
		} else {
			console.error(error);
			cb(obn);
		}
	});
} else {
	cb(obn);
}

}

! function get_ver_upd (drv, cb) {
var path_upd = 'iobroker/node_modules/iobroker.js-controller/conf/sources-dist.json';
if (fs.existsSync(path_upd)) {
fs.readFile(path_upd, function (error, data) {
if (!error) {
var result;
try {
result = JSON.parse(data);
} catch (err) {
log("Не парсится!");
return cb(drv);
}
request(result[drv].meta, function (error, response, body) {
if (!error && response.statusCode == 200) {
var result_ver;
try {
result_ver = JSON.parse(body);
} catch (err) {
console.error("Не парсится!");
return cb(drv);
}
cb(drv, result_ver.common.version);
} else {
console.error(error);
cb(drv);
}
});
} else {
console.error(error);
cb(drv);
}
});
} else {
cb(drv);
}
}
! function get_chang(readme, ver_c, ver_n, callback){
log(readme);
log(ver_c);
log(ver_n);
callback && callback();
}
! function processData(data, callback) {
if (data && !data instanceof Array) {
// convert data
var arr = [];
for (var a in data) {
data[a].name = a;
arr.push(data[a]);
}
data = arr;
}

if (!data || !data.length) {
	callback && callback();
	return;
}

var task = data.pop();

get_chang(task.readme, task.version, task.versionUpdate, function () {
	setTimeout(function () {
		processData(data, callback);
	}, 0);
});

}

! on({id: 'admin.0.info.updatesList', change: 'any'}, function (obj) {
var str = 'Доступно обновления для:\n';
if (getState('admin.0.info.updatesNumber').val) {
obn = obj.state.val.split(',');
var ready = 0;
var data = {};
for (var i = 0; i < obn.length; i++) {
ready++;
get_info(obn[i], function(adapter, r, v){
if (r) {
data[adapter] = data[adapter] || {};
data[adapter].readme = r;
data[adapter].version = v;
}
! if (!--ready) {
processData(arr);
}
});
ready++;
get_ver_upd(obn[i], function(adapter, v){
if (v) {
data[adapter] = data[adapter] || {};
data[adapter].versionUpdate = v;
}
if (!--ready) {
processData(data);
}
});
}
}
! });`[/i][/i]

electric

Ребят, такой вопрос.

В скрипте создаю переменную и ниже по тексту на нее же подписываюсь.

Первый раз скрипт не запускается, вываливается с ошибками типа таких:

! ReferenceError: 05 18:56:57.056 error at Socket.onpacket (/opt/iobroker/node_modules/iobroker.js-controller/node_modules/socket.io-client/lib/socket.js:221:12) ReferenceError: 05 18:56:57.056 error at Socket.onevent (/opt/iobroker/node_modules/iobroker.js-controller/node_modules/socket.io-client/lib/socket.js:263:10) ReferenceError: 05 18:56:57.056 error at Socket.Emitter.emit (/opt/iobroker/node_modules/iobroker.js-controller/node_modules/socket.io-client/node_modules/component-emitter/index.js:131:20) ReferenceError: 05 18:56:57.056 error at Socket. (/opt/iobroker/node_modules/iobroker.js-controller/lib/states/statesInMemClient.js:45:30) ReferenceError: 05 18:56:57.056 error at Object.that.states.States.change (/opt/iobroker/node_modules/iobroker.js-controller/lib/adapter.js:2036:80) ReferenceError: 05 18:56:57.056 error at Object.utils.adapter.stateChange (/opt/iobroker/node_modules/iobroker.javascript/javascript.js:215:17) ReferenceError: 05 18:56:57.056 error at checkPatterns (/opt/iobroker/node_modules/iobroker.javascript/javascript.js:537:17) ReferenceError: 05 18:56:57.056 error at getObjectEnums (/opt/iobroker/node_modules/iobroker.javascript/javascript.js:2624:45) ReferenceError: 05 18:56:57.056 error at /opt/iobroker/node_modules/iobroker.javascript/javascript.js:541:48 ReferenceError: 05 18:56:57.056 error at Object.subs.callback (/opt/iobroker/node_modules/iobroker.javascript/javascript.js:1207:48) ReferenceError: 05 18:56:57.056 error at Object. (script.js.common.cubietruck:224:23) ReferenceError: 05 18:56:57.056 error poll_ac is not defined message 05 18:56:57.053 error javascript.0.cubietruck.ac.poolinterval [object Object] poll_ac is not defined javascript-0 05 18:56:56.885 error at script.js.common.cubietruck:248:82 javascript-0 05 18:56:56.885 error script.js.common.cubietruck: TypeError: Cannot read property 'val' of null javascript-0 05 18:56:56.874 warn State "javascript.0.cubietruck.ac.poolinterval" not found !
Второй раз запускаю, все ОК.

Как заставить сначала создавать, потом подписываться?

Или есть вариант, что я не правильно понял ошибку?

Скрипт примерно такой:

var pool_ac = null; //интервал опроса переменных AC
createState('cubietruck.ac.poolinterval',10000);
//Изменение интервала опроса
on({id: 'javascript.0.cubietruck.ac.poolinterval', change: 'any'}, function (obj) {
    if (obj.newState.val !== '' || typeof obj.newState.val !== "undefined" || parseInt(obj.newState.val) >= 1000){
        clearInterval(poll_ac);
        poll_ac = setInterval(poolAC, parseInt(obj.newState.val));
    } else {
        clearInterval(poll_ac);
    }
});
function poolAC () {
   log("test");
}
poll_ac = setInterval(poolAC, getState('javascript.0.cubietruck.ac.poolinterval').val);

Ошибка по идее на последнюю строчку, т.е. не может получить getState().val хотя в createState('cubietruck.ac.poolinterval',10000); значение по-умолчанию прописано.

Bluefox

var pool_ac = null; //интервал опроса переменных AC
createState('cubietruck.ac.poolinterval',10000, function () {
    poll_ac = setInterval(poolAC, getState('javascript.0.cubietruck.ac.poolinterval').val);
});

//Изменение интервала опроса
on({id: 'javascript.0.cubietruck.ac.poolinterval', change: 'any'}, function (obj) {
    clearInterval(poll_ac);
    if (parseInt(obj.newState.val || 0) >= 1000) {
        poll_ac = setInterval(poolAC, parseInt(obj.newState.val));
    }
});

function poolAC () {
   log("test");
}

createState - асинхронная функция.

Наверное надо что-то сделать будет. Ты не первый, кто напоролся на это . :?

electric

Возникла проблемка с запуском скриптов.

Есть такая библиотека, называется https://github.com/EnotionZ/GpiO.

Она позволяет "подписываться" на изменение порта gpio функцией типа:

// bind to the "change" event
gpio4.on("change", function(val) {
   // value will report either 1 or 0 (number) when the value changes
   console.log(val)
});

Однако, если перезапустить скрипт или остановить, а затем опять запустить, этот EventEmitter не останавливается, а запускается еще один экземпляр.

Есть функция, чтобы отписаться:

// unbind all callbacks from the "change" event
gpio4.removeAllListeners("change");

Но как её использовать? Может есть функция, которая запускается при остановке скрипта, типа "сборщика мусора"?

BlueFox, прошу помощи :oops:

electric

Спасибо BlueFox, теперь есть специальная функция https://github.com/ioBroker/ioBroker.javascript#onstop.

Все http://www.iobroker.net/?page_id=4268&lang=ru#__-_GPIO_ioBroker как часы теперь…

spectrekr

Делаю запрос через sql драйвер,

sendTo('sql.0', 'query','SELECT UDH, UpdatedInDB FROM smsd.inbox WHERE ID = '+ id, function(res) {};

Результат возвращается в JSON и в итоге UpdatedInDB содержит дату формата 2016-08-25T07:28:07.000Z, а должен быть 2016-08-25 10:28:07. Как получить нужный формат, а то данное значение необходимо для следующего запроса?

Bluefox

~~@spectrekr:~~

Делаю запрос через sql драйвер,

sendTo('sql.0', 'query','SELECT UDH, UpdatedInDB FROM smsd.inbox WHERE ID = '+ id, function(res) {};

Результат возвращается в JSON и в итоге UpdatedInDB содержит дату формата 2016-08-25T07:28:07.000Z, а должен быть 2016-08-25 10:28:07. Как получить нужный формат, а то данное значение необходимо для следующего запроса? `

new Date('2016-08-25T07:28:07.000Z').toLocaleString() => "25.08.2016, 9:28:07"

oder

formatDate(new Date('2016-08-25T07:28:07.000Z'), 'YYYY-MM-DD hh:mm:ss.sss') => "2016-08-25 09:28:07.000"

MSapogov

Простите за глупый вопрос.

Очень хочется получить значение из переменной - squeezebox.0.Children.currentTitle

и отправить его в mqtt.0.beeiot.Bee-RGB.lcd.line2

И значение из squeezebox.0.Children.volume отправить на mqtt.0.beeiot.Bee-RGB.lcd.line3 добавив слово "Громкость" значение "%".

А так -же при появлении события mqtt.0.beeiot.Bee-RGB.gpioint1 неважно какое, главное новое событие - изменить значение squeezebox.0.Children.volume на +1

Этакий ваносной пульт от squeezebox по MQTT.

Community Forum

NEWS

Вопросы по написанию скриптов

Support us

871

32.4k

81.5k

1.3m