Realtime Client

1
import { SignalWire } from "@signalwire/realtime-api";
2
3
const client = await SignalWire({
4
  project: "your-project-id",
5
  token: "your-api-token"
6
});

1
const voiceClient = client.voice;
2
const videoClient = client.video;
3
const chatClient = client.chat;
4
const taskClient = client.task;
5
const pubSubClient = client.pubSub;

1
import { SignalWire } from "@signalwire/realtime-api";
2
3
const client = await SignalWire({
4
  project: "your-project-id",
5
  token: "your-api-token"
6
});
7
8
const voiceClient = client.voice;
9
10
// Listen for incoming calls
11
await voiceClient.listen({
12
  topics: ["office"],
13
  onCallReceived: async (call) => {
14
    console.log("Incoming call from:", call.from);
15
    await call.answer();
16
17
    // Play a greeting
18
    await call.playTTS({ text: "Welcome to our office" });
19
  }
20
});
21
22
// Make an outbound call
23
const call = await voiceClient.dialPhone({
24
  to: "+1234567890",
25
  from: "+0987654321"
26
});

1
import { SignalWire } from "@signalwire/realtime-api";
2
3
const client = await SignalWire({
4
  project: "your-project-id",
5
  token: "your-api-token"
6
});
7
8
const videoClient = client.video;
9
10
// Monitor room events
11
await videoClient.listen({
12
  onRoomStarted: async (roomSession) => {
13
    console.log("Room started:", roomSession.name);
14
15
    await roomSession.listen({
16
      onMemberJoined: (member) => {
17
        console.log("Member joined:", member.name);
18
      }
19
    });
20
  }
21
});
22
23
// Get active room sessions
24
const { roomSessions } = await videoClient.getRoomSessions();

1
import { SignalWire } from "@signalwire/realtime-api";
2
3
const client = await SignalWire({
4
  project: "your-project-id",
5
  token: "your-api-token"
6
});
7
8
const chatClient = client.chat;
9
10
// Listen for messages in conversations
11
await chatClient.listen({
12
  channels: ["general"],
13
  onMessageReceived: (message) => {
14
    console.log(`${message.member.name}: ${message.content}`);
15
  }
16
});
17
18
// Send a chat message
19
await chatClient.publish({
20
  channel: "general",
21
  content: "Hello team!"
22
});

1
import { SignalWire } from "@signalwire/realtime-api";
2
3
const client = await SignalWire({
4
  project: "your-project-id",
5
  token: "your-api-token"
6
});
7
8
const pubSubClient = client.pubSub;
9
10
// Listen for messages
11
await pubSubClient.listen({
12
  channels: ["notifications", "updates"],
13
  onMessageReceived: (message) => {
14
    console.log(`Channel: ${message.channel}`);
15
    console.log(`Content: ${message.content}`);
16
  }
17
});
18
19
// Publish a message
20
await pubSubClient.publish({
21
  channel: "notifications",
22
  content: { alert: "System maintenance in 30 minutes" }
23
});

1
import { SignalWire } from "@signalwire/realtime-api";
2
3
const client = await SignalWire({
4
  project: "your-project-id",
5
  token: "your-api-token"
6
});
7
8
const taskClient = client.task;
9
10
// Listen for incoming tasks
11
await taskClient.listen({
12
  topics: ["workers"],
13
  onTaskReceived: (payload) => {
14
    console.log("Received task:", payload);
15
16
    // Process the task based on payload
17
    if (payload.action === "send_email") {
18
      console.log(`Sending email to ${payload.recipient}: ${payload.subject}`);
19
      // Add your custom email sending logic here
20
    }
21
  }
22
});
23
24
// Send a task to workers
25
await taskClient.send({
26
  topic: "workers",
27
  message: {
28
    action: "send_email",
29
    recipient: "user@example.com",
30
    subject: "Welcome aboard!"
31
  }
32
});