blob: bd9a855381e6ae7c51b5b6c5afd86db0bdd5d387 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
using System.Net;
using System.Threading;
using System.Threading.Tasks;
using Impostor.Server.Config;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
namespace Impostor.Server.Net
{
internal class MatchmakerService : IHostedService
{
private readonly ILogger<MatchmakerService> _logger;
private readonly ServerConfig _serverConfig;
private readonly ServerRedirectorConfig _redirectorConfig;
private readonly Matchmaker _matchmaker;
public MatchmakerService(
ILogger<MatchmakerService> logger,
IOptions<ServerConfig> serverConfig,
IOptions<ServerRedirectorConfig> redirectorConfig,
Matchmaker matchmaker)
{
_logger = logger;
_serverConfig = serverConfig.Value;
_redirectorConfig = redirectorConfig.Value;
_matchmaker = matchmaker;
}
public async Task StartAsync(CancellationToken cancellationToken)
{
var endpoint = new IPEndPoint(IPAddress.Parse(_serverConfig.ResolveListenIp()), _serverConfig.ListenPort);
await _matchmaker.StartAsync(endpoint);
_logger.LogInformation(
"Matchmaker is listening on {0}:{1}, the public server ip is {2}:{3}.",
endpoint.Address,
endpoint.Port,
_serverConfig.ResolvePublicIp(),
_serverConfig.PublicPort);
if (_redirectorConfig.Enabled)
{
_logger.LogWarning(_redirectorConfig.Master
? "Server redirection is enabled as master, this instance will redirect clients to other nodes."
: "Server redirection is enabled as node, this instance will accept clients.");
}
}
public async Task StopAsync(CancellationToken cancellationToken)
{
_logger.LogWarning("Matchmaker is shutting down!");
await _matchmaker.StopAsync();
}
}
}
|
