Code

new functions for client messages: LOGIN, LOGOUT
[gosa.git] / gosa-si / modules / SIPackages.pm
index 933aade81f73963a07374e957e6f6490175cf823..06f310cf1c5d386a396e3f40ac05e0e07abc5295 100644 (file)
@@ -71,8 +71,8 @@ $server_mac_address= &get_mac($network_interface);
 if((not defined($main::gosa_unit_tag)) || length($main::gosa_unit_tag) == 0) {
        # Read gosaUnitTag from LDAP
        my $tmp_ldap= Net::LDAP->new($ldap_uri);
-       if(defined($tmp_ldap)) {
-               &main::daemon_log("Searching for servers gosaUnitTag with mac address $server_mac_address",6);
+       if( defined($tmp_ldap) ) {
+               &main::daemon_log("INFO: Searching for servers gosaUnitTag with mac address $server_mac_address",5);
                my $mesg= $tmp_ldap->bind($ldap_admin_dn, password => $ldap_admin_password);
                # Perform search for Unit Tag
                $mesg = $tmp_ldap->search(
@@ -86,14 +86,14 @@ if((not defined($main::gosa_unit_tag)) || length($main::gosa_unit_tag) == 0) {
                        my $entry= $mesg->entry(0);
                        my $unit_tag= $entry->get_value("gosaUnitTag");
                        if(defined($unit_tag) && length($unit_tag) > 0) {
-                               &main::daemon_log("Detected gosaUnitTag $unit_tag for creating entries", 4);
+                               &main::daemon_log("INFO: Detected gosaUnitTag $unit_tag for creating entries", 5);
                                $main::gosa_unit_tag= $unit_tag;
                        }
                } else {
                        # Perform another search for Unit Tag
                        my $hostname= `hostname -f`;
                        chomp($hostname);
-                       &main::daemon_log("Searching for servers gosaUnitTag with hostname $hostname",6);
+                       &main::daemon_log("INFO: Searching for servers gosaUnitTag with hostname $hostname",5);
                        $mesg = $tmp_ldap->search(
                                base   => $ldap_base,
                                scope  => 'sub',
@@ -104,14 +104,14 @@ if((not defined($main::gosa_unit_tag)) || length($main::gosa_unit_tag) == 0) {
                                my $entry= $mesg->entry(0);
                                my $unit_tag= $entry->get_value("gosaUnitTag");
                                if(defined($unit_tag) && length($unit_tag) > 0) {
-                                       &main::daemon_log("Detected gosaUnitTag $unit_tag for creating entries", 4);
+                                       &main::daemon_log("INFO: Detected gosaUnitTag $unit_tag for creating entries", 5);
                                        $main::gosa_unit_tag= $unit_tag;
                                }
                        } else {
                                # Perform another search for Unit Tag
                                $hostname= `hostname -s`;
                                chomp($hostname);
-                               &main::daemon_log("Searching for servers gosaUnitTag with hostname $hostname",6);
+                               &main::daemon_log("INFO: Searching for servers gosaUnitTag with hostname $hostname",5);
                                $mesg = $tmp_ldap->search(
                                        base   => $ldap_base,
                                        scope  => 'sub',
@@ -122,24 +122,20 @@ if((not defined($main::gosa_unit_tag)) || length($main::gosa_unit_tag) == 0) {
                                        my $entry= $mesg->entry(0);
                                        my $unit_tag= $entry->get_value("gosaUnitTag");
                                        if(defined($unit_tag) && length($unit_tag) > 0) {
-                                               &main::daemon_log("Detected gosaUnitTag $unit_tag for creating entries", 4);
+                                               &main::daemon_log("INFO: Detected gosaUnitTag $unit_tag for creating entries", 5);
                                                $main::gosa_unit_tag= $unit_tag;
                                        }
                                } else {
-                                       &main::daemon_log("Not using gosaUnitTag", 6);
+                                       &main::daemon_log("WARNING: No gosaUnitTag detected. Not using gosaUnitTag", 3);
                                }
                        }
                }
+        $tmp_ldap->unbind;
        } else {
-               &main::daemon_log("Using gosaUnitTag from config-file: $main::gosa_unit_tag",6);
+               &main::daemon_log("INFO: Using gosaUnitTag from config-file: $main::gosa_unit_tag",5);
        }
-       $tmp_ldap->unbind;
 }
 
-# complete addresses
-#if( $server_ip eq "0.0.0.0" ) {
-#    $server_ip = "127.0.0.1";
-#}
 
 my $server_address = "$server_ip:$server_port";
 $main::server_address = $server_address;
@@ -459,7 +455,7 @@ sub process_incoming_msg {
     # skip PREFIX
     $header =~ s/^CLMSG_//;
 
-    &main::daemon_log("SIPackages: msg to process: $header", 3);
+    &main::daemon_log("DEBUG: SIPackages: msg to process: $header", 7);
     &main::daemon_log("$msg", 8);
 
     if( 0 == length @target_l){     
@@ -479,7 +475,7 @@ sub process_incoming_msg {
             } else {
                 if( exists $event_hash->{$header} ) {
                     # a event exists with the header as name
-                    &main::daemon_log("found event '$header' at event-module '".$event_hash->{$header}."'", 5);
+                    &main::daemon_log("INFO: found event '$header' at event-module '".$event_hash->{$header}."'", 5);
                     no strict 'refs';
                     @out_msg_l = &{$event_hash->{$header}."::$header"}($msg, $msg_hash, $session_id);
                 }
@@ -493,7 +489,7 @@ sub process_incoming_msg {
             } 
         }
                else {
-                       &main::daemon_log("msg is not for gosa-si-server '$server_address', deliver it to target '$target'", 5);
+                       &main::daemon_log("INFO: msg is not for gosa-si-server '$server_address', deliver it to target '$target'", 5);
                        push(@out_msg_l, $msg);
                }
     }
@@ -630,8 +626,8 @@ sub here_i_am {
     # number of actual activ clients
     my $act_nu_clients = $nu_clients;
 
-    &main::daemon_log("number of actual activ clients: $act_nu_clients", 5);
-    &main::daemon_log("number of maximal allowed clients: $max_clients", 5);
+    &main::daemon_log("INFO: number of actual activ clients: $act_nu_clients", 5);
+    &main::daemon_log("INFO: number of maximal allowed clients: $max_clients", 5);
 
     if($max_clients <= $act_nu_clients) {
         my $out_hash = &create_xml_hash("denied", $server_address, $source);
@@ -658,6 +654,7 @@ sub here_i_am {
                                                 status=>'registered',
                                                 hostkey=>$new_passwd,
                                                 timestamp=>$act_timestamp,
+                                                login=>"nobody",
                                                 } );
 
     if ($res != 0)  {
@@ -683,7 +680,7 @@ sub here_i_am {
         &add_content2xml_hash($out_hash, "timestamp", $act_timestamp);
         my $new_client_out = &create_xml_string($out_hash);
         push(@out_msg_l, $new_client_out);
-        &main::daemon_log("send bus msg that client '$source' has registerd at server '$server_address'", 3);
+        &main::daemon_log("INFO: send bus msg that client '$source' has registerd at server '$server_address'", 5);
     }
 
     # give the new client his ldap config
@@ -790,7 +787,7 @@ sub new_ldap_config {
        # Perform search
        $mesg = $ldap->search( base   => $ldap_base,
                scope  => 'sub',
-               attrs => ['dn', 'gotoLdapServer', 'gosaUnitTag'],
+               attrs => ['dn', 'gotoLdapServer', 'gosaUnitTag', 'FAIclass'],
                filter => "(&(objectClass=GOhard)(macaddress=$macaddress))");
        #$mesg->code && die $mesg->error;
        if($mesg->code) {
@@ -815,12 +812,19 @@ sub new_ldap_config {
        my @ldap_uris;
        my $server;
        my $base;
+       my $release;
+
+       # Fill release if available
+       my $FAIclass= $entry->get_value("FAIclass");
+       if (defined $FAIclass && $FAIclass =~ /^.* :([A-Za-z0-9\/.]+).*$/) {
+               $release= $1;
+       }
 
        # Do we need to look at an object class?
        if (length(@servers) < 1){
                $mesg = $ldap->search( base   => $ldap_base,
                        scope  => 'sub',
-                       attrs => ['dn', 'gotoLdapServer'],
+                       attrs => ['dn', 'gotoLdapServer', 'FAIclass'],
                        filter => "(&(objectClass=gosaGroupOfNames)(member=$dn))");
                #$mesg->code && die $mesg->error;
                if($mesg->code) {
@@ -837,15 +841,22 @@ sub new_ldap_config {
                $entry= $mesg->entry(0);
                $dn= $entry->dn;
                @servers= $entry->get_value("gotoLdapServer");
+
+               if (not defined $release){
+                       $FAIclass= $entry->get_value("FAIclass");
+                       if (defined $FAIclass && $FAIclass =~ /^.* :([A-Za-z0-9\/.]+).*$/) {
+                               $release= $1;
+                       }
+               }
        }
 
        @servers= sort (@servers);
 
        foreach $server (@servers){
                # Conversation for backward compatibility
-               if ($server !=~ /^ldap[^:]+:\/\// ) {
+               if (not $server =~ /^ldap[^:]+:\/\// ) {
                    if ($server =~ /^([^:]+):(.*)$/ ) {
-                       $server= "1:dummy:ldap://$1/$2";
+                $server= "1:dummy:ldap://$1/$2";
                    }
                }
 
@@ -858,6 +869,9 @@ sub new_ldap_config {
        # Assemble data package
        my %data = ( 'ldap_uri'  => \@ldap_uris, 'ldap_base' => $base,
                'ldap_cfg' => \@ldap_cfg, 'pam_cfg' => \@pam_cfg,'nss_cfg' => \@nss_cfg );
+       if (defined $release){
+               $data{'release'}= $release;
+       }
 
        # Need to append GOto settings?
        if (defined $goto_admin and defined $goto_secret){
@@ -871,7 +885,7 @@ sub new_ldap_config {
                # Find admin base and department name
                $mesg = $ldap->search( base   => $ldap_base,
                        scope  => 'sub',
-                       attrs => ['dn', 'ou', 'FAIclass'],
+                       attrs => ['dn', 'ou'],
                        filter => "(&(objectClass=gosaAdministrativeUnit)(gosaUnitTag=$unit_tag))");
                #$mesg->code && die $mesg->error;
                if($mesg->code) {
@@ -893,15 +907,13 @@ sub new_ldap_config {
                $data{'unit_tag'}= $unit_tag;
        }
 
-       # Fill release if available
-       my $FAIclass= $entry->get_value("FAIclass");
-       if (defined $FAIclass && $FAIclass =~ /^.* :([A-Za-z0-9\/.]+).*$/) {
-               $data{'release'}= $1;
-       }
-
 
        # Unbind
        $mesg = $ldap->unbind;
+       if($mesg->code) {
+               &main::daemon_log($mesg->error, 1);
+               return;
+       }
 
        # Send information
        return &build_msg("new_ldap_config", $server_address, $address, \%data);