import { createError, readBody } from 'h3'
import { BridgeToken } from '../../models/BridgeToken'
import { getBridgeTokenFromHeader, resolveBridgeUser } from '../../utils/bridge'
import { logBridgeEvent } from '../../utils/bridgeLog'

interface StatusBody {
  simConnected?: boolean
  flightActive?: boolean
}

export default defineEventHandler(async (event) => {
  const token = getBridgeTokenFromHeader(event)
  if (!token) {
    throw createError({ statusCode: 401, statusMessage: 'x-bridge-token header fehlt oder ist ungültig.' })
  }

  const body = await readBody<StatusBody>(event)
  console.info(
    `\x1b[33m[bridge:status]\x1b[0m token=\x1b[96m${token.slice(0, 6)}...\x1b[0m simConnected=\x1b[92m${String(body.simConnected)}\x1b[0m flightActive=\x1b[92m${String(body.flightActive)}\x1b[0m`,
  )

  const updatePayload: Record<string, unknown> = {
    lastStatusAt: new Date(),
  }

  if (typeof body.simConnected === 'boolean') {
    updatePayload.simConnected = body.simConnected
  }

  if (typeof body.flightActive === 'boolean') {
    updatePayload.flightActive = body.flightActive
  }

  const document = await BridgeToken.findOneAndUpdate(
    { token },
    {
      $set: updatePayload,
      $setOnInsert: { token },
    },
    { new: true, upsert: true, runValidators: true },
  )

  if (!document) {
    throw createError({ statusCode: 500, statusMessage: 'Status konnte nicht aktualisiert werden.' })
  }

  const user = await resolveBridgeUser(document.user)

  const result = {
    token: document.token,
    connected: Boolean(user),
    user: user
      ? {
          id: String(user._id),
          email: user.email,
          name: user.name,
        }
      : null,
    simConnected: document.simConnected,
    flightActive: document.flightActive,
    connectedAt: document.connectedAt ? document.connectedAt.toISOString() : null,
    lastStatusAt: document.lastStatusAt ? document.lastStatusAt.toISOString() : null,
  }

  logBridgeEvent(token, {
    endpoint: '/api/bridge/status',
    method: 'POST',
    statusCode: 200,
    color: '#eab308',
    summary: `sim=${String(body.simConnected)} flight=${String(body.flightActive)}`,
    data: body as Record<string, unknown>,
  })

  return result
})