From d1599b3aafe1e201174caad61140e7c82ca0494e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ask=20Bj=C3=B8rn=20Hansen?= <ask@develooper.com>
Date: Mon, 24 May 2004 11:36:04 +0000
Subject: [PATCH] maildir queue plugin

git-svn-id: https://svn.perl.org/qpsmtpd/trunk@232 958fd67b-6ff1-0310-b445-bb7760255be9
---
 Changes               |  3 +-
 plugins/queue/maildir | 78 +++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 80 insertions(+), 1 deletion(-)
 create mode 100644 plugins/queue/maildir

diff --git a/Changes b/Changes
index 554458a..640e8db 100644
--- a/Changes
+++ b/Changes
@@ -1,5 +1,6 @@
 0.28
 
+  Added a "queue/maildir" plugin for writing incoming mails to a maildir.
 
   Create temp files with permissions 0600 (thanks to Robert James Kaes again)
 
@@ -10,7 +11,7 @@
   $Include feature in config/plugins
 
 
-0.27 - 2004/03/11
+0.27.1 - 2004/03/11
 
   SpamAssassin plugin Outlook compatibility fix (Thanks to Gergely Risko)
 
diff --git a/plugins/queue/maildir b/plugins/queue/maildir
new file mode 100644
index 0000000..c7da488
--- /dev/null
+++ b/plugins/queue/maildir
@@ -0,0 +1,78 @@
+=head1 NAME
+
+queue/maildir
+
+=head1 DESCRIPTION
+
+This plugin delivers mails to a maildir spool. 
+
+=head1 CONFIG
+
+It takes one required parameter, the location of the maildir.
+
+=cut
+
+use File::Path qw(mkpath);
+use Sys::Hostname qw(hostname);
+use Time::HiRes qw(gettimeofday);
+
+sub register {
+  my ($self, $qp, @args) = @_;
+
+  if (@args > 0) {
+    ($self->{_maildir}) = ($args[0] =~ m!([/\w\.]+)!);
+  }
+
+  unless ($self->{_maildir}) {
+    $self->log(1, "WARNING: maildir directory not specified");
+    return 0;
+  }
+
+  map { my $d = $self->{_maildir} . "/$_"; -e $d or mkpath $d, 0, 0700 } qw(cur tmp new); 
+
+  my $hostname = (hostname =~ m/([\w\._\-]+)/)[0];
+  $self->{_hostname} = $hostname;
+
+  $self->register_hook("queue", "queue_handler");
+
+}
+
+my $maildir_counter = 0;
+
+sub queue_handler {
+  my ($self, $transaction) = @_;
+
+  my ($time, $microseconds) = gettimeofday;
+
+  $time = ($time =~ m/(\d+)/)[0];
+  $microseconds =~ s/\D//g;
+
+  my $unique  = "P$$" . "M$microseconds" . "Q" . $maildir_counter++;
+  my $file    = join ".", $time, $unique, $self->{_hostname};
+  my $maildir = $self->{_maildir};
+
+  open (MF, ">$maildir/tmp/$file") or 
+    $self->log(LOGWARN, "could not open $maildir/tmp/$file: $!"),
+    return(DECLINED, "queue error (open)");
+
+  $transaction->header->print(\*MF);
+  $transaction->body_resetpos;
+  while (my $line = $transaction->body_getline) {
+    print MF $line;
+  }
+
+  close MF or
+    $self->log(LOGWARN, "could not close $maildir/tmp/$file: $!")
+    and return(DECLINED, "queue error (close)");
+
+  link "$maildir/tmp/$file", "$maildir/new/$file" or
+    $self->log(LOGWARN, "could not link $maildir/tmp/$file to $maildir/new/$file: $!")
+    and return(DECLINED, "queue error (link)");
+
+  unlink "$maildir/tmp/$file";
+
+  my $msg_id = $transaction->header->get('Message-Id') || '';
+  $msg_id =~ s/[\r\n].*//s;
+
+  return (OK, "Queued! $msg_id"); 
+}