git subrepo clone https://github.com/mailcow/mailcow-dockerized.git mailcow/src/mailcow-dockerized
subrepo: subdir: "mailcow/src/mailcow-dockerized"
merged: "a832becb"
upstream: origin: "https://github.com/mailcow/mailcow-dockerized.git"
branch: "master"
commit: "a832becb"
git-subrepo: version: "0.4.3"
origin: "???"
commit: "???"
Change-Id: If5be2d621a211e164c9b6577adaa7884449f16b5
diff --git a/mailcow/src/mailcow-dockerized/data/Dockerfiles/dovecot/imapsync_cron.pl b/mailcow/src/mailcow-dockerized/data/Dockerfiles/dovecot/imapsync_cron.pl
new file mode 100644
index 0000000..746b1d4
--- /dev/null
+++ b/mailcow/src/mailcow-dockerized/data/Dockerfiles/dovecot/imapsync_cron.pl
@@ -0,0 +1,180 @@
+#!/usr/bin/perl
+
+use DBI;
+use LockFile::Simple qw(lock trylock unlock);
+use Proc::ProcessTable;
+use Data::Dumper qw(Dumper);
+use IPC::Run 'run';
+use File::Temp;
+use Try::Tiny;
+use sigtrap 'handler' => \&sig_handler, qw(INT TERM KILL QUIT);
+
+sub trim { my $s = shift; $s =~ s/^\s+|\s+$//g; return $s };
+my $t = Proc::ProcessTable->new;
+my $imapsync_running = grep { $_->{cmndline} =~ /imapsync\s/i } @{$t->table};
+if ($imapsync_running ge 1)
+{
+ print "imapsync is active, exiting...";
+ exit;
+}
+
+sub qqw($) {
+ my @params = ();
+ my @values = split(/(?=--)/, $_[0]);
+ foreach my $val (@values) {
+ my @tmpparam = split(/ /, $val, 2);
+ foreach my $tmpval (@tmpparam) {
+ if ($tmpval ne '') {
+ push @params, $tmpval;
+ }
+ }
+ }
+ foreach my $val (@params) {
+ $val=trim($val);
+ }
+ return @params;
+}
+
+$run_dir="/tmp";
+$dsn = 'DBI:mysql:database=__DBNAME__;mysql_socket=/var/run/mysqld/mysqld.sock';
+$lock_file = $run_dir . "/imapsync_busy";
+$lockmgr = LockFile::Simple->make(-autoclean => 1, -max => 1);
+$lockmgr->lock($lock_file) || die "can't lock ${lock_file}";
+$dbh = DBI->connect($dsn, '__DBUSER__', '__DBPASS__', {
+ mysql_auto_reconnect => 1,
+ mysql_enable_utf8mb4 => 1
+});
+$dbh->do("UPDATE imapsync SET is_running = 0");
+
+sub sig_handler {
+ # Send die to force exception in "run"
+ die "sig_handler received signal, preparing to exit...\n";
+};
+
+open my $file, '<', "/etc/sogo/sieve.creds";
+my $creds = <$file>;
+close $file;
+my ($master_user, $master_pass) = split /:/, $creds;
+my $sth = $dbh->prepare("SELECT id,
+ user1,
+ user2,
+ host1,
+ authmech1,
+ password1,
+ exclude,
+ port1,
+ enc1,
+ delete2duplicates,
+ maxage,
+ subfolder2,
+ delete1,
+ delete2,
+ automap,
+ skipcrossduplicates,
+ maxbytespersecond,
+ custom_params,
+ subscribeall,
+ timeout1,
+ timeout2
+ FROM imapsync
+ WHERE active = 1
+ AND is_running = 0
+ AND (
+ UNIX_TIMESTAMP(NOW()) - UNIX_TIMESTAMP(last_run) > mins_interval * 60
+ OR
+ last_run IS NULL)
+ ORDER BY last_run");
+
+$sth->execute();
+my $row;
+
+while ($row = $sth->fetchrow_arrayref()) {
+
+ $id = @$row[0];
+ $user1 = @$row[1];
+ $user2 = @$row[2];
+ $host1 = @$row[3];
+ $authmech1 = @$row[4];
+ $password1 = @$row[5];
+ $exclude = @$row[6];
+ $port1 = @$row[7];
+ $enc1 = @$row[8];
+ $delete2duplicates = @$row[9];
+ $maxage = @$row[10];
+ $subfolder2 = @$row[11];
+ $delete1 = @$row[12];
+ $delete2 = @$row[13];
+ $automap = @$row[14];
+ $skipcrossduplicates = @$row[15];
+ $maxbytespersecond = @$row[16];
+ $custom_params = @$row[17];
+ $subscribeall = @$row[18];
+ $timeout1 = @$row[19];
+ $timeout2 = @$row[20];
+
+ if ($enc1 eq "TLS") { $enc1 = "--tls1"; } elsif ($enc1 eq "SSL") { $enc1 = "--ssl1"; } else { undef $enc1; }
+
+ my $template = $run_dir . '/imapsync.XXXXXXX';
+ my $passfile1 = File::Temp->new(TEMPLATE => $template);
+ my $passfile2 = File::Temp->new(TEMPLATE => $template);
+
+ print $passfile1 "$password1\n";
+ print $passfile2 trim($master_pass) . "\n";
+
+ my @custom_params_a = qqw($custom_params);
+ my $custom_params_ref = \@custom_params_a;
+
+ my $generated_cmds = [ "/usr/local/bin/imapsync",
+ "--tmpdir", "/tmp",
+ "--nofoldersizes",
+ ($timeout1 gt "0" ? () : ('--timeout1', $timeout1)),
+ ($timeout2 gt "0" ? () : ('--timeout2', $timeout2)),
+ ($exclude eq "" ? () : ("--exclude", $exclude)),
+ ($subfolder2 eq "" ? () : ('--subfolder2', $subfolder2)),
+ ($maxage eq "0" ? () : ('--maxage', $maxage)),
+ ($maxbytespersecond eq "0" ? () : ('--maxbytespersecond', $maxbytespersecond)),
+ ($delete2duplicates ne "1" ? () : ('--delete2duplicates')),
+ ($subscribeall ne "1" ? () : ('--subscribeall')),
+ ($delete1 ne "1" ? () : ('--delete')),
+ ($delete2 ne "1" ? () : ('--delete2')),
+ ($automap ne "1" ? () : ('--automap')),
+ ($skipcrossduplicates ne "1" ? () : ('--skipcrossduplicates')),
+ (!defined($enc1) ? () : ($enc1)),
+ "--host1", $host1,
+ "--user1", $user1,
+ "--passfile1", $passfile1->filename,
+ "--port1", $port1,
+ "--host2", "localhost",
+ "--user2", $user2 . '*' . trim($master_user),
+ "--passfile2", $passfile2->filename,
+ '--no-modulesversion',
+ '--noreleasecheck'];
+
+ try {
+ $is_running = $dbh->prepare("UPDATE imapsync SET is_running = 1 WHERE id = ?");
+ $is_running->bind_param( 1, ${id} );
+ $is_running->execute();
+
+ run [@$generated_cmds, @$custom_params_ref], '&>', \my $stdout;
+
+ $update = $dbh->prepare("UPDATE imapsync SET returned_text = ? WHERE id = ?");
+ $update->bind_param( 1, ${stdout} );
+ $update->bind_param( 2, ${id} );
+ $update->execute();
+ } catch {
+ $update = $dbh->prepare("UPDATE imapsync SET returned_text = 'Could not start or finish imapsync' WHERE id = ?");
+ $update->bind_param( 1, ${id} );
+ $update->execute();
+ } finally {
+ $update = $dbh->prepare("UPDATE imapsync SET last_run = NOW(), is_running = 0 WHERE id = ?");
+ $update->bind_param( 1, ${id} );
+ $update->execute();
+ };
+
+
+}
+
+$sth->finish();
+$dbh->disconnect();
+
+$lockmgr->unlock($lock_file);