import { Router, Response, NextFunction } from 'express';
import { LogService } from '@/services/logs/log.service.js';
import { AuditService } from '@/services/logs/audit.service.js';
import { AuthRequest, verifyAdmin } from '@/api/middlewares/auth.js';
import { successResponse, paginatedResponse } from '@/utils/response.js';
import { GetLogsResponse } from '@insforge/shared-schemas';
import { AppError } from '@/api/middlewares/error.js';
import { ERROR_CODES } from '@/types/error-constants.js';

const router = Router();

// All logs routes require admin authentication
router.use(verifyAdmin);

// GET /logs/audits - List audit logs
router.get('/audits', async (req: AuthRequest, res: Response, next: NextFunction) => {
  try {
    const { limit = 100, offset = 0, actor, action, module, start_date, end_date } = req.query;

    const auditService = AuditService.getInstance();

    // Build query parameters for audit service
    const queryParams = {
      limit: Number(limit),
      offset: Number(offset),
      ...(actor && typeof actor === 'string' && { actor }),
      ...(action && typeof action === 'string' && { action }),
      ...(module && typeof module === 'string' && { module }),
      ...(start_date && typeof start_date === 'string' && { start_date: new Date(start_date) }),
      ...(end_date && typeof end_date === 'string' && { end_date: new Date(end_date) }),
    };

    // Get audit logs with total count
    const { records, total } = await auditService.query(queryParams);

    paginatedResponse(res, records, total, Number(offset));
  } catch (error) {
    next(error);
  }
});

// GET /logs/audits/stats - Get audit logs statistics
router.get('/audits/stats', async (req: AuthRequest, res: Response, next: NextFunction) => {
  try {
    const { days = 7 } = req.query;

    const auditService = AuditService.getInstance();
    const stats = await auditService.getStats(Number(days));

    successResponse(res, stats);
  } catch (error) {
    next(error);
  }
});

// DELETE /logs/audits - Clear audit logs (admin only)
router.delete('/audits', async (req: AuthRequest, res: Response, next: NextFunction) => {
  try {
    const { days_to_keep = 90 } = req.query;

    const auditService = AuditService.getInstance();
    const deletedCount = await auditService.cleanup(Number(days_to_keep));

    successResponse(res, {
      message: 'Audit logs cleared successfully',
      deleted: deletedCount,
    });
  } catch (error) {
    next(error);
  }
});

// System logs routes
// GET /logs/sources - List all log sources
router.get('/sources', async (_req: AuthRequest, res: Response, next: NextFunction) => {
  try {
    const logService = LogService.getInstance();
    const sources = await logService.getLogSources();

    successResponse(res, sources);
  } catch (error) {
    next(error);
  }
});

// GET /logs/stats - Get statistics for all log sources
router.get('/stats', async (_req: AuthRequest, res: Response, next: NextFunction) => {
  try {
    const logService = LogService.getInstance();
    const stats = await logService.getLogSourceStats();

    successResponse(res, stats);
  } catch (error) {
    next(error);
  }
});

// GET /logs/search - Search across all logs or specific source
router.get('/search', async (req: AuthRequest, res: Response, next: NextFunction) => {
  try {
    const { q, source, limit = 100, offset = 0 } = req.query;

    if (!q || typeof q !== 'string') {
      throw new AppError('Search query parameter (q) is required', 400, ERROR_CODES.INVALID_INPUT);
    }

    const logService = LogService.getInstance();
    const result = await logService.searchLogs(
      q,
      source as string | undefined,
      Number(limit),
      Number(offset)
    );

    paginatedResponse(res, result.logs, result.total, Number(offset));
  } catch (error) {
    next(error);
  }
});

// GET /logs/:source - Get logs from specific source
router.get('/:source', async (req: AuthRequest, res: Response, next: NextFunction) => {
  try {
    const { source } = req.params;
    const { limit = 100, before_timestamp } = req.query;

    const logService = LogService.getInstance();
    const result = await logService.getLogsBySource(
      source,
      Number(limit),
      before_timestamp as string | undefined
    );

    const response: GetLogsResponse = {
      logs: result.logs,
      total: result.total,
    };

    successResponse(res, response);
  } catch (error) {
    next(error);
  }
});

export { router as logsRouter };