mirrors/oneuptime
1
0
Fork 0
mirror of https://github.com/OneUptime/oneuptime synced 2024-11-21 22:59:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename WorkerRoutes to WorkflowRoutes and establish connections to Postgres, Redis, and Clickhouse; initialize real-time functionalities

Browse Source
This commit is contained in:
Simon Larsen 2024-09-16 15:29:15 -07:00
parent a35d26bc6a
commit ae996dbe07
No known key found for this signature in database
GPG Key ID: 96C5DCA24769DBCA
1 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
Workflow/Index.ts
View File

@ -1,9 +1,14 @@
import WorkerRoutes from "./Routes";
import WorkflowRoutes from "./Routes";
import { PromiseVoidFunction } from "Common/Types/FunctionTypes";
import InfrastructureStatus from "Common/Server/Infrastructure/Status";
import logger from "Common/Server/Utils/Logger";
import App from "Common/Server/Utils/StartServer";
import Telemetry from "Common/Server/Utils/Telemetry";
import Realtime from "Common/Server/Utils/Realtime";
import PostgresAppInstance from "Common/Server/Infrastructure/PostgresDatabase";
import Redis from "Common/Server/Infrastructure/Redis";
import { ClickhouseAppInstance } from "Common/Server/Infrastructure/ClickhouseDatabase";
import "ejs";
const APP_NAME: string = "workflow";
@ -32,8 +37,22 @@ const init: PromiseVoidFunction = async (): Promise<void> => {
},
});
// Connect to Postgres database
await PostgresAppInstance.connect();
// Connect to Redis
await Redis.connect();
// Connect to Clickhouse database
await ClickhouseAppInstance.connect(
ClickhouseAppInstance.getDatasourceOptions(),
);
// Initialize real-time functionalities
await Realtime.init();
// Initialize home routes at the end since it has a catch-all route
await WorkerRoutes.init();
await WorkflowRoutes.init();
// Add default routes to the app
await App.addDefaultRoutes();