object_manager_mx_record.go

package ibclient

import "fmt"

func (objMgr *ObjectManager) CreateMXRecord(
	dnsView string,
	fqdn string,
	mx string,
	preference uint32,
	ttl uint32,
	useTtl bool,
	comment string,
	eas EA) (*RecordMX, error) {

	if dnsView == "" {
		dnsView = "default"
	}

	if fqdn == "" || mx == "" {
		return nil, fmt.Errorf("'fqdn' and 'mail_exchanger' fields must not be empty")
	}

	if preference < 0 || preference > 65535 {
		return nil, fmt.Errorf("'preference' is not in range 0 to 65535")
	}

	recordMx := NewRecordMX(RecordMX{
		View:       dnsView,
		Fqdn:       fqdn,
		MX:         mx,
		Preference: preference,
		Ttl:        ttl,
		UseTtl:     useTtl,
		Comment:    comment,
		Ea:         eas,
	})

	ref, err := objMgr.connector.CreateObject(recordMx)
	if err != nil {
		return nil, err
	}
	recordMx.Ref = ref
	return recordMx, err
}

func (objMgr *ObjectManager) GetMXRecordByRef(ref string) (*RecordMX, error) {
	recordMX := NewEmptyRecordMX()
	err := objMgr.connector.GetObject(recordMX, ref, NewQueryParams(false, nil), &recordMX)

	return recordMX, err
}

func (objMgr *ObjectManager) GetMXRecord(dnsView string, fqdn string, mx string, preference uint32) (*RecordMX, error) {
	if dnsView == "" || fqdn == "" {
		return nil, fmt.Errorf("'DNS view' and 'fqdn' are required to retrieve a unique mx record")
	}
	var res []RecordMX

	recordMX := NewEmptyRecordMX()
	sf := map[string]string{
		"view":           dnsView,
		"name":           fqdn,
		"mail_exchanger": mx,
		"preference":     fmt.Sprintf("%d", preference),
	}
	queryParams := NewQueryParams(false, sf)
	err := objMgr.connector.GetObject(recordMX, "", queryParams, &res)

	if err != nil {
		return nil, err
	}

	if res == nil || len(res) == 0 {
		return nil, NewNotFoundError(
			fmt.Sprintf(
				"MX record with name '%s' and MX '%s' in DNS view '%s' is not found",
				fqdn, mx, dnsView))
	}

	return &res[0], nil
}

func (objMgr *ObjectManager) UpdateMXRecord(
	ref string,
	dnsView string,
	fqdn string,
	mx string,
	preference uint32,
	ttl uint32,
	useTtl bool,
	comment string,
	eas EA) (*RecordMX, error) {

	res, err := objMgr.GetMXRecordByRef(ref)

	if err != nil {
		return nil, err
	}

	if dnsView != res.View {
		return nil, fmt.Errorf("changing 'dns_view' field after object creation is not allowed")
	}

	if preference < 0 || preference > 65535 {
		return nil, fmt.Errorf("'preference' is not in range 0 to 65535")
	}

	if mx == "" {
		return nil, fmt.Errorf("'mail_exchanger' field must not be empty")
	}
	recordMx := NewRecordMX(RecordMX{
		View:       dnsView,
		Fqdn:       fqdn,
		MX:         mx,
		Preference: preference,
		Ttl:        ttl,
		UseTtl:     useTtl,
		Comment:    comment,
		Ea:         eas,
	})

	recordMx.Ref = ref

	nw_ref, err := objMgr.connector.UpdateObject(recordMx, ref)

	if err != nil {
		return nil, err
	}

	recordMx.Ref = nw_ref

	return recordMx, err
}

func (objMgr *ObjectManager) DeleteMXRecord(ref string) (string, error) {
	return objMgr.connector.DeleteObject(ref)
}