From cb46c03db56a3f276948b651516a9a8bff5b6910 Mon Sep 17 00:00:00 2001
From: alma <alma@governance-labs.org>
Date: Sun, 11 May 2025 22:13:31 +0200
Subject: [PATCH] n8n

---
 app/api/missions/route.ts   | 10 ++++++++++
 lib/services/n8n-service.ts | 18 +++++++++++++++---
 2 files changed, 25 insertions(+), 3 deletions(-)

diff --git a/app/api/missions/route.ts b/app/api/missions/route.ts
index e3a479b4..de7b52e6 100644
--- a/app/api/missions/route.ts
+++ b/app/api/missions/route.ts
@@ -17,9 +17,19 @@ async function checkAuth(request: Request, body?: any) {
   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');
     return { authorized: true, userId: process.env.SYSTEM_USER_ID || 'system' };
   }
 
diff --git a/lib/services/n8n-service.ts b/lib/services/n8n-service.ts
index 2f8a1b49..666312ac 100644
--- a/lib/services/n8n-service.ts
+++ b/lib/services/n8n-service.ts
@@ -16,7 +16,8 @@ export class N8nService {
     try {
       console.log('Triggering n8n workflow for mission creation:', {
         name: missionData.name,
-        missionType: missionData.missionType
+        missionType: missionData.missionType,
+        webhookUrl: this.webhookUrl
       });
 
       const response = await axios.post(this.webhookUrl, missionData, {
@@ -25,7 +26,11 @@ export class N8nService {
         }
       });
 
-      console.log('n8n workflow response:', response.data);
+      console.log('n8n workflow response:', {
+        status: response.status,
+        statusText: response.statusText,
+        data: response.data
+      });
 
       if (response.data.errors && response.data.errors.length > 0) {
         console.warn('Workflow completed with partial success:', response.data.errors);
@@ -33,12 +38,19 @@ export class N8nService {
       }
 
       if (!response.data.success) {
+        console.error('Workflow execution failed:', {
+          message: response.data.message,
+          data: response.data
+        });
         throw new Error(`Workflow execution failed: ${response.data.message || 'Unknown error'}`);
       }
 
       return response.data;
     } catch (error) {
-      console.error('Error triggering n8n workflow:', error);
+      console.error('Error triggering n8n workflow:', {
+        error: error instanceof Error ? error.message : String(error),
+        webhookUrl: this.webhookUrl
+      });
       throw new Error(`Failed to trigger mission creation workflow: ${error instanceof Error ? error.message : String(error)}`);
     }
   }