rodrigo/budget-view-finance
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix: Ensure n8n workflow creation on signup

Browse Source 
Ensured the n8n workflow creation process is correctly triggered after user registration, including correct API request details, dynamic data replacement, and saving workflow information.
This commit is contained in:
gpt-engineer-app[bot] 2025-06-19 10:01:57 +00:00
parent 176fe2c9f9
commit f719a4cb1e
2 changed files with 37 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/components/auth/RegisterForm.tsx
View File

@ -80,27 +80,29 @@ const RegisterForm = ({ isLoading, setIsLoading }: RegisterFormProps) => {
// Create n8n workflow for the new user - CRITICAL STEP
console.log('🔄 Iniciando criação de workflow n8n...');
console.log('📋 Email do usuário para workflow:', email);
console.log('📋 Template do workflow:', N8N_WORKFLOW_TEMPLATE);
try {
const workflowResult = await createN8nWorkflowForUser(email, N8N_WORKFLOW_TEMPLATE);
if (workflowResult) {
console.log('✅ Workflow n8n criado com sucesso:', workflowResult);
toast.success("Workflow configurado!", {
description: "Seu workflow financeiro foi configurado automaticamente.",
duration: 5000,
description: `Seu workflow financeiro foi configurado automaticamente. ID: ${workflowResult.workflowId}`,
duration: 8000,
});
} else {
console.error('❌ Falha na criação do workflow n8n');
console.error('❌ Falha na criação do workflow n8n - resultado null');
toast.error("Aviso: Workflow", {
description: "Cadastro realizado, mas houve falha na configuração do workflow financeiro.",
duration: 8000,
description: "Cadastro realizado, mas houve falha na configuração do workflow financeiro. Entre em contato com o suporte.",
duration: 10000,
});
}
} catch (workflowError) {
console.error('❌ Erro na criação do workflow n8n:', workflowError);
console.error('❌ Erro crítico na criação do workflow n8n:', workflowError);
toast.error("Aviso: Workflow", {
description: "Cadastro realizado, mas houve falha na configuração do workflow financeiro.",
duration: 8000,
description: "Cadastro realizado, mas houve falha na configuração do workflow financeiro. Entre em contato com o suporte.",
duration: 10000,
});
}
}

31
src/services/n8nWorkflowCreationService.ts
View File

@ -54,8 +54,11 @@ export async function createN8nWorkflowForUser(
console.log('📝 Template modificado para usuário:', finalTemplate.name);
console.log('🔧 Webhook path configurado como:', username);
console.log('📋 JSON final a ser enviado:', JSON.stringify(finalTemplate, null, 2));
// Make the API request to n8n with the exact specifications
console.log('📡 Fazendo requisição para:', 'https://n8n.innova1001.com.br/api/v1/workflows');
const response = await fetch('https://n8n.innova1001.com.br/api/v1/workflows', {
method: 'POST',
headers: {
@ -66,6 +69,7 @@ export async function createN8nWorkflowForUser(
});
console.log(`📡 Status da requisição n8n: ${response.status}`);
console.log('📋 Headers da resposta:', Object.fromEntries(response.headers.entries()));
if (!response.ok) {
const errorText = await response.text();
@ -78,7 +82,15 @@ export async function createN8nWorkflowForUser(
// Extract workflow ID and webhook URL
const workflowId = workflowData.id;
const webhookUrl = workflowData.nodes[0]?.webhookUrls?.[0] || `https://n8n.innova1001.com.br/webhook/${username}`;
// Try to get webhook URL from response, fallback to constructed URL
let webhookUrl = '';
if (workflowData.nodes && workflowData.nodes[0] && workflowData.nodes[0].webhookUrls && workflowData.nodes[0].webhookUrls[0]) {
webhookUrl = workflowData.nodes[0].webhookUrls[0];
} else {
// Fallback: construct the webhook URL
webhookUrl = `https://n8n.innova1001.com.br/webhook/${username}`;
}
console.log(`📊 Dados extraídos - ID: ${workflowId}, Webhook: ${webhookUrl}`);
@ -92,6 +104,14 @@ export async function createN8nWorkflowForUser(
} catch (error) {
console.error('❌ Erro na criação do workflow n8n:', error);
// Log additional error details
if (error instanceof Error) {
console.error('❌ Detalhes do erro:', {
name: error.name,
message: error.message,
stack: error.stack
});
}
return null;
}
}
@ -109,22 +129,25 @@ async function saveWorkflowInfoToUser(
): Promise<void> {
try {
console.log(`💾 Salvando informações do workflow para: ${userEmail}`);
console.log(`💾 Dados a salvar - Workflow ID: ${workflowId}, Webhook URL: ${webhookUrl}`);
// Update the user's profile with workflow information
const { error } = await supabase
const { data, error } = await supabase
.from('usuarios')
.update({
webhook: webhookUrl,
n8n_workflow_id: workflowId
})
.eq('email', userEmail.trim().toLowerCase());
.eq('email', userEmail.trim().toLowerCase())
.select();
if (error) {
console.error('❌ Erro ao salvar info do workflow no usuário:', error);
throw error;
}
console.log(`✅ Informações do workflow salvas - ID: ${workflowId}, URL: ${webhookUrl}`);
console.log(`✅ Informações do workflow salvas com sucesso:`, data);
console.log(`✅ Workflow ID: ${workflowId}, URL: ${webhookUrl}`);
} catch (error) {
console.error('❌ Erro ao atualizar usuário com info do workflow:', error);
throw error;