X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=gosa-si%2Fserver%2Fevents%2FgosaTriggered.pm;h=f5035dc2b0d10a3fcbbff85e3ab6e1ba0f8d0eeb;hb=1509fd7edf9185a03bdc7eac0d4349488025d55e;hp=3f651b8becfa02dbeac9d5cc32b5938674ae1305;hpb=cd2b562f00e37a3aa2d7b21eaad8472feaedf4ae;p=gosa.git diff --git a/gosa-si/server/events/gosaTriggered.pm b/gosa-si/server/events/gosaTriggered.pm index 3f651b8be..f5035dc2b 100644 --- a/gosa-si/server/events/gosaTriggered.pm +++ b/gosa-si/server/events/gosaTriggered.pm @@ -8,6 +8,7 @@ my @events = ( "gen_smb_hash", "trigger_reload_ldap_config", "ping", + "new_ping", "network_completition", "set_activated_for_installation", "new_key_for_client", @@ -28,7 +29,11 @@ my @events = ( "trigger_action_rescan", "trigger_action_wake", "recreate_fai_server_db", + "recreate_fai_release_db", + "recreate_packages_list_db", "send_user_msg", + "get_available_kernel", + "trigger_activate_new", ); @EXPORT = @events; @@ -40,6 +45,7 @@ use Crypt::SmbHash; use Net::ARP; use Net::Ping; use Socket; +use Time::HiRes qw( usleep); BEGIN {} @@ -54,6 +60,16 @@ sub get_events { } sub send_user_msg { + +# msg from gosa +#
gosa_send_user_msg
GOSAGOSA +# 20080429151605 +# andreas.rettenberger +# hallo +# test +# GOSA +# + my ($msg, $msg_hash, $session_id) = @_ ; my $header = @{$msg_hash->{'header'}}[0]; my $source = @{$msg_hash->{'source'}}[0]; @@ -62,7 +78,8 @@ sub send_user_msg { #my $subject = &decode_base64(@{$msg_hash->{'subject'}}[0]); my $subject = @{$msg_hash->{'subject'}}[0]; my $from = @{$msg_hash->{'from'}}[0]; - my $to = @{$msg_hash->{'to'}}[0]; + my @users = @{$msg_hash->{'users'}}; + my @groups = @{$msg_hash->{'groups'}}[0]; my $delivery_time = @{$msg_hash->{'delivery_time'}}[0]; #my $message = &decode_base64(@{$msg_hash->{'message'}}[0]); my $message = @{$msg_hash->{'message'}}[0]; @@ -70,7 +87,7 @@ sub send_user_msg { # keep job queue uptodate if necessary my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -83,11 +100,29 @@ sub send_user_msg { } # add incoming message to messaging_db + my $new_msg_id = 1; + my $new_msg_id_sql = "SELECT MAX(CAST(id AS INTEGER)) FROM $main::messaging_tn"; + my $new_msg_id_res = $main::messaging_db->exec_statement($new_msg_id_sql); + if (defined @{@{$new_msg_id_res}[0]}[0] ) { + $new_msg_id = int(@{@{$new_msg_id_res}[0]}[0]); + $new_msg_id += 1; + } + + # highlight user name and group name + my @receiver_l; + @users = map(push(@receiver_l, "u_$_"), @users); + #@groups = map(push(@receiver_l, "g_$_"), @groups); +# TODO +# handling, was passiert wenn in einer liste nix drin steht +# handling von groups hinzufügen + + my $func_dic = {table=>$main::messaging_tn, - primkey=>['id'], + primkey=>[], + id=>$new_msg_id, subject=>$subject, message_from=>$from, - message_to=>$to, + message_to=>join(",", @receiver_l), flag=>"n", direction=>"in", delivery_time=>$delivery_time, @@ -104,114 +139,152 @@ sub send_user_msg { return; } -sub send_user_msg_OLD { - my ($msg, $msg_hash, $session_id) = @_ ; - my @out_msg_l; - my @user_list; - my @group_list; +#sub send_user_msg_OLD { +# my ($msg, $msg_hash, $session_id) = @_ ; +# my @out_msg_l; +# my @user_list; +# my @group_list; +# +# my $header = @{$msg_hash->{'header'}}[0]; +# my $source = @{$msg_hash->{'source'}}[0]; +# my $target = @{$msg_hash->{'target'}}[0]; +# my $message = @{$msg_hash->{'message'}}[0]; +# if( exists $msg_hash->{'user'} ) { @user_list = @{$msg_hash->{'user'}}; } +# if( exists $msg_hash->{'group'} ) { @group_list = @{$msg_hash->{'group'}}; } +# +# my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; +# if( defined $jobdb_id) { +# my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; +# &main::daemon_log("$session_id DEBUG: $sql_statement", 7); +# my $res = $main::job_db->exec_statement($sql_statement); +# } +# +# # error handling +# if( not @user_list && not @group_list ) { +# &main::daemon_log("$session_id WARNING: no user-tag or a group-tag specified in 'send_user_msg'", 3); +# return ("
$header
GOSAGOSA". +# "no user-tag or a group-tag specified in 'send_user_msg'"); +# } +# if( not defined $message ) { +# &main::daemon_log("$session_id WARNING: no message-tag specified in 'send_user_msg'", 3); +# return ("
$header
GOSAGOSA". +# "no message-tag specified in 'send_user_msg'"); +# +# } +# +# # resolve groups to users +# my $ldap_handle = &main::get_ldap_handle($session_id); +# if( @group_list ) { +# if( not defined $ldap_handle ) { +# &main::daemon_log("$session_id ERROR: cannot connect to ldap", 1); +# return (); +# } +# foreach my $group (@group_list) { # Perform search +# my $mesg = $ldap_handle->search( +# base => $main::ldap_base, +# scope => 'sub', +# attrs => ['memberUid'], +# filter => "(&(objectClass=posixGroup)(cn=$group)(memberUid=*))"); +# if($mesg->code) { +# &main::daemon_log($mesg->error, 1); +# return (); +# } +# my $entry= $mesg->entry(0); +# my @users= $entry->get_value("memberUid"); +# foreach my $user (@users) { push(@user_list, $user); } +# } +# } +# +# # drop multiple users in @user_list +# my %seen = (); +# foreach my $user (@user_list) { +# $seen{$user}++; +# } +# @user_list = keys %seen; +# +# # build xml messages sended to client where user is logged in +# foreach my $user (@user_list) { +# my $sql_statement = "SELECT * FROM $main::login_users_tn WHERE user='$user'"; +# my $db_res = $main::login_users_db->select_dbentry($sql_statement); +# +# if(0 == keys(%{$db_res})) { +# +# } else { +# while( my($hit, $content) = each %{$db_res} ) { +# my $out_hash = &create_xml_hash('send_user_msg', $main::server_address, $content->{'client'}); +# &add_content2xml_hash($out_hash, 'message', $message); +# &add_content2xml_hash($out_hash, 'user', $user); +# if( exists $msg_hash->{'jobdb_id'} ) { +# &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]); +# } +# my $out_msg = &create_xml_string($out_hash); +# push(@out_msg_l, $out_msg); +# } +# } +# } +# +# return @out_msg_l; +#} - my $header = @{$msg_hash->{'header'}}[0]; - my $source = @{$msg_hash->{'source'}}[0]; - my $target = @{$msg_hash->{'target'}}[0]; - my $message = @{$msg_hash->{'message'}}[0]; - if( exists $msg_hash->{'user'} ) { @user_list = @{$msg_hash->{'user'}}; } - if( exists $msg_hash->{'group'} ) { @group_list = @{$msg_hash->{'group'}}; } + +sub recreate_fai_server_db { + my ($msg, $msg_hash, $session_id) = @_ ; + my $out_msg; my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } - # error handling - if( not @user_list && not @group_list ) { - &main::daemon_log("$session_id WARNING: no user-tag or a group-tag specified in 'send_user_msg'", 3); - return ("
$header
GOSAGOSA". - "no user-tag or a group-tag specified in 'send_user_msg'"); - } - if( not defined $message ) { - &main::daemon_log("$session_id WARNING: no message-tag specified in 'send_user_msg'", 3); - return ("
$header
GOSAGOSA". - "no message-tag specified in 'send_user_msg'"); - - } - - # resolve groups to users - my $ldap_handle = &main::get_ldap_handle($session_id); - if( @group_list ) { - if( not defined $ldap_handle ) { - &main::daemon_log("$session_id ERROR: cannot connect to ldap", 1); - return (); - } - foreach my $group (@group_list) { # Perform search - my $mesg = $ldap_handle->search( - base => $main::ldap_base, - scope => 'sub', - attrs => ['memberUid'], - filter => "(&(objectClass=posixGroup)(cn=$group)(memberUid=*))"); - if($mesg->code) { - &main::daemon_log($mesg->error, 1); - return (); - } - my $entry= $mesg->entry(0); - my @users= $entry->get_value("memberUid"); - foreach my $user (@users) { push(@user_list, $user); } - } - } - - # drop multiple users in @user_list - my %seen = (); - foreach my $user (@user_list) { - $seen{$user}++; - } - @user_list = keys %seen; - - # build xml messages sended to client where user is logged in - foreach my $user (@user_list) { - my $sql_statement = "SELECT * FROM $main::login_users_tn WHERE user='$user'"; - my $db_res = $main::login_users_db->select_dbentry($sql_statement); - - if(0 == keys(%{$db_res})) { - - } else { - while( my($hit, $content) = each %{$db_res} ) { - my $out_hash = &create_xml_hash('send_user_msg', $main::server_address, $content->{'client'}); - &add_content2xml_hash($out_hash, 'message', $message); - &add_content2xml_hash($out_hash, 'user', $user); - if( exists $msg_hash->{'jobdb_id'} ) { - &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]); - } - my $out_msg = &create_xml_string($out_hash); - push(@out_msg_l, $out_msg); - } - } - } - + $main::fai_server_db->create_table("new_fai_server", \@main::fai_server_col_names); + &main::create_fai_server_db("new_fai_server",undef,"dont", $session_id); + $main::fai_server_db->move_table("new_fai_server", $main::fai_server_tn); + + my @out_msg_l = ( $out_msg ); return @out_msg_l; } -sub recreate_fai_server_db { +sub recreate_fai_release_db { my ($msg, $msg_hash, $session_id) = @_ ; my $out_msg; my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; - &main::daemon_log("$session_id DEBUG: $sql_statement", 7); + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; + &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } - $main::fai_server_db->create_table("new_fai_server", \@main::fai_server_col_names); - &main::create_fai_server_db("new_fai_server"); - $main::fai_server_db->move_table("new_fai_server", $main::fai_server_tn); + $main::fai_release_db->create_table("new_fai_release", \@main::fai_release_col_names); + &main::create_fai_release_db("new_fai_release", $session_id); + $main::fai_release_db->move_table("new_fai_release", $main::fai_release_tn); my @out_msg_l = ( $out_msg ); return @out_msg_l; } +sub recreate_packages_list_db { + my ($msg, $msg_hash, $session_id) = @_ ; + my $out_msg; + + my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; + if( defined $jobdb_id) { + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; + &main::daemon_log("$session_id DEBUG: $sql_statement", 7); + my $res = $main::job_db->exec_statement($sql_statement); + } + + &main::create_packages_list_db; + + my @out_msg_l = ( $out_msg ); + return @out_msg_l; +} + + sub get_login_usr_for_client { my ($msg, $msg_hash, $session_id) = @_ ; my $header = @{$msg_hash->{'header'}}[0]; @@ -221,7 +294,7 @@ sub get_login_usr_for_client { my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -248,7 +321,7 @@ sub get_client_for_login_usr { my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -273,7 +346,7 @@ sub ping { my $out_msg = $msg; my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -283,6 +356,57 @@ sub ping { my @out_msg_l = ( $out_msg ); return @out_msg_l; } +sub new_ping { + my ($msg, $msg_hash, $session_id) = @_ ; + my ($sql, $res); + my $out_msg = $msg; + my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; + if( defined $jobdb_id) { + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; + &main::daemon_log("$session_id DEBUG: $sql_statement", 7); + my $res = $main::job_db->exec_statement($sql_statement); + } + + $out_msg =~ s/
gosa_/
/; + + # send message + my $header = @{$msg_hash->{header}}[0]; + my $target = @{$msg_hash->{target}}[0]; + + $sql = "SELECT * FROM $main::known_clients_tn WHERE ((hostname='$target') || (macaddress LIKE '$target'))"; + $res = $main::known_clients_db->exec_statement($sql); + my $host_name = @{@$res[0]}[0]; + $out_msg =~ s/\S+<\/target>/$host_name<\/target>/; + $out_msg =~ s/\S+<\/source>/$main::server_address<\/source>/; + $out_msg =~ s/<\/xml>/$session_id<\/session_id><\/xml>/; + my $host_key = @{@$res[0]}[2]; + + my $error = &main::send_msg_to_target($out_msg, $host_name, $host_key, $header, $session_id); + #if ($error != 0) {} + + my $message_id; + while (1) { + $sql = "SELECT * FROM $main::incoming_tn WHERE headertag='answer_$session_id'"; + $res = $main::incoming_db->exec_statement($sql); + if (ref @$res[0] eq "ARRAY") { + $message_id = @{@$res[0]}[0]; + last; + } + usleep(100000); + } + my $answer_xml = @{@$res[0]}[3]; + my %data = ( 'answer_xml' => 'bin noch da' ); + my $answer_msg = &build_msg("got_new_ping", "$main::server_address", "GOSA", \%data); + + $sql = "DELETE FROM $main::incoming_tn WHERE id=$message_id"; + $res = $main::incoming_db->exec_statement($sql); + + + my @answer_msg_l = ( $answer_msg ); + return @answer_msg_l; +} + + sub gen_smb_hash { my ($msg, $msg_hash, $session_id) = @_ ; @@ -291,7 +415,12 @@ sub gen_smb_hash { my $password = @{$msg_hash->{password}}[0]; my %data= ('hash' => join(q[:], ntlmgen $password)); - my $out_msg = &build_msg("gen_smb_hash", $target, 'GOSA', \%data ); + my $out_msg = &build_msg("gen_smb_hash", $target, $source, \%data ); + my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0]; + if (defined $forward_to_gosa) { + $out_msg =~s/<\/xml>/$forward_to_gosa<\/forward_to_gosa><\/xml>/; + } + return ( $out_msg ); } @@ -317,8 +446,12 @@ sub network_completition { %data= ('ip' => '', 'mac' => ''); } - my $out_msg = &build_msg("network_completition", $target, 'GOSA', \%data ); - + my $out_msg = &build_msg("network_completition", $target, $source, \%data ); + my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0]; + if (defined $forward_to_gosa) { + $out_msg =~s/<\/xml>/$forward_to_gosa<\/forward_to_gosa><\/xml>/; + } + return ( $out_msg ); } @@ -330,7 +463,7 @@ sub detect_hardware { my $target = @{$msg_hash->{target}}[0]; my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -353,18 +486,14 @@ sub trigger_reload_ldap_config { my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } - my $out_hash = &create_xml_hash("reload_ldap_config", $main::server_address, $main::server_address, $target); - if( defined ) { - &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id); - } - my $out_msg = &create_xml_string($out_hash); - my @out_msg_l; - push(@out_msg_l, $out_msg); + my $out_msg = &ClientPackages::new_ldap_config($target, $session_id); + my @out_msg_l = ( $out_msg ); + return @out_msg_l; } @@ -374,20 +503,24 @@ sub set_activated_for_installation { my $header = @{$msg_hash->{header}}[0]; my $source = @{$msg_hash->{source}}[0]; my $target = @{$msg_hash->{target}}[0]; + my @out_msg_l; + # update status of job my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } + # create set_activated_for_installation message for delivery my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $target); if( defined $jobdb_id ) { &add_content2xml_hash($out_hash, 'jobdb_id', $jobdb_id); } my $out_msg = &create_xml_string($out_hash); - my @out_msg_l = ( $out_msg ); + push(@out_msg_l, $out_msg); + return @out_msg_l; } @@ -421,7 +554,7 @@ sub trigger_action_lock { &main::change_goto_state('locked', \@{$msg_hash->{target}}, $session_id); my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -439,7 +572,7 @@ sub trigger_action_activate { &main::change_goto_state('active', \@{$msg_hash->{target}}, $session_id); my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -460,7 +593,7 @@ sub trigger_action_localboot { &main::change_fai_state('localboot', \@{$msg_hash->{target}}, $session_id); my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -477,7 +610,7 @@ sub trigger_action_halt { &main::change_fai_state('halt', \@{$msg_hash->{target}}, $session_id); my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -494,7 +627,7 @@ sub trigger_action_reboot { &main::change_fai_state('reboot', \@{$msg_hash->{target}}, $session_id); my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -511,7 +644,7 @@ sub trigger_action_memcheck { &main::change_fai_state('memcheck', \@{$msg_hash->{target}}, $session_id); my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -555,7 +688,7 @@ sub trigger_action_instant_update { my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -574,7 +707,7 @@ sub trigger_action_sysinfo { &main::change_fai_state('sysinfo', \@{$msg_hash->{target}}, $session_id); my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -589,7 +722,7 @@ sub new_key_for_client { my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -605,7 +738,7 @@ sub trigger_action_rescan { my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -622,7 +755,7 @@ sub trigger_action_wake { my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0]; if( defined $jobdb_id) { - my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id='$jobdb_id'"; + my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id"; &main::daemon_log("$session_id DEBUG: $sql_statement", 7); my $res = $main::job_db->exec_statement($sql_statement); } @@ -635,4 +768,188 @@ sub trigger_action_wake { } +sub get_available_kernel { + my ($msg, $msg_hash, $session_id) = @_; + + my $source = @{$msg_hash->{'source'}}[0]; + my $target = @{$msg_hash->{'target'}}[0]; + my $release= @{$msg_hash->{'release'}}[0]; + + my @kernel; + # Get Kernel packages for release + my $sql_statement = "SELECT * FROM $main::packages_list_tn WHERE distribution='$release' AND package LIKE 'linux\-image\-%'"; + my $res_hash = $main::packages_list_db->select_dbentry($sql_statement); + my %data; + my $i=1; + + foreach my $package (keys %{$res_hash}) { + $data{"answer".$i++}= $data{"answer".$i++}= ${$res_hash}{$package}->{'package'}; + } + $data{"answer".$i++}= "default"; + + my $out_msg = &build_msg("get_available_kernel", $target, $source, \%data); + my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0]; + if (defined $forward_to_gosa) { + $out_msg =~s/<\/xml>/$forward_to_gosa<\/forward_to_gosa><\/xml>/; + } + + return ( $out_msg ); +} + + +sub trigger_activate_new { + my ($msg, $msg_hash, $session_id) = @_; + + my $source = @{$msg_hash->{'source'}}[0]; + my $target = @{$msg_hash->{'target'}}[0]; + my $header= @{$msg_hash->{'header'}}[0]; + my $mac= (defined($msg_hash->{'mac'}))?@{$msg_hash->{'mac'}}[0]:undef; + my $ogroup= (defined($msg_hash->{'ogroup'}))?@{$msg_hash->{'ogroup'}}[0]:undef; + my $timestamp= (defined($msg_hash->{'timestamp'}))?@{$msg_hash->{'timestamp'}}[0]:undef; + my $base= (defined($msg_hash->{'base'}))?@{$msg_hash->{'base'}}[0]:undef; + my $hostname= (defined($msg_hash->{'fqdn'}))?@{$msg_hash->{'fqdn'}}[0]:undef; + my $ip_address= (defined($msg_hash->{'ip'}))?@{$msg_hash->{'ip'}}[0]:undef; + my $dhcp_statement= (defined($msg_hash->{'dhcp'}))?@{$msg_hash->{'dhcp'}}[0]:undef; + my $jobdb_id= (defined($msg_hash->{'jobdb_id'}))?@{$msg_hash->{'jobdb_id'}}[0]:undef; + + my $ldap_handle = &main::get_ldap_handle(); + my $ldap_entry; + my $ogroup_entry; + + # build the base, use optional base parameter or take it from ogroup + if(!(defined($base) && (length($base) > 0))) { + my $ldap_mesg= $ldap_handle->search( + base => $main::ldap_base, + scope => 'sub', + filter => "(&(objectClass=gosaGroupOfnames)(cn=$ogroup))", + ); + if($ldap_mesg->count == 1) { + $ogroup_entry= $ldap_mesg->pop_entry(); + + # Subtract the ObjectGroup cn + $base = $1 if $ogroup_entry->dn =~ /cn=$ogroup,ou=groups,(.*)$/; + } elsif ($ldap_mesg->count == 0) { + &main::daemon_log("ERROR: A GosaGroupOfNames with cn '$ogroup' was not found in base '".$main::ldap_base."'!", 1); + } else { + &main::daemon_log("ERROR: More than one ObjectGroups with cn '$ogroup' was found in base '".$main::ldap_base."'!", 1); + } + } + + # prepend ou=systems + $base = "ou=systems,".$base; + + # Search for an existing entry (should be in ou=incoming) + my $ldap_mesg= $ldap_handle->search( + base => $main::ldap_base, + scope => 'sub', + filter => "(&(objectClass=GOhard)(|(macAddress=$mac)(dhcpHWaddress=$mac)))", + ); + + # TODO: Find a way to guess an ip address for hosts with no ldap entry (MAC->ARP->IP) + + if($ldap_mesg->count == 1) { + &main::daemon_log("NOTICE: One system with mac address '$mac' was found in base '".$main::ldap_base."'!", 1); + # Get the entry from LDAP + $ldap_entry= $ldap_mesg->pop_entry(); + + if(!($ldap_entry->dn() eq "cn=".$ldap_entry->get_value('cn').",$base")) { + # Move the entry to the new ou + $ldap_entry->changetype('moddn'); + $ldap_entry->add( + 'newrdn' => "cn=".$ldap_entry->get_value('cn'), + 'deleteoldrdn' => "1", + 'newsuperior' => $base, + ); + my $mesg = $ldap_entry->update($ldap_handle); + if($mesg->code() != 0) { + &main::daemon_log("ERROR: Updating the dn for system with mac address '$mac' failed (code ".$mesg->code().") with '".$mesg->{'errorMessage'}."'!", 1); + } + } + # Check for needed objectClasses + my $oclasses = $ldap_entry->get_value('objectClass', asref => 1); + foreach my $oclass ("FAIobject", "GOhard") { + if(!(scalar grep $_ eq $oclass, map {$_ => 1} @$oclasses)) { + $ldap_entry->add( + objectClass => $oclass, + ); + } + } + + # Set FAIstate + if(defined($ldap_entry->get_value('FAIstate'))) { + if(!($ldap_entry->get_value('FAIstate') eq 'install')) { + $ldap_entry->replace( + 'FAIstate' => 'install' + ); + my $faistate_mesg = $ldap_entry->update($ldap_handle); + if ($faistate_mesg->code() != 0) { + &main::daemon_log("ERROR: Updating the FAIstate for '".$ldap_entry->dn()."' failed (code '".$faistate_mesg->code()."') with '$@'!", 1); + } + } + } else { + $ldap_entry->add( + 'FAIstate' => 'install' + ); + my $faistate_mesg = $ldap_entry->update($ldap_handle); + if ($faistate_mesg->code() != 0) { + &main::daemon_log("ERROR: Updating the FAIstate for '".$ldap_entry->dn()."' failed (code '".$faistate_mesg->code()."') with '$@'!", 1); + } + } + + + } elsif ($ldap_mesg->count == 0) { + # TODO: Create a new entry + # $ldap_entry = Net::LDAP::Entry->new(); + # $ldap_entry->dn("cn=$mac,$base"); + &main::daemon_log("WARNING: No System with mac address '$mac' was found in base '".$main::ldap_base."'! Re-queuing job.", 4); + $main::job_db->select_dbentry("UPDATE jobs SET state = 'waiting', timestamp = '".&get_time()."' WHERE header = 'trigger_activate_new' AND mac_address LIKE '$mac'"); + } else { + &main::daemon_log("ERROR: More than one system with mac address '$mac' was found in base '".$main::ldap_base."'!", 1); + } + + my $update_mesg = $ldap_entry->update($ldap_handle); + if ($update_mesg->code() != 0) { + &main::daemon_log("ERROR: Updating attributes for '".$ldap_entry->dn()."' failed (code '".$update_mesg->code()."') with '".$update_mesg->{'errorMessage'}."'!", 1); + } + + # Add to ObjectGroup + if(!(scalar grep $_, map {$_ => 1} $ogroup_entry->get_value('member', asref => 1))) { + $ogroup_entry->add ( + 'member' => $ldap_entry->dn(), + ); + my $ogroup_result = $ogroup_entry->update($ldap_handle); + if ($ogroup_result->code() != 0) { + &main::daemon_log("ERROR: Updating the ObjectGroup '$ogroup' failed (code '".$ogroup_result->code()."') with '".$ogroup_result->{'errorMessage'}."'!", 1); + } + } + + # Finally set gotoMode to active + if(defined($ldap_entry->get_value('gotoMode'))) { + if(!($ldap_entry->get_value('gotoMode') eq 'active')) { + $ldap_entry->replace( + 'gotoMode' => 'active' + ); + } + } else { + $ldap_entry->add( + 'gotoMode' => 'active' + ); + } + my $activate_result = $ldap_entry->update($ldap_handle); + if ($activate_result->code() != 0) { + &main::daemon_log("ERROR: Activating system '".$ldap_entry->dn()."' failed (code '".$activate_result->code()."') with '".$activate_result->{'errorMessage'}."'!", 1); + } + + + my %data; + my $out_msg = &build_msg("activate_new", $target, $source, \%data); + my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0]; + if (defined $forward_to_gosa) { + $out_msg =~s/<\/xml>/$forward_to_gosa<\/forward_to_gosa><\/xml>/; + } + + return ( $out_msg ); +} + + 1;