拿到 key 后，按文档直接调。

推荐的商用放量顺序：
1. 先确认仓库侧或候选版本已通过 build / smoke / scene readiness / quality:commercial
2. 再用开发者页联调台验证当前租户 realtime 主链路是否稳定出 partial / final
3. 再看 health score、弱音频诊断、死信和失败回调是否处于健康区间
4. 满足验收线后，把当前版本作为稳定版放量
5. 新版本先作为 candidate 观察，不要直接替换稳定版
6. 如果出现回归，优先切回 rollback target，而不是临时修改协议或前端发包方式

<script src="https://omnimodal.shenliu.cc/assets/omnimodal-realtime-sdk.js"></script>
<script>
  const client = new OmniModalRealtime.OmniModalRealtimeClient({
    apiOrigin: "https://omnimodal.shenliu.cc",
    apiKey: "YOUR_KEY",
    tenantId: "YOUR_TENANT_ID",
  });

  const recorder = new OmniModalRealtime.OmniModalPcm16Recorder({
    targetSampleRate: 16000,
    chunkDurationMs: 100,
  });

  const autoCommit = new OmniModalRealtime.OmniModalAutoCommitController(
    OmniModalRealtime.getRecommendedAutoCommitProfileConfig("short_query"),
  );

  recorder.addEventListener("chunk", (event) => {
    const { pcm16Bytes, stats } = event.detail;
    client.sendPcm16Chunk(pcm16Bytes);
    autoCommit.observeChunk(stats);
    console.log("chunk", stats.sampleCount, stats.rms, stats.peakAbs);
  });

  autoCommit.addEventListener("autocommit", async () => {
    await recorder.stop();
    client.commit();
  });

  client.addEventListener("ack", (event) => {
    console.log("acked to", event.detail.lastAckedSequenceNo);
  });

  client.addEventListener("final", (event) => {
    console.log("final", event.detail.text);
  });

  async function startTalking() {
    await client.startSession();
    await client.connect();
    await recorder.start();
  }

  async function stopTalking() {
    await recorder.stop();
    client.commit();
  }
</script>

<script>
const API_BASE = "https://omnimodal.shenliu.cc/api";
const API_KEY = "YOUR_KEY";

let socket;
let mediaStream;
let audioContext;
let sourceNode;
let workletNode;
let chunkBuffer = [];
let chunkSampleCount = 0;
let chunkCount = 0;
let startedAt = 0;

function floatToPcm16(samples) {
  const pcm = new Int16Array(samples.length);
  for (let i = 0; i < samples.length; i += 1) {
    const s = Math.max(-1, Math.min(1, samples[i]));
    pcm[i] = s < 0 ? s * 0x8000 : s * 0x7fff;
  }
  return pcm;
}

function downsampleTo16k(samples, sourceRate) {
  if (sourceRate === 16000) return samples;
  const ratio = sourceRate / 16000;
  const out = new Float32Array(Math.floor(samples.length / ratio));
  for (let i = 0; i < out.length; i += 1) {
    const start = Math.floor(i * ratio);
    const end = Math.min(Math.floor((i + 1) * ratio), samples.length);
    let sum = 0;
    let count = 0;
    for (let j = start; j < end; j += 1) {
      sum += samples[j];
      count += 1;
    }
    out[i] = count ? sum / count : 0;
  }
  return out;
}

function base64FromInt16(int16) {
  const bytes = new Uint8Array(int16.buffer);
  let binary = "";
  const batchSize = 0x8000;
  for (let i = 0; i < bytes.length; i += batchSize) {
    binary += String.fromCharCode(...bytes.subarray(i, i + batchSize));
  }
  return btoa(binary);
}

async function createRealtimeSession() {
  const response = await fetch(API_BASE + "/v1/realtime/sessions", {
    method: "POST",
    headers: {
      "content-type": "application/json",
      "x-omnimodal-api-key": API_KEY,
    },
    body: JSON.stringify({
      tenantId: "YOUR_TENANT_ID",
      scene: "assistant",
      intent: "voice_query",
      mode: "voice",
      audioConfig: {
        codec: "pcm16",
        sampleRate: 16000,
        channelCount: 1,
      },
      tuning: {
        profile: "short_query",
      },
    }),
  });
  const payload = await response.json();
  return payload.data;
}

function sendVoiceChunk(force = false) {
  if (!socket || socket.readyState !== WebSocket.OPEN) return;
  if (!force && chunkSampleCount < 1600) return; // 约 100ms
  if (chunkSampleCount === 0) return;

  const merged = new Float32Array(chunkSampleCount);
  let offset = 0;
  for (const chunk of chunkBuffer) {
    merged.set(chunk, offset);
    offset += chunk.length;
  }

  chunkBuffer = [];
  chunkSampleCount = 0;
  chunkCount += 1;

  const pcm16 = floatToPcm16(merged);
  const audioBase64 = base64FromInt16(pcm16);

  socket.send(JSON.stringify({
    type: "audio.append",
    seq: chunkCount,
    sequenceNo: chunkCount,
    audioBase64,
  }));
}

async function startTalking() {
  const session = await createRealtimeSession();
  const wsUrl = new URL("api" + session.wsUrl, window.location.origin);
  wsUrl.protocol = location.protocol === "https:" ? "wss:" : "ws:";
  socket = new WebSocket(wsUrl);

  socket.addEventListener("message", (event) => {
    const message = JSON.parse(event.data);
    if (message.type === "transcript.partial") console.log("partial", message.text);
    if (message.type === "transcript.final") console.log("final", message.text);
  });

  await new Promise((resolve, reject) => {
    socket.addEventListener("open", resolve, { once: true });
    socket.addEventListener("error", () => reject(new Error("ws connect failed")), { once: true });
  });

  startedAt = Date.now();
  chunkBuffer = [];
  chunkSampleCount = 0;
  chunkCount = 0;

  mediaStream = await navigator.mediaDevices.getUserMedia({
    audio: {
      channelCount: 1,
      echoCancellation: true,
      noiseSuppression: true,
      autoGainControl: true,
    },
  });

  audioContext = new AudioContext();
  sourceNode = audioContext.createMediaStreamSource(mediaStream);

  const processorCode = `
    class OmniModalPcmProcessor extends AudioWorkletProcessor {
      process(inputs) {
        const channel = inputs[0]?.[0];
        if (channel?.length) this.port.postMessage(channel.slice(0));
        return true;
      }
    }
    registerProcessor("omnimodal-pcm-processor", OmniModalPcmProcessor);
  `;
  const blob = new Blob([processorCode], { type: "text/javascript" });
  const url = URL.createObjectURL(blob);
  await audioContext.audioWorklet.addModule(url);
  URL.revokeObjectURL(url);

  workletNode = new AudioWorkletNode(audioContext, "omnimodal-pcm-processor");
  workletNode.port.onmessage = (event) => {
    const downsampled = downsampleTo16k(event.data, audioContext.sampleRate);
    chunkBuffer.push(downsampled);
    chunkSampleCount += downsampled.length;
    sendVoiceChunk(false);
  };

  sourceNode.connect(workletNode);
  workletNode.connect(audioContext.destination);
}

async function stopTalking() {
  sendVoiceChunk(true);
  workletNode?.disconnect();
  sourceNode?.disconnect();
  await audioContext?.close();
  mediaStream?.getTracks().forEach((track) => track.stop());

  if (socket?.readyState === WebSocket.OPEN) {
    socket.send(JSON.stringify({
      type: "audio.commit",
      sequenceNo: Math.max(chunkCount, 1),
      durationMs: Math.max(0, Date.now() - startedAt),
    }));
    setTimeout(() => {
      if (socket?.readyState === WebSocket.OPEN) {
        socket.send(JSON.stringify({ type: "session.close" }));
      }
    }, 1200);
  }
}
</script>

curl -X POST https://omnimodal.shenliu.cc/api/v1/realtime/sessions \
  -H 'content-type: application/json' \
  -H 'x-omnimodal-api-key: YOUR_KEY' \
  -d '{
    "tenantId": "YOUR_TENANT_ID",
    "scene": "assistant",
    "intent": "voice_query",
    "mode": "voice",
    "audioConfig": {
      "codec": "pcm16",
      "sampleRate": 16000,
      "channelCount": 1
    },
    "businessContext": {
      "sourceSystem": "ziin",
      "industryCode": "logistics"
    }
  }'

curl -X PUT https://omnimodal.shenliu.cc/api/v1/tenants/YOUR_TENANT_ID/lexicons \
  -H 'content-type: application/json' \
  -H 'x-omnimodal-api-key: YOUR_KEY' \
  -d '{
    "industryCode": "logistics",
    "name": "物流高频词补丁",
    "description": "补充我们真实业务里的高频词",
    "priority": 70,
    "terms": [
      {
        "canonical": "签收回单",
        "aliases": ["签售回单", "签收回到"],
        "category": "document",
        "weight": 95,
        "source": "manual",
        "status": "active"
      }
    ]
  }'

curl -X POST https://omnimodal.shenliu.cc/api/v1/tenants/YOUR_TENANT_ID/transcript-feedback \
  -H 'content-type: application/json' \
  -H 'x-omnimodal-api-key: YOUR_KEY' \
  -d '{
    "sessionId": "rtsess_xxx",
    "utteranceId": "utt_xxx",
    "industryCode": "logistics",
    "sourceSystem": "ziin",
    "originalText": "签售回单怎么查询",
    "correctedText": "签收回单怎么查询",
    "note": "业务员口音导致误识别"
  }'

curl -H 'x-omnimodal-api-key: YOUR_KEY' \
  'https://omnimodal.shenliu.cc/api/v1/tenants/YOUR_TENANT_ID/transcript-feedback?industryCode=logistics&limit=20'