rust-soham/golem-claw/golem-wait-for-external-input-ts

import { createPromise, awaitPromise, completePromise } from '@golemcloud/golem-ts-sdk';
import type { PromiseId } from '@golemcloud/golem-ts-sdk';

const promiseId = createPromise();
// Pass promiseId to an external system...
// Agent is durably suspended here until the promise is completed
const resultBytes = await awaitPromise(promiseId);
const result = new TextDecoder().decode(resultBytes);

const data = new TextEncoder().encode(JSON.stringify({ status: "approved" }));
completePromise(promiseId, data);

const promiseId = createPromise();
const bytes = await awaitPromise(promiseId);
const decision = JSON.parse(new TextDecoder().decode(bytes));

POST /v1/components/{component_id}/workers/{agent_name}/complete
Content-Type: application/json
 
{"oplogIdx": <oplog_idx>, "data": [<bytes>]}

import { BaseAgent, agent, endpoint } from '@golemcloud/golem-ts-sdk';
import { createPromise, awaitPromise, completePromise } from '@golemcloud/golem-ts-sdk';
import type { PromiseId } from '@golemcloud/golem-ts-sdk';
@agent({ mount: "/workflows/{name}" })
class WorkflowAgent extends BaseAgent {
    private readonly name: string;
    constructor(name: string) {
        super();
        this.name = name;
    }
    @endpoint({ post: "/approve" })
    async startApproval(): Promise<string> {
        // 1. Create a promise
        const promiseId = createPromise();
        // 2. Pass promiseId.oplogIdx to an external system
        // The agent is now durably suspended.
        // 3. Wait for external completion
        const bytes = await awaitPromise(promiseId);
        const decision = JSON.parse(new TextDecoder().decode(bytes));
        if (decision.status === "approved") {
            return `Workflow ${this.name} approved ✅`;
        } else {
            return `Workflow ${this.name} rejected ❌`;
        }
    }
}