/[notice-sender]/trunk/sender.pl
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /trunk/sender.pl

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 6 by dpavlin, Sat May 14 12:31:27 2005 UTC revision 16 by dpavlin, Sun May 15 16:29:44 2005 UTC
# Line 3  Line 3 
3  use strict;  use strict;
4  use Class::DBI::Loader::Pg;  use Class::DBI::Loader::Pg;
5  use Getopt::Long;  use Getopt::Long;
6  use Data::Dumper;  use Mail::CheckUser qw(check_email);
7    use Email::Valid;
8    use Email::Send;
9    
10  =head1 NAME  =head1 NAME
11    
12  sender.pl - command line notify sender utility  sender.pl - command line notify sender utility
13    
14    =head1 SYNOPSYS
15    
16     sender.pl --add=mylist members.txt
17     sender.pl --list[=mylist]
18     sender.pl --queue[=mylist message.txt]
19     sender.pl --send=mylist
20    
21    =head2 Command options
22    
23    =over 20
24    
25  =cut  =cut
26    
27  my ($list_opt,$debug) = (0,0);  my $debug = 0;
28    my $verbose = 0;
29    my $list_opt;
30  my $add_opt;  my $add_opt;
31  my $queue_opt;  my $queue_opt;
32    my $send_opt;
33    
34  my $result = GetOptions(  my $result = GetOptions(
35          "list"  => \$list_opt,          "list:s" => \$list_opt,
36          "add=s" => \$add_opt,          "add=s" => \$add_opt,
37          "queue=s" => \$queue_opt,          "queue:s" => \$queue_opt,
38            "send:s" => \$send_opt,
39          "debug" => \$debug,          "debug" => \$debug,
40            "verbose" => \$verbose,
41  );  );
42    
43    
# Line 38  my $lists = $loader->find_class('lists') Line 56  my $lists = $loader->find_class('lists')
56  my $users = $loader->find_class('users');  my $users = $loader->find_class('users');
57  my $user_list = $loader->find_class('user_list');  my $user_list = $loader->find_class('user_list');
58  my $messages = $loader->find_class('messages');  my $messages = $loader->find_class('messages');
59  my $message_list = $loader->find_class('message_list');  my $queue = $loader->find_class('queue');
60    my $sent = $loader->find_class('sent');
61    
62    $queue->set_sql( list_queue => qq{
63            SELECT messages.message, messages.date AS date, lists.name AS list
64            FROM queue
65            JOIN messages on message_id = messages.id
66            JOIN lists on list_id = lists.id
67    } );
68    
69    
70    =item --list[=list_name]
71    
72    List all available lists and users on them.
73    
74    Optional value is name of list. With it, this option will produce just users
75    on that list.
76    
77  if ($list_opt) {  =cut
78          foreach my $list ($lists->retrieve_all) {  
79    if (defined($list_opt)) {
80            my @lists;
81            if ($list_opt ne '') {
82                    @lists = $lists->search( name=> $list_opt )->first || die "can't find list $list_opt";
83            } else {
84                    @lists = $lists->retrieve_all;
85            }
86    
87            foreach my $list (@lists) {
88                  print $list->name,"\n";                  print $list->name,"\n";
89                  foreach my $user_on_list ($user_list->search(list_id => $list->id)) {                  foreach my $user_on_list ($user_list->search(list_id => $list->id)) {
90                          my $user = $users->retrieve( id => $user_on_list->user_id );                          my $user = $users->retrieve( id => $user_on_list->user_id );
91                          print "\t",$user->full_name," <", $user->email, ">\n";                          print "\t",$user->full_name," <", $user->email, ">\n";
92                  }                  }
93          }          }
94    
95    =item --add=list_name
96    
97    Add users to list. Users are stored in file (which can be supplied as
98    argument) or read from C<STDIN>. List should be in following format:
99    
100     email@example.com      Optional full name of person
101     dpavlin@rot13.org      Dobrica Pavlinusic
102    
103    =cut
104    
105  } elsif ($add_opt) {  } elsif ($add_opt) {
106          #my $noticer = $loader->find_class('Noticer') || die "can't find my class!";          #my $noticer = $loader->find_class('Noticer') || die "can't find my class!";
107          my $list = $lists->find_or_create({          my $list = $lists->find_or_create({
# Line 60  if ($list_opt) { Line 114  if ($list_opt) {
114                  chomp;                  chomp;
115                  next if (/^#/ || /^\s*$/);                  next if (/^#/ || /^\s*$/);
116                  my ($email, $name) = split(/\s+/,$_, 2);                  my ($email, $name) = split(/\s+/,$_, 2);
117                    $name ||= '';
118                    if (! Email::Valid->address($email)) {
119                            print "SKIPPING $name <$email>\n";
120                            next;
121                    }
122                  print "# $name <$email>\n";                  print "# $name <$email>\n";
123                  my $this_user = $users->find_or_create({                  my $this_user = $users->find_or_create({
124                          email => $email,                          email => $email,
# Line 79  if ($list_opt) { Line 138  if ($list_opt) {
138    
139          print "list ",$list->name," has $added users\n";          print "list ",$list->name," has $added users\n";
140    
141  } elsif ($queue_opt) {  =item --queue[=list_name]
142          my $this_list = $lists->search(  
143                  name => $queue_opt,  Queue message for later delivery. Message can be read from file (specified as
144          )->first || die "can't find list $queue_opt";  argument) or read from C<STDIN>.
145    
146    This option without optional parametar will display pending queue. If you
147    add C<--verbose> flag, it will display all messages in queue.
148    
149    =cut
150    
151    } elsif (defined($queue_opt)) {
152    
153            if ($queue_opt ne '') {
154                    # add message to list queue
155    
156                    my $this_list = $lists->search(
157                            name => $queue_opt,
158                    )->first || die "can't find list $queue_opt";
159    
160                    my $message_text;
161                    while(<>) {
162                            $message_text .= $_;
163                    }
164    
165                    die "no message" unless ($message_text);
166    
167                    my $this_message = $messages->find_or_create({
168                            message => $message_text
169                    }) || die "can't insert message";
170    
171                    $this_message->dbi_commit() || die "can't add message";
172    
173                    $queue->find_or_create({
174                            message_id => $this_message->id,
175                            list_id => $this_list->id,
176                    }) || die "can't add message ",$this_message->id," to list ",$this_list->id, ": ",$this_list->name;
177    
178                    $queue->dbi_commit || die "can't add message to list ",$this_list->name;
179    
180                    print "added message ",$this_message->id, " to list ",$this_list->name,"\n";
181    
182            } else {
183                    # list messages in queue        
184    
185                    foreach my $m ($queue->retrieve_all) {
186                            next if ($m->all_sent && ! $verbose);
187    
188                            my $l = $m->all_sent ? 'S' : 'Q';
189    
190                            my $date = $m->message_id->date;
191                            $date =~ s/\..+$//;
192                            my $msg = $m->message_id->message;
193                            $msg =~ s/\s+/ /gs;
194    
195                            $l .= sprintf(" %-10s %15s : ", $m->list_id->name, $date);
196                            $l .= substr($msg, 0, 79 - length($l));
197    
198                            print "$l\n";
199                    }
200    
         my $message_text;  
         while(<>) {  
                 $message_text .= $_;  
201          }          }
202    
203          die "no message" unless ($message_text);  =item --send[=list_name]
204    
205          my $this_message = $messages->find_or_create({  Send e-mails waiting in queue, or with optional argument, just send messages
206                  message => $message_text  for single list.
         }) || die "can't insert message";  
207    
208          $this_message->dbi_commit();  =cut
209    
210    } elsif (defined($send_opt)) {
211    
212            my $my_q;
213            if ($send_opt ne '') {
214                    my $l_id = $lists->search_like( name => $send_opt )->first ||
215                            die "can't find list $send_opt";
216                    $my_q = $queue->search_like( list_id => $l_id ) ||
217                            die "can't find list $send_opt";
218            } else {
219                    $my_q = $queue->retrieve_all;
220            }
221    
222          $message_list->find_or_create({          while (my $m = $my_q->next) {
223                  message_id => $this_message->id,                  next if ($m->all_sent);
                 list_id => $this_list->id,  
         }) || die "can't add message ",$this_message->id," to list ",$this_list->id, ": ",$this_list->name;  
224    
225          print "added message ",$this_message->id, " to list ",$this_list->name,"\n";                  print "sending message ",$m->message_id," enqueued on ",$m->date," to list ",$m->list_id->name,"\n";
226                    my $msg = $m->message_id->message;
227    
228                    foreach my $u ($user_list->search(list_id => $m->list_id)) {
229    
230                            my $hdr = "To: ".$u->user_id->full_name." <". $u->user_id->email. ">\n";
231    
232                            if ($sent->search( message_id => $m->message_id, user_id => $u->user_id )) {
233                                    print "SKIP ",$u->user_id->email," message allready sent\n";
234                            } else {
235                                    print "\t",$u->user_id->email,"\n";
236                                    send IO => "$hdr\n$msg";
237                                    $sent->create({
238                                            message_id => $m->message_id,
239                                            user_id => $u->user_id,
240                                    });
241                                    $sent->dbi_commit;
242                            }
243                    }
244                    $m->all_sent(1);
245                    $m->update;
246                    $m->dbi_commit;
247            }
248    
249  } else  {  } else  {
250          die $0.'          die "see perldoc $0 for help";
         --list                          show all lists and users  
         --add=name_of_list < users.txt  add users (email@example.com full name)  
         --queue=name_of_list < message  queue message for sending to list  
         --debug  
 ';  
251  }  }
252    
253    =back
254    
255    
256    
257    =head2 Helper options
258    
259    =over 20
260    
261    =item --debug
262    
263    Turn on debugging output from C<Class::DBI>
264    
265    =item --verbose
266    
267    Dump more info on screen.
268    
269    =back
270    
271    
272    
273    =head1 AUTHOR
274    
275    Dobrica Pavlinusic <dpavlin@rot13.org>
276    
277    =cut
278    
Legend:
Removed from v.6  
changed lines
  Added in v.16
  ViewVC Help
Powered by ViewVC 1.1.26