factor out main Dancer app to packages
This commit is contained in:
Oliver Gorwits
@@ -4,385 +4,17 @@ use Dancer ':syntax';
|
||||
use Dancer::Plugin::Ajax;
|
||||
use Dancer::Plugin::DBIC;
|
||||
|
||||
use Digest::MD5 ();
|
||||
use Socket6 (); # to ensure dependency is met
|
||||
use HTML::Entities (); # to ensure dependency is met
|
||||
use NetAddr::IP::Lite ':lower';
|
||||
use Net::MAC ();
|
||||
use List::MoreUtils ();
|
||||
use netdisco (); # for sort_port
|
||||
|
||||
hook 'before' => sub {
|
||||
if (! session('user') && request->path !~ m{^/login}) {
|
||||
if (setting('environment') eq 'development') {
|
||||
session(user => 'developer');
|
||||
}
|
||||
else {
|
||||
var(requested_path => request->path);
|
||||
request->path_info('/');
|
||||
}
|
||||
}
|
||||
|
||||
# make hash lookups of query lists
|
||||
foreach my $opt (qw/model vendor os_ver/) {
|
||||
my $p = (ref [] eq ref param($opt) ? param($opt) : (param($opt) ? [param($opt)] : []));
|
||||
var("${opt}_lkp" => { map { $_ => 1 } @$p });
|
||||
}
|
||||
|
||||
# list of port detail columns
|
||||
var('port_columns' => [
|
||||
{ name => 'c_port', label => 'Port', default => 'on' },
|
||||
{ name => 'c_descr', label => 'Description', default => '' },
|
||||
{ name => 'c_type', label => 'Type', default => '' },
|
||||
{ name => 'c_duplex', label => 'Duplex', default => '' },
|
||||
{ name => 'c_lastchange', label => 'Last Change', default => '' },
|
||||
{ name => 'c_name', label => 'Name', default => 'on' },
|
||||
{ name => 'c_speed', label => 'Speed', default => '' },
|
||||
{ name => 'c_mac', label => 'Port MAC', default => '' },
|
||||
{ name => 'c_mtu', label => 'MTU', default => '' },
|
||||
{ name => 'c_vlan', label => 'Native VLAN', default => 'on' },
|
||||
{ name => 'c_vmember', label => 'VLAN Membership', default => 'on' },
|
||||
{ name => 'c_connected', label => 'Connected Devices', default => 'on' },
|
||||
{ name => 'c_stp', label => 'Spanning Tree', default => '' },
|
||||
{ name => 'c_up', label => 'Status', default => '' },
|
||||
]);
|
||||
|
||||
# view settings for port connected devices
|
||||
var('connected_properties' => [
|
||||
{ name => 'n_age', label => 'Age Stamp', default => '' },
|
||||
{ name => 'n_ip', label => 'IP Address', default => 'on' },
|
||||
{ name => 'n_archived', label => 'Archived Data', default => '' },
|
||||
]);
|
||||
|
||||
# set up default search options for each type
|
||||
if (request->path =~ m{^/device}) {
|
||||
if (not param('tab') or param('tab') ne 'ports' or scalar keys %{params()} < 4) {
|
||||
foreach my $col (@{ var('port_columns') }) {
|
||||
params->{$col->{name}} = 'checked' if $col->{default} eq 'on';
|
||||
}
|
||||
foreach my $col (@{ var('connected_properties') }) {
|
||||
params->{$col->{name}} = 'checked' if $col->{default} eq 'on';
|
||||
}
|
||||
params->{'age_num'} = 3;
|
||||
params->{'age_unit'} = 'months';
|
||||
}
|
||||
} elsif (request->path =~ m{^/search}) {
|
||||
if (not param('tab') or param('tab') ne 'node') {
|
||||
params->{'stamps'} = 'checked';
|
||||
}
|
||||
if (not param('tab') or param('tab') ne 'device') {
|
||||
params->{'matchall'} = 'checked';
|
||||
}
|
||||
}
|
||||
|
||||
# set up query string defaults for hyperlinks to templates with forms
|
||||
var('query_defaults' => { map { ($_ => "tab=$_") } qw/node device/ });
|
||||
|
||||
var('query_defaults')->{node} .= "\&$_=". (param($_) || '')
|
||||
for qw/stamps vendor archived partial/;
|
||||
var('query_defaults')->{device} .= "\&$_=". (param($_) || '')
|
||||
for qw/matchall/;
|
||||
};
|
||||
|
||||
ajax '/ajax/content/device/:thing' => sub {
|
||||
return "<p>Hello, this is where the ". param('thing') ." content goes.</p>";
|
||||
};
|
||||
|
||||
# device interface addresses
|
||||
ajax '/ajax/content/device/addresses' => sub {
|
||||
my $ip = param('ip');
|
||||
return unless $ip;
|
||||
|
||||
my $set = schema('netdisco')->resultset('DeviceIp')->search({ip => $ip}, { order_by => 'alias' });
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/device/addresses.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# device ports with a description (er, name) matching
|
||||
ajax '/ajax/content/device/ports' => sub {
|
||||
my $ip = param('ip');
|
||||
return unless $ip;
|
||||
|
||||
my $set = schema('netdisco')->resultset('DevicePort')->by_ip($ip);
|
||||
|
||||
# refine by ports if requested
|
||||
my $q = param('q');
|
||||
if ($q) {
|
||||
if ($q =~ m/^\d+$/) {
|
||||
$set = $set->by_vlan($q);
|
||||
}
|
||||
else {
|
||||
my $c = schema('netdisco')->resultset('DevicePort')->by_ip($ip)->by_port($q);
|
||||
if ($c->count) {
|
||||
$set = $set->by_port($q);
|
||||
}
|
||||
else {
|
||||
$set = $set->by_name($q);
|
||||
}
|
||||
}
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
# sort, and filter by free ports
|
||||
# the filter could be in the template but here allows a 'no records' msg
|
||||
my $results = [ sort { &netdisco::sort_port($a->port, $b->port) }
|
||||
grep { not param('free')
|
||||
or $_->is_free(param('age_num'), param('age_unit')) } $set->all ];
|
||||
|
||||
return unless scalar @$results;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/device/ports.tt', {
|
||||
results => $results,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# device details table
|
||||
ajax '/ajax/content/device/details' => sub {
|
||||
my $ip = param('ip');
|
||||
return unless $ip;
|
||||
|
||||
my $device = schema('netdisco')->resultset('Device')->find($ip);
|
||||
return unless $device;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/device/details.tt', {
|
||||
d => $device,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
get '/device' => sub {
|
||||
my $ip = NetAddr::IP::Lite->new(param('ip'));
|
||||
if (! $ip) {
|
||||
redirect '/?nosuchdevice=1';
|
||||
return;
|
||||
}
|
||||
|
||||
my $device = schema('netdisco')->resultset('Device')->find($ip->addr);
|
||||
if (! $device) {
|
||||
redirect '/?nosuchdevice=1';
|
||||
return;
|
||||
}
|
||||
|
||||
# list of tabs
|
||||
var('tabs' => [
|
||||
{ id => 'details', label => 'Details' },
|
||||
{ id => 'ports', label => 'Ports' },
|
||||
{ id => 'modules', label => 'Modules' },
|
||||
{ id => 'addresses', label => 'Addresses' },
|
||||
]);
|
||||
|
||||
params->{'tab'} ||= 'details';
|
||||
template 'device', { d => $device };
|
||||
};
|
||||
|
||||
# device with various properties or a default match-all
|
||||
ajax '/ajax/content/search/device' => sub {
|
||||
my $has_opt = List::MoreUtils::any {param($_)}
|
||||
qw/name location dns ip description model os_ver vendor/;
|
||||
my $set;
|
||||
|
||||
if ($has_opt) {
|
||||
$set = schema('netdisco')->resultset('Device')->by_field(scalar params);
|
||||
}
|
||||
else {
|
||||
my $q = param('q');
|
||||
return unless $q;
|
||||
|
||||
$set = schema('netdisco')->resultset('Device')->by_any($q);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/search/device.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# nodes matching the param as an IP or DNS hostname or MAC
|
||||
ajax '/ajax/content/search/node' => sub {
|
||||
my $node = param('q');
|
||||
return unless $node;
|
||||
content_type('text/html');
|
||||
|
||||
my $mac = Net::MAC->new(mac => $node, 'die' => 0, verbose => 0);
|
||||
if (eval { $mac->as_IEEE }) {
|
||||
|
||||
my $sightings = schema('netdisco')->resultset('Node')
|
||||
->by_mac(param('archived'), $mac->as_IEEE);
|
||||
|
||||
my $ips = schema('netdisco')->resultset('NodeIp')
|
||||
->by_mac(param('archived'), $mac->as_IEEE);
|
||||
|
||||
my $ports = schema('netdisco')->resultset('DevicePort')
|
||||
->by_mac($mac->as_IEEE);
|
||||
|
||||
return unless $sightings->count
|
||||
or $ips->count
|
||||
or $ports->count;
|
||||
|
||||
template 'ajax/search/node_by_mac.tt', {
|
||||
ips => $ips,
|
||||
sightings => $sightings,
|
||||
ports => $ports,
|
||||
}, { layout => undef };
|
||||
}
|
||||
else {
|
||||
my $set;
|
||||
|
||||
if (my $ip = NetAddr::IP::Lite->new($node)) {
|
||||
# by_ip() will extract cidr notation if necessary
|
||||
$set = schema('netdisco')->resultset('NodeIp')
|
||||
->by_ip(param('archived'), $ip);
|
||||
}
|
||||
else {
|
||||
$node = "\%$node\%" if param('partial');
|
||||
$set = schema('netdisco')->resultset('NodeIp')
|
||||
->by_name(param('archived'), $node);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
template 'ajax/search/node_by_ip.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
}
|
||||
};
|
||||
|
||||
# devices carrying vlan xxx
|
||||
ajax '/ajax/content/search/vlan' => sub {
|
||||
my $vlan = param('q');
|
||||
return unless $vlan;
|
||||
my $set;
|
||||
|
||||
if ($vlan =~ m/^\d+$/) {
|
||||
$set = schema('netdisco')->resultset('Device')->carrying_vlan($vlan);
|
||||
}
|
||||
else {
|
||||
$set = schema('netdisco')->resultset('Device')->carrying_vlan_name($vlan);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/search/vlan.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# device ports with a description (er, name) matching
|
||||
ajax '/ajax/content/search/port' => sub {
|
||||
my $q = param('q');
|
||||
return unless $q;
|
||||
my $set;
|
||||
|
||||
if ($q =~ m/^\d+$/) {
|
||||
$set = schema('netdisco')->resultset('DevicePort')->by_vlan($q);
|
||||
}
|
||||
else {
|
||||
$set = schema('netdisco')->resultset('DevicePort')->by_name($q);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/search/port.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
use Netdisco::Web::AuthN;
|
||||
use Netdisco::Web::Search;
|
||||
use Netdisco::Web::Device;
|
||||
|
||||
get '/' => sub {
|
||||
template 'index';
|
||||
};
|
||||
|
||||
get '/search' => sub {
|
||||
# set up property lists for device search
|
||||
var('model_list' => [
|
||||
schema('netdisco')->resultset('Device')->get_distinct('model')
|
||||
]);
|
||||
var('os_ver_list' => [
|
||||
schema('netdisco')->resultset('Device')->get_distinct('os_ver')
|
||||
]);
|
||||
var('vendor_list' => [
|
||||
schema('netdisco')->resultset('Device')->get_distinct('vendor')
|
||||
]);
|
||||
|
||||
my $q = param('q');
|
||||
if ($q and not param('tab')) {
|
||||
# pick most likely tab for initial results
|
||||
if ($q =~ m/^\d+$/) {
|
||||
params->{'tab'} = 'vlan';
|
||||
}
|
||||
else {
|
||||
my $s = schema('netdisco');
|
||||
if ($q =~ m{^[a-f0-9.:/]+$}i) {
|
||||
if (NetAddr::IP::Lite->new($q) and
|
||||
$s->resultset('Device')->find($q)) {
|
||||
params->{'tab'} = 'device';
|
||||
}
|
||||
else {
|
||||
# this will match for MAC addresses
|
||||
# and partial IPs (subnets?)
|
||||
params->{'tab'} = 'node';
|
||||
}
|
||||
}
|
||||
else {
|
||||
if ($s->resultset('Device')->search({
|
||||
dns => { '-ilike' => "\%$q\%" },
|
||||
})->count) {
|
||||
params->{'tab'} = 'device';
|
||||
}
|
||||
elsif ($s->resultset('NodeIp')->search({
|
||||
dns => { '-ilike' => "\%$q\%" },
|
||||
})->count) {
|
||||
params->{'tab'} = 'node';
|
||||
}
|
||||
elsif ($s->resultset('DevicePort')->search({
|
||||
name => { '-ilike' => "\%$q\%" },
|
||||
})->count) {
|
||||
params->{'tab'} = 'port';
|
||||
}
|
||||
}
|
||||
params->{'tab'} ||= 'device';
|
||||
}
|
||||
}
|
||||
elsif (not $q) {
|
||||
redirect '/';
|
||||
return;
|
||||
}
|
||||
|
||||
# list of tabs
|
||||
var('tabs' => [
|
||||
{ id => 'device', label => 'Device' },
|
||||
{ id => 'node', label => 'Node' },
|
||||
{ id => 'vlan', label => 'VLAN' },
|
||||
{ id => 'port', label => 'Port' },
|
||||
]);
|
||||
|
||||
template 'search';
|
||||
};
|
||||
|
||||
post '/login' => sub {
|
||||
if (param('username') and param('password')) {
|
||||
my $user = schema('netdisco')->resultset('User')->find(param('username'));
|
||||
if ($user) {
|
||||
my $sum = Digest::MD5::md5_hex(param('password'));
|
||||
if ($sum and $sum eq $user->password) {
|
||||
session(user => $user->username);
|
||||
redirect param('path') || '/';
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
redirect '/?failed=1';
|
||||
};
|
||||
|
||||
get '/logout' => sub {
|
||||
session->destroy;
|
||||
redirect '/?logout=1';
|
||||
};
|
||||
|
||||
any qr{.*} => sub {
|
||||
var('notfound' => true);
|
||||
status 'not_found';
|
||||
|
||||
38
Netdisco/lib/Netdisco/Web/AuthN.pm
Normal file
38
Netdisco/lib/Netdisco/Web/AuthN.pm
Normal file
@@ -0,0 +1,38 @@
|
||||
package Netdisco::Web::AuthN;
|
||||
|
||||
use Dancer ':syntax';
|
||||
use Digest::MD5 ();
|
||||
|
||||
hook 'before' => sub {
|
||||
if (! session('user') && request->path !~ m{^/login}) {
|
||||
if (setting('environment') eq 'development') {
|
||||
session(user => 'developer');
|
||||
}
|
||||
else {
|
||||
var(requested_path => request->path);
|
||||
request->path_info('/');
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
post '/login' => sub {
|
||||
if (param('username') and param('password')) {
|
||||
my $user = schema('netdisco')->resultset('User')->find(param('username'));
|
||||
if ($user) {
|
||||
my $sum = Digest::MD5::md5_hex(param('password'));
|
||||
if ($sum and $sum eq $user->password) {
|
||||
session(user => $user->username);
|
||||
redirect param('path') || '/';
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
redirect '/?failed=1';
|
||||
};
|
||||
|
||||
get '/logout' => sub {
|
||||
session->destroy;
|
||||
redirect '/?logout=1';
|
||||
};
|
||||
|
||||
true;
|
||||
147
Netdisco/lib/Netdisco/Web/Device.pm
Normal file
147
Netdisco/lib/Netdisco/Web/Device.pm
Normal file
@@ -0,0 +1,147 @@
|
||||
package Netdisco::Web::Device;
|
||||
|
||||
use Dancer ':syntax';
|
||||
use Dancer::Plugin::Ajax;
|
||||
use Dancer::Plugin::DBIC;
|
||||
|
||||
use NetAddr::IP::Lite ':lower';
|
||||
use netdisco (); # for sort_port
|
||||
|
||||
hook 'before' => sub {
|
||||
# list of port detail columns
|
||||
var('port_columns' => [
|
||||
{ name => 'c_port', label => 'Port', default => 'on' },
|
||||
{ name => 'c_descr', label => 'Description', default => '' },
|
||||
{ name => 'c_type', label => 'Type', default => '' },
|
||||
{ name => 'c_duplex', label => 'Duplex', default => '' },
|
||||
{ name => 'c_lastchange', label => 'Last Change', default => '' },
|
||||
{ name => 'c_name', label => 'Name', default => 'on' },
|
||||
{ name => 'c_speed', label => 'Speed', default => '' },
|
||||
{ name => 'c_mac', label => 'Port MAC', default => '' },
|
||||
{ name => 'c_mtu', label => 'MTU', default => '' },
|
||||
{ name => 'c_vlan', label => 'Native VLAN', default => 'on' },
|
||||
{ name => 'c_vmember', label => 'VLAN Membership', default => 'on' },
|
||||
{ name => 'c_connected', label => 'Connected Devices', default => 'on' },
|
||||
{ name => 'c_stp', label => 'Spanning Tree', default => '' },
|
||||
{ name => 'c_up', label => 'Status', default => '' },
|
||||
]);
|
||||
|
||||
# view settings for port connected devices
|
||||
var('connected_properties' => [
|
||||
{ name => 'n_age', label => 'Age Stamp', default => '' },
|
||||
{ name => 'n_ip', label => 'IP Address', default => 'on' },
|
||||
{ name => 'n_archived', label => 'Archived Data', default => '' },
|
||||
]);
|
||||
|
||||
# set up default search options for each type
|
||||
if (request->path =~ m{^/device}) {
|
||||
if (not param('tab') or param('tab') ne 'ports' or scalar keys %{params()} < 4) {
|
||||
foreach my $col (@{ var('port_columns') }) {
|
||||
params->{$col->{name}} = 'checked' if $col->{default} eq 'on';
|
||||
}
|
||||
foreach my $col (@{ var('connected_properties') }) {
|
||||
params->{$col->{name}} = 'checked' if $col->{default} eq 'on';
|
||||
}
|
||||
params->{'age_num'} = 3;
|
||||
params->{'age_unit'} = 'months';
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
ajax '/ajax/content/device/:thing' => sub {
|
||||
return "<p>Hello, this is where the ". param('thing') ." content goes.</p>";
|
||||
};
|
||||
|
||||
# device interface addresses
|
||||
ajax '/ajax/content/device/addresses' => sub {
|
||||
my $ip = param('ip');
|
||||
return unless $ip;
|
||||
|
||||
my $set = schema('netdisco')->resultset('DeviceIp')->search({ip => $ip}, { order_by => 'alias' });
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/device/addresses.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# device ports with a description (er, name) matching
|
||||
ajax '/ajax/content/device/ports' => sub {
|
||||
my $ip = param('ip');
|
||||
return unless $ip;
|
||||
|
||||
my $set = schema('netdisco')->resultset('DevicePort')->by_ip($ip);
|
||||
|
||||
# refine by ports if requested
|
||||
my $q = param('q');
|
||||
if ($q) {
|
||||
if ($q =~ m/^\d+$/) {
|
||||
$set = $set->by_vlan($q);
|
||||
}
|
||||
else {
|
||||
my $c = schema('netdisco')->resultset('DevicePort')->by_ip($ip)->by_port($q);
|
||||
if ($c->count) {
|
||||
$set = $set->by_port($q);
|
||||
}
|
||||
else {
|
||||
$set = $set->by_name($q);
|
||||
}
|
||||
}
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
# sort, and filter by free ports
|
||||
# the filter could be in the template but here allows a 'no records' msg
|
||||
my $results = [ sort { &netdisco::sort_port($a->port, $b->port) }
|
||||
grep { not param('free')
|
||||
or $_->is_free(param('age_num'), param('age_unit')) } $set->all ];
|
||||
|
||||
return unless scalar @$results;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/device/ports.tt', {
|
||||
results => $results,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# device details table
|
||||
ajax '/ajax/content/device/details' => sub {
|
||||
my $ip = param('ip');
|
||||
return unless $ip;
|
||||
|
||||
my $device = schema('netdisco')->resultset('Device')->find($ip);
|
||||
return unless $device;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/device/details.tt', {
|
||||
d => $device,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
get '/device' => sub {
|
||||
my $ip = NetAddr::IP::Lite->new(param('ip'));
|
||||
if (! $ip) {
|
||||
redirect '/?nosuchdevice=1';
|
||||
return;
|
||||
}
|
||||
|
||||
my $device = schema('netdisco')->resultset('Device')->find($ip->addr);
|
||||
if (! $device) {
|
||||
redirect '/?nosuchdevice=1';
|
||||
return;
|
||||
}
|
||||
|
||||
# list of tabs
|
||||
var('tabs' => [
|
||||
{ id => 'details', label => 'Details' },
|
||||
{ id => 'ports', label => 'Ports' },
|
||||
{ id => 'modules', label => 'Modules' },
|
||||
{ id => 'addresses', label => 'Addresses' },
|
||||
]);
|
||||
|
||||
params->{'tab'} ||= 'details';
|
||||
template 'device', { d => $device };
|
||||
};
|
||||
|
||||
true;
|
||||
216
Netdisco/lib/Netdisco/Web/Search.pm
Normal file
216
Netdisco/lib/Netdisco/Web/Search.pm
Normal file
@@ -0,0 +1,216 @@
|
||||
package Netdisco::Web::Search;
|
||||
|
||||
use Dancer ':syntax';
|
||||
use Dancer::Plugin::Ajax;
|
||||
use Dancer::Plugin::DBIC;
|
||||
|
||||
use NetAddr::IP::Lite ':lower';
|
||||
use Net::MAC ();
|
||||
use List::MoreUtils ();
|
||||
|
||||
hook 'before' => sub {
|
||||
# make hash lookups of query lists
|
||||
foreach my $opt (qw/model vendor os_ver/) {
|
||||
my $p = (ref [] eq ref param($opt) ? param($opt) : (param($opt) ? [param($opt)] : []));
|
||||
var("${opt}_lkp" => { map { $_ => 1 } @$p });
|
||||
}
|
||||
|
||||
# set up default search options for each type
|
||||
if (request->path =~ m{^/search}) {
|
||||
if (not param('tab') or param('tab') ne 'node') {
|
||||
params->{'stamps'} = 'checked';
|
||||
}
|
||||
if (not param('tab') or param('tab') ne 'device') {
|
||||
params->{'matchall'} = 'checked';
|
||||
}
|
||||
}
|
||||
|
||||
# set up query string defaults for hyperlinks to templates with forms
|
||||
var('query_defaults' => { map { ($_ => "tab=$_") } qw/node device/ });
|
||||
|
||||
var('query_defaults')->{node} .= "\&$_=". (param($_) || '')
|
||||
for qw/stamps vendor archived partial/;
|
||||
var('query_defaults')->{device} .= "\&$_=". (param($_) || '')
|
||||
for qw/matchall/;
|
||||
};
|
||||
|
||||
# device with various properties or a default match-all
|
||||
ajax '/ajax/content/search/device' => sub {
|
||||
my $has_opt = List::MoreUtils::any {param($_)}
|
||||
qw/name location dns ip description model os_ver vendor/;
|
||||
my $set;
|
||||
|
||||
if ($has_opt) {
|
||||
$set = schema('netdisco')->resultset('Device')->by_field(scalar params);
|
||||
}
|
||||
else {
|
||||
my $q = param('q');
|
||||
return unless $q;
|
||||
|
||||
$set = schema('netdisco')->resultset('Device')->by_any($q);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/search/device.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# nodes matching the param as an IP or DNS hostname or MAC
|
||||
ajax '/ajax/content/search/node' => sub {
|
||||
my $node = param('q');
|
||||
return unless $node;
|
||||
content_type('text/html');
|
||||
|
||||
my $mac = Net::MAC->new(mac => $node, 'die' => 0, verbose => 0);
|
||||
if (eval { $mac->as_IEEE }) {
|
||||
|
||||
my $sightings = schema('netdisco')->resultset('Node')
|
||||
->by_mac(param('archived'), $mac->as_IEEE);
|
||||
|
||||
my $ips = schema('netdisco')->resultset('NodeIp')
|
||||
->by_mac(param('archived'), $mac->as_IEEE);
|
||||
|
||||
my $ports = schema('netdisco')->resultset('DevicePort')
|
||||
->by_mac($mac->as_IEEE);
|
||||
|
||||
return unless $sightings->count
|
||||
or $ips->count
|
||||
or $ports->count;
|
||||
|
||||
template 'ajax/search/node_by_mac.tt', {
|
||||
ips => $ips,
|
||||
sightings => $sightings,
|
||||
ports => $ports,
|
||||
}, { layout => undef };
|
||||
}
|
||||
else {
|
||||
my $set;
|
||||
|
||||
if (my $ip = NetAddr::IP::Lite->new($node)) {
|
||||
# by_ip() will extract cidr notation if necessary
|
||||
$set = schema('netdisco')->resultset('NodeIp')
|
||||
->by_ip(param('archived'), $ip);
|
||||
}
|
||||
else {
|
||||
$node = "\%$node\%" if param('partial');
|
||||
$set = schema('netdisco')->resultset('NodeIp')
|
||||
->by_name(param('archived'), $node);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
template 'ajax/search/node_by_ip.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
}
|
||||
};
|
||||
|
||||
# devices carrying vlan xxx
|
||||
ajax '/ajax/content/search/vlan' => sub {
|
||||
my $vlan = param('q');
|
||||
return unless $vlan;
|
||||
my $set;
|
||||
|
||||
if ($vlan =~ m/^\d+$/) {
|
||||
$set = schema('netdisco')->resultset('Device')->carrying_vlan($vlan);
|
||||
}
|
||||
else {
|
||||
$set = schema('netdisco')->resultset('Device')->carrying_vlan_name($vlan);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/search/vlan.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
# device ports with a description (er, name) matching
|
||||
ajax '/ajax/content/search/port' => sub {
|
||||
my $q = param('q');
|
||||
return unless $q;
|
||||
my $set;
|
||||
|
||||
if ($q =~ m/^\d+$/) {
|
||||
$set = schema('netdisco')->resultset('DevicePort')->by_vlan($q);
|
||||
}
|
||||
else {
|
||||
$set = schema('netdisco')->resultset('DevicePort')->by_name($q);
|
||||
}
|
||||
return unless $set->count;
|
||||
|
||||
content_type('text/html');
|
||||
template 'ajax/search/port.tt', {
|
||||
results => $set,
|
||||
}, { layout => undef };
|
||||
};
|
||||
|
||||
get '/search' => sub {
|
||||
# set up property lists for device search
|
||||
var('model_list' => [
|
||||
schema('netdisco')->resultset('Device')->get_distinct('model')
|
||||
]);
|
||||
var('os_ver_list' => [
|
||||
schema('netdisco')->resultset('Device')->get_distinct('os_ver')
|
||||
]);
|
||||
var('vendor_list' => [
|
||||
schema('netdisco')->resultset('Device')->get_distinct('vendor')
|
||||
]);
|
||||
|
||||
my $q = param('q');
|
||||
if ($q and not param('tab')) {
|
||||
# pick most likely tab for initial results
|
||||
if ($q =~ m/^\d+$/) {
|
||||
params->{'tab'} = 'vlan';
|
||||
}
|
||||
else {
|
||||
my $s = schema('netdisco');
|
||||
if ($q =~ m{^[a-f0-9.:/]+$}i) {
|
||||
if (NetAddr::IP::Lite->new($q) and
|
||||
$s->resultset('Device')->find($q)) {
|
||||
params->{'tab'} = 'device';
|
||||
}
|
||||
else {
|
||||
# this will match for MAC addresses
|
||||
# and partial IPs (subnets?)
|
||||
params->{'tab'} = 'node';
|
||||
}
|
||||
}
|
||||
else {
|
||||
if ($s->resultset('Device')->search({
|
||||
dns => { '-ilike' => "\%$q\%" },
|
||||
})->count) {
|
||||
params->{'tab'} = 'device';
|
||||
}
|
||||
elsif ($s->resultset('NodeIp')->search({
|
||||
dns => { '-ilike' => "\%$q\%" },
|
||||
})->count) {
|
||||
params->{'tab'} = 'node';
|
||||
}
|
||||
elsif ($s->resultset('DevicePort')->search({
|
||||
name => { '-ilike' => "\%$q\%" },
|
||||
})->count) {
|
||||
params->{'tab'} = 'port';
|
||||
}
|
||||
}
|
||||
params->{'tab'} ||= 'device';
|
||||
}
|
||||
}
|
||||
elsif (not $q) {
|
||||
redirect '/';
|
||||
return;
|
||||
}
|
||||
|
||||
# list of tabs
|
||||
var('tabs' => [
|
||||
{ id => 'device', label => 'Device' },
|
||||
{ id => 'node', label => 'Node' },
|
||||
{ id => 'vlan', label => 'VLAN' },
|
||||
{ id => 'port', label => 'Port' },
|
||||
]);
|
||||
|
||||
template 'search';
|
||||
};
|
||||
|
||||
true;
|
||||
Reference in New Issue
Block a user