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

aurodionov

Хочу заставить бота слать информацию об обновлении, подписываюсь на драйвер, а он либо 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);
    }
});

```` `  

Вроде id: лишние

Пишу с пульта….

spectrekr

Так везде и всегда так подписываюсь на изменения, и в примерах так описано. Да и он отслеживает изменения и запускает на выполнение, только вот, насколько я понял, значение объекта в текст не может перевести.

instalator

~~@spectrekr:~~

Так везде и всегда так подписываюсь на изменения, и в примерах так описано. Да и он отслеживает изменения и запускает на выполнение, только вот, насколько я понял, значение объекта в текст не может перевести. `
Obj.val.toString()

instalator

~~@spectrekr:~~

Хочу заставить бота слать информацию об обновлении, подписываюсь на драйвер, а он либо 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 как часы теперь…

NEWS

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

Support us

1.1k
Online

31.7k
Users

79.7k
Topics

1.3m
Posts

NEWS

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

Support us

1.1kOnline

31.7kUsers

79.7kTopics

1.3mPosts

1.1k
Online

31.7k
Users

79.7k
Topics

1.3m
Posts