EventHandler.js

const Promise = require('bluebird');
const BuildProcessor = require('./BuildProcessor');
const BuildMonitor = require('./BuildMonitor');
const { TestResultsDB, BuildListDB, AuditLogsDB } = require('./Database');
const { logger } = require('./Utils');

const elapsed = [2 * 60, 5 * 60, 10 * 60];
/*
 * EventHandler processes builds that have status != Done
 * Once all builds are in status Done, it delays the process based on the time in elapsed array
 */
class EventHandler {
    async processBuild() {
        let count = 0;
        // break if all builds are done for consecutively 5 queries
        while (true) {
            try {
                const testResults = new TestResultsDB();
                let tasks = await testResults
                    .getData({ status: { $ne: 'Done' } })
                    .toArray();

                if (!tasks || tasks.length === 0) {
                    count++;
                } else {
                    count = 0;
                }

                for (let task of tasks) {
                    try {
                        const buildProcessor = new BuildProcessor();
                        await buildProcessor.execute(task);
                    } catch (e) {
                        logger.error('Exception in BuildProcessor: ', e);
                        await new AuditLogsDB().insertAuditLogs({
                            action: '[exception] ' + e,
                            ...task,
                        });
                    }
                    logger.debug(
                        'EventHandler: processBuild() is waiting for 1 secs before processing the next build'
                    );
                    await Promise.delay(1 * 1000);
                }
            } catch (e) {
                logger.error('Exception in database query: ', e);
                await new AuditLogsDB().insertAuditLogs({
                    action: '[exception] ' + e,
                    ...task,
                });
            }
            const elapsedTime = elapsed[Math.min(count, elapsed.length - 1)];
            logger.verbose(
                `EventHandler: processBuild() is waiting for ${elapsedTime} secs before checking DB for builds != Done`
            );
            await Promise.delay(elapsedTime * 1000);
        }
    }

    //this function monitors build in Jenkins
    async monitorBuild() {
        while (true) {
            try {
                const testResults = new BuildListDB();
                let tasks = await testResults.getData().toArray();
                tasks = tasks.filter((task) => task.monitoring === 'Yes');
                if (tasks && tasks.length > 0) {
                    for (let task of tasks) {
                        try {
                            const buildMonitor = new BuildMonitor();
                            await buildMonitor.deleteOldBuilds(task);
                            await buildMonitor.deleteOldAuditLogs();
                            await buildMonitor.execute(task);
                        } catch (e) {
                            logger.error('Exception in BuildMonitor: ', e);
                            await new AuditLogsDB().insertAuditLogs({
                                action: '[exception] ' + e,
                                ...task,
                            });
                        }
                    }
                }
            } catch (e) {
                logger.error('Exception in database query: ', e);
                await new AuditLogsDB().insertAuditLogs({
                    action: '[exception] ' + e,
                    ...task,
                });
            }
            const elapsedTime = 1 * 60;
            logger.verbose(
                `EventHandler: monitorBuild() is waiting for ${elapsedTime} secs`
            );
            await Promise.delay(elapsedTime * 1000);
        }
    }
}
module.exports = EventHandler;