Developer platform and agent infrastructure.

import { CommunicationOS } from "@communicationos/sdk";

const cos = new CommunicationOS({ apiKey: process.env.COS_API_KEY });

// One stream. Every network.
for await (const event of cos.events.stream({ types: ["message.received"] })) {
  const thread = await cos.threads.get(event.threadId);

  if (thread.classification === "noise") continue;

  const draft = await cos.ai.draft({
    threadId: thread.id,
    persona: "adam",
  });

  await cos.messages.send({
    threadId: thread.id,
    body: draft.text,
    channel: thread.preferredChannel,
  });
}

from communicationos import Client

cos = Client(api_key=os.environ["COS_API_KEY"])

# One stream. Every network.
for event in cos.events.stream(types=["message.received"]):
    thread = cos.threads.get(event.thread_id)

    if thread.classification == "noise":
        continue

    draft = cos.ai.draft(thread_id=thread.id, persona="adam")

    cos.messages.send(
        thread_id=thread.id,
        body=draft.text,
        channel=thread.preferred_channel,
    )

import CommunicationOS

let cos = Client(apiKey: Secrets.communicationOS)

// One stream. Every network.
for try await event in cos.events.stream(types: [.messageReceived]) {
    let thread = try await cos.threads.get(event.threadID)

    guard thread.classification != .noise else { continue }

    let draft = try await cos.ai.draft(threadID: thread.id, persona: "adam")

    try await cos.messages.send(
        threadID: thread.id,
        body: draft.text,
        channel: thread.preferredChannel
    )
}

curl https://api.communicationos.com/v1/threads/search \
  -H "Authorization: Bearer $COS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "query": "rotterdam shipment window",
    "channels": ["whatsapp", "telegram", "signal", "email"],
    "since": "2016-01-01",
    "include": ["attachments", "voice_transcripts"]
  }'