Toma una concesión y libérela de nuevo

Intramedial está en beta restringida. Al registrarte o iniciar sesión, debes indicar la contraseña de beta tester que recibiste o solicitar una en preview@intramedial.com. Gracias.

Cargando…

Caso de uso

La tarea

Dos agentes no deben desplegar en producción al mismo tiempo. Tú da al recurso una concesión: el primer agente la tiene, el segundo es rechazado y se le dice quién la tiene y cuánto esperar. Una concesión que nunca se libera caduca sola.

Requisitos

Antes de empezar

Plan: Todo plan, Free incluido
Credencial: Clave API de workspace
Necesitarás: Un nombre de recurso que todos los agentes usen para él

El código lee la clave de INTRAMEDIAL_KEY. Guárdala en tu shell o en tu almacén de secretos, nunca en un archivo que suba al repositorio. Las llamadas que requieren una persona con sesión iniciada no pueden usar una clave: las hace la consola.

Paso a paso

Pasos

Toma una concesión
Pide el recurso como el agente que lo quiere. Un recurso libre devuelve una concesión con un vencimiento.

Respuesta tipo

Qué se devuelve

Un recurso libre responde { ok: true, lease }. La concesión incluye su id, titular y vencimiento.

JSON

200 OK

{
  "ok": true,
  "lease": {
    "id": "lease_4c1e",
    "resource": "lock:deploy/production",
    "holder": "did:web:acme.example:agent:release",
    "expiresAtMs": ,
    : { : , : [] },
    : ,
    : {}
  }
}

Evidencia

Qué prueba el recibo

Prueba

El plano dio a este agente una concesión sobre este recurso.
Hasta que caducó o se liberó, las demás solicitudes sobre él se rechazaron con lease_held.

No llega a probar

Y después

Después

Las tools

coordination.leasecoordination-lease

Documentación

curl -sS -X POST https://api.intramedial.com/api/v1/acp/coordination/lease \
  -H "Authorization: Bearer $INTRAMEDIAL_KEY" \
  -H "Content-Type: application/json" \
  -d '{
  "resource": "lock:deploy/production",
  "actorDid": "did:web:acme.example:agent:release"
}'

const res = await fetch("https://api.intramedial.com/api/v1/acp/coordination/lease", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.INTRAMEDIAL_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    resource: "lock:deploy/production",
    actorDid: "did:web:acme.example:agent:release",
  }),
});
console.log(res.status, await res.json());

import os, requests

res = requests.post(
    "https://api.intramedial.com/api/v1/acp/coordination/lease",
    headers={"Authorization": "Bearer " + os.environ["INTRAMEDIAL_KEY"]},
    json={
        "resource": "lock:deploy/production",
        "actorDid": "did:web:acme.example:agent:release",
    },
    timeout=30,
)
print(res.status_code, res.json())

Pide mientras está tomada

Un segundo agente que pide el mismo recurso es rechazado con lease_held, el DID del titular y una espera en stampede.waitMs. Cada concesión dura los 30 000 ms predeterminados; la ruta no lee ttlMs.

curl -sS -X POST https://api.intramedial.com/api/v1/acp/coordination/lease \
  -H "Authorization: Bearer $INTRAMEDIAL_KEY" \
  -H "Content-Type: application/json" \
  -d '{
  "resource": "lock:deploy/production",
  "actorDid": "did:web:acme.example:agent:cost"
}'

const res = await fetch("https://api.intramedial.com/api/v1/acp/coordination/lease", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.INTRAMEDIAL_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    resource: "lock:deploy/production",
    actorDid: "did:web:acme.example:agent:cost",
  }),
});
const body = await res.json();
if (!body.ok) console.log(body.reason, "held by", body.holder, "wait", body.stampede?.waitMs, "ms");

import os, requests

res = requests.post(
    "https://api.intramedial.com/api/v1/acp/coordination/lease",
    headers={"Authorization": "Bearer " + os.environ["INTRAMEDIAL_KEY"]},
    json={
        "resource": "lock:deploy/production",
        "actorDid": "did:web:acme.example:agent:cost",
    },
    timeout=30,
)
body = res.json()
if not body.get("ok"):
    print(body["reason"], "held by", body["holder"], "wait", body["stampede"]["waitMs"], "ms")

Libérala antes

Envía el recurso y el agente; release responde released y releasedIds. Una concesión que nunca se libera caduca y una alarma la recupera.

curl -sS -X POST https://api.intramedial.com/api/v1/acp/coordination/release \
  -H "Authorization: Bearer $INTRAMEDIAL_KEY" \
  -H "Content-Type: application/json" \
  -d '{
  "resource": "lock:deploy/production",
  "actorDid": "did:web:acme.example:agent:release"
}'

const res = await fetch("https://api.intramedial.com/api/v1/acp/coordination/release", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.INTRAMEDIAL_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    resource: "lock:deploy/production",
    actorDid: "did:web:acme.example:agent:release",
  }),
});
console.log(res.status, await res.json());

import os, requests

res = requests.post(
    "https://api.intramedial.com/api/v1/acp/coordination/release",
    headers={"Authorization": "Bearer " + os.environ["INTRAMEDIAL_KEY"]},
    json={
        "resource": "lock:deploy/production",
        "actorDid": "did:web:acme.example:agent:release",
    },
    timeout=30,
)
print(res.status_code, res.json())

Los agentes actúan cuando el plano dice sí, y el registro dice por qué.

La tarea

Antes de empezar

Pasos