blob: 75247fbaf4213cd54eb566bfe2a20a09b4b5e69a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
package FS::Cron::check;
use strict;
use vars qw( @ISA @EXPORT_OK $DEBUG $FS_RUN $error_msg
$SELFSERVICE_USER $SELFSERVICE_MACHINES @SELFSERVICE_MACHINES
);
use Exporter;
use LWP::UserAgent;
use HTTP::Request;
use URI::Escape;
use Email::Send;
use FS::Conf;
use FS::Record qw(qsearch);
use FS::cust_pay_pending;
@ISA = qw( Exporter );
@EXPORT_OK = qw(
check_queued check_selfservice check_apache check_bop_failures
alert error_msg
);
$DEBUG = 0;
$FS_RUN = '/var/run';
sub check_queued {
_check_fsproc('queued');
}
$SELFSERVICE_USER = '%%%SELFSERVICE_USER%%%';
$SELFSERVICE_MACHINES = '%%%SELFSERVICE_MACHINES%%%'; #substituted by Makefile
$SELFSERVICE_MACHINES =~ s/^\s+//;
$SELFSERVICE_MACHINES =~ s/\s+$//;
@SELFSERVICE_MACHINES = split(/\s+/, $SELFSERVICE_MACHINES);
@SELFSERVICE_MACHINES = ()
if scalar(@SELFSERVICE_MACHINES) == 1
&& $SELFSERVICE_MACHINES[0] eq '%%%'.'SELFSERVICE_MACHINES'.'%%%';
sub check_selfservice {
foreach my $machine ( @SELFSERVICE_MACHINES ) {
unless ( _check_fsproc("selfservice-server.$SELFSERVICE_USER.$machine") ) {
$error_msg = "Self-service daemon not running for $machine";
return 0;
}
}
return 1;
}
sub _check_fsproc {
my $arg = shift;
_check_pidfile( "freeside-$arg.pid" );
}
sub _check_pidfile {
my $pidfile = shift;
open(PID, "$FS_RUN/$pidfile") or return 0;
chomp( my $pid = scalar(<PID>) );
close PID; # or return 0;
$pid && kill 0, $pid;
}
sub check_apache {
my $ua = new LWP::UserAgent;
$ua->agent("FreesideCronCheck/0.1 " . $ua->agent);
my $req = new HTTP::Request GET => 'https://localhost/';
my $res = $ua->request($req);
return 1 if $res->is_success || $res->status_line =~ /^403/;
$error_msg = $res->status_line;
return 0;
}
#and now for something entirely different...
my $num_consecutive_bop_failures = 60;
sub check_bop_failures {
return 1 if grep { $_->statustext eq 'captured' }
qsearch({
'table' => 'cust_pay_pending',
'hashref' => { 'status' => 'done' },
'order_by' => 'ORDER BY paypendingnum DESC'.
" LIMIT $num_consecutive_bop_failures",
});
$error_msg = "Last $num_consecutive_bop_failures real-time payments failed";
return 0;
}
#
sub error_msg {
$error_msg;
}
sub alert {
my( $alert, @emails ) = @_;
my $conf = new FS::Conf;
my $smtpmachine = $conf->config('smtpmachine');
my $company_name = $conf->config('company_name');
foreach my $email (@emails) {
warn "warning $email about $alert\n" if $DEBUG;
my $message = <<"__MESSAGE__";
From: support\@freeside.biz
To: $email
Subject: FREESIDE ALERT for $company_name
FREESIDE ALERT: $alert
__MESSAGE__
my $sender = Email::Send->new({ mailer => 'SMTP' });
$sender->mailer_args([ Host => $smtpmachine ]);
$sender->send($message);
}
}
1;
|
