--- trunk/sender.pl	2005/05/15 14:20:08	14
+++ trunk/sender.pl	2005/05/15 16:25:01	15
@@ -18,17 +18,14 @@
  sender.pl --queue[=mylist message.txt]
  sender.pl --send=mylist
 
-=head2 All options
+=head2 Command options
 
 =over 20
 
-=item --debug
-
-Turn on debugging output from C<Class::DBI>
-
 =cut
 
 my $debug = 0;
+my $verbose = 0;
 my $list_opt;
 my $add_opt;
 my $queue_opt;
@@ -40,6 +37,7 @@
 	"queue:s" => \$queue_opt,
 	"send:s" => \$send_opt,
 	"debug"	=> \$debug,
+	"verbose" => \$verbose,
 );
 
 
@@ -59,9 +57,10 @@
 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
@@ -115,6 +114,7 @@
 		chomp;
 		next if (/^#/ || /^\s*$/);
 		my ($email, $name) = split(/\s+/,$_, 2);
+		$name ||= '';
 		if (! Email::Valid->address($email)) {
 			print "SKIPPING $name <$email>\n";
 			next;
@@ -182,9 +182,18 @@
 		# list messages in queue	
 
 		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;
+			next if ($m->all_sent && ! $verbose);
+
+			my $l = $m->all_sent ? 'S' : 'Q';
+
+			my $date = $m->message_id->date;
+			$date =~ s/\..+$//;
+			my $msg = $m->message_id->message;
+			$msg =~ s/\s+/ /gs;
+
+			$l .= sprintf(" %-10s %15s : ", $m->list_id->name, $date);
+			$l .= substr($msg, 0, 79 - length($l));
+
 			print "$l\n";
 		}
 
@@ -199,15 +208,41 @@
 
 } elsif (defined($send_opt)) {
 
-
-	die "send option not yet implemented";
-
-	my @q;
+	my $my_q;
 	if ($send_opt ne '') {
-#		@q => $queue->search( name => 'foo' );
+		my $l_id = $lists->search_like( name => $send_opt )->first ||
+			die "can't find list $send_opt";
+		$my_q = $queue->search_like( list_id => $l_id ) ||
+			die "can't find list $send_opt";
+	} else {
+		$my_q = $queue->retrieve_all;
 	}
-	foreach my $q (@q) {
-		
+
+	while (my $m = $my_q->next) {
+		next if ($m->all_sent);
+
+		print "sending message ",$m->message_id," enqueued on ",$m->date," to list ",$m->list_id->name,"\n";
+		my $msg = $m->message_id->message;
+
+		foreach my $u ($user_list->search(list_id => $m->list_id)) {
+
+			my $hdr = "To: ".$u->user_id->full_name." <". $u->user_id->email. ">\n";
+
+			if ($sent->search( message_id => $m->message_id, user_id => $u->user_id )) {
+				print "SKIP ",$u->user_id->email," message allready sent\n";
+			} else {
+				print "\t",$u->user_id->email,"\n";
+				send IO => "$hdr\n$msg";
+				$sent->create({
+					message_id => $m->message_id,
+					user_id => $u->user_id,
+				});
+				$sent->dbi_commit;
+			}
+		}
+		$m->all_sent(1);
+		$m->update;
+		$m->dbi_commit;
 	}
 
 } else  {
@@ -216,6 +251,24 @@
 
 =back
 
+
+
+=head2 Helper options
+
+=over 20
+
+=item --debug
+
+Turn on debugging output from C<Class::DBI>
+
+=item --verbose
+
+Dump more info on screen.
+
+=back
+
+
+
 =head1 AUTHOR
 
 Dobrica Pavlinusic <dpavlin@rot13.org>