X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=gosa-si%2Fserver%2Fevents%2FlogHandling.pm;h=9e1f38cd999c7d774973743ecc06d7f5fd4dd7ee;hb=59ccab6435432d90df6793ea7f8dea06a43b1f50;hp=07e8c1adf2239ebb0d82a004db1bd056a5c7a834;hpb=a317750b8a698e35a5690309633b51332bf42d03;p=gosa.git

diff --git a/gosa-si/server/events/logHandling.pm b/gosa-si/server/events/logHandling.pm
index 07e8c1adf..9e1f38cd9 100644
--- a/gosa-si/server/events/logHandling.pm
+++ b/gosa-si/server/events/logHandling.pm
@@ -1,24 +1,30 @@
 package logHandling;
-use Exporter;
-@ISA = qw(Exporter);
-my @events = (
-    "get_events",
-#    "show_log_by_mac",
-#    "show_log_by_date",
-#    "show_log_by_date_and_mac",
-#    "get_log_by_date",
-#    "get_log_by_mac",
-#    "get_log_by_date_and_mac",
-#    "get_recent_log_by_mac",
-#    "delete_log_by_date_and_mac",
-    );
-@EXPORT = @events;
+
 
 use strict;
 use warnings;
-use GOSA::GosaSupportDaemon;
+
 use Data::Dumper;
 use File::Spec;
+use MIME::Base64;
+use GOsaSI::GosaSupportDaemon;
+
+use Exporter;
+
+our @ISA = qw(Exporter);
+
+my @events = (
+    "get_events",
+    "show_log_by_mac",
+    "show_log_by_date",
+    "show_log_by_date_and_mac",
+    "show_log_files_by_date_and_mac",
+    "get_log_file_by_date_and_mac",
+    "get_recent_log_by_mac",
+    "delete_log_by_date_and_mac",
+    );
+
+our @EXPORT = @events;
 
 BEGIN {}
 
@@ -26,146 +32,460 @@ END {}
 
 ### Start ######################################################################
 
-#&main::read_configfile($main::cfg_file, %cfg_defaults);
 
+#===  FUNCTION  ================================================================
+#         NAME:  get_events
+#   PARAMETERS:  none
+#      RETURNS:  reference of exported events
+#  DESCRIPTION:  tells the caller which functions are available
+#===============================================================================
 sub get_events {
     return \@events
 }
 
+
+#===  FUNCTION  ================================================================
+#         NAME: show_log_by_date
+#  DESCRIPTION: reporting installed hosts matching to regex of date
+#   PARAMETERS: [$msg]        original incoming message
+#               [$msg_hash]   incoming message transformed to hash concerning XML::Simple
+#               [$session_id] POE session id 
+#      RETURNS: gosa-si valid answer string
+#===============================================================================
 sub show_log_by_date {
     my ($msg, $msg_hash, $session_id) = @_;
     my $header = @{$msg_hash->{header}}[0];
-    $header =~ s/gosa_//;
     my $target = @{$msg_hash->{target}}[0];
     my $source = @{$msg_hash->{source}}[0];
-
     my $date_l =  $msg_hash->{date};
-	#my $date_h;
-	#map {$date_h->{$_}++} @{$date_l};
+    my $out_msg;
+    $header =~ s/gosa_//;
 
     if (not -d $main::client_fai_log_dir) {
-        &main::daemon_log("$session_id ERROR: client fai log directory '$main::client_fai_log_dir' do not exist", 1); 
-        return;
+        my $error_string = "client fai log directory '$main::client_fai_log_dir' do not exist";
+        &main::daemon_log("$session_id ERROR: $error_string", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
     }
 
     # build out_msg
     my $out_hash = &create_xml_hash($header, $target, $source);
     
-    # fetch mac directory
+    # read mac directory
     opendir(DIR, $main::client_fai_log_dir); 
     my @avail_macs = readdir(DIR);
     closedir(DIR);   
- 
- 	# goto each mac directory
-	# select all dates which matches the parameter dates
-	my %res_h;
-	foreach my $date ($date_l) {
-		
-		# go through all mac addresses 
-		foreach my $mac (@avail_macs) {
-			my $mac_dir = File::Spec->catdir($main::client_fai_log_dir, $mac);
-
-			opendir(DIR, $mac_dir);
-			my @avail_dates = readdir(DIR);
-			closedir(DIR);
-			
-			# go through all dates of one mac address
-			foreach my $avail_date (@avail_dates) {
-				if ($avail_date =~ /$date/i) {
-					if (not exists %res)
-					push(%res_h->{$mac}, );
-				}
-			}
-		}
-	}
+    foreach my $avail_mac (@avail_macs) {
+        # check mac address 
+        if ($avail_mac eq ".." || $avail_mac eq ".") { next; }
 
+        # read install dates directory
+        my $mac_dir = File::Spec->catdir($main::client_fai_log_dir, $avail_mac);
+        opendir(DIR, $mac_dir);
+        my @avail_dates = readdir(DIR);
+        closedir(DIR);
+        foreach my $date ( @{$date_l} ) {    # multiple date selection is allowed
+            foreach my $avail_date (@avail_dates) {
+                # check install date
+                if ($avail_date eq ".." || $avail_date eq ".") { next; }
+                if (not $avail_date =~ /$date/i) { next; }
+
+                # add content to out_msg
+                &add_content2xml_hash($out_hash, $avail_date, $avail_mac); 
+            }
+        }
+    }
+
+    $out_msg = &create_xml_string($out_hash);
+    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<\/forward_to_gosa><\/xml>/;
+    }
+
+    return ($out_msg);
 }
 
+
+#===  FUNCTION  ================================================================
+#         NAME: show_log_by_mac
+#  DESCRIPTION: reporting installation dates matching to regex of mac address
+#   PARAMETERS: [$msg]        original incoming message
+#               [$msg_hash]   incoming message transformed to hash concerning XML::Simple
+#               [$session_id] POE session id 
+#      RETURNS: gosa-si valid answer string 
+#===============================================================================
 sub show_log_by_mac {
     my ($msg, $msg_hash, $session_id) = @_;
     my $header = @{$msg_hash->{header}}[0];
-    $header =~ s/gosa_//;
     my $target = @{$msg_hash->{target}}[0];
     my $source = @{$msg_hash->{source}}[0];
     my $mac_l = $msg_hash->{mac};
 
+    $header =~ s/gosa_//;
+
     if (not -d $main::client_fai_log_dir) {
-        &main::daemon_log("$session_id ERROR: client fai log directory '$main::client_fai_log_dir' do not exist", 1); 
-        return;
+        my $error_string = "client fai log directory '$main::client_fai_log_dir' do not exist";
+        &main::daemon_log("$session_id ERROR: $error_string", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
     }
 
     # build out_msg
     my $out_hash = &create_xml_hash($header, $target, $source);
-    foreach my $mac (@{$mac_l}) {
-        my $act_log_dir = File::Spec->catdir($main::client_fai_log_dir, $mac);
-        if (not -d $act_log_dir) { next; }
-        $mac =~ s/:/_/g;
 
-        # fetch mac directory
-        opendir(DIR, $act_log_dir); 
-        my @install_dates = readdir(DIR);
-        closedir(DIR);   
-        foreach my $date (@install_dates) {
-            if ($date eq ".." || $date eq ".") { next; }
-            &add_content2xml_hash($out_hash, "mac_$mac", $date);
+    # read mac directory
+    opendir(DIR, $main::client_fai_log_dir); 
+    my @avail_macs = readdir(DIR);
+    closedir(DIR);   
+    foreach my $mac (@{$mac_l}) {   # multiple mac selection is allowed
+        foreach my $avail_mac ( @avail_macs ) {
+            # check mac address
+            if ($avail_mac eq ".." || $avail_mac eq ".") { next; }
+            if (not $avail_mac =~ /$mac/i) { next; }
+            
+            # read install dates directory
+            my $act_log_dir = File::Spec->catdir($main::client_fai_log_dir, $avail_mac);
+            if (not -d $act_log_dir) { next; }
+            opendir(DIR, $act_log_dir); 
+            my @avail_dates = readdir(DIR);
+            closedir(DIR);   
+            $avail_mac =~ s/:/_/g;   # make mac address XML::Simple valid
+            foreach my $avail_date (@avail_dates) {
+                # check install date
+                if ($avail_date eq ".." || $avail_date eq ".") { next; }
+
+                # add content to out_msg
+                &add_content2xml_hash($out_hash, "mac_$avail_mac", $avail_date);
+            }
         }
     }
 
     my $out_msg = &create_xml_string($out_hash);
+    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<\/forward_to_gosa><\/xml>/;
+    }
+
     return ($out_msg);
 }
 
 
+#===  FUNCTION  ================================================================
+#         NAME: show_log_by_date_and_mac
+#  DESCRIPTION: reporting host and installation dates matching to regex of date and regex of mac address
+#   PARAMETERS: [$msg]        original incoming message
+#               [$msg_hash]   incoming message transformed to hash concerning XML::Simple
+#               [$session_id] POE session id 
+#      RETURNS: gosa-si valid answer string 
+#===============================================================================
 sub show_log_by_date_and_mac {
     my ($msg, $msg_hash, $session_id) = @_ ;
-    my $date_l = $msg_hash->{date};
-    my $mac_l = $msg_hash->{mac};
-
-    print STDERR "###########################################################\n"; 
-    print STDERR "date:".Dumper($date_l); 
-    print STDERR "mac: ".Dumper($mac_l); 
-    print STDERR "client_fai_log_dir: $main::client_fai_log_dir\n"; 
+    my $header = @{$msg_hash->{header}}[0];
+    my $target = @{$msg_hash->{target}}[0];
+    my $source = @{$msg_hash->{source}}[0];
+    my $date = @{$msg_hash->{date}}[0];
+    my $mac = @{$msg_hash->{mac}}[0];
+    $header =~ s/gosa_//;
 
     if (not -d $main::client_fai_log_dir) {
-        &main::daemon_log("$session_id ERROR: client fai log directory '$main::client_fai_log_dir' do not exist", 1); 
-        return;
+        my $error_string = "client fai log directory '$main::client_fai_log_dir' do not exist"; 
+        &main::daemon_log("$session_id ERROR: $error_string", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
     }
 
-    # fetch mac directory
+    # build out_msg
+    my $out_hash = &create_xml_hash($header, $target, $source);
+
+    # read mac directory
     opendir(DIR, $main::client_fai_log_dir); 
     my @avail_macs = readdir(DIR);
     closedir(DIR);   
+    foreach my $avail_mac ( @avail_macs ) {
+        # check mac address
+        if ($avail_mac eq ".." || $avail_mac eq ".") { next; }
+        if (not $avail_mac =~ /$mac/i) { next; }
+        my $act_log_dir = File::Spec->catdir($main::client_fai_log_dir, $avail_mac);
     
-    foreach my $avail_mac (@avail_macs) {
-        if (not $avail_mac =~ /^([0-9a-f]{2}:[0-9a-f]{2}:[0-9a-f]{2}:[0-9a-f]{2}:[0-9a-f]{2}:[0-9a-f]{2})$/i ) { 
-            next; 
+        # read install date directory
+        opendir(DIR, $act_log_dir); 
+        my @install_dates = readdir(DIR);
+        closedir(DIR);   
+        foreach my $avail_date (@install_dates) {
+            # check install date
+            if ($avail_date eq ".." || $avail_date eq ".") { next; }
+            if (not $avail_date =~ /$date/i) { next; }
+
+            # add content to out_msg
+            &add_content2xml_hash($out_hash, $avail_date, $avail_mac);
         }
+    }
 
-        print STDERR "mac: $avail_mac\n"; 
-        # fetch date directory
-        my $mac_log_dir = File::Spec->catdir($main::client_fai_log_dir, $avail_mac);
-        opendir(DIR, $mac_log_dir); 
-        my @avail_dates = readdir(DIR);
-        closedir(DIR);
-        #print STDERR "\@avail_dates:".Dumper(@avail_dates); 
+    my $out_msg = &create_xml_string($out_hash);
+    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<\/forward_to_gosa><\/xml>/;
+    }
+
+    return $out_msg;
+}
+
+
+#===  FUNCTION  ================================================================
+#         NAME: show_log_files_by_date_and_mac
+#  DESCRIPTION: reporting installation log files matching exatly to date and mac address
+#   PARAMETERS: [$msg]        original incoming message
+#               [$msg_hash]   incoming message transformed to hash concerning XML::Simple
+#               [$session_id] POE session id 
+#      RETURNS: gosa-si valid answer string 
+#===============================================================================
+sub show_log_files_by_date_and_mac {
+    my ($msg, $msg_hash, $session_id) = @_ ;
+    my $header = @{$msg_hash->{header}}[0];
+    my $target = @{$msg_hash->{target}}[0];
+    my $source = @{$msg_hash->{source}}[0];
+    my $date = @{$msg_hash->{date}}[0];
+    my $mac = @{$msg_hash->{mac}}[0];
+    $header =~ s/gosa_//;
+
+    my $act_log_dir = File::Spec->catdir($main::client_fai_log_dir, $mac, $date);
+    if (not -d $act_log_dir) {
+        my $error_string = "client fai log directory '$act_log_dir' do not exist";
+        &main::daemon_log("$session_id ERROR: $error_string", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
+    }
+
+    # build out_msg
+    my $out_hash = &create_xml_hash($header, $target, $source);
+
+    # read mac / install date directory
+    opendir(DIR, $act_log_dir); 
+    my @log_files = readdir(DIR);
+    closedir(DIR);   
+
+    foreach my $log_file (@log_files) {
+        if ($log_file eq ".." || $log_file eq ".") { next; }
+
+        # add content to out_msg
+        &add_content2xml_hash($out_hash, $header, $log_file);
+    }
+
+    my $out_msg = &create_xml_string($out_hash);
+    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<\/forward_to_gosa><\/xml>/;
     }
 
-    return;
+    return $out_msg;
 }
 
 
-sub get_log_by_date {}
-sub get_log_by_mac {}
-sub get_log_by_date_and_mac {}
-sub fetch_log {}
+#===  FUNCTION  ================================================================
+#         NAME: get_log_file_by_date_and_mac
+#  DESCRIPTION: returning the given log file, base64 coded, matching exactly to date and mac address
+#   PARAMETERS: [$msg]        original incoming message
+#               [$msg_hash]   incoming message transformed to hash concerning XML::Simple
+#               [$session_id] POE session id 
+#      RETURNS: gosa-si valid answer string 
+#===============================================================================
+sub get_log_file_by_date_and_mac {
+    my ($msg, $msg_hash, $session_id) = @_ ;
+    my $header = @{$msg_hash->{header}}[0];
+    my $target = @{$msg_hash->{target}}[0];
+    my $source = @{$msg_hash->{source}}[0];
+    my $date = @{$msg_hash->{date}}[0];
+    my $mac = @{$msg_hash->{mac}}[0];
+    my $log_file = @{$msg_hash->{log_file}}[0];
+    $header =~ s/gosa_//;
+ 
+    # sanity check
+    my $act_log_file = File::Spec->catfile($main::client_fai_log_dir, $mac, $date, $log_file);
+    if (not -f $act_log_file) {
+        my $error_string = "client fai log file '$act_log_file' do not exist or could not be read"; 
+        &main::daemon_log("$session_id ERROR: $error_string", 1); 
+        &main::daemon_log("$session_id ERROR: mac='$mac', date='$date', log_file='$log_file'", 1); 
+        &main::daemon_log("$session_id ERROR: could not process message: $msg", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
+    }
+    
+    # read log file
+    my $log_content;
+    open(my $FILE, "<$act_log_file");
+    my @log_lines = <$FILE>;
+    close($FILE);
+
+    # prepare content for xml sending
+    $log_content = join("", @log_lines); 
+    $log_content = &encode_base64($log_content);
+
+    # build out_msg and send
+    my $out_hash = &create_xml_hash($header, $target, $source);
+    &add_content2xml_hash($out_hash, $log_file, $log_content);
+    my $out_msg = &create_xml_string($out_hash);
+    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<\/forward_to_gosa><\/xml>/;
+    }
 
+    return $out_msg;
+}
+
+
+# sorting function for fai log directory names
+# used by get_recent_log_by_mac
+sub transform {
+    my $a = shift;
+    $a =~ /_(\d{8}?)_(\d{6}?)$/ || return 0;
+    return int("$1$2");
+}
+sub by_log_date {
+    &transform($a) <=> &transform($b);
+}
+#===  FUNCTION  ================================================================
+#         NAME: get_recent_log_by_mac
+#  DESCRIPTION: reporting the latest installation date matching to regex of mac address
+#   PARAMETERS: [$msg]        original incoming message
+#               [$msg_hash]   incoming message transformed to hash concerning XML::Simple
+#               [$session_id] POE session id 
+#      RETURNS: gosa-si valid answer string 
+#===============================================================================
 sub get_recent_log_by_mac {
+    my ($msg, $msg_hash, $session_id) = @_ ;
+    my $header = @{$msg_hash->{header}}[0];
+    my $target = @{$msg_hash->{target}}[0];
+    my $source = @{$msg_hash->{source}}[0];
+    my $mac = @{$msg_hash->{mac}}[0];
+    $header =~ s/gosa_//;
+
+    # sanity check
+    if (not -d $main::client_fai_log_dir) {
+        my $error_string = "client fai log directory '$main::client_fai_log_dir' do not exist";
+        &main::daemon_log("$session_id ERROR: $error_string", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
+    }
+    
+    opendir (DIR, $main::client_fai_log_dir);
+    my @avail_macs = readdir(DIR);
+    closedir(DIR);
+    my $act_log_dir;
+    my $act_mac;
+    foreach my $avail_mac (@avail_macs) { 
+        if ($avail_mac eq ".." || $avail_mac eq ".") { next; }
+        if (not $avail_mac =~ /$mac/i) { next; }
+        $act_log_dir = File::Spec->catdir($main::client_fai_log_dir, $avail_mac);
+        $act_mac = $avail_mac;
+    }
+    if (not defined $act_log_dir) {
+        my $error_string = "do not find mac '$mac' in directory '$main::client_fai_log_dir'";
+        &main::daemon_log("$session_id ERROR: $error_string", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
+    }
+
+    # read mac directory
+    opendir(DIR, $act_log_dir); 
+    my @avail_dates = readdir(DIR);
+    closedir(DIR);   
+
+    # search for the latest log 
+    my @sorted_dates = sort by_log_date @avail_dates;
+    my $latest_log = pop(@sorted_dates);
+
+    # build out_msg
+    my $out_hash = &create_xml_hash($header, $target, $source);
 
+    # read latest log directory
+    my $latest_log_dir = File::Spec->catdir($main::client_fai_log_dir, $act_mac, $latest_log);
+    opendir(DIR, $latest_log_dir); 
+    my @log_files = readdir(DIR);
+    closedir(DIR);   
+
+    # add all log_files to out_msg
+    foreach my $log_file (@log_files) {
+        if ($log_file eq ".." || $log_file eq ".") { next; }
+        &add_content2xml_hash($out_hash, $latest_log, $log_file);
+    }
+
+    my $out_msg = &create_xml_string($out_hash);
+    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<\/forward_to_gosa><\/xml>/;
+    }
+
+    return $out_msg;
 }
 
 
+#===  FUNCTION  ================================================================
+#         NAME: delete_log_by_date_and_mac
+#  DESCRIPTION: delete installation date directory matching to regex of date and regex of mac address
+#               missing date or mac is substitutet with regex '.'; if both is missing, deleting is rejected
+#   PARAMETERS: [$msg]        original incoming message
+#               [$msg_hash]   incoming message transformed to hash concerning XML::Simple
+#               [$session_id] POE session id 
+#      RETURNS: gosa-si valid answer string
+#===============================================================================
 sub delete_log_by_date_and_mac {
+    my ($msg, $msg_hash, $session_id) = @_ ;
+    my $header = @{$msg_hash->{header}}[0];
+    my $target = @{$msg_hash->{target}}[0];
+    my $source = @{$msg_hash->{source}}[0];
+    my $date = @{$msg_hash->{date}}[0];
+    my $mac = @{$msg_hash->{mac}}[0];
+    $header =~ s/gosa_//;
+
+    # sanity check
+    if (not -d $main::client_fai_log_dir) {
+        my $error_string = "client fai log directory '$main::client_fai_log_dir' do not exist";
+        &main::daemon_log("$session_id ERROR: $session_id", 1); 
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
+    }
+    if ((not defined $date) && (not defined $mac)) {
+        my $error_string = "deleting all log files from gosa-si-server by an empty delete message is not permitted";
+        &main::daemon_log("$session_id INFO: $error_string", 5);
+        return &create_xml_string(&create_xml_hash($header, $target, $source, $error_string));
+    }
+    if (not defined $date) { $date = "."; }   # set date to a regular expression matching to everything
+    if (not defined $mac) { $mac = "."; }     # set mac to a regular expression matching to everything
+ 
+    # build out_msg
+    my $out_hash = &create_xml_hash($header, $target, $source);
+
+    # read mac directory
+    opendir(DIR, $main::client_fai_log_dir); 
+    my @avail_macs = readdir(DIR);
+    closedir(DIR);   
+    foreach my $avail_mac ( @avail_macs ) {
+        # check mac address
+        if ($avail_mac eq ".." || $avail_mac eq ".") { next; }
+        if (not $avail_mac =~ /$mac/i) { next; }
+        my $act_log_dir = File::Spec->catdir($main::client_fai_log_dir, $avail_mac);
+    
+        # read install date directory
+        opendir(DIR, $act_log_dir); 
+        my @install_dates = readdir(DIR);
+        closedir(DIR);   
+        foreach my $avail_date (@install_dates) {
+            # check install date
+            if ($avail_date eq ".." || $avail_date eq ".") { next; }
+            if (not $avail_date =~ /$date/i) { next; }
+            
+            # delete directory and reptorting
+            my $dir_to_delete = File::Spec->catdir($main::client_fai_log_dir, $avail_mac, $avail_date);
+            #my $error = rmdir($dir_to_delete);
+            my $error = 0;
+            if ($error == 1) {
+                &main::daemon_log("$session_id ERROR: log directory '$dir_to_delete' cannot be deleted: $!", 1); 
+            } else {
+                &main::daemon_log("$session_id INFO: log directory '$dir_to_delete' deleted", 5); 
+                &add_content2xml_hash($out_hash, $avail_date, $avail_mac);
+            }
+        }
+    }
+
+    my $out_msg = &create_xml_string($out_hash);
+    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<\/forward_to_gosa><\/xml>/;
+    }
 
+    return $out_msg;
 }
 
 1;