tweaking use of the IPAddress data pipeline

engine/plugins/dns/plugin.go

@@ -103,7 +103,7 @@ func (d *dnsPlugin) Start(r et.Registry) error {
 	if err := r.RegisterHandler(&et.Handler{
 		Plugin:       d,
 		Name:         d.reverse.name,
-		Priority:     9,
+		Priority:     8,
 		MaxInstances: support.MaxHandlerInstances,
 		Transforms:   []string{string(oam.FQDN)},
 		EventType:    oam.IPAddress,

engine/plugins/support/support.go

@@ -174,7 +174,7 @@ func IPToNetblock(session et.Session, ip *oamnet.IPAddress) (*oamnet.Netblock, e
 		return nil, errors.New("no netblock match in the cache")
 	}
 
-	addNetblock(session.ID().String(), found)
+	AddNetblock(session.ID().String(), found)
 	return found, nil
 }
 
@@ -205,7 +205,7 @@ func lookupNetblock(sessid string, ip *oamnet.IPAddress) (*oamnet.Netblock, erro
 	return found, nil
 }
 
-func addNetblock(sessid string, nb *oamnet.Netblock) {
+func AddNetblock(sessid string, nb *oamnet.Netblock) {
 	mlock.Lock()
 	defer mlock.Unlock()
 

engine/plugins/whois/bgptools/netblock.go

@@ -39,7 +39,7 @@ func (r *netblock) check(e *et.Event) error {
 	if reserved, _ := amassnet.IsReservedAddress(ipstr); reserved {
 		return nil
 	}
-	// check if there's a netblock and autonomous system associated with this IP address
+	// check if there's a netblock associated with this IP address
 	if _, err := support.IPToNetblock(e.Session, ip); err == nil {
 		// the rest of the work will be done further down the pipeline
 		return nil
@@ -58,6 +58,7 @@ func (r *netblock) check(e *et.Event) error {
 
 	if nb != nil {
 		r.process(e, e.Entity, nb)
+		support.AddNetblock(e.Session.ID().String(), nb.Asset.(*oamnet.Netblock))
 	}
 	return nil
 }