start of socket
This commit is contained in:
@@ -1,4 +1,8 @@
|
||||
using System.Text.Json;
|
||||
using System;
|
||||
using WebSocketSharp.Server;
|
||||
using WebSocketSharp;
|
||||
|
||||
using RelayServer.Models;
|
||||
using RelayServer.Services;
|
||||
|
||||
@@ -8,6 +12,12 @@ var cryptoService = new ChannelCryptoService();
|
||||
|
||||
await using var db = await surrealService.ConnectAsync();
|
||||
|
||||
var wssv = new WebSocketServer("ws://localhost:1337");
|
||||
wssv.AddWebSocketService<ChatTest>("/");
|
||||
wssv.Start();
|
||||
Console.ReadKey(true);
|
||||
wssv.Stop();
|
||||
|
||||
var keeper = await coreClient.GetUserByUsernameAsync("Keeper317");
|
||||
var kira = await coreClient.GetUserByUsernameAsync("Ru_Kira");
|
||||
|
||||
@@ -150,3 +160,13 @@ static string GetRecordId(object? id)
|
||||
|
||||
return $"{table}:{recordId}";
|
||||
}
|
||||
|
||||
public class ChatTest : WebSocketBehavior
|
||||
{
|
||||
protected override void OnMessage(MessageEventArgs e)
|
||||
{
|
||||
var msg = e.Data == "PING" ? "PONG" : "SERVER";
|
||||
Console.WriteLine(msg);
|
||||
Send(msg);
|
||||
}
|
||||
}
|
||||
@@ -9,6 +9,7 @@
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="SurrealDb.Net" Version="0.9.0" />
|
||||
<PackageReference Include="WebSocketSharp" Version="1.0.3-rc11" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
|
||||
Reference in New Issue
Block a user