alma/NeahNew
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

W n8n

Browse Source
This commit is contained in:
alma 2025-05-22 20:50:43 +02:00
parent 36faf6c818
commit 7ce04af59c
1 changed files with 22 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
app/api/missions/route.ts
View File

@ -187,12 +187,12 @@ export async function POST(request: Request) {
}); });
// Update the existing mission with new integration IDs // Update the existing mission with new integration IDs
const updateData: Prisma.MissionUncheckedUpdateInput = { const updateData = {
rocketChatChannelId: body.rocketchatChannelId || existingMission.rocketChatChannelId, rocketChatChannelId: body.rocketchatChannelId || existingMission.rocketChatChannelId,
leantimeProjectId: body.leantimeProjectId || existingMission.leantimeProjectId, leantimeProjectId: body.leantimeProjectId || existingMission.leantimeProjectId,
outlineCollectionId: body.documentationCollectionId || existingMission.outlineCollectionId, outlineCollectionId: body.documentationCollectionId || existingMission.outlineCollectionId,
giteaRepositoryUrl: body.gitRepoUrl || existingMission.giteaRepositoryUrl giteaRepositoryUrl: body.gitRepoUrl || existingMission.giteaRepositoryUrl
}; } as any;
const updatedMission = await prisma.mission.update({ const updatedMission = await prisma.mission.update({
where: { id: existingMission.id }, where: { id: existingMission.id },
@ -230,7 +230,10 @@ export async function POST(request: Request) {
if (!workflowResult.success) { if (!workflowResult.success) {
console.error('N8n workflow failed:', workflowResult.error); console.error('N8n workflow failed:', workflowResult.error);
return NextResponse.json({ error: 'Failed to create mission resources' }, { status: 500 }); return NextResponse.json({
error: 'Failed to create mission resources',
details: workflowResult.error
}, { status: 500 });
} }
// Process workflow results // Process workflow results
@ -306,8 +309,23 @@ export async function POST(request: Request) {
return NextResponse.json(mission); return NextResponse.json(mission);
} catch (error) { } catch (error) {
console.error('Error in n8n workflow:', error); console.error('Error in n8n workflow:', error);
// If there's an error, we should clean up any resources that were created
if (error instanceof Error && error.message.includes('HTTP error! status: 500')) {
return NextResponse.json(
{
error: 'Failed to create mission resources',
details: 'The mission creation process failed. Please try again later.',
code: 'WORKFLOW_ERROR'
},
{ status: 500 }
);
}
return NextResponse.json( return NextResponse.json(
{ error: 'Failed to create mission resources', details: error instanceof Error ? error.message : String(error) }, {
error: 'Failed to create mission',
details: error instanceof Error ? error.message : String(error),
code: 'MISSION_CREATION_ERROR'
},
{ status: 500 } { status: 500 }
); );
} }