Quickstart: text agent

import { randomUUID } from "node:crypto";
import { TalqingClient } from "@talqing/sdk";

const token = process.env.TALQING_API_KEY;
if (!token) throw new Error("TALQING_API_KEY is required");

const talqing = new TalqingClient({
  baseUrl: "https://api.in.talqing.com",
  token,
});

const CONTACT_KEY = "user-42";

// 1. Create the agent. Every write sends the whole config, never a patch.
const agent = await talqing.agents.create({
  createAgentRequest: {
    config: {
      name: "Northwind support",
      channel: "text",
      prompt: [
        "You are the support assistant for Northwind Tools, an online hardware store.",
        "Answer questions about orders, delivery and returns.",
        "Ask for the order number before you discuss a specific order.",
        "If you do not know something, say so plainly instead of guessing.",
        "Keep replies to two or three sentences.",
      ].join(" "),
      llm: { provider: "openai", model: "gpt-5.6-luna" },
    },
  },
});

// 2. Publish it. Nothing can talk to a draft.
await talqing.agents.publish({ agent_id: agent.id });

// 3. Open the thread. `contact_key` is your own id for the person.
const conversation = await talqing.conversations.create({
  createTextConversationRequest: { contact_key: CONTACT_KEY, agent_id: agent.id },
});

// 4. Say something. This returns as soon as the message is accepted.
const sent = await talqing.conversations.messages.create({
  textMessageRequest: {
    contact_key: CONTACT_KEY,
    client_message_id: randomUUID(),
    message: "My order 10432 never arrived. What happens now?",
  },
});

// 5. Poll for the reply. The agent answers asynchronously.
const deadline = Date.now() + 30_000;
let reply;
while (!reply && Date.now() < deadline) {
  await new Promise((resolve) => setTimeout(resolve, 1000));
  const page = await talqing.conversations.items.list({
    conversation_id: conversation.id,
    order: "desc",
    limit: 20,
  });
  reply = page.items.find(
    (item) =>
      item.trigger_item_id === sent.item.id &&
      item.type === "message" &&
      item.direction === "outbound",
  );
}

if (!reply) throw new Error("the agent did not reply within 30 seconds");
console.log(reply.text);

import os
import time
from uuid import uuid4

from talqing import Talqing

CONTACT_KEY = "user-42"

with Talqing(
    token=os.environ["TALQING_API_KEY"],
    base_url="https://api.in.talqing.com",
) as talqing:
    # 1. Create the agent. Every write sends the whole config, never a patch.
    agent = talqing.agents.create(
        config={
            "name": "Northwind support",
            "channel": "text",
            "prompt": (
                "You are the support assistant for Northwind Tools, an online hardware store. "
                "Answer questions about orders, delivery and returns. "
                "Ask for the order number before you discuss a specific order. "
                "If you do not know something, say so plainly instead of guessing. "
                "Keep replies to two or three sentences."
            ),
            "llm": {"provider": "openai", "model": "gpt-5.6-luna"},
        }
    )

    # 2. Publish it. Nothing can talk to a draft.
    talqing.agents.publish(agent["id"])

    # 3. Open the thread. `contact_key` is your own id for the person.
    conversation = talqing.conversations.create(
        contact_key=CONTACT_KEY, agent_id=agent["id"]
    )

    # 4. Say something. This returns as soon as the message is accepted.
    sent = talqing.conversations.messages.create(
        contact_key=CONTACT_KEY,
        client_message_id=str(uuid4()),
        message="My order 10432 never arrived. What happens now?",
    )

    # 5. Poll for the reply. The agent answers asynchronously.
    reply = None
    deadline = time.monotonic() + 30
    while reply is None and time.monotonic() < deadline:
        time.sleep(1)
        page = talqing.conversations.items.list(
            conversation["id"], order="desc", limit=20
        )
        reply = next(
            (
                item
                for item in page["items"]
                if item["trigger_item_id"] == sent["item"]["id"]
                and item["type"] == "message"
                and item["direction"] == "outbound"
            ),
            None,
        )

    if reply is None:
        raise RuntimeError("the agent did not reply within 30 seconds")
    print(reply["text"])

curl -N "https://api.in.talqing.com/v1/conversations/$CONVERSATION_ID/events" \
  -H "Authorization: Bearer $TALQING_API_KEY" \
  -H "Accept: text/event-stream"

const { stream } = await talqing.conversations.events({
  conversation_id: conversation.id,
});

await talqing.conversations.messages.create({
  textMessageRequest: {
    contact_key: CONTACT_KEY,
    client_message_id: randomUUID(),
    message: "And how long do returns usually take?",
  },
});

for await (const event of stream) {
  if (event.event === "assistant.delta") process.stdout.write(event.text);
  if (event.event === "assistant.completed") break;
}

with talqing.conversations.events(conversation["id"]) as events:
    talqing.conversations.messages.create(
        contact_key=CONTACT_KEY,
        client_message_id=str(uuid4()),
        message="And how long do returns usually take?",
    )

    for event in events:
        if event["event"] == "assistant.delta":
            print(event["text"], end="", flush=True)
        if event["event"] == "assistant.completed":
            break