1 package gosaTriggered;
2 use Exporter;
3 @ISA = qw(Exporter);
4 my @events = (
5 "get_events",
6 "get_login_usr_for_client",
7 "get_client_for_login_usr",
8 "gen_smb_hash",
9 "trigger_reload_ldap_config",
10 "ping",
11 "network_completition",
12 "set_activated_for_installation",
13 "new_key_for_client",
14 "detect_hardware",
15 "get_login_usr",
16 "get_login_client",
17 "trigger_action_localboot",
18 "trigger_action_faireboot",
19 "trigger_action_reboot",
20 "trigger_action_activate",
21 "trigger_action_lock",
22 "trigger_action_halt",
23 "trigger_action_update",
24 "trigger_action_reinstall",
25 "trigger_action_memcheck",
26 "trigger_action_sysinfo",
27 "trigger_action_instant_update",
28 "trigger_action_rescan",
29 "trigger_action_wake",
30 "recreate_fai_server_db",
31 "send_user_msg",
32 );
33 @EXPORT = @events;
35 use strict;
36 use warnings;
37 use GOSA::GosaSupportDaemon;
38 use Data::Dumper;
39 use Crypt::SmbHash;
40 use Net::ARP;
41 use Net::Ping;
42 use Socket;
43 use utf8;
45 BEGIN {}
47 END {}
49 ### Start ######################################################################
51 #&main::read_configfile($main::cfg_file, %cfg_defaults);
53 sub get_events {
54 return \@events;
55 }
57 sub send_user_msg {
58 my ($msg, $msg_hash, $session_id) = @_ ;
59 my @out_msg_l;
60 my @user_list;
61 my @group_list;
63 my $header = @{$msg_hash->{'header'}}[0];
64 my $source = @{$msg_hash->{'source'}}[0];
65 my $target = @{$msg_hash->{'target'}}[0];
66 my $message = @{$msg_hash->{'message'}}[0];
67 if( exists $msg_hash->{'user'} ) { @user_list = @{$msg_hash->{'user'}}; }
68 if( exists $msg_hash->{'group'} ) { @group_list = @{$msg_hash->{'group'}}; }
70 # error handling
71 if( not @user_list && not @group_list ) {
72 &main::daemon_log("WARNING: no user-tag or a group-tag specified in 'send_user_msg'", 3);
73 return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
74 "<error_string>no user-tag or a group-tag specified in 'send_user_msg'</error_string></xml>");
75 }
76 if( not defined $message ) {
77 &main::daemon_log("WARNING: no message-tag specified in 'send_user_msg'", 3);
78 return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
79 "<error_string>no message-tag specified in 'send_user_msg'</error_string></xml>");
81 }
83 # resolve groups to users
84 if( @group_list ) {
85 # build ldap connection
86 &main::refresh_ldap_handle();
87 if( not defined $main::ldap_handle ) {
88 &main::daemon_log("ERROR: cannot connect to ldap", 1);
89 return ();
90 }
91 foreach my $group (@group_list) {
92 # Perform search
93 my $mesg = $main::ldap_handle->search(
94 base => $main::ldap_base,
95 scope => 'sub',
96 attrs => ['memberUid'],
97 filter => "(&(objectClass=posixGroup)(cn=$group)(memberUid=*))");
98 if($mesg->code) {
99 &main::daemon_log($mesg->error, 1);
100 return ();
101 }
102 my $entry= $mesg->entry(0);
103 my @users= $entry->get_value("memberUid");
104 foreach my $user (@users) { push(@user_list, $user); }
105 }
106 }
108 # drop multiple users in @user_list
109 my %seen = ();
110 foreach my $user (@user_list) {
111 $seen{$user}++;
112 }
113 @user_list = keys %seen;
115 # build xml messages sended to client where user is logged in
116 foreach my $user (@user_list) {
117 my $sql_statement = "SELECT * FROM $main::login_users_tn WHERE user='$user'";
118 my $db_res = $main::login_users_db->select_dbentry($sql_statement);
120 if(0 == keys(%{$db_res})) {
122 } else {
123 while( my($hit, $content) = each %{$db_res} ) {
124 my $out_hash = &create_xml_hash('send_user_msg', $main::server_address, $content->{'client'});
125 &add_content2xml_hash($out_hash, 'message', $message);
126 &add_content2xml_hash($out_hash, 'user', $user);
127 if( exists $msg_hash->{'jobdb_id'} ) {
128 &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
129 }
130 my $out_msg = &create_xml_string($out_hash);
131 push(@out_msg_l, $out_msg);
132 }
133 }
134 }
136 return @out_msg_l;
137 }
140 sub recreate_fai_server_db {
141 my ($msg, $msg_hash, $session_id) = @_ ;
142 my $out_msg;
144 $main::fai_server_db->create_table("new_fai_server", \@main::fai_server_col_names);
145 &main::create_fai_server_db("new_fai_server");
146 $main::fai_server_db->move_table("new_fai_server", $main::fai_server_tn);
148 my @out_msg_l = ( $out_msg );
149 return @out_msg_l;
150 }
153 sub get_login_usr_for_client {
154 my ($msg, $msg_hash, $session_id) = @_ ;
155 my $header = @{$msg_hash->{'header'}}[0];
156 my $source = @{$msg_hash->{'source'}}[0];
157 my $target = @{$msg_hash->{'target'}}[0];
158 my $client = @{$msg_hash->{'client'}}[0];
160 $header =~ s/^gosa_//;
162 my $sql_statement = "SELECT * FROM known_clients WHERE hostname='$client' OR macaddress LIKE '$client'";
163 my $res = $main::known_clients_db->select_dbentry($sql_statement);
165 my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
166 $out_msg .= &db_res2xml($res);
167 $out_msg .= "</xml>";
169 my @out_msg_l = ( $out_msg );
170 return @out_msg_l;
171 }
174 sub get_client_for_login_usr {
175 my ($msg, $msg_hash, $session_id) = @_ ;
176 my $header = @{$msg_hash->{'header'}}[0];
177 my $source = @{$msg_hash->{'source'}}[0];
178 my $target = @{$msg_hash->{'target'}}[0];
179 my $usr = @{$msg_hash->{'usr'}}[0];
180 $header =~ s/^gosa_//;
182 my $sql_statement = "SELECT * FROM known_clients WHERE login LIKE '%$usr%'";
183 my $res = $main::known_clients_db->select_dbentry($sql_statement);
185 my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
186 $out_msg .= &db_res2xml($res);
187 $out_msg .= "</xml>";
188 my @out_msg_l = ( $out_msg );
189 return @out_msg_l;
191 }
194 sub ping {
195 my ($msg, $msg_hash, $session_id) = @_ ;
196 my $out_msg = $msg;
197 $out_msg =~ s/<header>gosa_/<header>/;
198 $out_msg =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
200 my @out_msg_l = ( $out_msg );
201 return @out_msg_l;
202 }
204 sub gen_smb_hash {
205 my ($msg, $msg_hash, $session_id) = @_ ;
206 my $source = @{$msg_hash->{source}}[0];
207 my $target = @{$msg_hash->{target}}[0];
208 my $password = @{$msg_hash->{password}}[0];
210 my %data= ('hash' => join(q[:], ntlmgen $password));
211 my $out_msg = &build_msg("gen_smb_hash", $target, 'GOSA', \%data );
212 return ( $out_msg );
213 }
216 sub network_completition {
217 my ($msg, $msg_hash, $session_id) = @_ ;
218 my $source = @{$msg_hash->{source}}[0];
219 my $target = @{$msg_hash->{target}}[0];
220 my $name = @{$msg_hash->{hostname}}[0];
222 # Can we resolv the name?
223 my %data;
224 if (inet_aton($name)){
225 my $address = inet_ntoa(inet_aton($name));
226 my $p = Net::Ping->new('tcp');
227 my $mac= "";
228 if ($p->ping($address, 1)){
229 $mac = Net::ARP::arp_lookup("", $address);
230 }
232 %data= ('ip' => $address, 'mac' => $mac);
233 } else {
234 %data= ('ip' => '', 'mac' => '');
235 }
237 my $out_msg = &build_msg("network_completition", $target, 'GOSA', \%data );
239 return ( $out_msg );
240 }
243 sub detect_hardware {
244 my ($msg, $msg_hash) = @_ ;
245 # just forward msg to client, but dont forget to split off 'gosa_' in header
246 my $source = @{$msg_hash->{source}}[0];
247 my $target = @{$msg_hash->{target}}[0];
249 my $out_hash = &create_xml_hash("detect_hardware", $source, $target);
250 if( exists $msg_hash->{'jobdb_id'} ) {
251 &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
252 }
253 my $out_msg = &create_xml_string($out_hash);
255 my @out_msg_l = ( $out_msg );
256 return @out_msg_l;
258 }
261 sub trigger_reload_ldap_config {
262 my ($msg, $msg_hash) = @_ ;
263 my $target = @{$msg_hash->{target}}[0];
265 my $out_hash = &create_xml_hash("reload_ldap_config", $main::server_address, $main::server_address, $target);
266 if( exists $msg_hash->{'jobdb_id'} ) {
267 &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
268 }
269 my $out_msg = &create_xml_string($out_hash);
270 my @out_msg_l;
271 push(@out_msg_l, $out_msg);
272 return @out_msg_l;
273 }
276 sub set_activated_for_installation {
277 my ($msg, $msg_hash) = @_;
279 my $header = @{$msg_hash->{header}}[0];
280 my $source = @{$msg_hash->{source}}[0];
281 my $target = @{$msg_hash->{target}}[0];
283 my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $target);
284 if( exists $msg_hash->{'jobdb_id'} ) {
285 &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
286 }
287 my $out_msg = &create_xml_string($out_hash);
288 my @out_msg_l = ( $out_msg );
289 return @out_msg_l;
290 }
293 sub trigger_action_faireboot {
294 my ($msg, $msg_hash) = @_;
295 my $macaddress = @{$msg_hash->{target}}[0];
296 my $source = @{$msg_hash->{source}}[0];
298 my @out_msg_l;
299 $msg =~ s/<header>gosa_trigger_action_faireboot<\/header>/<header>trigger_action_faireboot<\/header>/;
300 push(@out_msg_l, $msg);
302 &main::change_goto_state('locked', \@{$msg_hash->{target}});
303 &main::change_fai_state('localboot', \@{$msg_hash->{target}});
305 # delete all jobs from jobqueue which correspond to fai
306 my $sql_statement = "DELETE FROM $main::job_queue_tn WHERE (macaddress='$macaddress' AND ".
307 "status='processing')";
308 $main::job_db->del_dbentry($sql_statement );
310 return @out_msg_l;
311 }
314 sub trigger_action_lock {
315 my ($msg, $msg_hash) = @_;
316 my $macaddress = @{$msg_hash->{target}}[0];
317 my $source = @{$msg_hash->{source}}[0];
319 &main::change_goto_state('locked', \@{$msg_hash->{target}});
321 my @out_msg_l;
322 return @out_msg_l;
323 }
326 sub trigger_action_activate {
327 my ($msg, $msg_hash) = @_;
328 my $macaddress = @{$msg_hash->{target}}[0];
329 my $source = @{$msg_hash->{source}}[0];
331 &main::change_goto_state('active', \@{$msg_hash->{target}});
333 my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $macaddress);
334 if( exists $msg_hash->{'jobdb_id'} ) {
335 &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
336 }
337 my $out_msg = &create_xml_string($out_hash);
339 return ( $out_msg );
340 }
343 sub trigger_action_localboot {
344 my ($msg, $msg_hash) = @_;
345 $msg =~ s/<header>gosa_trigger_action_localboot<\/header>/<header>trigger_action_localboot<\/header>/;
347 &main::change_fai_state('localboot', \@{$msg_hash->{target}});
349 my @out_msg_l = ($msg);
350 return @out_msg_l;
351 }
354 sub trigger_action_halt {
355 my ($msg, $msg_hash) = @_;
356 $msg =~ s/<header>gosa_trigger_action_halt<\/header>/<header>trigger_action_halt<\/header>/;
358 &main::change_fai_state('halt', \@{$msg_hash->{target}});
360 my @out_msg_l = ($msg);
361 return @out_msg_l;
362 }
365 sub trigger_action_reboot {
366 my ($msg, $msg_hash) = @_;
367 $msg =~ s/<header>gosa_trigger_action_reboot<\/header>/<header>trigger_action_reboot<\/header>/;
369 &main::change_fai_state('reboot', \@{$msg_hash->{target}});
371 my @out_msg_l = ($msg);
372 return @out_msg_l;
373 }
376 sub trigger_action_memcheck {
377 my ($msg, $msg_hash) = @_ ;
378 $msg =~ s/<header>gosa_trigger_action_memcheck<\/header>/<header>trigger_action_memcheck<\/header>/;
380 &main::change_fai_state('memcheck', \@{$msg_hash->{target}});
382 my @out_msg_l = ($msg);
383 return @out_msg_l;
384 }
387 sub trigger_action_reinstall {
388 my ($msg, $msg_hash) = @_;
389 $msg =~ s/<header>gosa_trigger_action_reinstall<\/header>/<header>trigger_action_reinstall<\/header>/;
391 &main::change_fai_state('reinstall', \@{$msg_hash->{target}});
393 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
394 my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
395 my @out_msg_l = ($wake_msg, $msg);
396 return @out_msg_l;
397 }
400 sub trigger_action_update {
401 my ($msg, $msg_hash) = @_;
402 $msg =~ s/<header>gosa_trigger_action_update<\/header>/<header>trigger_action_update<\/header>/;
404 &main::change_fai_state('update', \@{$msg_hash->{target}});
406 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
407 my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
408 my @out_msg_l = ($wake_msg, $msg);
409 return @out_msg_l;
410 }
413 sub trigger_action_instant_update {
414 my ($msg, $msg_hash) = @_;
415 $msg =~ s/<header>gosa_trigger_action_instant_update<\/header>/<header>trigger_action_instant_update<\/header>/;
417 &main::change_fai_state('update', \@{$msg_hash->{target}});
419 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
420 my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
421 my @out_msg_l = ($wake_msg, $msg);
422 return @out_msg_l;
423 }
426 sub trigger_action_sysinfo {
427 my ($msg, $msg_hash) = @_;
428 $msg =~ s/<header>gosa_trigger_action_sysinfo<\/header>/<header>trigger_action_sysinfo<\/header>/;
430 &main::change_fai_state('sysinfo', \@{$msg_hash->{target}});
432 my @out_msg_l = ($msg);
433 return @out_msg_l;
434 }
437 sub new_key_for_client {
438 my ($msg, $msg_hash) = @_;
439 $msg =~ s/<header>gosa_new_key_for_client<\/header>/<header>new_key<\/header>/;
440 my @out_msg_l = ($msg);
441 return @out_msg_l;
442 }
445 sub trigger_action_rescan {
446 my ($msg, $msg_hash) = @_;
447 $msg =~ s/<header>gosa_trigger_action_rescan<\/header>/<header>trigger_action_rescan<\/header>/;
448 my @out_msg_l = ($msg);
449 return @out_msg_l;
450 }
453 sub trigger_action_wake {
454 my ($msg, $msg_hash) = @_;
455 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
456 my $out_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
457 my @out_msg_l = ($out_msg);
458 return @out_msg_l;
459 }
462 1;