fix sshcollector

lib/App/Netdisco/Util/Node.pm

@@ -11,6 +11,7 @@ our @EXPORT = ();
 our @EXPORT_OK = qw/
   check_mac
   is_nbtstatable
+  store_arp
 /;
 our %EXPORT_TAGS = (all => \@EXPORT_OK);
 
@@ -141,4 +142,54 @@ sub is_nbtstatable {
   return 1;
 }
 
+=head2 store_arp( \%host, $now? )
+
+Stores a new entry to the C<node_ip> table with the given MAC, IP (v4 or v6)
+and DNS host name. Host details are provided in a Hash ref:
+
+ {
+    ip   => '192.0.2.1',
+    node => '00:11:22:33:44:55',
+    dns  => 'myhost.example.com',
+ }
+
+The C<dns> entry is optional. The update will mark old entries for this IP as
+no longer C<active>.
+
+Optionally a literal string can be passed in the second argument for the
+C<time_last> timestamp, otherwise the current timestamp (C<now()>) is used.
+
+=cut
+
+sub store_arp {
+  my ($hash_ref, $now) = @_;
+  $now ||= 'now()';
+  my $ip   = $hash_ref->{'ip'};
+  my $mac  = NetAddr::MAC->new($hash_ref->{'node'});
+  my $name = $hash_ref->{'dns'};
+
+  return if !defined $mac or $mac->errstr;
+
+  schema('netdisco')->txn_do(sub {
+    my $current = schema('netdisco')->resultset('NodeIp')
+      ->search(
+        { ip => $ip, -bool => 'active'},
+        { columns => [qw/mac ip/] })->update({active => \'false'});
+
+    schema('netdisco')->resultset('NodeIp')
+      ->update_or_create(
+      {
+        mac => $mac->as_ieee,
+        ip => $ip,
+        dns => $name,
+        active => \'true',
+        time_last => \$now,
+      },
+      {
+        key => 'primary',
+        for => 'update',
+      });
+  });
+}
+
 1;