X-Git-Url: http://git.freeside.biz/gitweb/?p=freeside.git;a=blobdiff_plain;f=fs_signup%2Ffs_signup_server;h=77f7f3056430396b0a0f2f7461f5ee61336bbbbf;hp=cb0e693dd3a1d318517d4537d209f6ccd0655852;hb=8fc4118f1f055195d280b3250b39a3b5fcdf13dc;hpb=971e4ca0af5a6adbc8c724c9dff12cf8edf93dd9 diff --git a/fs_signup/fs_signup_server b/fs_signup/fs_signup_server index cb0e693dd..77f7f3056 100755 --- a/fs_signup/fs_signup_server +++ b/fs_signup/fs_signup_server @@ -1,77 +1,148 @@ #!/usr/bin/perl -Tw # -# fs_passwd_server +# fs_signup_server # -# portions of this script are copied from the `passwd' script in the original -# (perl 4) camel book, now archived at -# http://www.perl.com/CPAN/scripts/nutshell/ch6/passwd -# -# ivan@sisd.com 98-mar-9 -# -# crypt-aware, s/password/_password/; ivan@sisd.com 98-aug-23 use strict; use IO::Handle; -use FS::SSH qw(sshopen2); +use Storable qw(nstore_fd fd_retrieve); +use Tie::RefHash; +use Net::SSH qw(sshopen2); use FS::UID qw(adminsuidsetup); -use FS::Record qw(qsearchs); -use FS::svc_acct; +use FS::Record qw( qsearch qsearchs ); +use FS::cust_main_county; +use FS::cust_main; + +use vars qw( $opt $Debug ); + +$Debug = 2; + +my @payby = qw(CARD PREPAY); my $user = shift or die &usage; -adminsuidsetup $user; +&adminsuidsetup( $user ); + +my $machine = shift or die &usage; -my($shellmachine)=shift or die &usage; +my $agentnum = shift or die &usage; +my $agent = qsearchs( 'agent', { 'agentnum' => $agentnum } ) or die &usage; +my $pkgpart_href = $agent->pkgpart_hashref; -$SIG{CHLD} = sub { wait() }; +my $refnum = shift or die &usage; -my($fs_passwdd)="/usr/local/sbin/fs_passwdd"; +#causing trouble for some folks +#$SIG{CHLD} = sub { wait() }; + +my($fs_signupd)="/usr/local/sbin/fs_signupd"; while (1) { my($reader,$writer)=(new IO::Handle, new IO::Handle); - $writer->autoflush(1); - sshopen2($shellmachine,$reader,$writer,$fs_passwdd); + #seems to be broken - calling ->flush explicitly# $writer->autoflush(1); + warn "[fs_signup_server] Connecting to $machine...\n" if $Debug; + sshopen2($machine,$reader,$writer,$fs_signupd); + + my $init_data = { + + #'_protocol' => 'signup', + #'_version' => '0.1', + #'_packet' => 'init' + + 'cust_main_county' => + [ map { $_->hashref } qsearch('cust_main_county', {}) ], + + 'part_pkg' => + [ + map { $_->hashref } + grep { $_->svcpart('svc_acct') && $pkgpart_href->{ $_->pkgpart } } + qsearch( 'part_pkg', { 'disabled' => '' } ) + ], + + 'svc_acct_pop' => [ map { $_->hashref } qsearch ('svc_acct_pop',{} ) ], + + }; + + warn "[fs_signup_server] Sending init data...\n" if $Debug; + nstore_fd($init_data, $writer) or die "can't send init data: $!"; + $writer->flush; + + warn "[fs_signup_server] Entering main loop...\n" if $Debug; while (1) { - my($username,$old_password,$new_password,$new_gecos,$new_shell); - defined($username=<$reader>) or last; - defined($old_password=<$reader>) or last; - defined($new_password=<$reader>) or last; - defined($new_gecos=<$reader>) or last; - defined($new_shell=<$reader>) or last; - chop($username); - chop($old_password); - chop($new_password); - chop($new_gecos); - chop($new_shell); - my($svc_acct); - - #need to try both $old_password and encrypted $old_password - #maybe the crypt function in svc_acct.export needs to be a library? - my $salt = substr($old_password,0,2); - my $cold_password = crypt($old_password,$salt); - $svc_acct=qsearchs('svc_acct',{'username'=>$username, - '_password'=>$old_password, - } ) - || qsearchs('svc_acct',{'username'=>$username, - '_password'=>$cold_password, + warn "[fs_signup_server] Reading (waiting for) signup data...\n" if $Debug; + my $signup_data = fd_retrieve($reader); + + if ( $Debug > 1 ) { + warn join('', + map { " $_ => ". $signup_data->{$_}. "\n" } keys %$signup_data ); + } + + warn "[fs_signup_server] Processing signup...\n" if $Debug; + + my $error = ''; + + #shares some stuff with htdocs/edit/process/cust_main.cgi... take any + # common that are still here and library them. + my $cust_main = new FS::cust_main ( { + #'custnum' => '', + 'agentnum' => $agentnum, + 'refnum' => $refnum, + + map { $_ => $signup_data->{$_} } qw( + last first ss company address1 address2 city county state zip country + daytime night fax payby payinfo paydate payname referral_custnum + ), + + } ); + + $error = "Illegal payment type" + unless grep { $_ eq $signup_data->{'payby'} } @payby; + + my @invoicing_list = split( /\s*\,\s*/, $signup_data->{'invoicing_list'} ); + + my $part_pkg = + qsearchs( 'part_pkg', { 'pkgpart' => $signup_data->{'pkgpart'} } ) + or $error ||= "WARNING: unknown pkgpart ". $signup_data->{pkgpart}; + my $svcpart = $part_pkg->svcpart unless $error; + + # this should wind up in FS::cust_pkg! + my $agent = qsearchs( 'agent', { 'agentnum' => $agentnum } ); + #my $pkgpart_href = $agent->pkgpart_hashref; + $error ||= "WARNING: agent $agentnum can't purchase pkgpart ". + $signup_data->{pkgpart} + unless $pkgpart_href->{ $signup_data->{pkgpart} }; + + my $cust_pkg = new FS::cust_pkg ( { + #later#'custnum' => $custnum, + 'pkgpart' => $signup_data->{'pkgpart'}, + } ); + $error ||= $cust_pkg->check; + + my $svc_acct = new FS::svc_acct ( { + 'svcpart' => $svcpart, + map { $_ => $signup_data->{$_} } qw( username _password popnum ), } ); - unless ( $svc_acct ) { print $writer "Incorrect password.\n"; next; } - - my(%hash)=$svc_acct->hash; - my($new_svc_acct) = new FS::svc_acct ( \%hash ); - $new_svc_acct->setfield('_password',$new_password) - if $new_password && $new_password ne $old_password; - $new_svc_acct->setfield('finger',$new_gecos) if $new_gecos; - $new_svc_acct->setfield('shell',$new_shell) if $new_shell; - my($error)=$new_svc_acct->replace($svc_acct); - print $writer $error,"\n"; + + my $y = $svc_acct->setdefault; # arguably should be in new method + $error ||= $y unless ref($y); + + $error ||= $svc_acct->check; + + use Tie::RefHash; + tie my %hash, 'Tie::RefHash'; + %hash = ( $cust_pkg => [ $svc_acct ] ); + $error ||= $cust_main->insert( \%hash, \@invoicing_list ); + + warn "[fs_signup_server] Sending results...\n" if $Debug; + print $writer $error, "\n"; + } close $writer; close $reader; + warn "connection to $machine lost! waiting 60 seconds...\n"; sleep 60; - warn "Connection to $shellmachine lost! Reconnecting...\n"; + warn "reconnecting...\n"; } sub usage { - die "Usage:\n\n fs_passwd_server user shellmachine\n"; + die "Usage:\n\n fs_signup_server user machine agentnum refnum\n"; }