From 7e632a5cf7ecff948c71672389055bce9ed031cb Mon Sep 17 00:00:00 2001 From: alma Date: Sun, 11 May 2025 22:15:11 +0200 Subject: [PATCH] n8n --- app/api/missions/route.ts | 8 +++++++- lib/services/n8n-service.ts | 11 +++++++++++ 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/app/api/missions/route.ts b/app/api/missions/route.ts index de7b52e6..1be5c9b7 100644 --- a/app/api/missions/route.ts +++ b/app/api/missions/route.ts @@ -30,7 +30,13 @@ async function checkAuth(request: Request, body?: any) { } // 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' }; + // 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 diff --git a/lib/services/n8n-service.ts b/lib/services/n8n-service.ts index 666312ac..d740c117 100644 --- a/lib/services/n8n-service.ts +++ b/lib/services/n8n-service.ts @@ -32,6 +32,17 @@ export class N8nService { data: response.data }); + // Handle string response + if (typeof response.data === 'string') { + console.log('Received string response from n8n, treating as success'); + return { + success: true, + results: { + message: response.data + } + }; + } + if (response.data.errors && response.data.errors.length > 0) { console.warn('Workflow completed with partial success:', response.data.errors); return response.data;