Function connect

core/http/static/talk.js:255–366

()

}

async function connect() {
  const model = getModel();
  if (!model) {
    alert('Please select a pipeline model first.');
    return;
  }

  if (!navigator.mediaDevices || !navigator.mediaDevices.getUserMedia) {
    setStatus('error', 'Microphone access requires HTTPS or localhost.');
    return;
  }

  setStatus('connecting', 'Connecting...');
  connectButton.style.display = 'none';
  disconnectButton.style.display = '';
  testToneButton.style.display = '';
  diagnosticsButton.style.display = '';

  try {
    // Get microphone access
    localStream = await navigator.mediaDevices.getUserMedia({ audio: true });

    // Create peer connection
    pc = new RTCPeerConnection({});

    // Add local audio track
    for (const track of localStream.getAudioTracks()) {
      pc.addTrack(track, localStream);
    }

    // Handle remote audio track (server's TTS output)
    pc.ontrack = (event) => {
      audioPlayback.srcObject = event.streams[0];
      // If diagnostics panel is open, start analyzing the new stream
      if (diagVisible) startDiagnostics();
    };

    // Create the events data channel (client must create it so m=application
    // is included in the SDP offer — the answerer cannot add new m-lines)
    dc = pc.createDataChannel('oai-events');
    dc.onmessage = (msg) => {
      try {
        const text = typeof msg.data === 'string'
          ? msg.data
          : new TextDecoder().decode(msg.data);
        const event = JSON.parse(text);
        handleServerEvent(event);
      } catch (e) {
        console.error('Failed to parse server event:', e);
      }
    };
    dc.onclose = () => {
      console.log('Data channel closed');
    };

    pc.onconnectionstatechange = () => {
      console.log('Connection state:', pc.connectionState);
      if (pc.connectionState === 'connected') {