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
|
package MasterServer::UDP::UpLink;
use strict;
use warnings;
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: basic, info, rules, status.
## Note: this replaces the \about\ query in the TCP handler!
################################################################################
sub handle_status_query {
# self, handle, packed address, buffer
my ($self, $udp, $paddress, $buffer) = @_;
my $rx = $self->data2hashref($buffer);
my $response = "";
# for compliance, query ids between 0-99
$query_id = ($query_id >= 98) ? 1 : ++$query_id;
my $sub_id = 1;
# get database info to present game stats, 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 $rx->{secure}) {
$response .= "\\validate\\"
. $self->validate_string(
gamename => "333networks",
enctype => 0,
secure => $rx->{secure}
);
}
# basic query
if (defined $rx->{basic} || defined $rx->{status}) {
$response .= "\\gamename\\333networks"
. "\\gamever\\$self->{short_version}"
. "\\location\\0"
. "\\queryid\\$query_id.".$sub_id++;
}
# info query
if (defined $rx->{info} || defined $rx->{status}) {
$response .= "\\hostname\\".($self->{masterserver_hostname} || "")
. "\\hostport\\$self->{listen_port}"
. "\\gametype\\MasterServer"
. "\\mapname\\333networks"
. "\\numplayers\\".(scalar @{$gameinfo} || 0)
. "\\maxplayers\\".($maxgames || 0)
. "\\gamemode\\openplaying"
. "\\queryid\\$query_id.".$sub_id++;
}
# rules query
if (defined $rx->{rules} || defined $rx->{status}) {
$response .= "\\mutators\\333networks synchronization, UCC Master applet synchronization, Server Status Checker"
. "\\AdminName\\".($self->{masterserver_name} || "")
. "\\AdminEMail\\".($self->{masterserver_contact} || "")
. "\\queryid\\$query_id.".$sub_id++;
}
# close query with final tag
$response .= "\\final\\";
# split the response in chunks of 512 characters and send
while (length $response > 512) {
my $chunk = substr $response, 0, 512, '';
$udp->push_send($chunk, $paddress);
}
# last <512 chunk
$udp->push_send($response, $paddress);
}
1;
|
