29 lines
924 B
C#
29 lines
924 B
C#
using System.Net.WebSockets;
|
|
using System.Text.Json;
|
|
using EmbedIO.WebSockets;
|
|
using TorchRemote.Models.Responses;
|
|
using TorchRemote.Plugin.Utils;
|
|
namespace TorchRemote.Plugin.Modules;
|
|
|
|
public class ChatModule : WebSocketModule
|
|
{
|
|
public ChatModule(string urlPath, bool enableConnectionWatchdog) : base(urlPath, enableConnectionWatchdog)
|
|
{
|
|
}
|
|
|
|
public async void SendChatResponse(ChatResponseBase response)
|
|
{
|
|
if (ActiveContexts.Count == 0)
|
|
return;
|
|
|
|
var buffer = JsonSerializer.SerializeToUtf8Bytes(response, Statics.SerializerOptions);
|
|
await Task.WhenAll(ActiveContexts
|
|
.Where(b => b.WebSocket.State is WebSocketState.Open)
|
|
.Select(context => context.WebSocket.SendAsync(buffer, true)));
|
|
}
|
|
|
|
protected override async Task OnMessageReceivedAsync(IWebSocketContext context, byte[] buffer, IWebSocketReceiveResult result)
|
|
{
|
|
}
|
|
}
|