7d1bda9ddf8948c24f7b85a3f68c46db146cffbb
1 package GosaPackages;
3 use Exporter;
4 @ISA = ("Exporter");
6 use strict;
7 use warnings;
8 use GOSA::GosaSupportDaemon;
9 use IO::Socket::INET;
10 use XML::Simple;
11 use File::Spec;
12 use Data::Dumper;
13 use GOSA::DBsqlite;
14 use MIME::Base64;
16 BEGIN{}
17 END{}
19 my ($server_activ, $server_port, $server_passwd, $max_clients, $server_event_dir);
20 my ($bus_activ, $bus_passwd, $bus_ip, $bus_port);
21 my ($gosa_activ, $gosa_ip, $gosa_port, $gosa_passwd);
22 my ($job_queue_timeout, $job_queue_file_name);
24 my $gosa_server;
26 my %cfg_defaults =
27 ("general" =>
28 {"job_queue_file_name" => [\$job_queue_file_name, '/var/lib/gosa-si/jobs.db'],
29 },
30 "server" =>
31 {"server_activ" => [\$server_activ, "on"],
32 "server_port" => [\$server_port, "20081"],
33 "server_passwd" => [\$server_passwd, ""],
34 "max_clients" => [\$max_clients, 100],
35 "server_event_dir" => [\$server_event_dir, '/usr/lib/gosa-si/server/events'],
36 },
37 "bus" =>
38 {"bus_activ" => [\$bus_activ, "on"],
39 "bus_passwd" => [\$bus_passwd, ""],
40 "bus_ip" => [\$bus_ip, ""],
41 "bus_port" => [\$bus_port, "20080"],
42 },
43 "gosa" =>
44 {"gosa_activ" => [\$gosa_activ, "on"],
45 "gosa_ip" => [\$gosa_ip, "0.0.0.0"],
46 "gosa_port" => [\$gosa_port, "20082"],
47 "gosa_passwd" => [\$gosa_passwd, "none"],
48 },
49 );
52 ## START ##########################
54 # read configfile and import variables
55 &read_configfile();
57 # detect own ip and mac address
58 my ($server_ip, $server_mac_address) = &get_ip_and_mac();
60 # complete addresses
61 my $server_address = "$server_ip:$server_port";
62 my $bus_address = "$bus_ip:$bus_port";
63 my $gosa_address = "$gosa_ip:$gosa_port";
65 # create general settings for this module
66 my $gosa_cipher = &create_ciphering($gosa_passwd);
67 my $xml = new XML::Simple();
69 # open gosa socket
70 if ($gosa_activ eq "on") {
71 &main::daemon_log(" ",1);
72 $gosa_server = IO::Socket::INET->new(LocalPort => $gosa_port,
73 Type => SOCK_STREAM,
74 Reuse => 1,
75 Listen => 1,
76 );
77 if (not defined $gosa_server) {
78 &main::daemon_log("cannot start tcp server at $gosa_port for communication to gosa: $@", 1);
79 die;
80 } else {
81 &main::daemon_log("start server for communication to gosa: $gosa_address", 1);
83 }
84 }
86 # create gosa job queue as a SQLite DB
87 my $table_name = "jobs";
88 my $sqlite = GOSA::DBsqlite->new($job_queue_file_name);
93 ## FUNCTIONS #################################################################
95 sub get_module_info {
96 my @info = ($gosa_address,
97 $gosa_passwd,
98 $gosa_server,
99 $gosa_activ,
100 "socket",
101 );
102 return \@info;
103 }
106 #=== FUNCTION ================================================================
107 # NAME: read_configfile
108 # PARAMETERS: cfg_file - string -
109 # RETURNS: nothing
110 # DESCRIPTION: read cfg_file and set variables
111 #===============================================================================
112 sub read_configfile {
113 my $cfg;
114 if( defined( $main::cfg_file) && ( length($main::cfg_file) > 0 )) {
115 if( -r $main::cfg_file ) {
116 $cfg = Config::IniFiles->new( -file => $main::cfg_file );
117 } else {
118 print STDERR "Couldn't read config file!";
119 }
120 } else {
121 $cfg = Config::IniFiles->new() ;
122 }
123 foreach my $section (keys %cfg_defaults) {
124 foreach my $param (keys %{$cfg_defaults{ $section }}) {
125 my $pinfo = $cfg_defaults{ $section }{ $param };
126 ${@$pinfo[0]} = $cfg->val( $section, $param, @$pinfo[1] );
127 }
128 }
129 }
132 #=== FUNCTION ================================================================
133 # NAME: get_ip_and_mac
134 # PARAMETERS: nothing
135 # RETURNS: (ip, mac)
136 # DESCRIPTION: executes /sbin/ifconfig and parses the output, the first occurence
137 # of a inet address is returned as well as the mac address in the line
138 # above the inet address
139 #===============================================================================
140 sub get_ip_and_mac {
141 my $ip = "0.0.0.0.0"; # Defualt-IP
142 my $mac = "00:00:00:00:00:00"; # Default-MAC
143 my @ifconfig = qx(/sbin/ifconfig);
144 foreach(@ifconfig) {
145 if (/Hardware Adresse (\S{2}):(\S{2}):(\S{2}):(\S{2}):(\S{2}):(\S{2})/) {
146 $mac = "$1:$2:$3:$4:$5:$6";
147 next;
148 }
149 if (/inet Adresse:(\d+).(\d+).(\d+).(\d+)/) {
150 $ip = "$1.$2.$3.$4";
151 last;
152 }
153 }
154 return ($ip, $mac);
155 }
158 #=== FUNCTION ================================================================
159 # NAME: open_socket
160 # PARAMETERS: PeerAddr string something like 192.168.1.1 or 192.168.1.1:10000
161 # [PeerPort] string necessary if port not appended by PeerAddr
162 # RETURNS: socket IO::Socket::INET
163 # DESCRIPTION: open a socket to PeerAddr
164 #===============================================================================
165 sub open_socket {
166 my ($PeerAddr, $PeerPort) = @_ ;
167 if(defined($PeerPort)){
168 $PeerAddr = $PeerAddr.":".$PeerPort;
169 }
170 my $socket;
171 $socket = new IO::Socket::INET(PeerAddr => $PeerAddr ,
172 Porto => "tcp" ,
173 Type => SOCK_STREAM,
174 Timeout => 5,
175 );
176 if(not defined $socket) {
177 return;
178 }
179 &main::daemon_log("open_socket to: $PeerAddr", 7);
180 return $socket;
181 }
184 #=== FUNCTION ================================================================
185 # NAME: process_incoming_msg
186 # PARAMETERS: crypted_msg - string - incoming crypted message
187 # RETURNS: nothing
188 # DESCRIPTION: handels the proceeded distribution to the appropriated functions
189 #===============================================================================
190 sub process_incoming_msg {
191 my ($crypted_msg) = @_ ;
192 if(not defined $crypted_msg) {
193 &main::daemon_log("function 'process_incoming_msg': got no msg", 7);
194 }
195 &main::daemon_log("GosaPackages: incoming msg: \n$crypted_msg", 7);
197 $crypted_msg =~ /^([\s\S]*?)\.(\d{1,3}?)\.(\d{1,3}?)\.(\d{1,3}?)\.(\d{1,3}?)$/;
198 $crypted_msg = $1;
199 my $host = sprintf("%s.%s.%s.%s", $2, $3, $4, $5);
201 # collect addresses from possible incoming clients
202 # only gosa is allowd as incoming client
203 &main::daemon_log("GosaPackages: host_key: $host", 7);
204 &main::daemon_log("GosaPackages: key_passwd: $gosa_passwd", 7);
206 $gosa_cipher = &create_ciphering($gosa_passwd);
208 # determine the correct passwd for deciphering of the incoming msgs
209 my $msg = "";
210 my $msg_hash;
211 eval{
212 $msg = &decrypt_msg($crypted_msg, $gosa_cipher);
213 &main::daemon_log("GosaPackages: decrypted_msg: \n$msg", 7);
215 $msg_hash = $xml->XMLin($msg, ForceArray=>1);
216 };
217 if($@) {
218 &main::daemon_log("WARNING: GosaPackages do not understand the message:", 5);
219 &main::daemon_log("$@", 7);
220 return;
221 }
223 my $header = @{$msg_hash->{header}}[0];
225 &main::daemon_log("GosaPackages: recieve '$header' from $host", 1);
227 my $out_msg;
228 if ($header =~ /^job_/) {
229 $out_msg = &process_job_msg($msg, $msg_hash);
230 } elsif ($header =~ /^gosa_/) {
231 $out_msg = &process_gosa_msg($msg, $header);
232 } else {
233 &main::daemon_log("ERROR: $header is not a valid GosaPackage-header, need a 'job_' or a 'gosa_' prefix");
234 }
236 if (not defined $out_msg) {
237 return;
238 }
240 if ($out_msg =~ /<jobdb_id>(\d*?)<\/jobdb_id>/) {
241 my $job_id = $1;
242 my $sql = "UPDATE '$main::job_queue_table_name' SET status='done', result='$out_msg' WHERE id='$job_id'";
243 my $res = $main::job_db->exec_statement($sql);
244 return;
246 } else {
247 my $out_cipher = &create_ciphering($gosa_passwd);
248 $out_msg = &encrypt_msg($out_msg, $out_cipher);
249 return $out_msg;
250 }
252 }
254 sub process_gosa_msg {
255 my ($msg, $header) = @_ ;
256 my $out_msg;
257 $header =~ s/gosa_//;
258 &main::daemon_log("GosaPackages: got a gosa msg $header", 5);
260 # decide wether msg is a core function or a event handler
261 if ( $header eq 'query_jobdb') { $out_msg = &query_jobdb }
262 elsif ($header eq 'delete_jobdb_entry') { $out_msg = &delete_jobdb_entry }
263 elsif ($header eq 'clear_jobdb') { $out_msg = &clear_jobdb }
264 elsif ($header eq 'update_status_jobdb_entry' ) { $out_msg = &update_status_jobdb_entry }
265 elsif ($header eq 'update_timestamp_jobdb_entry' ) { $out_msg = &update_timestamp_jobdb_entry }
266 else {
267 # msg could not be assigned to core function
268 # fetch all available eventhandler under $server_event_dir
269 opendir (DIR, $server_event_dir) or &main::daemon_log("ERROR cannot open $server_event_dir: $!\n", 1) and return;
270 while (defined (my $file = readdir (DIR))) {
271 if (not $file eq $header) {
272 next;
273 }
274 # try to deliver incoming msg to eventhandler
275 my $cmd = File::Spec->join($server_event_dir, $header)." '$msg'";
276 &main::daemon_log("GosaPackages: execute event_handler $header", 3);
277 &main::daemon_log("GosaPackages: cmd: $cmd", 7);
279 $out_msg = "";
280 open(PIPE, "$cmd 2>&1 |");
281 while(<PIPE>) {
282 $out_msg.=$_;
283 }
284 close(PIPE);
285 &main::daemon_log("GosaPackages: answer of cmd: $out_msg", 5);
286 last;
287 }
288 }
290 # if delivery not possible raise error and return
291 if (not defined $out_msg) {
292 &main::daemon_log("ERROR: GosaPackages: no event handler or core function defined for $header", 1);
293 } elsif ($out_msg eq "") {
294 &main::daemon_log("ERROR: GosaPackages got not answer from event_handler $header", 1);
295 }
296 return $out_msg;
298 }
301 sub process_job_msg {
302 my ($msg, $msg_hash)= @_ ;
304 my $header = @{$msg_hash->{header}}[0];
305 $header =~ s/job_//;
306 &main::daemon_log("GosaPackages: got a job msg for queue: $header", 5);
308 # check wether mac address is already known in known_daemons or known_clients
309 my $target = 'none';
311 # add job to job queue
312 my $func_dic = {table=>$main::job_queue_table_name,
313 primkey=>'id',
314 timestamp=>@{$msg_hash->{timestamp}}[0],
315 status=>'waiting',
316 result=>'none',
317 headertag=>$header,
318 targettag=>$target,
319 xmlmessage=>$msg,
320 macaddress=>@{$msg_hash->{mac}}[0],
321 };
322 my $res = $main::job_db->add_dbentry($func_dic);
323 if (not $res == 0) {
324 &main::daemon_log("ERROR: GosaPackages: process_job_msg: $res", 1);
325 }
327 &main::daemon_log("GosaPackages: $header job successfully added to job queue", 3);
328 return "<xml><1>$res</1></xml>";
330 }
333 sub db_res_2_xml {
334 my ($db_res) = @_ ;
335 my $xml = "<xml>";
337 while ( my ($hit, $hash) = each %{ $db_res } ) {
338 $xml .= "<answer$hit>";
340 while ( my ($column_name, $column_value) = each %{$hash} ) {
341 $xml .= "<$column_name>";
342 my $xml_content = $column_value;
343 if( $column_name eq "xml" ) {
344 $xml_content = &encode_base64($column_value);
345 }
346 $xml .= $xml_content;
347 $xml .= "</$column_name>";
348 }
350 $xml .= "</answer$hit>";
351 }
353 $xml .= "</xml>";
354 return $xml;
355 }
358 ## CORE FUNCTIONS ############################################################
360 sub query_jobdb {
361 my ($msg) = @_;
362 my $msg_hash = &transform_msg2hash($msg);
364 # prepare query sql statement
365 my @where = @{$msg_hash->{where}};
366 my $where_hash = {table=>$main::job_queue_table_name };
367 foreach my $where_pram (@where) {
368 my $where_val = @{$msg_hash->{$where_pram}}[0];
369 if (defined $where_val) {
370 $where_hash->{$where_pram} = $where_val;
371 }
372 }
374 # execute db query
375 my $res_hash = $main::job_db->select_dbentry($where_hash);
377 my $out_xml = &db_res_2_xml($res_hash);
378 return $out_xml;
379 }
381 sub delete_jobdb_entry {
382 my ($msg) = @_ ;
383 my $msg_hash = &transform_msg2hash($msg);
385 # prepare query sql statement
386 my @where = @{$msg_hash->{where}};
387 my $where_hash = {table=>$main::job_queue_table_name };
388 foreach my $where_pram (@where) {
389 my $where_val = @{$msg_hash->{$where_pram}}[0];
390 if (defined $where_val) {
391 $where_hash->{$where_pram} = $where_val;
392 }
393 }
395 # execute db query
396 my $db_res = $main::job_db->del_dbentry($where_hash);
398 my $res;
399 if( $db_res > 0 ) {
400 $res = 0 ;
401 } else {
402 $res = 1;
403 }
405 # prepare xml answer
406 my $out_xml = "<xml><answer1>$res</answer1></xml>";
407 return $out_xml;
409 }
411 sub clear_jobdb {
412 my ($msg) = @_ ;
413 my $msg_hash = &transform_msg2hash($msg);
415 my $where_hash = {table=>$main::job_queue_table_name };
417 # execute db query
418 my $db_res = $main::job_db->del_dbentry($where_hash);
419 print STDERR "db_res=$db_res\n";
420 my $res;
421 if( $db_res eq '0E0' ) {
422 $res = 0 ;
423 } else {
424 $res = 1;
425 }
427 # prepare xml answer
428 my $out_xml = "<xml><answer1>$res</answer1></xml>";
429 return $out_xml;
430 }
432 sub update_status_jobdb_entry {
433 my ($msg) = @_ ;
434 my $msg_hash = &transform_msg2hash($msg);
436 # prepare query sql statement
437 my $update_hash = {table=>$main::job_queue_table_name };
438 if( exists $msg_hash->{where} ) {
439 $update_hash->{where} = $msg_hash->{where};
440 } else {
441 $update_hash->{where} = [];
442 }
444 if( not exists $msg_hash->{update}[0]->{status} ) {
445 return "<xml><answer1>1</answer1></xml>";
446 }
447 $update_hash->{update} = [ { status=>$msg_hash->{update}[0]->{status} } ];
449 # execute db query
450 my $db_res = $main::job_db->update_dbentry($update_hash);
452 # transform db answer to error returnment
453 my $res;
454 if( $db_res > 0 ) {
455 $res = 0 ;
456 } else {
457 $res = 1;
458 }
460 # prepare xml answer
461 my $out_xml = "<xml><answer1>$res</answer1></xml>";
462 return $out_xml;
463 }
465 sub update_timestamp_jobdb_entry {
466 my ($msg) = @_ ;
467 my $msg_hash = &transform_msg2hash($msg);
469 # prepare query sql statement
470 my $update_hash = {table=>$main::job_queue_table_name };
471 if( exists $msg_hash->{where} ) {
472 $update_hash->{where} = $msg_hash->{where};
473 } else {
474 $update_hash->{where} = [];
475 }
477 if( not exists $msg_hash->{update}[0]->{timestamp} ) {
478 return "<xml><answer1>1</answer1></xml>";
479 }
481 $update_hash->{update} = [ { timestamp=>$msg_hash->{update}[0]->{timestamp} } ];
483 # execute db query
484 my $db_res = $main::job_db->update_dbentry($update_hash);
486 # transform db answer to error returnment
487 my $res;
488 if( $db_res > 0 ) {
489 $res = 0 ;
490 } else {
491 $res = 1;
492 }
494 # prepare xml answer
495 my $out_xml = "<xml><answer1>$res</answer1></xml>";
496 return $out_xml;
498 }
501 1;