gosa-si/server/events/databases.pm

   1 package databases;
   2 use Exporter;
   3 @ISA = qw(Exporter);
   4 my @events = (
   5     "get_events",
   6     "query_jobdb",
   7     "count_jobdb",
   8     "delete_jobdb_entry",
   9     "clear_jobdb",
  10     "update_status_jobdb_entry",
  11     "query_packages_list",
  12     "count_packages_list",
  13     "query_fai_server",
  14     "count_fai_server",
  15     "query_fai_release",
  16     "count_fai_release",
  17     );
  18 @EXPORT = @events;
  19
  20 use strict;
  21 use warnings;
  22 use GOSA::GosaSupportDaemon;
  23 use Data::Dumper;
  24
  25 BEGIN {}
  26
  27 END {}
  28
  29 ### Start ######################################################################
  30
  31 #&main::read_configfile($main::cfg_file, %cfg_defaults);
  32
  33 sub get_events {
  34     return \@events;
  35 }
  36
  37 sub query_fai_release{ return &query_db( @_ ); }
  38 sub query_fai_server{ return &query_db( @_ ) ; }
  39 sub query_packages_list { return &query_db( @_ ) ; }
  40 sub query_jobdb { return &query_db( @_ ) ; }
  41 sub query_db {
  42     my ($msg, $msg_hash, $session_id) = @_ ;
  43     my $header = @{$msg_hash->{'header'}}[0];
  44     my $target = @{$msg_hash->{'target'}}[0];
  45     my $source = @{$msg_hash->{'source'}}[0];
  46     my $table;
  47     my $db;
  48     if( $header =~ /query_jobdb/ ) {
  49         $table = $main::job_queue_tn;
  50         $db = $main::job_db;
  51     } elsif( $header =~ /query_packages_list/ ) {
  52         $table = $main::packages_list_tn;
  53         $db = $main::packages_list_db;
  54     } elsif( $header =~ /query_fai_server/ ) {
  55         $table = $main::fai_server_tn;
  56         $db = $main::fai_server_db;
  57     } elsif( $header =~ /query_fai_release/ ) {
  58         $table = $main::fai_release_tn;
  59         $db = $main::fai_release_db;
  60     }
  61
  62
  63     # prepare sql statement and execute query
  64     my $select= &get_select_statement($msg, $msg_hash);
  65     my $where= &get_where_statement($msg, $msg_hash);
  66     my $limit= &get_limit_statement($msg, $msg_hash);
  67     my $orderby= &get_orderby_statement($msg, $msg_hash);
  68     my $sql_statement= "SELECT $select FROM $table $where $orderby $limit";
  69     my $res_hash = $db->select_dbentry($sql_statement);
  70
  71     my $out_xml = &db_res2si_msg($res_hash, $header, $source, $target);
  72     #$out_xml =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
  73     my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0];
  74     if (defined $forward_to_gosa) {
  75         #&add_content2xml_hash($out_hash, "forward_to_gosa", $forward_to_gosa);
  76         $out_xml =~s/<\/xml>/<forward_to_gosa>$forward_to_gosa<\/forward_to_gosa><\/xml>/;
  77     }
  78     my @out_msg_l = ( $out_xml );
  79
  80     return @out_msg_l;
  81 }
  82
  83 sub count_fai_release{ return &count_db( @_ ); }
  84 sub count_fai_server{ return &count_db( @_ ); }
  85 sub count_packages_list{ return &count_db( @_ ); }
  86 sub count_jobdb{ return &count_db( @_ ); }
  87 sub count_db {
  88     my ($msg, $msg_hash, $session_id) = @_;
  89     my $header = @{$msg_hash->{'header'}}[0];
  90     my $target = @{$msg_hash->{'target'}}[0];
  91     my $source = @{$msg_hash->{'source'}}[0];
  92     my $table;
  93     my $db;
  94
  95     if( $header =~ /count_jobdb/ ) {
  96         $table = $main::job_queue_tn;
  97         $db = $main::job_db;
  98     } elsif( $header =~ /count_packages_list/ ) {
  99         $table = $main::packages_list_tn;
 100         $db = $main::packages_list_db;
 101     } elsif( $header =~ /count_fai_server/ ) {
 102         $table = $main::fai_server_tn;
 103         $db = $main::fai_server_db;
 104     } elsif( $header =~ /count_fai_release/ ) {
 105         $table = $main::fai_release_tn;
 106         $db = $main::fai_release_db;
 107     }
 108
 109                 my $count = $db->count_dbentries($table);
 110     my $out_xml= "<xml><header>answer</header><source>$target</source><target>$source</target><count>$count</count><session_id>$session_id</session_id></xml>";
 111     my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0];
 112     if (defined $forward_to_gosa) {
 113         #&add_content2xml_hash($out_hash, "forward_to_gosa", $forward_to_gosa);
 114         $out_xml =~s/<\/xml>/<forward_to_gosa>$forward_to_gosa<\/forward_to_gosa><\/xml>/;
 115     }
 116
 117     my @out_msg_l = ( $out_xml );
 118     return @out_msg_l;
 119 }
 120
 121 sub delete_jobdb_entry {
 122     my ($msg, $msg_hash, $session_id) = @_ ;
 123     my $target = @{$msg_hash->{'target'}}[0];
 124     my $source = @{$msg_hash->{'source'}}[0];
 125
 126     # prepare query sql statement
 127     my $where= &get_where_statement($msg, $msg_hash);
 128
 129     #my $sql_statement = "DELETE FROM $main::job_queue_tn $where";
 130         #&main::daemon_log("$session_id DEBUG: $sql_statement",7);
 131     # execute db query
 132     #my $db_res = $main::job_db->del_dbentry($sql_statement);
 133     #
 134     #my $res;
 135     #if( $db_res > 0 ) {
 136     #    $res = 0 ;
 137     #} else {
 138     #    $res = 1;
 139     #}
 140
 141     # set job to status 'done', job will be deleted automatically
 142     my $sql_statement = "UPDATE $main::job_queue_tn ".
 143         "SET status='done', modified='1' ".
 144         "$where";
 145     &main::daemon_log("$session_id DEBUG: $sql_statement", 7);
 146     my $res = $main::job_db->update_dbentry( $sql_statement );
 147
 148     # prepare xml answer
 149     my $out_xml = "<xml><header>answer</header><source>$target</source><target>$source</target><answer1>$res</answer1><session_id>$session_id</session_id></xml>";
 150     my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0];
 151     if (defined $forward_to_gosa) {
 152         $out_xml =~s/<\/xml>/<forward_to_gosa>$forward_to_gosa<\/forward_to_gosa><\/xml>/;
 153     }
 154
 155     my @out_msg_l = ( $out_xml );
 156     return @out_msg_l;
 157
 158 }
 159
 160
 161 sub clear_jobdb {
 162     my ($msg, $msg_hash, $session_id) = @_ ;
 163     my $target = @{$msg_hash->{'target'}}[0];
 164     my $source = @{$msg_hash->{'source'}}[0];
 165
 166     my $error= 0;
 167     my $out_xml= "<xml><answer1>1</answer1></xml>";
 168
 169     my $table= $main::job_queue_tn;
 170
 171     my $sql_statement = "DELETE FROM $table";
 172     my $db_res = $main::job_db->del_dbentry($sql_statement);
 173     if( not $db_res > 0 ) { $error++; };
 174
 175     if( $error == 0 ) {
 176         $out_xml = "<xml><header>answer</header><source>$target</source><target>$source</target><answer1>0</answer1><session_id>$session_id</session_id></xml>";
 177     }
 178     my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0];
 179     if (defined $forward_to_gosa) {
 180         #&add_content2xml_hash($out_hash, "forward_to_gosa", $forward_to_gosa);
 181         $out_xml =~s/<\/xml>/<forward_to_gosa>$forward_to_gosa<\/forward_to_gosa><\/xml>/;
 182     }
 183
 184     my @out_msg_l = ( $out_xml );
 185     return @out_msg_l;
 186 }
 187
 188
 189 sub update_status_jobdb_entry {
 190     my ($msg, $msg_hash, $session_id) = @_ ;
 191     my $target = @{$msg_hash->{'target'}}[0];
 192     my $source = @{$msg_hash->{'source'}}[0];
 193
 194     my $error= 0;
 195     my $out_xml= "<xml><header>answer</header><source>$target</source><target>$source</target><answer1>1</answer1><session_id>$session_id</session_id></xml>";
 196
 197     my @len_hash = keys %{$msg_hash};
 198     if( 0 == @len_hash) {  $error++; };
 199
 200     # prepare query sql statement
 201     if( $error == 0) {
 202         my $table= $main::job_queue_tn;
 203         my $where= &get_where_statement($msg, $msg_hash);
 204         my $update= &get_update_statement($msg, $msg_hash);
 205
 206         # conditions
 207         # no timestamp update if status eq waiting
 208         my $sql_statement = "SELECT * FROM $table $where AND status='processing'";
 209         my $res_hash = $main::job_db->select_dbentry($sql_statement);
 210         if( (0 != keys(%$res_hash)) && ($update =~ /timestamp/i) ) {
 211             $error ++;
 212             $out_xml = "<answer1>1</answer1><error_string>there is no timestamp update allowed while status is 'processing'</error_string>";
 213         }
 214
 215         if( $error == 0 ) {
 216             my $sql_statement = "UPDATE $table $update $where";
 217             # execute db query
 218             my $db_res = $main::job_db->update_dbentry($sql_statement);
 219
 220             # check success of db update
 221             if( not $db_res > 0 ) { $error++; };
 222         }
 223     }
 224
 225     if( $error == 0) {
 226         $out_xml = "<answer1>0</answer1>";
 227     }
 228
 229     my $out_msg = sprintf("<xml><header>answer</header><source>%s</source><target>%s</target>%s<session_id>$session_id</session_id></xml>", $target, $source, $out_xml);
 230     my $forward_to_gosa = @{$msg_hash->{'forward_to_gosa'}}[0];
 231     if (defined $forward_to_gosa) {
 232         #&add_content2xml_hash($out_hash, "forward_to_gosa", $forward_to_gosa);
 233         $out_xml =~s/<\/xml>/<forward_to_gosa>$forward_to_gosa<\/forward_to_gosa><\/xml>/;
 234     }
 235
 236     my @out_msg_l = ( $out_msg );
 237     return @out_msg_l;
 238 }
 239
 240
 241 =pod
 242
 243 =head1 NAME
 244
 245 databases - Implementation of a GOsa-SI event module for GOsa-SI-server.
 246
 247 =head1 SYNOPSIS
 248
 249  use GOSA::GosaSupportDaemon;
 250
 251 =head1 DESCRIPTION
 252
 253 This GOsa-SI event module containing all functions to handle messages coming from GOsa and concerning GOsa-SI databases.
 254
 255 This module will be automatically imported by GOsa-SI if it is under F</usr/lib/gosa-si/server/E<lt>PACKAGEMODULEE<gt>/> .
 256
 257 =head1 METHODS
 258
 259 =over 4
 260
 261 =item get_events ( )
 262
 263 =item query_jobdb ( )
 264
 265 =item count_jobdb ( )
 266
 267 =item delete_jobdb_entry ( )
 268
 269 =item clear_jobdb ( )
 270
 271 =item update_status_jobdb_entry ( )
 272
 273 =item query_packages_list ( )
 274
 275 =item count_packages_list ( )
 276
 277 =item query_fai_server ( )
 278
 279 =item count_fai_server ( )
 280
 281 =item query_fai_release ( )
 282
 283 =item count_fai_release ( )
 284
 285 =back
 286
 287 =head1 BUGS
 288
 289 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>
 290
 291 =head1 COPYRIGHT
 292
 293 This code is part of GOsa (L<http://www.gosa-project.org>)
 294
 295 Copyright (C) 2003-2008 GONICUS GmbH
 296
 297 This program is distributed in the hope that it will be useful,
 298 but WITHOUT ANY WARRANTY; without even the implied warranty of
 299 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 300 GNU General Public License for more details.
 301
 302 =cut
 303
 304
 305 1;