gosa-si/server/events/mailqueue_com.pm

   1 =pod
   2
   3 =head1 NAME
   4
   5 mailqueue_com - Implementation of a GOsa-SI event module.
   6
   7 =head1 SYNOPSIS
   8
   9  use GOSA::GosaSupportDaemon;
  10  use Time::HiRes qw(usleep);
  11  use MIME::Base64;
  12
  13 =head1 DESCRIPTION
  14
  15 A GOsa-SI event module containing all functions used by GOsa mail queue. This module will
  16 be automatically imported by GOsa-SI if it is under F</usr/lib/gosa-si/server/E<lt>PACKAGEMODULEE<gt>/> .
  17
  18
  19 =head1 METHODS
  20
  21 =cut
  22
  23 package mailqueue_com;
  24 use Exporter;
  25 @ISA = qw(Exporter);
  26 my @events = (
  27     "get_events",
  28     "mailqueue_query",
  29     "mailqueue_header",
  30 );
  31 @EXPORT = @events;
  32
  33 use strict;
  34 use warnings;
  35 use GOSA::GosaSupportDaemon;
  36 use Data::Dumper;
  37 use Time::HiRes qw( usleep);
  38 use MIME::Base64;
  39
  40
  41 BEGIN {}
  42
  43 END {}
  44
  45 ### Start ######################################################################
  46
  47 =pod
  48
  49 =over 4
  50
  51 =item get_events ( )
  52
  53 Returns a list of functions which are exported by the module.
  54
  55 =back
  56
  57 =cut
  58
  59 sub get_events {
  60     return \@events;
  61 }
  62
  63
  64 =pod
  65
  66 =over 4
  67
  68 =item mailqueue_query( $msg, $msg_hash, $session_id )
  69
  70 This function do for incoming messages with header 'mailqueue_query' the target translation from mac address to ip:port address, updates job_queue, send message to client and wait for client answer.
  71
  72 Returns the answer of the client.
  73
  74 =back
  75
  76 =cut
  77
  78 sub mailqueue_query {
  79     my ($msg, $msg_hash, $session_id) = @_ ;
  80     my $header = @{$msg_hash->{header}}[0];
  81     my $target = @{$msg_hash->{target}}[0];
  82     my $source = @{$msg_hash->{source}}[0];
  83     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
  84     my $error = 0;
  85     my $error_string;
  86     my $answer_msg;
  87     my ($sql, $res);
  88
  89     if( defined $jobdb_id) {
  90         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
  91         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
  92         my $res = $main::job_db->exec_statement($sql_statement);
  93     }
  94
  95     # search for the correct target address
  96     $sql = "SELECT * FROM $main::known_clients_tn WHERE ((hostname='$target') || (macaddress LIKE '$target'))";
  97     $res = $main::known_clients_db->exec_statement($sql);
  98     my ($host_name, $host_key);  # sanity check of db result
  99     if ((defined $res) && (@$res > 0) && @{@$res[0]} > 0) {
 100         $host_name = @{@$res[0]}[0];
 101         $host_key = @{@$res[0]}[2];
 102     } else {
 103         &main::daemon_log("$session_id ERROR: cannot determine host_name and host_key from known_clients_db\n$msg", 1);
 104         $error_string = "Cannot determine host_name and host_key from known_clients_db";
 105         $error = 1;
 106     }
 107
 108     # send message to target
 109     if (not $error) {
 110         $msg =~ s/<source>GOSA<\/source>/<source>$main::server_address<\/source>/g;
 111         $msg =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
 112         &main::send_msg_to_target($msg, $host_name, $host_key, $header, $session_id);
 113     }
 114
 115     # waiting for answer
 116     if (not $error) {
 117         my $message_id;
 118         my $i = 0;
 119         while (1) {
 120             $i++;
 121             $sql = "SELECT * FROM $main::incoming_tn WHERE headertag='answer_$session_id'";
 122             $res = $main::incoming_db->exec_statement($sql);
 123             if (ref @$res[0] eq "ARRAY") {
 124                 $message_id = @{@$res[0]}[0];
 125                 last;
 126             }
 127             if ($i > 100) { last; } # do not run into a endless loop
 128             usleep(100000);
 129         }
 130         # if answer exists
 131         if (defined $message_id) {
 132             $answer_msg = decode_base64(@{@$res[0]}[4]);
 133             $answer_msg =~ s/<target>\S+<\/target>/<target>$source<\/target>/;
 134             $answer_msg =~ s/<header>\S+<\/header>/<header>$header<\/header>/;
 135
 136             my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0];
 137             if (defined $forward_to_gosa){
 138                 $answer_msg =~s/<\/xml>/<forward_to_gosa>$forward_to_gosa<\/forward_to_gosa><\/xml>/;
 139             }
 140             $sql = "DELETE FROM $main::incoming_tn WHERE id=$message_id";
 141             $res = $main::incoming_db->exec_statement($sql);
 142         }
 143     }
 144
 145     return ( $answer_msg );
 146 }
 147
 148 =pod
 149
 150 =over 4
 151
 152 =item mailqueue_header ( $msg, $msg_hash, $session_id )
 153
 154 This function do for incoming messages with header 'mailqueue_header' the target translation from mac address to ip:port address, updates job_queue, send message to client and wait for client answer.
 155
 156 Returns the answer of the client.
 157
 158 =back
 159
 160 =cut
 161 sub mailqueue_header {
 162     my ($msg, $msg_hash, $session_id) = @_ ;
 163     my $header = @{$msg_hash->{header}}[0];
 164     my $target = @{$msg_hash->{target}}[0];
 165     my $source = @{$msg_hash->{source}}[0];
 166     my $jobdb_id = @{$msg_hash->{'jobdb_id'}}[0];
 167     my $error = 0;
 168     my $error_string;
 169     my $answer_msg;
 170     my ($sql, $res);
 171
 172     if( defined $jobdb_id) {
 173         my $sql_statement = "UPDATE $main::job_queue_tn SET status='processed' WHERE id=jobdb_id";
 174         &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 175         my $res = $main::job_db->exec_statement($sql_statement);
 176     }
 177
 178     # search for the correct target address
 179     $sql = "SELECT * FROM $main::known_clients_tn WHERE ((hostname='$target') || (macaddress LIKE '$target'))";
 180     $res = $main::known_clients_db->exec_statement($sql);
 181     my ($host_name, $host_key);
 182     if ((defined $res) && (@$res > 0) && @{@$res[0]} > 0) {   # sanity check of db result
 183         $host_name = @{@$res[0]}[0];
 184         $host_key = @{@$res[0]}[2];
 185     } else {
 186         &main::daemon_log("$session_id ERROR: cannot determine host_name and host_key from known_clients_db\n$msg", 1);
 187         $error_string = "Cannot determine host_name and host_key from known_clients_db";
 188         $error = 1;
 189     }
 190
 191     # send message to target
 192     if (not $error) {
 193         $msg =~ s/<source>GOSA<\/source>/<source>$main::server_address<\/source>/g;
 194         $msg =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
 195         &main::send_msg_to_target($msg, $host_name, $host_key, $header, $session_id);
 196     }
 197
 198     # waiting for answer
 199     if (not $error) {
 200         my $message_id;
 201         my $i = 0;
 202         while (1) {
 203             $i++;
 204             $sql = "SELECT * FROM $main::incoming_tn WHERE headertag='answer_$session_id'";
 205             $res = $main::incoming_db->exec_statement($sql);
 206             if (ref @$res[0] eq "ARRAY") {
 207                 $message_id = @{@$res[0]}[0];
 208                 last;
 209             }
 210             if ($i > 100) { last; } # do not run into a endless loop
 211             usleep(100000);
 212         }
 213         # if answer exists
 214         if (defined $message_id) {
 215             $answer_msg = decode_base64(@{@$res[0]}[4]);
 216             $answer_msg =~ s/<target>\S+<\/target>/<target>$source<\/target>/;
 217             $answer_msg =~ s/<header>\S+<\/header>/<header>$header<\/header>/;
 218
 219             my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0];
 220             if (defined $forward_to_gosa){
 221                 $answer_msg =~s/<\/xml>/<forward_to_gosa>$forward_to_gosa<\/forward_to_gosa><\/xml>/;
 222             }
 223             $sql = "DELETE FROM $main::incoming_tn WHERE id=$message_id";
 224             $res = $main::incoming_db->exec_statement($sql);
 225         }
 226     }
 227
 228     return ( $answer_msg );
 229 }
 230
 231
 232 =pod
 233
 234 =head1 BUGS
 235
 236 Please report any bugs, or post any suggestions, to the GOsa mailing list E<lt>gosa-devel@oss.gonicus.deE<gt> or to L<https://oss.gonicus.de/labs/gosa>
 237
 238 =head1 COPYRIGHT
 239
 240 This code is part of GOsa (L<http://www.gosa-project.org>)
 241
 242 Copyright (C) 2003-2008 GONICUS GmbH
 243
 244 ID: $$Id$$
 245
 246 This program is free software; you can redistribute it and/or modify
 247 it under the terms of the GNU General Public License as published by
 248 the Free Software Foundation; either version 2 of the License, or
 249 (at your option) any later version.
 250
 251 This program is distributed in the hope that it will be useful,
 252 but WITHOUT ANY WARRANTY; without even the implied warranty of
 253 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 254 GNU General Public License for more details.
 255
 256 You should have received a copy of the GNU General Public License
 257 along with this program; if not, write to the Free Software
 258 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 259
 260
 261 =cut
 262
 263 # vim:ts=4:shiftwidth:expandtab
 264 1;