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     "new_ping",
  12     "network_completition",
  13     "set_activated_for_installation",
  14     "new_key_for_client",
  15     "detect_hardware",
  16     "get_login_usr",
  17     "get_login_client",
  18     "trigger_action_localboot",
  19     "trigger_action_faireboot",
  20     "trigger_action_reboot",
  21     "trigger_action_activate",
  22     "trigger_action_lock",
  23     "trigger_action_halt",
  24     "trigger_action_update",
  25     "trigger_action_reinstall",
  26     "trigger_action_memcheck",
  27     "trigger_action_sysinfo",
  28     "trigger_action_instant_update",
  29     "trigger_action_rescan",
  30     "trigger_action_wake",
  31     "recreate_fai_server_db",
  32     "recreate_fai_release_db",
  33     "recreate_packages_list_db",
  34     "send_user_msg",
  35     "get_available_kernel",
  36         "trigger_activate_new",
  37     );
  38 @EXPORT = @events;
  39
  40 use strict;
  41 use warnings;
  42 use GOSA::GosaSupportDaemon;
  43 use Data::Dumper;
  44 use Crypt::SmbHash;
  45 use Net::ARP;
  46 use Net::Ping;
  47 use Socket;
  48 use Time::HiRes qw( usleep);
  49
  50 BEGIN {}
  51
  52 END {}
  53
  54 ### Start ######################################################################
  55
  56 #&main::read_configfile($main::cfg_file, %cfg_defaults);
  57
  58 sub get_events {
  59     return \@events;
  60 }
  61
  62 sub send_user_msg {
  63
  64 # msg from gosa
  65 # <xml><header>gosa_send_user_msg</header><source>GOSA</source><target>GOSA</target>
  66 # <timestamp>20080429151605</timestamp>
  67 # <users>andreas.rettenberger</users>
  68 # <subject>hallo</subject>
  69 # <message>test</message>
  70 # <macaddress>GOSA</macaddress>
  71 # </xml>
  72
  73     my ($msg, $msg_hash, $session_id) = @_ ;
  74     my $header = @{$msg_hash->{'header'}}[0];
  75     my $source = @{$msg_hash->{'source'}}[0];
  76     my $target = @{$msg_hash->{'target'}}[0];
  77
  78     #my $subject = &decode_base64(@{$msg_hash->{'subject'}}[0]);
  79     my $subject = @{$msg_hash->{'subject'}}[0];
  80     my $from = @{$msg_hash->{'from'}}[0];
  81     my @users = @{$msg_hash->{'users'}};
  82         my @groups = @{$msg_hash->{'groups'}}[0];
  83     my $delivery_time = @{$msg_hash->{'delivery_time'}}[0];
  84     #my $message = &decode_base64(@{$msg_hash->{'message'}}[0]);
  85     my $message = @{$msg_hash->{'message'}}[0];
  86
  87     # keep job queue uptodate if necessary
  88     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
  89     if( defined $jobdb_id) {
  90         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
  91         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
  92         my $res = $main::job_db->exec_statement($sql_statement);
  93     }
  94
  95     # error handling
  96     if (not $delivery_time =~ /^\d{14}$/) {
  97         my $error_string = "delivery_time '$delivery_time' is not a valid timestamp, please use format 'yyyymmddhhmmss'";
  98         &main::daemon_log("$session_id ERROR: $error_string", 1);
  99         return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
 100     }
 101
 102     # add incoming message to messaging_db
 103     my $new_msg_id = 1;
 104         my $new_msg_id_sql = "SELECT MAX(CAST(id AS INTEGER)) FROM $main::messaging_tn";
 105     my $new_msg_id_res = $main::messaging_db->exec_statement($new_msg_id_sql);
 106     if (defined @{@{$new_msg_id_res}[0]}[0] ) {
 107         $new_msg_id = int(@{@{$new_msg_id_res}[0]}[0]);
 108         $new_msg_id += 1;
 109     }
 110
 111         # highlight user name and group name
 112         my @receiver_l;
 113         @users = map(push(@receiver_l, "u_$_"), @users);
 114         #@groups = map(push(@receiver_l, "g_$_"), @groups);
 115 # TODO
 116 # handling, was passiert wenn in einer liste nix drin steht
 117 # handling von groups hinzufügen
 118
 119
 120     my $func_dic = {table=>$main::messaging_tn,
 121         primkey=>[],
 122         id=>$new_msg_id,
 123         subject=>$subject,
 124         message_from=>$from,
 125         message_to=>join(",", @receiver_l),
 126         flag=>"n",
 127         direction=>"in",
 128         delivery_time=>$delivery_time,
 129         message=>$message,
 130         timestamp=>&get_time(),
 131     };
 132     my $res = $main::messaging_db->add_dbentry($func_dic);
 133     if (not $res == 0) {
 134         &main::daemon_log("$session_id ERROR: gosaTriggered.pm: cannot add message to message_db: $res", 1);
 135     } else {
 136         &main::daemon_log("$session_id INFO: gosaTriggered.pm: message with subject '$subject' successfully added to message_db", 5);
 137     }
 138
 139     return;
 140 }
 141
 142 sub send_user_msg_OLD {
 143     my ($msg, $msg_hash, $session_id) = @_ ;
 144     my @out_msg_l;
 145     my @user_list;
 146     my @group_list;
 147
 148     my $header = @{$msg_hash->{'header'}}[0];
 149     my $source = @{$msg_hash->{'source'}}[0];
 150     my $target = @{$msg_hash->{'target'}}[0];
 151     my $message = @{$msg_hash->{'message'}}[0];
 152     if( exists $msg_hash->{'user'} ) { @user_list = @{$msg_hash->{'user'}}; }
 153     if( exists $msg_hash->{'group'} ) { @group_list = @{$msg_hash->{'group'}}; }
 154
 155     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 156     if( defined $jobdb_id) {
 157         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 158         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 159         my $res = $main::job_db->exec_statement($sql_statement);
 160     }
 161
 162     # error handling
 163     if( not @user_list && not @group_list ) {
 164         &main::daemon_log("$session_id WARNING: no user-tag or a group-tag specified in 'send_user_msg'", 3);
 165         return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
 166                 "<error_string>no user-tag or a group-tag specified in 'send_user_msg'</error_string></xml>");
 167     }
 168     if( not defined $message ) {
 169         &main::daemon_log("$session_id WARNING: no message-tag specified in 'send_user_msg'", 3);
 170         return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
 171                 "<error_string>no message-tag specified in 'send_user_msg'</error_string></xml>");
 172
 173     }
 174
 175     # resolve groups to users
 176     my $ldap_handle = &main::get_ldap_handle($session_id);
 177     if( @group_list ) {
 178         if( not defined $ldap_handle ) {
 179             &main::daemon_log("$session_id ERROR: cannot connect to ldap", 1);
 180             return ();
 181         }
 182         foreach my $group (@group_list) {   # Perform search
 183             my $mesg = $ldap_handle->search(
 184                     base => $main::ldap_base,
 185                     scope => 'sub',
 186                     attrs => ['memberUid'],
 187                     filter => "(&(objectClass=posixGroup)(cn=$group)(memberUid=*))");
 188             if($mesg->code) {
 189                 &main::daemon_log($mesg->error, 1);
 190                 return ();
 191             }
 192             my $entry= $mesg->entry(0);
 193             my @users= $entry->get_value("memberUid");
 194             foreach my $user (@users) { push(@user_list, $user); }
 195         }
 196     }
 197
 198     # drop multiple users in @user_list
 199     my %seen = ();
 200     foreach my $user (@user_list) {
 201         $seen{$user}++;
 202     }
 203     @user_list = keys %seen;
 204
 205     # build xml messages sended to client where user is logged in
 206     foreach my $user (@user_list) {
 207         my $sql_statement = "SELECT * FROM $main::login_users_tn WHERE user='$user'";
 208         my $db_res = $main::login_users_db->select_dbentry($sql_statement);
 209
 210         if(0 == keys(%{$db_res})) {
 211
 212         } else {
 213             while( my($hit, $content) = each %{$db_res} ) {
 214                 my $out_hash = &create_xml_hash('send_user_msg', $main::server_address, $content->{'client'});
 215                 &add_content2xml_hash($out_hash, 'message', $message);
 216                 &add_content2xml_hash($out_hash, 'user', $user);
 217                 if( exists $msg_hash->{'jobdb_id'} ) {
 218                     &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 219                 }
 220                 my $out_msg = &create_xml_string($out_hash);
 221                 push(@out_msg_l, $out_msg);
 222             }
 223         }
 224     }
 225
 226     return @out_msg_l;
 227 }
 228
 229
 230 sub recreate_fai_server_db {
 231     my ($msg, $msg_hash, $session_id) = @_ ;
 232     my $out_msg;
 233
 234     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 235     if( defined $jobdb_id) {
 236         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 237         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 238         my $res = $main::job_db->exec_statement($sql_statement);
 239     }
 240
 241     $main::fai_server_db->create_table("new_fai_server", \@main::fai_server_col_names);
 242     &main::create_fai_server_db("new_fai_server",undef,"dont", $session_id);
 243     $main::fai_server_db->move_table("new_fai_server", $main::fai_server_tn);
 244
 245     my @out_msg_l = ( $out_msg );
 246     return @out_msg_l;
 247 }
 248
 249
 250 sub recreate_fai_release_db {
 251     my ($msg, $msg_hash, $session_id) = @_ ;
 252     my $out_msg;
 253
 254     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 255     if( defined $jobdb_id) {
 256         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 257         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 258         my $res = $main::job_db->exec_statement($sql_statement);
 259     }
 260
 261     $main::fai_release_db->create_table("new_fai_release", \@main::fai_release_col_names);
 262     &main::create_fai_release_db("new_fai_release", $session_id);
 263     $main::fai_release_db->move_table("new_fai_release", $main::fai_release_tn);
 264
 265     my @out_msg_l = ( $out_msg );
 266     return @out_msg_l;
 267 }
 268
 269
 270 sub recreate_packages_list_db {
 271         my ($msg, $msg_hash, $session_id) = @_ ;
 272         my $out_msg;
 273
 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         &main::create_packages_list_db;
 282
 283         my @out_msg_l = ( $out_msg );
 284         return @out_msg_l;
 285 }
 286
 287
 288 sub get_login_usr_for_client {
 289     my ($msg, $msg_hash, $session_id) = @_ ;
 290     my $header = @{$msg_hash->{'header'}}[0];
 291     my $source = @{$msg_hash->{'source'}}[0];
 292     my $target = @{$msg_hash->{'target'}}[0];
 293     my $client = @{$msg_hash->{'client'}}[0];
 294
 295     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 296     if( defined $jobdb_id) {
 297         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 298         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 299         my $res = $main::job_db->exec_statement($sql_statement);
 300     }
 301
 302     $header =~ s/^gosa_//;
 303
 304     my $sql_statement = "SELECT * FROM known_clients WHERE hostname='$client' OR macaddress LIKE '$client'";
 305     my $res = $main::known_clients_db->select_dbentry($sql_statement);
 306
 307     my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
 308     $out_msg .= &db_res2xml($res);
 309     $out_msg .= "</xml>";
 310
 311     my @out_msg_l = ( $out_msg );
 312     return @out_msg_l;
 313 }
 314
 315
 316 sub get_client_for_login_usr {
 317     my ($msg, $msg_hash, $session_id) = @_ ;
 318     my $header = @{$msg_hash->{'header'}}[0];
 319     my $source = @{$msg_hash->{'source'}}[0];
 320     my $target = @{$msg_hash->{'target'}}[0];
 321
 322     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 323     if( defined $jobdb_id) {
 324         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 325         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 326         my $res = $main::job_db->exec_statement($sql_statement);
 327     }
 328
 329     my $usr = @{$msg_hash->{'usr'}}[0];
 330     $header =~ s/^gosa_//;
 331
 332     my $sql_statement = "SELECT * FROM known_clients WHERE login LIKE '%$usr%'";
 333     my $res = $main::known_clients_db->select_dbentry($sql_statement);
 334
 335     my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
 336     $out_msg .= &db_res2xml($res);
 337     $out_msg .= "</xml>";
 338     my @out_msg_l = ( $out_msg );
 339     return @out_msg_l;
 340
 341 }
 342
 343
 344 sub ping {
 345     my ($msg, $msg_hash, $session_id) = @_ ;
 346     my $out_msg = $msg;
 347     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 348     if( defined $jobdb_id) {
 349         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 350         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 351         my $res = $main::job_db->exec_statement($sql_statement);
 352     }
 353
 354     $out_msg =~ s/<header>gosa_/<header>/;
 355
 356     my @out_msg_l = ( $out_msg );
 357     return @out_msg_l;
 358 }
 359 sub new_ping {
 360     my ($msg, $msg_hash, $session_id) = @_ ;
 361     my ($sql, $res);
 362     my $out_msg = $msg;
 363     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 364     if( defined $jobdb_id) {
 365         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 366         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 367         my $res = $main::job_db->exec_statement($sql_statement);
 368     }
 369
 370     $out_msg =~ s/<header>gosa_/<header>/;
 371
 372     # send message
 373     my $header = @{$msg_hash->{header}}[0];
 374     my $target = @{$msg_hash->{target}}[0];
 375
 376     $sql = "SELECT * FROM $main::known_clients_tn WHERE ((hostname='$target') || (macaddress LIKE '$target'))";
 377     $res = $main::known_clients_db->exec_statement($sql);
 378     my $host_name = @{@$res[0]}[0];
 379     $out_msg =~ s/<target>\S+<\/target>/<target>$host_name<\/target>/;
 380     $out_msg =~ s/<source>\S+<\/source>/<source>$main::server_address<\/source>/;
 381     $out_msg =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
 382     my $host_key = @{@$res[0]}[2];
 383
 384     my $error = &main::send_msg_to_target($out_msg, $host_name, $host_key, $header, $session_id);
 385     #if ($error != 0) {}
 386
 387     my $message_id;
 388     while (1) {
 389         $sql = "SELECT * FROM $main::incoming_tn WHERE headertag='answer_$session_id'";
 390         $res = $main::incoming_db->exec_statement($sql);
 391         if (ref @$res[0] eq "ARRAY") {
 392             $message_id = @{@$res[0]}[0];
 393             last;
 394         }
 395         usleep(100000);
 396     }
 397     my $answer_xml = @{@$res[0]}[3];
 398     my %data = ( 'answer_xml'  => 'bin noch da' );
 399     my $answer_msg = &build_msg("got_new_ping", "$main::server_address", "GOSA", \%data);
 400
 401     $sql = "DELETE FROM $main::incoming_tn WHERE id=$message_id";
 402     $res = $main::incoming_db->exec_statement($sql);
 403
 404
 405     my @answer_msg_l = ( $answer_msg );
 406     return @answer_msg_l;
 407 }
 408
 409
 410
 411 sub gen_smb_hash {
 412      my ($msg, $msg_hash, $session_id) = @_ ;
 413      my $source = @{$msg_hash->{source}}[0];
 414      my $target = @{$msg_hash->{target}}[0];
 415      my $password = @{$msg_hash->{password}}[0];
 416
 417      my %data= ('hash' => join(q[:], ntlmgen $password));
 418      my $out_msg = &build_msg("gen_smb_hash", $target, 'GOSA', \%data );
 419      return ( $out_msg );
 420 }
 421
 422
 423 sub network_completition {
 424      my ($msg, $msg_hash, $session_id) = @_ ;
 425      my $source = @{$msg_hash->{source}}[0];
 426      my $target = @{$msg_hash->{target}}[0];
 427      my $name = @{$msg_hash->{hostname}}[0];
 428
 429      # Can we resolv the name?
 430      my %data;
 431      if (inet_aton($name)){
 432              my $address = inet_ntoa(inet_aton($name));
 433              my $p = Net::Ping->new('tcp');
 434              my $mac= "";
 435              if ($p->ping($address, 1)){
 436                $mac = Net::ARP::arp_lookup("", $address);
 437              }
 438
 439              %data= ('ip' => $address, 'mac' => $mac);
 440      } else {
 441              %data= ('ip' => '', 'mac' => '');
 442      }
 443
 444      my $out_msg = &build_msg("network_completition", $target, 'GOSA', \%data );
 445
 446      return ( $out_msg );
 447 }
 448
 449
 450 sub detect_hardware {
 451     my ($msg, $msg_hash, $session_id) = @_ ;
 452     # just forward msg to client, but dont forget to split off 'gosa_' in header
 453     my $source = @{$msg_hash->{source}}[0];
 454     my $target = @{$msg_hash->{target}}[0];
 455     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 456     if( defined $jobdb_id) {
 457         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 458         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 459         my $res = $main::job_db->exec_statement($sql_statement);
 460     }
 461
 462     my $out_hash = &create_xml_hash("detect_hardware", $source, $target);
 463     if( defined $jobdb_id ) {
 464         &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
 465     }
 466     my $out_msg = &create_xml_string($out_hash);
 467
 468     my @out_msg_l = ( $out_msg );
 469     return @out_msg_l;
 470
 471 }
 472
 473
 474 sub trigger_reload_ldap_config {
 475     my ($msg, $msg_hash, $session_id) = @_ ;
 476     my $target = @{$msg_hash->{target}}[0];
 477
 478     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 479     if( defined $jobdb_id) {
 480         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 481         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 482         my $res = $main::job_db->exec_statement($sql_statement);
 483     }
 484
 485         my $out_msg = &ClientPackages::new_ldap_config($target, $session_id);
 486         my @out_msg_l = ( $out_msg );
 487
 488     return @out_msg_l;
 489 }
 490
 491
 492 sub set_activated_for_installation {
 493     my ($msg, $msg_hash, $session_id) = @_;
 494     my $header = @{$msg_hash->{header}}[0];
 495     my $source = @{$msg_hash->{source}}[0];
 496     my $target = @{$msg_hash->{target}}[0];
 497         my @out_msg_l;
 498
 499         # update status of job
 500     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 501     if( defined $jobdb_id) {
 502         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 503         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 504         my $res = $main::job_db->exec_statement($sql_statement);
 505     }
 506
 507         # create set_activated_for_installation message for delivery
 508     my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $target);
 509     if( defined $jobdb_id ) {
 510         &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id);
 511     }
 512     my $out_msg = &create_xml_string($out_hash);
 513         push(@out_msg_l, $out_msg);
 514
 515     return @out_msg_l;
 516 }
 517
 518
 519 sub trigger_action_faireboot {
 520     my ($msg, $msg_hash, $session_id) = @_;
 521     my $macaddress = @{$msg_hash->{target}}[0];
 522     my $source = @{$msg_hash->{source}}[0];
 523
 524     my @out_msg_l;
 525     $msg =~ s/<header>gosa_trigger_action_faireboot<\/header>/<header>trigger_action_faireboot<\/header>/;
 526     push(@out_msg_l, $msg);
 527
 528     &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id);
 529         &main::change_fai_state('install', \@{$msg_hash->{target}}, $session_id);
 530
 531     # delete all jobs from jobqueue which correspond to fai
 532     my $sql_statement = "DELETE FROM $main::job_queue_tn WHERE (macaddress='$macaddress' AND ".
 533         "status='processing')";
 534     $main::job_db->del_dbentry($sql_statement );
 535
 536     return @out_msg_l;
 537 }
 538
 539
 540 sub trigger_action_lock {
 541     my ($msg, $msg_hash, $session_id) = @_;
 542     my $macaddress = @{$msg_hash->{target}}[0];
 543     my $source = @{$msg_hash->{source}}[0];
 544
 545     &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id);
 546     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 547     if( defined $jobdb_id) {
 548         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 549         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 550         my $res = $main::job_db->exec_statement($sql_statement);
 551     }
 552
 553     my @out_msg_l;
 554     return @out_msg_l;
 555 }
 556
 557
 558 sub trigger_action_activate {
 559     my ($msg, $msg_hash, $session_id) = @_;
 560     my $macaddress = @{$msg_hash->{target}}[0];
 561     my $source = @{$msg_hash->{source}}[0];
 562
 563     &main::change_goto_state('active', \@{$msg_hash->{target}}, $session_id);
 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 $out_hash = &create_xml_hash("set_activated_for_installation", $source, $macaddress);
 572     if( exists $msg_hash->{'jobdb_id'} ) {
 573         &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 574     }
 575     my $out_msg = &create_xml_string($out_hash);
 576
 577     return ( $out_msg );
 578 }
 579
 580
 581 sub trigger_action_localboot {
 582     my ($msg, $msg_hash, $session_id) = @_;
 583     $msg =~ s/<header>gosa_trigger_action_localboot<\/header>/<header>trigger_action_localboot<\/header>/;
 584     &main::change_fai_state('localboot', \@{$msg_hash->{target}}, $session_id);
 585     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 586     if( defined $jobdb_id) {
 587         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 588         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 589         my $res = $main::job_db->exec_statement($sql_statement);
 590     }
 591
 592     my @out_msg_l = ($msg);
 593     return @out_msg_l;
 594 }
 595
 596
 597 sub trigger_action_halt {
 598     my ($msg, $msg_hash, $session_id) = @_;
 599     $msg =~ s/<header>gosa_trigger_action_halt<\/header>/<header>trigger_action_halt<\/header>/;
 600
 601     &main::change_fai_state('halt', \@{$msg_hash->{target}}, $session_id);
 602     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 603     if( defined $jobdb_id) {
 604         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 605         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 606         my $res = $main::job_db->exec_statement($sql_statement);
 607     }
 608
 609     my @out_msg_l = ($msg);
 610     return @out_msg_l;
 611 }
 612
 613
 614 sub trigger_action_reboot {
 615     my ($msg, $msg_hash, $session_id) = @_;
 616     $msg =~ s/<header>gosa_trigger_action_reboot<\/header>/<header>trigger_action_reboot<\/header>/;
 617
 618     &main::change_fai_state('reboot', \@{$msg_hash->{target}}, $session_id);
 619     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 620     if( defined $jobdb_id) {
 621         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 622         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 623         my $res = $main::job_db->exec_statement($sql_statement);
 624     }
 625
 626     my @out_msg_l = ($msg);
 627     return @out_msg_l;
 628 }
 629
 630
 631 sub trigger_action_memcheck {
 632     my ($msg, $msg_hash, $session_id) = @_ ;
 633     $msg =~ s/<header>gosa_trigger_action_memcheck<\/header>/<header>trigger_action_memcheck<\/header>/;
 634
 635     &main::change_fai_state('memcheck', \@{$msg_hash->{target}}, $session_id);
 636     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 637     if( defined $jobdb_id) {
 638         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 639         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 640         my $res = $main::job_db->exec_statement($sql_statement);
 641     }
 642
 643     my @out_msg_l = ($msg);
 644     return @out_msg_l;
 645 }
 646
 647
 648 sub trigger_action_reinstall {
 649     my ($msg, $msg_hash, $session_id) = @_;
 650     $msg =~ s/<header>gosa_trigger_action_reinstall<\/header>/<header>trigger_action_reinstall<\/header>/;
 651
 652     &main::change_fai_state('reinstall', \@{$msg_hash->{target}}, $session_id);
 653
 654     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 655     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 656     my @out_msg_l = ($wake_msg, $msg);
 657     return @out_msg_l;
 658 }
 659
 660
 661 sub trigger_action_update {
 662     my ($msg, $msg_hash, $session_id) = @_;
 663     $msg =~ s/<header>gosa_trigger_action_update<\/header>/<header>trigger_action_update<\/header>/;
 664
 665     &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
 666
 667     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 668     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 669     my @out_msg_l = ($wake_msg, $msg);
 670     return @out_msg_l;
 671 }
 672
 673
 674 sub trigger_action_instant_update {
 675     my ($msg, $msg_hash, $session_id) = @_;
 676     $msg =~ s/<header>gosa_trigger_action_instant_update<\/header>/<header>trigger_action_instant_update<\/header>/;
 677
 678     &main::change_fai_state('update', \@{$msg_hash->{target}}, $session_id);
 679
 680     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 681     if( defined $jobdb_id) {
 682         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 683         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 684         my $res = $main::job_db->exec_statement($sql_statement);
 685     }
 686
 687     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 688     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 689     my @out_msg_l = ($wake_msg, $msg);
 690     return @out_msg_l;
 691 }
 692
 693
 694 sub trigger_action_sysinfo {
 695     my ($msg, $msg_hash, $session_id) = @_;
 696     $msg =~ s/<header>gosa_trigger_action_sysinfo<\/header>/<header>trigger_action_sysinfo<\/header>/;
 697
 698     &main::change_fai_state('sysinfo', \@{$msg_hash->{target}}, $session_id);
 699     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 700     if( defined $jobdb_id) {
 701         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 702         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 703         my $res = $main::job_db->exec_statement($sql_statement);
 704     }
 705
 706     my @out_msg_l = ($msg);
 707     return @out_msg_l;
 708 }
 709
 710
 711 sub new_key_for_client {
 712     my ($msg, $msg_hash, $session_id) = @_;
 713
 714     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 715     if( defined $jobdb_id) {
 716         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 717         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 718         my $res = $main::job_db->exec_statement($sql_statement);
 719     }
 720
 721     $msg =~ s/<header>gosa_new_key_for_client<\/header>/<header>new_key<\/header>/;
 722     my @out_msg_l = ($msg);
 723     return @out_msg_l;
 724 }
 725
 726
 727 sub trigger_action_rescan {
 728     my ($msg, $msg_hash, $session_id) = @_;
 729
 730     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 731     if( defined $jobdb_id) {
 732         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 733         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 734         my $res = $main::job_db->exec_statement($sql_statement);
 735     }
 736
 737
 738     $msg =~ s/<header>gosa_trigger_action_rescan<\/header>/<header>trigger_action_rescan<\/header>/;
 739     my @out_msg_l = ($msg);
 740     return @out_msg_l;
 741 }
 742
 743
 744 sub trigger_action_wake {
 745     my ($msg, $msg_hash, $session_id) = @_;
 746
 747     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 748     if( defined $jobdb_id) {
 749         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 750         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 751         my $res = $main::job_db->exec_statement($sql_statement);
 752     }
 753
 754
 755     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 756     my $out_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 757     my @out_msg_l = ($out_msg);
 758     return @out_msg_l;
 759 }
 760
 761
 762 sub get_available_kernel {
 763         my ($msg, $msg_hash, $session_id) = @_;
 764
 765         my $source = @{$msg_hash->{'source'}}[0];
 766         my $target = @{$msg_hash->{'target'}}[0];
 767         my $release= @{$msg_hash->{'release'}}[0];
 768
 769         my @kernel;
 770         # Get Kernel packages for release
 771         my $sql_statement = "SELECT * FROM $main::packages_list_tn WHERE distribution='$release' AND package LIKE 'linux\-image\-%'";
 772         my $res_hash = $main::packages_list_db->select_dbentry($sql_statement);
 773         my %data;
 774         my $i=1;
 775
 776         foreach my $package (keys %{$res_hash}) {
 777                 $data{"answer".$i++}= $data{"answer".$i++}= ${$res_hash}{$package}->{'package'};
 778         }
 779         $data{"answer".$i++}= "default";
 780
 781         my $out_msg = &build_msg("get_available_kernel", $target, "GOSA", \%data);
 782         return ( $out_msg );
 783 }
 784
 785
 786 sub trigger_activate_new {
 787         my ($msg, $msg_hash, $session_id) = @_;
 788
 789         my $source = @{$msg_hash->{'source'}}[0];
 790         my $target = @{$msg_hash->{'target'}}[0];
 791         my $header= @{$msg_hash->{'header'}}[0];
 792         my $mac= (defined($msg_hash->{'mac'}))?@{$msg_hash->{'mac'}}[0]:undef;
 793         my $ogroup= (defined($msg_hash->{'ogroup'}))?@{$msg_hash->{'ogroup'}}[0]:undef;
 794         my $timestamp= (defined($msg_hash->{'timestamp'}))?@{$msg_hash->{'timestamp'}}[0]:undef;
 795         my $base= (defined($msg_hash->{'base'}))?@{$msg_hash->{'base'}}[0]:undef;
 796         my $hostname= (defined($msg_hash->{'fqdn'}))?@{$msg_hash->{'fqdn'}}[0]:undef;
 797         my $ip_address= (defined($msg_hash->{'ip'}))?@{$msg_hash->{'ip'}}[0]:undef;
 798         my $dhcp_statement= (defined($msg_hash->{'dhcp'}))?@{$msg_hash->{'dhcp'}}[0]:undef;
 799         my $jobdb_id= (defined($msg_hash->{'jobdb_id'}))?@{$msg_hash->{'jobdb_id'}}[0]:undef;
 800
 801         my $ldap_handle = &main::get_ldap_handle();
 802         my $ldap_entry;
 803         my $ogroup_entry;
 804
 805         # build the base, use optional base parameter or take it from ogroup
 806         if(!(defined($base) && (length($base) > 0))) {
 807                 my $ldap_mesg= $ldap_handle->search(
 808                         base => $main::ldap_base,
 809                         scope => 'sub',
 810                         filter => "(&(objectClass=gosaGroupOfnames)(cn=$ogroup))",
 811                 );
 812                 if($ldap_mesg->count == 1) {
 813                         $ogroup_entry= $ldap_mesg->pop_entry();
 814
 815                         # Subtract the ObjectGroup cn
 816                         $base = $1 if $ogroup_entry->dn =~ /cn=$ogroup,ou=groups,(.*)$/;
 817                 } elsif ($ldap_mesg->count == 0) {
 818                         &main::daemon_log("ERROR: A GosaGroupOfNames with cn '$ogroup' was not found in base '".$main::ldap_base."'!", 1);
 819                 } else {
 820                         &main::daemon_log("ERROR: More than one ObjectGroups with cn '$ogroup' was found in base '".$main::ldap_base."'!", 1);
 821                 }
 822         }
 823
 824         # prepend ou=systems
 825         $base = "ou=systems,".$base;
 826
 827         # Search for an existing entry (should be in ou=incoming)
 828         my $ldap_mesg= $ldap_handle->search(
 829                 base => $main::ldap_base,
 830                 scope => 'sub',
 831                 filter => "(&(objectClass=GOhard)(|(macAddress=$mac)(dhcpHWaddress=$mac)))",
 832         );
 833
 834         # TODO: Find a way to guess an ip address for hosts with no ldap entry (MAC->ARP->IP)
 835
 836         if($ldap_mesg->count == 1) {
 837                 &main::daemon_log("NOTICE: One system with mac address '$mac' was found in base '".$main::ldap_base."'!", 1);
 838                 # Get the entry from LDAP
 839                 $ldap_entry= $ldap_mesg->pop_entry();
 840
 841                 if(!($ldap_entry->dn() eq "cn=".$ldap_entry->get_value('cn').",$base")) {
 842                                 # Move the entry to the new ou
 843                                 $ldap_entry->changetype('moddn');
 844                                 $ldap_entry->add(
 845                                         'newrdn' => "cn=".$ldap_entry->get_value('cn'),
 846                                         'deleteoldrdn' => "1",
 847                                         'newsuperior' => $base,
 848                                 );
 849                                 my $mesg = $ldap_entry->update($ldap_handle);
 850                                 if($mesg->code() != 0) {
 851                                         &main::daemon_log("ERROR: Updating the dn for system with mac address '$mac' failed (code ".$mesg->code().") with '".$mesg->{'errorMessage'}."'!", 1);
 852                                 }
 853                         }
 854                 # Check for needed objectClasses
 855                 my $oclasses = $ldap_entry->get_value('objectClass', asref => 1);
 856                 foreach my $oclass ("FAIobject", "GOhard") {
 857                         if(!(scalar grep $_ eq $oclass, map {$_ => 1} @$oclasses)) {
 858                                 $ldap_entry->add(
 859                                         objectClass => $oclass,
 860                                 );
 861                         }
 862                 }
 863
 864                 # Set FAIstate
 865                 if(defined($ldap_entry->get_value('FAIstate'))) {
 866                         if(!($ldap_entry->get_value('FAIstate') eq 'install')) {
 867                                 $ldap_entry->replace(
 868                                         'FAIstate' => 'install'
 869                                 );
 870                                 my $faistate_mesg = $ldap_entry->update($ldap_handle);
 871                                 if ($faistate_mesg->code() != 0) {
 872                                         &main::daemon_log("ERROR: Updating the FAIstate for '".$ldap_entry->dn()."' failed (code '".$faistate_mesg->code()."') with '$@'!", 1);
 873                                 }
 874                         }
 875                 } else {
 876                         $ldap_entry->add(
 877                                 'FAIstate' => 'install'
 878                         );
 879                         my $faistate_mesg = $ldap_entry->update($ldap_handle);
 880                         if ($faistate_mesg->code() != 0) {
 881                                 &main::daemon_log("ERROR: Updating the FAIstate for '".$ldap_entry->dn()."' failed (code '".$faistate_mesg->code()."') with '$@'!", 1);
 882                         }
 883                 }
 884
 885
 886         } elsif ($ldap_mesg->count == 0) {
 887                 # TODO: Create a new entry
 888                 # $ldap_entry = Net::LDAP::Entry->new();
 889                 # $ldap_entry->dn("cn=$mac,$base");
 890                 &main::daemon_log("WARNING: No System with mac address '$mac' was found in base '".$main::ldap_base."'! Re-queuing job.", 4);
 891                 $main::job_db->select_dbentry("UPDATE jobs SET state = 'waiting', timestamp = '".&get_time()."' WHERE header = 'trigger_activate_new' AND mac_address LIKE '$mac'");
 892         } else {
 893                 &main::daemon_log("ERROR: More than one system with mac address '$mac' was found in base '".$main::ldap_base."'!", 1);
 894         }
 895
 896         my $update_mesg = $ldap_entry->update($ldap_handle);
 897         if ($update_mesg->code() != 0) {
 898                 &main::daemon_log("ERROR: Updating attributes for '".$ldap_entry->dn()."' failed (code '".$update_mesg->code()."') with '".$update_mesg->{'errorMessage'}."'!", 1);
 899         }
 900
 901         # Add to ObjectGroup
 902         if(!(scalar grep $_, map {$_ => 1} $ogroup_entry->get_value('member', asref => 1))) {
 903                 $ogroup_entry->add (
 904                         'member' => $ldap_entry->dn(),
 905                 );
 906                 my $ogroup_result = $ogroup_entry->update($ldap_handle);
 907                 if ($ogroup_result->code() != 0) {
 908                         &main::daemon_log("ERROR: Updating the ObjectGroup '$ogroup' failed (code '".$ogroup_result->code()."') with '".$ogroup_result->{'errorMessage'}."'!", 1);
 909                 }
 910         }
 911
 912         # Finally set gotoMode to active
 913         if(defined($ldap_entry->get_value('gotoMode'))) {
 914                 if(!($ldap_entry->get_value('gotoMode') eq 'active')) {
 915                         $ldap_entry->replace(
 916                                 'gotoMode' => 'active'
 917                         );
 918                 }
 919         } else {
 920                 $ldap_entry->add(
 921                         'gotoMode' => 'active'
 922                 );
 923         }
 924         my $activate_result = $ldap_entry->update($ldap_handle);
 925         if ($activate_result->code() != 0) {
 926                 &main::daemon_log("ERROR: Activating system '".$ldap_entry->dn()."' failed (code '".$activate_result->code()."') with '".$activate_result->{'errorMessage'}."'!", 1);
 927         }
 928
 929
 930         my %data;
 931         my $out_msg = &build_msg("activate_new", $target, "GOSA", \%data);
 932         return ( $out_msg );
 933 }
 934
 935
 936 1;