imapsync_cron.pl 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. #!/usr/bin/perl
  2. use DBI;
  3. use File::Temp qw/ mkstemp /;
  4. use LockFile::Simple qw(lock trylock unlock);
  5. use Data::Dumper qw(Dumper);
  6. use IPC::Run 'run';
  7. use String::Util 'trim';
  8. $DBNAME = '';
  9. $DBUSER = '';
  10. $DBPASS = '';
  11. $run_dir="/tmp";
  12. $dsn = "DBI:mysql:database=" . $DBNAME . ";host=mysql";
  13. $lock_file = $run_dir . "/imapsync_busy";
  14. $lockmgr = LockFile::Simple->make(-autoclean => 1, -max => 1);
  15. $lockmgr->lock($lock_file) || die "can't lock ${lock_file}";
  16. $dbh = DBI->connect($dsn, $DBUSER, $DBPASS);
  17. open my $file, '<', "/etc/sogo/sieve.creds";
  18. my $creds = <$file>;
  19. close $file;
  20. my ($master_user, $master_pass) = split /:/, $creds;
  21. my $sth = $dbh->prepare("SELECT id, user1, user2, host1, authmech1, password1, exclude, port1, enc1, delete2duplicates FROM imapsync WHERE active = 1 AND (UNIX_TIMESTAMP(NOW()) - UNIX_TIMESTAMP(last_run) > mins_interval * 60 OR last_run IS NULL)");
  22. $sth->execute();
  23. my $row;
  24. while ($row = $sth->fetchrow_arrayref()) {
  25. $id = @$row[0];
  26. $user1 = @$row[1];
  27. $user2 = @$row[2];
  28. $host1 = @$row[3];
  29. $authmech1 = @$row[4];
  30. $password1 = @$row[5];
  31. $exclude = @$row[6];
  32. $port1 = @$row[7];
  33. $enc1 = @$row[8];
  34. $delete2duplicates = @$row[9];
  35. $user_w_master = $user2 . '*' . trim($master_user);
  36. if ($enc1 eq "TLS") {
  37. $enc1 = "--tls1";
  38. }
  39. elsif ($enc1 eq "SSL") {
  40. $enc1 = "--ssl1";
  41. }
  42. else {
  43. $enc1 = "";
  44. }
  45. if ($exclude eq "") {
  46. $exclude = "nothing^";
  47. }
  48. if ($delete2duplicates eq "1") {
  49. $delete2duplicates = "--delete2duplicates";
  50. }
  51. else {
  52. $delete2duplicates = "";
  53. }
  54. run [ "/usr/local/bin/imapsync", ,"--timeout1", "10", "--tmpdir", "/tmp", "--subscribe", "--exclude", $exclude, "--host1", $host1, "--user1", $user1, "--password1", $password1, "--port1", $port1, $enc1, $delete2duplicates, "--host2", "localhost", "--user2", $user_w_master, "--password2", trim($master_pass), '--no-modulesversion'], ">", \my $stdout;
  55. $update = $dbh->prepare("UPDATE imapsync SET returned_text = ?, last_run = NOW() WHERE id = ?");
  56. $update->bind_param( 1, ${stdout} );
  57. $update->bind_param( 2, ${id} );
  58. $update->execute();
  59. }
  60. $sth->finish();
  61. $dbh->disconnect();
  62. $lockmgr->unlock($lock_file);