From a20503ff2755ea1dbb96971e9f54eba434f2375e Mon Sep 17 00:00:00 2001 From: rettenbe Date: Thu, 15 May 2008 09:33:42 +0000 Subject: [PATCH] * group translation for message delivery * not finished git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@10910 594d385d-05f5-0310-b6e9-bd551577e9d8 --- gosa-si/gosa-si-server-nobus | 102 ++++++++++++++++++++++------------- 1 file changed, 65 insertions(+), 37 deletions(-) diff --git a/gosa-si/gosa-si-server-nobus b/gosa-si/gosa-si-server-nobus index a09ca6cf4..433097085 100755 --- a/gosa-si/gosa-si-server-nobus +++ b/gosa-si/gosa-si-server-nobus @@ -122,6 +122,7 @@ my $incoming_file_name; my @incoming_col_names = ("id INTEGER PRIMARY KEY", "timestamp DEFAULT 'none'", "headertag DEFAULT 'none'", + "targettag DEFAULT 'none'", "xmlmessage DEFAULT 'none'", "module DEFAULT 'none'", ); @@ -1043,18 +1044,21 @@ sub msg_to_decrypt { $error++; } - # schiebe sie in incoming_db + # add message to incoming_db if( $error == 0) { my $header = @{$msg_hash->{'header'}}[0]; + my $target = @{$msg_hash->{'target'}}[0]; my $res = $incoming_db->add_dbentry( {table=>$incoming_tn, primkey=>[], headertag=>$header, + targettag=>$target, xmlmessage=>$msg, timestamp=>&get_time, module=>$module, } ); if ($res != 0) { - &daemon_log(); + # TODO ist das mit $! so ok??? + #&daemon_log("$session_id ERROR: cannot add message to incoming.db: $!", 1); } } @@ -1118,40 +1122,13 @@ sub process_task { daemon_log("$session_id INFO: Incoming msg with session ID $session_id from '".$heap->{'remote_ip'}."'", 5); #daemon_log("$session_id DEBUG: Incoming msg:\n$input", 9); -# #################### -# # check incoming msg -# # msg is from a new client or gosa -# ($msg, $msg_hash, $module) = &input_from_unknown_host($input, $session_id); -# # msg is from a gosa-si-server or gosa-si-bus -# if(( !$msg ) || ( !$msg_hash ) || ( !$module )){ -# ($msg, $msg_hash, $module) = &input_from_known_server($input, $heap->{'remote_ip'}, $session_id); -# } -# # msg is from a gosa-si-client -# if(( !$msg ) || ( !$msg_hash ) || ( !$module )){ -# ($msg, $msg_hash, $module) = &input_from_known_client($input, $heap->{'remote_ip'}, $session_id); -# } -# # an error occurred -# if(( !$msg ) || ( !$msg_hash ) || ( !$module )){ -# # if an incoming msg could not be decrypted (maybe a wrong key), send client a ping. If the client -# # could not understand a msg from its server the client cause a re-registering process -# daemon_log("$session_id INFO cannot understand incoming msg, send 'ping'-msg to all host with ip '".$heap->{remote_ip}."' to cause a re-registering of the client if necessary", 5); -# my $sql_statement = "SELECT * FROM $main::known_clients_tn WHERE (hostname LIKE '".$heap->{'remote_ip'}."%')"; -# my $query_res = $known_clients_db->select_dbentry( $sql_statement ); -# while( my ($hit_num, $hit) = each %{ $query_res } ) { -# my $host_name = $hit->{'hostname'}; -# my $host_key = $hit->{'hostkey'}; -# my $ping_msg = "
gosa_ping
$server_address $host_name"; -# my $error = &send_msg_to_target($ping_msg, $host_name, $host_key, "gosa_ping", $session_id); -# &update_jobdb_status_for_send_msgs($ping_msg, $error); -# } -# $error++; -# } - - + ################################################## + # fetch first unprocessed message from incoming_db # sometimes the program is faster than sqlite, so wait until informations are present at db my $id_sql; my $id_res; my $message_id; +# TODO : das hier ist sehr sehr unschön while (1) { $id_sql = "SELECT min(id) FROM $incoming_tn WHERE (NOT headertag LIKE 'answer%')"; $id_res = $incoming_db->exec_statement($id_sql); @@ -1159,9 +1136,6 @@ sub process_task { if (defined $message_id) { last } } -print STDERR "min(id): $message_id\n"; - - # fetch new message from incoming_db my $sql = "SELECT * FROM $incoming_tn WHERE id=$message_id"; my $res = $incoming_db->exec_statement($sql); @@ -1205,8 +1179,6 @@ print STDERR "min(id): $message_id\n"; if( $error == 0 ) { foreach my $answer ( @{$answer_l} ) { - # for each answer in answer list - # check outgoing msg to xml validity my $answer_hash = &check_outgoing_xml_validity($answer); if( not defined $answer_hash ) { @@ -1489,6 +1461,62 @@ sub watch_for_new_messages { $receiver_h{$1} = 0; } elsif ($receiver =~ /^g_([\s\S]*)$/) { # TODO implement receiver translation + # fetch all group members from ldap + my $ldap_handle = &get_ldap_handle($session_id); + my $mesg = $ldap_handle->search( + base => $ldap_base, + scope => 'sub', + attrs => ['memberUid'], + filter => "cn=$1"; + ); + if ($mesg->count) { + my @entries = $mesg->entries; + foreach my $entry (@entries) { + my @receivers= $entry->get_value("memberUid"); + foreach my $receiver (@receivers) { + $receiver_h{$1} = 0; + } + } + } +# if ($mesg->count) { +# my @entries = $mesg->entries; +# foreach my $entry (@entries) { +# # Only modify entry if it is not set to '$state' +# if ($entry->get_value("FAIstate") ne "$state"){ +# daemon_log("$session_id INFO: Setting FAIstate to '$state' for ".$entry->dn, 5); +# my $result; +# my %tmp = map { $_ => 1 } $entry->get_value("objectClass"); +# if (exists $tmp{'FAIobject'}){ +# if ($state eq ''){ +# $result= $ldap_handle->modify($entry->dn, changes => [ +# delete => [ FAIstate => [] ] ]); +# } else { +# $result= $ldap_handle->modify($entry->dn, changes => [ +# replace => [ FAIstate => $state ] ]); +# } +# } elsif ($state ne ''){ +# $result= $ldap_handle->modify($entry->dn, changes => [ +# add => [ objectClass => 'FAIobject' ], +# add => [ FAIstate => $state ] ]); +# } +# +# # Errors? +# if ($result->code){ +# daemon_log("$session_id Error: Setting FAIstate to '$state' for ".$entry->dn. "failed: ".$result->error, 1); +# } +# } else { +# daemon_log("$session_id DEBUG FAIstate at host '".$entry->dn."' already at state '$st'", 7); +# } +# } +# } +# # if no ldap handle defined +# } else { +# daemon_log("$session_id ERROR: no LDAP handle defined for update FAIstate", 1); +# } +# + + # add each member to receiver hash + } else { my $sbjct = &encode_base64(@{$hit}[1]); my $msg = &encode_base64(@{$hit}[7]); -- 2.30.2