From 8d283ea3b46ddaee510f8e00de0d15c9086709b5 Mon Sep 17 00:00:00 2001 From: janw Date: Thu, 29 May 2008 07:06:33 +0000 Subject: [PATCH] Added new event "trigger_activate_new" - activates FAI systems that are waiting for activation and moves them to the right place in LDAP. git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@11091 594d385d-05f5-0310-b6e9-bd551577e9d8 --- gosa-si/server/events/gosaTriggered.pm | 149 +++++++++++++++++++++++++ 1 file changed, 149 insertions(+) diff --git a/gosa-si/server/events/gosaTriggered.pm b/gosa-si/server/events/gosaTriggered.pm index 8f55b3368..164c4913e 100644 --- a/gosa-si/server/events/gosaTriggered.pm +++ b/gosa-si/server/events/gosaTriggered.pm @@ -33,6 +33,7 @@ my @events = ( "recreate_packages_list_db", "send_user_msg", "get_available_kernel", + "trigger_activate_new", ); @EXPORT = @events; @@ -782,4 +783,152 @@ sub get_available_kernel { } +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]; + &main::daemon_log(Dumper($msg_hash)); + 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' + ); + } + } 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); + &main::daemon_log(Dumper($ogroup_result)); + } + } + + # 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, "GOSA", \%data); + return ( $out_msg ); +} + + 1; -- 2.30.2