- depend on Net::SSH 0.07, for OpenSSH -T fix
[freeside.git] / FS / FS / part_export / www_shellcommands.pm
1 package FS::part_export::www_shellcommands;
2
3 use strict;
4 use vars qw(@ISA);
5 use FS::part_export;
6
7 @ISA = qw(FS::part_export);
8
9 sub rebless { shift; }
10
11 sub _export_insert {
12   my($self) = shift;
13   $self->_export_command('useradd', @_);
14 }
15
16 sub _export_delete {
17   my($self) = shift;
18   $self->_export_command('userdel', @_);
19 }
20
21 sub _export_command {
22   my ( $self, $action, $svc_www) = (shift, shift, shift);
23   my $command = $self->option($action);
24
25   #set variable for the command
26   no strict 'vars';
27   {
28     no strict 'refs';
29     ${$_} = $svc_www->getfield($_) foreach $svc_www->fields;
30   }
31   my $domain_record = $svc_www->domain_record; # or die ?
32   my $zone = $domain_record->reczone; # or die ?
33   unless ( $zone =~ /\.$/ ) {
34     my $svc_domain = $domain_record->svc_domain; # or die ?
35     $zone .= '.'. $svc_domain->domain;
36   }
37
38   my $svc_acct = $svc_www->svc_acct; # or die ?
39   my $username = $svc_acct->username;
40   my $homedir = $svc_acct->dir; # or die ?
41
42   #done setting variables for the command
43
44   $self->shellcommands_queue( $svc_www->svcnum,
45     user         => $self->option('user')||'root',
46     host         => $self->machine,
47     command      => eval(qq("$command")),
48   );
49 }
50
51 sub _export_replace {
52   my($self, $new, $old ) = (shift, shift, shift);
53   my $command = $self->option('usermod');
54   
55   #set variable for the command
56   no strict 'vars';
57   {
58     no strict 'refs';
59     ${"old_$_"} = $old->getfield($_) foreach $old->fields;
60     ${"new_$_"} = $new->getfield($_) foreach $new->fields;
61   }
62   my $old_domain_record = $old->domain_record; # or die ?
63   my $old_zone = $old_domain_record->reczone; # or die ?
64   unless ( $old_zone =~ /\.$/ ) {
65     my $old_svc_domain = $old_domain_record->svc_domain; # or die ?
66     $old_zone .= '.'. $old_svc_domain->domain;
67   }
68
69   my $old_svc_acct = $old->svc_acct; # or die ?
70   my $old_username = $old_svc_acct->username;
71   my $old_homedir = $old_svc_acct->dir; # or die ?
72
73   my $new_domain_record = $new->domain_record; # or die ?
74   my $new_zone = $new_domain_record->reczone; # or die ?
75   unless ( $new_zone =~ /\.$/ ) {
76     my $new_svc_domain = $new_domain_record->svc_domain; # or die ?
77     $new_zone .= '.'. $new_svc_domain->domain;
78   }
79
80   my $new_svc_acct = $new->svc_acct; # or die ?
81   my $new_username = $new_svc_acct->username;
82   my $new_homedir = $new_svc_acct->dir; # or die ?
83
84   #done setting variables for the command
85
86   $self->shellcommands_queue( $new->svcnum,
87     user         => $self->option('user')||'root',
88     host         => $self->machine,
89     command      => eval(qq("$command")),
90   );
91 }
92
93 #a good idea to queue anything that could fail or take any time
94 sub shellcommands_queue {
95   my( $self, $svcnum ) = (shift, shift);
96   my $queue = new FS::queue {
97     'svcnum' => $svcnum,
98     'job'    => "FS::part_export::www_shellcommands::ssh_cmd",
99   };
100   $queue->insert( @_ );
101 }
102
103 sub ssh_cmd { #subroutine, not method
104   use Net::SSH '0.07';
105   &Net::SSH::ssh_cmd( { @_ } );
106 }
107
108 #sub shellcommands_insert { #subroutine, not method
109 #}
110 #sub shellcommands_replace { #subroutine, not method
111 #}
112 #sub shellcommands_delete { #subroutine, not method
113 #}
114