--- trunk/sender.pl 2005/05/15 14:20:08 14 +++ trunk/sender.pl 2005/05/16 22:32:58 32 @@ -1,11 +1,9 @@ #!/usr/bin/perl -w use strict; -use Class::DBI::Loader::Pg; +use blib; +use Nos; use Getopt::Long; -use Mail::CheckUser qw(check_email); -use Email::Valid; -use Email::Send; =head1 NAME @@ -13,60 +11,85 @@ =head1 SYNOPSYS + sender.pl --new=mylist sender.pl --add=mylist members.txt sender.pl --list[=mylist] sender.pl --queue[=mylist message.txt] sender.pl --send=mylist -=head2 All options +In C something like: -=over 20 + mylist: "| /path/to/sender.pl --inbox=mylist" -=item --debug +=head2 Command options -Turn on debugging output from C +=over 20 =cut my $debug = 0; -my $list_opt; -my $add_opt; -my $queue_opt; -my $send_opt; +my $verbose = 0; +my $opt; my $result = GetOptions( - "list:s" => \$list_opt, - "add=s" => \$add_opt, - "queue:s" => \$queue_opt, - "send:s" => \$send_opt, + "new=s" => \$opt->{'new'}, + "list:s" => \$opt->{'list'}, + "add=s" => \$opt->{'add'}, + "queue:s" => \$opt->{'queue'}, + "send:s" => \$opt->{'send'}, + "inbox=s" => \$opt->{'inbox'}, "debug" => \$debug, + "verbose" => \$verbose, + "email=s" => \$opt->{'email'}, ); - -my $loader = Class::DBI::Loader::Pg->new( - debug => $debug, - dsn => "dbi:Pg:dbname=notices", - user => "dpavlin", - password => "", - namespace => "Noticer", -# additional_classes => qw/Class::DBI::AbstractSearch/, -# additional_base_classes => qw/My::Stuff/, - relationships => 1, +my $nos = new Nos( + dsn => 'dbi:Pg:dbname=notices', + user => 'dpavlin', + passwd => '', + debug => $debug, + verbose => $verbose, ); +my $loader = $nos->{'loader'} || die "can't find loader?"; + my $lists = $loader->find_class('lists'); my $users = $loader->find_class('users'); my $user_list = $loader->find_class('user_list'); my $messages = $loader->find_class('messages'); my $queue = $loader->find_class('queue'); +my $sent = $loader->find_class('sent'); $queue->set_sql( list_queue => qq{ - SELECT messages.message, messages.date AS message_date, lists.name AS list + SELECT messages.message, messages.date AS date, lists.name AS list FROM queue JOIN messages on message_id = messages.id JOIN lists on list_id = lists.id } ); +my $list_name; + + +=item --new=list_name my-list@example.com + +Adds new list. You can also feed list name as first line to C. + +=cut + +if ($list_name = $opt->{'new'}) { + + my $email = shift @ARGV || <>; + chomp($email); + + die "need e-mail address for list (as argument or on STDIN)\n" unless ($email); + + my $l = $nos->_get_list($list_name) || $nos->_add_list( + list => $list_name, + email => $email, + ) || die "can't add list $list_name\n"; + + print "added list $list_name with ID ",$l->id,"\n"; + =item --list[=list_name] @@ -77,22 +100,25 @@ =cut -if (defined($list_opt)) { +} elsif (defined($list_name = $opt->{'list'})) { + my @lists; - if ($list_opt ne '') { - @lists = $lists->search( name=> $list_opt )->first || die "can't find list $list_opt"; + + if ($list_name ne '') { + @lists = $lists->search( name=> $list_name )->first || die "can't find list $list_name"; } else { @lists = $lists->retrieve_all; } foreach my $list (@lists) { - print $list->name,"\n"; + print $list->name," <",$list->email,">\n"; foreach my $user_on_list ($user_list->search(list_id => $list->id)) { my $user = $users->retrieve( id => $user_on_list->user_id ); print "\t",$user->full_name," <", $user->email, ">\n"; } } + =item --add=list_name Add users to list. Users are stored in file (which can be supplied as @@ -101,13 +127,16 @@ email@example.com Optional full name of person dpavlin@rot13.org Dobrica Pavlinusic +You may use C<--email> parametar at any time to set From: e-mail address for list. +B. + =cut -} elsif ($add_opt) { - #my $noticer = $loader->find_class('Noticer') || die "can't find my class!"; +} elsif ($list_name = $opt->{'add'}) { + my $list = $lists->find_or_create({ - name => $add_opt, - }) || die "can't add list $add_opt\n"; + name => $list_name, + }) || die "can't add list $list_name\n"; my $added = 0; @@ -115,107 +144,111 @@ chomp; next if (/^#/ || /^\s*$/); my ($email, $name) = split(/\s+/,$_, 2); - if (! Email::Valid->address($email)) { - print "SKIPPING $name <$email>\n"; - next; - } - print "# $name <$email>\n"; - my $this_user = $users->find_or_create({ - email => $email, - full_name => $name, - }) || die "can't find or create member\n"; - my $user_on_list = $user_list->find_or_create({ - user_id => $this_user->id, - list_id => $list->id, - }) || die "can't add user to list"; - $added++; - } - - foreach my $c_name ($loader->tables) { - my $c = $loader->find_class($c_name)|| die "can't find $c_name"; - $c->dbi_commit(); + $added++ if ($nos->add_member_to_list( email => $email, name => $name, list => $list_name )); } print "list ",$list->name," has $added users\n"; + =item --queue[=list_name] Queue message for later delivery. Message can be read from file (specified as argument) or read from C. -This options without optional parametars it will display current queue. +This option without optional parametar will display pending queue. If you +add C<--verbose> flag, it will display all messages in queue. =cut -} elsif (defined($queue_opt)) { +} elsif (defined($list_name = $opt->{'queue'})) { - if ($queue_opt ne '') { + if ($list_name ne '') { # add message to list queue - my $this_list = $lists->search( - name => $queue_opt, - )->first || die "can't find list $queue_opt"; - my $message_text; while(<>) { $message_text .= $_; } - die "no message" unless ($message_text); + my $id = $nos->add_message_to_list( + list => $list_name, + message => $message_text, + ) || die "can't add message to list $list_name\n"; - my $this_message = $messages->find_or_create({ - message => $message_text - }) || die "can't insert message"; + print "added message $id to list $list_name\n"; - $this_message->dbi_commit() || die "can't add message"; + } else { + # list messages in queue - $queue->find_or_create({ - message_id => $this_message->id, - list_id => $this_list->id, - }) || die "can't add message ",$this_message->id," to list ",$this_list->id, ": ",$this_list->name; + foreach my $m ($queue->retrieve_all) { + next if ($m->all_sent && ! $verbose); - $queue->dbi_commit || die "can't add message to list ",$this_list->name; + my $l = $m->all_sent ? 'S' : 'Q'; - print "added message ",$this_message->id, " to list ",$this_list->name,"\n"; + my $date = $m->message_id->date; + $date =~ s/\..+$//; + my $msg = $m->message_id->message; + $msg =~ s/\s+/ /gs; - } else { - # list messages in queue + $l .= sprintf(" %-10s %15s : ", $m->list_id->name, $date); + $l .= substr($msg, 0, 79 - length($l)); - foreach my $m ($queue->retrieve_all) { - my $l = sprintf("%-10s %15s : ", $m->list_id->name, $m->message_id->date); - $l .= substr($m->message_id->message, 0, 79 - length($l)); - $l =~ s/[\n\r]/ /gs; print "$l\n"; } } + =item --send[=list_name] -Send e-mail waiting in queue for all lists, or with optional argument for -just single list. +Send e-mails waiting in queue, or with optional argument, just send messages +for single list. =cut -} elsif (defined($send_opt)) { +} elsif (defined($list_name = $opt->{'send'})) { + $nos->send_queued_messages($list_name); - die "send option not yet implemented"; - my @q; - if ($send_opt ne '') { -# @q => $queue->search( name => 'foo' ); - } - foreach my $q (@q) { - - } +=item --inbox=list_name + +Feed incomming message back into notice sender. + +=cut + +} elsif ($opt->{'inbox'}) { + + warn "inbox option is not implemented"; } else { - die "see perldoc $0 for help"; + die "see perldoc $0 for help\n"; } =back + + +=head2 Helper options + +=over 20 + +=item --debug + +Turn on debugging output from C + +=item --verbose + +Dump more info on screen. + +=item --email + +Used to specify e-mail address where needed. + +=back + + + =head1 AUTHOR Dobrica Pavlinusic