admin_kafkas.go

package mocks

import (
	"fmt"

	"github.com/bf2fc6cc711aee1a0c2a/kas-fleet-manager/internal/kafka/constants"
	"github.com/bf2fc6cc711aee1a0c2a/kas-fleet-manager/internal/kafka/internal/api/admin/private"

	mocksupportedinstancetypes "github.com/bf2fc6cc711aee1a0c2a/kas-fleet-manager/internal/kafka/test/mocks/supported_instance_types"
)

func BuildAdminKafkaRequest(modifyFn func(kafka *private.Kafka)) *private.Kafka {
	kafka := &private.Kafka{
		ClusterId:           DefaultClusterID,
		Region:              DefaultKafkaRequestRegion,
		CloudProvider:       DefaultKafkaRequestProvider,
		Status:              constants.KafkaRequestStatusReady.String(),
		MultiAz:             DefaultMultiAz,
		Owner:               user,
		AccountNumber:       "mock-ebs-0", // value relies on mock from here: pkg/services/account/account_mock.go
		Name:                DefaultKafkaRequestName,
		Namespace:           DefaultKafkaRequestName,
		InstanceType:        DefaultInstanceType,
		SizeId:              mocksupportedinstancetypes.DefaultKafkaInstanceSizeId,
		BootstrapServerHost: fmt.Sprintf("%s:443", DefaultBootstrapServerHost),
		OrganisationId:      DefaultOrganisationId,
	}
	if modifyFn != nil {
		modifyFn(kafka)
	}
	return kafka
}