NeahNew/app/api/missions/route.ts

import { NextResponse } from 'next/server';
import { getServerSession } from 'next-auth';
import { authOptions } from "@/app/api/auth/options";
import { prisma } from '@/lib/prisma';
import { getPublicUrl } from '@/lib/s3';
import { S3_CONFIG } from '@/lib/s3';
import { N8nService } from '@/lib/services/n8n-service';
import { MissionUser, Prisma } from '@prisma/client';

interface MissionUserInput {
  role: string;
  userId: string;
  missionId: string;
}

// Helper function to check authentication
async function checkAuth(request: Request, body?: any) {
  // Check for service account API key first
  const apiKey = request.headers.get('x-api-key');
  console.log('API key from header:', apiKey);
  console.log('API key from env:', process.env.N8N_API_KEY);
  console.log('Keys match:', apiKey === process.env.N8N_API_KEY);
  if (apiKey === process.env.N8N_API_KEY) {
    // For service account, use the creatorId from the request body
    if (body?.creatorId) {
      console.log('Using creatorId from request body:', body.creatorId);
      // Verify the user exists
      const user = await prisma.user.findUnique({
        where: { id: body.creatorId }
      });
      if (!user) {
        console.error('Creator user not found:', body.creatorId);
        return { authorized: false, userId: null };
      }
      return { authorized: true, userId: body.creatorId };
    }
    // Fallback to system user if no creatorId provided
    console.log('No creatorId provided, using system user');
    // Use the first user in the database as system user
    const systemUser = await prisma.user.findFirst();
    if (!systemUser) {
      console.error('No users found in database for system user fallback');
      return { authorized: false, userId: null };
    }
    return { authorized: true, userId: systemUser.id };
  }

  // Fall back to NextAuth session for regular users
  const session = await getServerSession(authOptions);
  if (!session?.user?.id) {
    console.error('Unauthorized access attempt:', {
      url: request.url,
      method: request.method,
      headers: Object.fromEntries(request.headers)
    });
    return { authorized: false, userId: null };
  }
  return { authorized: true, userId: session.user.id };
}

// GET endpoint to list missions with filters
export async function GET(request: Request) {
  try {
    const { authorized, userId } = await checkAuth(request);
    if (!authorized || !userId) {
      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
    }

    const { searchParams } = new URL(request.url);
    const limit = Number(searchParams.get('limit') || '10');
    const offset = Number(searchParams.get('offset') || '0');
    const search = searchParams.get('search');
    
    // Build query conditions
    const where: any = {};
    
    // Add search filter if provided
    if (search) {
      where.OR = [
        { name: { contains: search, mode: 'insensitive' } },
        { intention: { contains: search, mode: 'insensitive' } }
      ];
    }
    
    // Get missions with basic info
    const missions = await (prisma as any).mission.findMany({
      where,
      skip: offset,
      take: limit,
      orderBy: { createdAt: 'desc' },
      select: {
        id: true,
        name: true,
        logo: true,
        oddScope: true,
        niveau: true,
        missionType: true,
        projection: true,
        participation: true,
        services: true,
        intention: true,
        createdAt: true,
        creator: {
          select: {
            id: true,
            email: true
          }
        },
        missionUsers: {
          select: {
            id: true,
            role: true,
            user: {
              select: {
                id: true,
                email: true
              }
            }
          }
        }
      }
    });
    
    // Get total count
    const totalCount = await (prisma as any).mission.count({ where });
    
    // Transform logo paths to public URLs
    const missionsWithPublicUrls = missions.map((mission: any) => ({
      ...mission,
      logo: mission.logo ? `/api/missions/image/${mission.logo}` : null
    }));
    
    return NextResponse.json({
      missions: missionsWithPublicUrls,
      pagination: {
        total: totalCount,
        offset,
        limit
      }
    });
  } catch (error) {
    console.error('Error listing missions:', error);
    return NextResponse.json({ 
      error: 'Internal server error', 
      details: error instanceof Error ? error.message : String(error) 
    }, { status: 500 });
  }
}

// POST endpoint to create a new mission
export async function POST(request: Request) {
  try {
    const session = await getServerSession(authOptions);
    if (!session?.user) {
      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
    }

    const body = await request.json();
    const { name, oddScope, niveau, intention, missionType, donneurDOrdre, projection, services, participation, profils, guardians, volunteers } = body;

    // Check if mission with same name exists
    const existingMission = await prisma.mission.findFirst({
      where: { name }
    });

    if (existingMission) {
      return NextResponse.json({ error: 'A mission with this name already exists' }, { status: 400 });
    }

    // Create the mission
    const mission = await prisma.mission.create({
      data: {
        name,
        oddScope,
        niveau,
        intention,
        missionType,
        donneurDOrdre,
        projection,
        services,
        profils,
        creatorId: session.user.id
      }
    });

    // Add guardians and volunteers
    if (guardians || volunteers) {
      const missionUsers: MissionUserInput[] = [];

      // Add guardians
      if (guardians) {
        Object.entries(guardians).forEach(([role, userId]) => {
          if (userId) {
            missionUsers.push({
              role,
              userId: userId as string,
              missionId: mission.id
            });
          }
        });
      }

      // Add volunteers
      if (volunteers && Array.isArray(volunteers)) {
        volunteers.forEach(userId => {
          if (userId) {
            missionUsers.push({
              role: 'volontaire',
              userId,
              missionId: mission.id
            });
          }
        });
      }

      if (missionUsers.length > 0) {
        await prisma.missionUser.createMany({
          data: missionUsers
        });
      }
    }

    // Trigger n8n workflow
    const n8nService = new N8nService();
    console.log('About to trigger n8n workflow with data:', {
      missionId: mission.id,
      name: mission.name,
      creatorId: mission.creatorId,
      fullData: body
    });

    try {
      const workflowResult = await n8nService.triggerMissionCreation({
        ...body,
        missionId: mission.id,
        creatorId: mission.creatorId
      });

      console.log('Received workflow result:', workflowResult);

      if (!workflowResult.success) {
        console.error('N8n workflow failed:', workflowResult.error);
        // Continue with mission creation even if n8n workflow fails
        return NextResponse.json(mission);
      }

      // Process workflow results
      const results = workflowResult.results || {};
      console.log('Processing workflow results:', results);

      // Update mission with integration data
      const integrationData = {
        leantimeProjectId: results.leantimeProjectId?.toString(),
        outlineCollectionId: results.outlineCollectionId?.toString(),
        rocketChatChannelId: results.rocketChatChannelId?.toString(),
        giteaRepositoryUrl: results.giteaRepositoryUrl?.toString()
      } as Prisma.MissionUpdateInput;

      console.log('Updating mission with integration data:', integrationData);

      const updatedMission = await prisma.mission.update({
        where: { id: mission.id },
        data: integrationData
      });

      return NextResponse.json(updatedMission);
    } catch (error) {
      console.error('Error in n8n workflow:', error);
      // Return the mission even if n8n workflow fails
      return NextResponse.json(mission);
    }
  } catch (error) {
    console.error('Error creating mission:', error);
    return NextResponse.json(
      { error: 'Failed to create mission' },
      { status: 500 }
    );
  }
}