You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
139 lines
3.5 KiB
Perl
139 lines
3.5 KiB
Perl
#!/usr/bin/perl
|
|
|
|
use DBI;
|
|
use MIME::Base64;
|
|
# use Data::Dumper;
|
|
use File::Temp qw/ mkstemp /;
|
|
use Sys::Syslog;
|
|
# require liblockfile-simple-perl
|
|
use LockFile::Simple qw(lock trylock unlock);
|
|
|
|
######################################################################
|
|
########## Change the following variables to fit your needs ##########
|
|
|
|
# database settings
|
|
|
|
# database backend - uncomment one of these
|
|
our $db_type = 'Pg';
|
|
#my $db_type = 'mysql';
|
|
|
|
# host name
|
|
our $db_host="127.0.0.1";
|
|
# database name
|
|
our $db_name="postfix";
|
|
# database username
|
|
our $db_username="mail";
|
|
# database password
|
|
our $db_password="CHANGE_ME!";
|
|
|
|
# instead of changing this script, you can put your settings to /etc/mail/postfixadmin/fetchmail.conf
|
|
# just use perl syntax there to fill the variables listed above (without the "our" keyword). Example:
|
|
# $db_username = 'mail';
|
|
if (-f "/etc/mail/postfixadmin/fetchmail.conf") {
|
|
require "/etc/mail/postfixadmin/fetchmail.conf";
|
|
}
|
|
|
|
|
|
#################### Don't change anything below! ####################
|
|
######################################################################
|
|
|
|
openlog("fetchmail-all", "pid", "mail");
|
|
|
|
sub log_and_die {
|
|
my($message) = @_;
|
|
syslog("err", $message);
|
|
die $message;
|
|
}
|
|
|
|
# read options and arguments
|
|
|
|
$configfile = "/etc/fetchmail-all/config";
|
|
|
|
@ARGS1 = @ARGV;
|
|
|
|
while ($_ = shift @ARGS1) {
|
|
if (/^-/) {
|
|
if (/^--config$/) {
|
|
$configfile = shift @ARGS1
|
|
}
|
|
}
|
|
}
|
|
|
|
$run_dir="/var/run/fetchmail";
|
|
|
|
# use specified config file
|
|
if (-e $configfile) {
|
|
do $configfile;
|
|
}
|
|
|
|
if($db_type eq "Pg" || $db_type eq "mysql") {
|
|
$dsn = "DBI:$db_type:database=$db_name;host=$db_host";
|
|
} else {
|
|
log_and_die "unsupported db_type $db_type";
|
|
}
|
|
|
|
$lock_file=$run_dir . "/fetchmail-all.lock";
|
|
|
|
$lockmgr = LockFile::Simple->make(-autoclean => 1, -max => 1);
|
|
$lockmgr->lock($lock_file) || log_and_die "can't lock ${lock_file}";
|
|
|
|
# database connect
|
|
$dbh = DBI->connect($dsn, $db_username, $db_password) || log_and_die "cannot connect the database";
|
|
|
|
if($db_type eq "Pg") {
|
|
$sql_cond = "date_part('epoch',now())-date_part('epoch',date)";
|
|
} elsif($db_type eq "mysql") {
|
|
$sql_cond = "unix_timestamp(now())-unix_timestamp(date)";
|
|
}
|
|
|
|
$sql = "
|
|
SELECT id,mailbox,src_server,src_auth,src_user,src_password,src_folder,fetchall,keep,protocol,mda,extra_options,usessl
|
|
FROM fetchmail
|
|
WHERE $sql_cond > poll_time*60
|
|
";
|
|
|
|
my (%config);
|
|
map{
|
|
my ($id,$mailbox,$src_server,$src_auth,$src_user,$src_password,$src_folder,$fetchall,$keep,$protocol,$mda,$extra_options,$usessl)=@$_;
|
|
|
|
syslog("info","fetch ${src_user}@${src_server} for ${mailbox}");
|
|
|
|
$cmd="user '${src_user}' there with password '".decode_base64($src_password)."'";
|
|
$cmd.=" folder '${src_folder}'" if ($src_folder);
|
|
$cmd.=" mda ".$mda if ($mda);
|
|
|
|
# $cmd.=" mda \"/usr/local/libexec/dovecot/deliver -m ${mailbox}\"";
|
|
$cmd.=" is '${mailbox}' here";
|
|
|
|
$cmd.=" keep" if ($keep);
|
|
$cmd.=" fetchall" if ($fetchall);
|
|
$cmd.=" ssl" if ($usessl);
|
|
$cmd.=" ".$extra_options if ($extra_options);
|
|
|
|
$text=<<TXT;
|
|
set postmaster "postmaster"
|
|
set nobouncemail
|
|
set no spambounce
|
|
set properties ""
|
|
set syslog
|
|
|
|
poll ${src_server} with proto ${protocol}
|
|
$cmd
|
|
|
|
TXT
|
|
|
|
($file_handler, $filename) = mkstemp( "/tmp/fetchmail-all-XXXXX" ) or log_and_die "cannot open/create fetchmail temp file";
|
|
print $file_handler $text;
|
|
close $file_handler;
|
|
|
|
$ret=`/usr/bin/fetchmail -f $filename -i $run_dir/fetchmail.pid`;
|
|
|
|
unlink $filename;
|
|
|
|
$sql="UPDATE fetchmail SET returned_text=".$dbh->quote($ret).", date=now() WHERE id=".$id;
|
|
$dbh->do($sql);
|
|
}@{$dbh->selectall_arrayref($sql)};
|
|
|
|
$lockmgr->unlock($lock_file);
|
|
closelog();
|