summaryrefslogtreecommitdiff
path: root/Echolot/Mailin.pm
diff options
context:
space:
mode:
authorPeter Palfrader <peter@palfrader.org>2002-06-05 04:05:40 +0000
committerPeter Palfrader <peter@palfrader.org>2002-06-05 04:05:40 +0000
commitecd052098413f87701ba00e28f88563248a177f6 (patch)
tree0b31ba6942617df44e2745014b291df97625021c /Echolot/Mailin.pm
Initial Import
Diffstat (limited to 'Echolot/Mailin.pm')
-rw-r--r--Echolot/Mailin.pm120
1 files changed, 120 insertions, 0 deletions
diff --git a/Echolot/Mailin.pm b/Echolot/Mailin.pm
new file mode 100644
index 0000000..411433a
--- /dev/null
+++ b/Echolot/Mailin.pm
@@ -0,0 +1,120 @@
+package Echolot::Mailin;
+
+# (c) 2002 Peter Palfrader <peter@palfrader.org>
+# $Id: Mailin.pm,v 1.1 2002/06/05 04:05:40 weasel Exp $
+#
+
+=pod
+
+=head1 Name
+
+Echolot::Mailin - Incoming Mail Dispatcher for Echolot
+
+=head1 DESCRIPTION
+
+
+=cut
+
+use strict;
+use warnings;
+use Carp qw{cluck};
+use English;
+use Echolot::Globals;
+
+sub make_sane_name() {
+ my $result = time().'.'.$PROCESS_ID.'_'.Echolot::Globals::get()->{'internal_counter'}++.'.'.Echolot::Globals::get()->{'hostname'};
+ return $result;
+};
+
+sub sane_move($$) {
+ my ($from, $to) = @_;
+
+ my $link_success = link($from, $to);
+ $link_success or
+ cluck("Cannot link $from to $to: $! - Trying move"),
+ rename($from, $to) or
+ cluck("Renaming $from to $to didn't work either: $!"),
+ return 0;
+
+ $link_success && (unlink($from) or
+ cluck("Cannot unlink $from: $!") );
+ return 1;
+};
+
+sub handle($) {
+ my ($file) = @_;
+
+ open (FH, $file) or
+ cluck("Cannot open file $file: $!"),
+ return 0;
+
+ my $to;
+ while (<FH>) {
+ chomp;
+ last if $_ eq '';
+
+ if (m/^To:\s*(.*?)\s*$/) {
+ $to = $1;
+ };
+ };
+ my $body = join('', <FH>);
+ close (FH) or
+ cluck("Cannot close file $file: $!");
+
+ (defined $to) or
+ cluck("No To header found in $file"),
+ return 0;
+
+ my $delimiter = quotemeta( Echolot::Config::get()->{'recipient_delimiter'});
+ my ($type, $timestamp, $received_hash) = $to =~ /$delimiter (.*) = (\d+) = ([0-9a-f]+) @/x or
+ cluck("Could not parse to header '$to'"),
+ return 0;
+
+ my $token = $type.'='.$timestamp;
+ my $hash = Echolot::Tools::hash($token . Echolot::Globals::get()->{'storage'}->get_secret() );
+ my $cut_hash = substr($hash, 0, Echolot::Config::get()->{'hash_len'});
+
+ ($cut_hash eq $received_hash) or
+ cluck("Hash mismatch in '$to'"),
+ return 0;
+
+ Echolot::Conf::remailer_conf($body, $type, $timestamp), return 1 if ($type =~ /^conf\./);
+ Echolot::Conf::remailer_key($body, $type, $timestamp), return 1 if ($type =~ /^key\./);
+ Echolot::Conf::remailer_help($body, $type, $timestamp), return 1 if ($type =~ /^help\./);
+ Echolot::Conf::remailer_stats($body, $type, $timestamp), return 1 if ($type =~ /^stats\./);
+
+ Echolot::Ping::receive($body, $type, $timestamp), return 1 if ($type =~ /^ping\./);
+
+ cluck("Didn't know what to do with '$to'"),
+ return 0;
+};
+
+sub process() {
+ my $mailindir = Echolot::Config::get()->{'mailindir'};
+ my $targetdir = Echolot::Config::get()->{'mailerrordir'};
+ my @files = ();
+ for my $sub (qw{new cur}) {
+ opendir(DIR, $mailindir.'/'.$sub) or
+ cluck("Cannot open direcotry '$mailindir/$sub': $!"),
+ return 0;
+ push @files, map { $sub.'/'.$_ } grep { ! /^\./ } readdir(DIR);
+ closedir(DIR) or
+ cluck("Cannot close direcotry '$mailindir/$sub': $!");
+ };
+ for my $file (@files) {
+ $file =~ /^(.*)$/s or
+ croak("I really should match here. ('$file').");
+ $file = $1;
+ if (handle($mailindir.'/'.$file)) {
+ unlink($mailindir.'/'.$file);
+ } else {
+ my $name = make_sane_name();
+ sane_move($mailindir.'/'.$file, $targetdir.'/new/'.$name) or
+ cluck("Sane moving of $mailindir/$file to $targetdir/new/$name failed");
+ };
+ };
+};
+
+1;
+
+# vim: set ts=4 shiftwidth=4: