Bug 29794: Add missing include in delete_items.pl
[srvgit] / misc / cronjobs / process_message_queue.pl
index 0532a5b..d8918be 100755 (executable)
 
 use strict;
 use warnings;
-BEGIN {
-    # find Koha's Perl modules
-    # test carefully before changing this
-    use FindBin;
-    eval { require "$FindBin::Bin/../kohalib.pl" };
-}
 
 use Koha::Script -cron;
-use C4::Letters;
-use C4::Log;
-use Getopt::Long;
+use C4::Letters qw( SendQueuedMessages );
+use C4::Log qw( cronlogaction );
+use Getopt::Long qw( GetOptions );
+use Try::Tiny qw( catch try );
 
 my $username = undef;
 my $password = undef;
@@ -38,6 +33,7 @@ my $method = 'LOGIN';
 my $help = 0;
 my $verbose = 0;
 my $type = q{};
+my $letter_code;
 
 GetOptions(
     'u|username:s'      => \$username,
@@ -47,6 +43,7 @@ GetOptions(
     'h|help|?'          => \$help,
     'v|verbose'         => \$verbose,
     't|type:s'          => \$type,
+    'c|code:s'          => \$letter_code,
 );
 my $usage = << 'ENDUSAGE';
 
@@ -60,6 +57,7 @@ This script has the following parameters :
     -u --username: username of mail account
     -p --password: password of mail account
     -t --type: If supplied, only processes this type of message ( email, sms )
+    -c --code: If supplied, only processes messages with this letter code
     -l --limit: The maximum number of messages to process for this run
     -m --method: authentication method required by SMTP server (See perldoc Sendmail.pm for supported authentication types.)
     -h --help: this message
@@ -70,14 +68,39 @@ die $usage if $help;
 
 cronlogaction();
 
+if ( C4::Context->config("enable_plugins") ) {
+    my @plugins = Koha::Plugins->new->GetPlugins({
+        method => 'before_send_messages',
+    });
+
+    if (@plugins) {
+        foreach my $plugin ( @plugins ) {
+            try {
+                $plugin->before_send_messages(
+                    {
+                        verbose     => $verbose,
+                        limit       => $limit,
+                        type        => $type,
+                        letter_code => $letter_code,
+                    }
+                );
+            }
+            catch {
+                warn "$_";
+            };
+        }
+    }
+}
+
 C4::Letters::SendQueuedMessages(
     {
-        verbose  => $verbose,
-        username => $username,
-        password => $password,
-        method   => $method,
-        limit    => $limit,
-        type     => $type,
+        verbose     => $verbose,
+        username    => $username,
+        password    => $password,
+        method      => $method,
+        limit       => $limit,
+        type        => $type,
+        letter_code => $letter_code,
     }
 );