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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
package MasterServer::UDP::BeaconProcessor;
use strict;
use warnings;
use Data::Dumper 'Dumper';
use AnyEvent::Handle::UDP;
use Exporter 'import';
our @EXPORT = qw| process_udp_beacon process_udp_validate |;
## process beacons that have a \heartbeat\ and \gamename\ format
sub process_udp_beacon {
# $self, handle, packed address, udp data, peer ip address, $port
my ($self, $udp, $pa, $buf, $peer_addr, $port) = @_;
# received heartbeat in $buf: \heartbeat\7778\gamename\ut\
my %r;
$buf =~ s/\\([^\\]+)\\([^\\]+)/$r{$1}=$2/eg;
# check whether the beacon has a gamename that is supported in our list
if (defined $r{gamename} && exists $self->{game}->{lc $r{gamename}}) {
# log the beacon
$self->log("beacon", "$peer_addr:$r{heartbeat} for $r{gamename}");
# some games (like bcommander) have a default port and don't send a
# heartbeat port.
if ($r{heartbeat} == 0) {
# assuming a default port exists
if (exists $self->{game}->{lc $r{gamename}}->{port}) {
$r{heartbeat} = $self->{game}->{lc $r{gamename}}->{port};
}
}
#
# verify valid server address (ip+port)
if ($self->valid_address($peer_addr,$r{heartbeat})) {
# generate a new secure string
my $secure = $self->secure_string();
# update beacon in serverlist if it already exists, otherwise update
# or add to pending with new secure string.
my $auth = $self->add_beacon($peer_addr, $port, $r{heartbeat}, $r{gamename}, $secure);
# send secure string back
if ($auth > 0) {
# verify that this is a legitimate client by sending the "secure" query
$udp->push_send("\\secure\\$secure\\final\\", $pa);
# log this as a new beacon
$self->log("secure", "challenged new beacon $peer_addr:$port with $secure.");
}
}
# invalid ip+port combination, like \heartbeat\0\ or local IP
else {
# Log that beacon had incorrect information, such as port 0 or so. Spams log!
$self->log("invalid","$peer_addr:$r{heartbeat} ($r{heartbeat}) had bad information");
}
}
# gamename not valid or not found in supportedgames.pl
else {
# log
$self->log("support", "received unknown beacon \"$r{gamename}\" from $peer_addr:$r{heartbeat}");
}
}
## process the received validate query and determine whether the server is allowed in our database
sub process_udp_validate {
# $self, udp data, ip, port
my ($self, $buf, $peer_addr, $port, $heartbeat) = @_;
# received heartbeat in $b: \validate\string\queryid\99.9\
my %r;
$buf =~ s/\\([^\\]+)\\([^\\]+)/$r{$1}=$2/eg;
# get our existing knowledge about this server from the database
# if the heartbeat/queryport known? then use that instead as beacon ports --> may vary after server restarts!
my $pending = (defined $heartbeat) ? $self->get_pending_info($peer_addr, $heartbeat) : $self->get_pending_beacon($peer_addr, $port);
# if indeed in the pending list, check
if (defined $pending) {
#determine if it uses any enctype
my $enc = (defined $r{enctype}) ? $r{enctype} : 0;
# database may not contain the correct gamename (ucc applet, incomplete beacon, change of gameserver)
$pending->[4] = (defined $r{gamename} && exists $self->{game}->{lc $r{gamename}}) ? $r{gamename} : $pending->[4];
# verify challenge gamename secure enctype validate_response
my $val = $self->validated_beacon($pending->[4], $pending->[5], $enc, $r{validate});
# log challenge results
$self->log("secure", "$peer_addr:$port validated with $val for $pending->[4]");
# if validated, add to db
if ($val > 0) {
# successfully added? ip, query port, gamename
my $sa = $self->add_to_serverlist($pending->[1], $pending->[3], $pending->[4]);
# remove the entry from pending if successfully added
$self->remove_pending($pending->[0]) if ( $sa >= 0);
# and set as direct beacon
$self->set_direct_beacon($pending->[1], $pending->[3]);
}
else {
# else failed validation
$self->log("error","beacon $peer_addr:$port failed validation for $pending->[4] (details: $pending->[5] sent, got $r{validate})");
}
}
}
1;
|
