logger.debug('delaying captured \''+filtered.type+'\' event for \''+filtered.key+'\' from watcher \''+this.device+'\'');
return;
}
logger.info('executing command \''+filtered.command+'\' (args: \''+filtered.args+'\') registered for captured \''+filtered.type+'\' event for \''+filtered.key+'\' from watcher \''+this.device+'\'');
cli.execute(filtered.command,filtered.args)
.then(logger.info)
.catch(logger.error);
});
}
addStdErrListener(){
if(this.process==undefined){
return;
}
logger.debug('adding stderr listener to watcher \''+this.device+'\'...');
this.process.stderr.on('data',(data)=>{
logger.error(data);
});
}
addCloseListener(){
if(this.process==undefined){
return;
}
logger.debug('adding close listener to watcher \''+this.device+'\'...');
this.process.on('close',(code)=>{
logger.info('watcher \''+this.device+'\' finished with exit code '+code);
if(this.callback!=undefined){
this.callback(null,this.device,code);
}
});
}
addErrorListener(){
if(this.process==undefined){
return;
}
logger.debug('adding error listener to \''+this.device+'\'...');