1
import { MeshAPI, RealtimeError } from "meshapi-node-sdk";
2
3
const client = new MeshAPI({ baseUrl: "https://api.meshapi.ai", token: "rsk_..." });
4
5
const session = await client.realtime.connect({ model: "openai/gpt-realtime-mini" });

1
await session.send({
2
  type: "session.update",
3
  session: {
4
    type:         "realtime",
5
    modalities:   ["audio", "text"],
6
    voice:        "alloy",
7
    instructions: "You are a helpful assistant.",
8
  },
9
});

1
// pcmBytes is a Uint8Array of raw 16-bit PCM at 24 kHz mono
2
await session.sendAudio(pcmBytes);

1
try {
2
  for await (const msg of session) {
3
    if (msg.audio) {
4
      playAudio(msg.audio);           // Uint8Array
5
    } else if (msg.event) {
6
      const type = msg.event.type as string;
7
      if (type === "response.text.delta") {
8
        process.stdout.write(msg.event.delta as string);
9
      } else if (type === "response.done") {
10
        break;
11
      }
12
    }
13
  }
14
} finally {
15
  await session.close();
16
}

1
session
2
  .on("message", (msg) => {
3
    if (msg.audio) playAudio(msg.audio);
4
    else if (msg.event?.type === "response.text.delta") {
5
      process.stdout.write(msg.event.delta as string);
6
    }
7
  })
8
  .on("error", (err) => console.error("error:", err))
9
  .on("close", (code, reason) => console.log("closed", code, reason));

1
await session.close();

1
try {
2
  for await (const msg of session) { ... }
3
} catch (err) {
4
  if (err instanceof RealtimeError) {
5
    console.error("code:", err.code);     // "invalid_api_key", "insufficient_quota", …
6
    console.error("message:", err.message);
7
  }
8
}

1
const session = await client.realtime.connect({ model: "openai/gpt-realtime-mini" });
2
3
await session.send({
4
  type: "session.update",
5
  session: { type: "realtime", modalities: ["audio"], voice: "alloy" },
6
});
7
8
// Stream microphone audio
9
(async () => {
10
  for await (const chunk of micStream) {
11
    await session.sendAudio(chunk);
12
  }
13
  await session.send({ type: "input_audio_buffer.commit" });
14
  await session.send({ type: "response.create" });
15
})();
16
17
// Play response audio
18
for await (const msg of session) {
19
  if (msg.audio) speaker.write(msg.audio);
20
}
21
await session.close();