import Fastify from 'fastify';
import fastifyJwt from '@fastify/jwt';
import fastifyCors from '@fastify/cors';
import fastifyWebSocket from '@fastify/websocket';
import fastifyMultipart from '@fastify/multipart';
import fastifyStatic from '@fastify/static';
import webpush from 'web-push';
import { initDB } from './db.js';
import { setupWebSocket } from './ws.js';
import authRoutes from './routes/auth.js';
import adminRoutes from './routes/admin.js';
import chatRoutes from './routes/chats.js';
import messageRoutes from './routes/messages.js';
import userRoutes from './routes/users.js';
import pushRoutes from './routes/push.js';

async function main() {
  const app = Fastify({ logger: true });

  // VAPID
  if (process.env.VAPID_PUBLIC_KEY && process.env.VAPID_PRIVATE_KEY) {
    webpush.setVapidDetails(
      `mailto:${process.env.VAPID_EMAIL || 'admin@janichat.ru'}`,
      process.env.VAPID_PUBLIC_KEY,
      process.env.VAPID_PRIVATE_KEY
    );
  }

  // Plugins
  await app.register(fastifyCors, {
    origin: (process.env.ALLOWED_ORIGINS || '').split(','),
    credentials: true,
  });

  await app.register(fastifyJwt, { secret: process.env.JWT_SECRET! });

  await app.register(fastifyWebSocket);

  await app.register(fastifyMultipart, {
    limits: { fileSize: 50 * 1024 * 1024 },
  });

  await app.register(fastifyStatic, {
    root: '/uploads',
    prefix: '/uploads/',
  });

  // Auth decorator
  app.decorate('authenticate', async function(request: any, reply: any) {
    try {
      await request.jwtVerify();
    } catch {
      reply.status(401).send({ error: 'Unauthorized' });
    }
  });

  // Routes
  await app.register(authRoutes, { prefix: '/api/auth' });
  await app.register(adminRoutes, { prefix: '/api/admin' });
  await app.register(chatRoutes, { prefix: '/api/chats' });
  await app.register(messageRoutes, { prefix: '/api/messages' });
  await app.register(userRoutes, { prefix: '/api/users' });
  await app.register(pushRoutes, { prefix: '/api/push' });

  // Health check
  app.get('/health', async () => ({ ok: true }));

  // WebSocket
  setupWebSocket(app);

  // Init DB
  await initDB();

  // Start
  await app.listen({ port: parseInt(process.env.PORT || '3000'), host: '0.0.0.0' });
}

main().catch(err => {
  console.error(err);
  process.exit(1);
});