Log total received key count.

[onak.git] / onak-mail.pl

diff --git a/onak-mail.pl b/onak-mail.pl
index 841d4eea4ac38248fa73126d57939031515e5ba9..6799b3d86b4c897fd41aacc25bdf03f912f60b61 100755 (executable)
--- a/onak-mail.pl
+++ b/onak-mail.pl
@@ -1,5 +1,4 @@
 #!/usr/bin/perl -w
 #!/usr/bin/perl -w

-

 #
 # onak-mail.pl - Mail processing interface for onak, an OpenPGP Keyserver.
 #
 #
 # onak-mail.pl - Mail processing interface for onak, an OpenPGP Keyserver.
 #


@@ -7,10 +6,9 @@
 # Copyright 2002 Project Purple
 # Released under the GPL.
 #
 # Copyright 2002 Project Purple
 # Released under the GPL.
 #

-# $Id: onak-mail.pl,v 1.7 2003/09/28 17:25:40 noodles Exp $
-#

 
 use strict;
 
 use strict;

+use Fcntl ':flock';

 use IPC::Open3;
 
 my %config;
 use IPC::Open3;
 
 my %config;


@@ -39,6 +37,8 @@ sub readconfig {
                        $config{'mta'} = $1;
                } elsif (/^pks_bin_dir (.*)/) {
                        $config{'pks_bin_dir'} = $1;
                        $config{'mta'} = $1;
                } elsif (/^pks_bin_dir (.*)/) {
                        $config{'pks_bin_dir'} = $1;

+               } elsif (/^db_dir (.*)/) {
+                       $config{'db_dir'} = $1;

                } elsif (/^syncsite (.*)/) {
                        push @{$config{'syncsites'}}, $1;
                }
                } elsif (/^syncsite (.*)/) {
                        push @{$config{'syncsites'}}, $1;
                }


@@ -60,13 +60,22 @@ sub submitupdate {
        my @data = @_;
        my (@errors, @mergedata);
 
        my @data = @_;
        my (@errors, @mergedata);
 

+       open(LOCKFILE, '>'.$config{'db_dir'}.'/onak-mail.lck');
+       flock(LOCKFILE, LOCK_EX);
+       print LOCKFILE "$$";
+

        open3(\*MERGEIN, \*MERGEOUT, \*MERGEERR,
                $config{'pks_bin_dir'}."/onak", "-u", "add");
 
        print MERGEIN @data;
        close MERGEIN;
        @mergedata = <MERGEOUT>;
        open3(\*MERGEIN, \*MERGEOUT, \*MERGEERR,
                $config{'pks_bin_dir'}."/onak", "-u", "add");
 
        print MERGEIN @data;
        close MERGEIN;
        @mergedata = <MERGEOUT>;

+       close MERGEOUT;

        @errors = <MERGEERR>;
        @errors = <MERGEERR>;

+       close MERGEERR;
+
+       flock(LOCKFILE, LOCK_UN);
+       close(LOCKFILE);

 
        return @mergedata;
 }
 
        return @mergedata;
 }


@@ -95,6 +104,9 @@ while (<>) {
                push @body, $_;
        }
 }
                push @body, $_;
        }
 }

+if (! defined($replyto)) {
+       $replyto = $from;
+}

 
 # HELP, ADD, INCREMENTAL, VERBOSE INDEX <keyid>, INDEX <keyid>, GET <keyid>,
 # LAST <days>
 
 # HELP, ADD, INCREMENTAL, VERBOSE INDEX <keyid>, INDEX <keyid>, GET <keyid>,
 # LAST <days>


@@ -156,7 +168,34 @@ if ($subject =~ /^INCREMENTAL$/i) {
                print MAIL "MIME-Version: 1.0\n";
                print MAIL "Content-Type: application/pgp-keys\n";
                print MAIL "\n";
                print MAIL "MIME-Version: 1.0\n";
                print MAIL "Content-Type: application/pgp-keys\n";
                print MAIL "\n";

-               print @newupdate;
+               print MAIL @newupdate;

                close MAIL;
        }
                close MAIL;
        }

+} elsif ($subject =~ /^(VERBOSE )?INDEX (.*)$/i) {
+       my (@indexdata, $command);
+
+       $command = "index";
+       if (defined($1)) {
+               $command = "vindex";
+       }
+
+       open3(\*INDEXIN, \*INDEXOUT, \*INDEXERR,
+               $config{'pks_bin_dir'}."/onak", $command, "$2");
+       close INDEXIN;
+       @indexdata = <INDEXOUT>;
+       close INDEXOUT;
+       close INDEXERR;
+
+       open(MAIL, "|$config{mta}");
+       print MAIL "From: $config{adminemail}\n";
+       print MAIL "To: $replyto\n";
+       print MAIL "Subject: Reply to INDEX $2\n";
+       print MAIL "Precedence: list\n";
+       print MAIL "MIME-Version: 1.0\n";
+       print MAIL "Content-Type: text/plain\n";
+       print MAIL "\n";
+       print MAIL "Below follows the reply to your recent keyserver query:\n";
+       print MAIL "\n";
+       print MAIL @indexdata;
+       close MAIL;

 }
 }