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
+# 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 ("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 ("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 ("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 ("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;