64 lines
2.3 KiB
JavaScript
64 lines
2.3 KiB
JavaScript
const { Worker } = require('worker_threads');
|
|
const moment = require('moment');
|
|
module.exports = (s,config,lang) => {
|
|
const {
|
|
legacyFilterEvents
|
|
} = require('./events/utils.js')(s,config,lang)
|
|
if(config.doCronAsWorker===undefined)config.doCronAsWorker = true;
|
|
const startWorker = () => {
|
|
const pathToWorkerScript = __dirname + `/cron/worker.js`
|
|
const workerProcess = new Worker(pathToWorkerScript)
|
|
workerProcess.on('message',function(data){
|
|
if(data.time === 'moment()')data.time = moment();
|
|
switch(data.f){
|
|
case'debugLog':
|
|
s.debugLog(...data.data)
|
|
break;
|
|
case'systemLog':
|
|
s.systemLog(...data.data)
|
|
break;
|
|
case'filters':
|
|
legacyFilterEvents(data.ff,data)
|
|
break;
|
|
case's.tx':
|
|
s.tx(data.data,data.to)
|
|
break;
|
|
case's.deleteVideo':
|
|
s.deleteVideo(data.file)
|
|
break;
|
|
case's.deleteFileBinEntry':
|
|
s.deleteFileBinEntry(data.file)
|
|
break;
|
|
case's.setDiskUsedForGroup':
|
|
function doOnMain(){
|
|
s.setDiskUsedForGroup(data.ke,data.size,data.target || undefined)
|
|
}
|
|
if(data.videoRow){
|
|
let storageIndex = s.getVideoStorageIndex(data.videoRow);
|
|
if(storageIndex){
|
|
s.setDiskUsedForGroupAddStorage(data.ke,{
|
|
size: data.size,
|
|
storageIndex: storageIndex
|
|
})
|
|
}else{
|
|
doOnMain()
|
|
}
|
|
}else{
|
|
doOnMain()
|
|
}
|
|
break;
|
|
default:
|
|
s.systemLog('CRON.js MESSAGE : ',data)
|
|
break;
|
|
}
|
|
})
|
|
setTimeout(() => {
|
|
workerProcess.postMessage({
|
|
f: 'init',
|
|
})
|
|
},2000)
|
|
return workerProcess
|
|
}
|
|
if(config.doCronAsWorker === true)startWorker()
|
|
}
|