![[tokkee]](http://tokkee.org/images/avatar.png){kind=avatar}
index 0094ebccb540a8fecb4261822da843df76821b8d..6bf2e3658bcb077a4ca11e8fde1765462237e7cb 100644 (file)
my $gosa_address = "$gosa_ip:$gosa_port";
# create general settings for this module
-my $gosa_cipher = &create_ciphering($gosa_passwd);
+#y $gosa_cipher = &create_ciphering($gosa_passwd);
my $xml = new XML::Simple();
return $result;
}
-#=== FUNCTION ================================================================
-# NAME: open_socket
-# PARAMETERS: PeerAddr string something like 192.168.1.1 or 192.168.1.1:10000
-# [PeerPort] string necessary if port not appended by PeerAddr
-# RETURNS: socket IO::Socket::INET
-# DESCRIPTION: open a socket to PeerAddr
-#===============================================================================
-sub open_socket {
- my ($PeerAddr, $PeerPort) = @_ ;
- if(defined($PeerPort)){
- $PeerAddr = $PeerAddr.":".$PeerPort;
- }
- my $socket;
- $socket = new IO::Socket::INET(PeerAddr => $PeerAddr ,
- Porto => "tcp" ,
- Type => SOCK_STREAM,
- Timeout => 5,
- );
- if(not defined $socket) {
- return;
- }
- &main::daemon_log("open_socket to: $PeerAddr", 7);
- return $socket;
-}
-
#=== FUNCTION ================================================================
# NAME: process_incoming_msg
# DESCRIPTION: handels the proceeded distribution to the appropriated functions
#===============================================================================
sub process_incoming_msg {
- my ($crypted_msg) = @_ ;
- if( (not(defined($crypted_msg))) || (length($crypted_msg) <= 0)) {
- &main::daemon_log("function 'process_incoming_msg': got no msg", 7);
- return;
- }
-
- $crypted_msg =~ /^([\s\S]*?)\.(\d{1,3}?)\.(\d{1,3}?)\.(\d{1,3}?)\.(\d{1,3}?)$/;
- $crypted_msg = $1;
- my $host = sprintf("%s.%s.%s.%s", $2, $3, $4, $5);
-
- # collect addresses from possible incoming clients
- # only gosa is allowd as incoming client
- &main::daemon_log("GosaPackages: host_key: $host", 7);
- &main::daemon_log("GosaPackages: key_passwd: $gosa_passwd", 7);
-
- $gosa_cipher = &create_ciphering($gosa_passwd);
-
- # determine the correct passwd for deciphering of the incoming msgs
- my $msg = "";
- my $msg_hash;
- eval{
- $msg = &decrypt_msg($crypted_msg, $gosa_cipher);
- &main::daemon_log("GosaPackages: decrypted_msg: \n$msg", 8);
-
- $msg_hash = $xml->XMLin($msg, ForceArray=>1);
- };
- if($@) {
- &main::daemon_log("WARNING: GosaPackages do not understand the message:", 5);
- &main::daemon_log("$@", 7);
- return;
- }
-
+ my ($msg, $msg_hash) = @_ ;
my $header = @{$msg_hash->{header}}[0];
+ my $out_msg;
- &main::daemon_log("GosaPackages: receive '$header' from $host", 1);
+ &main::daemon_log("GosaPackages: receive '$header'", 1);
- my $out_msg;
if ($header =~ /^job_/) {
$out_msg = &process_job_msg($msg, $msg_hash);
- } elsif ($header =~ /^gosa_/) {
+ }
+ elsif ($header =~ /^gosa_/) {
$out_msg = &process_gosa_msg($msg, $header);
- } else {
+ }
+ else {
&main::daemon_log("ERROR: $header is not a valid GosaPackage-header, need a 'job_' or a 'gosa_' prefix");
}
-
- if (not defined $out_msg) {
- return;
- }
+ # keep job queue uptodate and save result and status
if ($out_msg =~ /<jobdb_id>(\d*?)<\/jobdb_id>/) {
my $job_id = $1;
my $sql = "UPDATE '".$main::job_queue_table_name.
"' SET status='done', result='".$out_msg.
"' WHERE id='$job_id'";
my $res = $main::job_db->exec_statement($sql);
- return;
-
- } else {
-
- my $out_cipher = &create_ciphering($gosa_passwd);
- $out_msg = &encrypt_msg($out_msg, $out_cipher);
-
- return $out_msg;
- }
+ }
+ my @out_msg_l;
+ push(@out_msg_l, $out_msg);
+ return \@out_msg_l;
}
+
sub process_gosa_msg {
my ($msg, $header) = @_ ;
my $out_msg;
$header =~ s/gosa_//;
# decide wether msg is a core function or a event handler
- if ( $header eq 'query_jobdb') { $out_msg = &query_jobdb }
- elsif ($header eq 'delete_jobdb_entry') { $out_msg = &delete_jobdb_entry }
- elsif ($header eq 'clear_jobdb') { $out_msg = &clear_jobdb }
- elsif ($header eq 'update_status_jobdb_entry' ) { $out_msg = &update_status_jobdb_entry }
- elsif ($header eq 'count_jobdb' ) { $out_msg = &count_jobdb }
- else {
+ if ( $header eq 'query_jobdb') {
+ $out_msg = &query_jobdb
+ } elsif ($header eq 'delete_jobdb_entry') {
+ $out_msg = &delete_jobdb_entry
+ } elsif ($header eq 'clear_jobdb') {
+ $out_msg = &clear_jobdb
+ } elsif ($header eq 'update_status_jobdb_entry' ) {
+ $out_msg = &update_status_jobdb_entry
+ } elsif ($header eq 'count_jobdb' ) {
+ $out_msg = &count_jobdb
+ } else {
# msg could not be assigned to core function
# fetch all available eventhandler under $server_event_dir
opendir (DIR, $server_event_dir) or &main::daemon_log("ERROR cannot open $server_event_dir: $!\n", 1) and return;
# try to deliver incoming msg to eventhandler
my $cmd = File::Spec->join($server_event_dir, $header)." '$msg'";
&main::daemon_log("GosaPackages: execute event_handler $header", 3);
- &main::daemon_log("GosaPackages: cmd: $cmd", 7);
+ &main::daemon_log("GosaPackages: cmd: $cmd", 8);
$out_msg = "";
open(PIPE, "$cmd 2>&1 |");
my $orderby= &get_orderby_statement($msg, $msg_hash);
my $sql_statement= "SELECT $select FROM $table $where $orderby $limit";
-print STDERR "\n\n$sql_statement\n\n";
-
# execute db query
my $res_hash = $main::job_db->select_dbentry($sql_statement);
my $out_xml = &db_res_2_xml($res_hash);