Add CRUD endpoints for Infrastructure Access Targets

.changelog/3183.txt

@@ -0,0 +1,3 @@
+```release-note:enhancement
+infrastructure_targets: initialize CRUD endpoints for infrastructure access endpoints
+```

infrastructure_targets.go

@@ -0,0 +1,236 @@
+package cloudflare
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"net/http"
+	"time"
+
+	"github.com/goccy/go-json"
+)
+
+var ErrMissingTargetId = errors.New("required target id missing")
+
+// InfrastructureTarget represents an Infrastructure InfrastructureTarget.
+type InfrastructureTarget struct {
+	Hostname   string                     `json:"hostname"`
+	ID         string                     `json:"id"`
+	IP         InfrastructureTargetIPInfo `json:"ip"`
+	CreatedAt  time.Time                  `json:"created_at"`
+	ModifiedAt time.Time                  `json:"modified_at"`
+}
+
+type InfrastructureTargetIPDetails struct {
+	IPAddr           string `json:"ip_addr"`
+	VirtualNetworkId string `json:"virtual_network_id"`
+}
+
+type InfrastructureTargetIPInfo struct {
+	IPV4 *InfrastructureTargetIPDetails `json:"ipv4,omitempty"`
+	IPV6 *InfrastructureTargetIPDetails `json:"ipv6,omitempty"`
+}
+
+type InfrastructureTargetParams struct {
+	Hostname string                     `json:"hostname"`
+	IP       InfrastructureTargetIPInfo `json:"ip"`
+}
+
+type CreateInfrastructureTargetParams struct {
+	InfrastructureTargetParams
+}
+
+type UpdateInfrastructureTargetParams struct {
+	ID           string                     `json:"-"`
+	ModifyParams InfrastructureTargetParams `json:"modify_params"`
+}
+
+// InfrastructureTargetDetailResponse is the API response, containing a single target.
+type InfrastructureTargetDetailResponse struct {
+	Result InfrastructureTarget `json:"result"`
+	Response
+}
+
+type InfrastructureTargetListDetailResponse struct {
+	Result []InfrastructureTarget `json:"result"`
+	Response
+	ResultInfo `json:"result_info"`
+}
+
+type InfrastructureTargetListParams struct {
+	CreatedAfter     string `url:"created_after,omitempty"`
+	Hostname         string `url:"hostname,omitempty"`
+	HostnameContains string `url:"hostname_contains,omitempty"`
+	IPV4             string `url:"ip_v4,omitempty"`
+	IPV6             string `url:"ip_v6,omitempty"`
+	ModifedAfter     string `url:"modified_after,omitempty"`
+	VirtualNetworkId string `url:"virtual_network_id,omitempty"`
+
+	ResultInfo
+}
+
+// ListInfrastructureTargets returns all applications within an account or zone.
+//
+// API reference: https://developers.cloudflare.com/api/operations/infra-targets-list
+func (api *API) ListInfrastructureTargets(ctx context.Context, rc *ResourceContainer, params InfrastructureTargetListParams) ([]InfrastructureTarget, *ResultInfo, error) {
+	if rc.Identifier == "" {
+		return []InfrastructureTarget{}, &ResultInfo{}, ErrMissingAccountID
+	}
+
+	baseURL := fmt.Sprintf("/%s/%s/infrastructure/targets", rc.Level, rc.Identifier)
+
+	autoPaginate := true
+	if params.PerPage >= 1 || params.Page >= 1 {
+		autoPaginate = false
+	}
+
+	if params.PerPage < 1 {
+		params.PerPage = 25
+	}
+
+	if params.Page < 1 {
+		params.Page = 1
+	}
+
+	var applications []InfrastructureTarget
+	var r InfrastructureTargetListDetailResponse
+
+	for {
+		uri := buildURI(baseURL, params)
+
+		res, err := api.makeRequestContext(ctx, http.MethodGet, uri, nil)
+		if err != nil {
+			return []InfrastructureTarget{}, &ResultInfo{}, fmt.Errorf("%s: %w", errMakeRequestError, err)
+		}
+
+		err = json.Unmarshal(res, &r)
+		if err != nil {
+			return []InfrastructureTarget{}, &ResultInfo{}, fmt.Errorf("%s: %w", errUnmarshalError, err)
+		}
+		applications = append(applications, r.Result...)
+		params.ResultInfo = r.ResultInfo.Next()
+		if params.ResultInfo.Done() || !autoPaginate {
+			break
+		}
+	}
+
+	return applications, &r.ResultInfo, nil
+}
+
+// CreateInfrastructureTarget creates a new infrastructure target.
+//
+// API reference: https://developers.cloudflare.com/api/operations/infra-targets-post
+func (api *API) CreateInfrastructureTarget(ctx context.Context, rc *ResourceContainer, params CreateInfrastructureTargetParams) (InfrastructureTarget, error) {
+	if rc.Identifier == "" {
+		return InfrastructureTarget{}, ErrMissingAccountID
+	}
+
+	uri := fmt.Sprintf("/%s/%s/infrastructure/targets", rc.Level, rc.Identifier)
+
+	res, err := api.makeRequestContext(ctx, http.MethodPost, uri, params)
+	if err != nil {
+		return InfrastructureTarget{}, fmt.Errorf("%s: %w", errMakeRequestError, err)
+	}
+
+	var targetDetailResponse InfrastructureTargetDetailResponse
+	err = json.Unmarshal(res, &targetDetailResponse)
+	if err != nil {
+		return InfrastructureTarget{}, fmt.Errorf("%s: %w", errUnmarshalError, err)
+	}
+
+	return targetDetailResponse.Result, nil
+}
+
+// UpdateInfrastructureTarget updates an existing infrastructure target.
+//
+// API reference: https://developers.cloudflare.com/api/operations/infra-targets-put
+func (api *API) UpdateInfrastructureTarget(ctx context.Context, rc *ResourceContainer, params UpdateInfrastructureTargetParams) (InfrastructureTarget, error) {
+	if rc.Identifier == "" {
+		return InfrastructureTarget{}, ErrMissingAccountID
+	}
+
+	if params.ID == "" {
+		return InfrastructureTarget{}, ErrMissingTargetId
+	}
+
+	uri := fmt.Sprintf(
+		"/%s/%s/infrastructure/targets/%s",
+		rc.Level,
+		rc.Identifier,
+		params.ID,
+	)
+
+	res, err := api.makeRequestContext(ctx, http.MethodPut, uri, params.ModifyParams)
+	if err != nil {
+		return InfrastructureTarget{}, fmt.Errorf("%s: %w", errMakeRequestError, err)
+	}
+
+	var targetDetailResponse InfrastructureTargetDetailResponse
+	err = json.Unmarshal(res, &targetDetailResponse)
+	if err != nil {
+		return InfrastructureTarget{}, fmt.Errorf("%s: %w", errUnmarshalError, err)
+	}
+
+	return targetDetailResponse.Result, nil
+}
+
+// GetInfrastructureTarget returns a single infrastructure target based on target ID
+// ID for either account or zone.
+//
+// API reference: https://developers.cloudflare.com/api/operations/infra-targets-get
+func (api *API) GetInfrastructureTarget(ctx context.Context, rc *ResourceContainer, targetID string) (InfrastructureTarget, error) {
+	if rc.Identifier == "" {
+		return InfrastructureTarget{}, ErrMissingAccountID
+	}
+
+	if targetID == "" {
+		return InfrastructureTarget{}, ErrMissingTargetId
+	}
+
+	uri := fmt.Sprintf(
+		"/%s/%s/infrastructure/targets/%s",
+		rc.Level,
+		rc.Identifier,
+		targetID,
+	)
+
+	res, err := api.makeRequestContext(ctx, http.MethodGet, uri, nil)
+	if err != nil {
+		return InfrastructureTarget{}, fmt.Errorf("%s: %w", errMakeRequestError, err)
+	}
+
+	var targetDetailResponse InfrastructureTargetDetailResponse
+	err = json.Unmarshal(res, &targetDetailResponse)
+	if err != nil {
+		return InfrastructureTarget{}, fmt.Errorf("%s: %w", errUnmarshalError, err)
+	}
+
+	return targetDetailResponse.Result, nil
+}
+
+// DeleteInfrastructureTarget deletes an infrastructure target.
+//
+// API reference: https://developers.cloudflare.com/api/operations/infra-targets-delete
+func (api *API) DeleteInfrastructureTarget(ctx context.Context, rc *ResourceContainer, targetID string) error {
+	if rc.Identifier == "" {
+		return ErrMissingAccountID
+	}
+
+	if targetID == "" {
+		return ErrMissingTargetId
+	}
+
+	uri := fmt.Sprintf(
+		"/%s/%s/infrastructure/targets/%s",
+		rc.Level,
+		rc.Identifier,
+		targetID,
+	)
+
+	_, err := api.makeRequestContext(ctx, http.MethodDelete, uri, nil)
+	if err != nil {
+		return fmt.Errorf("%s: %w", errMakeRequestError, err)
+	}
+
+	return nil
+}