Cookbook

import {
  client,
  agentExecutePost,
  executionGet,
  executionUserMessagesAdd,
} from 'asteroid-odyssey';

client.setConfig({
  headers: { 'X-Asteroid-Agents-Api-Key': process.env.ASTEROID_API_KEY! },
});

const { data, error } = await agentExecutePost({
  path: { agentId: 'your-agent-id' },
  body: {
    inputs: {
      task: 'Ask the user to confirm before submitting the final form',
    },
  },
});
if (error) throw new Error(JSON.stringify(error));
const executionId = data.executionId;

// Wait for the agent to pause for input
let exec;
do {
  await new Promise((r) => setTimeout(r, 3000));
  const res = await executionGet({ path: { executionId } });
  exec = res.data;
} while (exec?.status === 'running' || exec?.status === 'starting');

if (exec?.status === 'paused_by_agent') {
  await executionUserMessagesAdd({
    path: { executionId },
    body: { message: 'Confirmed. Please continue.' },
  });
}

// Continue polling until terminal state
do {
  await new Promise((r) => setTimeout(r, 3000));
  const res = await executionGet({ path: { executionId } });
  exec = res.data;
} while (exec?.status === 'running' || exec?.status === 'paused_by_agent');

console.log(exec?.status);

import {
  client,
  agentExecutePost,
  tempFilesStage,
  executionContextFilesUpload,
  executionContextFilesGet,
} from 'asteroid-odyssey';
import { readFileSync, writeFileSync } from 'node:fs';

client.setConfig({
  headers: { 'X-Asteroid-Agents-Api-Key': process.env.ASTEROID_API_KEY! },
});

const invoiceBytes = readFileSync('./invoice.pdf');
const invoice = new File([invoiceBytes], 'invoice.pdf', { type: 'application/pdf' });

const { data: staged } = await tempFilesStage({
  path: { organizationId: 'your-org-id' },
  body: { files: [invoice] },
});

const { data, error } = await agentExecutePost({
  path: { agentId: 'your-agent-id' },
  body: {
    inputs: {
      task: 'Read the attached invoice and summarize it',
    },
    tempFiles: staged?.tempFiles,
  },
});
if (error) throw new Error(JSON.stringify(error));
const executionId = data.executionId;

await executionContextFilesUpload({
  path: { executionId },
  body: { files: [invoice] },
});

const { data: files } = await executionContextFilesGet({
  path: { executionId },
});
for (const file of files ?? []) {
  const response = await fetch(file.downloadUrl, {
    headers: { 'X-Asteroid-Agents-Api-Key': process.env.ASTEROID_API_KEY! },
  });
  if (!response.ok) throw new Error(`Download failed: ${response.status}`);
  writeFileSync(`./downloads/${file.fileName}`, Buffer.from(await response.arrayBuffer()));
}