]>
git.refcnt.org Git - distdns.git/blob - client.pl
3 # Copyright (c) 2013 Michel Ketterle, Steven Schubiger
5 # This file is part of distdns.
7 # distdns is free software: you can redistribute it and/or modify
8 # it under the terms of the GNU General Public License as published by
9 # the Free Software Foundation, either version 3 of the License, or
10 # (at your option) any later version.
12 # distdns is distributed in the hope that it will be useful,
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 # GNU General Public License for more details.
17 # You should have received a copy of the GNU General Public License
18 # along with distdns. If not, see <http://www.gnu.org/licenses/>.
22 use constant false
=> 0;
25 use Digest
::MD5
qw(md5_hex);
27 use File
::Spec
::Functions
qw(catfile rel2abs);
29 use Getopt::Long qw(:config no_auto_abbrev no_ignore_case);
30 use JSON
qw(decode_json);
32 use Sys
::Hostname
qw(hostname);
37 my $conf_file = catfile
($Bin, 'client.conf');
39 sub _die
{ die "$0: [client] $_[0]" }
45 -d, --debug server debugging
46 -h, --help this help screen
47 -i, --init initialize session data
48 -l, --list list remote entries
54 GetOptions
(\
%opts, qw(d|debug h|help i|init l|list)) or usage
();
57 my $config = Config
::Tiny
->new;
58 $config = Config
::Tiny
->read($conf_file);
60 my $get_config_opts = sub
62 my ($section, $options) = @_;
64 _die
"Section '$section' missing in $conf_file\n" unless exists $config->{$section};
67 @options{@
$options} = @
{$config->{$section}}{@
$options};
69 foreach my $option (@
$options) {
70 _die
"Option '$option' not set in $conf_file\n" unless defined $options{$option} && length $options{$option};
73 return @options{@
$options};
76 my ($hosts_file, $session_file) = map rel2abs
($_, $Bin), $get_config_opts->('path', [ qw(hosts_file session_file) ]);
78 my ($server_url) = $get_config_opts->('url', [ qw(server_url) ]);
79 my ($netz, $name) = $get_config_opts->('data', [ qw(netz name) ]);
81 my $save_session = sub
85 open(my $fh, '>', $session_file) or _die
"Cannot open $session_file for writing: $!\n";
86 print {$fh} "$session\n";
92 open(my $fh, '<', $session_file) or _die
"Cannot open $session_file for reading: $!\nPerhaps try running --init\n";
93 my $session = do { local $/; <$fh> };
100 my $session = $opts{i
} ?
substr(md5_hex
(md5_hex
(time() . {} . rand() . $$)), 0, 32) : $get_session->();
106 debug
=> $opts{d
} || false
,
107 init
=> $opts{i
} || false
,
108 list
=> $opts{l
} || false
,
112 my $ua = LWP
::UserAgent
->new;
114 my $response = $ua->post($server_url, \
%params);
116 if ($response->is_success) {
120 $data = decode_json
($response->decoded_content);
123 die "$0: [server] $data->{error}" if defined $data->{error
};
125 $save_session->($session) if $opts{i
};
130 =============================================================================
132 foreach my $entry (sort { $a->{netz
} cmp $b->{netz
} } @
{$data->{entries
}}) {
134 @
<<<<<<<<<<<<<< @
<<<<<<<<<<<<<< @
<<<<<<<<<<<<<<<<<<< @
<<<<<<<<<<<<<<
135 @
$entry{qw(ip name pc netz)}
143 foreach my $entry (@
{$data->{entries
}}) {
144 my $host = "$entry->{ip}\t" . join '.', @
$entry{qw(name pc netz)};
145 push @
{$list{$entry->{netz
}}}, $host;
148 my $o = tie
my @hosts, 'Tie::File', $hosts_file or _die
"Cannot tie $hosts_file: $!\n";
151 foreach my $network (keys %list) {
153 for (my $i = 0; $i < @hosts; $i++) {
154 if ($hosts[$i] =~ /^\#$network\#$/i) {
155 $indexes{start
} = $i;
157 elsif (exists $indexes{start
} && $hosts[$i] =~ /^\#\/$network\#
$/i
) {
159 my $count = ($indexes{end
} - $indexes{start
} > 1)
160 ?
$indexes{end
} - $indexes{start
} - 1
162 splice @hosts, $indexes{start
} + 1, $count, @
{$list{$network}};
172 warn $response->status_line, "\n";