SimpleWebChat/SimpleWebChat.BlazorWasm/UI/VoiceMeeting.razor

@using System.Text
@using System.Net.WebSockets
@inject HttpClient http
@code {
    private bool ready = false;

    private List<string> logs = new();
    private ClientWebSocket sck;
}

<div class="container">
    <h2>Simple Web Chat(Voice meeting)</h2>

    @if (!ready)
    {

        <div class="row m-2">
            <div class="col-12">
                <button @onclick="@Init" class="btn btn-primary">Open Microphone and Connect</button>
            </div>
        </div>
    }
    else
    {
        <div class="row">
            <div class="col-12">
                @foreach (var s in logs)
                {
                    <div>
                        <pre>@s</pre>
                    </div>
                }
            </div>
        </div>
    }
</div>

@code {
    private WebSocket socket;

    private async Task Init()
    {
        ready = await AudioCaptureModule.Init();
        if (ready)
        {
            AudioCaptureModule.ChunkArrive += SendChunk;
            await Go();
        }
    }

    private void SendChunk(byte[] obj)
    {
        socket?.SendAsync(obj, WebSocketMessageType.Binary, true, default);
    }

    private async Task Go()
    {
        if (socket != null)
        {
            try
            {
                await socket.CloseAsync(WebSocketCloseStatus.Empty, "Brrrrrr", default);
            }
            catch
            {
                //FUCK ERR
            }

            try
            {
                socket.Dispose();
            }
            catch
            {
                //FUCK ERR
            }

            logs.Insert(0, "Disconnected");
            StateHasChanged();
            socket = null;
        }

        sck = new ClientWebSocket();
        sck.Options.AddSubProtocol("svmp");

        var b = http.BaseAddress;
        try
        {
            await sck.ConnectAsync(new Uri($"{(b.Scheme == "https" ? "wss" : "ws")}://{b.Host}:{b.Port}/connect/voice/meeting"), default);
            logs.Insert(0, "Connected");
            StateHasChanged();

            socket = sck;
            await AudioCaptureModule.Start();
            while (true)
            {
                var buf = new Byte[15384];
                var r = await sck.ReceiveAsync(buf, default);
                if (r.Count == 0)
                {
                    logs.Insert(0, "Disconnected");
                    StateHasChanged();
                    break;
                }
                if (r.MessageType == WebSocketMessageType.Text)
                {
                    logs.Insert(0, Encoding.UTF8.GetString(buf, 0, r.Count));
                    StateHasChanged();
                }
                else
                {
                    var chunk = new byte[r.Count];
                    Array.Copy(buf, 0, chunk, 0, chunk.Length);
                    await AudioPlaybackModule.PlayChunk(chunk);
                }
            }
        }
        catch (Exception e)
        {
            logs.Insert(0, e.ToString());
            StateHasChanged();
        }

    }
}