mirror of
https://github.com/domfelipe/mika-agent-assist.git
synced 2026-08-07 07:56:42 +00:00
Changes
Co-authored-by: domfelipe <53182096+domfelipe@users.noreply.github.com>
This commit is contained in:
parent
8f10c589ad
commit
074513e5ff
4 changed files with 35 additions and 17 deletions
10
README.md
10
README.md
|
|
@ -24,6 +24,16 @@ Já configuradas via `.env` (gerado automaticamente pelo Lovable Cloud):
|
||||||
- `PADDLE_API_KEY` / `PADDLE_WEBHOOK_SECRET`
|
- `PADDLE_API_KEY` / `PADDLE_WEBHOOK_SECRET`
|
||||||
- `SUPABASE_SERVICE_ROLE_KEY`
|
- `SUPABASE_SERVICE_ROLE_KEY`
|
||||||
- `RAILWAY_API_TOKEN` — token da Railway Public API, usado por `provision-agent`/`suspend-agent`/`resume-agent` para criar e gerenciar containers Hermes.
|
- `RAILWAY_API_TOKEN` — token da Railway Public API, usado por `provision-agent`/`suspend-agent`/`resume-agent` para criar e gerenciar containers Hermes.
|
||||||
|
|
||||||
|
> **Suspend/Resume via flag, não via stop.** Railway não permite parar containers sem redeploy. As Edge Functions `suspend-agent`/`resume-agent` usam a env var `HERMES_SUSPENDED` + `serviceInstanceRedeploy`:
|
||||||
|
> - `suspend` → upsert `HERMES_SUSPENDED=true` e redeploy → container entra em `sleep infinity`.
|
||||||
|
> - `resume` → upsert `HERMES_SUSPENDED=""` e redeploy → container sobe normal.
|
||||||
|
>
|
||||||
|
> Isso depende do start command verificar a flag. Novos serviços já são provisionados com o comando correto (`HERMES_START_COMMAND` em `_shared/railway.ts`):
|
||||||
|
> ```bash
|
||||||
|
> /bin/bash -c 'if [ "$HERMES_SUSPENDED" = "true" ]; then echo "Agent suspended" && sleep infinity; fi && if [ -n "$HERMES_SOUL_OVERRIDE" ]; then echo "$HERMES_SOUL_OVERRIDE" > /opt/data/SOUL.md; fi && /opt/hermes/docker/entrypoint.sh gateway run'
|
||||||
|
> ```
|
||||||
|
> **Para serviços Railway existentes (provisionados antes desta mudança):** atualize manualmente o Start Command via Railway UI/Agent para o comando acima — caso contrário `suspend-agent` apenas marcará `status='suspended'` no banco mas o container continuará rodando.
|
||||||
- `OPENROUTER_API_KEY` — **obrigatório**. Injetado em cada container Hermes provisionado para que o agente possa chamar os modelos `openrouter/google/gemma-4-*-it`. Sem isso o `provision-agent` retorna 500.
|
- `OPENROUTER_API_KEY` — **obrigatório**. Injetado em cada container Hermes provisionado para que o agente possa chamar os modelos `openrouter/google/gemma-4-*-it`. Sem isso o `provision-agent` retorna 500.
|
||||||
- `ADMIN_TELEGRAM_BOT_TOKEN` — token do bot de admin (ex: `@mika_test2_bot`) usado pelo `payments-webhook` para enviar notificações de novos clientes, falhas de pagamento e cancelamentos.
|
- `ADMIN_TELEGRAM_BOT_TOKEN` — token do bot de admin (ex: `@mika_test2_bot`) usado pelo `payments-webhook` para enviar notificações de novos clientes, falhas de pagamento e cancelamentos.
|
||||||
- `ADMIN_TELEGRAM_CHAT_ID` — chat ID do admin que recebe as notificações (ex: `179720882`).
|
- `ADMIN_TELEGRAM_CHAT_ID` — chat ID do admin que recebe as notificações (ex: `179720882`).
|
||||||
|
|
|
||||||
|
|
@ -10,6 +10,7 @@ import {
|
||||||
configureRailwayService,
|
configureRailwayService,
|
||||||
deployRailwayService,
|
deployRailwayService,
|
||||||
deleteTelegramWebhook,
|
deleteTelegramWebhook,
|
||||||
|
HERMES_START_COMMAND,
|
||||||
} from "../_shared/railway.ts";
|
} from "../_shared/railway.ts";
|
||||||
|
|
||||||
interface RequestBody {
|
interface RequestBody {
|
||||||
|
|
@ -191,7 +192,7 @@ Deno.serve(async (req) => {
|
||||||
serviceId: railwayServiceId,
|
serviceId: railwayServiceId,
|
||||||
environmentId: pool.railway_environment_id,
|
environmentId: pool.railway_environment_id,
|
||||||
image: "nousresearch/hermes-agent:latest",
|
image: "nousresearch/hermes-agent:latest",
|
||||||
startCommand: "/opt/hermes/docker/entrypoint.sh gateway run",
|
startCommand: HERMES_START_COMMAND,
|
||||||
variables: envVars,
|
variables: envVars,
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,11 +1,11 @@
|
||||||
// resume-agent
|
// resume-agent
|
||||||
// Retoma o serviço Railway (numReplicas=1) e marca agent_instance.status='active'.
|
// Retoma o serviço Hermes removendo HERMES_SUSPENDED (string vazia) e disparando redeploy.
|
||||||
// Disparado automaticamente quando subscription volta para active/trialing,
|
// Disparado automaticamente quando subscription volta para active/trialing,
|
||||||
// ou manualmente pelo painel admin.
|
// ou manualmente pelo painel admin.
|
||||||
|
|
||||||
import { createClient } from "https://esm.sh/@supabase/supabase-js@2.45.4";
|
import { createClient } from "https://esm.sh/@supabase/supabase-js@2.45.4";
|
||||||
import { corsHeaders } from "../_shared/cors.ts";
|
import { corsHeaders } from "../_shared/cors.ts";
|
||||||
import { setRailwayReplicas, getServiceEnvironmentId } from "../_shared/railway.ts";
|
import { setHermesSuspended, getServiceEnvironmentId } from "../_shared/railway.ts";
|
||||||
|
|
||||||
const SUPABASE_URL = Deno.env.get("SUPABASE_URL")!;
|
const SUPABASE_URL = Deno.env.get("SUPABASE_URL")!;
|
||||||
const SUPABASE_SERVICE_ROLE_KEY = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
|
const SUPABASE_SERVICE_ROLE_KEY = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
|
||||||
|
|
@ -55,15 +55,17 @@ Deno.serve(async (req) => {
|
||||||
return jsonResponse(200, { ok: true, already_active: true });
|
return jsonResponse(200, { ok: true, already_active: true });
|
||||||
}
|
}
|
||||||
|
|
||||||
// Resolve environmentId: prioriza vps_pool, fallback para query no Railway
|
// Resolve environmentId/projectId
|
||||||
let environmentId: string | null = null;
|
let environmentId: string | null = null;
|
||||||
|
let projectId: string | undefined;
|
||||||
if (agent.vps_pool_id) {
|
if (agent.vps_pool_id) {
|
||||||
const { data: pool } = await supabase
|
const { data: pool } = await supabase
|
||||||
.from("vps_pool")
|
.from("vps_pool")
|
||||||
.select("railway_environment_id")
|
.select("railway_environment_id, railway_project_id")
|
||||||
.eq("id", agent.vps_pool_id)
|
.eq("id", agent.vps_pool_id)
|
||||||
.maybeSingle();
|
.maybeSingle();
|
||||||
environmentId = pool?.railway_environment_id ?? null;
|
environmentId = pool?.railway_environment_id ?? null;
|
||||||
|
projectId = pool?.railway_project_id ?? undefined;
|
||||||
}
|
}
|
||||||
if (!environmentId) {
|
if (!environmentId) {
|
||||||
environmentId = await getServiceEnvironmentId({
|
environmentId = await getServiceEnvironmentId({
|
||||||
|
|
@ -76,16 +78,17 @@ Deno.serve(async (req) => {
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await setRailwayReplicas({
|
await setHermesSuspended({
|
||||||
token: RAILWAY_API_TOKEN,
|
token: RAILWAY_API_TOKEN,
|
||||||
serviceId: agent.railway_service_id,
|
serviceId: agent.railway_service_id,
|
||||||
environmentId,
|
environmentId,
|
||||||
replicas: 1,
|
projectId,
|
||||||
|
suspend: false,
|
||||||
});
|
});
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
const msg = e instanceof Error ? e.message : String(e);
|
const msg = e instanceof Error ? e.message : String(e);
|
||||||
console.error("resume-agent: setRailwayReplicas failed:", msg);
|
console.error("resume-agent: setHermesSuspended failed:", msg);
|
||||||
return jsonResponse(500, { error: "railway scale-up failed", detail: msg });
|
return jsonResponse(500, { error: "railway resume failed", detail: msg });
|
||||||
}
|
}
|
||||||
|
|
||||||
await supabase
|
await supabase
|
||||||
|
|
|
||||||
|
|
@ -1,11 +1,12 @@
|
||||||
// suspend-agent
|
// suspend-agent
|
||||||
// Pausa o serviço Railway (numReplicas=0) e marca agent_instance.status='suspended'.
|
// Pausa o serviço Hermes setando HERMES_SUSPENDED=true e disparando redeploy.
|
||||||
|
// O start command verifica essa flag e entra em `sleep infinity` (agente pausado).
|
||||||
// Disparado automaticamente quando subscription muda para canceled/past_due/unpaid/paused,
|
// Disparado automaticamente quando subscription muda para canceled/past_due/unpaid/paused,
|
||||||
// ou manualmente pelo painel admin.
|
// ou manualmente pelo painel admin.
|
||||||
|
|
||||||
import { createClient } from "https://esm.sh/@supabase/supabase-js@2.45.4";
|
import { createClient } from "https://esm.sh/@supabase/supabase-js@2.45.4";
|
||||||
import { corsHeaders } from "../_shared/cors.ts";
|
import { corsHeaders } from "../_shared/cors.ts";
|
||||||
import { setRailwayReplicas, getServiceEnvironmentId } from "../_shared/railway.ts";
|
import { setHermesSuspended, getServiceEnvironmentId } from "../_shared/railway.ts";
|
||||||
|
|
||||||
const SUPABASE_URL = Deno.env.get("SUPABASE_URL")!;
|
const SUPABASE_URL = Deno.env.get("SUPABASE_URL")!;
|
||||||
const SUPABASE_SERVICE_ROLE_KEY = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
|
const SUPABASE_SERVICE_ROLE_KEY = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!;
|
||||||
|
|
@ -56,15 +57,17 @@ Deno.serve(async (req) => {
|
||||||
return jsonResponse(200, { ok: true, no_container: true });
|
return jsonResponse(200, { ok: true, no_container: true });
|
||||||
}
|
}
|
||||||
|
|
||||||
// Resolve o environmentId: prioriza vps_pool, fallback para query no Railway
|
// Resolve o environmentId/projectId via vps_pool, fallback Railway query
|
||||||
let environmentId: string | null = null;
|
let environmentId: string | null = null;
|
||||||
|
let projectId: string | undefined;
|
||||||
if (agent.vps_pool_id) {
|
if (agent.vps_pool_id) {
|
||||||
const { data: pool } = await supabase
|
const { data: pool } = await supabase
|
||||||
.from("vps_pool")
|
.from("vps_pool")
|
||||||
.select("railway_environment_id")
|
.select("railway_environment_id, railway_project_id")
|
||||||
.eq("id", agent.vps_pool_id)
|
.eq("id", agent.vps_pool_id)
|
||||||
.maybeSingle();
|
.maybeSingle();
|
||||||
environmentId = pool?.railway_environment_id ?? null;
|
environmentId = pool?.railway_environment_id ?? null;
|
||||||
|
projectId = pool?.railway_project_id ?? undefined;
|
||||||
}
|
}
|
||||||
if (!environmentId) {
|
if (!environmentId) {
|
||||||
environmentId = await getServiceEnvironmentId({
|
environmentId = await getServiceEnvironmentId({
|
||||||
|
|
@ -77,16 +80,17 @@ Deno.serve(async (req) => {
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await setRailwayReplicas({
|
await setHermesSuspended({
|
||||||
token: RAILWAY_API_TOKEN,
|
token: RAILWAY_API_TOKEN,
|
||||||
serviceId: agent.railway_service_id,
|
serviceId: agent.railway_service_id,
|
||||||
environmentId,
|
environmentId,
|
||||||
replicas: 0,
|
projectId,
|
||||||
|
suspend: true,
|
||||||
});
|
});
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
const msg = e instanceof Error ? e.message : String(e);
|
const msg = e instanceof Error ? e.message : String(e);
|
||||||
console.error("suspend-agent: setRailwayReplicas failed:", msg);
|
console.error("suspend-agent: setHermesSuspended failed:", msg);
|
||||||
return jsonResponse(500, { error: "railway scale-down failed", detail: msg });
|
return jsonResponse(500, { error: "railway suspend failed", detail: msg });
|
||||||
}
|
}
|
||||||
|
|
||||||
await supabase
|
await supabase
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue