kisybi/server.js

const schedule = require('node-schedule');
const { spawn } = require('child_process');
const { ipc } = require('./config.server.js');
const path = require('node:path')

require('./thirdparty/naturalSort.js');
require('./src/settings.js');
require('./src/db.js');
require('./src/dao.js');
require('./src/crawler.js');

const app = require('./config.server.js').app
const ipb = require('./config.server.js').ipb

let crawlState = 'off';

let crawlFn = async () => {
    ipb('global:refresh')
}

ipc.on("global:refresh:done", () => {
    let getProcess = spawn("bash", ["get.sh"], {cwd: path.join(__dirname, 'tmp')})

    getProcess.stdout.pipe(process.stdout)
    getProcess.stderr.pipe(process.stderr)
    
    getProcess.on('close', (code) => {
        console.log(`child process exited with code ${code}`);
        if(code == 0){

        }
    });
    crawlState = 'off'
})

let crawlFnSafe = async () => {
    try {
        crawlState = 'on'
        await crawlFn()
    } catch (e) {
        console.error("error on job", e)
    }
}


schedule.scheduleJob('0 3 * * *', () => {
    if(crawlState === 'off'){
        return new Promise(async () => await crawlFnSafe())
    } else {
        console.log("job already running")
    }
});

schedule.scheduleJob('*/5 * * * *', () => {
    console.log("service is alive")
})