create.go

package main

import (
	"encoding/json"
	"flag"
	"fmt"
	"os"

	"github.com/Azure/ARO-HCP/internal/api"
	"github.com/Azure/ARO-HCP/internal/api/arm"
)

const (
	flagName = "type"
	cluster  = "cluster"
	nodePool = "node_pool"
)

func main() {
	example := "go run frontend/utils/create.go -type cluster"
	usage := fmt.Sprintf("type of object you want to create: %v or %v.\nExample: %v\n", cluster, nodePool, example)
	objectType := flag.String(flagName, cluster, usage)
	flag.Parse()

	if *objectType == cluster {
		err := CreateJSONFile()
		if err != nil {
			panic(err)
		}
		return
	}

	if *objectType == nodePool {
		err := CreateNodePool()
		if err != nil {
			panic(err)
		}
		return
	}

	help := "go run frontend/utils/create.go -type"
	panic(fmt.Sprintf("invalid object type, run: '%v'", help))
}

// CreateJSONFile creates a base cluster JSON file for use with testing frontend to create clusters
func CreateJSONFile() error {
	cluster := api.HCPOpenShiftCluster{
		Properties: api.HCPOpenShiftClusterProperties{
			Spec: api.ClusterSpec{
				Version: api.VersionProfile{
					ID:           "openshift-v4.17.0",
					ChannelGroup: "stable",
				},
				DNS: api.DNSProfile{},
				Network: api.NetworkProfile{
					NetworkType: api.NetworkTypeOVNKubernetes,
					PodCIDR:     "10.128.0.0/14",
					ServiceCIDR: "172.30.0.0/16",
					MachineCIDR: "10.0.0.0/16",
					HostPrefix:  23,
				},
				Console: api.ConsoleProfile{},
				API: api.APIProfile{
					Visibility: api.Visibility("public"),
				},
				FIPS:                          false,
				EtcdEncryption:                false,
				DisableUserWorkloadMonitoring: false,
				Proxy:                         api.ProxyProfile{},
				Platform: api.PlatformProfile{
					ManagedResourceGroup:   "dev-test-mrg",
					NetworkSecurityGroupID: "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/dev-test-rg/providers/Microsoft.Network/networkSecurityGroups/xyz",
					SubnetID:               "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/dev-test-rg/providers/Microsoft.Network/virtualNetworks/xyz/subnets/xyz",
					OutboundType:           api.OutboundType("loadBalancer"),
				},
				IssuerURL:    "",
				ExternalAuth: api.ExternalAuthConfigProfile{},
			},
		},
	}

	data, err := json.MarshalIndent(cluster, "", "  ")
	if err != nil {
		return err
	}

	err = os.WriteFile("cluster.json", data, 0643)
	if err != nil {
		return err
	}

	return nil
}

func CreateNodePool() error {
	nodePool := api.HCPOpenShiftClusterNodePool{
		Properties: api.HCPOpenShiftClusterNodePoolProperties{
			ProvisioningState: arm.ProvisioningState(""),
			Spec: api.NodePoolSpec{
				Version: api.VersionProfile{
					ID:           "openshift-v4.17.0",
					ChannelGroup: "stable",
				},
				Platform: api.NodePoolPlatformProfile{
					SubnetID:    "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/dev-test-rg/providers/Microsoft.Network/virtualNetworks/xyz/subnets/xyz",
					DiskSizeGiB: 30,

					// VMSize should match configs/cloud-resources/instance-types.yaml
					// and configs/cloud-resource-constraints/instance-type-constraints.yaml
					// in CS config files.
					VMSize:                 "Standard_D8s_v3",
					DiskStorageAccountType: "StandardSSD_LRS",
					EphemeralOSDisk:        false,
				},
				Replicas: 2,
			},
		},
	}

	data, err := json.MarshalIndent(nodePool, "", "  ")
	if err != nil {
		return err
	}

	err = os.WriteFile("node_pool.json", data, 0643)
	if err != nil {
		return err
	}

	return nil
}