X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=gosa-si%2Fmodules%2FGosaSupportDaemon.pm;h=7d769c08ad6ff4e302a900203e214f955cb2b16c;hb=fcfa0de5a118f5e42a0a48bfbb3d355d3e180c51;hp=d4c7ee49559296c98a65c4b062ba7fc70ec1a365;hpb=15bd70c0525399236fb944e8e4acf0cef919d907;p=gosa.git
diff --git a/gosa-si/modules/GosaSupportDaemon.pm b/gosa-si/modules/GosaSupportDaemon.pm
index d4c7ee495..7d769c08a 100644
--- a/gosa-si/modules/GosaSupportDaemon.pm
+++ b/gosa-si/modules/GosaSupportDaemon.pm
@@ -5,11 +5,14 @@ use Exporter;
my @functions = (
"create_passwd",
"create_xml_hash",
+ "createXmlHash",
+ "myXmlHashToString",
"get_content_from_xml_hash",
"add_content2xml_hash",
"create_xml_string",
"transform_msg2hash",
"get_time",
+ "get_utc_time",
"build_msg",
"db_res2xml",
"db_res2si_msg",
@@ -26,7 +29,15 @@ my @functions = (
"get_ip",
"get_interface_for_ip",
"get_interfaces",
- "run_as",
+ "get_mac_for_interface",
+ "get_local_ip_for_remote_ip",
+ "is_local",
+ "run_as",
+ "inform_all_other_si_server",
+ "read_configfile",
+ "check_opsi_res",
+ "calc_timestamp",
+ "opsi_callobj2string",
);
@EXPORT = @functions;
use strict;
@@ -35,10 +46,11 @@ use IO::Socket::INET;
use Crypt::Rijndael;
use Digest::MD5 qw(md5 md5_hex md5_base64);
use MIME::Base64;
+use XML::Quote qw(:all);
use XML::Simple;
use Data::Dumper;
use Net::DNS;
-
+use DateTime;
my $op_hash = {
'eq' => '=',
@@ -57,7 +69,7 @@ END {}
### Start ######################################################################
-my $xml = new XML::Simple();
+our $xml = new XML::Simple();
sub daemon_log {
my ($msg, $level) = @_ ;
@@ -103,6 +115,91 @@ sub create_xml_hash {
return $hash
}
+sub createXmlHash {
+ my ($header, $source, $target) = @_;
+ return { header=>$header, source=>$source, target=>$target};
+}
+
+sub _transformHashToString {
+ my ($hash) = @_;
+ my $s = "";
+
+ while (my ($tag, $content) = each(%$hash)) {
+
+ if (ref $content eq "HASH") {
+ $s .= "<$tag>".&_transformHashToString($content)."$tag>";
+ } elsif ( ref $content eq "ARRAY") {
+ $s .= &_transformArrayToString($tag, $content);
+ } else {
+ $content = defined $content ? $content : "";
+ $s .= "<$tag>".&xml_quote($content)."$tag>";
+ }
+ }
+ return $s;
+}
+
+sub _transformArrayToString {
+ my ($tag, $contentArray) = @_;
+ my $s = "";
+ foreach my $content (@$contentArray) {
+ if (ref $content eq "HASH") {
+ $s .= "<$tag>".&_transformHashToString($content)."$tag>";
+ } else {
+ $content = defined $content ? $content : "";
+ $s .= "<$tag>".&xml_quote($content)."$tag>";
+ }
+ }
+ return $s;
+}
+
+
+#=== FUNCTION ================================================================
+# NAME: myXmlHashToString
+# PARAMETERS: xml_hash - hash - hash from function createXmlHash
+# RETURNS: xml_string - string - xml string representation of the hash
+# DESCRIPTION: Transforms the given hash to a xml wellformed string. I.e.:
+# {
+# 'header' => 'a'
+# 'source' => 'c',
+# 'target' => 'b',
+# 'hit' => [ '1',
+# '2',
+# {
+# 'hit31' => 'ABC',
+# 'hit32' => 'XYZ'
+# }
+# ],
+# 'res0' => {
+# 'res1' => {
+# 'res2' => 'result'
+# }
+# },
+# };
+#
+# will be transformed to
+#
+#
+#
+# b
+# 1
+# 2
+#
+# ABC
+# XYZ
+#
+#
+#
+# result
+#
+#
+#
+#
+#===============================================================================
+sub myXmlHashToString {
+ my ($hash) = @_;
+ return "".&_transformHashToString($hash)."";
+}
+
#=== FUNCTION ================================================================
# NAME: create_xml_string
@@ -172,17 +269,23 @@ sub add_content2xml_hash {
sub get_time {
- my ($seconds, $minutes, $hours, $monthday, $month,
- $year, $weekday, $yearday, $sommertime) = localtime(time);
- $hours = $hours < 10 ? $hours = "0".$hours : $hours;
- $minutes = $minutes < 10 ? $minutes = "0".$minutes : $minutes;
- $seconds = $seconds < 10 ? $seconds = "0".$seconds : $seconds;
- $month+=1;
- $month = $month < 10 ? $month = "0".$month : $month;
- $monthday = $monthday < 10 ? $monthday = "0".$monthday : $monthday;
- $year+=1900;
- return "$year$month$monthday$hours$minutes$seconds";
+ my ($seconds, $minutes, $hours, $monthday, $month,
+ $year, $weekday, $yearday, $sommertime) = localtime;
+ $hours = $hours < 10 ? $hours = "0".$hours : $hours;
+ $minutes = $minutes < 10 ? $minutes = "0".$minutes : $minutes;
+ $seconds = $seconds < 10 ? $seconds = "0".$seconds : $seconds;
+ $month+=1;
+ $month = $month < 10 ? $month = "0".$month : $month;
+ $monthday = $monthday < 10 ? $monthday = "0".$monthday : $monthday;
+ $year+=1900;
+ return "$year$month$monthday$hours$minutes$seconds";
+}
+
+sub get_utc_time {
+ my $utc_time = qx(date --utc +%Y%m%d%H%M%S);
+ $utc_time =~ s/\s$//;
+ return $utc_time;
}
@@ -230,7 +333,7 @@ sub db_res2xml {
if( $column_name eq "xmlmessage" ) {
$xml_content = &encode_base64($column_value);
} else {
- $xml_content = $column_value;
+ $xml_content = defined $column_value ? $column_value : "";
}
$xml .= $xml_content;
$xml .= "$column_name>";
@@ -292,6 +395,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 +404,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,12 +531,10 @@ 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;
+ my $error_string;
my $error = 0;
my $res = Net::DNS::Resolver->new;
@@ -441,7 +547,7 @@ sub get_server_addresses {
}
}
else {
- #warn "query failed: ", $res->errorstring, "\n";
+ $error_string = "determination of '_gosa-si._tcp' server in domain '$domain' failed: ".$res->errorstring;
$error++;
}
@@ -460,7 +566,7 @@ sub get_server_addresses {
}
}
- return @result;
+ return \@result, $error_string;
}
@@ -505,14 +611,23 @@ sub import_events {
if ($error == 0) {
while (defined (my $event = readdir ($DIR))) {
- if( $event eq "." || $event eq ".." ) { next; }
+ if( $event eq "." || $event eq ".." || ($event =~ /^\.pm$/)) { next; }
+
+ # Check config file to exclude disabled event plugins (i.e. Opsi)
+ if ($event eq "opsi_com.pm" && $main::opsi_enabled ne "true") {
+ &main::daemon_log("0 WARNING: opsi-module is installed but not enabled in config file, please set under section '[OPSI]': 'enabled=true'", 3);
+ next;
+ }
# try to import event module
eval{ require $event; };
if( $@ ) {
$error++;
- push(@result, "import of event module '$event' failed: $@");
- next;
+ #push(@result, "import of event module '$event' failed: $@");
+ #next;
+
+ &main::daemon_log("ERROR: Import of event module '$event' failed: $@",1);
+ exit(1);
}
# fetch all single events
@@ -520,7 +635,7 @@ sub import_events {
my $event_module = $1;
my $events_l = eval( $1."::get_events()") ;
foreach my $event_name (@{$events_l}) {
- $event_hash->{$event_name} = $event_module;
+ $event_hash->{$event_module}->{$event_name} = "";
}
my $events_string = join( ", ", @{$events_l});
push(@result, "import of event module '$event' succeed: $events_string");
@@ -572,6 +687,15 @@ sub get_ip {
sub get_interface_for_ip {
my $result;
my $ip= shift;
+
+ if($ip =~ /^[a-z]/i) {
+ my $ip_address = inet_ntoa(scalar gethostbyname($ip));
+ if(defined($ip_address) && $ip_address =~ /^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/) {
+ # Write ip address to $source variable
+ $ip = $ip_address;
+ }
+ }
+
if ($ip && length($ip) > 0) {
my @ifs= &get_interfaces();
if($ip eq "0.0.0.0") {
@@ -619,6 +743,119 @@ sub get_interfaces {
return @result;
}
+sub get_local_ip_for_remote_ip {
+ my $remote_ip= shift;
+ my $result="0.0.0.0";
+
+ if($remote_ip =~ /^(\d\d?\d?\.){3}\d\d?\d?$/) {
+ my $PROC_NET_ROUTE= ('/proc/net/route');
+
+ open(PROC_NET_ROUTE, "<$PROC_NET_ROUTE")
+ or die "Could not open $PROC_NET_ROUTE";
+
+ my @ifs = ;
+
+ close(PROC_NET_ROUTE);
+
+ # Eat header line
+ shift @ifs;
+ chomp @ifs;
+ my $iffallback = '';
+
+ # linux-vserver might have * as Iface due to hidden interfaces, set a default
+ foreach my $line(@ifs) {
+ my ($Iface,$Destination,$Gateway,$Flags,$RefCnt,$Use,$Metric,$Mask,$MTU,$Window,$IRTT)=split(/\s/, $line);
+ if ($Iface =~ m/^[^\*]+$/) {
+ $iffallback = $Iface;
+ }
+ }
+
+ foreach my $line(@ifs) {
+ my ($Iface,$Destination,$Gateway,$Flags,$RefCnt,$Use,$Metric,$Mask,$MTU,$Window,$IRTT)=split(/\s/, $line);
+ my $destination;
+ my $mask;
+ my ($d,$c,$b,$a)=unpack('a2 a2 a2 a2', $Destination);
+ if ($Iface =~ m/^[^\*]+$/) {
+ $iffallback = $Iface;
+ }
+ $destination= sprintf("%d.%d.%d.%d", hex($a), hex($b), hex($c), hex($d));
+ ($d,$c,$b,$a)=unpack('a2 a2 a2 a2', $Mask);
+ $mask= sprintf("%d.%d.%d.%d", hex($a), hex($b), hex($c), hex($d));
+ if(new NetAddr::IP($remote_ip)->within(new NetAddr::IP($destination, $mask))) {
+ # destination matches route, save mac and exit
+ #$result= &get_ip($Iface);
+
+ if ($Iface =~ m/^\*$/ ) {
+ $result= &get_ip($iffallback);
+ } else {
+ $result= &get_ip($Iface);
+ }
+ last;
+ }
+ }
+ }
+
+ return $result;
+}
+
+
+sub get_mac_for_interface {
+ my $ifreq= shift;
+ my $result;
+ if ($ifreq && length($ifreq) > 0) {
+ if($ifreq eq "all") {
+ $result = "00:00:00:00:00:00";
+ } else {
+ my $SIOCGIFHWADDR= 0x8927; # man 2 ioctl_list
+
+ # A configured MAC Address should always override a guessed value
+ if ($main::server_mac_address and length($main::server_mac_address) > 0) {
+ $result= $main::server_mac_address;
+ }
+
+ socket SOCKET, PF_INET, SOCK_DGRAM, getprotobyname('ip')
+ or die "socket: $!";
+
+ if(ioctl SOCKET, $SIOCGIFHWADDR, $ifreq) {
+ my ($if, $mac)= unpack 'h36 H12', $ifreq;
+
+ if (length($mac) > 0) {
+ $mac=~ m/^([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])([0-9a-f][0-9a-f])$/;
+ $mac= sprintf("%s:%s:%s:%s:%s:%s", $1, $2, $3, $4, $5, $6);
+ $result = $mac;
+ }
+ }
+ }
+ }
+ return $result;
+}
+
+
+#=== 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
@@ -634,11 +871,139 @@ 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 = {'resultCode' => $?};
+ my $cmd_line= "$sudo_cmd su - $uid -c '$command'";
+ open(PIPE, "$cmd_line |");
+ my $result = {'command' => $cmd_line};
push @{$result->{'output'}}, ;
+ close(PIPE);
+ my $exit_value = $? >> 8;
+ $result->{'resultCode'} = $exit_value;
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/\w*<\/target>/$act_target_address<\/target>/g;
+ $act_msg =~ s/