index cd0716f2b8ecce71b3c6daf8f6b927de1fe11859..17a731bab481a6e701b1116f1c57a743b8e81728 100644 (file)
use XML::Simple;
use File::Spec;
use Data::Dumper;
-use GOSA::DBsqlite;
+use GOSA::DBmysql;
use MIME::Base64;
my $event_dir = "/usr/lib/gosa-si/server/GosaPackages";
}
}
+# build vice versa event_hash, event_name => module
+my $event2module_hash = {};
+while (my ($module, $mod_events) = each %$event_hash) {
+ while (my ($event_name, $nothing) = each %$mod_events) {
+ $event2module_hash->{$event_name} = $module;
+ }
+
+}
+
## FUNCTIONS #################################################################
sub get_module_info {
my @info = ($main::gosa_address,
$main::gosa_passwd,
+ $event_hash,
);
return \@info;
}
$out_msg =~ s/<source>GOSA<\/source>/<source>$act_server_ip:$main::server_port<\/source>/g;
}
- # Patch the correct outgoing forward_to_gosa address
- if ($out_msg =~ /<forward_to_gosa>(\S+),(\d+)<\/forward_to_gosa>/ ) {
- $out_msg =~ s/<forward_to_gosa>\S+<\/forward_to_gosa>/<forward_to_gosa>$act_server_ip:$main::server_port,$session_id<\/forward_to_gosa>/;
- } else {
- $out_msg =~ s/<\/xml>/<forward_to_gosa>$act_server_ip:$main::server_port,$session_id<\/forward_to_gosa> <\/xml>/;
- }
-
# Add to each outgoing message the current POE session id
$out_msg =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
my $target = @{$msg_hash->{'target'}}[0];
# check local installed events
- if( exists $event_hash->{$header} ) {
+ if( exists $event2module_hash->{$header} ) {
# a event exists with the header as name
- &main::daemon_log("$session_id INFO: found event '$header' at event-module '".$event_hash->{$header}."'", 5);
+ &main::daemon_log("$session_id INFO: found event '$header' at event-module '".$event2module_hash->{$header}."'", 5);
no strict 'refs';
- @out_msg_l = &{$event_hash->{$header}."::$header"}( $msg, $msg_hash, $session_id );
+ @out_msg_l = &{$event2module_hash->{$header}."::$header"}( $msg, $msg_hash, $session_id );
# check client registered events
} else {
# client is registered for this event, deliver this message to client
if ($client_events =~ /,$header,/) {
+ &main::daemon_log("$session_id INFO: client '$target' is registerd for event '$header', forward message to client.", 5);
@out_msg_l = ( $msg );
# client is not registered for this event, set error
&daemon_log("$session_id ERROR: opsi_install_client-message has no xml-tag 'hostID', job was not created: $msg", 1);
} else {
$plain_name = $msg_hash->{'hostId'}[0];
+ $header = "trigger_action_reinstall"
}
} else { # Try to determine plain_name via ladp search
scope => 'sub',
attrs => ['cn'],
filter => "(macAddress=$macaddress)");
- if($mesg->code) {
+ if($mesg->code || ($mesg->count!=1)) {
&main::daemon_log($mesg->error, 1);
$plain_name = "none";
} else {