Voice Streaming

import { spawn } from "child_process";

// 1. Get stream token
const resp = await fetch("https://api.argon.gl/api/bot/IVoice/v1/StreamToken", {
  method: "POST",
  headers: {
    "Authorization": "Bot YOUR_TOKEN",
    "Content-Type": "application/json",
  },
  body: JSON.stringify({ spaceId: "...", channelId: "..." }),
});
const { token, ingressUrl } = await resp.json();

// 2. Encode audio to Opus with ffmpeg (stereo, 48kHz)
const ffmpeg = spawn("ffmpeg", [
  "-i", "music.mp3",
  "-f", "opus", "-ar", "48000", "-ac", "2",
  "-frame_duration", "20", "pipe:1",
]);

// 3. Stream to ingress (stereo, 20ms frames)
const wsUrl = `${ingressUrl}?token=${token}&stereo=true&frame_duration_ms=20&track_name=music`;
const ws = new WebSocket(wsUrl);

ws.addEventListener("open", () => {
  ffmpeg.stdout.on("data", (chunk) => {
    ws.send(chunk);
  });
});

ffmpeg.on("close", () => ws.close());

using System.Diagnostics;
using System.Net.Http.Json;
using System.Net.WebSockets;

// 1. Get stream token
using var http = new HttpClient();
http.DefaultRequestHeaders.Add("Authorization", "Bot YOUR_TOKEN");

var resp = await http.PostAsJsonAsync(
    "https://api.argon.gl/api/bot/IVoice/v1/StreamToken",
    new { spaceId = "...", channelId = "..." });
var data = await resp.Content.ReadFromJsonAsync<JsonElement>();
var token = data.GetProperty("token").GetString()!;
var url = data.GetProperty("ingressUrl").GetString()!;

// 2. Encode audio with ffmpeg
var ffmpeg = Process.Start(new ProcessStartInfo {
    FileName = "ffmpeg",
    Arguments = "-i music.mp3 -f opus -ar 48000 -ac 2 -frame_duration 20 pipe:1",
    RedirectStandardOutput = true,
    UseShellExecute = false
})!;

// 3. Stream to ingress
using var ws = new ClientWebSocket();
await ws.ConnectAsync(
    new Uri($"{url}?token={token}&stereo=true&frame_duration_ms=20&track_name=music"),
    CancellationToken.None);

var buf = new byte[960];
int read;
while ((read = await ffmpeg.StandardOutput.BaseStream.ReadAsync(buf)) > 0)
    await ws.SendAsync(buf.AsMemory(0, read), WebSocketMessageType.Binary, true, CancellationToken.None);