Real-Time Events

connection.onreconnecting((error) => {
  console.warn("Connection lost, reconnecting...", error);
});

connection.onreconnected((connectionId) => {
  console.log("Reconnected:", connectionId);
  // Re-join document rooms after reconnect
  connection.invoke("JoinDocument", documentId);
});

connection.onclose((error) => {
  console.error("Connection closed permanently:", error);
  // Implement manual reconnect or fallback to polling
});

import {
  HubConnectionBuilder,
  HubConnection,
  LogLevel,
} from "@microsoft/signalr";

const API_KEY = process.env.TAILOR_API_KEY!;
const DOC_ID = process.env.DOCUMENT_ID!;

async function main() {
  const connection: HubConnection = new HubConnectionBuilder()
    .withUrl("wss://tailor.au/hubs/tap", {
      accessTokenFactory: () => API_KEY,
    })
    .withAutomaticReconnect([0, 2000, 5000, 10000, 30000])
    .configureLogging(LogLevel.Information)
    .build();

  // Proposals
  connection.on("pact.proposal.created", (payload) => {
    console.log("[proposal] new:", payload.data.summary);
  });
  connection.on("pact.proposal.approved", (payload) => {
    console.log("[proposal] approved:", payload.data.proposalId);
  });
  connection.on("pact.proposal.merged", (payload) => {
    console.log("[proposal] merged:", payload.data.proposalId);
  });

  // Agents
  connection.on("pact.agent.joined", (payload) => {
    console.log("[agent] joined:", payload.data.agentName);
  });
  connection.on("pact.agent.left", (payload) => {
    console.log("[agent] left:", payload.data.agentName);
  });

  // Intents & Constraints
  connection.on("pact.intent.declared", (payload) => {
    console.log("[intent]", payload.data.agentId, "→", payload.data.goal);
  });
  connection.on("pact.constraint.published", (payload) => {
    console.log("[constraint]", payload.data.boundary);
  });

  // Escalations
  connection.on("pact.human-query.created", (payload) => {
    console.log("[escalation] question:", payload.data.question);
  });

  // Reconnection
  connection.onreconnecting(() => console.warn("Reconnecting..."));
  connection.onreconnected(() => {
    console.log("Reconnected — re-joining document room");
    connection.invoke("JoinDocument", DOC_ID);
  });

  await connection.start();
  await connection.invoke("JoinDocument", DOC_ID);
  console.log("Listening for events on", DOC_ID);
}

main().catch(console.error);

pip install signalrcore

import os
from signalrcore.hub_connection_builder import HubConnectionBuilder

API_KEY = os.environ["TAILOR_API_KEY"]
DOC_ID = os.environ["DOCUMENT_ID"]

connection = (
    HubConnectionBuilder()
    .with_url(
        "wss://tailor.au/hubs/tap",
        options={"access_token_factory": lambda: API_KEY},
    )
    .with_automatic_reconnect(
        {"type": "raw", "keep_alive_interval": 10, "reconnect_interval": 5}
    )
    .build()
)

def on_proposal(payload):
    print(f"[proposal] {payload['data']['summary']}")

def on_agent_joined(payload):
    print(f"[agent] joined: {payload['data']['agentName']}")

def on_intent(payload):
    print(f"[intent] {payload['data']['agentId']} → {payload['data']['goal']}")

connection.on("pact.proposal.created", on_proposal)
connection.on("pact.agent.joined", on_agent_joined)
connection.on("pact.intent.declared", on_intent)

connection.start()
connection.send("JoinDocument", [DOC_ID])

print(f"Listening for events on {DOC_ID}")
input("Press Enter to disconnect...\n")
connection.stop()