ingest-bun.controller.ts

import { Controller, Post, Body, Get } from '@nestjs/common';
import { IngestBunService } from './ingest-bun.service';

export interface IngestResponse {
  id: string;
  t_ms: number;
}

export interface HealthResponse {
  status: string;
  timestamp: string;
  runtime: string;
}

@Controller()
export class IngestBunController {
  constructor(private readonly ingestService: IngestBunService) {}

  @Post('ingest')
  async ingest(@Body() payload: Record<string, any>): Promise<IngestResponse> {
    const startTime = process.hrtime.bigint();
    
    const id = await this.ingestService.process(payload);
    
    const endTime = process.hrtime.bigint();
    const elapsedMs = Number(endTime - startTime) / 1000000; // Convert nanoseconds to milliseconds
    
    return {
      id,
      t_ms: Math.round(elapsedMs * 100) / 100 // Round to 2 decimal places
    };
  }

  @Get('health')
  getHealth(): HealthResponse {
    return {
      status: 'ok',
      timestamp: new Date().toISOString(),
      runtime: typeof Bun !== 'undefined' ? `Bun ${Bun.version}` : `Node.js ${process.version}`
    };
  }
}