1 package server_server_com;
2 use Exporter;
3 @ISA = qw(Exporter);
4 my @events = (
5 'new_server',
6 'confirm_new_server',
7 'new_foreign_client',
8 );
9 @EXPORT = @events;
11 use strict;
12 use warnings;
13 use Data::Dumper;
14 use GOSA::GosaSupportDaemon;
15 use Time::HiRes qw( usleep);
18 BEGIN {}
20 END {}
22 ### Start ######################################################################
24 sub get_events {
25 return \@events;
26 }
29 sub new_server {
30 my ($msg, $msg_hash, $session_id) = @_ ;
31 my $header = @{$msg_hash->{'header'}}[0];
32 my $source = @{$msg_hash->{'source'}}[0];
33 my $target = @{$msg_hash->{'target'}}[0];
34 my $key = @{$msg_hash->{'key'}}[0];
35 my @clients = exists $msg_hash->{'client'} ? @{$msg_hash->{'client'}} : qw();
37 # sanity check
38 if (ref $key eq 'HASH') {
39 &main::daemon_log("$session_id ERROR: 'new_server'-message from host '$source' contains no key!", 1);
40 return;
41 }
43 # add foreign server to known_server_db
44 my $func_dic = {table=>$main::known_server_tn,
45 primkey=>['hostname'],
46 hostname => $source,
47 status => "new_server",
48 hostkey => $key,
49 timestamp=>&get_time(),
50 };
51 my $res = $main::known_server_db->add_dbentry($func_dic);
52 if (not $res == 0) {
53 &main::daemon_log("$session_id ERROR: server_server_com.pm: cannot add server to known_server_db: $res", 1);
54 } else {
55 &main::daemon_log("$session_id INFO: server_server_com.pm: server '$source' successfully added to known_server_db", 5);
56 }
58 # delete all entries at foreign_clients_db coresponding to this server
59 my $del_sql = "DELETE FROM $main::foreign_clients_tn WHERE regserver='$source' ";
60 my $del_res = $main::foreign_clients_db->exec_statement($del_sql);
62 # add clients of foreign server to known_foreign_clients_db
63 my @sql_list;
64 foreach my $client (@clients) {
65 my @client_details = split(/,/, $client);
67 # workaround to avoid double entries in foreign_clients_db
68 my $del_sql = "DELETE FROM $main::foreign_clients_tn WHERE hostname='".$client_details[0]."'";
69 push(@sql_list, $del_sql);
71 my $sql = "INSERT INTO $main::foreign_clients_tn VALUES ("
72 ."'".$client_details[0]."'," # hostname
73 ."'".$client_details[1]."'," # macaddress
74 ."'".$source."'," # regserver
75 ."'".&get_time()."')"; # timestamp
76 push(@sql_list, $sql);
77 }
78 if (@sql_list) {
79 my $len = @sql_list;
80 $len /= 2;
81 &main::daemon_log("$session_id DEBUG: Inserting ".$len." entries to foreign_clients_db", 8);
82 my $res = $main::foreign_clients_db->exec_statementlist(\@sql_list);
83 }
85 # fetch all registered clients
86 my $client_sql = "SELECT * FROM $main::known_clients_tn";
87 my $client_res = $main::known_clients_db->exec_statement($client_sql);
90 # add already connected clients to registration message
91 my $myhash = &create_xml_hash('confirm_new_server', $main::server_address, $source);
92 &add_content2xml_hash($myhash, 'key', $key);
93 map(&add_content2xml_hash($myhash, 'client', @{$_}[0].",".@{$_}[4]), @$client_res);
95 # build registration message and send it
96 my $out_msg = &create_xml_string($myhash);
99 # build confirm_new_server message
100 #my %data = ( key=>$key );
101 #my $out_msg = &build_msg('confirm_new_server', $main::server_address, $source, \%data);
102 my $error = &main::send_msg_to_target($out_msg, $source, $main::ServerPackages_key, 'confirm_new_server', $session_id);
104 return;
105 }
108 sub confirm_new_server {
109 my ($msg, $msg_hash, $session_id) = @_ ;
110 my $header = @{$msg_hash->{'header'}}[0];
111 my $source = @{$msg_hash->{'source'}}[0];
112 my $key = @{$msg_hash->{'key'}}[0];
113 my @clients = exists $msg_hash->{'client'} ? @{$msg_hash->{'client'}} : qw();
115 my $sql = "UPDATE $main::known_server_tn SET status='$header', hostkey='$key' WHERE hostname='$source'";
116 my $res = $main::known_server_db->update_dbentry($sql);
118 # add clients of foreign server to known_foreign_clients_db
119 my @sql_list;
120 foreach my $client (@clients) {
121 my @client_details = split(/,/, $client);
123 # workaround to avoid double entries in foreign_clients_db
124 my $del_sql = "DELETE FROM $main::foreign_clients_tn WHERE hostname='".$client_details[0]."'";
125 push(@sql_list, $del_sql);
127 my $sql = "INSERT INTO $main::foreign_clients_tn VALUES ("
128 ."'".$client_details[0]."'," # hostname
129 ."'".$client_details[1]."'," # macaddress
130 ."'".$source."'," # regserver
131 ."'".&get_time()."')"; # timestamp
132 push(@sql_list, $sql);
133 }
134 if (@sql_list) {
135 my $len = @sql_list;
136 $len /= 2;
137 &main::daemon_log("$session_id DEBUG: Inserting ".$len." entries to foreign_clients_db", 8);
138 my $res = $main::foreign_clients_db->exec_statementlist(\@sql_list);
139 }
142 return;
143 }
146 sub new_foreign_client {
147 my ($msg, $msg_hash, $session_id) = @_ ;
148 my $header = @{$msg_hash->{'header'}}[0];
149 my $source = @{$msg_hash->{'source'}}[0];
150 my $hostname = @{$msg_hash->{'client'}}[0];
151 my $macaddress = @{$msg_hash->{'macaddress'}}[0];
152 # if new client is known in known_clients_db
153 my $check_sql = "SELECT * FROM $main::known_clients_tn WHERE (macaddress LIKE '$macaddress')";
154 my $check_res = $main::known_clients_db->select_dbentry($check_sql);
156 if( (keys(%$check_res) == 1) ) {
157 my $host_key = $check_res->{1}->{'hostkey'};
159 # check if new client is still alive
160 my $client_hash = &create_xml_hash("ping", $main::server_address, $hostname);
161 &add_content2xml_hash($client_hash, 'session_id', $session_id);
162 my $client_msg = &create_xml_string($client_hash);
163 my $error = &main::send_msg_to_target($client_msg, $hostname, $host_key, 'ping', $session_id);
164 my $message_id;
165 my $i = 0;
166 while (1) {
167 $i++;
168 my $sql = "SELECT * FROM $main::incoming_tn WHERE headertag='answer_$session_id'";
169 my $res = $main::incoming_db->exec_statement($sql);
170 if (ref @$res[0] eq "ARRAY") {
171 $message_id = @{@$res[0]}[0];
172 last;
173 }
175 # do not run into a endless loop
176 if ($i > 50) { last; }
177 usleep(100000);
178 }
180 # client is alive
181 # -> new_foreign_client will be ignored
182 if (defined $message_id) {
183 &main::daemon_log("$session_id ERROR: At new_foreign_clients: host '$hostname' is reported as a new foreign client, ".
184 "but the host is still registered at this server. So, the new_foreign_client-msg will be ignored: $msg", 1);
185 }
186 }
189 # new client is not found in known_clients_db or
190 # new client is dead -> new_client-msg from foreign server is valid
191 # -> client will be deleted from known_clients_db
192 # -> inserted to foreign_clients_db
194 my $del_sql = "DELETE FROM $main::known_clients_tn WHERE (hostname='$hostname')";
195 my $del_res = $main::known_clients_db->exec_statement($del_sql);
196 my $func_dic = { table => $main::foreign_clients_tn,
197 primkey => ['hostname'],
198 hostname => $hostname,
199 macaddress => $macaddress,
200 regserver => $source,
201 timestamp => &get_time(),
202 };
203 my $res = $main::foreign_clients_db->add_dbentry($func_dic);
204 if (not $res == 0) {
205 &main::daemon_log("$session_id ERROR: server_server_com.pm: cannot add server to foreign_clients_db: $res", 1);
206 } else {
207 &main::daemon_log("$session_id INFO: server_server_com.pm: client '$hostname' successfully added to foreign_clients_db", 5);
208 }
210 return;
211 }
214 1;