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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
package MasterServer::UDP::UpLink;
use strict;
use warnings;
use Encode;
use AnyEvent::Handle::UDP;
use Socket qw(sockaddr_in inet_ntoa);
use Exporter 'import';
our @EXPORT = qw| send_heartbeats
do_uplink
process_udp_secure
handle_status_query |;
# for compliance, query ID
my $query_id = 0;
################################################################################
## Broadcast heartbeats to other masterservers
##
################################################################################
sub send_heartbeats {
my $self = shift;
# in order to be permitted to sync, you need to share your address too so
# others can sync from you too.
if ($self->{sync_enabled}) {
# get serverlist
my $masterserverlist = $self->get_server(
updated => 3600,
gamename => "333networks",
);
# uplink to every 333networks-based masterserver
foreach my $ms (@{$masterserverlist}) {
# send uplink
$self->do_uplink($ms->{ip}, $ms->{port});
}
}
}
################################################################################
## Do an uplink to other 333networks-based masterservers so we can be shared
## along the 333networks synchronization protocol. Other 333networks-based
## masterservers are shared in this way too.
################################################################################
sub do_uplink {
my ($self, $ip, $port) = @_;
# do not proceed if not all information is available
return unless (defined $ip && defined $port && $port > 0);
# report uplinks to log
$self->log("uplink", "Uplink to Masterserver $ip:$port");
# connect with UDP server
my $udp_client; $udp_client = AnyEvent::Handle::UDP->new(
connect => [$ip, $port],
timeout => $self->{timeout_time},
on_timeout => sub {$udp_client->destroy()},
on_error => sub {$udp_client->destroy()},
on_recv => sub {
my ($self, $buf, $udp, $pa) = @_;
$self->handle_status_query($udp, $pa, $buf)
if ($buf =~ m/secure/);
},
);
# Send heardbeat
$udp_client->push_send("\\heartbeat\\$self->{beacon_port}\\gamename\\333networks");
}
################################################################################
## Respond to status-like queries. Supported queries are basic, info, rules,
## players, status.
## Note: this replaces the \about\ query in the TCP handler!
################################################################################
sub handle_status_query {
my ($self, $udp, $pa, $buf) = @_;
# hotfix for one-word queries
$buf .= "\\dummy\\";
my %r;
$buf = encode('UTF-8', $buf);
$buf =~ s/\n//;
$buf =~ s/\\\\/\\undef\\/g; # where to add the +? seperate perl script!
$buf =~ s/\\([^\\]+)\\([^\\]+)/$r{$1}=$2/eg;
# response string
my $response = "";
# for compliance, query ids between 0-99
$query_id = ($query_id >= 99) ? 1 : ++$query_id;
my $sub_id = 1;
# get database info to present game stats as players, where num_total > 0
my $maxgames = $self->check_cipher_count();
my $gameinfo = $self->get_game_props(
num_gt => 1,
sort => "num_total",
reverse => 1
);
# secure challenge
if (defined $r{secure}) {
$response .= "\\validate\\"
. $self->validate_string(
gamename => "333networks",
enctype => 0,
secure => $r{secure}
);
}
# basic query
if (defined $r{basic} || defined $r{status}) {
$response .= "\\gamename\\333networks"
. "\\gamever\\$self->{short_version}"
. "\\location\\0"
. "\\queryid\\$query_id.".$sub_id++;
}
# info query
if (defined $r{info} || defined $r{status}) {
$response .= "\\hostname\\$self->{masterserver_hostname}"
. "\\hostport\\$self->{listen_port}"
. "\\gametype\\MasterServer"
. "\\numplayers\\". scalar @{$gameinfo}
. "\\maxplayers\\$maxgames"
. "\\gamemode\\openplaying"
. "\\queryid\\$query_id.".$sub_id++;
}
# rules query
if (defined $r{rules} || defined $r{status}) {
$response .= "\\mutators\\333networks synchronization, master applet synchronization"
. "\\AdminName\\$self->{masterserver_name}"
. "\\AdminEMail\\$self->{masterserver_contact}"
. "\\queryid\\$query_id.".$sub_id++;
}
# players query
if (defined $r{players} || defined $r{status}) {
# list game stats as if they were players, with game description as
# player_$, gamename as skin_$, total servers as frags_$ and number of
# direct uplinks as deaths_$
my $c = 0;
foreach my $p (@{$gameinfo}) {
$c++; # count players
$response .= "\\player_$c\\$p->{description}"
. "\\skin_$c\\$p->{gamename}"
. "\\frags_$c\\$p->{num_total}"
. "\\deaths_$c\\$p->{num_uplink}";
}
$response .= "\\queryid\\$query_id.".$sub_id++;
}
# close query with final tag
$response .= "\\final\\";
# split the response in chunks of 512 bytes and send
while (length $response > 512) {
my $chunk = substr $response, 0, 512, '';
$udp->push_send($chunk, $pa);
}
# last <512 chunk
$udp->push_send($response, $pa);
}
1;
|
