gosa-si/server/events/gosaTriggered.pm

   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     "recreate_fai_release_db",
  32     "recreate_packages_list_db",
  33     "send_user_msg",
  34     "get_available_kernel",
  35     );
  36 @EXPORT = @events;
  37
  38 use strict;
  39 use warnings;
  40 use GOSA::GosaSupportDaemon;
  41 use Data::Dumper;
  42 use Crypt::SmbHash;
  43 use Net::ARP;
  44 use Net::Ping;
  45 use Socket;
  46
  47 BEGIN {}
  48
  49 END {}
  50
  51 ### Start ######################################################################
  52
  53 #&main::read_configfile($main::cfg_file, %cfg_defaults);
  54
  55 sub get_events {
  56     return \@events;
  57 }
  58
  59 sub send_user_msg {
  60     my ($msg, $msg_hash, $session_id) = @_ ;
  61     my $header = @{$msg_hash->{'header'}}[0];
  62     my $source = @{$msg_hash->{'source'}}[0];
  63     my $target = @{$msg_hash->{'target'}}[0];
  64
  65     #my $subject = &decode_base64(@{$msg_hash->{'subject'}}[0]);
  66     my $subject = @{$msg_hash->{'subject'}}[0];
  67     my $from = @{$msg_hash->{'from'}}[0];
  68     my $to = @{$msg_hash->{'to'}}[0];
  69     my $delivery_time = @{$msg_hash->{'delivery_time'}}[0];
  70     #my $message = &decode_base64(@{$msg_hash->{'message'}}[0]);
  71     my $message = @{$msg_hash->{'message'}}[0];
  72
  73     # keep job queue uptodate if necessary
  74     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
  75     if( defined $jobdb_id) {
  76         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
  77         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
  78         my $res = $main::job_db->exec_statement($sql_statement);
  79     }
  80
  81     # error handling
  82     if (not $delivery_time =~ /^\d{14}$/) {
  83         my $error_string = "delivery_time '$delivery_time' is not a valid timestamp, please use format 'yyyymmddhhmmss'";
  84         &main::daemon_log("$session_id ERROR: $error_string", 1);
  85         return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
  86     }
  87
  88     # add incoming message to messaging_db
  89     my $new_msg_id = 1;
  90     my $new_msg_id_sql = "SELECT MAX(id) FROM $main::messaging_tn";
  91     my $new_msg_id_res = $main::messaging_db->exec_statement($new_msg_id_sql);
  92     if (defined @{@{$new_msg_id_res}[0]}[0] ) {
  93         $new_msg_id = int(@{@{$new_msg_id_res}[0]}[0]);
  94         $new_msg_id += 1;
  95     }
  96
  97     my $func_dic = {table=>$main::messaging_tn,
  98         primkey=>[],
  99         id=>$new_msg_id,
 100         subject=>$subject,
 101         message_from=>$from,
 102         message_to=>$to,
 103         flag=>"n",
 104         direction=>"in",
 105         delivery_time=>$delivery_time,
 106         message=>$message,
 107         timestamp=>&get_time(),
 108     };
 109     my $res = $main::messaging_db->add_dbentry($func_dic);
 110     if (not $res == 0) {
 111         &main::daemon_log("$session_id ERROR: gosaTriggered.pm: cannot add message to message_db: $res", 1);
 112     } else {
 113         &main::daemon_log("$session_id INFO: gosaTriggered.pm: message with subject '$subject' successfully added to message_db", 5);
 114     }
 115
 116     return;
 117 }
 118
 119 sub send_user_msg_OLD {
 120     my ($msg, $msg_hash, $session_id) = @_ ;
 121     my @out_msg_l;
 122     my @user_list;
 123     my @group_list;
 124
 125     my $header = @{$msg_hash->{'header'}}[0];
 126     my $source = @{$msg_hash->{'source'}}[0];
 127     my $target = @{$msg_hash->{'target'}}[0];
 128     my $message = @{$msg_hash->{'message'}}[0];
 129     if( exists $msg_hash->{'user'} ) { @user_list = @{$msg_hash->{'user'}}; }
 130     if( exists $msg_hash->{'group'} ) { @group_list = @{$msg_hash->{'group'}}; }
 131
 132     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 133     if( defined $jobdb_id) {
 134         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 135         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 136         my $res = $main::job_db->exec_statement($sql_statement);
 137     }
 138
 139     # error handling
 140     if( not @user_list && not @group_list ) {
 141         &main::daemon_log("$session_id WARNING: no user-tag or a group-tag specified in 'send_user_msg'", 3);
 142         return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
 143                 "<error_string>no user-tag or a group-tag specified in 'send_user_msg'</error_string></xml>");
 144     }
 145     if( not defined $message ) {
 146         &main::daemon_log("$session_id WARNING: no message-tag specified in 'send_user_msg'", 3);
 147         return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
 148                 "<error_string>no message-tag specified in 'send_user_msg'</error_string></xml>");
 149
 150     }
 151
 152     # resolve groups to users
 153     my $ldap_handle = &main::get_ldap_handle($session_id);
 154     if( @group_list ) {
 155         if( not defined $ldap_handle ) {
 156             &main::daemon_log("$session_id ERROR: cannot connect to ldap", 1);
 157             return ();
 158         }
 159         foreach my $group (@group_list) {   # Perform search
 160             my $mesg = $ldap_handle->search(
 161                     base => $main::ldap_base,
 162                     scope => 'sub',
 163                     attrs => ['memberUid'],
 164                     filter => "(&(objectClass=posixGroup)(cn=$group)(memberUid=*))");
 165             if($mesg->code) {
 166                 &main::daemon_log($mesg->error, 1);
 167                 return ();
 168             }
 169             my $entry= $mesg->entry(0);
 170             my @users= $entry->get_value("memberUid");
 171             foreach my $user (@users) { push(@user_list, $user); }
 172         }
 173     }
 174
 175     # drop multiple users in @user_list
 176     my %seen = ();
 177     foreach my $user (@user_list) {
 178         $seen{$user}++;
 179     }
 180     @user_list = keys %seen;
 181
 182     # build xml messages sended to client where user is logged in
 183     foreach my $user (@user_list) {
 184         my $sql_statement = "SELECT * FROM $main::login_users_tn WHERE user='$user'";
 185         my $db_res = $main::login_users_db->select_dbentry($sql_statement);
 186
 187         if(0 == keys(%{$db_res})) {
 188
 189         } else {
 190             while( my($hit, $content) = each %{$db_res} ) {
 191                 my $out_hash = &create_xml_hash('send_user_msg', $main::server_address, $content->{'client'});
 192                 &add_content2xml_hash($out_hash, 'message', $message);
 193                 &add_content2xml_hash($out_hash, 'user', $user);
 194                 if( exists $msg_hash->{'jobdb_id'} ) {
 195                     &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 196                 }
 197                 my $out_msg = &create_xml_string($out_hash);
 198                 push(@out_msg_l, $out_msg);
 199             }
 200         }
 201     }
 202
 203     return @out_msg_l;
 204 }
 205
 206
 207 sub recreate_fai_server_db {
 208     my ($msg, $msg_hash, $session_id) = @_ ;
 209     my $out_msg;
 210
 211     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 212     if( defined $jobdb_id) {
 213         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 214         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 215         my $res = $main::job_db->exec_statement($sql_statement);
 216     }
 217
 218     $main::fai_server_db->create_table("new_fai_server", \@main::fai_server_col_names);
 219     &main::create_fai_server_db("new_fai_server",undef,"dont", $session_id);
 220     $main::fai_server_db->move_table("new_fai_server", $main::fai_server_tn);
 221
 222     my @out_msg_l = ( $out_msg );
 223     return @out_msg_l;
 224 }
 225
 226
 227 sub recreate_fai_release_db {
 228     my ($msg, $msg_hash, $session_id) = @_ ;
 229     my $out_msg;
 230
 231     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 232     if( defined $jobdb_id) {
 233         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 234         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 235         my $res = $main::job_db->exec_statement($sql_statement);
 236     }
 237
 238     $main::fai_release_db->create_table("new_fai_release", \@main::fai_release_col_names);
 239     &main::create_fai_release_db("new_fai_release", $session_id);
 240     $main::fai_release_db->move_table("new_fai_release", $main::fai_release_tn);
 241
 242     my @out_msg_l = ( $out_msg );
 243     return @out_msg_l;
 244 }
 245
 246
 247 sub recreate_packages_list_db {
 248         my ($msg, $msg_hash, $session_id) = @_ ;
 249         my $out_msg;
 250
 251         my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 252         if( defined $jobdb_id) {
 253                 my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 254                 &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 255                 my $res = $main::job_db->exec_statement($sql_statement);
 256         }
 257
 258         &main::create_packages_list_db;
 259
 260         my @out_msg_l = ( $out_msg );
 261         return @out_msg_l;
 262 }
 263
 264
 265 sub get_login_usr_for_client {
 266     my ($msg, $msg_hash, $session_id) = @_ ;
 267     my $header = @{$msg_hash->{'header'}}[0];
 268     my $source = @{$msg_hash->{'source'}}[0];
 269     my $target = @{$msg_hash->{'target'}}[0];
 270     my $client = @{$msg_hash->{'client'}}[0];
 271
 272     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 273     if( defined $jobdb_id) {
 274         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 275         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 276         my $res = $main::job_db->exec_statement($sql_statement);
 277     }
 278
 279     $header =~ s/^gosa_//;
 280
 281     my $sql_statement = "SELECT * FROM known_clients WHERE hostname='$client' OR macaddress LIKE '$client'";
 282     my $res = $main::known_clients_db->select_dbentry($sql_statement);
 283
 284     my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
 285     $out_msg .= &db_res2xml($res);
 286     $out_msg .= "</xml>";
 287
 288     my @out_msg_l = ( $out_msg );
 289     return @out_msg_l;
 290 }
 291
 292
 293 sub get_client_for_login_usr {
 294     my ($msg, $msg_hash, $session_id) = @_ ;
 295     my $header = @{$msg_hash->{'header'}}[0];
 296     my $source = @{$msg_hash->{'source'}}[0];
 297     my $target = @{$msg_hash->{'target'}}[0];
 298
 299     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 300     if( defined $jobdb_id) {
 301         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 302         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 303         my $res = $main::job_db->exec_statement($sql_statement);
 304     }
 305
 306     my $usr = @{$msg_hash->{'usr'}}[0];
 307     $header =~ s/^gosa_//;
 308
 309     my $sql_statement = "SELECT * FROM known_clients WHERE login LIKE '%$usr%'";
 310     my $res = $main::known_clients_db->select_dbentry($sql_statement);
 311
 312     my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
 313     $out_msg .= &db_res2xml($res);
 314     $out_msg .= "</xml>";
 315     my @out_msg_l = ( $out_msg );
 316     return @out_msg_l;
 317
 318 }
 319
 320
 321 sub ping {
 322     my ($msg, $msg_hash, $session_id) = @_ ;
 323     my $out_msg = $msg;
 324     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 325     if( defined $jobdb_id) {
 326         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 327         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 328         my $res = $main::job_db->exec_statement($sql_statement);
 329     }
 330
 331     $out_msg =~ s/<header>gosa_/<header>/;
 332
 333     my @out_msg_l = ( $out_msg );
 334     return @out_msg_l;
 335 }
 336
 337 sub gen_smb_hash {
 338      my ($msg, $msg_hash, $session_id) = @_ ;
 339      my $source = @{$msg_hash->{source}}[0];
 340      my $target = @{$msg_hash->{target}}[0];
 341      my $password = @{$msg_hash->{password}}[0];
 342
 343      my %data= ('hash' => join(q[:], ntlmgen $password));
 344      my $out_msg = &build_msg("gen_smb_hash", $target, 'GOSA', \%data );
 345      return ( $out_msg );
 346 }
 347
 348
 349 sub network_completition {
 350      my ($msg, $msg_hash, $session_id) = @_ ;
 351      my $source = @{$msg_hash->{source}}[0];
 352      my $target = @{$msg_hash->{target}}[0];
 353      my $name = @{$msg_hash->{hostname}}[0];
 354
 355      # Can we resolv the name?
 356      my %data;
 357      if (inet_aton($name)){
 358              my $address = inet_ntoa(inet_aton($name));
 359              my $p = Net::Ping->new('tcp');
 360              my $mac= "";
 361              if ($p->ping($address, 1)){
 362                $mac = Net::ARP::arp_lookup("", $address);
 363              }
 364
 365              %data= ('ip' => $address, 'mac' => $mac);
 366      } else {
 367              %data= ('ip' => '', 'mac' => '');
 368      }
 369
 370      my $out_msg = &build_msg("network_completition", $target, 'GOSA', \%data );
 371
 372      return ( $out_msg );
 373 }
 374
 375
 376 sub detect_hardware {
 377     my ($msg, $msg_hash, $session_id) = @_ ;
 378     # just forward msg to client, but dont forget to split off 'gosa_' in header
 379     my $source = @{$msg_hash->{source}}[0];
 380     my $target = @{$msg_hash->{target}}[0];
 381     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 382     if( defined $jobdb_id) {
 383         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 384         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 385         my $res = $main::job_db->exec_statement($sql_statement);
 386     }
 387
 388     my $out_hash = &create_xml_hash("detect_hardware", $source, $target);
 389     if( defined $jobdb_id ) {
 390         &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
 391     }
 392     my $out_msg = &create_xml_string($out_hash);
 393
 394     my @out_msg_l = ( $out_msg );
 395     return @out_msg_l;
 396
 397 }
 398
 399
 400 sub trigger_reload_ldap_config {
 401     my ($msg, $msg_hash, $session_id) = @_ ;
 402     my $target = @{$msg_hash->{target}}[0];
 403
 404     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 405     if( defined $jobdb_id) {
 406         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 407         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 408         my $res = $main::job_db->exec_statement($sql_statement);
 409     }
 410
 411     my $out_hash = &create_xml_hash("reload_ldap_config", $main::server_address, $main::server_address, $target);
 412     if( defined ) {
 413         &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
 414     }
 415     my $out_msg = &create_xml_string($out_hash);
 416     my @out_msg_l;
 417     push(@out_msg_l, $out_msg);
 418     return @out_msg_l;
 419 }
 420
 421
 422 sub set_activated_for_installation {
 423     my ($msg, $msg_hash, $session_id) = @_;
 424     my $header = @{$msg_hash->{header}}[0];
 425     my $source = @{$msg_hash->{source}}[0];
 426     my $target = @{$msg_hash->{target}}[0];
 427         my @out_msg_l;
 428
 429         # update status of job
 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     }
 436
 437         # create set_activated_for_installation message for delivery
 438     my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $target);
 439     if( defined $jobdb_id ) {
 440         &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
 441     }
 442     my $out_msg = &create_xml_string($out_hash);
 443         push(@out_msg_l, $out_msg);
 444
 445     return @out_msg_l;
 446 }
 447
 448
 449 sub trigger_action_faireboot {
 450     my ($msg, $msg_hash, $session_id) = @_;
 451     my $macaddress = @{$msg_hash->{target}}[0];
 452     my $source = @{$msg_hash->{source}}[0];
 453
 454     my @out_msg_l;
 455     $msg =~ s/<header>gosa_trigger_action_faireboot<\/header>/<header>trigger_action_faireboot<\/header>/;
 456     push(@out_msg_l, $msg);
 457
 458     &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id);
 459         &main::change_fai_state('install', \@{$msg_hash->{target}}, $session_id);
 460
 461     # delete all jobs from jobqueue which correspond to fai
 462     my $sql_statement = "DELETE FROM $main::job_queue_tn WHERE (macaddress='$macaddress' AND ".
 463         "status='processing')";
 464     $main::job_db->del_dbentry($sql_statement );
 465
 466     return @out_msg_l;
 467 }
 468
 469
 470 sub trigger_action_lock {
 471     my ($msg, $msg_hash, $session_id) = @_;
 472     my $macaddress = @{$msg_hash->{target}}[0];
 473     my $source = @{$msg_hash->{source}}[0];
 474
 475     &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id);
 476     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 477     if( defined $jobdb_id) {
 478         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 479         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 480         my $res = $main::job_db->exec_statement($sql_statement);
 481     }
 482
 483     my @out_msg_l;
 484     return @out_msg_l;
 485 }
 486
 487
 488 sub trigger_action_activate {
 489     my ($msg, $msg_hash, $session_id) = @_;
 490     my $macaddress = @{$msg_hash->{target}}[0];
 491     my $source = @{$msg_hash->{source}}[0];
 492
 493     &main::change_goto_state('active', \@{$msg_hash->{target}}, $session_id);
 494     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 495     if( defined $jobdb_id) {
 496         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 497         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 498         my $res = $main::job_db->exec_statement($sql_statement);
 499     }
 500
 501     my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $macaddress);
 502     if( exists $msg_hash->{'jobdb_id'} ) {
 503         &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 504     }
 505     my $out_msg = &create_xml_string($out_hash);
 506
 507     return ( $out_msg );
 508 }
 509
 510
 511 sub trigger_action_localboot {
 512     my ($msg, $msg_hash, $session_id) = @_;
 513     $msg =~ s/<header>gosa_trigger_action_localboot<\/header>/<header>trigger_action_localboot<\/header>/;
 514     &main::change_fai_state('localboot', \@{$msg_hash->{target}}, $session_id);
 515     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 516     if( defined $jobdb_id) {
 517         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 518         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 519         my $res = $main::job_db->exec_statement($sql_statement);
 520     }
 521
 522     my @out_msg_l = ($msg);
 523     return @out_msg_l;
 524 }
 525
 526
 527 sub trigger_action_halt {
 528     my ($msg, $msg_hash, $session_id) = @_;
 529     $msg =~ s/<header>gosa_trigger_action_halt<\/header>/<header>trigger_action_halt<\/header>/;
 530
 531     &main::change_fai_state('halt', \@{$msg_hash->{target}}, $session_id);
 532     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 533     if( defined $jobdb_id) {
 534         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 535         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 536         my $res = $main::job_db->exec_statement($sql_statement);
 537     }
 538
 539     my @out_msg_l = ($msg);
 540     return @out_msg_l;
 541 }
 542
 543
 544 sub trigger_action_reboot {
 545     my ($msg, $msg_hash, $session_id) = @_;
 546     $msg =~ s/<header>gosa_trigger_action_reboot<\/header>/<header>trigger_action_reboot<\/header>/;
 547
 548     &main::change_fai_state('reboot', \@{$msg_hash->{target}}, $session_id);
 549     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 550     if( defined $jobdb_id) {
 551         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 552         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 553         my $res = $main::job_db->exec_statement($sql_statement);
 554     }
 555
 556     my @out_msg_l = ($msg);
 557     return @out_msg_l;
 558 }
 559
 560
 561 sub trigger_action_memcheck {
 562     my ($msg, $msg_hash, $session_id) = @_ ;
 563     $msg =~ s/<header>gosa_trigger_action_memcheck<\/header>/<header>trigger_action_memcheck<\/header>/;
 564
 565     &main::change_fai_state('memcheck', \@{$msg_hash->{target}}, $session_id);
 566     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 567     if( defined $jobdb_id) {
 568         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 569         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 570         my $res = $main::job_db->exec_statement($sql_statement);
 571     }
 572
 573     my @out_msg_l = ($msg);
 574     return @out_msg_l;
 575 }
 576
 577
 578 sub trigger_action_reinstall {
 579     my ($msg, $msg_hash, $session_id) = @_;
 580     $msg =~ s/<header>gosa_trigger_action_reinstall<\/header>/<header>trigger_action_reinstall<\/header>/;
 581
 582     &main::change_fai_state('reinstall', \@{$msg_hash->{target}}, $session_id);
 583
 584     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 585     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 586     my @out_msg_l = ($wake_msg, $msg);
 587     return @out_msg_l;
 588 }
 589
 590
 591 sub trigger_action_update {
 592     my ($msg, $msg_hash, $session_id) = @_;
 593     $msg =~ s/<header>gosa_trigger_action_update<\/header>/<header>trigger_action_update<\/header>/;
 594
 595     &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
 596
 597     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 598     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 599     my @out_msg_l = ($wake_msg, $msg);
 600     return @out_msg_l;
 601 }
 602
 603
 604 sub trigger_action_instant_update {
 605     my ($msg, $msg_hash, $session_id) = @_;
 606     $msg =~ s/<header>gosa_trigger_action_instant_update<\/header>/<header>trigger_action_instant_update<\/header>/;
 607
 608     &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
 609
 610     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 611     if( defined $jobdb_id) {
 612         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 613         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 614         my $res = $main::job_db->exec_statement($sql_statement);
 615     }
 616
 617     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 618     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 619     my @out_msg_l = ($wake_msg, $msg);
 620     return @out_msg_l;
 621 }
 622
 623
 624 sub trigger_action_sysinfo {
 625     my ($msg, $msg_hash, $session_id) = @_;
 626     $msg =~ s/<header>gosa_trigger_action_sysinfo<\/header>/<header>trigger_action_sysinfo<\/header>/;
 627
 628     &main::change_fai_state('sysinfo', \@{$msg_hash->{target}}, $session_id);
 629     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 630     if( defined $jobdb_id) {
 631         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 632         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 633         my $res = $main::job_db->exec_statement($sql_statement);
 634     }
 635
 636     my @out_msg_l = ($msg);
 637     return @out_msg_l;
 638 }
 639
 640
 641 sub new_key_for_client {
 642     my ($msg, $msg_hash, $session_id) = @_;
 643
 644     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 645     if( defined $jobdb_id) {
 646         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 647         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 648         my $res = $main::job_db->exec_statement($sql_statement);
 649     }
 650
 651     $msg =~ s/<header>gosa_new_key_for_client<\/header>/<header>new_key<\/header>/;
 652     my @out_msg_l = ($msg);
 653     return @out_msg_l;
 654 }
 655
 656
 657 sub trigger_action_rescan {
 658     my ($msg, $msg_hash, $session_id) = @_;
 659
 660     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 661     if( defined $jobdb_id) {
 662         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 663         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 664         my $res = $main::job_db->exec_statement($sql_statement);
 665     }
 666
 667
 668     $msg =~ s/<header>gosa_trigger_action_rescan<\/header>/<header>trigger_action_rescan<\/header>/;
 669     my @out_msg_l = ($msg);
 670     return @out_msg_l;
 671 }
 672
 673
 674 sub trigger_action_wake {
 675     my ($msg, $msg_hash, $session_id) = @_;
 676
 677     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 678     if( defined $jobdb_id) {
 679         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 680         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 681         my $res = $main::job_db->exec_statement($sql_statement);
 682     }
 683
 684
 685     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 686     my $out_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 687     my @out_msg_l = ($out_msg);
 688     return @out_msg_l;
 689 }
 690
 691
 692 sub get_available_kernel {
 693         my ($msg, $msg_hash, $session_id) = @_;
 694
 695         my $source = @{$msg_hash->{'source'}}[0];
 696         my $target = @{$msg_hash->{'target'}}[0];
 697         my $release= @{$msg_hash->{'release'}}[0];
 698
 699         my @kernel;
 700         # Get Kernel packages for release
 701         my $sql_statement = "SELECT * FROM $main::packages_list_tn WHERE distribution='$release' AND package LIKE 'linux\-image\-%'";
 702         my $res_hash = $main::packages_list_db->select_dbentry($sql_statement);
 703         my %data;
 704         my $i=1;
 705
 706         foreach my $package (keys %{$res_hash}) {
 707                 $data{"answer".$i++}= $data{"answer".$i++}= ${$res_hash}{$package}->{'package'};
 708         }
 709         $data{"answer".$i++}= "default";
 710
 711         my $out_msg = &build_msg("get_available_kernel", $target, "GOSA", \%data);
 712         return ( $out_msg );
 713 }
 714
 715
 716 1;