1 package FS::part_export::vpopmail;
3 use vars qw(@ISA %info @saltset $exportdir);
7 use FS::UID qw( datasrc );
10 @ISA = qw(FS::part_export);
12 tie my %options, 'Tie::IxHash',
13 #'machine' => { label=>'vpopmail machine', },
14 'dir' => { label=>'directory', }, # ?more info? default?
15 'uid' => { label=>'vpopmail uid' },
16 'gid' => { label=>'vpopmail gid' },
17 'restart' => { label=> 'vpopmail restart command',
18 default=> 'cd /home/vpopmail/domains; for domain in *; do /home/vpopmail/bin/vmkpasswd $domain; done; /var/qmail/bin/qmail-newu; killall -HUP qmail-send',
24 'desc' => 'Real-time export to vpopmail text files',
25 'options' => \%options,
27 Real time export to <a href="http://inter7.com/vpopmail/">vpopmail</a> text
28 files. <a href="http://search.cpan.org/dist/File-Rsync">File::Rsync</a>
29 must be installed, and you will need to
30 <a href="../docs/ssh.html">setup SSH for unattended operation</a>
31 to <b>vpopmail</b>@<i>export.host</i>. See shellcommands_withdomain for an
32 export that uses vpopmail commands instead.
36 @saltset = ( 'a'..'z' , 'A'..'Z' , '0'..'9' , '.' , '/' );
38 sub rebless { shift; }
41 my($self, $svc_acct) = (shift, shift);
42 $self->vpopmail_queue( $svc_acct->svcnum, 'insert',
44 crypt($svc_acct->_password,$saltset[int(rand(64))].$saltset[int(rand(64))]),
52 my( $self, $new, $old ) = (shift, shift, shift);
54 my $cpassword = crypt(
55 $new->_password, $saltset[int(rand(64))].$saltset[int(rand(64))]
58 return "can't change username with vpopmail"
59 if $old->username ne $new->username;
61 #no.... if mail can't be preserved, better to disallow username changes
62 #if ($old->username ne $new->username || $old->domain ne $new->domain ) {
63 # vpopmail_queue( $svc_acct->svcnum, 'delete',
64 # $old->username, $old->domain
66 # vpopmail_queue( $svc_acct->svcnum, 'insert',
72 return '' unless $old->_password ne $new->_password;
74 $self->vpopmail_queue( $new->svcnum, 'replace',
75 $new->username, $cpassword, $new->domain, $new->quota, $new->finger );
79 my( $self, $svc_acct ) = (shift, shift);
80 $self->vpopmail_queue( $svc_acct->svcnum, 'delete',
81 $svc_acct->username, $svc_acct->domain );
84 #a good idea to queue anything that could fail or take any time
86 my( $self, $svcnum, $method ) = (shift, shift, shift);
88 my $exportdir = "/usr/local/etc/freeside/export." . datasrc;
89 mkdir $exportdir, 0700 or die $! unless -d $exportdir;
90 $exportdir .= "/vpopmail";
91 mkdir $exportdir, 0700 or die $! unless -d $exportdir;
92 $exportdir .= '/'. $self->machine;
93 mkdir $exportdir, 0700 or die $! unless -d $exportdir;
94 mkdir "$exportdir/domains", 0700 or die $! unless -d "$exportdir/domains";
96 my $queue = new FS::queue {
98 'job' => "FS::part_export::vpopmail::vpopmail_$method",
103 $self->option('dir'),
104 $self->option('uid'),
105 $self->option('gid'),
106 $self->option('restart'),
111 sub vpopmail_insert { #subroutine, not method
112 my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
113 my( $username, $password, $domain, $quota, $finger ) = @_;
115 mkdir "$exportdir/domains/$domain", 0700 or die $!
116 unless -d "$exportdir/domains/$domain";
118 (open(VPASSWD, ">>$exportdir/domains/$domain/vpasswd")
119 and flock(VPASSWD,LOCK_EX)
120 ) or die "can't open vpasswd file for $username\@$domain: ".
121 "$exportdir/domains/$domain/vpasswd: $!";
122 print VPASSWD join(":",
128 "$dir/domains/$domain/$username",
129 $quota ? $quota.'S' : 'NOQUOTA',
132 flock(VPASSWD,LOCK_UN);
136 grep { ! -d $_ } map { "$exportdir/domains/$domain/$username$_" }
137 ( '', qw( /Maildir /Maildir/cur /Maildir/new /Maildir/tmp ) )
139 mkdir $mkdir, 0700 or die "can't mkdir $mkdir: $!";
142 vpopmail_sync( $exportdir, $machine, $dir, $uid, $gid, $restart );
146 sub vpopmail_replace { #subroutine, not method
147 my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
148 my( $username, $password, $domain, $quota, $finger ) = @_;
150 (open(VPASSWD, "$exportdir/domains/$domain/vpasswd")
151 and flock(VPASSWD,LOCK_EX)
152 ) or die "can't open $exportdir/domains/$domain/vpasswd: $!";
154 open(VPASSWDTMP, ">$exportdir/domains/$domain/vpasswd.tmp")
155 or die "Can't open $exportdir/domains/$domain/vpasswd.tmp: $!";
158 my ($mailbox, $pw, $vuid, $vgid, $vfinger, $vdir, $vquota, @rest) =
160 if ( $username ne $mailbox ) {
164 print VPASSWDTMP join (':',
170 "$dir/domains/$domain/$username", #$vdir
171 $quota ? $quota.'S' : 'NOQUOTA',
177 rename "$exportdir/domains/$domain/vpasswd.tmp", "$exportdir/domains/$domain/vpasswd"
178 or die "Can't rename $exportdir/domains/$domain/vpasswd.tmp: $!";
180 flock(VPASSWD,LOCK_UN);
183 vpopmail_sync( $exportdir, $machine, $dir, $uid, $gid, $restart );
187 sub vpopmail_delete { #subroutine, not method
188 my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
189 my( $username, $domain ) = @_;
191 (open(VPASSWD, "$exportdir/domains/$domain/vpasswd")
192 and flock(VPASSWD,LOCK_EX)
193 ) or die "can't open $exportdir/domains/$domain/vpasswd: $!";
195 open(VPASSWDTMP, ">$exportdir/domains/$domain/vpasswd.tmp")
196 or die "Can't open $exportdir/domains/$domain/vpasswd.tmp: $!";
199 my ($mailbox, $rest) = split(':', $_);
200 print VPASSWDTMP $_ unless $username eq $mailbox;
205 rename "$exportdir/domains/$domain/vpasswd.tmp",
206 "$exportdir/domains/$domain/vpasswd"
207 or die "Can't rename $exportdir/domains/$domain/vpasswd.tmp: $!";
209 flock(VPASSWD,LOCK_UN);
212 rmtree "$exportdir/domains/$domain/$username"
213 or die "can't rmtree $exportdir/domains/$domain/$username: $!";
215 vpopmail_sync( $exportdir, $machine, $dir, $uid, $gid, $restart );
219 my( $exportdir, $machine, $dir, $uid, $gid, $restart ) = splice @_,0,6;
222 # my @args = ( $rsync, "-rlpt", "-e", $ssh, "domains/",
223 # "vpopmail\@$machine:$dir/domains/" );
224 # system {$args[0]} @args;
226 eval "use File::Rsync;";
229 my $rsync = File::Rsync->new({ rsh => 'ssh' });
235 src => "$exportdir/domains/",
236 dest => "vpopmail\@$machine:$dir/domains/",
237 } ); # true/false return value from exec is not working, alas
239 die "error uploading to vpopmail\@$machine:$dir/domains/ : ".
240 'exit status: '. $rsync->status. ', '.
241 'STDERR: '. join(" / ", $rsync->err). ', '.
242 'STDOUT: '. join(" / ", $rsync->out);
245 eval "use Net::SSH qw(ssh);";
248 ssh("vpopmail\@$machine", $restart) if $restart;