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';
import { ClickhouseAppInstance } from 'CommonServer/Infrastructure/ClickhouseDatabase';

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']
        );
    }
);

const init: () => Promise<void> = 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();

        await ClickhouseAppInstance.connect(
            ClickhouseAppInstance.getDatasourceOptions()
        );

        // Job process.
        QueueWorker.getWorker(
            QueueName.Workflow,
            async (job: QueueJob) => {
                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 }
        );
    } catch (err) {
        logger.error('App Init Failed:');
        logger.error(err);
        throw err;
    }
};

init().catch((err: Error) => {
    logger.error(err);
    logger.info('Exiting node process');
    process.exit(1);
});

export default app;