1
from meshapi import MeshAPI
2
3
client = MeshAPI(base_url="https://api.meshapi.ai", token="rsk_...")
4
5
with client.realtime.connect(model="openai/gpt-realtime-2") as session:
6
    pass  # clean close on exit

1
from meshapi import AsyncMeshAPI
2
3
async with AsyncMeshAPI(base_url="https://api.meshapi.ai", token="rsk_...") as client:
4
    async with client.realtime.connect(model="openai/gpt-realtime-2") as session:
5
        pass

1
session.send({
2
    "type": "session.update",
3
    "session": {
4
        "type": "realtime",
5
        "output_modalities": ["audio"],          # or ["text"]
6
        "instructions": "You are a helpful assistant.",
7
        "audio": {
8
            "input": {"format": {"type": "audio/pcm", "rate": 24000}},
9
            "output": {"format": {"type": "audio/pcm", "rate": 24000}, "voice": "alloy"},
10
        },
11
    },
12
})

1
# pcm_bytes is raw 16-bit PCM at 24 kHz mono
2
session.send_audio(pcm_bytes)

1
from meshapi.resources.realtime import RealtimeError
2
3
msg = session.receive()
4
5
if msg.audio:
6
    play_audio(msg.audio)
7
elif msg.event:
8
    print("event type:", msg.event.get("type"))

1
with client.realtime.connect(model="openai/gpt-realtime-2") as session:
2
    session.send({"type": "session.update", "session": {"type": "realtime", "output_modalities": ["text"]}})
3
    session.send({"type": "response.create"})
4
5
    for msg in session:           # iterates until connection closes
6
        if msg.event:
7
            t = msg.event.get("type")
8
            if t == "response.output_text.delta":
9
                print(msg.event.get("delta"), end="", flush=True)
10
            elif t == "response.done":
11
                break

1
async with client.realtime.connect(model="openai/gpt-realtime-2") as session:
2
    await session.send({"type": "session.update", "session": {"type": "realtime", "output_modalities": ["text"]}})
3
    await session.send({"type": "response.create"})
4
5
    async for msg in session:
6
        if msg.event and msg.event.get("type") == "response.output_text.delta":
7
            print(msg.event.get("delta"), end="", flush=True)

1
from meshapi.resources.realtime import RealtimeError
2
3
try:
4
    msg = session.receive()
5
except RealtimeError as e:
6
    print("code:", e.code)       # "invalid_api_key", "insufficient_quota", …
7
    print("message:", str(e))

1
import threading
2
3
with client.realtime.connect(model="openai/gpt-realtime-2") as session:
4
    session.send({
5
        "type": "session.update",
6
        "session": {"type": "realtime", "output_modalities": ["audio"],
7
                     "audio": {"output": {"format": {"type": "audio/pcm", "rate": 24000}, "voice": "alloy"}}},
8
    })
9
10
    def send_audio():
11
        for chunk in mic_stream():
12
            session.send_audio(chunk)
13
        session.send({"type": "input_audio_buffer.commit"})
14
        session.send({"type": "response.create"})
15
16
    threading.Thread(target=send_audio, daemon=True).start()
17
18
    for msg in session:
19
        if msg.audio:
20
            speaker.write(msg.audio)