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 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
71 if( defined $jobdb_id) {
72 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
73 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
74 my $res = $main::job_db->exec_statement($sql_statement);
75 }
77 # error handling
78 if( not @user_list && not @group_list ) {
79 &main::daemon_log("WARNING: no user-tag or a group-tag specified in 'send_user_msg'", 3);
80 return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
81 "<error_string>no user-tag or a group-tag specified in 'send_user_msg'</error_string></xml>");
82 }
83 if( not defined $message ) {
84 &main::daemon_log("WARNING: no message-tag specified in 'send_user_msg'", 3);
85 return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
86 "<error_string>no message-tag specified in 'send_user_msg'</error_string></xml>");
88 }
90 # resolve groups to users
91 if( @group_list ) {
92 # build ldap connection
93 &main::refresh_ldap_handle();
94 if( not defined $main::ldap_handle ) {
95 &main::daemon_log("ERROR: cannot connect to ldap", 1);
96 return ();
97 }
98 foreach my $group (@group_list) {
99 # Perform search
100 my $mesg = $main::ldap_handle->search(
101 base => $main::ldap_base,
102 scope => 'sub',
103 attrs => ['memberUid'],
104 filter => "(&(objectClass=posixGroup)(cn=$group)(memberUid=*))");
105 if($mesg->code) {
106 &main::daemon_log($mesg->error, 1);
107 return ();
108 }
109 my $entry= $mesg->entry(0);
110 my @users= $entry->get_value("memberUid");
111 foreach my $user (@users) { push(@user_list, $user); }
112 }
113 }
115 # drop multiple users in @user_list
116 my %seen = ();
117 foreach my $user (@user_list) {
118 $seen{$user}++;
119 }
120 @user_list = keys %seen;
122 # build xml messages sended to client where user is logged in
123 foreach my $user (@user_list) {
124 my $sql_statement = "SELECT * FROM $main::login_users_tn WHERE user='$user'";
125 my $db_res = $main::login_users_db->select_dbentry($sql_statement);
127 if(0 == keys(%{$db_res})) {
129 } else {
130 while( my($hit, $content) = each %{$db_res} ) {
131 my $out_hash = &create_xml_hash('send_user_msg', $main::server_address, $content->{'client'});
132 &add_content2xml_hash($out_hash, 'message', $message);
133 &add_content2xml_hash($out_hash, 'user', $user);
134 if( exists $msg_hash->{'jobdb_id'} ) {
135 &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
136 }
137 my $out_msg = &create_xml_string($out_hash);
138 push(@out_msg_l, $out_msg);
139 }
140 }
141 }
143 return @out_msg_l;
144 }
147 sub recreate_fai_server_db {
148 my ($msg, $msg_hash, $session_id) = @_ ;
149 my $out_msg;
151 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
152 if( defined $jobdb_id) {
153 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
154 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
155 my $res = $main::job_db->exec_statement($sql_statement);
156 }
158 $main::fai_server_db->create_table("new_fai_server", \@main::fai_server_col_names);
159 &main::create_fai_server_db("new_fai_server");
160 $main::fai_server_db->move_table("new_fai_server", $main::fai_server_tn);
162 my @out_msg_l = ( $out_msg );
163 return @out_msg_l;
164 }
167 sub get_login_usr_for_client {
168 my ($msg, $msg_hash, $session_id) = @_ ;
169 my $header = @{$msg_hash->{'header'}}[0];
170 my $source = @{$msg_hash->{'source'}}[0];
171 my $target = @{$msg_hash->{'target'}}[0];
172 my $client = @{$msg_hash->{'client'}}[0];
174 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
175 if( defined $jobdb_id) {
176 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
177 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
178 my $res = $main::job_db->exec_statement($sql_statement);
179 }
181 $header =~ s/^gosa_//;
183 my $sql_statement = "SELECT * FROM known_clients WHERE hostname='$client' OR macaddress LIKE '$client'";
184 my $res = $main::known_clients_db->select_dbentry($sql_statement);
186 my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
187 $out_msg .= &db_res2xml($res);
188 $out_msg .= "</xml>";
190 my @out_msg_l = ( $out_msg );
191 return @out_msg_l;
192 }
195 sub get_client_for_login_usr {
196 my ($msg, $msg_hash, $session_id) = @_ ;
197 my $header = @{$msg_hash->{'header'}}[0];
198 my $source = @{$msg_hash->{'source'}}[0];
199 my $target = @{$msg_hash->{'target'}}[0];
201 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
202 if( defined $jobdb_id) {
203 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
204 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
205 my $res = $main::job_db->exec_statement($sql_statement);
206 }
208 my $usr = @{$msg_hash->{'usr'}}[0];
209 $header =~ s/^gosa_//;
211 my $sql_statement = "SELECT * FROM known_clients WHERE login LIKE '%$usr%'";
212 my $res = $main::known_clients_db->select_dbentry($sql_statement);
214 my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
215 $out_msg .= &db_res2xml($res);
216 $out_msg .= "</xml>";
217 my @out_msg_l = ( $out_msg );
218 return @out_msg_l;
220 }
223 sub ping {
224 my ($msg, $msg_hash, $session_id) = @_ ;
225 my $out_msg = $msg;
226 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
227 if( defined $jobdb_id) {
228 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
229 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
230 my $res = $main::job_db->exec_statement($sql_statement);
231 }
233 $out_msg =~ s/<header>gosa_/<header>/;
235 my @out_msg_l = ( $out_msg );
236 return @out_msg_l;
237 }
239 sub gen_smb_hash {
240 my ($msg, $msg_hash, $session_id) = @_ ;
241 my $source = @{$msg_hash->{source}}[0];
242 my $target = @{$msg_hash->{target}}[0];
243 my $password = @{$msg_hash->{password}}[0];
245 my %data= ('hash' => join(q[:], ntlmgen $password));
246 my $out_msg = &build_msg("gen_smb_hash", $target, 'GOSA', \%data );
247 return ( $out_msg );
248 }
251 sub network_completition {
252 my ($msg, $msg_hash, $session_id) = @_ ;
253 my $source = @{$msg_hash->{source}}[0];
254 my $target = @{$msg_hash->{target}}[0];
255 my $name = @{$msg_hash->{hostname}}[0];
257 # Can we resolv the name?
258 my %data;
259 if (inet_aton($name)){
260 my $address = inet_ntoa(inet_aton($name));
261 my $p = Net::Ping->new('tcp');
262 my $mac= "";
263 if ($p->ping($address, 1)){
264 $mac = Net::ARP::arp_lookup("", $address);
265 }
267 %data= ('ip' => $address, 'mac' => $mac);
268 } else {
269 %data= ('ip' => '', 'mac' => '');
270 }
272 my $out_msg = &build_msg("network_completition", $target, 'GOSA', \%data );
274 return ( $out_msg );
275 }
278 sub detect_hardware {
279 my ($msg, $msg_hash, $session_id) = @_ ;
280 # just forward msg to client, but dont forget to split off 'gosa_' in header
281 my $source = @{$msg_hash->{source}}[0];
282 my $target = @{$msg_hash->{target}}[0];
283 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
284 if( defined $jobdb_id) {
285 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
286 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
287 my $res = $main::job_db->exec_statement($sql_statement);
288 }
290 my $out_hash = &create_xml_hash("detect_hardware", $source, $target);
291 if( defined $jobdb_id ) {
292 &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
293 }
294 my $out_msg = &create_xml_string($out_hash);
296 my @out_msg_l = ( $out_msg );
297 return @out_msg_l;
299 }
302 sub trigger_reload_ldap_config {
303 my ($msg, $msg_hash, $session_id) = @_ ;
304 my $target = @{$msg_hash->{target}}[0];
306 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
307 if( defined $jobdb_id) {
308 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
309 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
310 my $res = $main::job_db->exec_statement($sql_statement);
311 }
313 my $out_hash = &create_xml_hash("reload_ldap_config", $main::server_address, $main::server_address, $target);
314 if( defined ) {
315 &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
316 }
317 my $out_msg = &create_xml_string($out_hash);
318 my @out_msg_l;
319 push(@out_msg_l, $out_msg);
320 return @out_msg_l;
321 }
324 sub set_activated_for_installation {
325 my ($msg, $msg_hash, $session_id) = @_;
326 my $header = @{$msg_hash->{header}}[0];
327 my $source = @{$msg_hash->{source}}[0];
328 my $target = @{$msg_hash->{target}}[0];
330 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
331 if( defined $jobdb_id) {
332 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
333 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
334 my $res = $main::job_db->exec_statement($sql_statement);
335 }
337 my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $target);
338 if( defined $jobdb_id ) {
339 &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
340 }
341 my $out_msg = &create_xml_string($out_hash);
342 my @out_msg_l = ( $out_msg );
343 return @out_msg_l;
344 }
347 sub trigger_action_faireboot {
348 my ($msg, $msg_hash, $session_id) = @_;
349 my $macaddress = @{$msg_hash->{target}}[0];
350 my $source = @{$msg_hash->{source}}[0];
352 my @out_msg_l;
353 $msg =~ s/<header>gosa_trigger_action_faireboot<\/header>/<header>trigger_action_faireboot<\/header>/;
354 push(@out_msg_l, $msg);
356 &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id);
357 &main::change_fai_state('localboot', \@{$msg_hash->{target}}, $session_id);
359 # delete all jobs from jobqueue which correspond to fai
360 my $sql_statement = "DELETE FROM $main::job_queue_tn WHERE (macaddress='$macaddress' AND ".
361 "status='processing')";
362 $main::job_db->del_dbentry($sql_statement );
364 return @out_msg_l;
365 }
368 sub trigger_action_lock {
369 my ($msg, $msg_hash, $session_id) = @_;
370 my $macaddress = @{$msg_hash->{target}}[0];
371 my $source = @{$msg_hash->{source}}[0];
373 &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id);
374 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
375 if( defined $jobdb_id) {
376 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
377 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
378 my $res = $main::job_db->exec_statement($sql_statement);
379 }
381 my @out_msg_l;
382 return @out_msg_l;
383 }
386 sub trigger_action_activate {
387 my ($msg, $msg_hash, $session_id) = @_;
388 my $macaddress = @{$msg_hash->{target}}[0];
389 my $source = @{$msg_hash->{source}}[0];
391 &main::change_goto_state('active', \@{$msg_hash->{target}}, $session_id);
392 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
393 if( defined $jobdb_id) {
394 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
395 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
396 my $res = $main::job_db->exec_statement($sql_statement);
397 }
399 my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $macaddress);
400 if( exists $msg_hash->{'jobdb_id'} ) {
401 &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
402 }
403 my $out_msg = &create_xml_string($out_hash);
405 return ( $out_msg );
406 }
409 sub trigger_action_localboot {
410 my ($msg, $msg_hash, $session_id) = @_;
411 $msg =~ s/<header>gosa_trigger_action_localboot<\/header>/<header>trigger_action_localboot<\/header>/;
412 &main::change_fai_state('localboot', \@{$msg_hash->{target}}, $session_id);
413 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
414 if( defined $jobdb_id) {
415 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
416 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
417 my $res = $main::job_db->exec_statement($sql_statement);
418 }
420 my @out_msg_l = ($msg);
421 return @out_msg_l;
422 }
425 sub trigger_action_halt {
426 my ($msg, $msg_hash, $session_id) = @_;
427 $msg =~ s/<header>gosa_trigger_action_halt<\/header>/<header>trigger_action_halt<\/header>/;
429 &main::change_fai_state('halt', \@{$msg_hash->{target}}, $session_id);
430 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
431 if( defined $jobdb_id) {
432 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
433 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
434 my $res = $main::job_db->exec_statement($sql_statement);
435 }
437 my @out_msg_l = ($msg);
438 return @out_msg_l;
439 }
442 sub trigger_action_reboot {
443 my ($msg, $msg_hash, $session_id) = @_;
444 $msg =~ s/<header>gosa_trigger_action_reboot<\/header>/<header>trigger_action_reboot<\/header>/;
446 &main::change_fai_state('reboot', \@{$msg_hash->{target}}, $session_id);
447 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
448 if( defined $jobdb_id) {
449 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
450 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
451 my $res = $main::job_db->exec_statement($sql_statement);
452 }
454 my @out_msg_l = ($msg);
455 return @out_msg_l;
456 }
459 sub trigger_action_memcheck {
460 my ($msg, $msg_hash, $session_id) = @_ ;
461 $msg =~ s/<header>gosa_trigger_action_memcheck<\/header>/<header>trigger_action_memcheck<\/header>/;
463 &main::change_fai_state('memcheck', \@{$msg_hash->{target}}, $session_id);
464 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
465 if( defined $jobdb_id) {
466 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
467 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
468 my $res = $main::job_db->exec_statement($sql_statement);
469 }
471 my @out_msg_l = ($msg);
472 return @out_msg_l;
473 }
476 sub trigger_action_reinstall {
477 my ($msg, $msg_hash, $session_id) = @_;
478 $msg =~ s/<header>gosa_trigger_action_reinstall<\/header>/<header>trigger_action_reinstall<\/header>/;
480 &main::change_fai_state('reinstall', \@{$msg_hash->{target}}, $session_id);
482 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
483 my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
484 my @out_msg_l = ($wake_msg, $msg);
485 return @out_msg_l;
486 }
489 sub trigger_action_update {
490 my ($msg, $msg_hash, $session_id) = @_;
491 $msg =~ s/<header>gosa_trigger_action_update<\/header>/<header>trigger_action_update<\/header>/;
493 &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
495 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
496 my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
497 my @out_msg_l = ($wake_msg, $msg);
498 return @out_msg_l;
499 }
502 sub trigger_action_instant_update {
503 my ($msg, $msg_hash, $session_id) = @_;
504 $msg =~ s/<header>gosa_trigger_action_instant_update<\/header>/<header>trigger_action_instant_update<\/header>/;
506 &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
508 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
509 if( defined $jobdb_id) {
510 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
511 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
512 my $res = $main::job_db->exec_statement($sql_statement);
513 }
515 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
516 my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
517 my @out_msg_l = ($wake_msg, $msg);
518 return @out_msg_l;
519 }
522 sub trigger_action_sysinfo {
523 my ($msg, $msg_hash, $session_id) = @_;
524 $msg =~ s/<header>gosa_trigger_action_sysinfo<\/header>/<header>trigger_action_sysinfo<\/header>/;
526 &main::change_fai_state('sysinfo', \@{$msg_hash->{target}}, $session_id);
527 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
528 if( defined $jobdb_id) {
529 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
530 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
531 my $res = $main::job_db->exec_statement($sql_statement);
532 }
534 my @out_msg_l = ($msg);
535 return @out_msg_l;
536 }
539 sub new_key_for_client {
540 my ($msg, $msg_hash, $session_id) = @_;
542 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
543 if( defined $jobdb_id) {
544 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
545 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
546 my $res = $main::job_db->exec_statement($sql_statement);
547 }
549 $msg =~ s/<header>gosa_new_key_for_client<\/header>/<header>new_key<\/header>/;
550 my @out_msg_l = ($msg);
551 return @out_msg_l;
552 }
555 sub trigger_action_rescan {
556 my ($msg, $msg_hash, $session_id) = @_;
558 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
559 if( defined $jobdb_id) {
560 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
561 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
562 my $res = $main::job_db->exec_statement($sql_statement);
563 }
566 $msg =~ s/<header>gosa_trigger_action_rescan<\/header>/<header>trigger_action_rescan<\/header>/;
567 my @out_msg_l = ($msg);
568 return @out_msg_l;
569 }
572 sub trigger_action_wake {
573 my ($msg, $msg_hash, $session_id) = @_;
575 my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
576 if( defined $jobdb_id) {
577 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'";
578 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
579 my $res = $main::job_db->exec_statement($sql_statement);
580 }
583 my %data = ( 'macAddress' => \@{$msg_hash->{target}} );
584 my $out_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
585 my @out_msg_l = ($out_msg);
586 return @out_msg_l;
587 }
590 1;