feat(api): implement ingest route and log schema for logging functionality

Author: Prateet-Github

api/app.ts

@@ -1,5 +1,6 @@
 import Fastify from 'fastify';
 import { healthRoute } from './routes/health.route.js';
+import { ingestRoute } from './routes/ingest.route.js';
 
 export const buildApp = () => {
   const app = Fastify({ logger: true });
@@ -8,5 +9,9 @@ export const buildApp = () => {
     prefix: '/api/health',
   });
 
+  app.register(ingestRoute, {
+    prefix: '/api/ingest',
+  });
+
   return app;
 };

api/controllers/ingest.controller.ts

@@ -0,0 +1,43 @@
+import type { FastifyRequest, FastifyReply } from 'fastify';
+import { producer } from '../lib/kafka.js';
+import { logSchema } from '../schemas/log.schema.js';
+import type { LogInput } from '../schemas/log.schema.js';
+
+export const createLog = async (
+  request: FastifyRequest<{ Body: LogInput }>, 
+  reply: FastifyReply
+) => {
+  
+  // 1. Validate
+  const result = logSchema.safeParse(request.body);
+  
+  if (!result.success) {
+    return reply.status(400).send({ 
+      error: 'Validation Failed', 
+      details: result.error.format() 
+    });
+  }
+
+  const logData = result.data;
+
+  try {
+    // 2. Business Logic
+    await producer.send({
+      topic: 'app-logs',
+      messages: [
+        {
+          value: JSON.stringify({
+            ...logData,
+            timestamp: new Date().toISOString(),
+          }),
+        },
+      ],
+    });
+
+    return reply.status(202).send({ status: 'queued', id: crypto.randomUUID() });
+
+  } catch (error) {
+    request.log.error(error);
+    return reply.status(500).send({ error: 'Failed to queue log' });
+  }
+};

api/routes/ingest.route.ts

@@ -0,0 +1,6 @@
+import type { FastifyInstance } from 'fastify';
+import { createLog } from '../controllers/ingest.controller.js';
+
+export async function ingestRoute(fastify: FastifyInstance) {
+  fastify.post('/', createLog);
+}

api/schemas/log.schema.ts

@@ -0,0 +1,10 @@
+import z from 'zod';
+
+export const logSchema = z.object({
+  service: z.string().min(1, "Service name is required"),
+  level: z.enum(['INFO', 'WARN', 'ERROR', 'DEBUG']),
+  message: z.string().min(1, "Log message cannot be empty"),
+  metadata: z.record(z.string(), z.any()).optional(),
+});
+
+export type LogInput = z.infer<typeof logSchema>;