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 { IntegrationService } from '@/lib/services/integration-service';
import { N8nService } from '@/lib/services/n8n-service';

// Helper function to check authentication
async function checkAuth(request: Request) {
  // 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 a default system user ID
    return { authorized: true, userId: process.env.SYSTEM_USER_ID || 'system' };
  }

  // 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 { authorized, userId } = await checkAuth(request);
    if (!authorized || !userId) {
      return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
    }

    // Parse the request body
    const body = await request.json();
    const { 
      name,
      logo,
      oddScope,
      niveau,
      intention,
      missionType,
      donneurDOrdre,
      projection,
      services,
      participation,
      profils,
      guardians,
      volunteers
    } = body;
    
    // Validate required fields
    if (!name || !niveau || !intention || !missionType || !donneurDOrdre || !projection) {
      return NextResponse.json({ 
        error: 'Missing required fields',
        required: { 
          name: true, 
          niveau: true, 
          intention: true, 
          missionType: true,
          donneurDOrdre: true,
          projection: true
        },
        received: { 
          name: !!name, 
          niveau: !!niveau, 
          intention: !!intention, 
          missionType: !!missionType,
          donneurDOrdre: !!donneurDOrdre,
          projection: !!projection
        }
      }, { status: 400 });
    }

    // Create the mission in the database first
    const mission = await prisma.mission.create({
      data: {
        name,
        logo,
        oddScope: oddScope || [],
        niveau,
        intention,
        missionType,
        donneurDOrdre,
        projection,
        services: services || [],
        participation,
        profils: profils || [],
        creatorId: userId
      }
    });

    // Add guardians if provided
    if (guardians) {
      const guardianRoles = ['gardien-temps', 'gardien-parole', 'gardien-memoire'];
      const guardianEntries = Object.entries(guardians)
        .filter(([role, userId]) => guardianRoles.includes(role) && userId)
        .map(([role, userId]) => ({
          role,
          userId: userId as string,
          missionId: mission.id
        }));
      
      if (guardianEntries.length > 0) {
        await prisma.missionUser.createMany({
          data: guardianEntries
        });
      }
    }
    
    // Add volunteers if provided
    if (volunteers && volunteers.length > 0) {
      const volunteerEntries = volunteers.map((userId: string) => ({
        role: 'volontaire',
        userId,
        missionId: mission.id
      }));
      
      await prisma.missionUser.createMany({
        data: volunteerEntries
      });
    }

    try {
      // Trigger the n8n workflow
      const n8nService = new N8nService();
      const workflowResult = await n8nService.createMission({
        ...body,
        missionId: mission.id,
        creatorId: userId
      });

      // Update mission with integration results, even if some failed
      if (workflowResult.results) {
        const updateData: any = {};
        
        // Only update fields that were successfully created
        if (workflowResult.results.gitRepo?.html_url) {
          updateData.giteaRepositoryUrl = workflowResult.results.gitRepo.html_url;
        }
        if (workflowResult.results.leantimeProject?.result) {
          updateData.leantimeProjectId = workflowResult.results.leantimeProject.result.toString();
        }
        if (workflowResult.results.rocketChatChannel?.channel?._id) {
          updateData.rocketChatChannelId = workflowResult.results.rocketChatChannel.channel._id;
        }
        if (workflowResult.results.docCollection?.id) {
          updateData.outlineCollectionId = workflowResult.results.docCollection.id;
        }

        // Only update if we have any successful integrations
        if (Object.keys(updateData).length > 0) {
          await prisma.mission.update({
            where: { id: mission.id },
            data: updateData
          });
        }
      }

      return NextResponse.json({
        success: true,
        mission: {
          id: mission.id,
          name: mission.name,
          createdAt: mission.createdAt
        },
        workflow: {
          status: workflowResult.success ? 'success' : 'partial_success',
          data: workflowResult,
          errors: workflowResult.errors || []
        }
      });
    } catch (workflowError) {
      // If workflow fails completely, delete the mission and report failure
      console.error('Workflow error:', workflowError);
      await prisma.mission.delete({ where: { id: mission.id } });
      
      return NextResponse.json({ 
        error: 'Failed to set up external services', 
        details: workflowError instanceof Error ? workflowError.message : String(workflowError)
      }, { status: 500 });
    }
  } catch (error) {
    console.error('Error creating mission:', error);
    return NextResponse.json({ 
      error: 'Internal server error', 
      details: error instanceof Error ? error.message : String(error) 
    }, { status: 500 });
  }
}