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