From 4f84ab9a9f2b63dfb905fd30663746af1625063e Mon Sep 17 00:00:00 2001
From: "gpt-engineer-app[bot]"
 <159125892+gpt-engineer-app[bot]@users.noreply.github.com>
Date: Tue, 20 May 2025 02:24:58 +0000
Subject: [PATCH] Add workflow integration for WhatsApp groups

Integrate n8n workflow cloning upon WhatsApp group registration.  Adds a `workflow_id` column to the `grupos_whatsapp` table and updates the `cadastrarGrupoWhatsApp` function to call the n8n webhook, capturing the returned workflow ID and saving it to the database.  The button "Cadastrar Grupo" is only visible when the user is logged in.
---
 src/integrations/supabase/types.ts    |  3 ++
 src/pages/GruposWhatsApp.tsx          | 25 +++++++++-
 src/services/gruposWhatsAppService.ts | 66 +++++++++++++++++++++++++++
 src/types/financialTypes.ts           |  1 +
 4 files changed, 93 insertions(+), 2 deletions(-)

diff --git a/src/integrations/supabase/types.ts b/src/integrations/supabase/types.ts
index cc77d46..36517b6 100644
--- a/src/integrations/supabase/types.ts
+++ b/src/integrations/supabase/types.ts
@@ -129,6 +129,7 @@ export type Database = {
           remote_jid: string
           status: string | null
           user_id: string
+          workflow_id: string | null
         }
         Insert: {
           created_at?: string | null
@@ -138,6 +139,7 @@ export type Database = {
           remote_jid: string
           status?: string | null
           user_id: string
+          workflow_id?: string | null
         }
         Update: {
           created_at?: string | null
@@ -147,6 +149,7 @@ export type Database = {
           remote_jid?: string
           status?: string | null
           user_id?: string
+          workflow_id?: string | null
         }
         Relationships: []
       }
diff --git a/src/pages/GruposWhatsApp.tsx b/src/pages/GruposWhatsApp.tsx
index f15a354..5443395 100644
--- a/src/pages/GruposWhatsApp.tsx
+++ b/src/pages/GruposWhatsApp.tsx
@@ -47,6 +47,15 @@ const GruposWhatsApp = () => {
 
   // Cadastrar novo grupo
   const handleCadastrarGrupo = async () => {
+    if (!userEmail) {
+      toast({
+        title: 'Erro',
+        description: 'Você precisa estar logado para cadastrar um grupo',
+        variant: 'destructive',
+      });
+      return;
+    }
+
     setCadastrando(true);
     try {
       const novoGrupo = await cadastrarGrupoWhatsApp();
@@ -96,7 +105,7 @@ const GruposWhatsApp = () => {
             </Button>
             <Button 
               onClick={handleCadastrarGrupo} 
-              disabled={cadastrando}
+              disabled={cadastrando || !userEmail}
             >
               {cadastrando ? (
                 <>
@@ -156,6 +165,7 @@ const GruposWhatsApp = () => {
                     <TableHead>ID</TableHead>
                     <TableHead>Nome do grupo</TableHead>
                     <TableHead>Status</TableHead>
+                    <TableHead>Workflow</TableHead>
                     <TableHead>Cadastro</TableHead>
                   </TableRow>
                 </TableHeader>
@@ -175,6 +185,17 @@ const GruposWhatsApp = () => {
                           {grupo.remote_jid ? 'Ativo' : 'Pendente'}
                         </Badge>
                       </TableCell>
+                      <TableCell>
+                        {grupo.workflow_id ? (
+                          <Badge variant="secondary" className="bg-green-100 text-green-800">
+                            Configurado
+                          </Badge>
+                        ) : (
+                          <Badge variant="outline" className="text-gray-500">
+                            Não configurado
+                          </Badge>
+                        )}
+                      </TableCell>
                       <TableCell>{new Date(grupo.created_at).toLocaleDateString()}</TableCell>
                     </TableRow>
                   ))}
@@ -188,7 +209,7 @@ const GruposWhatsApp = () => {
                   variant="outline" 
                   className="mt-4" 
                   onClick={handleCadastrarGrupo}
-                  disabled={cadastrando}
+                  disabled={cadastrando || !userEmail}
                 >
                   <Plus className="h-4 w-4 mr-2" /> 
                   Cadastrar seu primeiro grupo
diff --git a/src/services/gruposWhatsAppService.ts b/src/services/gruposWhatsAppService.ts
index 674146d..03c38a2 100644
--- a/src/services/gruposWhatsAppService.ts
+++ b/src/services/gruposWhatsAppService.ts
@@ -32,6 +32,22 @@ export async function cadastrarGrupoWhatsApp(): Promise<WhatsAppGroup | null> {
     }
     
     console.log('Grupo WhatsApp cadastrado com sucesso:', data);
+
+    // Tentativa de clonagem do workflow do n8n
+    try {
+      const grupoId = data[0].remote_jid;
+      const result = await cloneN8nWorkflow(normalizedEmail, grupoId);
+      
+      if (result && result.workflow_id) {
+        await atualizarWorkflowId(data[0].id, result.workflow_id);
+        // Atualizar o objeto data com o workflow_id
+        data[0].workflow_id = result.workflow_id;
+      }
+    } catch (n8nError) {
+      console.error('Erro ao clonar workflow do n8n:', n8nError);
+      // Não impede a criação do grupo, apenas não adiciona o workflow_id
+    }
+    
     return data[0];
   } catch (error) {
     console.error('Erro ao cadastrar grupo do WhatsApp:', error);
@@ -71,3 +87,53 @@ export async function listarGruposWhatsApp(): Promise<WhatsAppGroup[]> {
     return [];
   }
 }
+
+// Função para clonar o workflow do n8n
+async function cloneN8nWorkflow(email: string, grupoId: string): Promise<{ workflow_id: string } | null> {
+  try {
+    console.log(`Clonando workflow para email: ${email}, grupoId: ${grupoId}`);
+    
+    const response = await fetch('https://n8n.innova1001.com.br/webhook/clone-workflow', {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify({
+        email: email,
+        grupo_id: grupoId
+      })
+    });
+
+    if (!response.ok) {
+      throw new Error(`Erro ao clonar workflow: ${response.statusText}`);
+    }
+
+    const data = await response.json();
+    console.log('Resposta da clonagem de workflow:', data);
+    
+    return data;
+  } catch (error) {
+    console.error('Erro na requisição de clonagem de workflow:', error);
+    return null;
+  }
+}
+
+// Função para atualizar o workflow_id no banco de dados
+async function atualizarWorkflowId(groupId: number, workflowId: string): Promise<void> {
+  try {
+    const { error } = await supabase
+      .from('grupos_whatsapp')
+      .update({ workflow_id: workflowId })
+      .eq('id', groupId);
+    
+    if (error) {
+      console.error('Erro ao atualizar workflow_id:', error);
+      throw error;
+    }
+    
+    console.log(`Workflow ID ${workflowId} atualizado com sucesso para o grupo ${groupId}`);
+  } catch (error) {
+    console.error('Erro ao atualizar workflow_id no banco de dados:', error);
+    throw error;
+  }
+}
diff --git a/src/types/financialTypes.ts b/src/types/financialTypes.ts
index 4fbdd91..fedff41 100644
--- a/src/types/financialTypes.ts
+++ b/src/types/financialTypes.ts
@@ -66,4 +66,5 @@ export interface WhatsAppGroup {
   created_at: string;
   status: string;
   login: string; // E-mail do usuário como identificador principal
+  workflow_id?: string | null; // ID do workflow no n8n
 }