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