bankr-dev---api-workflow

const status = await fetch(`${API_URL}/agent/job/${jobId}`, {
  headers: { "x-api-key": API_KEY },
});

const cancel = await fetch(`${API_URL}/agent/job/${jobId}/cancel`, {
  method: "POST",
  headers: { "x-api-key": API_KEY, "Content-Type": "application/json" },
});

async function waitForCompletion(
  jobId: string,
  onProgress?: (message: string) => void
): Promise<JobStatusResponse> {
  const POLL_INTERVAL = 2000; // 2 seconds
  const MAX_POLLS = 150;      // 5 minutes max
  let lastUpdateCount = 0;
 
  for (let i = 0; i < MAX_POLLS; i++) {
    const status = await getJobStatus(jobId);
 
    // Report new status updates
    if (onProgress && status.statusUpdates) {
      for (let j = lastUpdateCount; j < status.statusUpdates.length; j++) {
        onProgress(status.statusUpdates[j].message);
      }
      lastUpdateCount = status.statusUpdates.length;
    }
 
    // Terminal states
    if (["completed", "failed", "cancelled"].includes(status.status)) {
      return status;
    }
 
    await new Promise((r) => setTimeout(r, POLL_INTERVAL));
  }
 
  throw new Error("Job timed out");
}

// Start a conversation
const first = await submitPrompt("What is the price of ETH?");
const threadId = first.threadId;
 
// Continue the conversation (agent remembers context)
const second = await submitPrompt("And what about BTC?", threadId);
 
// Each response includes the same threadId

type RichData = {
  type?: string;          // "social-card", "chart", etc.
  [key: string]: unknown;
};

// Handle rate limits
if (response.status === 429) {
  const error = await response.json();
  const waitMs = error.resetAt - Date.now();
  console.log(`Rate limited. Resets in ${Math.ceil(waitMs / 60000)} minutes`);
}

import { submitPrompt, waitForCompletion } from "./bankr-client";
 
async function main() {
  // Submit
  const { jobId } = await submitPrompt("Swap 0.1 ETH for USDC on Base");
  console.log(`Job: ${jobId}`);
 
  // Poll with progress
  const result = await waitForCompletion(jobId, (msg) => {
    console.log(`Progress: ${msg}`);
  });
 
  // Handle result
  if (result.status === "completed") {
    console.log(result.response);
    for (const tx of result.transactions || []) {
      console.log(`Transaction: ${tx.type}`);
    }
  } else if (result.status === "failed") {
    console.error(`Failed: ${result.error}`);
  }
}