From: janw <janw@594d385d-05f5-0310-b6e9-bd551577e9d8>
Date: Fri, 1 Feb 2008 10:19:49 +0000 (+0000)
Subject: Various Fixes.
X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=dd1b722dbfaa3c8082d55589da77ab1b79d05d0e;p=gosa.git

Various Fixes.
Detected Hardware gets sent to server.


git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@8712 594d385d-05f5-0310-b6e9-bd551577e9d8
---

diff --git a/gosa-si/gosa-si-client b/gosa-si/gosa-si-client
index 27ae2d160..2076b0979 100755
--- a/gosa-si/gosa-si-client
+++ b/gosa-si/gosa-si-client
@@ -1003,6 +1003,7 @@ sub process_incoming_msg {
     elsif ($header eq 'ping') { &got_ping($msg_hash) }
     elsif ($header eq 'wake_up') { &execute_event($msg_hash)}
     elsif ($header eq 'new_passwd') { &new_passwd()}
+	elsif ($header eq 'detect_hardware') { &detect_hardware()}
     else { daemon_log("ERROR: no function assigned to msg $header", 5) }
 
     return;
@@ -1279,8 +1280,8 @@ sub detect_hardware {
 	chomp $hwinfo;
 
 	if (!(defined($hwinfo) && length($hwinfo) > 0)) {
-		print "ERROR: hwinfo was not found in \$PATH!\n";
-		exit(1);
+		&main::daemon_log("ERROR: hwinfo was not found in \$PATH! Hardware detection will not work!", 1);
+		return;
 	}
 
 	my $result= {
@@ -1303,6 +1304,7 @@ sub detect_hardware {
 		ghScsiDev       => [],
 	};
 
+	&main::daemon_log("Starting hardware detection", 4);
 	my $gfxcard= `$hwinfo --gfxcard`;
 	my $primary_adapter= $1 if $gfxcard =~ /^Primary display adapter:\s#(\d+)\n/m;
 	if(defined($primary_adapter)) {
@@ -1379,7 +1381,13 @@ sub detect_hardware {
 		push (@{$result->{ghScsiDev}}, "$1 $2");
 	}
 
-	return $result;
+	&main::daemon_log("Hardware detection done!", 4);
+
+    return &send_msg_hash2address(
+		&create_xml_hash("detected_hardware", $client_address, $server_address, $result),
+		$server_address, 
+		$server_passwd
+	);
 }
 
 #==== MAIN = main ==============================================================
diff --git a/gosa-si/gosa-si-server b/gosa-si/gosa-si-server
index 1db1836ec..f0deffab0 100755
--- a/gosa-si/gosa-si-server
+++ b/gosa-si/gosa-si-server
@@ -454,18 +454,18 @@ sub input_from_known_server {
             next;
         }
         my $host_key = $hit->{hostkey};
-        daemon_log("ServerPackages: host_name: $host_name", 7);
-        daemon_log("ServerPackages: host_key: $host_key", 7);
+        daemon_log("SIPackages: host_name: $host_name", 7);
+        daemon_log("SIPackages: host_key: $host_key", 7);
 
         # check if module can open msg envelope with module key
         my ($msg, $msg_hash) = &check_key_and_xml_validity($input, $host_key);
         if( (!$msg) || (!$msg_hash) ) {
-            daemon_log("ServerPackages: deciphering raise error", 7);
+            daemon_log("SIPackages: deciphering raise error", 7);
             daemon_log("$@", 8);
             next;
         }
         else {
-            $module = "ServerPackages";
+            $module = "SIPackages";
             last;
         }
     }
@@ -486,28 +486,29 @@ sub input_from_known_client {
     my $query_res = $known_clients_db->select_dbentry( $sql_statement ); 
     while( my ($hit_num, $hit) = each %{ $query_res } ) {    
         my $host_name = $hit->{hostname};
-        if( not $host_name =~ "^$remote_ip") {
+        if( not $host_name =~ /^$remote_ip:\d*$/) {
             next;
-        }
+		}
         my $host_key = $hit->{hostkey};
-        daemon_log("ServerPackages: host_name: $host_name", 7);
-        daemon_log("ServerPackages: host_key: $host_key", 7);
+        &daemon_log("SIPackages: host_name: $host_name", 7);
+        &daemon_log("SIPackages: host_key: $host_key", 7);
 
         # check if module can open msg envelope with module key
-        my ($msg, $msg_hash) = &check_key_and_xml_validity($input, $host_key);
+        ($msg, $msg_hash) = &check_key_and_xml_validity($input, $host_key);
+
         if( (!$msg) || (!$msg_hash) ) {
-            daemon_log("ServerPackages: deciphering raise error", 7);
-            daemon_log("$@", 8);
+            &daemon_log("SIPackages: deciphering raise error", 7);
+            &daemon_log("$@", 8);
             next;
         }
         else {
-            $module = "ServerPackages";
+            $module = "SIPackages";
             last;
         }
     }
 
     if( (!$msg) || (!$msg_hash) || (!$module) ) {
-        daemon_log("Incoming message is not from a known client", 3);
+        &daemon_log("Incoming message is not from a known client", 3);
     }
 
     return ($msg, $msg_hash, $module);
@@ -703,7 +704,7 @@ sub client_input {
 
     # msg is from a gosa-si-client
     if(( !$msg ) || ( !$msg_hash ) || ( !$module )){
-        ($msg, $msg_hash, $module) = &input_from_known_client($input);
+        ($msg, $msg_hash, $module) = &input_from_known_client($input, $heap->{'remote_ip'});
     }
 
     # an error occurred
diff --git a/gosa-si/modules/SIPackages.pm b/gosa-si/modules/SIPackages.pm
index 4e2e0279b..e7372d8df 100644
--- a/gosa-si/modules/SIPackages.pm
+++ b/gosa-si/modules/SIPackages.pm
@@ -326,8 +326,9 @@ sub process_incoming_msg {
             elsif ($header eq 'who_has_i_do') { @out_msg_l = &who_has_i_do($msg_hash) }
             elsif ($header eq 'got_ping') { @out_msg_l = &got_ping($msg_hash)}
             elsif ($header eq 'get_load') { @out_msg_l = &execute_actions($msg_hash)}
+            elsif ($header eq 'detected_hardware') { @out_msg_l = &process_detected_hardware($msg_hash)}
             else {
-                &main::daemon_log("ERROR: $header is an unknown core funktion", 1);
+                &main::daemon_log("ERROR: $header is an unknown core function", 1);
                 $error++;
             }
         }
@@ -435,6 +436,7 @@ sub here_i_am {
 
     my $source = @{$msg_hash->{source}}[0];
     my $mac_address = @{$msg_hash->{mac_address}}[0];
+	my $gotoHardwareChecksum = @{$msg_hash->{gotoHardwareChecksum}}[0];
 
     # number of known clients
     my $nu_clients= $main::known_clients_db->count_dbentries('known_clients');
@@ -511,6 +513,10 @@ sub here_i_am {
         push(@out_msg_l, $new_ldap_config_out);
     }
 
+	my $hardware_config_out = &hardware_config($source, $gotoHardwareChecksum);
+	if( $hardware_config_out ) {
+		push(@out_msg_l, $hardware_config_out);
+	}
 
     return @out_msg_l;
 }
@@ -562,7 +568,6 @@ sub who_has_i_do {
     print "\ngot msg $header:\nserver $source has client with $search_param $search_value\n";
 }
 
-
 #===  FUNCTION  ================================================================
 #         NAME:  new_ldap_config
 #   PARAMETERS:  address - string - ip address and port of a host
@@ -570,7 +575,156 @@ sub who_has_i_do {
 #  DESCRIPTION:  send to address the ldap configuration found for dn gotoLdapServer
 #===============================================================================
 sub new_ldap_config {
-    my ($address) = @_ ;
+	my ($address) = @_ ;
+
+	my $sql_statement= "SELECT * FROM known_clients WHERE hostname='$address'";
+	my $res = $main::known_clients_db->select_dbentry( $sql_statement );
+
+	# check hit
+	my $hit_counter = keys %{$res};
+	if( not $hit_counter == 1 ) {
+		&main::daemon_log("ERROR: more or no hit found in known_clients_db by query by '$address'", 1);
+	}
+
+	my $macaddress = $res->{1}->{macaddress};
+	my $hostkey = $res->{1}->{hostkey};
+
+	if (not defined $macaddress) {
+		&main::daemon_log("ERROR: no mac address found for client $address", 1);
+		return;
+	}
+
+	# Build LDAP connection
+	my $ldap = Net::LDAP->new($ldap_uri);
+	if( not defined $ldap ) {
+		&main::daemon_log("ERROR: cannot connect to ldap: $ldap_uri", 1);
+		return;
+	} 
+
+
+	# Bind to a directory with dn and password
+	my $mesg= $ldap->bind($ldap_admin_dn, $ldap_admin_password);
+
+	# Perform search
+	$mesg = $ldap->search( base   => $ldap_base,
+		scope  => 'sub',
+		attrs => ['dn', 'gotoLdapServer', 'gosaUnitTag'],
+		filter => "(&(objectClass=GOhard)(macaddress=$macaddress))");
+	#$mesg->code && die $mesg->error;
+	if($mesg->code) {
+		&main::daemon_log($mesg->error, 1);
+		return;
+	}
+
+	# Sanity check
+	if ($mesg->count != 1) {
+		&main::daemon_log("WARNING: client mac address $macaddress not found/not unique in ldap search", 1);
+		&main::daemon_log("\tbase: $ldap_base", 1);
+		&main::daemon_log("\tscope: sub", 1);
+		&main::daemon_log("\tattrs: dn, gotoLdapServer", 1);
+		&main::daemon_log("\tfilter: (&(objectClass=GOhard)(macaddress=$macaddress))", 1);
+		return;
+	}
+
+	my $entry= $mesg->entry(0);
+	my $dn= $entry->dn;
+	my @servers= $entry->get_value("gotoLdapServer");
+	my $unit_tag= $entry->get_value("gosaUnitTag");
+	my @ldap_uris;
+	my $server;
+	my $base;
+
+	# Do we need to look at an object class?
+	if (length(@servers) < 1){
+		$mesg = $ldap->search( base   => $ldap_base,
+			scope  => 'sub',
+			attrs => ['dn', 'gotoLdapServer'],
+			filter => "(&(objectClass=gosaGroupOfNames)(member=$dn))");
+		#$mesg->code && die $mesg->error;
+		if($mesg->code) {
+			&main::daemon_log($mesg->error, 1);
+			return;
+		}
+
+		# Sanity check
+		if ($mesg->count != 1) {
+			&main::daemon_log("WARNING: no LDAP information found for client mac $macaddress", 1);
+			return;
+		}
+
+		$entry= $mesg->entry(0);
+		$dn= $entry->dn;
+		@servers= $entry->get_value("gotoLdapServer");
+	}
+
+	@servers= sort (@servers);
+
+	foreach $server (@servers){
+		$base= $server;
+		$server =~ s%^[^:]+:[^:]+:(ldap.*://[^/]+)/.*$%$1%;
+		$base =~ s%^[^:]+:[^:]+:ldap.*://[^/]+/(.*)$%$1%;
+		push (@ldap_uris, $server);
+	}
+
+	# Assemble data package
+	my %data = ( 'ldap_uri'  => \@ldap_uris, 'ldap_base' => $base,
+		'ldap_cfg' => \@ldap_cfg, 'pam_cfg' => \@pam_cfg,'nss_cfg' => \@nss_cfg );
+
+	# Need to append GOto settings?
+	if (defined $goto_admin and defined $goto_secret){
+		$data{'goto_admin'}= $goto_admin;
+		$data{'goto_secret'}= $goto_secret;
+	}
+
+	# Append unit tag if needed
+	if (defined $unit_tag){
+
+		# Find admin base and department name
+		$mesg = $ldap->search( base   => $ldap_base,
+			scope  => 'sub',
+			attrs => ['dn', 'ou'],
+			filter => "(&(objectClass=gosaAdministrativeUnit)(gosaUnitTag=$unit_tag))");
+		#$mesg->code && die $mesg->error;
+		if($mesg->code) {
+			&main::daemon_log($mesg->error, 1);
+			return;
+		}
+
+		# Sanity check
+		if ($mesg->count != 1) {
+			&main::daemon_log("WARNING: cannot find administrative unit for client with tag $unit_tag", 1);
+			return;
+		}
+
+		$entry= $mesg->entry(0);
+		$data{'admin_base'}= $entry->dn;
+		$data{'department'}= $entry->get_value("ou");
+
+		# Append unit Tag
+		$data{'unit_tag'}= $unit_tag;
+	}
+
+	# Unbind
+	$mesg = $ldap->unbind;
+
+	# Send information
+	return send_msg("new_ldap_config", $server_address, $address, \%data, $hostkey);
+}
+
+sub process_detected_hardware {
+	my $msg_hash = shift;
+
+
+	return;
+}
+#===  FUNCTION  ================================================================
+#         NAME:  hardware_config
+#   PARAMETERS:  address - string - ip address and port of a host
+#      RETURNS:  
+#  DESCRIPTION:  
+#===============================================================================
+sub hardware_config {
+    my ($address, $gotoHardwareChecksum, $detectedHardware) = @_ ;
     
     my $sql_statement= "SELECT * FROM known_clients WHERE hostname='$address'";
     my $res = $main::known_clients_db->select_dbentry( $sql_statement );
@@ -603,59 +757,16 @@ sub new_ldap_config {
     # Perform search
     $mesg = $ldap->search( base   => $ldap_base,
 		    scope  => 'sub',
-		    attrs => ['dn', 'gotoLdapServer', 'gosaUnitTag'],
+		    attrs => ['dn', 'gotoHardwareChecksum'],
 		    filter => "(&(objectClass=GOhard)(macaddress=$macaddress))");
-    $mesg->code && die $mesg->error;
-
-    # Sanity check
-    if ($mesg->count != 1) {
-	    &main::daemon_log("WARNING: client mac address $macaddress not found/not unique in ldap search", 1);
-	    &main::daemon_log("\tbase: $ldap_base", 1);
-	    &main::daemon_log("\tscope: sub", 1);
-	    &main::daemon_log("\tattrs: dn, gotoLdapServer", 1);
-	    &main::daemon_log("\tfilter: (&(objectClass=GOhard)(macaddress=$macaddress))", 1);
-	    return;
-    }
+		#$mesg->code && die $mesg->error;
 
-    my $entry= $mesg->entry(0);
-    my $dn= $entry->dn;
-    my @servers= $entry->get_value("gotoLdapServer");
-    my $unit_tag= $entry->get_value("gosaUnitTag");
-    my @ldap_uris;
-    my $server;
-    my $base;
-
-    # Do we need to look at an object class?
-    if (length(@servers) < 1){
-	    $mesg = $ldap->search( base   => $ldap_base,
-			    scope  => 'sub',
-			    attrs => ['dn', 'gotoLdapServer'],
-			    filter => "(&(objectClass=gosaGroupOfNames)(member=$dn))");
-	    $mesg->code && die $mesg->error;
-
-            # Sanity check
-	    if ($mesg->count != 1) {
-		    &main::daemon_log("WARNING: no LDAP information found for client mac $macaddress", 1);
-		    return;
-	    }
-
-	    $entry= $mesg->entry(0);
-	    $dn= $entry->dn;
-	    @servers= $entry->get_value("gotoLdapServer");
-    }
-
-    @servers= sort (@servers);
-
-    foreach $server (@servers){
-	    $base= $server;
-	    $server =~ s%^[^:]+:[^:]+:(ldap.*://[^/]+)/.*$%$1%;
-	    $base =~ s%^[^:]+:[^:]+:ldap.*://[^/]+/(.*)$%$1%;
-	    push (@ldap_uris, $server);
-    }
+    	#my $entry= $mesg->entry(0);
+    	#my $dn= $entry->dn;
+    	#my @servers= $entry->get_value("gotoHardwareChecksum");
 
     # Assemble data package
-    my %data = ( 'ldap_uri'  => \@ldap_uris, 'ldap_base' => $base,
-	             'ldap_cfg' => \@ldap_cfg, 'pam_cfg' => \@pam_cfg,'nss_cfg' => \@nss_cfg );
+    my %data = ();
 
     # Need to append GOto settings?
     if (defined $goto_admin and defined $goto_secret){
@@ -663,35 +774,12 @@ sub new_ldap_config {
 	    $data{'goto_secret'}= $goto_secret;
     }
 
-    # Append unit tag if needed
-    if (defined $unit_tag){
-           
-            # Find admin base and department name
-	    $mesg = $ldap->search( base   => $ldap_base,
-			    scope  => 'sub',
-			    attrs => ['dn', 'ou'],
-			    filter => "(&(objectClass=gosaAdministrativeUnit)(gosaUnitTag=$unit_tag))");
-	    $mesg->code && die $mesg->error;
-
-            # Sanity check
-	    if ($mesg->count != 1) {
-		    &main::daemon_log("WARNING: cannot find administrative unit for client with tag $unit_tag", 1);
-		    return;
-	    }
-
-	    $entry= $mesg->entry(0);
-	    $data{'admin_base'}= $entry->dn;
-	    $data{'department'}= $entry->get_value("ou");
-
-	    # Append unit Tag
-	    $data{'unit_tag'}= $unit_tag;
-    }
-
     # Unbind
     $mesg = $ldap->unbind;
 
+	&main::daemon_log("Send detect_hardware message to $address", 4);
     # Send information
-    return send_msg("new_ldap_config", $server_address, $address, \%data, $hostkey);
+    return send_msg("detect_hardware", $server_address, $address, \%data, $hostkey);
 }