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

Refactor WhatsApp workflow activation to use webhook

Browse Source 
Replaced direct n8n API call with a webhook POST request to `/webhook/ativarworkflow` containing the user's email after WhatsApp instance creation.
This commit is contained in:
gpt-engineer-app[bot] 2025-06-19 23:52:52 +00:00
parent 7ed70a35ff
commit d14f68d709
1 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/services/whatsAppInstance/workflowOperations.ts
View File

@ -1,48 +1,48 @@
import { N8N_CONFIG } from './config'; import { N8N_CONFIG } from './config';
import { getUserWorkflowId } from './databaseOperations';
/** /**
* N8N workflow operations * N8N workflow operations
*/ */
/** /**
* Activates user workflow in n8n * Notifica o n8n para ativar o workflow do usuário via webhook
*/ */
export async function activateUserWorkflow(userEmail: string): Promise<void> { export async function activateUserWorkflow(userEmail: string): Promise<void> {
try { try {
console.log(`🔄 Iniciando ativação do workflow para usuário: ${userEmail}`); console.log(`🔔 Enviando webhook para ativar workflow do usuário: ${userEmail}`);
// Get user's workflow ID // Nova lógica: webhook simples para o n8n
const workflowId = await getUserWorkflowId(userEmail); const webhookUrl = 'https://webhookn8n.innova1001.com.br/webhook/ativarworkflow';
console.log(`📋 Workflow ID encontrado: ${workflowId}`); console.log(`🔗 URL do webhook: ${webhookUrl}`);
// Make activation request - formato exato conforme o print const webhookBody = {
const activationUrl = `${N8N_CONFIG.BASE_URL}/workflows/${workflowId}/activate`; email: userEmail
console.log(`🔗 URL de ativação: ${activationUrl}`); };
const response = await fetch(activationUrl, { console.log('📦 Dados do webhook:', JSON.stringify(webhookBody, null, 2));
const response = await fetch(webhookUrl, {
method: 'POST', method: 'POST',
headers: { headers: {
'X-N8N-API-KEY': N8N_CONFIG.API_KEY,
'Content-Type': 'application/json' 'Content-Type': 'application/json'
} },
// Sem body - conforme mostrado no print, não há body na requisição body: JSON.stringify(webhookBody)
}); });
console.log(`📡 Status da resposta da ativação: ${response.status}`); console.log(`📡 Status da resposta do webhook: ${response.status}`);
if (!response.ok) { if (!response.ok) {
const errorText = await response.text(); const errorText = await response.text();
console.error(`❌ Erro ao ativar workflow: ${response.status} - ${errorText}`); console.error(`❌ Erro ao enviar webhook: ${response.status} - ${errorText}`);
throw new Error(`Erro ao ativar workflow: ${response.status} - ${errorText}`); throw new Error(`Erro ao notificar ativação do workflow: ${response.status} - ${errorText}`);
} }
const responseData = await response.json(); const responseData = await response.text();
console.log('✅ Workflow ativado com sucesso:', responseData); console.log('✅ Webhook enviado com sucesso:', responseData);
} catch (error) { } catch (error) {
console.error('💥 Erro crítico ao ativar workflow do usuário:', error); console.error('💥 Erro crítico ao enviar webhook de ativação:', error);
throw error; throw error;
} }
} }