X-Git-Url: http://git.freeside.biz/gitweb/?a=blobdiff_plain;f=FS%2FFS%2Fsvc_acct.pm;h=3c564ec9db57a442be14ce2b25c3d3af5df6f1d2;hb=e5b4bae07ce072ba1cc6997eadbe3f0c09ff7308;hp=2a0c904459cce3c69809bfa0af6d176914bd9abd;hpb=da4c9633b45d04091fc1b8d420e5d75e294ebf86;p=freeside.git

diff --git a/FS/FS/svc_acct.pm b/FS/FS/svc_acct.pm
index 2a0c90445..3c564ec9d 100644
--- a/FS/FS/svc_acct.pm
+++ b/FS/FS/svc_acct.pm
@@ -10,8 +10,12 @@ use vars qw( @ISA $nossh_hack $conf $dir_prefix @shells $usernamemin
              $cp_server $cp_user $cp_pass $cp_workgroup
              $dirhash
              $icradius_dbh
-             @saltset @pw_set);
+             @saltset @pw_set
+             $rsync $ssh $exportdir $vpopdir);
 use Carp;
+use File::Path;
+use Fcntl qw(:flock);
+use FS::UID qw( datasrc );
 use FS::Conf;
 use FS::Record qw( qsearch qsearchs fields dbh );
 use FS::svc_Common;
@@ -28,6 +32,8 @@ use FS::queue;
 
 #ask FS::UID to run this stuff for us later
 $FS::UID::callback{'FS::svc_acct'} = sub { 
+  $rsync = "rsync";
+  $ssh = "ssh";
   $conf = new FS::Conf;
   $dir_prefix = $conf->config('home');
   @shells = $conf->config('shells');
@@ -95,6 +101,14 @@ $FS::UID::callback{'FS::svc_acct'} = sub {
     $icradius_dbh = '';
   }
   $dirhash = $conf->config('dirhash') || 0;
+  $exportdir = "/usr/local/etc/freeside/export." . datasrc;
+  if ( $conf->exists('vpopmailmachines') ) {
+    my (@vpopmailmachines) = $conf->config('vpopmailmachines');
+    my ($machine, $dir, $uid, $gid) = split (/\s+/, $vpopmailmachines[0]);
+    $vpopdir = $dir;
+  } else {
+    $vpopdir = '';
+  }
 };
 
 @saltset = ( 'a'..'z' , 'A'..'Z' , '0'..'9' , '.' , '/' );
@@ -345,9 +359,28 @@ sub insert {
       $dbh->rollback if $oldAutoCommit;
       return "queueing job (transaction rolled back): $error";
     }
+  }
+
+  if ( $vpopdir ) {
+
+    my $vpopmail_queue =
+      new FS::queue { 
+      'svcnum' => $self->svcnum,
+      'job' => 'FS::svc_acct::vpopmail_insert'
+    };
+    $error = $vpopmail_queue->insert( $self->username,
+      crypt($self->_password,$saltset[int(rand(64))].$saltset[int(rand(64))]),
+                                      $self->domain,
+                                      $vpopdir,
+                                    );
+    if ( $error ) {
+      $dbh->rollback if $oldAutoCommit;
+      return "queueing job (transaction rolled back): $error";
+    }
 
   }
 
+
   $dbh->commit or die $dbh->errstr if $oldAutoCommit;
   ''; #no error
 }
@@ -457,6 +490,50 @@ sub icradius_rr_insert {
   1;
 }
 
+
+sub vpopmail_insert {
+  my( $username, $password, $domain, $vpopdir ) = @_;
+  
+  (open(VPASSWD, ">>$exportdir/domains/$domain/vpasswd")
+    and flock(VPASSWD,LOCK_EX)
+  ) or die "can't open vpasswd file for $username\@$domain: $exportdir/domains/$domain/vpasswd";
+  print VPASSWD join(":",
+    $username,
+    $password,
+    '1',
+    '0',
+    $username,
+    "$vpopdir/domains/$domain/$username",
+    'NOQUOTA',
+  ), "\n";
+
+  flock(VPASSWD,LOCK_UN);
+  close(VPASSWD);
+
+  mkdir "$exportdir/domains/$domain/$username", 0700  or die "can't create Maildir";
+  mkdir "$exportdir/domains/$domain/$username/Maildir", 0700 or die "can't create Maildir";
+  mkdir "$exportdir/domains/$domain/$username/Maildir/cur", 0700 or die "can't create Maildir";
+  mkdir "$exportdir/domains/$domain/$username/Maildir/new", 0700 or die "can't create Maildir";
+  mkdir "$exportdir/domains/$domain/$username/Maildir/tmp", 0700 or die "can't create Maildir";
+ 
+  my $queue = new FS::queue { 'job' => 'FS::svc_acct::vpopmail_sync' };
+  my $error = $queue->insert;
+  die $error if $error;
+
+  1;
+}
+
+sub vpopmail_sync {
+
+  my (@vpopmailmachines) = $conf->config('vpopmailmachines');
+  my ($machine, $dir, $uid, $gid) = split (/\s+/, $vpopmailmachines[0]);
+  
+  chdir $exportdir;
+  my @args = ("$rsync", "-rlpt", "-e", "$ssh", "domains/", "vpopmail\@$machine:$vpopdir/domains/");
+  system {$args[0]} @args;
+
+}
+
 =item delete
 
 Deletes this account from the database.  If there is an error, returns the
@@ -601,6 +678,14 @@ sub delete {
       $dbh->rollback if $oldAutoCommit;
       return "queueing job (transaction rolled back): $error";
     }
+  }
+  if ( $vpopdir ) {
+    my $queue = new FS::queue { 'job' => 'FS::svc_acct::vpopmail_delete' };
+    $error = $queue->insert( $self->username, $self->domain );
+    if ( $error ) {
+      $dbh->rollback if $oldAutoCommit;
+      return "queueing job (transaction rolled back): $error";
+    }
 
   }
 
@@ -671,6 +756,33 @@ sub icradius_rr_delete {
   1;
 }
 
+sub vpopmail_delete {
+  my( $username, $domain ) = @_;
+  
+  (open(VPASSWD, "$exportdir/domains/$domain/vpasswd")
+    and flock(VPASSWD,LOCK_EX)
+  ) or die "can't open $exportdir/domains/$domain/vpasswd: $!";
+
+  open(VPASSWDTMP, ">$exportdir/domains/$domain/vpasswd.tmp")
+    or die "Can't open $exportdir/domains/$domain/vpasswd.tmp: $!";
+
+  while (<VPASSWD>) {
+    my ($mailbox, $rest) = split(':', $_);
+    print VPASSWDTMP $_ unless $username eq $mailbox;
+  }
+
+  close(VPASSWDTMP);
+
+  rename "$exportdir/domains/$domain/vpasswd.tmp", "$exportdir/domains/$domain/vpasswd"
+    or die "Can't rename $exportdir/domains/$domain/vpasswd.tmp: $!";
+
+  flock(VPASSWD,LOCK_UN);
+  close(VPASSWD);
+
+  rmtree "$exportdir/domains/$domain/$username" or die "can't destroy Maildir";+ 
+  1;
+}
+
 =item replace OLD_RECORD
 
 Replaces OLD_RECORD with this one in the database.  If there is an error,
@@ -791,6 +903,31 @@ sub replace {
       return "queueing job (transaction rolled back): $error";
     }
   }
+  if ( $vpopdir ) {
+    my $cpassword = crypt(
+      $new->_password,$saltset[int(rand(64))].$saltset[int(rand(64))]
+    );
+
+    if ($old->username ne $new->username || $old->domain ne $new->domain ) {
+      my $queue  = new FS::queue { 'job' => 'FS::svc_acct::vpopmail_delete' };
+        $error = $queue->insert( $old->username, $old->domain );
+      my $queue2 = new FS::queue { 'job' => 'FS::svc_acct::vpopmail_insert' };
+        $error = $queue2->insert( $new->username,
+                                  $cpassword,
+                                  $new->domain,
+                                  $vpopdir,
+                                )
+        unless $error;
+    } elsif ($old->_password ne $new->_password) {
+      my $queue = new FS::queue { 'job' => 'FS::svc_acct::vpopmail_replace_password' };
+      $error = $queue->insert( $new->username, $cpassword, $new->domain );
+    }
+    if ( $error ) {
+      $dbh->rollback if $oldAutoCommit;
+      return "queueing job (transaction rolled back): $error";
+    }
+  }
+
 
   $dbh->commit or die $dbh->errstr if $oldAutoCommit;
   ''; #no error
@@ -840,16 +977,66 @@ sub cp_change {
                         #Debug    => 1,
                       ) or die "$@\n";
 
+  if ( $password =~ /^\*SUSPENDED\* (.*)$/ ) {
+    $password = $1;
+    $app->set_mailbox_status(
+                              Domain       => $mydomain,
+                              Mailbox      => $username,
+                              Other        => 'T',
+                              Other_Bounce => 'T',
+                            );
+  } else {
+    $app->set_mailbox_status(
+                              Domain       => $mydomain,
+                              Mailbox      => $username,
+                              Other        => 'F',
+                              Other_Bounce => 'F',
+                            );
+  }
+  die $app->message."\n" unless $app->ok;
+
   $app->change_mailbox(
                         Domain    => $mydomain,
                         Mailbox   => $username,
                         Password  => $password,
                       );
-
   die $app->message."\n" unless $app->ok;
 
 }
 
+sub vpopmail_replace_password {
+  my( $username, $password, $domain ) = @_;
+  
+  (open(VPASSWD, "$exportdir/domains/$domain/vpasswd")
+    and flock(VPASSWD,LOCK_EX)
+  ) or die "can't open $exportdir/domains/$domain/vpasswd: $!";
+
+  open(VPASSWDTMP, ">$exportdir/domains/$domain/vpasswd.tmp")
+    or die "Can't open $exportdir/domains/$domain/vpasswd.tmp: $!";
+
+  while (<VPASSWD>) {
+    my ($mailbox, $pw, @rest) = split(':', $_);
+    print VPASSWDTMP $_ unless $username eq $mailbox;
+    print VPASSWDTMP join (':', ($mailbox, $password, @rest))
+      if $username eq $mailbox;
+  }
+
+  close(VPASSWDTMP);
+
+  rename "$exportdir/domains/$domain/vpasswd.tmp", "$exportdir/domains/$domain/vpasswd"
+    or die "Can't rename $exportdir/domains/$domain/vpasswd.tmp: $!";
+
+  flock(VPASSWD,LOCK_UN);
+  close(VPASSWD);
+
+  my $queue = new FS::queue { 'job' => 'FS::svc_acct::vpopmail_sync' };
+  my $error = $queue->insert;
+  die $error if $error;
+
+  1;
+}
+
+
 =item suspend
 
 Suspends this account by prefixing *SUSPENDED* to the password.  If there is an