Menghubungkan ke model dan aplikasi

func onConnectionStatusChange(_ status: AoqConnectionStatus) {
    if status == .connected { sendSessionUpdate() }
}

private func sendSessionUpdate() {
    let json = """
    {
      // ID event ini, dihasilkan oleh client
      "event_id": "event_ToPZqeobitzUJnt3QqtWg",
      // Jenis event, tetap sebagai session.update
      "type": "session.update",
      // Konfigurasi sesi
      "session": {
          // Modalitas output. Atur ke ["text"] (hanya teks) atau ["text","audio"] (teks dan audio).
          "modalities": [
              "text",
              "audio"
          ],
          // Voice untuk output audio
          "voice": "Ethan",
          // Format audio input. Hanya pcm yang didukung. Audio input adalah aliran audio PCM dengan laju sampel 16 kHz.
          "input_audio_format": "pcm",
          // Format audio output. Hanya pcm yang didukung. Audio output adalah aliran audio PCM dengan laju sampel 24 kHz.
          "output_audio_format": "pcm",
          // Pesan sistem yang menetapkan tujuan atau peran model.
          "instructions": "Anda adalah agen layanan pelanggan AI di hotel bintang lima. Jawab pertanyaan pelanggan secara akurat dan sopan mengenai tipe kamar, fasilitas, harga, dan kebijakan pemesanan. Selalu tanggapi dengan cara profesional dan membantu, serta jangan pernah memberikan informasi yang tidak diverifikasi atau di luar cakupan layanan hotel.",
          // Apakah akan mengaktifkan deteksi aktivitas suara. Untuk mengaktifkannya, kirim objek konfigurasi; server kemudian secara otomatis mendeteksi kapan ucapan dimulai dan dihentikan.
          // Atur ke null agar client yang menentukan kapan memicu respons model.
          "turn_detection": {
              // Jenis VAD: server_vad atau semantic_vad. semantic_vad direkomendasikan untuk model seri qwen3.5-omni-realtime.
              "type": "semantic_vad",
              // Ambang batas deteksi VAD. Tingkatkan nilainya di lingkungan bising dan turunkan di lingkungan tenang.
              "threshold": 0.5,
              // Durasi diam untuk mendeteksi akhir ucapan. Respons model dipicu setelah durasi ini terlampaui
              "silence_duration_ms": 800
          }
      }
    }
    """
    let msg = AoqDataMsg()
    msg.data = json.data(using: .utf8)!
    engine.send(msg)
}

# pip install aiortc aiohttp certifi
import asyncio, aiohttp, ssl, certifi
from aiortc import RTCPeerConnection, RTCConfiguration, RTCSessionDescription
from aiortc.mediastreams import AudioStreamTrack

API_KEY = "your-api-key"
MODEL = "target-model"
SIGNALING_URL = f"https://{{endpoint}}/api/v1/webrtc/realtime?model={MODEL}"

async def connect():
    pc = RTCPeerConnection(RTCConfiguration(iceServers=[]))

    # Tambahkan track audio agar Offer SDP berisi m=audio (diperlukan oleh server)
    pc.addTrack(AudioStreamTrack())

    # Buat DataChannel untuk memicu negosiasi SDP (nama dapat dikustomisasi; server mendorong event melalui channel bernama "txt")
    pc.createDataChannel("oai-events")

    # Pertukaran SDP: buat Offer dan kirim ke server
    offer = await pc.createOffer()
    await pc.setLocalDescription(offer)

    async with aiohttp.ClientSession() as session:
        async with session.post(
            SIGNALING_URL,
            ssl=ssl.create_default_context(cafile=certifi.where()),
            data=offer.sdp.encode("utf-8"),
            headers={
                "Content-Type": "application/sdp",
                "Authorization": f"Bearer {API_KEY}",
            },
        ) as resp:
            if not resp.ok:
                raise Exception(f"Pertukaran SDP gagal: {resp.status} {await resp.text()}")
            answer_sdp = await resp.text()

    print("=== Offer SDP ===")
    print(offer.sdp)
    print("=== Answer SDP ===")
    print(answer_sdp)

    # Penyiapan koneksi ICE selesai secara otomatis
    await pc.setRemoteDescription(RTCSessionDescription(sdp=answer_sdp, type="answer"))
    print("Koneksi WebRTC berhasil dibangun")
    return pc