![[tokkee]](http://tokkee.org/images/avatar.png){kind=avatar}
index 31bd729a53d05c6c9840e8188b0831a9880c0072..d8942c9e6b1c629b1b3e714134a981d19ed8631d 100644 (file)
use GOSA::DBsqlite;
use MIME::Base64;
+
BEGIN{}
END{}
my $gosa_cipher = &create_ciphering($gosa_passwd);
my $xml = new XML::Simple();
-# open gosa socket
-if ($gosa_activ eq "on") {
- &main::daemon_log(" ",1);
- $gosa_server = IO::Socket::INET->new(LocalPort => $gosa_port,
- Type => SOCK_STREAM,
- Reuse => 1,
- Listen => 1,
- );
- if (not defined $gosa_server) {
- &main::daemon_log("cannot start tcp server at $gosa_port for communication to gosa: $@", 1);
- die;
- } else {
- &main::daemon_log("start server for communication to gosa: $gosa_address", 1);
-
- }
-}
-
-# create gosa job queue as a SQLite DB
-my $table_name = "jobs";
-my $sqlite = GOSA::DBsqlite->new($job_queue_file_name);
-
-
-
## FUNCTIONS #################################################################
# 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;
-}
+#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 ================================================================
#===============================================================================
sub process_incoming_msg {
my ($crypted_msg) = @_ ;
- if( (not(defined($crypted_msg))) || (length($crypted_msg) <= 0)) {
+ 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);
+ my $host = sprintf("%s.%s.%s.%s", $2, $3, $4, $5);
# collect addresses from possible incoming clients
# only gosa is allowd as incoming client
my $msg_hash;
eval{
$msg = &decrypt_msg($crypted_msg, $gosa_cipher);
- &main::daemon_log("GosaPackages: decrypted_msg: \n$msg", 7);
+ &main::daemon_log("GosaPackages: decrypted_msg: \n$msg", 8);
$msg_hash = $xml->XMLin($msg, ForceArray=>1);
};
} 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;
}
if ($out_msg =~ /<jobdb_id>(\d*?)<\/jobdb_id>/) {
my $job_id = $1;
- my $sql = "BEGIN TRANSATION; UPDATE '".$main::job_queue_table_name.
+ my $sql = "UPDATE '".$main::job_queue_table_name.
"' SET status='done', result='".$out_msg.
- "' WHERE id='$job_id'; COMMIT;";
+ "' WHERE id='$job_id'";
my $res = $main::job_db->exec_statement($sql);
return;
my $out_cipher = &create_ciphering($gosa_passwd);
$out_msg = &encrypt_msg($out_msg, $out_cipher);
return $out_msg;
- }
+ }
}
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 'update_timestamp_jobdb_entry' ) { $out_msg = &update_timestamp_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
}
&main::daemon_log("GosaPackages: $header job successfully added to job queue", 3);
- return "<xml><1>$res</1></xml>";
+ return "<xml><answer1>$res</answer1></xml>";
}
my $xml = "<xml>";
- while ( my ($hit, $hash) = each %{ $db_res } ) {
- $xml .= "\n<answer$hit>";
+ my $len_db_res= keys %{$db_res};
+ for( my $i= 1; $i<= $len_db_res; $i++ ) {
+ $xml .= "\n<answer$i>";
+ my $hash= $db_res->{$i};
while ( my ($column_name, $column_value) = each %{$hash} ) {
$xml .= "<$column_name>";
my $xml_content;
$xml .= $xml_content;
$xml .= "</$column_name>";
}
+ $xml .= "</answer$i>";
- $xml .= "</answer$hit>";
}
$xml .= "</xml>";
my $msg_hash = &transform_msg2hash($msg);
# prepare query sql statement
- my @where = @{$msg_hash->{where}};
- my $where_hash = {table=>$main::job_queue_table_name };
- foreach my $where_pram (@where) {
- my $where_val = @{$msg_hash->{$where_pram}}[0];
- if (defined $where_val) {
- $where_hash->{$where_pram} = $where_val;
- }
- }
-
- # execute db query
- my $res_hash = $main::job_db->select_dbentry($where_hash);
+ my $select= &get_select_statement($msg, $msg_hash);
+ my $table= $main::job_queue_table_name;
+ my $where= &get_where_statement($msg, $msg_hash);
+ my $limit= &get_limit_statement($msg, $msg_hash);
+ my $orderby= &get_orderby_statement($msg, $msg_hash);
+ my $sql_statement= "SELECT $select FROM $table $where $orderby $limit";
+ # execute db query
+ my $res_hash = $main::job_db->select_dbentry($sql_statement);
my $out_xml = &db_res_2_xml($res_hash);
+
+ return $out_xml;
+}
+
+
+sub count_jobdb {
+ my ($msg)= @_;
+ my $out_xml= "<xml><count>error</count></xml>";
+
+ # prepare query sql statement
+ my $table= $main::job_queue_table_name;
+ my $sql_statement= "SELECT * FROM $table ";
+
+ # execute db query
+ my $res_hash = $main::job_db->select_dbentry($sql_statement);
+
+ my $count = keys(%{$res_hash});
+ $out_xml= "<xml><count>$count</count></xml>";
+
return $out_xml;
}
+
sub delete_jobdb_entry {
my ($msg) = @_ ;
my $msg_hash = &transform_msg2hash($msg);
# prepare query sql statement
- my @where = @{$msg_hash->{where}};
- my $where_hash = {table=>$main::job_queue_table_name };
- foreach my $where_pram (@where) {
- my $where_val = @{$msg_hash->{$where_pram}}[0];
- if (defined $where_val) {
- $where_hash->{$where_pram} = $where_val;
- }
- }
+ my $table= $main::job_queue_table_name;
+ my $where= &get_where_statement($msg, $msg_hash);
+ my $sql_statement = "DELETE FROM $table $where";
# execute db query
- my $db_res = $main::job_db->del_dbentry($where_hash);
+ my $db_res = $main::job_db->del_dbentry($sql_statement);
my $res;
if( $db_res > 0 ) {
}
+
sub clear_jobdb {
my ($msg) = @_ ;
my $msg_hash = &transform_msg2hash($msg);
+ my $error= 0;
+ my $out_xml= "<xml><answer1>1</answer1></xml>";
+
+ my $table= $main::job_queue_table_name;
- my $where_hash = {table=>$main::job_queue_table_name };
+ my $sql_statement = "DELETE FROM $table";
+ my $db_res = $main::job_db->del_dbentry($sql_statement);
+ if( not $db_res > 0 ) { $error++; };
- # execute db query
- my $db_res = $main::job_db->del_dbentry($where_hash);
- print STDERR "db_res=$db_res\n";
- my $res;
- if( $db_res eq '0E0' ) {
- $res = 0 ;
- } else {
- $res = 1;
+ if( $error == 0 ) {
+ $out_xml = "<xml><answer1>0</answer1></xml>";
}
-
- # prepare xml answer
- my $out_xml = "<xml><answer1>$res</answer1></xml>";
+
return $out_xml;
}
+
sub update_status_jobdb_entry {
my ($msg) = @_ ;
my $msg_hash = &transform_msg2hash($msg);
-
- # prepare query sql statement
- my $update_hash = {table=>$main::job_queue_table_name };
- if( exists $msg_hash->{where} ) {
- $update_hash->{where} = $msg_hash->{where};
- } else {
- $update_hash->{where} = [];
- }
-
- if( not exists $msg_hash->{update}[0]->{status} ) {
- return "<xml><answer1>1</answer1></xml>";
- }
- $update_hash->{update} = [ { status=>$msg_hash->{update}[0]->{status} } ];
+ my $error= 0;
+ my $out_xml= "<xml><answer1>1</answer1></xml>";
- # execute db query
- my $db_res = $main::job_db->update_dbentry($update_hash);
-
- # transform db answer to error returnment
- my $res;
- if( $db_res > 0 ) {
- $res = 0 ;
- } else {
- $res = 1;
- }
-
- # prepare xml answer
- my $out_xml = "<xml><answer1>$res</answer1></xml>";
- return $out_xml;
-}
-
-sub update_timestamp_jobdb_entry {
- my ($msg) = @_ ;
- my $msg_hash = &transform_msg2hash($msg);
+ my @len_hash = keys %{$msg_hash};
+ if( 0 == @len_hash) { $error++; };
# prepare query sql statement
- my $update_hash = {table=>$main::job_queue_table_name };
- if( exists $msg_hash->{where} ) {
- $update_hash->{where} = $msg_hash->{where};
- } else {
- $update_hash->{where} = [];
- }
+ if( $error == 0) {
+ my $table= $main::job_queue_table_name;
+ my $where= &get_where_statement($msg, $msg_hash);
+ my $update= &get_update_statement($msg, $msg_hash);
- if( not exists $msg_hash->{update}[0]->{timestamp} ) {
- return "<xml><answer1>1</answer1></xml>";
- }
+ my $sql_statement = "UPDATE $table $update $where";
- $update_hash->{update} = [ { timestamp=>$msg_hash->{update}[0]->{timestamp} } ];
+ # execute db query
+ my $db_res = $main::job_db->update_dbentry($sql_statement);
- # execute db query
- my $db_res = $main::job_db->update_dbentry($update_hash);
+ # check success of db update
+ if( not $db_res > 0 ) { $error++; };
+ }
- # transform db answer to error returnment
- my $res;
- if( $db_res > 0 ) {
- $res = 0 ;
- } else {
- $res = 1;
+ if( $error == 0) {
+ $out_xml = "<xml><answer1>0</answer1></xml>";
}
- # prepare xml answer
- my $out_xml = "<xml><answer1>$res</answer1></xml>";
return $out_xml;
-
}
+#sub update_timestamp_jobdb_entry {
+# my ($msg) = @_ ;
+# my $msg_hash = &transform_msg2hash($msg);
+#
+# # prepare query sql statement
+# my $update_hash = {table=>$main::job_queue_table_name };
+# if( exists $msg_hash->{where} ) {
+# $update_hash->{where} = $msg_hash->{where};
+# } else {
+# $update_hash->{where} = [];
+# }
+#
+# if( not exists $msg_hash->{update}[0]->{timestamp} ) {
+# return "<xml><answer1>1</answer1></xml>";
+# }
+#
+# $update_hash->{update} = [ { timestamp=>$msg_hash->{update}[0]->{timestamp} } ];
+#
+# # execute db query
+# my $db_res = $main::job_db->update_dbentry($update_hash);
+#
+# # transform db answer to error returnment
+# my $res;
+# if( $db_res > 0 ) {
+# $res = 0 ;
+# } else {
+# $res = 1;
+# }
+#
+# # prepare xml answer
+# my $out_xml = "<xml><answer1>$res</answer1></xml>";
+# return $out_xml;
+#
+#}
+
1;