dkim: add QID in warnings

[pmg-api.git] / PMG / Postfix.pm

diff --git a/PMG/Postfix.pm b/PMG/Postfix.pm
deleted file mode 100644 (file)
index f29d1a5..0000000
--- a/PMG/Postfix.pm
+++ /dev/null
@@ -1,182 +0,0 @@
-package PMG::Postfix;
-
-use strict;
-use warnings;
-use Data::Dumper;
-use File::Find;
-use JSON;
-
-use PMG::Utils;
-
-my $spooldir = "/var/spool/postfix";
-
-my $postfix_rec_get = sub {
-    my ($fh) = @_;
-
-    my $r = getc($fh);
-    return if !defined($r);
-
-    my $l = 0;
-    my $shift = 0;
-
-    while (defined(my $lb = getc($fh))) {
-       my $o = ord($lb);
-       $l |= ($o & 0x7f) << $shift ;
-       last if (($o & 0x80) == 0);
-       $shift += 7;
-       return if ($shift > 7); # XXX: max rec len of 4096
-    }
-
-    my $d = "";
-    return unless ($l == 0 || read($fh, $d, $l) == $l);
-    return ($r, $l, $d);
-};
-
-my $postfix_qenv = sub {
-    my ($filename) = @_;
-
-    my $fh = new IO::File($filename, "r");
-    return undef if !defined($fh);
-
-    my $dlen;
-    my $res = { receivers => [] };
-    while (my ($r, $l, $d) = $postfix_rec_get->($fh)) {
-       #print "test:$r:$l:$d\n";
-       if ($r eq "C") { $dlen = $1 if $d =~ /^\s*(\d+)\s+\d+\s+\d+/; }
-       elsif ($r eq 'T') { $res->{time} = $1 if $d =~ /^\s*(\d+)\s\d+/; }
-       elsif ($r eq 'S') { $res->{sender} = $d; }
-       elsif ($r eq 'R') { push @{$res->{receivers}}, $d; }
-       elsif ($r eq 'N') {
-           if ($d =~ m/^Subject:\s+(.*)$/i) {
-               $res->{subject} = $1;
-           } elsif (!$res->{messageid} && $d =~ m/^Message-Id:\s+<(.*)>$/i) {
-               $res->{messageid} = $1;
-           }
-       }
-       #elsif ($r eq "M") { last unless defined $dlen; seek($fh, $dlen, 1); }
-       elsif ($r eq "E") { last; }
-    }
-
-    close($fh);
-
-    return $res;
-};
-
-# Fixme: it is a bad idea to scan everything - list can be too large
-sub show_deferred_queue {
-    my $res;
-
-    my $queue = 'deferred';
-
-    my $callback = sub {
-       my $path = $File::Find::name;
-       my $filename = $_;
-
-       my ($dev, $ino, $mode) = lstat($path);
-
-       return if !defined($mode);
-       return if !(-f _ && (($mode & 07777) == 0700));
-
-       if (my $rec = $postfix_qenv->($path)) {
-           $rec->{queue} = $queue;
-           $rec->{qid} = $filename;
-           push @$res, $rec;
-       }
-    };
-
-    find($callback, "$spooldir/deferred");
-
-    return $res;
-}
-
-sub qshape {
-    my ($queues) = @_;
-
-    open(my $fh, '-|', '/usr/sbin/qshape', $queues) || die "ERROR: unable to run qshape: $!\n";
-
-    my $line = <$fh>;
-    if (!$line || !($line =~ m/^\s+T\s+5\s+10\s+20\s+40\s+80\s+160\s+320\s+640\s+1280\s+1280\+$/)) {
-       close (CMD);
-       die "ERROR: unable to parse qshape output: - $line";
-    }
-
-    my $count = 0;
-    my $res = [];
-    while (($count++ < 10000) && (defined($line = <$fh>))) {
-       if ($line =~ m/^\s+(\S+\s+\d+\s+\d+\s+\d+\s+\d+\s+\d+\s+\d+\s+\d+\s+\d+\s+\d+\s+\d+\s+\d+)$/) {
-           my @d = split(/\s+/, $1);
-           push @$res, { 
-               domain => $d[0],
-               total => $d[1],
-               '5s' => $d[2],
-               '10s' => $d[3],
-               '20s' => $d[4],
-               '40s' => $d[5],
-               '80s' => $d[6],
-               '160s' => $d[7],
-               '320s' => $d[8],
-               '640s' => $d[9],
-               '1280s' => $d[10],
-               '1280s+' => $d[11],
-           };
-       }
-    }
-
-    close($fh);
-
-    return $res;
-}
-
-sub mailq {
-    my ($filter, $start, $limit) = @_;
-
-    open(my $fh, '-|', '/usr/sbin/postqueue', '-j') || die "ERROR: unable to run postqueue - $!\n";
-
-    my $count = 0;
-
-    $start = 0 if !$start;
-    $limit = 50 if !$limit;
-
-    my $res = [];
-    my $line;
-    while (defined($line = <$fh>)) {
-       my $rec = decode_json($line);
-       my $recipients = $rec->{recipients};
-
-       foreach my $entry (@$recipients) {
-           if (!$filter || $entry->{address} =~ m/$filter/i ||
-               $rec->{sender} =~ m/$filter/i) {
-               next if $count++ < $start;
-               next if $limit-- <= 0;
-
-               my $data = {};
-               foreach my $k (qw(queue_name queue_id arrival_time message_size sender)) {
-                   $data->{$k} = $rec->{$k};
-               }
-               $data->{receiver} = $entry->{address};
-               $data->{reason} = $entry->{delay_reason};
-               push @$res, $data;
-           }
-       }
-    }
-
-    close (CMD);
-
-    return ($count, $res);
-}
-
-sub flush_queues {
-    system("/usr/sbin/postqueue -f");
-}
-
-sub delete_deferred_queue {
-    system("/usr/sbin/postsuper -d ALL deferred");
-}
-
-sub discard_verify_cache {
-    unlink "/var/lib/postfix/verify_cache.db";
-
-    PMG::Utils::service_cmd('postfix', 'reload');
-}
-
-1;