Corrigiu provenção token do bot

X-Lovable-Edit-ID: edt-a169bb9e-e525-4b91-b180-2d62dcb9da78
Co-authored-by: domfelipe <53182096+domfelipe@users.noreply.github.com>

supabase/functions/provision-agent/index.ts

@@ -197,9 +197,18 @@ Deno.serve(async (req) => {
   }
 
   if (!telegramBotToken) {
-    console.error(`[provision-agent] telegram_bot_token ausente — usuário ainda não conectou bot`);
+    // Onboarding ainda não concluído. NÃO marca agent como 'error' — o wizard de Telegram
-    await failJob(supabase, agent, job.id, "telegram_bot_token ausente no Vault — usuário precisa concluir onboarding antes");
+    // dispara este endpoint de novo após o usuário salvar o token (validate-telegram-bot).
-    return jsonResponse(412, { error: "telegram token missing" });
+    console.log(`[provision-agent] aguardando token do Telegram (job=${job.id})`);
+    await supabase
+      .from("provisioning_jobs")
+      .update({
+        status: "pending",
+        error_message: "Aguardando o usuário conectar o bot do Telegram",
+        completed_at: null,
+      })
+      .eq("id", job.id);
+    return jsonResponse(202, { waiting_for_token: true, agent_instance_id: agent.id });
   }
   console.log(`[provision-agent] token Telegram OK (len=${telegramBotToken.length})`);
 

supabase/functions/validate-telegram-bot/index.ts

@@ -98,12 +98,13 @@ Deno.serve(async (req) => {
         409,
       );
     }
-    if (agent.status === "suspended" || agent.status === "error") {
+    if (agent.status === "suspended") {
       return jsonResponse(
         { error: "Agente suspenso. Regularize sua assinatura antes de conectar o Telegram." },
         403,
       );
     }
+    // status='error' por falta de token anterior é recuperável — apenas seguimos.
 
     // 4) Verifica unicidade do bot username (em outro agent_instance)
     const { data: conflict } = await admin
@@ -186,7 +187,9 @@ Deno.serve(async (req) => {
       );
     }
 
-    // 7) Atualiza agent_instances
+    // 7) Atualiza agent_instances — reseta para 'provisioning' se estava em erro,
+    // garante que o provision-agent re-execute do zero.
+    const nextStatus = agent.status === "error" ? "provisioning" : agent.status;
     const { error: updErr } = await admin
       .from("agent_instances")
       .update({
@@ -196,6 +199,7 @@ Deno.serve(async (req) => {
         telegram_token_invalid: false,
         telegram_webhook_configured: false,
         telegram_first_message_received_at: null,
+        status: nextStatus,
         updated_at: new Date().toISOString(),
       })
       .eq("id", agent.id);
@@ -205,6 +209,26 @@ Deno.serve(async (req) => {
       return jsonResponse({ error: "Falha ao salvar dados do bot." }, 500);
     }
 
+    // 8) Auto-provisionamento: dispara provision-agent assincronamente para que
+    // o container seja criado/atualizado no Railway. Fire-and-forget — o wizard
+    // não bloqueia esperando o deploy completar.
+    if (nextStatus === "provisioning" || agent.status === "active") {
+      try {
+        const provisionUrl = `${supabaseUrl}/functions/v1/provision-agent`;
+        console.log(`auto-provision: disparando para agent ${agent.id}`);
+        fetch(provisionUrl, {
+          method: "POST",
+          headers: {
+            "Content-Type": "application/json",
+            Authorization: `Bearer ${serviceKey}`,
+          },
+          body: JSON.stringify({ agent_instance_id: agent.id }),
+        }).catch((err) => console.error("auto-provision fetch error:", err));
+      } catch (err) {
+        console.error("auto-provision trigger error:", err);
+      }
+    }
+
     return jsonResponse({
       valid: true,
       bot_username: botUsername,