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 use utf8;
  44
  45 BEGIN {}
  46
  47 END {}
  48
  49 ### Start ######################################################################
  50
  51 #&main::read_configfile($main::cfg_file, %cfg_defaults);
  52
  53 sub get_events {
  54     return \@events;
  55 }
  56
  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;
  62
  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'}}; }
  69
  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     }
  76
  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>");
  87
  88     }
  89
  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     }
 114
 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;
 121
 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);
 126
 127         if(0 == keys(%{$db_res})) {
 128
 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     }
 142
 143     return @out_msg_l;
 144 }
 145
 146
 147 sub recreate_fai_server_db {
 148     my ($msg, $msg_hash, $session_id) = @_ ;
 149     my $out_msg;
 150
 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     }
 157
 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);
 161
 162     my @out_msg_l = ( $out_msg );
 163     return @out_msg_l;
 164 }
 165
 166
 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];
 173
 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     }
 180
 181     $header =~ s/^gosa_//;
 182
 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);
 185
 186     my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
 187     $out_msg .= &db_res2xml($res);
 188     $out_msg .= "</xml>";
 189
 190     my @out_msg_l = ( $out_msg );
 191     return @out_msg_l;
 192 }
 193
 194
 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];
 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     my $usr = @{$msg_hash->{'usr'}}[0];
 209     $header =~ s/^gosa_//;
 210
 211     my $sql_statement = "SELECT * FROM known_clients WHERE login LIKE '%$usr%'";
 212     my $res = $main::known_clients_db->select_dbentry($sql_statement);
 213
 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;
 219
 220 }
 221
 222
 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     }
 232
 233     $out_msg =~ s/<header>gosa_/<header>/;
 234
 235     my @out_msg_l = ( $out_msg );
 236     return @out_msg_l;
 237 }
 238
 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];
 244
 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 }
 249
 250
 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];
 256
 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              }
 266
 267              %data= ('ip' => $address, 'mac' => $mac);
 268      } else {
 269              %data= ('ip' => '', 'mac' => '');
 270      }
 271
 272      my $out_msg = &build_msg("network_completition", $target, 'GOSA', \%data );
 273
 274      return ( $out_msg );
 275 }
 276
 277
 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     }
 289
 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);
 295
 296     my @out_msg_l = ( $out_msg );
 297     return @out_msg_l;
 298
 299 }
 300
 301
 302 sub trigger_reload_ldap_config {
 303     my ($msg, $msg_hash, $session_id) = @_ ;
 304     my $target = @{$msg_hash->{target}}[0];
 305
 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     }
 312
 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 }
 322
 323
 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];
 329
 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     }
 336
 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 }
 345
 346
 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];
 351
 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);
 355
 356     &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id);
 357     &main::change_fai_state('localboot', \@{$msg_hash->{target}}, $session_id);
 358
 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 );
 363
 364     return @out_msg_l;
 365 }
 366
 367
 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];
 372
 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     }
 380
 381     my @out_msg_l;
 382     return @out_msg_l;
 383 }
 384
 385
 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];
 390
 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     }
 398
 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);
 404
 405     return ( $out_msg );
 406 }
 407
 408
 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     }
 419
 420     my @out_msg_l = ($msg);
 421     return @out_msg_l;
 422 }
 423
 424
 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>/;
 428
 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     }
 436
 437     my @out_msg_l = ($msg);
 438     return @out_msg_l;
 439 }
 440
 441
 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>/;
 445
 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     }
 453
 454     my @out_msg_l = ($msg);
 455     return @out_msg_l;
 456 }
 457
 458
 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>/;
 462
 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     }
 470
 471     my @out_msg_l = ($msg);
 472     return @out_msg_l;
 473 }
 474
 475
 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>/;
 479
 480     &main::change_fai_state('reinstall', \@{$msg_hash->{target}}, $session_id);
 481
 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 }
 487
 488
 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>/;
 492
 493     &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
 494
 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 }
 500
 501
 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>/;
 505
 506     &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
 507
 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     }
 514
 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 }
 520
 521
 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>/;
 525
 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     }
 533
 534     my @out_msg_l = ($msg);
 535     return @out_msg_l;
 536 }
 537
 538
 539 sub new_key_for_client {
 540     my ($msg, $msg_hash, $session_id) = @_;
 541
 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     }
 548
 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 }
 553
 554
 555 sub trigger_action_rescan {
 556     my ($msg, $msg_hash, $session_id) = @_;
 557
 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     }
 564
 565
 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 }
 570
 571
 572 sub trigger_action_wake {
 573     my ($msg, $msg_hash, $session_id) = @_;
 574
 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     }
 581
 582
 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 }
 588
 589
 590 1;