Human-in-the-loop: pause, ask, and resume the Assistant

curl -X POST https://api.modulex.dev/assistant/chat/f2b1c0de-1111-2222-3333-444455556666/resume \
  -H "Authorization: Bearer mx_live_your_api_key" \
  -H "X-Organization-ID: org_your_organization_id" \
  -H "Content-Type: application/json" \
  -d '{
    "request_id": "yesno-req-42",
    "response": { "kind": "yes_no", "answer": true },
    "llm": {
      "integration_name": "openai",
      "provider_id": "openai",
      "model_id": "gpt-4o"
    }
  }'

from modulex import Modulex
from modulex.types.realtime import (
    user_input_request_from_event,
    YesNoResponse,
    ComposerLLMConfig,
)

client = Modulex(
    api_key="mx_live_your_api_key",
    organization_id="org_your_organization_id",
)

llm = ComposerLLMConfig(integration_name="openai", provider_id="openai", model_id="gpt-4o")

# Start a turn, then watch for a question.
start = await client.assistant.chat("Send the welcome email to new signups", llm=llm)
chat_id, run_id = start.chat_id, start.run_id

while True:
    paused = None
    async with client.assistant.listen(chat_id, run_id) as stream:
        async for event in stream:
            if event.event == "user_input_request":
                paused = user_input_request_from_event(event.data)  # nested data.data
                break  # stop reading; go answer it
            if event.is_terminal:
                break
    if paused is None:
        break  # the turn finished

    # Answer the question. Resume mints a NEW run_id.
    resumed = await client.assistant.resume(
        chat_id,
        request_id=paused.request_id,
        response=YesNoResponse(answer=True),
        llm=llm,  # required on assistant resume (no default)
    )
    run_id = resumed.run_id  # re-listen on the new run

import { Modulex } from "modulex";

const client = new Modulex({
  apiKey: "mx_live_your_api_key",
  organizationId: "org_your_organization_id",
});

const start = await client.assistant.chat({
  message: "Send the welcome email to new signups",
  llm: { integration_name: "openai", provider_id: "openai", model_id: "gpt-4o" },
});

let chatId = start.chat_id;
let runId = start.run_id;

for (;;) {
  let paused = null;
  for await (const evt of client.assistant.listen(chatId, runId)) {
    if (evt.type === "user_input_request") {
      paused = evt.data; // UserInputRequest; discriminate on paused.kind
      break; // stop reading; go answer it
    }
    if (evt.type === "done" || evt.type === "error") break;
  }
  if (!paused) break; // the turn finished

  // Answer the question. Resume mints a NEW run_id.
  const resumed = await client.assistant.resume(chatId, {
    requestId: paused.request_id,
    response: { kind: "yes_no", answer: true },
    llm: { integration_name: "openai", provider_id: "openai", model_id: "gpt-4o" },
  });
  runId = resumed.run_id; // re-listen on the new run
}