120 lines
4.2 KiB
C#
120 lines
4.2 KiB
C#
using System.Diagnostics;
|
|
using System.Net;
|
|
using System.Net.Sockets;
|
|
using TanksServer.GameLogic;
|
|
using TanksServer.Graphics;
|
|
|
|
namespace TanksServer.Interactivity;
|
|
|
|
internal sealed class SendToServicePointDisplay : IFrameConsumer, IDisposable
|
|
{
|
|
private const int ScoresWidth = 12;
|
|
private const int ScoresHeight = 20;
|
|
private const int ScoresPlayerRows = ScoresHeight - 6;
|
|
|
|
private readonly Connection _displayConnection;
|
|
private readonly MapService _mapService;
|
|
private readonly ILogger<SendToServicePointDisplay> _logger;
|
|
private readonly PlayerServer _players;
|
|
private readonly CharGrid _scoresBuffer;
|
|
private readonly TimeSpan _minFrameTime;
|
|
private readonly IOptionsMonitor<HostConfiguration> _options;
|
|
|
|
private DateTime _nextFailLogAfter = DateTime.Now;
|
|
private DateTime _nextFrameAfter = DateTime.Now;
|
|
|
|
public SendToServicePointDisplay(
|
|
PlayerServer players,
|
|
ILogger<SendToServicePointDisplay> logger,
|
|
Connection displayConnection,
|
|
IOptions<HostConfiguration> hostOptions,
|
|
MapService mapService,
|
|
IOptionsMonitor<HostConfiguration> options,
|
|
IOptions<DisplayConfiguration> displayConfig)
|
|
{
|
|
_players = players;
|
|
_logger = logger;
|
|
_displayConnection = displayConnection;
|
|
_mapService = mapService;
|
|
_minFrameTime = TimeSpan.FromMilliseconds(hostOptions.Value.ServicePointDisplayMinFrameTimeMs);
|
|
_options = options;
|
|
|
|
var localIp = GetLocalIPv4(displayConfig.Value).Split('.');
|
|
Debug.Assert(localIp.Length == 4);
|
|
_scoresBuffer = new CharGrid(ScoresWidth, ScoresHeight);
|
|
|
|
_scoresBuffer.SetRow(00, "== TANKS! ==");
|
|
_scoresBuffer.SetRow(01, "-- scores --");
|
|
_scoresBuffer.SetRow(17, "-- join --");
|
|
_scoresBuffer.SetRow(18, $"{localIp[0]}.{localIp[1]}".PadRight(ScoresWidth));
|
|
_scoresBuffer.SetRow(19, $"{localIp[2]}.{localIp[3]}".PadRight(ScoresWidth));
|
|
}
|
|
|
|
public async Task OnFrameDoneAsync(GamePixelGrid gamePixelGrid, Bitmap observerPixels)
|
|
{
|
|
if (!_options.CurrentValue.EnableServicePointDisplay)
|
|
return;
|
|
|
|
if (DateTime.Now < _nextFrameAfter)
|
|
return;
|
|
|
|
_nextFrameAfter = DateTime.Now + _minFrameTime;
|
|
await Task.Yield();
|
|
|
|
RefreshScores();
|
|
|
|
try
|
|
{
|
|
_displayConnection.Send(Command.BitmapLinearWin(0, 0, observerPixels, CompressionCode.Lzma));
|
|
_displayConnection.Send(Command.Cp437Data(MapService.TilesPerRow, 0, _scoresBuffer.ToCp437()));
|
|
}
|
|
catch (SocketException ex)
|
|
{
|
|
if (DateTime.Now > _nextFailLogAfter)
|
|
{
|
|
_logger.LogWarning("could not send data to service point display: {}", ex.Message);
|
|
_nextFailLogAfter = DateTime.Now + TimeSpan.FromSeconds(5);
|
|
}
|
|
}
|
|
}
|
|
|
|
private void RefreshScores()
|
|
{
|
|
var playersToDisplay = _players.Players
|
|
.OrderByDescending(p => p.Scores.Kills)
|
|
.Take(ScoresPlayerRows);
|
|
|
|
ushort row = 2;
|
|
foreach (var p in playersToDisplay)
|
|
{
|
|
var score = p.Scores.Kills.ToString();
|
|
var nameLength = Math.Min(p.Name.Length, ScoresWidth - score.Length - 1);
|
|
|
|
var name = p.Name[..nameLength];
|
|
var spaces = new string(' ', ScoresWidth - score.Length - nameLength);
|
|
|
|
_scoresBuffer.SetRow(row, name + spaces + score);
|
|
row++;
|
|
}
|
|
|
|
for (; row < 16; row++)
|
|
_scoresBuffer.SetRow(row, new string(' ', ScoresWidth));
|
|
|
|
_scoresBuffer.SetRow(16, _mapService.Current.Name[..(Math.Min(ScoresWidth, _mapService.Current.Name.Length) - 1)].PadRight(ScoresWidth));
|
|
}
|
|
|
|
private static string GetLocalIPv4(DisplayConfiguration configuration)
|
|
{
|
|
using var socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, 0);
|
|
socket.Connect(configuration.Hostname, configuration.Port);
|
|
var endPoint = socket.LocalEndPoint as IPEndPoint ?? throw new NotSupportedException();
|
|
return endPoint.Address.ToString();
|
|
}
|
|
|
|
public void Dispose()
|
|
{
|
|
_displayConnection.Dispose();
|
|
_scoresBuffer.Dispose();
|
|
}
|
|
}
|