Built motion from commit de2cb856.|2.0.30

[motion2.git] / server / services / routing / server / applications / queue.js

diff --git a/server/services/routing/server/applications/queue.js b/server/services/routing/server/applications/queue.js
index e87a03c..373cecc 100644 (file)
--- a/server/services/routing/server/applications/queue.js
+++ b/server/services/routing/server/applications/queue.js
@@ -1 +1 @@
-var _0x3884=["\x75\x73\x65\x20\x73\x74\x72\x69\x63\x74","\x76\x61\x6C\x69\x64\x61\x74\x65","\x6C\x6F\x64\x61\x73\x68","\x75\x74\x69\x6C","\x73\x65\x71\x2D\x71\x75\x65\x75\x65","\x72\x6F\x75\x74\x69\x6E\x67","\x2E\x2E\x2F\x2E\x2E\x2F\x2E\x2E\x2F\x2E\x2E\x2F\x63\x6F\x6E\x66\x69\x67\x2F\x6C\x6F\x67\x67\x65\x72","\x2E\x2F\x73\x74\x72\x61\x74\x65\x67\x79","\x73\x74\x72\x69\x6E\x67","\x6E\x61\x6D\x65\x20\x69\x73\x20\x61\x20\x73\x74\x72\x69\x6E\x67\x20\x61\x6E\x64\x20\x69\x74\x20\x69\x73\x20\x72\x65\x71\x75\x69\x72\x65\x64","\x6E\x75\x6D\x62\x65\x72","\x74\x69\x6D\x65\x6F\x75\x74\x20\x69\x73\x20\x61\x20\x6E\x75\x6D\x62\x65\x72","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x5B\x4E\x41\x4D\x45\x3A\x25\x73\x5D\x5B\x53\x54\x41\x54\x55\x53\x3A\x25\x73\x5D","\x6E\x61\x6D\x65","\x66\x6F\x72\x6D\x61\x74","\x69\x6E\x66\x6F","\x74\x6F\x4C\x6F\x77\x65\x72\x43\x61\x73\x65","\x63\x6F\x6E\x73\x65\x71\x75\x65\x6E\x63\x65","\x6C\x65\x6E\x67\x74\x68","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x25\x73","\x2C\x20","\x6A\x6F\x69\x6E","\x6D\x65\x73\x73\x61\x67\x65","\x6D\x61\x70","\x65\x72\x72\x6F\x72","\x73\x74\x6F\x70","\x63\x68\x61\x6E\x6E\x65\x6C","\x51\x75\x65\x75\x65\x73","\x66\x69\x6E\x64","\x74\x69\x6D\x65\x6F\x75\x74","\x53\x54\x41\x52\x54\x3A\x25\x73\x3A\x25\x73\x3A\x25\x73","\x73\x74\x72\x61\x74\x65\x67\x79","\x63\x72\x65\x61\x74\x65\x51\x75\x65\x75\x65","\x69\x64","\x61\x74\x69\x6D\x65\x6F\x75\x74","\x71\x74\x69\x6D\x65\x6F\x75\x74","\x72\x75\x6C\x65\x73","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x52\x4F\x55\x54\x49\x4E\x47\x20\x53\x54\x4F\x50\x50\x45\x44","\x63\x6C\x6F\x73\x65","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x52\x4F\x55\x54\x49\x4E\x47\x20\x45\x4E\x44","\x6E\x65\x78\x74","\x72\x72\x6D\x65\x6D\x6F\x72\x79","\x62\x65\x65\x70\x61\x6C\x6C","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x71\x75\x65\x75\x65\x20\x6E\x6F\x74\x20\x66\x6F\x75\x6E\x64\x20\x25\x73","\x6C\x6F\x67","\x73\x74\x72\x69\x6E\x67\x69\x66\x79"];_0x3884[0];var schema=require(_0x3884[1]);var _=require(_0x3884[2]);var util=require(_0x3884[3]);var seqqueue=require(_0x3884[4]);var logger=require(_0x3884[6])(_0x3884[5]);var strategy=require(_0x3884[7]);var queue=schema({name:{type:_0x3884[8],required:true,message:_0x3884[9]},timeout:{type:_0x3884[10],message:_0x3884[11]}});function writeLog(_0xc6b3x9,_0xc6b3xa,_0xc6b3xb){return logger[_0x3884[15]](util[_0x3884[14]](_0x3884[12],_0xc6b3x9,_0xc6b3xa[_0x3884[13]],_0xc6b3xb))}function handleFindQueue(_0xc6b3xd){return function(_0xc6b3xe){return _0xc6b3xe[_0x3884[13]][_0x3884[16]]()=== _0xc6b3xd[_0x3884[16]]()}}exports[_0x3884[17]]= function(_0xc6b3xf,_0xc6b3x10,_0xc6b3x11,_0xc6b3x12){return function(_0xc6b3x13){try{var _0xc6b3xa={name:_0xc6b3x10[0],timeout:_0xc6b3x10[1]};var _0xc6b3x14=queue[_0x3884[1]](_0xc6b3xa,{typecast:true});if(_0xc6b3x14[_0x3884[18]]){logger[_0x3884[24]](_0x3884[19],_0xc6b3xf,_[_0x3884[23]](_0xc6b3x14,_0x3884[22])[_0x3884[21]](_0x3884[20]));_0xc6b3x13[_0x3884[25]]()}else {var _0xc6b3x15=_[_0x3884[28]](_0xc6b3x11[_0xc6b3x12[_0x3884[26]]+ _0x3884[27]],handleFindQueue(_0xc6b3xa[_0x3884[13]]));if(_0xc6b3x15){var _0xc6b3x16=(_0xc6b3x15[_0x3884[29]]|| 10)* 1000;var _0xc6b3x17=(_0xc6b3xa[_0x3884[29]]|| 20)* 1000;var _0xc6b3x18,_0xc6b3x19;if(_0xc6b3x16> _0xc6b3x17){_0xc6b3x17= _0xc6b3x16};writeLog(_0xc6b3xf,_0xc6b3x15,util[_0x3884[14]](_0x3884[30],_0xc6b3x17,_0xc6b3x16,_0xc6b3x15[_0x3884[31]]));var _0xc6b3x1a=seqqueue[_0x3884[32]](_0xc6b3x16);_0xc6b3x1a[_0x3884[33]]= _0xc6b3xf;_0xc6b3x1a[_0x3884[34]]= _0xc6b3x16;_0xc6b3x1a[_0x3884[35]]= _0xc6b3x17;_0xc6b3x1a[_0x3884[26]]= _0xc6b3x12[_0x3884[26]];_0xc6b3x19= setInterval(function(){if(_0xc6b3x11[_0x3884[36]]&&  !_0xc6b3x11[_0x3884[36]][_0xc6b3xf]){logger[_0x3884[15]](_0x3884[37],_0xc6b3xf);clearTimeout(_0xc6b3x18);clearInterval(_0xc6b3x19);_0xc6b3x18= undefined;_0xc6b3x1a[_0x3884[38]](true);_0xc6b3x13[_0x3884[25]]()}},1000);_0xc6b3x18= setTimeout(function(){logger[_0x3884[15]](_0x3884[39],_0xc6b3xf);clearInterval(_0xc6b3x19);_0xc6b3x19= undefined;_0xc6b3x1a[_0x3884[38]](true);_0xc6b3x13[_0x3884[40]]()},_0xc6b3x17);switch(_0xc6b3x15[_0x3884[31]]){case _0x3884[41]:strategy[_0x3884[41]](_0xc6b3x1a,_0xc6b3x15,_0xc6b3x11);break;default:strategy[_0x3884[42]](_0xc6b3x1a,_0xc6b3x15,_0xc6b3x11)}}else {logger[_0x3884[24]](_0x3884[43],_0xc6b3xf,_0xc6b3xa[_0x3884[13]]);_0xc6b3x13[_0x3884[25]]()}}}catch(e){console[_0x3884[44]](e);logger[_0x3884[24]](_0x3884[19],_0xc6b3xf,JSON[_0x3884[45]](e));_0xc6b3x13[_0x3884[25]]()}}}
\ No newline at end of file
+var _0x100f=["\x75\x73\x65\x20\x73\x74\x72\x69\x63\x74","\x76\x61\x6C\x69\x64\x61\x74\x65","\x6C\x6F\x64\x61\x73\x68","\x75\x74\x69\x6C","\x73\x65\x71\x2D\x71\x75\x65\x75\x65","\x72\x6F\x75\x74\x69\x6E\x67","\x2E\x2E\x2F\x2E\x2E\x2F\x2E\x2E\x2F\x2E\x2E\x2F\x63\x6F\x6E\x66\x69\x67\x2F\x6C\x6F\x67\x67\x65\x72","\x2E\x2F\x73\x74\x72\x61\x74\x65\x67\x79","\x73\x74\x72\x69\x6E\x67","\x6E\x61\x6D\x65\x20\x69\x73\x20\x61\x20\x73\x74\x72\x69\x6E\x67\x20\x61\x6E\x64\x20\x69\x74\x20\x69\x73\x20\x72\x65\x71\x75\x69\x72\x65\x64","\x6E\x75\x6D\x62\x65\x72","\x74\x69\x6D\x65\x6F\x75\x74\x20\x69\x73\x20\x61\x20\x6E\x75\x6D\x62\x65\x72","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x5B\x4E\x41\x4D\x45\x3A\x25\x73\x5D\x5B\x53\x54\x41\x54\x55\x53\x3A\x25\x73\x5D","\x6E\x61\x6D\x65","\x66\x6F\x72\x6D\x61\x74","\x69\x6E\x66\x6F","\x74\x6F\x4C\x6F\x77\x65\x72\x43\x61\x73\x65","\x63\x6F\x6E\x73\x65\x71\x75\x65\x6E\x63\x65","\x6C\x65\x6E\x67\x74\x68","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x25\x73","\x2C\x20","\x6A\x6F\x69\x6E","\x6D\x65\x73\x73\x61\x67\x65","\x6D\x61\x70","\x65\x72\x72\x6F\x72","\x73\x74\x6F\x70","\x63\x68\x61\x6E\x6E\x65\x6C","\x51\x75\x65\x75\x65\x73","\x66\x69\x6E\x64","\x74\x69\x6D\x65\x6F\x75\x74","\x53\x54\x41\x52\x54\x3A\x25\x73\x3A\x25\x73\x3A\x25\x73","\x73\x74\x72\x61\x74\x65\x67\x79","\x63\x72\x65\x61\x74\x65\x51\x75\x65\x75\x65","\x69\x64","\x61\x74\x69\x6D\x65\x6F\x75\x74","\x71\x74\x69\x6D\x65\x6F\x75\x74","\x72\x75\x6C\x65\x73","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x52\x4F\x55\x54\x49\x4E\x47\x20\x53\x54\x4F\x50\x50\x45\x44","\x63\x6C\x6F\x73\x65","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x52\x4F\x55\x54\x49\x4E\x47\x20\x45\x4E\x44","\x6E\x65\x78\x74","\x72\x72\x6D\x65\x6D\x6F\x72\x79","\x62\x65\x65\x70\x61\x6C\x6C","\x5B\x25\x73\x5D\x5B\x51\x55\x45\x55\x45\x5D\x20\x71\x75\x65\x75\x65\x20\x6E\x6F\x74\x20\x66\x6F\x75\x6E\x64\x20\x25\x73","\x6C\x6F\x67","\x73\x74\x72\x69\x6E\x67\x69\x66\x79"];_0x100f[0];var schema=require(_0x100f[1]);var _=require(_0x100f[2]);var util=require(_0x100f[3]);var seqqueue=require(_0x100f[4]);var logger=require(_0x100f[6])(_0x100f[5]);var strategy=require(_0x100f[7]);var queue=schema({name:{type:_0x100f[8],required:true,message:_0x100f[9]},timeout:{type:_0x100f[10],message:_0x100f[11]}});function writeLog(_0x6d6fx9,_0x6d6fxa,_0x6d6fxb){return logger[_0x100f[15]](util[_0x100f[14]](_0x100f[12],_0x6d6fx9,_0x6d6fxa[_0x100f[13]],_0x6d6fxb))}function handleFindQueue(_0x6d6fxd){return function(_0x6d6fxe){return _0x6d6fxe[_0x100f[13]][_0x100f[16]]()=== _0x6d6fxd[_0x100f[16]]()}}exports[_0x100f[17]]= function(_0x6d6fxf,_0x6d6fx10,_0x6d6fx11,_0x6d6fx12){return function(_0x6d6fx13){try{var _0x6d6fxa={name:_0x6d6fx10[0],timeout:_0x6d6fx10[1]};var _0x6d6fx14=queue[_0x100f[1]](_0x6d6fxa,{typecast:true});if(_0x6d6fx14[_0x100f[18]]){logger[_0x100f[24]](_0x100f[19],_0x6d6fxf,_[_0x100f[23]](_0x6d6fx14,_0x100f[22])[_0x100f[21]](_0x100f[20]));_0x6d6fx13[_0x100f[25]]()}else {var _0x6d6fx15=_[_0x100f[28]](_0x6d6fx11[_0x6d6fx12[_0x100f[26]]+ _0x100f[27]],handleFindQueue(_0x6d6fxa[_0x100f[13]]));if(_0x6d6fx15){var _0x6d6fx16=(_0x6d6fx15[_0x100f[29]]|| 10)* 1000;var _0x6d6fx17=(_0x6d6fxa[_0x100f[29]]|| 20)* 1000;var _0x6d6fx18,_0x6d6fx19;if(_0x6d6fx16> _0x6d6fx17){_0x6d6fx17= _0x6d6fx16};writeLog(_0x6d6fxf,_0x6d6fx15,util[_0x100f[14]](_0x100f[30],_0x6d6fx17,_0x6d6fx16,_0x6d6fx15[_0x100f[31]]));var _0x6d6fx1a=seqqueue[_0x100f[32]](_0x6d6fx16);_0x6d6fx1a[_0x100f[33]]= _0x6d6fxf;_0x6d6fx1a[_0x100f[34]]= _0x6d6fx16;_0x6d6fx1a[_0x100f[35]]= _0x6d6fx17;_0x6d6fx1a[_0x100f[26]]= _0x6d6fx12[_0x100f[26]];_0x6d6fx19= setInterval(function(){if(_0x6d6fx11[_0x100f[36]]&&  !_0x6d6fx11[_0x100f[36]][_0x6d6fxf]){logger[_0x100f[15]](_0x100f[37],_0x6d6fxf);clearTimeout(_0x6d6fx18);clearInterval(_0x6d6fx19);_0x6d6fx18= undefined;_0x6d6fx1a[_0x100f[38]](true);_0x6d6fx13[_0x100f[25]]()}},1000);_0x6d6fx18= setTimeout(function(){logger[_0x100f[15]](_0x100f[39],_0x6d6fxf);clearInterval(_0x6d6fx19);_0x6d6fx19= undefined;_0x6d6fx1a[_0x100f[38]](true);_0x6d6fx13[_0x100f[40]]()},_0x6d6fx17);switch(_0x6d6fx15[_0x100f[31]]){case _0x100f[41]:strategy[_0x100f[41]](_0x6d6fx1a,_0x6d6fx15,_0x6d6fx11);break;default:strategy[_0x100f[42]](_0x6d6fx1a,_0x6d6fx15,_0x6d6fx11)}}else {logger[_0x100f[24]](_0x100f[43],_0x6d6fxf,_0x6d6fxa[_0x100f[13]]);_0x6d6fx13[_0x100f[25]]()}}}catch(e){console[_0x100f[44]](e);logger[_0x100f[24]](_0x100f[19],_0x6d6fxf,JSON[_0x100f[45]](e));_0x6d6fx13[_0x100f[25]]()}}}
\ No newline at end of file