mirror of
https://github.com/OneUptime/oneuptime.git
synced 2026-01-11 19:56:44 +00:00
a256f4be54
- Updated logging statements in Sitemap.ts to enhance code clarity. - Reformatted logger.info calls in IncomingRequestIngest, OpenTelemetryIngest, Probe, ProbeIngest, and ServerMonitorIngest to use multi-line formatting for better readability. - Adjusted import statements in Probe to follow a consistent multi-line format.
83 lines
2.6 KiB
TypeScript
83 lines
2.6 KiB
TypeScript
import MonitorAPI from "./API/Monitor";
|
|
import ProbeIngest from "./API/Probe";
|
|
import RegisterAPI from "./API/Register";
|
|
import MetricsAPI from "./API/Metrics";
|
|
import { PromiseVoidFunction } from "Common/Types/FunctionTypes";
|
|
import { ClickhouseAppInstance } from "Common/Server/Infrastructure/ClickhouseDatabase";
|
|
import PostgresAppInstance from "Common/Server/Infrastructure/PostgresDatabase";
|
|
import Redis from "Common/Server/Infrastructure/Redis";
|
|
import InfrastructureStatus from "Common/Server/Infrastructure/Status";
|
|
import Express, { ExpressApplication } from "Common/Server/Utils/Express";
|
|
import logger from "Common/Server/Utils/Logger";
|
|
import Realtime from "Common/Server/Utils/Realtime";
|
|
import App from "Common/Server/Utils/StartServer";
|
|
import Telemetry from "Common/Server/Utils/Telemetry";
|
|
import "./Jobs/ProbeIngest/ProcessProbeIngest";
|
|
import { PROBE_INGEST_CONCURRENCY } from "./Config";
|
|
import "ejs";
|
|
|
|
const app: ExpressApplication = Express.getExpressApp();
|
|
|
|
const APP_NAME: string = "probe-ingest";
|
|
|
|
// "/ingestor" is used here for backward compatibility because probes are already deployed with this path in client environments.
|
|
app.use([`/${APP_NAME}`, "/ingestor", "/"], RegisterAPI);
|
|
app.use([`/${APP_NAME}`, "/ingestor", "/"], MonitorAPI);
|
|
app.use([`/${APP_NAME}`, "/ingestor", "/"], ProbeIngest);
|
|
app.use([`/${APP_NAME}`, "/"], MetricsAPI);
|
|
|
|
const init: PromiseVoidFunction = async (): Promise<void> => {
|
|
try {
|
|
const statusCheck: PromiseVoidFunction = async (): Promise<void> => {
|
|
return await InfrastructureStatus.checkStatusWithRetry({
|
|
checkClickhouseStatus: true,
|
|
checkPostgresStatus: true,
|
|
checkRedisStatus: true,
|
|
retryCount: 3,
|
|
});
|
|
};
|
|
|
|
// Initialize telemetry
|
|
Telemetry.init({
|
|
serviceName: APP_NAME,
|
|
});
|
|
|
|
logger.info(
|
|
`ProbeIngest Service - Queue concurrency: ${PROBE_INGEST_CONCURRENCY}`,
|
|
);
|
|
|
|
// init the app
|
|
await App.init({
|
|
appName: APP_NAME,
|
|
statusOptions: {
|
|
liveCheck: statusCheck,
|
|
readyCheck: statusCheck,
|
|
},
|
|
});
|
|
|
|
// connect to the database.
|
|
await PostgresAppInstance.connect();
|
|
|
|
// connect redis
|
|
await Redis.connect();
|
|
|
|
await ClickhouseAppInstance.connect(
|
|
ClickhouseAppInstance.getDatasourceOptions(),
|
|
);
|
|
|
|
await Realtime.init();
|
|
|
|
// add default routes
|
|
await App.addDefaultRoutes();
|
|
} catch (err) {
|
|
logger.error("App Init Failed:");
|
|
logger.error(err);
|
|
throw err;
|
|
}
|
|
};
|
|
|
|
init().catch((err: Error) => {
|
|
logger.error(err);
|
|
logger.error("Exiting node process");
|
|
process.exit(1);
|
|
});
|