Function retoolGetMessage

retool.ts:137–164

(
  acc: RetoolAccount,
  agentId: string,
  runId: string,
  timeoutMs = 300_000,
)

  return data.content.runId as string;
}
async function retoolGetMessage(
  acc: RetoolAccount,
  agentId: string,
  runId: string,
  timeoutMs = 300_000,
) {
  const url = `https://${acc.domain_name}/api/agents/${agentId}/logs/${runId}`;
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const resp = await fetch(url, {
      headers: {
        "x-xsrf-token": acc.x_xsrf_token,
        "Cookie": `accessToken=${acc.accessToken}`,
        "Accept": "application/json",
      },
    });
    if (!resp.ok) throw new Error(`get log failed ${resp.status}`);
    const data = await resp.json();
    if (data.status === "COMPLETED") {
      const trace = data.trace;
      const last = trace[trace.length - 1];
      // deep path: data.data.content
      return last.data.data.content as string;
    }
    await new Promise((r) => setTimeout(r, 1_000));
  }
  throw new Error("timeout waiting for completion");
}

// ----------------------------------------------------------------------------
// Utility logic