79 lines
2.2 KiB
Perl
79 lines
2.2 KiB
Perl
package App::Netdisco::Backend::Worker::Poller::Expiry;
|
||
|
||
use Dancer qw/:moose :syntax :script/;
|
||
use Dancer::Plugin::DBIC 'schema';
|
||
|
||
use App::Netdisco::Backend::Util ':all';
|
||
use App::Netdisco::Util::Statistics 'update_stats';
|
||
|
||
use Role::Tiny;
|
||
use namespace::clean;
|
||
|
||
# expire devices and nodes according to config
|
||
sub expire {
|
||
my ($self, $job) = @_;
|
||
|
||
if (setting('expire_devices') and setting('expire_devices') > 0) {
|
||
schema('netdisco')->txn_do(sub {
|
||
schema('netdisco')->resultset('Device')->search({
|
||
-or => [ 'vendor' => undef, 'vendor' => { '!=' => 'netdisco' }],
|
||
last_discover => \[q/< (now() - ?::interval)/,
|
||
(setting('expire_devices') * 86400)],
|
||
})->delete();
|
||
});
|
||
}
|
||
|
||
if (setting('expire_nodes') and setting('expire_nodes') > 0) {
|
||
schema('netdisco')->txn_do(sub {
|
||
schema('netdisco')->resultset('Node')->search({
|
||
time_last => \[q/< (now() - ?::interval)/,
|
||
(setting('expire_nodes') * 86400)],
|
||
})->delete();
|
||
});
|
||
}
|
||
|
||
if (setting('expire_nodes_archive') and setting('expire_nodes_archive') > 0) {
|
||
schema('netdisco')->txn_do(sub {
|
||
schema('netdisco')->resultset('Node')->search({
|
||
-not_bool => 'active',
|
||
time_last => \[q/< (now() - ?::interval)/,
|
||
(setting('expire_nodes_archive') * 86400)],
|
||
})->delete();
|
||
});
|
||
}
|
||
|
||
if (setting('expire_jobs') and setting('expire_jobs') > 0) {
|
||
schema('netdisco')->txn_do(sub {
|
||
schema('netdisco')->resultset('Admin')->search({
|
||
entered => \[q/< (now() - ?::interval)/,
|
||
(setting('expire_jobs') * 86400)],
|
||
})->delete();
|
||
});
|
||
}
|
||
|
||
# now update stats
|
||
update_stats();
|
||
|
||
return job_done("Checked expiry and updated stats");
|
||
}
|
||
|
||
# expire nodes for a specific device
|
||
sub expirenodes {
|
||
my ($self, $job) = @_;
|
||
|
||
return job_error('Missing device') unless $job->device;
|
||
|
||
schema('netdisco')->txn_do(sub {
|
||
schema('netdisco')->resultset('Node')->search({
|
||
switch => $job->device->ip,
|
||
($job->port ? (port => $job->port) : ()),
|
||
})->delete(
|
||
($job->extra ? () : ({ archive_nodes => 1 }))
|
||
);
|
||
});
|
||
|
||
return job_done("Expired nodes for ". $job->device->ip);
|
||
}
|
||
|
||
1;
|