removed images.

[gosa.git] / gosa-si / modules / GosaSupportDaemon.pm

diff --git a/gosa-si/modules/GosaSupportDaemon.pm b/gosa-si/modules/GosaSupportDaemon.pm
index af23971bf83b37251d40503052f451ede444569d..ae94225520dbe79d3449fec53d9d05e68e85c6b2 100644 (file)
--- a/gosa-si/modules/GosaSupportDaemon.pm
+++ b/gosa-si/modules/GosaSupportDaemon.pm
@@ -26,7 +26,9 @@ my @functions = (
     "get_ip",
     "get_interface_for_ip",
     "get_interfaces",
-       "run_as",
+    "is_local",
+    "run_as",
+    "inform_all_other_si_server",
     ); 
 @EXPORT = @functions;
 use strict;
@@ -292,6 +294,8 @@ sub get_where_statement {
                 my @xml_tags = keys %{$phrase};
                 my $tag = $xml_tags[0];
                 my $val = $phrase->{$tag}[0];
+                if( ref($val) eq "HASH" ) { next; }  # empty xml-tags should not appear in where statement
+
                                # integer columns do not have to have single quotes besides the value
                                if ($tag eq "id") {
                                                push(@phrase_l, "$tag$operator$val");
@@ -299,8 +303,11 @@ sub get_where_statement {
                                                push(@phrase_l, "$tag$operator'$val'");
                                }
             }
-            my $clause_str .= join(" $connector ", @phrase_l);
-            push(@clause_l, "($clause_str)");
+
+            if (not 0 == @phrase_l) {
+                my $clause_str .= join(" $connector ", @phrase_l);
+                push(@clause_l, "($clause_str)");
+            }
         }
 
         if( not 0 == @clause_l ) {
@@ -423,9 +430,6 @@ sub get_dns_domains() {
 }
 
 
-#############################################
-# moved from gosa-si-client: rettenbe, 16.05.2008
-# outcommented at gosa-si-client
 sub get_server_addresses {
     my $domain= shift;
     my @result;
@@ -620,10 +624,37 @@ sub get_interfaces {
 }
 
 
+#===  FUNCTION  ================================================================
+#         NAME:  is_local
+#   PARAMETERS:  Server Address
+#      RETURNS:  true if Server Address is on this host, false otherwise
+#  DESCRIPTION:  Checks all interface addresses, stops on first match
+#===============================================================================
+sub is_local {
+    my $server_address = shift || "";
+    my $result = 0;
+
+    my $server_ip = $1 if $server_address =~ /^(\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}):\d{1,6}$/;
+
+    if(defined($server_ip) && length($server_ip) > 0) {
+        foreach my $interface(&get_interfaces()) {
+            my $ip_address= &get_ip($interface);
+            if($ip_address eq $server_ip) {
+                $result = 1;
+                last;
+            }
+        }
+    }
+
+    return $result;
+}
+
+
 #===  FUNCTION  ================================================================
 #         NAME:  run_as
 #   PARAMETERS:  uid, command
-#      RETURNS:  result of command
+#      RETURNS:  hash with keys 'resultCode' = resultCode of command and 
+#                'output' = program output
 #  DESCRIPTION:  Runs command as uid using the sudo utility.
 #===============================================================================
 sub run_as {
@@ -633,10 +664,46 @@ sub run_as {
        if(! -x $sudo_cmd) {
                &main::daemon_log("ERROR: The sudo utility is not available! Please fix this!");
        }
-       open(PIPE, "$sudo_cmd su - $uid -c '$command' |");
-       my @result=<PIPE>;
-       return @result;
+       my $cmd_line= "$sudo_cmd su - $uid -c '$command'";
+       open(PIPE, "$cmd_line |");
+       my $result = {'resultCode' => $?};
+       $result->{'command'} = $cmd_line;
+       push @{$result->{'output'}}, <PIPE>;
+       return $result;
 }
 
 
+#===  FUNCTION  ================================================================
+#         NAME:  inform_other_si_server
+#   PARAMETERS:  message
+#      RETURNS:  nothing
+#  DESCRIPTION:  Sends message to all other SI-server found in known_server_db. 
+#===============================================================================
+sub inform_all_other_si_server {
+    my ($msg) = @_;
+
+    # determine all other si-server from known_server_db
+    my $sql_statement= "SELECT * FROM $main::known_server_tn";
+    my $res = $main::known_server_db->select_dbentry( $sql_statement ); 
+
+    while( my ($hit_num, $hit) = each %$res ) {    
+        my $act_target_address = $hit->{hostname};
+        my $act_target_key = $hit->{hostkey};
+
+        # determine the source address corresponding to the actual target address
+        my ($act_target_ip, $act_target_port) = split(/:/, $act_target_address);
+        my $act_source_address = &main::get_local_ip_for_remote_ip($act_target_ip).":$act_target_port";
+
+        # fill into message the correct target and source addresses
+        my $act_msg = $msg;
+        $act_msg =~ s/<target>\w*<\/target>/<target>$act_target_address<\/target>/g;
+        $act_msg =~ s/<source>\w*<\/source>/<source>$act_source_address<\/source>/g;
+
+        # send message to the target
+        &main::send_msg_to_target($act_msg, $act_target_address, $act_target_key, "foreign_job_updates" , "J");
+    }
+
+    return;
+}
+
 1;