120 lines
4.5 KiB
Perl
Executable File
120 lines
4.5 KiB
Perl
Executable File
#!/usr/bin/env perl
|
|
#
|
|
# Copyright (c) 2022 Mischa Peters <mischa @ high5.nl>
|
|
#
|
|
# Permission to use, copy, modify, and distribute this software for any
|
|
# purpose with or without fee is hereby granted, provided that the above
|
|
# copyright notice and this permission notice appear in all copies.
|
|
#
|
|
# THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
# WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
# MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
|
# ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
# WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
|
# ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
|
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
#
|
|
use 5.024;
|
|
use strict;
|
|
use warnings;
|
|
use autodie;
|
|
use Getopt::Std;
|
|
use DBI;
|
|
|
|
my $db_type = 'MariaDB';
|
|
my $db_host = '';
|
|
my $db_user = '';
|
|
my $db_pass = '';
|
|
my $db_name = '';
|
|
|
|
getopts('dv');
|
|
our($opt_d, $opt_v);
|
|
|
|
my $email = "";
|
|
my $from = "";
|
|
my %ooo;
|
|
my $dbh = DBI->connect("DBI:$db_type:$db_name:$db_host", "$db_user", "$db_pass", {RaiseError => 1});
|
|
sub do_query {
|
|
my ($query) = @_;
|
|
my $sth = $dbh->prepare($query);
|
|
$sth->execute;
|
|
return $sth;
|
|
}
|
|
|
|
open (my $fh, '>', "/tmp/virtualvacation.log") if ($opt_d);
|
|
select(STDOUT);
|
|
$|++;
|
|
select($fh);
|
|
$|++;
|
|
print STDOUT "register|report|smtp-in|tx-mail\n";
|
|
print STDOUT "register|report|smtp-in|tx-rcpt\n";
|
|
print STDOUT "register|filter|smtp-in|data-line\n";
|
|
print STDOUT "register|ready\n";
|
|
|
|
while (my $line = <>) {
|
|
next if ($line =~ m/^config/);
|
|
chomp $line;
|
|
print $fh (scalar localtime() . " $line\n") if ($opt_v);
|
|
if ($line =~ m/^report/) {
|
|
print $fh (scalar localtime() . " $line\n") if ($opt_d);
|
|
my ($stream, $version, $timestamp, $subsystem, $event, $sid, $token, $code, $address) = split /\|/, $line;
|
|
if ($event eq "tx-mail" && $code eq "ok") {
|
|
$ooo{$sid} = 1;
|
|
$from = $address;
|
|
print $fh (scalar localtime() . " Virtual Vacation: created session $sid\n") if ($opt_d);
|
|
if ($from =~ m/^(postmaster|hostmaster|noreply|no-reply|bounce.*)@/i) { $ooo{$sid} = 0; }
|
|
} elsif ($event eq "tx-mail" && $code ne "ok") {
|
|
$ooo{$sid} = 0;
|
|
}
|
|
if ($event eq "tx-rcpt" && $code eq "ok") {
|
|
$email = $address;
|
|
} elsif ($event eq "tx-rcpt" && $code ne "ok") {
|
|
delete $ooo{$sid};
|
|
print $fh (scalar localtime() . " Virtual Vacation: removed session $sid\n") if ($opt_d);
|
|
}
|
|
}
|
|
if ($line =~ m/^filter/) {
|
|
my ($stream, $version, $timestamp, $subsystem, $event, $sid, $token, $data) = split /\|/, $line;
|
|
if ($line =~ m/data-line/) {
|
|
if (!$data) { $data = ""; }
|
|
if ($data =~ m/^precedence:\s+(bulk|list|junk)/i) { $ooo{$sid} = 0; print "Virtual Vacation: header found $data\n" if ($opt_d); }
|
|
if ($data =~ m/^list-(help|id|owner|post|subscribe|unsubscribe):.*/i) { $ooo{$sid} = 0; print "Virtual Vacation: header found $data\n" if ($opt_d); }
|
|
if ($data =~ m/^x-loop:\s+opensmtpd\ admin\ virtual\ vacation/i) { $ooo{$sid} = 0; }
|
|
print STDOUT "filter-dataline|$sid|$token|$data\n";
|
|
}
|
|
if ($line =~ m/data-line/ && $data eq '.' && $ooo{$sid} == 1) {
|
|
print $fh (scalar localtime() . " Virtual Vacation: To: $email, From: $from\n") if ($opt_d);
|
|
my $query = qq{SELECT subject,body FROM vacation WHERE email='$email' and active=1};
|
|
my $sth = do_query($query);
|
|
my $rv = $sth->rows;
|
|
if ($rv == 1) {
|
|
print $fh (scalar localtime() . " Virtual Vacation: Found OOO for $email\n") if ($opt_d);
|
|
my @vacation_msg = $sth->fetchrow_array;
|
|
$query = qq{SELECT cache FROM vacation WHERE email='$email' AND FIND_IN_SET('$from',cache)};
|
|
$sth = do_query($query);
|
|
$rv = $sth->rows;
|
|
if ($rv == 0) {
|
|
print $fh (scalar localtime() . " Virtual Vacation: Sending OOO to $from\n") if ($opt_d);
|
|
$query = qq{UPDATE vacation SET cache=CONCAT(cache,',','$from') WHERE email='$email'};
|
|
$sth = do_query($query);
|
|
open my $fh_email, "|-", "/usr/sbin/sendmail -t";
|
|
print $fh_email "From: $email\n";
|
|
print $fh_email "To: $from\n";;
|
|
print $fh_email "Subject: $vacation_msg[0]\n";
|
|
print $fh_email "X-Loop: OpenSMTPD Admin Virtual Vacation\n";
|
|
print $fh_email "Content-Type: text/plain; charset=utf-8\n\n";
|
|
print $fh_email "$vacation_msg[1]\n";
|
|
close $fh_email;
|
|
}
|
|
delete $ooo{$sid};
|
|
print $fh (scalar localtime() . " Virtual Vacation: removed session $sid\n") if ($opt_d);
|
|
}
|
|
} elsif ($line =~ m/data-line/ && $data eq '.' && $ooo{$sid} == 0) {
|
|
delete $ooo{$sid};
|
|
print $fh (scalar localtime() . " Virtual Vacation: removed session $sid\n") if ($opt_d);
|
|
}
|
|
}
|
|
}
|
|
close $fh;
|
|
0;
|