X-Git-Url: http://wagnertech.de/git?a=blobdiff_plain;f=scripts%2Ftask_server.pl;h=ff21183da57b1a362de2b26ea7cfe44da3a855b4;hb=6d5743899631690b4a82190a977a075c66eb4a0d;hp=eb407cb35543c6e6973cf3f0857506a2d17034a9;hpb=db7dbf2671f1f6b7bbac2c284308dcd79c427711;p=kivitendo-erp.git diff --git a/scripts/task_server.pl b/scripts/task_server.pl index eb407cb35..ff21183da 100755 --- a/scripts/task_server.pl +++ b/scripts/task_server.pl @@ -1,10 +1,16 @@ #!/usr/bin/perl + +use List::MoreUtils qw(any); + use strict; my $exe_dir; BEGIN { + use FindBin; + use lib "$FindBin::Bin/.."; + use SL::System::Process; $exe_dir = SL::System::Process::exe_dir; @@ -20,6 +26,7 @@ use Cwd; use Daemon::Generic; use Data::Dumper; use DateTime; +use Encode qw(); use English qw(-no_match_vars); use File::Spec; use List::Util qw(first); @@ -33,12 +40,20 @@ use SL::InstanceConfiguration; use SL::LXDebug; use SL::LxOfficeConf; use SL::Locale; +use SL::Mailer; use SL::System::TaskServer; +use Template; our %lx_office_conf; +sub debug { + return if !$lx_office_conf{task_server}->{debug}; + $::lxdebug->message(0, @_); +} + sub lxinit { - my $login = $lx_office_conf{task_server}->{login}; + my $login = $lx_office_conf{task_server}->{login}; + my $client = $lx_office_conf{task_server}->{client}; package main; @@ -46,6 +61,7 @@ sub lxinit { $::locale = Locale->new($::lx_office_conf{system}->{language}); $::form = Form->new; $::auth = SL::Auth->new; + die "No client configured or no client found with the name/ID '$client'" unless $::auth->set_client($client); $::instance_conf = SL::InstanceConfiguration->new; $::request = { cgi => CGI->new({}) }; @@ -59,6 +75,22 @@ sub lxinit { die "cannot find locale for user $login" unless $::locale = Locale->new('de'); } +sub per_job_initialization { + $::locale = Locale->new($::myconfig{countrycode} || $::lx_office_conf{system}->{language}); + $::form = Form->new; + $::instance_conf = SL::InstanceConfiguration->new; + $::request = SL::Request->new( + cgi => CGI->new({}), + layout => SL::Layout::None->new, + ); + + $::auth->restore_session; + + $::instance_conf->init; + + $::form->{__ERROR_HANDLER} = sub { die @_ }; +} + sub drop_privileges { my $user = $lx_office_conf{task_server}->{run_as}; return unless $user; @@ -87,13 +119,58 @@ sub drop_privileges { } } +sub notify_on_failure { + my (%params) = @_; + + my $cfg = $lx_office_conf{'task_server/notify_on_failure'} || {}; + + return if any { !$cfg->{$_} } qw(send_email_to email_from email_subject email_template); + + chdir $exe_dir; + + return debug("Template " . $cfg->{email_template} . " missing!") unless -f $cfg->{email_template}; + + my $email_to = $cfg->{send_email_to}; + if ($email_to !~ m{\@}) { + my %user = $::auth->read_user(login => $email_to); + return debug("cannot find user for notification $email_to") unless %user; + + $email_to = $user{email}; + return debug("user for notification " . $user{login} . " doesn't have a valid email address") unless $email_to =~ m{\@}; + } + + my $template = Template->new({ + INTERPOLATE => 0, + EVAL_PERL => 0, + ABSOLUTE => 1, + CACHE_SIZE => 0, + }); + + return debug("Could not create Template instance") unless $template; + + $params{client} = $::auth->client; + + my $body; + $template->process($cfg->{email_template}, \%params, \$body); + + Mailer->new( + from => $cfg->{email_from}, + to => $email_to, + subject => $cfg->{email_subject}, + content_type => 'text/plain', + charset => 'utf-8', + message => Encode::decode('utf-8', $body), + )->send; +} + sub gd_preconfig { my $self = shift; SL::LxOfficeConf->read($self->{configfile}); - die "Missing section [task_server] in config file" unless $lx_office_conf{task_server}; - die "Missing key 'login' in section [task_server] in config file" unless $lx_office_conf{task_server}->{login}; + die "Missing section [task_server] in config file" unless $lx_office_conf{task_server}; + die "Missing key 'login' in section [task_server] in config file" unless $lx_office_conf{task_server}->{login}; + die "Missing key 'client' in section [task_server] in config file" unless $lx_office_conf{task_server}->{client}; drop_privileges(); lxinit(); @@ -104,35 +181,39 @@ sub gd_preconfig { sub gd_run { while (1) { my $ok = eval { - $::lxdebug->message(0, "Retrieving jobs") if $lx_office_conf{task_server}->{debug}; + debug("Retrieving jobs"); my $jobs = SL::DB::Manager::BackgroundJob->get_all_need_to_run; - $::lxdebug->message(0, " Found: " . join(' ', map { $_->package_name } @{ $jobs })) if $lx_office_conf{task_server}->{debug} && @{ $jobs }; + debug(" Found: " . join(' ', map { $_->package_name } @{ $jobs })) if @{ $jobs }; foreach my $job (@{ $jobs }) { # Provide fresh global variables in case legacy code modifies # them somehow. - $::locale = Locale->new($::lx_office_conf{system}->{language}); - $::form = Form->new; + per_job_initialization(); chdir $exe_dir; - $job->run; + my $history = $job->run; + + notify_on_failure(history => $history) if $history && $history->has_failed; } 1; }; - if ($lx_office_conf{task_server}->{debug}) { - $::lxdebug->message(0, "Exception during execution: ${EVAL_ERROR}") if !$ok; - $::lxdebug->message(0, "Sleeping"); + if (!$ok) { + my $error = $EVAL_ERROR; + debug("Exception during execution: ${error}"); + notify_on_failure(exception => $error); } + debug("Sleeping"); + my $seconds = 60 - (localtime)[0]; if (!eval { local $SIG{'ALRM'} = sub { - $::lxdebug->message(0, "Got woken up by SIGALRM") if $lx_office_conf{task_server}->{debug}; + debug("Got woken up by SIGALRM"); die "Alarm!\n" }; sleep($seconds < 30 ? $seconds + 60 : $seconds); @@ -143,6 +224,17 @@ sub gd_run { } } +sub end_of_request { + $main::lxdebug->show_backtrace(); + die <abs2rel(Cwd::abs_path($file), Cwd::abs_path($exe_dir)); newdaemon(configfile => $file, - progname => 'kivitendo-task-server', + progname => 'kivitendo-background-jobs', pidbase => SL::System::TaskServer::PID_BASE() . '/', );