70 lines
2.1 KiB
C#
70 lines
2.1 KiB
C#
// Licensed to Timothy Schenk under the GNU AGPL Version 3 License.
|
|
|
|
using System.Net;
|
|
using System.Net.Sockets;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using Microsoft.Extensions.Hosting;
|
|
using Microsoft.Extensions.Logging;
|
|
using NetCoreServer;
|
|
|
|
namespace Continuity.AuthServer.Services;
|
|
|
|
public class WonderkingAuthServer : TcpServer, IHostedService {
|
|
private readonly ILogger<WonderkingAuthServer> _logger;
|
|
private readonly IServiceProvider _serviceProvider;
|
|
|
|
public WonderkingAuthServer(IPAddress address, int port, ILogger<WonderkingAuthServer> logger,
|
|
IServiceProvider serviceProvider) : base(address, port) {
|
|
_logger = logger;
|
|
_serviceProvider = serviceProvider;
|
|
}
|
|
|
|
public Task StartAsync(CancellationToken cancellationToken) {
|
|
Start();
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
public Task StopAsync(CancellationToken cancellationToken) {
|
|
DisconnectAll();
|
|
Stop();
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
protected override TcpSession CreateSession() {
|
|
return ActivatorUtilities.CreateInstance<AuthSession>(_serviceProvider, this);
|
|
}
|
|
|
|
protected override void OnStarting() {
|
|
_logger.LogInformation("Starting");
|
|
base.OnStarting();
|
|
}
|
|
|
|
protected override void OnStarted() {
|
|
_logger.LogInformation("Started");
|
|
base.OnStarted();
|
|
}
|
|
|
|
protected override void OnStopping() {
|
|
_logger.LogInformation("Stopping");
|
|
base.OnStopping();
|
|
}
|
|
|
|
protected override void OnStopped() {
|
|
_logger.LogInformation("Stopped");
|
|
base.OnStopped();
|
|
}
|
|
|
|
protected override void OnConnected(TcpSession session) {
|
|
_logger.LogInformation("Client connected {Session}", session.Id);
|
|
base.OnConnected(session);
|
|
}
|
|
|
|
protected override void OnDisconnected(TcpSession session) {
|
|
_logger.LogInformation("Client disconnected {Session}", session.Id);
|
|
base.OnDisconnected(session);
|
|
}
|
|
|
|
protected override void OnError(SocketError error) {
|
|
_logger.LogError("An error has occured {Error}", error);
|
|
}
|
|
}
|