2 # ---------------------------------------------------------------
3 # Copyright (C) 2009 Equinox Software, Inc
4 # Author: Bill Erickson <erickson@esilibrary.com>
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.
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 # ---------------------------------------------------------------
20 use OpenSRF::AppSession;
21 use OpenSRF::Utils::JSON;
22 use OpenSRF::Utils::Logger qw/$logger/;
23 use OpenSRF::EX qw(:try);
24 use OpenILS::Utils::Fieldmapper;
25 my $req_timeout = 10800;
29 my $opt_lockfile = '/tmp/action-trigger-LOCK';
30 my $opt_osrf_config = '@sysconfdir@/opensrf_core.xml';
31 my $opt_custom_filter = '@sysconfdir@/action_trigger_filters.json';
32 my $opt_max_sleep = 3600; # default to 1 hour
33 my $opt_run_pending = 0;
34 my $opt_debug_stdout = 0;
38 my $opt_process_hooks = 0;
39 my $opt_granularity = undef;
40 my $opt_gran_only = undef;
42 (-f $opt_custom_filter) or undef($opt_custom_filter); # discard default if no file exists
45 'max-sleep' => \$opt_max_sleep,
46 'osrf-config=s' => \$opt_osrf_config,
47 'run-pending' => \$opt_run_pending,
48 'hooks=s' => \$opt_hooks,
49 'granularity=s' => \$opt_granularity,
50 'granularity-only' => \$opt_gran_only,
51 'process-hooks' => \$opt_process_hooks,
52 'debug-stdout' => \$opt_debug_stdout,
53 'custom-filters=s' => \$opt_custom_filter,
54 'lock-file=s' => \$opt_lockfile,
55 'verbose' => \$opt_verbose,
59 my $max_sleep = $opt_max_sleep;
61 #XXX need to figure out why this is required...
62 $opt_gran_only = $opt_granularity ? 1 : 0;
64 $opt_lockfile .= '.' . $opt_granularity if ($opt_granularity && $opt_gran_only);
66 # typical passive hook filters
69 # default overdue circulations
71 context_org => 'circ_lib',
73 checkin_time => undef,
75 {stop_fines => ['MAXFINES']},
82 if ($opt_custom_filter) {
83 open FILTERS, $opt_custom_filter or die "Cannot read custom filters at $opt_custom_filter";
84 $hook_handlers = OpenSRF::Utils::JSON->JSON2perl(join('',(<FILTERS>)));
91 $0 : Create and process action/trigger events
93 --osrf-config=<config_file>
94 OpenSRF core config file. Defaults to:
95 @sysconfdir@/opensrf_core.xml
97 --custom-filters=<filter_file>
98 File containing a JSON Object which describes any hooks that should
99 use a user-defined filter to find their target objects. Defaults to:
100 @sysconfdir@/action_trigger_filters.json
108 --max-sleep=<seconds>
109 When in process-hooks mode, wait up to <seconds> for the lock file to
110 go away. Defaults to 3600 (1 hour).
112 --hooks=hook1[,hook2,hook3,...]
113 Define which hooks to create events for. If none are defined,
114 it defaults to the list of hooks defined in the --custom-filters option.
116 --granularity=<label>
117 Run events with {label} granularity setting, or no granularity setting
120 Used in combination with --granularity, prevents the running of events with no granularity setting
123 Print server responses to stdout (as JSON) for debugging
125 --lock-file=<file_name>
133 # To run all pending events. This is what you tell CRON to run at
135 perl $0 --osrf-config @sysconfdir@/opensrf_core.xml --run-pending
137 # To batch create all "checkout.due" events
138 perl $0 --osrf-config @sysconfdir@/opensrf_core.xml --hooks=checkout.due --process-hooks
144 # create events for the specified hooks using the configured filters and context orgs
146 $opt_verbose and print "process_hooks: " . ($opt_process_hooks ? '(start)' : 'SKIPPING') . "\n";
147 return unless $opt_process_hooks;
149 my @hooks = ($opt_hooks) ? split(',', $opt_hooks) : keys(%$hook_handlers);
150 my $ses = OpenSRF::AppSession->create('open-ils.trigger');
152 for my $hook (@hooks) {
153 my $config = $$hook_handlers{$hook};
154 $opt_verbose and print "process_hooks: $hook " . ($config ? ($opt_granularity || '') : ' NO HANDLER') . "\n";
157 my $method = 'open-ils.trigger.passive.event.autocreate.batch';
158 $method =~ s/passive/active/ if $config->{active};
160 my $req = $ses->request($method, $hook, $config->{context_org}, $config->{filter}, $opt_granularity);
162 my $debug_hook = "'$hook' and filter ".OpenSRF::Utils::JSON->perl2JSON($config->{filter});
163 $logger->info("at_runner: creating events for $debug_hook");
166 while (my $resp = $req->recv(timeout => $req_timeout)) {
167 push(@event_ids, $resp->content);
171 $logger->info("at_runner: created ".scalar(@event_ids)." events for $debug_hook");
172 } elsif($req->complete) {
173 $logger->info("at_runner: no events to create for $debug_hook");
175 $logger->warn("at_runner: timeout occurred during event creation for $debug_hook");
181 $opt_verbose and print "run_pending: " .
184 ( $opt_granularity . (
195 return unless $opt_run_pending;
196 my $ses = OpenSRF::AppSession->create('open-ils.trigger');
197 my $req = $ses->request('open-ils.trigger.event.run_all_pending' => $opt_granularity => $opt_gran_only);
199 my $check_lockfile = 1;
200 while (my $resp = $req->recv(timeout => $req_timeout)) {
201 if ($check_lockfile && -e $opt_lockfile) {
202 open LF, $opt_lockfile;
205 unlink $opt_lockfile if ($contents == $$);
208 $opt_debug_stdout and print OpenSRF::Utils::JSON->perl2JSON($resp->content) . "\n";
212 help() and exit if $opt_help;
213 help() and exit unless ($opt_run_pending or $opt_process_hooks);
216 if (-e $opt_lockfile) {
217 die "I'm already running with lockfile $opt_lockfile\n" unless ($opt_process_hooks or $opt_granularity);
218 # sleeping loop if we're in --process-hooks mode
219 while ($max_sleep >= 0 && sleep(1)) {
220 last unless ( -e $opt_lockfile );
225 # there's a tiny race condition here ... oh well
226 die "Someone else has been holding the lockfile $opt_lockfile for at least $opt_max_sleep. Giving up now ...\n" if (-e $opt_lockfile);
229 open(F, ">$opt_lockfile") or die "Unable to open lockfile $opt_lockfile for writing\n";
234 OpenSRF::System->bootstrap_client(config_file => $opt_osrf_config);
235 Fieldmapper->import(IDL => OpenSRF::Utils::SettingsClient->new->config_value("IDL"));
243 if (-e $opt_lockfile) {
244 open LF, $opt_lockfile;
247 unlink $opt_lockfile if ($contents == $$);