ec/ecresource/deploymentresource/apm/v2/apm_read.go

// Licensed to Elasticsearch B.V. under one or more contributor
// license agreements. See the NOTICE file distributed with
// this work for additional information regarding copyright
// ownership. Elasticsearch B.V. licenses this file to you under
// the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied.  See the License for the
// specific language governing permissions and limitations
// under the License.

package v2

import (
	"github.com/elastic/cloud-sdk-go/pkg/models"
	"github.com/elastic/cloud-sdk-go/pkg/util/ec"
	"github.com/elastic/terraform-provider-ec/ec/internal/converters"
	"github.com/elastic/terraform-provider-ec/ec/internal/util"
)

type Apm struct {
	ElasticsearchClusterRefId          *string    `tfsdk:"elasticsearch_cluster_ref_id"`
	RefId                              *string    `tfsdk:"ref_id"`
	ResourceId                         *string    `tfsdk:"resource_id"`
	Region                             *string    `tfsdk:"region"`
	HttpEndpoint                       *string    `tfsdk:"http_endpoint"`
	HttpsEndpoint                      *string    `tfsdk:"https_endpoint"`
	InstanceConfigurationId            *string    `tfsdk:"instance_configuration_id"`
	LatestInstanceConfigurationId      *string    `tfsdk:"latest_instance_configuration_id"`
	InstanceConfigurationVersion       *int       `tfsdk:"instance_configuration_version"`
	LatestInstanceConfigurationVersion *int       `tfsdk:"latest_instance_configuration_version"`
	Size                               *string    `tfsdk:"size"`
	SizeResource                       *string    `tfsdk:"size_resource"`
	ZoneCount                          int        `tfsdk:"zone_count"`
	Config                             *ApmConfig `tfsdk:"config"`
}

func ReadApms(in []*models.ApmResourceInfo) (*Apm, error) {
	for _, model := range in {
		if util.IsCurrentApmPlanEmpty(model) || IsApmStopped(model) {
			continue
		}

		apm, err := ReadApm(model)
		if err != nil {
			return nil, err
		}

		return apm, nil
	}

	return nil, nil
}

func ReadApm(in *models.ApmResourceInfo) (*Apm, error) {
	var apm Apm

	apm.RefId = in.RefID
	apm.ResourceId = in.Info.ID
	apm.Region = in.Region
	plan := in.Info.PlanInfo.Current.Plan

	topologies, err := readApmTopologies(plan.ClusterTopology)
	if err != nil {
		return nil, err
	}

	if len(topologies) > 0 {
		apm.InstanceConfigurationId = topologies[0].InstanceConfigurationId
		apm.InstanceConfigurationVersion = topologies[0].InstanceConfigurationVersion
		apm.Size = topologies[0].Size
		apm.SizeResource = topologies[0].SizeResource
		apm.ZoneCount = topologies[0].ZoneCount
	}

	apm.ElasticsearchClusterRefId = in.ElasticsearchClusterRefID

	apm.HttpEndpoint, apm.HttpsEndpoint = converters.ExtractEndpoints(in.Info.Metadata)

	configs, err := readApmConfigs(plan.Apm)
	if err != nil {
		return nil, err
	}

	if len(configs) > 0 {
		apm.Config = &configs[0]
	}

	return &apm, nil
}

// IsApmStopped returns true if the resource is stopped.
func IsApmStopped(res *models.ApmResourceInfo) bool {
	return res == nil || res.Info == nil || res.Info.Status == nil ||
		*res.Info.Status == "stopped"
}

func SetLatestInstanceConfigInfo(currentTopology *Apm, latestTopology *models.ApmTopologyElement) {
	if currentTopology != nil && latestTopology != nil {
		currentTopology.LatestInstanceConfigurationId = &latestTopology.InstanceConfigurationID
		if latestTopology.InstanceConfigurationVersion != nil {
			currentTopology.LatestInstanceConfigurationVersion = ec.Int(int(*latestTopology.InstanceConfigurationVersion))
		}
	}
}

func SetLatestInstanceConfigInfoToCurrent(topology *Apm) {
	if topology != nil {
		topology.LatestInstanceConfigurationId = topology.InstanceConfigurationId
		topology.LatestInstanceConfigurationVersion = topology.InstanceConfigurationVersion
	}
}