setInterval()

in azure-pipelines-wrapper/env_init.js [22:89]
67 lines of code
9 McCabe index (conditional complexity)

    setInterval(async function() {
        const uuid = uuidv4();
        try {
            fs.mkdirSync('daemon_lock')
        } catch(e) {
            if(e.code == 'EEXIST') {
                let lock = fs.statSync('daemon_lock').ctimeMs
                let now = Date.now()
                if (now - lock > 25 * 60 * 1000){
                    app.log.info(`[ DAEMON ] [${uuid}] lock more than 30 minutes. release lock!`);
                    fs.rmdirSync("daemon_lock");
                    return
                } else {
                    app.log.info(`[ DAEMON ] [${uuid}] daemon process return!`);
                    return
                }
            } else {
                throw(e)
            }
        }
        const privateKey = await akv.getAppPrivateKey();
        const secret = await akv.getAppWebhookSecret();
        var ms_checker_flag = await akv.getSecretFromCache("mschecker")

        let appclinet = new App({
            appId: process.env.APP_ID,
            privateKey: privateKey,
            webhooks: {
                secret: secret,
            },
        })
        let data = await appclinet.octokit.request("/app");
        app.log.info(`[ DAEMON ] [${uuid}] START ${data.data.name}!`);
        let oct = await appclinet.getInstallationOctokit(26573885);
        execFile('bash', ['-c', `env_init_daemon.sh ${uuid} 2>&1 > env_init_daemon.stdout | while IFS= read -r line; do echo [$(date +%FT%TZ)] [${uuid}] $line >> env_init_daemon.stderr; done; cat env_init_daemon.stdout`], { uid: 0, encoding: 'utf-8' }, async (error, stdout, stderr)=>{
            for (const line of stdout.split(/\r?\n/)){
                if (line.includes("ms_checker.detail: ")){
                    let detail = line.split(' ').pop()
                    if (detail.split(',').length >= 5){
                        let result = detail.split(',')[0]
                        let commit = detail.split(',')[1]
                        let msprid = detail.split(',')[2]
                        let prid = detail.split(',')[3]
                        let msg = detail.split(',')[4]
                        app.log.info(`[ DAEMON ] [${uuid}] Result: ${PRPrefix}${msprid} ${prid} ${result} ${commit} ${ms_checker_flag}`);
                        if (result != "in_progress"){
                            param={
                                owner: 'sonic-net',
                                repo: 'sonic-buildimage',
                                head_sha: commit,
                                name: MsChecker,
                                status: COMPLETED,
                                conclusion: 'success', // TODO
                                output: {
                                    title: "MS PR validation",
                                    summary: `Please check result in ${PRPrefix}${msprid}<br>${msg}`,
                                },
                            }
                            app.log.info(`[ DAEMON ] [${uuid}] check_create ${PRPrefix}${msprid} ${prid} ${result}`)
                            let re = await oct.request("POST /repos/sonic-net/sonic-buildimage/check-runs", param);
                            app.log.info(`[ DAEMON ] [${uuid}] check_create ${JSON.stringify(re.data)}`)
                        }
                    }
                }
            }
            app.log.info(`[ DAEMON ] [${uuid}] END!`);
        })
    }, 30 * 60 * 1000);