Expose a workflow to chat

# 1. Start the run as a chat turn (ephemeral defaults to false).
curl -X POST https://api.modulex.dev/workflows/run \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 11111111-1111-1111-1111-111111111111" \
  -H "Content-Type: application/json" \
  -d '{
        "workflow_id": "550e8400-e29b-41d4-a716-446655440000",
        "input": { "query": "Summarize Q2 support tickets" },
        "config": { "recursion_limit": 50 }
      }'
# -> {"status":"running","run_id":"6a7b8c9d-...","thread_id":"550e8400-...",
#     "chat_id":"550e8400-...","ephemeral":false, ... }

# 2. Stream the run by run_id (data-only SSE; ends on done/error/cancelled).
curl -N https://api.modulex.dev/workflows/listen/6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 11111111-1111-1111-1111-111111111111"

import asyncio
from modulex import Modulex

async def main():
    async with Modulex(
        api_key="mx_live_xxx",
        organization_id="11111111-1111-1111-1111-111111111111",
    ) as client:
        # 1. Start the run as a chat turn (ephemeral defaults to False).
        run = await client.executions.run(
            workflow_id="550e8400-e29b-41d4-a716-446655440000",
            input={"query": "Summarize Q2 support tickets"},
            config={"recursion_limit": 50},
        )
        print(run.run_id, run.thread_id, run.chat_id)

        # 2. Stream node events until the run finishes.
        async for event in client.executions.listen(run.run_id):
            print(event.event, event.data)

asyncio.run(main())

import { Modulex } from 'modulex-js';

const client = new Modulex({
  apiKey: 'mx_live_xxx',
  organizationId: '11111111-1111-1111-1111-111111111111',
});

// 1. Start the run as a chat turn (ephemeral defaults to false).
const run = await client.executions.run({
  workflowId: '550e8400-e29b-41d4-a716-446655440000',
  input: { query: 'Summarize Q2 support tickets' },
  config: { recursion_limit: 50 },
});
console.log(run.run_id, run.thread_id, run.chat_id);

// 2. Stream node events until the run finishes.
for await (const event of client.executions.listen(run.run_id)) {
  console.log(event.type, event);
}