lib/PXElator/client.pm

package client;

use warnings;
use strict;
use autodie;

use File::Slurp;
use Net::Ping;
use Carp qw/confess/;

use server;
use format;

sub mkbasedir {
        my $path = shift;
        $path =~ s{(^.*)/[^/]+$}{$1};
        mkdir $path unless -d $path;
        return $path;
}

sub mac_path { $server::conf . '/mac/' . $_[0] }
sub  ip_path { $server::conf . '/ip/'  . join('/', @_) }
sub conf_value {
        my $path = shift;
        my $value;
        if ( -l $path ) {
                $value = readlink $path;
                $value =~ s{.*/([^/]+)$}{$1};
        } elsif ( -f $path ) {
                $value = read_file $path;
        } else {
                confess "$path not file or symlink";
        }
        return $value;
}

sub conf {
        my $ip  = shift;
        my $name = shift;
        my ( $default, $value );
        if ( $#_ == 0 ) {
                $value = shift;
        } elsif ( $#_ == 1 && $_[0] eq 'default' ) {
                $default = $_[1]
        }

        my $path = ip_path $ip;
        mkdir $path unless -d $path;
        $path .= '/' . $name;

        if ( defined $value ) {
                mkbasedir  $path;
                write_file $path, $value;
                warn "update $path = $value";
        } elsif ( ! -e $path && defined $default ) {
                mkbasedir  $path;
                write_file $path, $default;
                warn "default $path = $default";
                $value = $default;
        } elsif ( -f $path ) {
                $value = read_file $path;
        } else {
                confess "conf $name";
        }
        return $value;
}

sub next_ip($) {
        my $mac = shift;

        my $p = Net::Ping->new;

        my $prefix = $server::ip;
        $prefix =~ s{\.\d+$}{.};
        my $addr = $server::ip_from || die;
        my $ip = $prefix . $addr;

        while ( -e ip_path($ip) || $p->ping( $ip, 0.7 ) ) {
                $ip = $prefix . $addr++;
                die "all addresses allocated!" if $addr == $server::ip_to;
                warn "skip $ip\n";
        }

        warn "next_ip $ip\n";

        mkdir ip_path($ip);

        my $mac_path = mac_path($mac);
        unlink $mac_path if -e $mac_path;       # XXX audit?
        symlink ip_path($ip), $mac_path;
        write_file ip_path($ip,'mac'), $mac;

        return $ip;

}

sub ip_from_mac($) {
        my $mac = shift;

        $mac = lc $mac;
        $mac =~ s{:}{}g;

        my $mac_path = mac_path $mac;
        return unless -e $mac_path;

        my $ip;

        if ( -f $mac_path ) {
                $ip = read_file $mac_path;
                unlink $mac_path;
                symlink ip_path($ip), $mac_path;
                warn "I: upgrade to mac symlink $mac_path\n";
        } elsif ( -l $mac_path ) {
                $ip = conf_value $mac_path;
        } else {
                die "$mac_path not file or symlink";
        }

        return $ip;
}

sub mac_from_ip($) {
        my $ip = shift;
        conf_value ip_path($ip, 'mac');
}

sub change_ip($$) {
        my ($old, $new) = @_;
        my $mac = mac_from_ip($old);
        rename ip_path($old), ip_path($new);
        unlink mac_path($mac);
        symlink ip_path($new), mac_path($mac);
}

1;
1	dpavlin	156	package client;
2
3			use warnings;
4			use strict;
5			use autodie;
6
7			use File::Slurp;
8	dpavlin	168	use Net::Ping;
9	dpavlin	219	use Carp qw/confess/;
10
11			use server;
12	dpavlin	208	use format;
13	dpavlin	156
14	dpavlin	219	sub mkbasedir {
15			my $path = shift;
16			$path =~ s{(^.*)/[^/]+$}{$1};
17			mkdir $path unless -d $path;
18			return $path;
19			}
20
21	dpavlin	200	sub mac_path { $server::conf . '/mac/' . $_[0] }
22			sub ip_path { $server::conf . '/ip/' . join('/', @_) }
23	dpavlin	219	sub conf_value {
24			my $path = shift;
25			my $value;
26			if ( -l $path ) {
27			$value = readlink $path;
28			$value =~ s{.*/([^/]+)$}{$1};
29			} elsif ( -f $path ) {
30			$value = read_file $path;
31			} else {
32			confess "$path not file or symlink";
33			}
34			return $value;
35			}
36	dpavlin	200
37	dpavlin	156	sub conf {
38			my $ip = shift;
39			my $name = shift;
40			my ( $default, $value );
41			if ( $#_ == 0 ) {
42			$value = shift;
43			} elsif ( $#_ == 1 && $_[0] eq 'default' ) {
44			$default = $_[1]
45			}
46
47	dpavlin	200	my $path = ip_path $ip;
48	dpavlin	156	mkdir $path unless -d $path;
49			$path .= '/' . $name;
50
51			if ( defined $value ) {
52	dpavlin	219	mkbasedir $path;
53	dpavlin	156	write_file $path, $value;
54			warn "update $path = $value";
55			} elsif ( ! -e $path && defined $default ) {
56	dpavlin	219	mkbasedir $path;
57	dpavlin	156	write_file $path, $default;
58			warn "default $path = $default";
59			$value = $default;
60	dpavlin	219	} elsif ( -f $path ) {
61			$value = read_file $path;
62			} else {
63			confess "conf $name";
64	dpavlin	156	}
65			return $value;
66			}
67
68	dpavlin	200	sub next_ip($) {
69			my $mac = shift;
70	dpavlin	168
71			my $p = Net::Ping->new;
72
73			my $prefix = $server::ip;
74			$prefix =~ s{\.\d+$}{.};
75			my $addr = $server::ip_from \|\| die;
76			my $ip = $prefix . $addr;
77
78	dpavlin	200	while ( -e ip_path($ip) \|\| $p->ping( $ip, 0.7 ) ) {
79	dpavlin	168	$ip = $prefix . $addr++;
80			die "all addresses allocated!" if $addr == $server::ip_to;
81			warn "skip $ip\n";
82			}
83
84			warn "next_ip $ip\n";
85	dpavlin	200
86			mkdir ip_path($ip);
87
88	dpavlin	217	my $mac_path = mac_path($mac);
89			unlink $mac_path if -e $mac_path; # XXX audit?
90			symlink ip_path($ip), $mac_path;
91	dpavlin	200	write_file ip_path($ip,'mac'), $mac;
92
93	dpavlin	168	return $ip;
94
95			}
96
97	dpavlin	200	sub ip_from_mac($) {
98	dpavlin	194	my $mac = shift;
99
100			$mac = lc $mac;
101			$mac =~ s{:}{}g;
102
103	dpavlin	200	my $mac_path = mac_path $mac;
104	dpavlin	194	return unless -e $mac_path;
105
106			my $ip;
107
108			if ( -f $mac_path ) {
109			$ip = read_file $mac_path;
110			unlink $mac_path;
111	dpavlin	200	symlink ip_path($ip), $mac_path;
112	dpavlin	194	warn "I: upgrade to mac symlink $mac_path\n";
113			} elsif ( -l $mac_path ) {
114	dpavlin	219	$ip = conf_value $mac_path;
115	dpavlin	194	} else {
116			die "$mac_path not file or symlink";
117			}
118
119			return $ip;
120			}
121
122	dpavlin	200	sub mac_from_ip($) {
123			my $ip = shift;
124	dpavlin	219	conf_value ip_path($ip, 'mac');
125	dpavlin	200	}
126
127			sub change_ip($$) {
128			my ($old, $new) = @_;
129			my $mac = mac_from_ip($old);
130			rename ip_path($old), ip_path($new);
131			unlink mac_path($mac);
132			symlink ip_path($new), mac_path($mac);
133			}
134
135	dpavlin	156	1;