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

export default defineEventHandler(async (event) => {
  const token = getBridgeTokenFromHeader(event)

  if (!token) {
    throw createError({
      statusCode: 401,
      statusMessage: 'Unauthorized',
      message: 'x-bridge-token header fehlt oder ist ungültig.',
    })
  }

  console.info(`\x1b[36m[bridge:me]\x1b[0m token=\x1b[96m${token.slice(0, 6)}...\x1b[0m request received`)

  const document = await BridgeToken.findOne({ token })
  const bridgeUser = await resolveBridgeUser(document?.user)

  if (!document || !bridgeUser) {
    const result = {
      token,
      connected: false,
      user: null,
      simConnected: false,
      flightActive: false,
      connectedAt: document?.connectedAt ? document.connectedAt.toISOString() : null,
      lastStatusAt: document?.lastStatusAt ? document.lastStatusAt.toISOString() : null,
    }

    logBridgeEvent(token, {
      endpoint: '/api/bridge/me',
      method: 'GET',
      statusCode: 200,
      color: '#06b6d4',
      summary: 'Status check — not connected',
    })

    return result
  }

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

  logBridgeEvent(token, {
    endpoint: '/api/bridge/me',
    method: 'GET',
    statusCode: 200,
    color: '#06b6d4',
    summary: `Status check — connected as ${bridgeUser.name || bridgeUser.email}`,
  })

  return result
})