]> git.evergreen-ils.org Git - working/Evergreen.git/blob - Open-ILS/src/support-scripts/action_trigger_runner.pl
Minor whitespace/syntax changes, sifted out of the previous telephony commit.
[working/Evergreen.git] / Open-ILS / src / support-scripts / action_trigger_runner.pl
1 #!/usr/bin/perl
2 # ---------------------------------------------------------------
3 # Copyright (C) 2009 Equinox Software, Inc
4 # Author: Bill Erickson <erickson@esilibrary.com>
5 #
6 # This program is free software; you can redistribute it and/or
7 # modify it under the terms of the GNU General Public License
8 # as published by the Free Software Foundation; either version 2
9 # of the License, or (at your option) any later version.
10
11 # This program is distributed in the hope that it will be useful,
12 # but WITHOUT ANY WARRANTY; without even the implied warranty of
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 # GNU General Public License for more details.
15 # ---------------------------------------------------------------
16 use strict;
17 use warnings;
18 use Getopt::Long;
19 use OpenSRF::System;
20 use OpenSRF::AppSession;
21 use OpenSRF::Utils::JSON;
22 use OpenSRF::EX qw(:try);
23 use OpenILS::Utils::Fieldmapper;
24
25 # DEFAULT values
26
27 my $opt_lockfile      = '/tmp/action-trigger-LOCK';
28 my $opt_osrf_config   = '/openils/conf/opensrf_core.xml';
29 my $opt_custom_filter = '/openils/conf/action_trigger_filters.json';
30 my $opt_max_sleep     = 3600;  # default to 1 hour
31 my $opt_run_pending   = 0;
32 my $opt_debug_stdout  = 0;
33 my $opt_help          = 0;
34 my $opt_verbose;
35 my $opt_hooks;
36 my $opt_process_hooks = 0;
37 my $opt_granularity   = undef;
38
39 (-f $opt_custom_filter) or undef($opt_custom_filter);   # discard default if no file exists
40
41 GetOptions(
42     'max-sleep'        => \$opt_max_sleep,
43     'osrf-config=s'    => \$opt_osrf_config,
44     'run-pending'      => \$opt_run_pending,
45     'hooks=s'          => \$opt_hooks,
46     'granularity=s'    => \$opt_granularity,
47     'process-hooks'    => \$opt_process_hooks,
48     'debug-stdout'     => \$opt_debug_stdout,
49     'custom-filters=s' => \$opt_custom_filter,
50     'lock-file=s'      => \$opt_lockfile,
51     'verbose'          => \$opt_verbose,
52     'help'             => \$opt_help,
53 );
54
55 my $max_sleep = $opt_max_sleep;
56
57 # typical passive hook filters
58 my $hook_handlers = {
59
60     # default overdue circulations
61     'checkout.due' => {
62         context_org => 'circ_lib',
63         filter => {
64             checkin_time => undef, 
65             '-or' => [
66                 {stop_fines => ['MAXFINES', 'LONGOVERDUE']}, 
67                 {stop_fines => undef}
68             ]
69         }
70     }
71 };
72
73 if ($opt_custom_filter) {
74     open FILTERS, $opt_custom_filter or die "Cannot read custom filters at $opt_custom_filter";
75     $hook_handlers = OpenSRF::Utils::JSON->JSON2perl(join('',(<FILTERS>)));
76     close FILTERS;
77 }
78
79 sub help {
80     print <<HELP;
81
82 $0 : Create and process action/trigger events
83
84     --osrf-config=<config_file>
85         OpenSRF core config file.  Defaults to:
86             /openils/conf/opensrf_core.xml
87
88     --custom-filters=<filter_file>
89         File containing a JSON Object which describes any hooks that should
90         use a user-defined filter to find their target objects.  Defaults to:
91             /openils/conf/action_trigger_filters.json
92
93     --run-pending
94         Run pending events
95
96     --process-hooks
97         Create hook events
98
99     --max-sleep=<seconds>
100         When in process-hooks mode, wait up to <seconds> for the lock file to
101         go away.  Defaults to 3600 (1 hour).
102
103     --hooks=hook1[,hook2,hook3,...]
104         Define which hooks to create events for.  If none are defined,
105         it defaults to the list of hooks defined in the --custom-filters option.
106
107     --granularity=<label>
108         Run events with {label} granularity setting, or no granularity setting
109
110     --debug-stdout
111         Print server responses to stdout (as JSON) for debugging
112
113     --lock-file=<file_name>
114         Lock file
115
116     --help
117         Show this help
118
119     Examples:
120
121         # To run all pending events.  This is what you tell CRON to run at
122         # regular intervals
123         perl $0 --osrf-config /openils/conf/opensrf_core.xml --run-pending
124
125         # To batch create all "checkout.due" events
126         perl $0 --osrf-config /openils/conf/opensrf_core.xml --hooks checkout.due
127
128 HELP
129 }
130
131
132 # create events for the specified hooks using the configured filters and context orgs
133 sub process_hooks {
134     $opt_verbose and print "process_hooks: " . ($opt_process_hooks ? '(start)' : 'SKIPPING') . "\n";
135     return unless $opt_process_hooks;
136
137     my @hooks = ($opt_hooks) ? split(',', $opt_hooks) : keys(%$hook_handlers);
138     my $ses = OpenSRF::AppSession->create('open-ils.trigger');
139
140     for my $hook (@hooks) {
141         my $config = $$hook_handlers{$hook};
142         $opt_verbose and print "process_hooks: $hook " . ($config ? ($opt_granularity || '') : ' NO HANDLER') . "\n";
143         $config or next;
144
145         my $method = 'open-ils.trigger.passive.event.autocreate.batch';
146         $method =~ s/passive/active/ if $config->{active};
147         
148         my $req = $ses->request($method, $hook, $config->{context_org}, $config->{filter}, $opt_granularity);
149         while (my $resp = $req->recv(timeout => 1800)) {
150             $opt_debug_stdout and print OpenSRF::Utils::JSON->perl2JSON($resp->content) . "\n";
151         }
152     }
153 }
154
155 sub run_pending {
156     $opt_verbose and print "run_pending: " .
157         ($opt_run_pending ? ($opt_granularity || 'ALL granularity') : 'SKIPPING') . "\n";
158     return unless $opt_run_pending;
159     my $ses = OpenSRF::AppSession->create('open-ils.trigger');
160     my $req = $ses->request('open-ils.trigger.event.run_all_pending' => $opt_granularity);
161
162     my $check_lockfile = 1;
163     while (my $resp = $req->recv(timeout => 7200)) {
164         if ($check_lockfile && -e $opt_lockfile) {
165             open LF, $opt_lockfile;
166             my $contents = <LF>;
167             close LF;
168             unlink $opt_lockfile if ($contents == $$);
169             $check_lockfile = 0;
170         }
171         $opt_debug_stdout and print OpenSRF::Utils::JSON->perl2JSON($resp->content) . "\n";
172     }
173 }
174
175 help() and exit if $opt_help;
176 help() and exit unless ($opt_run_pending or $opt_process_hooks);
177
178 # check the lockfile
179 if (-e $opt_lockfile) {
180     die "I'm already running with lockfile $opt_lockfile\n" if (!$opt_process_hooks);
181     # sleeping loop if we're in --process-hooks mode
182     do { last unless ( -e $opt_lockfile ); $max_sleep--; } while ($max_sleep >= 0 && sleep(1));
183 }
184
185 # there's a tiny race condition here ... oh well
186 die "Someone else has been holding the lockfile $opt_lockfile for at least $opt_max_sleep. Giving up now ...\n" if (-e $opt_lockfile);
187
188 # set the lockfile
189 open(F, ">$opt_lockfile") or die "Unable to open lockfile $opt_lockfile for writing\n";
190 print F $$;
191 close F;
192
193 try {
194         OpenSRF::System->bootstrap_client(config_file => $opt_osrf_config);
195         Fieldmapper->import(IDL => OpenSRF::Utils::SettingsClient->new->config_value("IDL"));
196     process_hooks();
197     run_pending();
198 } otherwise {
199     my $e = shift;
200     warn "$e\n";
201 };
202
203 if (-e $opt_lockfile) {
204     open LF, $opt_lockfile;
205     my $contents = <LF>;
206     close LF;
207     unlink $opt_lockfile if ($contents == $$);
208 }