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