$config{'fetchmail_path'}"),"\n";
&ui_print_footer("/", $text{'index'});
exit;
}
@conf = &parse_config_file($fetchmail_config);
@conf = grep { $_->{'poll'} } @conf;
&show_polls(\@conf, $fetchmail_config, $remote_user_info[0]);
if (@conf) {
# Show the fetchmail daemon form
print "
\n";
print "\n";
if (&foreign_check("cron")) {
# Show button to manage cron job
print "\n";
}
print "| \n";
foreach $pf ("$remote_user_info[7]/.fetchmail.pid",
"$remote_user_info[7]/.fetchmail") {
if (open(PID, $pf) && ($line=) &&
(($pid,$interval) = split(/\s+/, $line)) && $pid &&
kill(0, $pid)) {
$running = $pf;
last;
}
}
if ($running) {
# daemon is running - offer to stop it
print " | \n";
print "",&text('index_stopmsg', $interval)," | \n";
}
else {
# daemon isn't running - offer to start it
print "
\n";
}
&ui_print_footer("/", $text{'index'});
# show_polls(&polls, file, user)
sub show_polls
{
print "\n";
print " | $text{'index_poll'} | ",
"$text{'index_active'} | ",
"$text{'index_proto'} | ",
"$text{'index_users'} |
\n" if (@{$_[0]});
foreach $p (@{$_[0]}) {
print "\n";
print "| ",&html_escape($p->{'poll'}),
" | \n";
print "",$p->{'skip'} ? "$text{'no'}"
: $text{'yes'}," | \n";
print "",$p->{'proto'} ? &html_escape(uc($p->{'proto'}))
: $text{'default'}," | \n";
print "\n";
foreach $u (@{$p->{'users'}}) {
printf "%s -> %s
\n",
&html_escape($u->{'user'}),
&html_escape(@{$u->{'is'}} ? join(" ", @{$u->{'is'}})
: $_[2]);
}
print " |
\n";
}
print "
\n";
if (!@{$_[0]}) {
print "$text{'index_noservers'}\n";
}
print "$text{'index_add'}\n";
print " \n";
print "$text{'index_global'}\n";
print " \n";
if (@{$_[0]}) {
print "$text{'index_run'}\n";
}
print "
\n";
}
fetchmail/fetchmail-lib.pl 0100664 0005671 0000012 00000017707 10232571017 015544 0 ustar jcameron wheel # fetchmail-lib.pl
# Functions for parsing fetchmail config files
do '../web-lib.pl';
&init_config();
%access = &get_module_acl();
do '../ui-lib.pl';
if ($module_info{'usermin'}) {
if ($no_switch_user) {
@remote_user_info = getpwnam($remote_user);
}
else {
&switch_to_remote_user();
&create_user_config_dirs();
}
$cron_cmd = "$user_module_config_directory/check.pl";
$cron_user = $remote_user;
$fetchmail_config = "$remote_user_info[7]/.fetchmailrc";
}
else {
$cron_cmd = "$module_config_directory/check.pl";
$cron_user = "root";
$fetchmail_config = $config{'config_file'};
}
# parse_config_file(file, [&global])
# Parses a fetchmail config file into a list of hashes, each representing
# one mail server to poll
sub parse_config_file
{
local $lnum = 0;
local ($line, @rv, @toks);
# Tokenize the file
open(FILE, $_[0]);
while($line = ) {
$line =~ s/\r|\n//g;
$line =~ s/^\s*#.*$//;
while($line =~ /^[\s:;,]*"([^"]*)"(.*)$/ ||
$line =~ /^[\s:;,]*'([^"]*)'(.*)$/ ||
$line =~ /^[\s:;,]*([^\s:;,]+)(.*)$/) {
push(@toks, [ $1, $lnum ]);
$line = $2;
}
$lnum++;
}
close(FILE);
# Split into poll sections
@toks = grep { $_->[0] !~ /^(and|with|has|wants|options|here)$/i } @toks;
local ($poll, $user, $i);
for($i=0; $i<@toks; $i++) {
local $t = $toks[$i];
# Server options
if ($t->[0] eq 'poll' || $t->[0] eq 'server' ||
$t->[0] eq 'skip' || $t->[0] eq 'defaults') {
# Start of a new poll
$poll = { 'line' => $t->[1],
'file' => $_[0],
'index' => scalar(@rv),
'skip' => ($t->[0] eq 'skip'),
'defaults' => ($t->[0] eq 'defaults') };
$poll->{'poll'} = $toks[++$i]->[0] if (!$poll->{'defaults'});
undef($user);
push(@rv, $poll);
}
elsif ($t->[0] eq 'proto' || $t->[0] eq 'protocol') {
$poll->{'proto'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'via') {
$poll->{'via'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'port') {
$poll->{'port'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'timeout') {
$poll->{'timeout'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'interface') {
$poll->{'interface'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'monitor') {
$poll->{'monitor'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'auth' || $t->[0] eq 'authenticate') {
$poll->{'auth'} = $toks[++$i]->[0];
}
# User options
elsif ($t->[0] eq 'user' || $t->[0] eq 'username') {
$user = { 'user' => $toks[++$i]->[0] };
push(@{$poll->{'users'}}, $user);
}
elsif ($t->[0] eq 'pass' || $t->[0] eq 'password') {
$user->{'pass'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'is' || $t->[0] eq 'to') {
$i++;
while($i < @toks &&
$toks[$i]->[1] == $t->[1]) {
push(@{$user->{'is'}}, $toks[$i]->[0]);
$i++;
}
$i--;
}
elsif ($t->[0] eq 'folder') {
$user->{'folder'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'keep') { $user->{'keep'} = 1; }
elsif ($t->[0] eq 'nokeep') { $user->{'keep'} = 0; }
elsif ($t->[0] eq 'no' && $toks[$i+1]->[0] eq 'keep') {
$user->{'keep'} = 0;
$i++;
}
elsif ($t->[0] eq 'fetchall') { $user->{'fetchall'} = 1; }
elsif ($t->[0] eq 'nofetchall') { $user->{'fetchall'} = 0; }
elsif ($t->[0] eq 'no' && $toks[$i+1]->[0] eq 'fetchall') {
$user->{'fetchall'} = 0;
$i++;
}
elsif ($t->[0] eq 'ssl') { $user->{'ssl'} = 1; }
elsif ($t->[0] eq 'nossl') { $user->{'ssl'} = 0; }
elsif ($t->[0] eq 'no' && $toks[$i+1]->[0] eq 'ssl') {
$user->{'ssl'} = 0;
$i++;
}
elsif ($t->[0] eq 'preconnect') {
$user->{'preconnect'} = $toks[++$i]->[0];
}
elsif ($t->[0] eq 'postconnect') {
$user->{'postconnect'} = $toks[++$i]->[0];
}
else {
# Found an unknown option!
if ($user) {
push(@{$user->{'unknown'}}, $t->[0]);
}
elsif ($poll) {
push(@{$poll->{'unknown'}}, $t->[0]);
}
}
if ($poll) {
if ($i<@toks) {
$poll->{'eline'} = $toks[$i]->[1];
}
else {
$poll->{'eline'} = $toks[$#toks]->[1];
}
}
}
return @rv;
}
# create_poll(&poll, file)
# Add a new poll section to a fetchmail config file
sub create_poll
{
local $lref = &read_file_lines($_[1]);
if ($_[0]->{'defaults'}) {
# Put a new defaults section at the top
splice(@$lref, 0, 0, &poll_lines($_[0]));
}
else {
push(@$lref, &poll_lines($_[0]));
}
&flush_file_lines();
}
# delete_poll(&poll, file)
# Delete a poll section from a fetchmail config file
sub delete_poll
{
local $lref = &read_file_lines($_[1]);
splice(@$lref, $_[0]->{'line'}, $_[0]->{'eline'} - $_[0]->{'line'} + 1);
&flush_file_lines();
}
# modify_poll(&poll, file)
# Modify a poll section in a fetchmail config file
sub modify_poll
{
local $lref = &read_file_lines($_[1]);
splice(@$lref, $_[0]->{'line'}, $_[0]->{'eline'} - $_[0]->{'line'} + 1,
&poll_lines($_[0]));
&flush_file_lines();
}
sub poll_lines
{
local @rv;
if ($_[0]->{'skip'}) {
push(@rv, "skip $_[0]->{'poll'}");
}
elsif ($_[0]->{'defaults'}) {
push(@rv, "defaults $_[0]->{'poll'}");
}
else {
push(@rv, "poll $_[0]->{'poll'}");
}
push(@rv, "\tproto $_[0]->{'proto'}") if ($_[0]->{'proto'});
push(@rv, "\tauth $_[0]->{'auth'}") if ($_[0]->{'auth'});
push(@rv, "\tvia $_[0]->{'via'}") if ($_[0]->{'via'});
push(@rv, "\tport $_[0]->{'port'}") if ($_[0]->{'port'});
push(@rv, "\ttimeout $_[0]->{'timeout'}") if ($_[0]->{'timeout'});
push(@rv, "\tinterface \"$_[0]->{'interface'}\"") if ($_[0]->{'interface'});
push(@rv, "\tmonitor $_[0]->{'monitor'}") if ($_[0]->{'monitor'});
push(@rv, "\t".join(" ", map { /^\S+$/ ? $_ : "\"$_\"" }
@{$_[0]->{'unknown'}})) if (@{$_[0]->{'unknown'}});
foreach $u (@{$_[0]->{'users'}}) {
push(@rv, "\tuser \"$u->{'user'}\"");
push(@rv, "\tpass \"$u->{'pass'}\"") if ($u->{'pass'});
push(@rv, "\tis ".join(" ", @{$u->{'is'}})) if (@{$u->{'is'}});
push(@rv, "\tfolder $u->{'folder'}") if ($u->{'folder'});
push(@rv, "\tkeep") if ($u->{'keep'} eq '1');
push(@rv, "\tnokeep") if ($u->{'keep'} eq '0');
push(@rv, "\tfetchall") if ($u->{'fetchall'} eq '1');
push(@rv, "\tno fetchall") if ($u->{'fetchall'} eq '0');
push(@rv, "\tssl") if ($u->{'ssl'} eq '1');
push(@rv, "\tno ssl") if ($u->{'ssl'} eq '0');
push(@rv, "\tpreconnect \"$u->{'preconnect'}\"")
if ($u->{'preconnect'});
push(@rv, "\tpostconnect \"$u->{'postconnect'}\"")
if ($u->{'postconnect'});
push(@rv, "\t".join(" ", map { /^\S+$/ ? $_ : "\"$_\"" }
@{$u->{'unknown'}})) if (@{$u->{'unknown'}});
}
return @rv;
}
# can_edit_user(user)
sub can_edit_user
{
local %umap;
map { $umap{$_}++; } split(/\s+/, $access{'users'});
if ($access{'mode'} == 1 && !$umap{$_[0]} ||
$access{'mode'} == 2 && $umap{$_[0]}) { return 0; }
elsif ($access{'mode'} == 3) {
return $remote_user eq $_[0];
}
else {
return 1;
}
}
# get_fetchmail_version([&out])
sub get_fetchmail_version
{
local $out = `$config{'fetchmail_path'} -V 2>&1 \n";
print " | $text{'index_poll'} | ",
"$text{'index_active'} | ",
"$text{'index_proto'} | ",
"$text{'index_users'} |
\n" if (@{$_[0]});
foreach $p (@{$_[0]}) {
print "\n";
print "| ",&html_escape($p->{'poll'}),
" | \n";
print "",$p->{'skip'} ? "$text{'no'}"
: $text{'yes'}," | \n";
print "",$p->{'proto'} ? &html_escape(uc($p->{'proto'}))
: $text{'default'}," | \n";
print "\n";
foreach $u (@{$p->{'users'}}) {
printf "%s -> %s
\n",
&html_escape($u->{'user'}),
&html_escape(@{$u->{'is'}} ? join(" ", @{$u->{'is'}})
: $_[2]);
}
print " |
\n";
}
print "\n";
print "$text{'index_add'}\n";
print " \n";
print "$text{'index_global'}\n";
print " \n";
if (@{$_[0]}) {
print "$text{'index_run'}\n";
}
print "\n";
}
1;
fetchmail/edit_poll.cgi 0100775 0005671 0000012 00000016073 10232571401 015141 0 ustar jcameron wheel #!/usr/local/bin/perl
# edit_poll.cgi
# Display one server polled by fetchmail
require './fetchmail-lib.pl';
&ReadParse();
if ($config{'config_file'}) {
$file = $config{'config_file'};
}
else {
&can_edit_user($in{'user'}) || &error($text{'poll_ecannot'});
@uinfo = getpwnam($in{'user'});
$file = "$uinfo[7]/.fetchmailrc";
}
if ($in{'new'}) {
&ui_print_header(undef, $text{'poll_create'}, "");
}
else {
&ui_print_header(undef, $text{'poll_edit'}, "");
@conf = &parse_config_file($file);
$poll = $conf[$in{'idx'}];
}
print "
\n";
&ui_print_footer("", $text{'index_return'});
fetchmail/save_cron.cgi 0100775 0005671 0000012 00000003371 10232442036 015143 0 ustar jcameron wheel #!/usr/local/bin/perl
# save_cron.cgi
# Create, update or delete a cron job for fetchmail
require './fetchmail-lib.pl';
&foreign_require("cron", "cron-lib.pl");
$access{'cron'} || &error($text{'cron_ecannot2'});
&error_setup($text{'cron_err'});
&ReadParse();
@jobs = &cron::list_cron_jobs();
($job) = grep { $_->{'user'} eq $cron_user &&
$_->{'command'} =~ /^$cron_cmd/ } @jobs;
# Validate inputs
$cmd = $cron_cmd;
if ($in{'output'} == 0) {
$cmd .= " --null";
}
elsif ($in{'output'} == 1) {
$in{'file'} =~ /^\/.+$/ || &error($text{'cron_efile'});
$cmd .= " --file ".quotemeta($in{'file'});
}
elsif ($in{'output'} == 2) {
$in{'mail'} =~ /^\S+$/ || &error($text{'cron_efile'});
$cmd .= " --mail ".quotemeta($in{'mail'});
}
elsif ($in{'output'} == 3) {
$cmd .= " --output";
}
elsif ($in{'output'} == 4) {
$cmd .= " --owner";
}
if ($in{'errors'}) {
$cmd .= " --errors";
}
if ($cron_user eq "root" && $fetchmail_config) {
defined(getpwnam($in{'user'})) || &error($text{'cron_euser'});
$cmd .= " --user $in{'user'}";
}
if ($job && $in{'enabled'}) {
# Update cron job
$job->{'command'} = $cmd;
&cron::parse_times_input($job, \%in);
&lock_file(&cron::cron_file($job));
&cron::change_cron_job($job);
$what = "update";
}
elsif (!$job && $in{'enabled'}) {
# Create job
$job = { 'user' => $cron_user,
'command' => $cmd,
'active' => 1 };
&cron::parse_times_input($job, \%in);
&lock_file($cron_cmd);
&cron::create_wrapper($cron_cmd, $module_name, "check.pl");
&lock_file(&cron::cron_file($job));
&cron::create_cron_job($job);
$what = "create";
}
elsif ($job && !$in{'enabled'}) {
# Delete job
&lock_file(&cron::cron_file($job));
&cron::delete_cron_job($job);
$what = "delete";
}
&unlock_all_files();
&webmin_log($what, "cron");
&redirect("");
fetchmail/check.pl 0100775 0005671 0000012 00000004760 10326147054 014123 0 ustar jcameron wheel #!/usr/local/bin/perl
# check.pl
# Run fetchmail, and send the output somewhere
$no_acl_check++;
$ENV{'REMOTE_USER'} = getpwuid($<);
require './fetchmail-lib.pl';
# Parse command-line args
while(@ARGV > 0) {
local $a = shift(@ARGV);
if ($a eq "--mail") {
$mail = shift(@ARGV);
}
elsif ($a eq "--file") {
$file = shift(@ARGV);
}
elsif ($a eq "--output") {
$output = 1;
}
elsif ($a eq "--user") {
$user = shift(@ARGV);
}
elsif ($a eq "--errors") {
$errors = 1;
}
elsif ($a eq "--owner") {
$owner = 1;
}
}
if ($fetchmail_config) {
# Just run once for a single config file
&run_fetchmail($fetchmail_config, $user);
}
else {
# Run for all users
setpwent();
while(@uinfo = getpwent()) {
next if ($donehome{$uinfo[7]}++);
@conf = &parse_config_file("$uinfo[7]/.fetchmailrc");
@conf = grep { $_->{'poll'} } @conf;
if (@conf) {
&run_fetchmail("$uinfo[7]/.fetchmailrc", $uinfo[0]);
}
}
endpwent();
}
# run_fetchmail(config, user)
sub run_fetchmail
{
local ($config, $user) = @_;
# Build the command
local $cmd = "$config{'fetchmail_path'} -v -f ".quotemeta($config);
if ($config{'mda_command'}) {
$cmd .= " -m ".quotemeta($config{'mda_command'});
}
if ($user && $user ne "root") {
$cmd = "su ".quotemeta($user)." -c ".quotemeta($cmd);
}
# Run it
local $out = `($cmd) 2>&1 $file");
print FILE $out;
close(FILE);
}
elsif ($mail) {
# Capture output and email
$mm = $module_info{'usermin'} ? "mailbox" : "mailboxes";
if (&foreign_check($mm)) {
&foreign_require($mm, "$mm-lib.pl");
&foreign_require($mm, "boxes-lib.pl");
if ($module_info{'usermin'}) {
($froms, $doms) =
&foreign_call($mm, "list_from_addresses");
$fr = $froms->[0];
}
else {
$fr = $user."\@".&get_system_hostname();
}
$email = { 'headers' =>
[ [ 'From', $fr ],
[ 'Subject', $?/256 <= 1 ? "Fetchmail output"
: "Fetchmail error"],
[ 'To', $mail ] ],
'attach' => [ { 'headers' => [ [ 'Content-type',
'text/plain' ] ],
'data' => $out } ]
};
&foreign_call($mm, "send_mail", $email);
}
else {
print "$mm module not installed - could not email the following output :\n";
print $out;
}
}
elsif ($output) {
# Output goes to cron
print STDERR $out;
}
else {
# Just throw away output
}
}
fetchmail/CHANGELOG 0100664 0005671 0000012 00000000232 10025707656 013714 0 ustar jcameron wheel ---- Changes since 1.060 ----
A new form has been added for creating and scheduling a Cron job to run Fetchmail, as an alternative to running the daemon