3 # Copyright (c) 2015 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;
27 [ 'Config::Tiny', [ ] ],
28 [ 'Digest::MD5', [ qw(md5_hex) ] ],
29 [ 'Fcntl', [ qw(:flock) ] ],
30 [ 'File::Spec::Functions', [ qw(catfile rel2abs) ] ],
31 [ 'FindBin', [ qw($Bin) ] ],
32 [ 'Getopt::Long', [ qw(:config no_auto_abbrev no_ignore_case) ] ],
33 [ 'JSON', [ qw(decode_json) ] ],
34 [ 'LWP::UserAgent', [ ] ],
35 [ 'POSIX', [ qw(strftime) ] ],
36 [ 'Sys::Hostname', [ qw(hostname) ] ],
39 my (@missing, @import);
40 foreach my $module (@modules) {
41 unless (eval "require $module->[0]; 1") {
42 push @missing, $module->[0];
45 unless (eval { $module->[0]->import(@
{$module->[1]}); 1 }) {
46 push @import, $module->[0];
49 if (@missing || @import) {
51 Modules missing: @missing
52 Import failures: @import
60 my $conf_file = catfile
($Bin, 'client.conf');
62 sub _die
{ die "$0: [client] $_[0]" }
66 warn "$_[0]\n" if defined $_[0];
69 -d, --debug server debugging
70 -h, --help this help screen
71 -i, --init initialize session data
72 -l, --list list remote entries
78 GetOptions
(\
%opts, qw(d|debug h|help i|init l|list)) or usage
();
81 usage
('Cannot combine --init and --list') if $opts{i
} && $opts{l
};
83 my $config = Config
::Tiny
->new;
84 $config = Config
::Tiny
->read($conf_file);
86 my $get_config_opts = sub
88 my ($section, $options) = @_;
90 _die
"Section '$section' missing in $conf_file\n" unless exists $config->{$section};
93 @options{@
$options} = @
{$config->{$section}}{@
$options};
95 foreach my $option (@
$options) {
96 _die
"Option '$option' not set in $conf_file\n" unless defined $options{$option} && length $options{$option};
99 return @options{@
$options};
102 my ($hosts_file, $session_file) = map rel2abs
($_, $Bin), $get_config_opts->('path', [ qw(hosts_file session_file) ]);
104 my ($server_url) = $get_config_opts->('url', [ qw(server_url) ]);
105 my ($netz, $name) = $get_config_opts->('data', [ qw(netz name) ]);
107 my $save_session = sub
111 open(my $fh, '>', $session_file) or _die
"Cannot open $session_file for writing: $!\n";
112 print {$fh} "$session\n";
116 my $get_session = sub
118 open(my $fh, '<', $session_file) or _die
"Cannot open $session_file for reading: $!\nPerhaps try running --init\n";
119 chomp(my $session = <$fh>);
125 my $session = $opts{i
} ?
substr(md5_hex
(md5_hex
(time() . {} . rand() . $$)), 0, 32) : $get_session->();
131 debug
=> $opts{d
} || false
,
132 init
=> $opts{i
} || false
,
133 list
=> $opts{l
} || false
,
137 my $ua = LWP
::UserAgent
->new;
139 my $response = $ua->post($server_url, \
%params);
141 if ($response->is_success) {
145 $data = decode_json
($response->decoded_content);
148 die "$0: [server] $data->{error}" if defined $data->{error
};
151 $save_session->($session);
155 IP Name PC Netz Aktualisiert
156 ====================================================================================================
158 foreach my $entry (sort { $a->{netz
} cmp $b->{netz
} } @
{$data->{entries
}}) {
159 my $updated = strftime
'%Y-%m-%d %H:%M:%S', localtime $entry->{time};
161 @
<<<<<<<<<<<<<< @
<<<<<<<<<<<<<< @
<<<<<<<<<<<<<<<<<<< @
<<<<<<<<<<<<<< @
<<<<<<<<<<<<<<<<<<
162 @
$entry{qw(ip name pc netz)}, $updated
169 foreach my $entry (@
{$data->{entries
}}) {
170 my $host = "$entry->{ip}\t" . join '.', @
$entry{qw(name pc netz)};
171 push @
{$list{$entry->{netz
}}}, $host;
174 my $o = tie
my @hosts, 'Tie::File', $hosts_file or _die
"Cannot tie $hosts_file: $!\n";
177 foreach my $network (keys %list) {
179 for (my $i = 0; $i < @hosts; $i++) {
180 if ($hosts[$i] =~ /^\#$network\#$/i) {
181 $indexes{start
} = $i;
183 elsif (exists $indexes{start
} && $hosts[$i] =~ /^\#\/$network\#
$/i
) {
185 my $count = ($indexes{end
} - $indexes{start
} > 1)
186 ?
$indexes{end
} - $indexes{start
} - 1
188 splice @hosts, $indexes{start
} + 1, $count, @
{$list{$network}};
199 warn $response->status_line, "\n";