wip

decentraland · Feb 12, 2024 · 96db925 · 96db925
1 parent 00c956f
commit 96db925
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 8 deletions.
diff --git a/core/src/service.ts b/core/src/service.ts
@@ -9,7 +9,7 @@ export async function main(program: Lifecycle.EntryPointParameters<AppComponents
   // start ports: db, listeners, synchronizations, etc
   await startComponents()
 
-  const { nats, config, logs, metrics, publisher, engine } = components
+  const { nats, config, logs, publisher, engine } = components
 
   const flushFrequency = await config.requireNumber('ARCHIPELAGO_FLUSH_FREQUENCY')
   const checkHeartbeatInterval = await config.requireNumber('CHECK_HEARTBEAT_INTERVAL')

diff --git a/ws-connector/src/controllers/routes.ts b/ws-connector/src/controllers/routes.ts
@@ -44,12 +44,7 @@ export async function setupRoutes(context: GlobalContext): Promise<Router<Global
     }
   }
 
-  // TODO
-  // *  - GET /health/ready - readyness probe
-  // *  - GET /health/startup - startup probe
-  // *  - GET /health/live - liveness probe
-
-  registerWsHandler(context.components)
+  await registerWsHandler(context.components)
 
   {
     const handler = await createStatusHandler(context.components)
@@ -61,5 +56,26 @@ export async function setupRoutes(context: GlobalContext): Promise<Router<Global
     server.app.get(path, handler)
   }
 
+  // TODO: do I need to implement these?
+  // *  - GET /health/ready - readyness probe
+  // *  - GET /health/startup - startup probe
+
+  server.app.any('/health/live', (res, req) => {
+    const { end, labels } = onRequestStart(metrics, req.getMethod(), '/health/live')
+    res.writeStatus('200 OK')
+    res.writeHeader('Access-Control-Allow-Origin', '*')
+    res.end('alive')
+    onRequestEnd(metrics, labels, 404, end)
+  })
+
+  server.app.any('/*', (res, req) => {
+    const { end, labels } = onRequestStart(metrics, req.getMethod(), '')
+    res.writeStatus('404 Not Found')
+    res.writeHeader('Access-Control-Allow-Origin', '*')
+    res.writeHeader('content-type', 'application/json')
+    res.end(JSON.stringify({ error: 'Not Found' }))
+    onRequestEnd(metrics, labels, 404, end)
+  })
+
   return router
 }
diff --git a/ws-connector/src/types.ts b/ws-connector/src/types.ts
@@ -28,7 +28,7 @@ export type BaseComponents = {
 }
 
 // components used in runtime
-export type AppComponents = BaseComponents & {}
+export type AppComponents = BaseComponents
 
 // components used in tests
 export type TestComponents = BaseComponents & {