X-Git-Url: http://git.jankratochvil.net/?p=PerlMail.git;a=blobdiff_plain;f=perlmail-submit;h=d01bc39860cdd09c91475063fd8bb6ec2c60e6dd;hp=9976014a21c711fba026b0dd4978a9d5e2c65990;hb=65c28e49c04b12b3b29d6bafb13e1c5fa19082a1;hpb=02d67bd115b03e0cc7e9e76a2362050909fce6e0 diff --git a/perlmail-submit b/perlmail-submit index 9976014..d01bc39 100755 --- a/perlmail-submit +++ b/perlmail-submit @@ -1,12 +1,34 @@ #! /usr/bin/perl -# +# # $Id$ +# Copyright (C) 2002-2003 Jan Kratochvil +# +# This program is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation; either version 2 of the License, or +# (at your option) any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + use vars qw($VERSION); $VERSION=do { my @r=(q$Revision$=~/\d+/g); sprintf "%d.".("%03d"x$#r),@r; }; use strict; use warnings; +use File::Basename; +BEGIN { + use lib $ENV{"PERLMAIL_BASEDIR"} || File::Basename::dirname($0); + use PerlMail::Config; + } + use Getopt::Long; use DBI; use Carp qw(cluck confess); @@ -16,32 +38,31 @@ use POSIX qw(mktime); use Fcntl qw(:flock); -my $Lock_pathname="/tmp/LaceMail.lock"; -my $PeerAddr="dejhome.dyn.jankratochvil.net.:852"; -my $Socket_timeout=600; # 15sec is NOT enough! -my $DB_table="LaceMail_folder"; -my $DBI_database="short"; -my $DBI_user="short"; -my $DBI_pwd=$ENV{"HOME"}."/priv/mysql.".$DBI_user.".pwd"; open DBI_PWD,$DBI_pwd or die "open \"$DBI_pwd\": $!"; $DBI_pwd=; close DBI_PWD or warn "close DBI_pwd: $!"; chomp $DBI_pwd; -my $DBI=DBI->connect_cached("DBI:mysql:database=$DBI_database;host=","$DBI_user",$DBI_pwd,{ +my $DBI; +sub DBI +{ + return $DBI if $DBI; + $DBI=DBI->connect("DBI:mysql:database=$DBI_database;host=","$DBI_user",$DBI_pwd,{ "PrintError"=>0, # handled by "RaiseError" below "RaiseError"=>1, "ShowErrorStatement"=>1, "AutoCommit"=>1, }) or confess "Failed DBI->connect(): $!"; + return $DBI; +} # $name,@$cols sub create_table { my($name,$cols)=@_; - eval { $DBI->do("drop table $name"); }; - $DBI->do("create table $name (".join(",",@$cols).")"); + eval { DBI()->do("drop table $name"); }; + DBI()->do("create table $name (".join(",",@$cols).")"); } sub initdb @@ -53,7 +74,7 @@ sub initdb "retries int null default 0", # null=>done, 0=not yet tried to submit ], ); - $DBI->do("alter table $DB_table add index (retries,id)"); + DBI()->do("alter table $DB_table add index (retries,id)"); print "done.\n"; exit 0; } @@ -65,16 +86,26 @@ sub store local $/; $message=; } + close STDIN or cluck "close STDIN: $!"; my %row=( "message"=>$message, # assume "retries"=>0, ); - my $prep=$DBI->prepare_cached("insert into $DB_table (".join(",",keys(%row)).")" + my $prep=DBI()->prepare("insert into $DB_table (".join(",",keys(%row)).")" ." values (".join(",",map("?",keys(%row))).")"); $prep->execute(values(%row)); print $prep->{"mysql_insertid"}."\n"; } +sub forkoff +{ + my $pid=fork(); + confess if !defined $pid; + $DBI=undef(); # Prevent: Server has gone away + exit 0 if $pid; # parent + # child +} + my $submitonce_run=0; sub submitonce { @@ -86,7 +117,7 @@ sub submitonce print "LOCKED\n"; exit 0; } - my $sth=$DBI->prepare("select id,message from $DB_table where retries is not null" + my $sth=DBI()->prepare("select id,message from $DB_table where retries is not null" # process only non-problematic mails during rerun .($submitonce_run==1 ? "" : " and retries=0") ." order by retries asc,id asc"); @@ -95,7 +126,7 @@ sub submitonce autoflush STDOUT 1; my $sock; while (my $row=$sth->fetchrow_hashref()) { - $DBI->do("update $DB_table set retries=retries+1 where id=".$row->{"id"}); + DBI()->do("update $DB_table set retries=retries+1 where id=".$row->{"id"}); if (!$sock) { $sock=IO::Socket::INET->new( "PeerAddr"=>$PeerAddr, @@ -116,7 +147,7 @@ sub submitonce undef $sock; } else { - $DBI->do("update $DB_table set retries=null where id=".$row->{"id"}); + DBI()->do("update $DB_table set retries=null where id=".$row->{"id"}); } print $progresschar.$row->{"id"}.($got eq "1" ? "" : "=FAIL"); $progresschar=","; @@ -138,22 +169,74 @@ sub submit 1 while submitonce(); } -sub pending +sub print_messages { - my $sth=$DBI->prepare("select message from $DB_table where retries is not null order by id"); +my($cond)=@_; + + my $sth=DBI()->prepare("select message from $DB_table $cond order by id"); $sth->execute(); while (my $row=$sth->fetchrow_hashref()) { print $row->{"message"},"\n"; } } +sub pending +{ + print_messages("where retries is not null"); +} + +sub dump +{ + print_messages(""); +} + +sub clean +{ +my($keyword,$interval)=@_; + + # FIXME: SQL "now()" is raced against the block above + my $sth=DBI()->prepare("select id,time,retries from $DB_table where time>now()"); + $sth->execute(); + while (my $row=$sth->fetchrow_hashref()) { + warn "Message time in future: ".join(",",map( + "$_=".(!defined $row->{$_} ? "NULL" : $row->{$_}) + ,keys(%$row))); + } + + return if $interval eq ""; + local $_=$interval; + my $print=s/^print://; + s/(\d+)y/($1*12)."m"/ge; + s/(\d+)m/($1*30)."d"/ge; + s/(\d+)d/($1*24)."h"/ge; + s/(\d+)h/($1*60)."M"/ge; + s/(\d+)M/($1*60)."s"/ge; + my $sec=0; + $sec+=$1 while s/(\d+)s//g; + die "Interval parse error; left \"$_\", parsed: $interval" if $_ ne ""; + $sth=DBI()->prepare(($print ? "select id" : "delete") + ." from $DB_table where retries is null and timeexecute(); + if (!$print) { + print $sth->rows()."\n"; + } + else { + while (my $row=$sth->fetchrow_hashref()) { + print $row->{"id"},"\n"; + } + } +} + $Getopt::Long::ignorecase=0; die if !GetOptions( "initdb" ,\&initdb, "store" ,\&store, + "forkoff",\&forkoff, "submit" ,\&submit, "pending",\&pending, - "V|version",sub { print "lacemail-submit: $VERSION\n"; exit 0; }, + "dump" ,\&dump, + "clean:s",\&clean, + "V|version",sub { print "perlmail-submit: $VERSION\n"; exit 0; }, ); exit 0;