oneuptime/Workflow/Index.ts

import Express, {
    ExpressApplication,
    ExpressRequest,
    ExpressResponse,
} from 'CommonServer/Utils/Express';
import App from 'CommonServer/Utils/StartServer';
import { PostgresAppInstance } from 'CommonServer/Infrastructure/PostgresDatabase';
import Redis from 'CommonServer/Infrastructure/Redis';
import logger from 'CommonServer/Utils/Logger';
import ManualAPI from './API/Manual';
import ComponentCode from './API/ComponentCode';
import { QueueJob, QueueName } from 'CommonServer/Infrastructure/Queue';
import QueueWorker from 'CommonServer/Infrastructure/QueueWorker';
import RunWorkflow from './Services/RunWorkflow';
import { JSONObject } from 'Common/Types/JSON';
import ObjectID from 'Common/Types/ObjectID';
import WorkflowAPI from './API/Workflow';

const APP_NAME: string = 'workflow';

const app: ExpressApplication = Express.getExpressApp();

app.use(`/${APP_NAME}/manual`, new ManualAPI().router);

app.use(`/${APP_NAME}`, new WorkflowAPI().router);

app.get(
    `/${APP_NAME}/docs/:componentName`,
    (req: ExpressRequest, res: ExpressResponse) => {
        res.sendFile(
            __dirname +
                '/Docs/ComponentDocumentation/' +
                req.params['componentName']
        );
    }
);

// Job process.
QueueWorker.getWorker(
    QueueName.Workflow,
    async (job: QueueJob) => {

        console.log("Job Pending: ");
        console.log(job.data);

        await new RunWorkflow().runWorkflow({
            workflowId: new ObjectID(job.data['workflowId'] as string),
            workflowLogId: job.data['workflowLogId'] ? new ObjectID(job.data['workflowLogId'] as string): null,
            arguments: job.data.data as JSONObject,
            timeout: 5000,
        });
    },
    { concurrency: 10 }
);

const init: Function = async (): Promise<void> => {
    try {
        // connect to the database.
        await PostgresAppInstance.connect(
            PostgresAppInstance.getDatasourceOptions()
        );

        app.use(`/${APP_NAME}`, new ComponentCode().router);

        // init the app
        await App(APP_NAME);

        // connect redis
        await Redis.connect();
    } catch (err) {
        logger.error('App Init Failed:');
        logger.error(err);
    }
};

init();

export default app;