app/api/v1/lambda-executions/route.ts

import { NextRequest } from 'next/server'
import { Db } from 'mongodb'
import { writeShard, invalidateUsage } from '@/lib/mongoPool'
import { checkAuth } from '@/lib/auth'
import { record } from '@/lib/ingestLog'

// Atlas raises this once a cluster is over its storage quota.
function isQuotaError(err: unknown): boolean {
  return /over your space quota|quota exceeded|you are over/i.test(String(err))
}

export async function POST(req: NextRequest) {
  try {
    const rawBody = Buffer.from(await req.arrayBuffer())
    const auth = checkAuth(rawBody, req.headers)
    if (!auth.ok) {
      record({ route: 'lambda-executions', ok: false, count: 0, detail: auth.error ?? 'auth failed' })
      return Response.json({ error: auth.error }, { status: 401 })
    }

    const body = JSON.parse(rawBody.toString('utf-8'))
    const events = body?.events
    if (!Array.isArray(events) || events.length === 0) {
      return Response.json({ error: 'events array required' }, { status: 400 })
    }

    const now = new Date()
    const docs = events.map((ev) => ({
      event_id: ev.event_id ?? crypto.randomUUID(),
      project_id: ev.project_id ?? 'unknown',
      func_name: ev.func_name ?? 'unknown',
      stage: ev.stage ?? 'prod',
      created_at: now,
    }))

    const write = async (db: Db) => db.collection('lambda_events').insertMany(docs, { ordered: false })

    let db = await writeShard('lambda')
    try {
      await write(db)
    } catch (err) {
      if (!isQuotaError(err)) throw err
      // The cached size estimate was stale and this shard filled between checks.
      // Re-probe and roll to the next one rather than dropping the batch.
      console.warn('lambda shard full, rolling over')
      invalidateUsage('lambda')
      db = await writeShard('lambda')
      await write(db)
    }

    const funcs = [...new Set(docs.map((d) => d.func_name))]
    record({
      route: 'lambda-executions',
      ok: true,
      count: docs.length,
      detail: `${docs[0]?.stage ?? '?'} · ${funcs.slice(0, 3).join(', ')}${funcs.length > 3 ? ` +${funcs.length - 3}` : ''}`,
    })
    return Response.json({ success: true, inserted: docs.length })
  } catch (err) {
    console.error('lambda-executions error:', err)
    return Response.json({ error: 'Internal server error' }, { status: 500 })
  }
}