1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
|
package FS::part_export::radiator;
use vars qw(@ISA %info $radusers);
use Tie::IxHash;
use FS::part_export::sqlradius;
tie my %options, 'Tie::IxHash', %FS::part_export::sqlradius::options;
%info = (
'svc' => 'svc_acct',
'desc' => 'Real-time export to RADIATOR',
'options' => \%options,
'nodomain' => '',
'notes' => <<'END',
Real-time export of the <b>radusers</b> table to any SQL database in
<a href="http://www.open.com.au/radiator/">Radiator</a>-native format.
To setup accounting, see the RADIATOR documentation for hooks to update
a standard <b>radacct</b> table.
END
);
@ISA = qw(FS::part_export::sqlradius); #for regular sqlradius accounting
$radusers = 'RADUSERS'; #MySQL is case sensitive about table names! huh
#sub export_username {
# my($self, $svc_acct) = (shift, shift);
# $svc_acct->email;
#}
sub _export_insert {
my( $self, $svc_acct ) = (shift, shift);
$self->radiator_queue(
$svc_acct->svcnum,
'insert',
$self->_radiator_hash($svc_acct),
);
}
sub _export_replace {
my( $self, $new, $old ) = (shift, shift, shift);
# return "can't (yet) change domain with radiator export"
# if $old->domain ne $new->domain;
# return "can't (yet) change username with radiator export"
# if $old->username ne $new->username;
$self->radiator_queue(
$new->svcnum,
'replace',
$self->export_username($old),
$self->_radiator_hash($new),
);
}
sub _export_delete {
my( $self, $svc_acct ) = (shift, shift);
$self->radiator_queue(
$svc_acct->svcnum,
'delete',
$self->export_username($svc_acct),
);
}
sub _radiator_hash {
my( $self, $svc_acct ) = @_;
my %hash = (
'username' => $self->export_username($svc_acct),
'pass_word' => $svc_acct->crypt_password,
'fullname' => $svc_acct->finger,
map { my $method = "radius_$_"; $_ => $svc_acct->$method(); }
qw( framed_filter_id framed_mtu framed_netmask framed_protocol
framed_routing login_host login_service login_tcp_port )
);
$hash{'timeleft'} = $svc_acct->seconds
if $svc_acct->seconds =~ /^\d+$/;
$hash{'staticaddress'} = $svc_acct->slipip
if $svc_acct->slipip =~ /^[\d\.]+$/; # and $self->slipip ne '0.0.0.0';
$hash{'servicename'} = ( $svc_acct->radius_groups )[0];
my $cust_pkg = $svc_acct->cust_svc->cust_pkg;
$hash{'validto'} = $cust_pkg->bill
if $cust_pkg && $cust_pkg->part_pkg->is_prepaid && $cust_pkg->bill;
#some other random stuff, should probably be attributes or virtual fields
#$hash{'state'} = 0; #only inserts
#$hash{'badlogins'} = 0; #only inserts
$hash{'maxlogins'} = 1;
$hash{'addeddate'} = $cust_pkg->setup
if $cust_pkg && $cust_pkg->setup;
$hash{'validfrom'} = $cust_pkg->last_bill || $cust_pkg->setup
if $cust_pkg && ( $cust_pkg->last_bill || $cust_pkg->setup );
$hash{'state'} = $cust_pkg->susp ? 1 : 0
if $cust_pkg;
%hash;
}
sub radiator_queue {
my( $self, $svcnum, $method ) = (shift, shift, shift);
my $queue = new FS::queue {
'svcnum' => $svcnum,
'job' => "FS::part_export::radiator::radiator_$method",
};
$queue->insert(
$self->option('datasrc'),
$self->option('username'),
$self->option('password'),
@_,
); # or $queue;
}
sub radiator_insert { #subroutine, not method
my $dbh = radiator_connect(shift, shift, shift);
my %hash = @_;
$hash{'state'} = 0; #see "random stuff" above
$hash{'badlogins'} = 0; #see "random stuff" above
my $sth = $dbh->prepare(
"INSERT INTO $radusers ( ". join(', ', keys %hash ). ' ) '.
'VALUES ( '. join(', ', map '?', keys %hash ). ' ) '
) or die $dbh->errstr;
$sth->execute( values %hash )
or die $sth->errstr;
$dbh->disconnect;
}
sub radiator_replace { #subroutine, not method
my $dbh = radiator_connect(shift, shift, shift);
my ( $old_username, %hash ) = @_;
my $sth = $dbh->prepare(
"UPDATE $radusers SET ". join(', ', map " $_ = ?", keys %hash ).
' WHERE username = ?'
) or die $dbh->errstr;
$sth->execute( values(%hash), $old_username )
or die $sth->errstr;
$dbh->disconnect;
}
sub radiator_delete { #subroutine, not method
my $dbh = radiator_connect(shift, shift, shift);
my ( $username ) = @_;
my $sth = $dbh->prepare(
"DELETE FROM $radusers WHERE username = ?"
) or die $dbh->errstr;
$sth->execute( $username )
or die $sth->errstr;
$dbh->disconnect;
}
sub radiator_connect {
#my($datasrc, $username, $password) = @_;
#DBI->connect($datasrc, $username, $password) or die $DBI::errstr;
DBI->connect(@_) or die $DBI::errstr;
}
1;
|
