Inspect and wait for executions

import { Eyeball, type ExecutionSource } from "@eyeball/sdk";

const eyeball = new Eyeball({
  apiKey: process.env.EYEBALL_API_KEY!,
  baseUrl: process.env.EYEBALL_EXECUTOR_URL!,
});
const execution = await eyeball.executions.get("exe_01JZ6WA0Q73ZQ5B51SRYB6M4Z8");
console.log(execution.status);

if (execution.replayed === true) {
  console.log("An accepted replay reused this execution ID");
}

const sourceHandlers = {
  voice_session(source: Extract<ExecutionSource, { kind: "voice_session" }>) {
    console.log("Voice session", source.sessionId);
  },
} satisfies {
  [Kind in ExecutionSource["kind"]]: (
    source: Extract<ExecutionSource, { kind: Kind }>,
  ) => void;
};

if (execution.source) sourceHandlers[execution.source.kind](execution.source);

for (const fileId of execution.attachments?.fileIds ?? []) {
  console.log("Historical staged file", fileId);
}

import { Eyeball } from "@eyeball/sdk";

const eyeball = new Eyeball({
  apiKey: process.env.EYEBALL_API_KEY!,
  baseUrl: process.env.EYEBALL_EXECUTOR_URL!,
});
const page = await eyeball.executions.list({
  status: "failed",
  tool: "gmail.send_email",
  userId: "demo_user",
  limit: 25,
});
console.log(page.executions, page.nextCursor);

import { Eyeball } from "@eyeball/sdk";

const eyeball = new Eyeball({
  apiKey: process.env.EYEBALL_API_KEY!,
  baseUrl: process.env.EYEBALL_EXECUTOR_URL!,
});
const cancelled = await eyeball.executions.cancel(
  "exe_01JZ6WA0Q73ZQ5B51SRYB6M4Z8",
);

if (cancelled.cancellation.dispatchMayHaveBegun) {
  console.warn("Upstream work or external side effects may still complete.");
}

import { Eyeball } from "@eyeball/sdk";

const eyeball = new Eyeball({
  apiKey: process.env.EYEBALL_API_KEY!,
  baseUrl: process.env.EYEBALL_EXECUTOR_URL!,
});
const terminal = await eyeball.executions.wait(
  "exe_01JZ6WA0Q73ZQ5B51SRYB6M4Z8",
  { pollMs: 500, timeoutMs: 60_000 },
);
console.log(terminal.status);