$self->shell,
);
if ( $username && $uid && $dir && $shellmachine && ! $nossh_hack ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::ssh' };
+ my $queue = new FS::queue {
+ 'svcnum' => $self->svcnum,
+ 'job' => 'Net::SSH::ssh_cmd',
+ };
$error = $queue->insert("root\@$shellmachine", eval qq("$useradd") );
if ( $error ) {
$dbh->rollback if $oldAutoCommit;
}
if ( $cyrus_server ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::cyrus_insert' };
+ my $queue = new FS::queue {
+ 'svcnum' => $self->svcnum,
+ 'job' => 'FS::svc_acct::cyrus_insert',
+ };
$error = $queue->insert($self->username, $self->quota);
if ( $error ) {
$dbh->rollback if $oldAutoCommit;
}
if ( $cp_server ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::cp_insert' };
+ my $queue = new FS::queue {
+ 'svcnum' => $self->svcnum,
+ 'job' => 'FS::svc_acct::cp_insert'
+ };
$error = $queue->insert($self->username, $self->_password);
if ( $error ) {
$dbh->rollback if $oldAutoCommit;
if ( $icradius_dbh ) {
my $radcheck_queue =
- new FS::queue { 'job' => 'FS::svc_acct::icradius_rc_insert' };
+ new FS::queue {
+ 'svcnum' => $self->svcnum,
+ 'job' => 'FS::svc_acct::icradius_rc_insert'
+ };
$error = $radcheck_queue->insert( $self->username,
$self->_password,
$self->radius_check
}
my $radreply_queue =
- new FS::queue { 'job' => 'FS::svc_acct::icradius_rr_insert' };
+ new FS::queue {
+ 'svcnum' => $self->svcnum,
+ 'job' => 'FS::svc_acct::icradius_rr_insert'
+ };
$error = $radreply_queue->insert( $self->username,
$self->_password,
$self->radius_reply
Domain => $mydomain,
Timeout => 60,
#Debug => 1,
- ) or die $@;
+ ) or die "$@\n";
$app->create_mailbox(
Mailbox => $username,
Domain => $mydomain,
);
- die $app->message unless $app->ok;
+ die $app->message."\n" unless $app->ok;
}
sub icradius_rc_insert {
$self->dir,
);
if ( $username && $shellmachine && ! $nossh_hack ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::ssh' };
+ my $queue = new FS::queue { 'job' => 'Net::SSH::ssh_cmd' };
$error = $queue->insert("root\@$shellmachine", eval qq("$userdel") );
if ( $error ) {
$dbh->rollback if $oldAutoCommit;
Domain => $mydomain,
Timeout => 60,
#Debug => 1,
- ) or die $@;
+ ) or die "$@\n";
$app->delete_mailbox(
Mailbox => $username,
Domain => $mydomain,
);
- die $app->message unless $app->ok;
+ die $app->message."\n" unless $app->ok;
}
sub icradius_rc_delete {
$new->getfield('gid'),
);
if ( $old_dir && $new_dir && $old_dir ne $new_dir && ! $nossh_hack ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::ssh' };
+ my $queue = new FS::queue {
+ 'svcnum' => $new->svcnum,
+ 'job' => 'Net::SSH::ssh_cmd'
+ };
$error = $queue->insert("root\@$shellmachine", eval qq("$usermod") );
if ( $error ) {
$dbh->rollback if $oldAutoCommit;
}
if ( $cp_server && $old->username ne $new->username ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::cp_rename' };
+ my $queue = new FS::queue {
+ 'svcnum' => $new->svcnum,
+ 'job' => 'FS::svc_acct::cp_rename'
+ };
$error = $queue->insert( $old->username, $new->username );
if ( $error ) {
$dbh->rollback if $oldAutoCommit;
}
if ( $cp_server && $old->_password ne $new->_password ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::cp_change' };
+ my $queue = new FS::queue {
+ 'svcnum' => $new->svcnum,
+ 'job' => 'FS::svc_acct::cp_change'
+ };
$error = $queue->insert( $new->username, $new->_password );
if ( $error ) {
$dbh->rollback if $oldAutoCommit;
}
if ( $icradius_dbh ) {
- my $queue = new FS::queue { 'job' => 'FS::svc_acct::icradius_rc_replace' };
+ my $queue = new FS::queue {
+ 'svcnum' => $new->svcnum,
+ 'job' => 'FS::svc_acct::icradius_rc_replace'
+ };
$error = $queue->insert( $new->username,
$new->_password,
);
}
sub cp_rename {
- my ( $old_username, $new_username );
+ my ( $old_username, $new_username ) = @_;
my $app = new Net::APP ( $cp_server,
User => $cp_user,
Domain => $mydomain,
Timeout => 60,
#Debug => 1,
- ) or die $@;
+ ) or die "$@\n";
$app->rename_mailbox(
Domain => $mydomain,
New_Mailbox => $new_username,
);
- die $app->message unless $app->ok;
+ die $app->message."\n" unless $app->ok;
}
sub cp_change {
- my ( $username, $password );
+ my ( $username, $password ) = @_;
my $app = new Net::APP ( $cp_server,
User => $cp_user,
Domain => $mydomain,
Timeout => 60,
#Debug => 1,
- ) or die $@;
+ ) 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 unless $app->ok;
+ die $app->message."\n" unless $app->ok;
}
$self->cust_svc->seconds_since(@_);
}
-=item ssh
-
-=cut
-
-sub ssh {
- my ( $host, @cmd_and_args ) = @_;
-
- use IO::File;
- my $reader = IO::File->new();
- my $writer = IO::File->new();
- my $error = IO::File->new();
-
- &Net::SSH::sshopen3( $host, $reader, $writer, $error, @cmd_and_args) or die $!;
-
- local $/ = undef;
- my $output_stream = <$writer>;
- my $error_stream = <$error>;
- if ( length $error_stream ) {
- #warn "[FS::svc_acct::ssh] STDERR $error_stream";
- die "[FS::svc_acct::ssh] STDERR $error_stream";
- }
- if ( length $output_stream ) {
- warn "[FS::svc_acct::ssh] STDOUT $output_stream";
- }
-
-# &Net::SSH::ssh(@args,">>/usr/local/etc/freeside/sshoutput 2>&1");
-}
-
=back
=head1 BUGS