1 package FS::part_export::broadband_shellcommands;
4 use vars qw(@ISA %info);
8 @ISA = qw(FS::part_export);
10 tie my %options, 'Tie::IxHash',
11 'user' => { label => 'Remote username',
12 default => 'freeside' },
13 'insert' => { label => 'Insert command',
14 default => 'php provision.php --mac=$mac_addr --plan=$plan_id --account=active',
16 'delete' => { label => 'Delete command',
19 'replace' => { label => 'Modification command',
22 'suspend' => { label => 'Suspension command',
23 default => 'php provision.php --mac=$mac_addr --plan=$plan_id --account=suspend',
25 'unsuspend' => { label => 'Unsuspension command',
28 'uppercase_mac' => { label => 'Force MACs to uppercase',
34 'svc' => 'svc_broadband',
35 'desc' => 'Run remote commands via SSH, for svc_broadband services',
36 'options' => \%options,
38 Run remote commands via SSH, for broadband services.
40 All fields in svc_broadband are available for interpolation (prefixed with
41 <code>new_</code> or <code>old_</code> for replace operations).
46 sub rebless { shift; }
50 $self->_export_command('insert', @_);
55 $self->_export_command('delete', @_);
60 $self->_export_command('suspend', @_);
63 sub _export_unsuspend {
65 $self->_export_command('unsuspend', @_);
69 my ( $self, $action, $svc_broadband) = (shift, shift, shift);
70 my $command = $self->option($action);
71 return '' if $command =~ /^\s*$/;
73 #set variables for the command
77 ${$_} = $svc_broadband->getfield($_) foreach $svc_broadband->fields;
80 $mac_addr = uc $mac_addr
81 if $self->option('uppercase_mac');
83 #done setting variables for the command
85 $self->shellcommands_queue( $svc_broadband->svcnum,
86 user => $self->option('user')||'root',
87 host => $self->machine,
88 command => eval(qq("$command")),
93 my($self, $new, $old ) = (shift, shift, shift);
94 my $command = $self->option('replace');
96 #set variable for the command
100 ${"old_$_"} = $old->getfield($_) foreach $old->fields;
101 ${"new_$_"} = $new->getfield($_) foreach $new->fields;
104 if ( $self->option('uppercase_mac') ) {
105 $old_mac_addr = uc $old_mac_addr;
106 $new_mac_addr = uc $new_mac_addr;
109 #done setting variables for the command
111 $self->shellcommands_queue( $new->svcnum,
112 user => $self->option('user')||'root',
113 host => $self->machine,
114 command => eval(qq("$command")),
118 #a good idea to queue anything that could fail or take any time
119 sub shellcommands_queue {
120 my( $self, $svcnum ) = (shift, shift);
121 my $queue = new FS::queue {
123 'job' => "FS::part_export::broadband_shellcommands::ssh_cmd",
125 $queue->insert( @_ );
128 sub ssh_cmd { #subroutine, not method
131 my $ssh = Net::OpenSSH->new($opt->{'user'}.'@'.$opt->{'host'});
132 die "Couldn't establish SSH connection: ". $ssh->error if $ssh->error;
133 my ($output, $errput) = $ssh->capture2($opt->{'command'});
134 die "Error running SSH command: ". $ssh->error if $ssh->error;
135 die $errput if $errput;
136 die $output if $output;