Upgrade packages.
This commit is contained in:
@@ -11,7 +11,7 @@
|
||||
</PropertyGroup>
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Aiursoft.Scanner" Version="7.0.1" />
|
||||
<PackageReference Include="Aiursoft.WebTools" Version="7.0.13" />
|
||||
<PackageReference Include="Aiursoft.WebTools" Version="7.0.15" />
|
||||
<PackageReference Include="Gera.Chess" Version="1.0.5" />
|
||||
</ItemGroup>
|
||||
</Project>
|
||||
@@ -1,4 +1,4 @@
|
||||
using AiurObserver;
|
||||
using Aiursoft.AiurObserver;
|
||||
using Aiursoft.ChessServer.Data;
|
||||
using Aiursoft.ChessServer.Models;
|
||||
using Aiursoft.WebTools.Services;
|
||||
@@ -35,7 +35,7 @@ public class GamesController : Controller
|
||||
public async Task GetWebSocket([FromRoute] int id)
|
||||
{
|
||||
var pusher = await HttpContext.AcceptWebSocketClient();
|
||||
var subscription = _database.GetOrAddGame(id).Channel.Subscribe(t => pusher.Send(t, HttpContext.RequestAborted));
|
||||
var subscription = _database.GetOrAddGame(id).BoardChannel.Subscribe(t => pusher.Send(t, HttpContext.RequestAborted));
|
||||
try
|
||||
{
|
||||
await pusher.Listen(HttpContext.RequestAborted);
|
||||
@@ -88,7 +88,7 @@ public class GamesController : Controller
|
||||
game.Board.Move(move);
|
||||
}
|
||||
var fen = game.Board.ToFen();
|
||||
await Task.WhenAll(game.Channel.Broadcast(fen));
|
||||
await game.BoardChannel.BroadcastAsync(fen);
|
||||
return Ok(fen);
|
||||
}
|
||||
}
|
||||
@@ -1,4 +1,4 @@
|
||||
using AiurObserver;
|
||||
using Aiursoft.AiurObserver;
|
||||
using Chess;
|
||||
|
||||
namespace Aiursoft.ChessServer.Models;
|
||||
@@ -7,7 +7,7 @@ public class Game
|
||||
{
|
||||
public ChessBoard Board { get; } = new();
|
||||
|
||||
public AsyncObservable<string> Channel { get; } = new();
|
||||
public AsyncObservable<string> BoardChannel { get; } = new();
|
||||
|
||||
public object MovePieceLock { get; } = new();
|
||||
}
|
||||
@@ -23,7 +23,7 @@ public class GameContext
|
||||
{ "websocket", $"games/{id}.ws" },
|
||||
{ "move-post", $"games/{id}/move/{{player}}/{{move_algebraic_notation}}" }
|
||||
};
|
||||
Listeners = game.Channel.GetListenerCount();
|
||||
Listeners = game.BoardChannel.GetListenerCount();
|
||||
}
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user