feat: add NS record support

- support NS record creation

Signed-off-by: Brian Richardson <[email protected]>

Author: bdrich

internal/infoblox/common.go

@@ -67,6 +67,21 @@ func ToCNAMEResponseMap(res []ibclient.RecordCNAME) *ResponseMap {
 	return rm
 }
 
+func ToNSResponseMap(res []ibclient.RecordNS) *ResponseMap {
+	rm := &ResponseMap{
+		Map:        make(map[string]ResponseDetails),
+		RecordType: ibclient.ZoneDelegatedConst,
+	}
+	for _, record := range res {
+		if _, ok := rm.Map[record.Name]; !ok {
+			rm.Map[record.Name] = ResponseDetails{{Target: AsString(record.Nameserver)}}
+			continue
+		}
+		rm.Map[record.Name] = append(rm.Map[record.Name], ResponseDetail{Target: AsString(record.Nameserver)})
+	}
+	return rm
+}
+
 func ToTXTResponseMap(res []ibclient.RecordTXT) *ResponseMap {
 	rm := &ResponseMap{
 		Map:        make(map[string]ResponseDetails),

internal/infoblox/infoblox.go

@@ -241,6 +241,17 @@ func (p *Provider) Records(_ context.Context) (endpoints []*endpoint.Endpoint, e
 		endpointsTXT := ToTXTResponseMap(resT).ToEndpoints()
 		endpoints = append(endpoints, endpointsTXT...)
 
+		var resNS []ibclient.RecordNS
+		objNS := ibclient.NewEmptyRecordNS()
+		objNS.View = p.config.View
+		objNS.Zone = zone.Fqdn
+		err = PagingGetObject(p.client, objNS, "", searchParams, &resNS)
+		if err != nil && !isNotFoundError(err) {
+			return nil, fmt.Errorf("could not fetch NS records from zone '%s': %w", zone.Fqdn, err)
+		}
+		endpointsNS := ToNSResponseMap(resNS).ToEndpoints()
+		endpoints = append(endpoints, endpointsNS...)
+
 		if p.config.CreatePTR {
 			arpaZone, err := rfc2317.CidrToInAddr(zone.Fqdn)
 			if err == nil {
@@ -451,6 +462,13 @@ func getRefID(record *infobloxRecordSet) (string, log.Fields, error) {
 			return r.Ref, l, nil
 		}
 		return "", l, nil
+	case "RecordNS":
+		l["record"] = record.obj.(*ibclient.RecordNS).Name
+		l["target"] = AsString(record.obj.(*ibclient.RecordNS).Nameserver)
+		for _, r := range *record.res.(*[]ibclient.RecordNS) {
+			return r.Ref, l, nil
+		}
+		return "", l, nil
 	}
 	return "", l, fmt.Errorf("unknown type '%s'", t)
 }
@@ -758,6 +776,26 @@ func (p *Provider) recordSet(ep *endpoint.Endpoint, getObject bool) (recordSet i
 			obj: obj,
 			res: &res,
 		}
+	case endpoint.RecordTypeNS:
+		var res []ibclient.RecordNS
+		obj := ibclient.NewEmptyRecordNS()
+		obj.Name = ep.DNSName
+		obj.Nameserver = &ep.Targets[0]
+		if getObject {
+			queryParams := ibclient.NewQueryParams(false, map[string]string{"name": obj.Name})
+			err = p.client.GetObject(obj, "", queryParams, &res)
+			if err != nil && !isNotFoundError(err) {
+				return
+			}
+		} else {
+			// If getObject is not set (action == create), we need to set the View for Infoblox to find the parent zone
+			// If View is set for the other actions, Infoblox will complain that the view field is not allowed
+			obj.View = p.config.View
+		}
+		recordSet = infobloxRecordSet{
+			obj: obj,
+			res: &res,
+		}
 	case endpoint.RecordTypeTXT:
 		var res []ibclient.RecordTXT
 		// The Infoblox API strips enclosing double quotes from TXT records lacking whitespace.