2 # BEGIN BPS TAGGED BLOCK {{{
6 # This software is Copyright (c) 1996-2014 Best Practical Solutions, LLC
7 # <sales@bestpractical.com>
9 # (Except where explicitly superseded by other copyright notices)
14 # This work is made available to you under the terms of Version 2 of
15 # the GNU General Public License. A copy of that license should have
16 # been provided with this software, but in any event can be snarfed
19 # This work is distributed in the hope that it will be useful, but
20 # WITHOUT ANY WARRANTY; without even the implied warranty of
21 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
22 # General Public License for more details.
24 # You should have received a copy of the GNU General Public License
25 # along with this program; if not, write to the Free Software
26 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
27 # 02110-1301 or visit their web page on the internet at
28 # http://www.gnu.org/licenses/old-licenses/gpl-2.0.html.
31 # CONTRIBUTION SUBMISSION POLICY:
33 # (The following paragraph is not intended to limit the rights granted
34 # to you to modify and distribute this software under the terms of
35 # the GNU General Public License and is only of importance to you if
36 # you choose to contribute your changes and enhancements to the
37 # community by submitting them to Best Practical Solutions, LLC.)
39 # By intentionally submitting any modifications, corrections or
40 # derivatives to this work, or any other work intended for use with
41 # Request Tracker, to Best Practical Solutions, LLC, you confirm that
42 # you are the copyright holder for those contributions and you grant
43 # Best Practical Solutions, LLC a nonexclusive, worldwide, irrevocable,
44 # royalty-free, perpetual, license to use, copy, create derivative
45 # works based on those contributions, and sublicense and distribute
46 # those contributions and any derivatives thereof.
48 # END BPS TAGGED BLOCK }}}
52 BEGIN { # BEGIN RT CMD BOILERPLATE
55 my @libs = ("lib", "local/lib");
59 unless ( File::Spec->file_name_is_absolute($lib) ) {
60 $bin_path ||= ( File::Spec->splitpath(Cwd::abs_path(__FILE__)) )[1];
61 $lib = File::Spec->catfile( $bin_path, File::Spec->updir, $lib );
68 use Date::Format qw( strftime );
71 use RT::Interface::CLI qw( CleanEnv loc );
72 use RT::Interface::Email;
80 print loc("Usage:") . " $0 -m (daily|weekly) [--print] [--help]\n";
82 "[_1] is a utility, meant to be run from cron, that dispatches all deferred RT notifications as a per-user digest.",
85 print "\n\t-m, --mode\t"
86 . loc("Specify whether this is a daily or weekly run.") . "\n";
87 print "\t-p, --print\t"
88 . loc("Print the resulting digest messages to STDOUT; don't mail them. Do not mark them as sent")
90 print "\t-v, --verbose\t" . loc("Give output even on messages successfully sent") . "\n";
91 print "\t-h, --help\t" . loc("Print this message") . "\n";
93 if ( $error eq 'help' ) {
96 print loc("Error") . ": " . loc($error) . "\n";
101 my ( $frequency, $print, $verbose, $help ) = ( '', '', '', '' );
103 'mode=s' => \$frequency,
105 'verbose' => \$verbose,
109 usage('help') if $help;
110 usage("Mode argument must be 'daily' or 'weekly'")
111 unless $frequency =~ /^(daily|weekly)$/;
113 run( $frequency, $print );
116 my $frequency = shift;
119 ## Find all the tickets that have been modified within the time frame
120 ## described by $frequency.
122 my ( $all_digest, $sent_transactions ) = find_transactions($frequency);
124 ## Iterate through our huge hash constructing the digest message
125 ## for each user and sending it.
127 foreach my $user ( keys %$all_digest ) {
128 my ( $contents_list, $contents_body ) = build_digest_for_user( $user, $all_digest->{$user} );
129 # Now we have a content head and a content body. We can send a message.
130 if ( send_digest( $user, $contents_list, $contents_body ) ) {
131 print "Sent message to $user\n" if $verbose;
132 mark_transactions_sent( $frequency, $user, values %{$sent_transactions->{$user}} ) unless ($print);
134 print "Failed to send message to $user\n";
143 my ( $to, $index, $messages ) = @_;
145 # Combine the index and the messages.
147 my $body = "============== Tickets with activity in the last "
148 . ( $frequency eq 'daily' ? "day" : "seven days" ) . "\n\n";
151 $body .= "\n\n============== Messages recorded in the last "
152 . ( $frequency eq 'daily' ? "day" : "seven days" ) . "\n\n";
155 # Load our template. If we cannot load the template, abort
156 # immediately rather than failing through many loops.
157 my $digest_template = RT::Template->new( RT->SystemUser );
158 my ( $ret, $msg ) = $digest_template->Load('Email Digest');
160 print loc("Failed to load template")
161 . " 'Email Digest': "
163 . ". Cannot continue.\n";
166 ( $ret, $msg ) = $digest_template->Parse( Argument => $body );
168 print loc("Failed to parse template")
169 . " 'Email Digest'. Cannot continue.\n";
173 # Set our sender and recipient.
174 $digest_template->MIMEObj->head->replace(
175 'From', Encode::encode( "UTF-8", RT::Config->Get('CorrespondAddress') ) );
176 $digest_template->MIMEObj->head->replace(
177 'To', Encode::encode( "UTF-8", $to ) );
180 $digest_template->MIMEObj->print;
183 return RT::Interface::Email::SendEmail( Entity => $digest_template->MIMEObj)
187 # =item mark_transactions_sent( $frequency, $user, @txn_list );
189 # Takes a frequency string (either 'daily' or 'weekly'), a user and one or more
190 # transaction objects as its arguments. Marks the given deferred
191 # notifications as sent.
195 sub mark_transactions_sent {
196 my ( $freq, $user, @txns ) = @_;
197 return unless $freq =~ /(daily|weekly)/;
199 foreach my $txn (@txns) {
201 # Grab the attribute, mark the "sent" as true, and store the new
203 if ( my $attr = $txn->FirstAttribute('DeferredRecipients') ) {
204 my $deferred = $attr->Content;
205 $deferred->{$freq}->{$user}->{'_sent'} = 1;
207 Name => 'DeferredRecipients',
208 Description => 'Deferred recipients for this message',
209 Content => $deferred,
216 my $frequency = shift;
218 # Specify a short time for digest overlap, in case we aren't starting
219 # this process exactly on time.
220 my $OVERLAP_HEDGE = -30;
222 my $since_date = RT::Date->new( RT->SystemUser );
223 $since_date->Set( Format => 'unix', Value => time() );
224 if ( $frequency eq 'daily' ) {
225 $since_date->AddDays(-1);
227 $since_date->AddDays(-7);
230 $since_date->AddSeconds($OVERLAP_HEDGE);
235 sub find_transactions {
236 my $frequency = shift;
237 my $since_date = since_date($frequency);
239 my $txns = RT::Transactions->new( RT->SystemUser );
241 # First limit to recent transactions.
245 VALUE => $since_date->ISO
248 # Next limit to ticket transactions.
250 FIELD => 'ObjectType',
252 VALUE => 'RT::Ticket',
253 ENTRYAGGREGATOR => 'AND'
256 my $sent_transactions = {};
258 while ( my $txn = $txns->Next ) {
259 my $ticket = $txn->Ticket;
260 my $queue = $txn->TicketObj->QueueObj->Name;
261 # Xxx todo - may clobber if two queues have the same name
262 foreach my $user ( $txn->DeferredRecipients($frequency) ) {
263 $all_digest->{$user}->{$queue}->{$ticket}->{ $txn->id } = $txn;
264 $sent_transactions->{$user}->{ $txn->id } = $txn;
268 return ( $all_digest, $sent_transactions );
271 sub build_digest_for_user {
273 my $user_digest = shift;
275 my $contents_list = ''; # Holds the digest index.
276 my $contents_body = ''; # Holds the digest body.
278 # Has the user been disabled since a message was deferred on his/her
280 my $user_obj = RT::User->new( RT->SystemUser );
281 $user_obj->LoadByEmail($user);
282 if ( $user_obj->PrincipalObj->Disabled ) {
283 print STDERR loc("Skipping disabled user") . " $user\n";
287 print loc("Message for user") . " $user:\n\n" if $print;
288 foreach my $queue ( keys %$user_digest ) {
289 $contents_list .= "Queue $queue:\n";
290 $contents_body .= "Queue $queue:\n";
291 foreach my $ticket ( sort keys %{ $user_digest->{$queue} } ) {
292 my $tkt_txns = $user_digest->{$queue}->{$ticket};
293 my $ticket_obj = RT::Ticket->new( RT->SystemUser );
294 $ticket_obj->Load($ticket);
296 # Spit out the index entry for this ticket.
297 my $ticket_title = sprintf(
299 $ticket, $ticket_obj->Status, $ticket_obj->OwnerObj->Name,
302 $contents_list .= $ticket_title;
304 # Spit out the messages for the transactions on this ticket.
305 $contents_body .= "\n== $ticket_title\n";
306 foreach my $txn ( sort keys %$tkt_txns ) {
307 my $top = $tkt_txns->{$txn}->Attachments->First;
309 # $top contains the top-most RT::Attachment with our
310 # outgoing message. It may not be the MIME part with
311 # the content. Print a few headers from it for
313 $contents_body .= "From: " . $top->GetHeader('From') . "\n";
314 my $date = $top->GetHeader('Date ');
316 my $txn_obj = RT::Transaction->new( RT->SystemUser );
317 $txn_obj->Load($txn);
318 my $date_obj = RT::Date->new( RT->SystemUser );
321 Value => $txn_obj->Created
323 $date = strftime( '%a, %d %b %Y %H:%M:%S %z',
324 @{ [ localtime( $date_obj->Unix ) ] } );
326 $contents_body .= "Date: $date\n\n";
327 $contents_body .= $tkt_txns->{$txn}->ContentObj->Content . "\n";
328 $contents_body .= "-------\n";
329 } # foreach transaction
333 return ( $contents_list, $contents_body );
341 rt-email-digest - dispatch deferred notifications as a per-user digest
345 rt-email-digest -m (daily|weekly) [--print] [--help]
349 This script is a tool to dispatch all deferred RT notifications as a per-user
358 Specify whether this is a daily or weekly run.
360 --mode is equal to -m
364 Print the resulting digest messages to STDOUT; don't mail them. Do not mark them as sent
366 --print is equal to -p
372 --help is equal to -h