1package App::Netdisco::Worker::Plugin::PortName; 2 3use Dancer ':syntax'; 4use App::Netdisco::Worker::Plugin; 5use aliased 'App::Netdisco::Worker::Status'; 6 7use App::Netdisco::Transport::SNMP; 8use App::Netdisco::Util::Port ':all'; 9 10register_worker({ phase => 'check' }, sub { 11 my ($job, $workerconf) = @_; 12 return Status->error('Missing device (-d).') unless defined $job->device; 13 return Status->error('Missing port (-p).') unless defined $job->port; 14 return Status->error('Missing name (-e).') unless defined $job->subaction; 15 16 vars->{'port'} = get_port($job->device, $job->port) 17 or return Status->error(sprintf "Unknown port name [%s] on device %s", 18 $job->port, $job->device); 19 20 return Status->done('PortName is able to run'); 21}); 22 23register_worker({ phase => 'main', driver => 'snmp' }, sub { 24 my ($job, $workerconf) = @_; 25 my ($device, $pn, $data) = map {$job->$_} qw/device port extra/; 26 27 # update pseudo devices directly in database 28 unless ($device->is_pseudo()) { 29 # snmp connect using rw community 30 my $snmp = App::Netdisco::Transport::SNMP->writer_for($device) 31 or return Status->defer("failed to connect to $device to update alias"); 32 33 my $iid = get_iid($snmp, vars->{'port'}) 34 or return Status->error("Failed to get port ID for [$pn] from $device"); 35 36 my $rv = $snmp->set_i_alias($data, $iid); 37 38 if (!defined $rv) { 39 return Status->error(sprintf 'Failed to set [%s] alias to [%s] on $device: %s', 40 $pn, $data, ($snmp->error || '')); 41 } 42 43 # confirm the set happened 44 $snmp->clear_cache; 45 my $state = ($snmp->i_alias($iid) || ''); 46 if (ref {} ne ref $state or $state->{$iid} ne $data) { 47 return Status->error("Verify of [$pn] alias failed on $device"); 48 } 49 } 50 51 # update netdisco DB 52 vars->{'port'}->update({name => $data}); 53 54 return Status->done("Updated [$pn] alias on [$device] to [$data]"); 55}); 56 57true; 58