646af44cd2e325d333b4801d4eb33458027544b3
[freeside.git] / FS / FS / part_export / vpopmail.pm
1 package FS::part_export::vpopmail;
2
3 use vars qw(@ISA @saltset $exportdir);
4 use Fcntl qw(:flock);
5 use File::Path;
6 use FS::UID qw( datasrc );
7 use FS::part_export;
8
9 @ISA = qw(FS::part_export);
10
11 @saltset = ( 'a'..'z' , 'A'..'Z' , '0'..'9' , '.' , '/' );
12
13 sub rebless { shift; }
14
15 sub _export_insert {
16   my($self, $svc_acct) = (shift, shift);
17   $self->vpopmail_queue( $svc_acct->svcnum, 'insert',
18     $svc_acct->username,
19     crypt($svc_acct->_password,$saltset[int(rand(64))].$saltset[int(rand(64))]),
20     $svc_acct->domain,
21     $svc_acct->quota,
22     $svc_acct->finger,
23   );
24 }
25
26 sub _export_replace {
27   my( $self, $new, $old ) = (shift, shift, shift);
28
29   my $cpassword = crypt(
30     $new->_password, $saltset[int(rand(64))].$saltset[int(rand(64))]
31   );
32
33   return "can't change username with vpopmail"
34     if $old->username ne $new->username;
35
36   #no.... if mail can't be preserved, better to disallow username changes
37   #if ($old->username ne $new->username || $old->domain ne $new->domain ) {
38   #  vpopmail_queue( $svc_acct->svcnum, 'delete', 
39   #    $old->username, $old->domain
40   #  );
41   #  vpopmail_queue( $svc_acct->svcnum, 'insert', 
42   #    $new->username,
43   #    $cpassword,
44   #    $new->domain,
45   #  );
46
47   return '' unless $old->_password ne $new->_password;
48
49   $self->vpopmail_queue( $new->svcnum, 'replace',
50     $new->username, $cpassword, $new->domain, $new->quota, $new->finger );
51 }
52
53 sub _export_delete {
54   my( $self, $svc_acct ) = (shift, shift);
55   $self->vpopmail_queue( $svc_acct->svcnum, 'delete',
56     $svc_acct->username, $svc_acct->domain );
57 }
58
59 #a good idea to queue anything that could fail or take any time
60 sub vpopmail_queue {
61   my( $self, $svcnum, $method ) = (shift, shift, shift);
62
63   my $exportdir = "/usr/local/etc/freeside/export." . datasrc;
64   mkdir $exportdir, 0700 or die $! unless -d $exportdir;
65   $exportdir .= "/vpopmail";
66   mkdir $exportdir, 0700 or die $! unless -d $exportdir;
67   $exportdir .= '/'. $self->machine;
68   mkdir $exportdir, 0700 or die $! unless -d $exportdir;
69   mkdir "$exportdir/domains", 0700 or die $! unless -d "$exportdir/domains";
70
71   my $queue = new FS::queue {
72     'svcnum' => $svcnum,
73     'job'    => "FS::part_export::vpopmail::vpopmail_$method",
74   };
75   $queue->insert(
76     $exportdir,
77     $self->machine,
78     $self->option('dir'),
79     $self->option('uid'),
80     $self->option('gid'),
81     $self->option('restart'),
82     @_
83   );
84 }
85
86 sub vpopmail_insert { #subroutine, not method
87   my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
88   my( $username, $password, $domain, $quota, $finger ) = @_;
89
90   mkdir "$exportdir/domains/$domain", 0700 or die $!
91     unless -d "$exportdir/domains/$domain";
92
93   (open(VPASSWD, ">>$exportdir/domains/$domain/vpasswd")
94     and flock(VPASSWD,LOCK_EX)
95   ) or die "can't open vpasswd file for $username\@$domain: ".
96            "$exportdir/domains/$domain/vpasswd: $!";
97   print VPASSWD join(":",
98     $username,
99     $password,
100     '1',
101     '0',
102     $finger,
103     "$dir/domains/$domain/$username",
104     $quota ? $quota.'S' : 'NOQUOTA',
105   ), "\n";
106
107   flock(VPASSWD,LOCK_UN);
108   close(VPASSWD);
109
110   for my $mkdir (
111     grep { ! -d $_ } map { "$exportdir/domains/$domain/$username$_" }
112         ( '', qw( /Maildir /Maildir/cur /Maildir/new /Maildir/tmp ) )
113   ) {
114     mkdir $mkdir, 0700 or die "can't mkdir $mkdir: $!";
115   }
116
117   vpopmail_sync( $exportdir, $machine, $dir, $uid, $gid, $restart );
118
119 }
120
121 sub vpopmail_replace { #subroutine, not method
122   my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
123   my( $username, $password, $domain, $quota, $finger ) = @_;
124   
125   (open(VPASSWD, "$exportdir/domains/$domain/vpasswd")
126     and flock(VPASSWD,LOCK_EX)
127   ) or die "can't open $exportdir/domains/$domain/vpasswd: $!";
128
129   open(VPASSWDTMP, ">$exportdir/domains/$domain/vpasswd.tmp")
130     or die "Can't open $exportdir/domains/$domain/vpasswd.tmp: $!";
131
132   while (<VPASSWD>) {
133     my ($mailbox, $pw, $vuid, $vgid, $vfinger, $vdir, $vquota, @rest) =
134       split(':', $_);
135     if ( $username ne $mailbox ) {
136       print VPASSWDTMP $_;
137       next
138     }
139     print VPASSWDTMP join (':',
140       $mailbox,
141       $password,
142       '1',
143       '0',
144       $finger,
145       "$dir/domains/$domain/$username", #$vdir
146       $quota ? $quota.'S' : 'NOQUOTA',
147     ), "\n";
148   }
149
150   close(VPASSWDTMP);
151
152   rename "$exportdir/domains/$domain/vpasswd.tmp", "$exportdir/domains/$domain/vpasswd"
153     or die "Can't rename $exportdir/domains/$domain/vpasswd.tmp: $!";
154
155   flock(VPASSWD,LOCK_UN);
156   close(VPASSWD);
157
158   vpopmail_sync( $exportdir, $machine, $dir, $uid, $gid, $restart );
159
160 }
161
162 sub vpopmail_delete { #subroutine, not method
163   my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
164   my( $username, $domain ) = @_;
165   
166   (open(VPASSWD, "$exportdir/domains/$domain/vpasswd")
167     and flock(VPASSWD,LOCK_EX)
168   ) or die "can't open $exportdir/domains/$domain/vpasswd: $!";
169
170   open(VPASSWDTMP, ">$exportdir/domains/$domain/vpasswd.tmp")
171     or die "Can't open $exportdir/domains/$domain/vpasswd.tmp: $!";
172
173   while (<VPASSWD>) {
174     my ($mailbox, $rest) = split(':', $_);
175     print VPASSWDTMP $_ unless $username eq $mailbox;
176   }
177
178   close(VPASSWDTMP);
179
180   rename "$exportdir/domains/$domain/vpasswd.tmp",
181          "$exportdir/domains/$domain/vpasswd"
182     or die "Can't rename $exportdir/domains/$domain/vpasswd.tmp: $!";
183
184   flock(VPASSWD,LOCK_UN);
185   close(VPASSWD);
186
187   rmtree "$exportdir/domains/$domain/$username"
188     or die "can't rmtree $exportdir/domains/$domain/$username: $!";
189
190   vpopmail_sync( $exportdir, $machine, $dir, $uid, $gid, $restart );
191 }
192
193 sub vpopmail_sync {
194   my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
195   
196   chdir $exportdir;
197 #  my @args = ( $rsync, "-rlpt", "-e", $ssh, "domains/",
198 #               "vpopmail\@$machine:$dir/domains/"  );
199 #  system {$args[0]} @args;
200
201   eval "use File::Rsync;";
202   die $@ if $@;
203
204   my $rsync = File::Rsync->new({ rsh => 'ssh' });
205
206   $rsync->exec( {
207     recursive => 1,
208     perms     => 1,
209     times     => 1,
210     src       => "$exportdir/domains/",
211     dest      => "vpopmail\@$machine:$dir/domains/",
212   } ); # true/false return value from exec is not working, alas
213   if ( $rsync->err ) {
214     die "error uploading to vpopmail\@$machine:$dir/domains/ : ".
215         'exit status: '. $rsync->status. ', '.
216         'STDERR: '. join(" / ", $rsync->err). ', '.
217         'STDOUT: '. join(" / ", $rsync->out);
218   }
219
220   eval "use Net::SSH;";
221   die $@ if $@;
222
223   ssh("vpopmail\@$machine", $restart) if $restart;
224 }
225
226