diff --git a/supabase/functions/provision-agent/index.ts b/supabase/functions/provision-agent/index.ts index 7ee1c42..adcc97c 100644 --- a/supabase/functions/provision-agent/index.ts +++ b/supabase/functions/provision-agent/index.ts @@ -75,6 +75,8 @@ Deno.serve(async (req) => { auth: { persistSession: false, autoRefreshToken: false }, }); + console.log(`[provision-agent] início para agent_instance_id=${body.agent_instance_id}`); + // 1) Carregar agent_instance const { data: agent, error: agentErr } = await supabase .from("agent_instances") @@ -85,14 +87,17 @@ Deno.serve(async (req) => { .maybeSingle(); if (agentErr || !agent) { + console.error(`[provision-agent] agent_instance não encontrado: ${agentErr?.message}`); return jsonResponse(404, { error: "agent_instance not found", detail: agentErr?.message }); } if (agent.status !== "provisioning") { + console.log(`[provision-agent] status atual=${agent.status}, abortando`); return jsonResponse(409, { error: "agent_instance is not in provisioning status", status: agent.status }); } if (agent.railway_service_id) { + console.log(`[provision-agent] já tem railway_service_id=${agent.railway_service_id}, abortando`); return jsonResponse(409, { error: "agent_instance already has a railway_service_id", railway_service_id: agent.railway_service_id }); } @@ -106,6 +111,7 @@ Deno.serve(async (req) => { const fullName = (profile?.full_name?.trim() || "Usuário").toString(); const firstName = fullName.split(" ")[0] || "Usuário"; const agentName = body.agent_name?.trim() || `Mika de ${firstName}`; + console.log(`[provision-agent] profile carregado: ${fullName} → agent_name=${agentName}`); // 1c) Carregar subscription ativa (para definir modelo Pro vs Basic) const { data: subscription } = await supabase @@ -120,6 +126,7 @@ Deno.serve(async (req) => { // deno-lint-ignore no-explicit-any const planSlug = ((subscription as any)?.plans?.slug as string | undefined) ?? "basic"; const isPro = ["professional", "enterprise"].includes(planSlug); + console.log(`[provision-agent] plano=${planSlug} isPro=${isPro}`); // 2) Buscar pool disponível (com IDs Railway preenchidos e capacidade) const { data: pool, error: poolErr } = await supabase @@ -133,9 +140,17 @@ Deno.serve(async (req) => { .maybeSingle(); if (poolErr || !pool || !pool.railway_project_id || !pool.railway_environment_id) { + console.error(`[provision-agent] sem vps_pool disponível: ${poolErr?.message}`); await failJob(supabase, agent, null, "Nenhum vps_pool com Railway IDs configurados disponível"); + await notifyAdmin( + `❌ Falha no auto-provisionamento\n\n` + + `👤 Cliente: ${fullName}\n` + + `❗ Erro: Nenhum vps_pool disponível\n\n` + + `➡️ Resolver manualmente`, + ); return jsonResponse(503, { error: "no railway pool available" }); } + console.log(`[provision-agent] pool selecionado: ${pool.id} (railway_project=${pool.railway_project_id})`); // 3) Criar provisioning_job em status running const { data: job, error: jobErr } = await supabase @@ -158,12 +173,15 @@ Deno.serve(async (req) => { .single(); if (jobErr || !job) { + console.error(`[provision-agent] falha ao criar job: ${jobErr?.message}`); return jsonResponse(500, { error: "failed to create provisioning_job", detail: jobErr?.message }); } + console.log(`[provision-agent] provisioning_job criado: ${job.id}`); // 4) Decrypt do telegram_bot_token (se existir) let telegramBotToken = ""; if (agent.telegram_bot_token_vault_id) { + console.log(`[provision-agent] decifrando token do Vault: ${agent.telegram_bot_token_vault_id}`); const { data: secret } = await supabase.rpc("vault_decrypt_secret", { secret_id: agent.telegram_bot_token_vault_id, }); @@ -171,15 +189,18 @@ Deno.serve(async (req) => { } if (!telegramBotToken) { + console.error(`[provision-agent] telegram_bot_token ausente — usuário ainda não conectou bot`); await failJob(supabase, agent, job.id, "telegram_bot_token ausente no Vault — usuário precisa concluir onboarding antes"); return jsonResponse(412, { error: "telegram token missing" }); } + console.log(`[provision-agent] token Telegram OK (len=${telegramBotToken.length})`); // 5) Apagar webhook Telegram (Hermes vai usar polling) try { await deleteTelegramWebhook(telegramBotToken); + console.log(`[provision-agent] deleteTelegramWebhook OK`); } catch (e) { - console.warn("deleteTelegramWebhook failed (continuing):", String(e)); + console.warn("[provision-agent] deleteTelegramWebhook failed (continuing):", String(e)); } // 6) Montar variáveis de ambiente do container @@ -212,6 +233,7 @@ Deno.serve(async (req) => { // 7) Criar serviço no Railway const serviceName = `mika-${agent.uuid_tenant.replace(/-/g, "").slice(0, 8)}`; + console.log(`[provision-agent] criando serviço Railway: ${serviceName}`); let railwayServiceId: string; try { @@ -220,6 +242,7 @@ Deno.serve(async (req) => { projectId: pool.railway_project_id, name: serviceName, }); + console.log(`[provision-agent] serviço criado: ${railwayServiceId}`); await configureRailwayService({ token: RAILWAY_API_TOKEN, @@ -229,16 +252,26 @@ Deno.serve(async (req) => { startCommand: HERMES_START_COMMAND, variables: envVars, }); + console.log(`[provision-agent] serviço configurado com ${Object.keys(envVars).length} env vars`); await deployRailwayService({ token: RAILWAY_API_TOKEN, serviceId: railwayServiceId, environmentId: pool.railway_environment_id, }); + console.log(`[provision-agent] deploy disparado em Railway`); } catch (e) { const msg = e instanceof Error ? e.message : String(e); - console.error("Railway provisioning failed:", msg); - await scheduleRetry(supabase, agent, job.id, msg); + console.error("[provision-agent] Railway provisioning failed:", msg); + const reachedMax = await scheduleRetry(supabase, agent, job.id, msg); + if (reachedMax) { + await notifyAdmin( + `❌ Falha no auto-provisionamento\n\n` + + `👤 Cliente: ${fullName}\n` + + `❗ Erro: ${msg}\n\n` + + `➡️ Provisionar manualmente`, + ); + } return jsonResponse(500, { error: "railway provisioning failed", detail: msg }); } @@ -262,6 +295,8 @@ Deno.serve(async (req) => { .update({ railway_service_id: railwayServiceId, status: "running" }) .eq("id", job.id); + console.log(`[provision-agent] sucesso: agent=${agent.id} railway=${railwayServiceId} (aguardando deploy)`); + // status do agent permanece 'provisioning' — railway-webhook atualiza para 'active' quando deploy subir return jsonResponse(200, { success: true,