cleanup: health

Author: izadoesdev

apps/api/package.json

@@ -17,6 +17,7 @@
     "@elysiajs/cors": "^1.3.3",
     "@elysiajs/trpc": "^1.1.0",
     "@elysiajs/websocket": "^0.2.8",
+    "@logtail/edge": "^0.5.5",
     "@trpc/server": "^11.4.3",
     "autumn-js": "0.0.101-beta.1",
     "dayjs": "^1.11.13",

apps/api/src/lib/logger.ts

@@ -0,0 +1,9 @@
+import { Logtail } from '@logtail/edge';
+
+const token = process.env.LOGTAIL_SOURCE_TOKEN as string;
+const endpoint = process.env.LOGTAIL_ENDPOINT as string;
+export const logger = new Logtail(token, {
+	endpoint,
+	batchSize: 10,
+	batchInterval: 1000,
+});

apps/api/src/routes/health.ts

@@ -1,13 +1,14 @@
 import { chQuery, db } from '@databuddy/db';
-import { redis } from '@databuddy/redis';
+import { redis as redisClient } from '@databuddy/redis';
 import { Elysia } from 'elysia';
+import { logger } from '../lib/logger';
 
 const checkClickhouse = async () => {
 	try {
 		const result = await chQuery('SELECT 1 FROM analytics.events LIMIT 1');
 		return result.length > 0;
 	} catch (error) {
-		console.error('ClickHouse health check failed:', error);
+		logger.error('ClickHouse health check failed:', { error });
 		return false;
 	}
 };
@@ -19,17 +20,17 @@ const checkDatabase = async () => {
 		});
 		return result.length > 0;
 	} catch (error) {
-		console.error('Database health check failed:', error);
+		logger.error('Database health check failed:', { error });
 		return false;
 	}
 };
 
 const checkRedis = async () => {
 	try {
-		const result = await redis.ping();
+		const result = await redisClient.ping();
 		return result === 'PONG';
 	} catch (error) {
-		console.error('Redis health check failed:', error);
+		logger.error('Redis health check failed:', { error });
 		return false;
 	}
 };

bun.lock

@@ -19,6 +19,7 @@
         "@elysiajs/cors": "^1.3.3",
         "@elysiajs/trpc": "^1.1.0",
         "@elysiajs/websocket": "^0.2.8",
+        "@logtail/edge": "^0.5.5",
         "@trpc/server": "^11.4.3",
         "autumn-js": "0.0.101-beta.1",
         "dayjs": "^1.11.13",