import type { IncomingMessage, ServerResponse } from 'node:http';

import { buildApi } from '../apps/api/src/app.js';

import { TrustEngine } from '../packages/core/src/index.js';

import { HostedRepository } from '../packages/persistence/src/hosted.js';

import { dashboardTokenFromCookie, loadAuth0Profile, verifyAuth0Token } from './auth0.js';

const databaseUrl = process.env.DATABASE_URL;

const repository = databaseUrl ? new HostedRepository(databaseUrl) : undefined;

const app = buildApi(new TrustEngine(), undefined, repository);

const ready = app.ready();

export default async function handler(request: IncomingMessage, response: ServerResponse) {

  const incoming = new URL(request.url ?? '/', 'https://openclasp.local');

  const target = incoming.searchParams.get('path');

  if (target) request.url = target;

  if ((request.url ?? '').startsWith('/v0.1/')) {

    const authorization = request.headers.authorization;

    const token = authorization?.startsWith('Bearer ')

      ? authorization.slice(7)

      : dashboardTokenFromCookie(request.headers.cookie);

    if (!token) {

      response.statusCode = 401;

      response.setHeader('content-type', 'application/json');

      response.end(JSON.stringify({ error: 'authentication_required' }));

      return;

    }

    try {

      const authentication = await verifyAuth0Token(token, { dashboard: true });

      request.headers['x-openclasp-operator'] = authentication.payload.sub!;

      if ((request.url ?? '').startsWith('/v0.1/account')) {

        const user = await loadAuth0Profile(token);

        request.headers['x-openclasp-email'] = encodeURIComponent(user.email ?? '');

        request.headers['x-openclasp-name'] = encodeURIComponent(user.name ?? '');

      }

    } catch {

      response.statusCode = 401;

      response.setHeader('content-type', 'application/json');

      response.end(JSON.stringify({ error: 'invalid_session' }));

      return;

    }

  }

  await ready;

  app.server.emit('request', request, response);

}