snc: implement openshift-snc for azure

Author: anjannath

cmd/mapt/cmd/azure/azure.go

@@ -35,6 +35,7 @@ func GetCmd() *cobra.Command {
 		hosts.GetUbuntuCmd(),
 		hosts.GetRHELCmd(),
 		hosts.GetFedoraCmd(),
-		services.GetAKSCmd())
+		services.GetAKSCmd(),
+		services.GetOpenshiftSNCCmd())
 	return c
 }

cmd/mapt/cmd/azure/services/openshift-snc.go

@@ -0,0 +1,117 @@
+package services
+
+import (
+	"github.com/redhat-developer/mapt/cmd/mapt/cmd/params"
+	maptContext "github.com/redhat-developer/mapt/pkg/manager/context"
+	sncAPI "github.com/redhat-developer/mapt/pkg/provider/api/openshift-snc"
+	openshiftsnc "github.com/redhat-developer/mapt/pkg/provider/azure/action/openshift-snc"
+	"github.com/redhat-developer/mapt/pkg/util/logging"
+	"github.com/spf13/cobra"
+	"github.com/spf13/pflag"
+	"github.com/spf13/viper"
+)
+
+const (
+	cmdOpenshiftSNC     = "openshift-snc"
+	cmdOpenshiftSNCDesc = "Manage an OpenShift Single Node Cluster based on OpenShift Local. This is not intended for production use"
+
+	ocpVersion         = "version"
+	ocpVersionDesc     = "version for Openshift. If not set it will pick latest available version"
+	pullSecretFile     = "pull-secret-file"
+	pullSecretFileDesc = "file path of image pull secret (download from https://console.redhat.com/openshift/create/local)"
+
+	location        = "location"
+	locationDesc    = "If spot is passed location will be calculated based on spot results. Otherwise localtion will be used to create resources."
+	defaultLocation = "centralindia"
+)
+
+func GetOpenshiftSNCCmd() *cobra.Command {
+	c := &cobra.Command{
+		Use:   cmdOpenshiftSNC,
+		Short: cmdOpenshiftSNCDesc,
+		RunE: func(cmd *cobra.Command, args []string) error {
+			if err := viper.BindPFlags(cmd.Flags()); err != nil {
+				return err
+			}
+			return nil
+		},
+	}
+	flagSet := pflag.NewFlagSet(cmdOpenshiftSNC, pflag.ExitOnError)
+	params.AddCommonFlags(flagSet)
+	c.PersistentFlags().AddFlagSet(flagSet)
+	c.AddCommand(createSNC(), destroySNC())
+	return c
+
+}
+
+func createSNC() *cobra.Command {
+	c := &cobra.Command{
+		Use:   params.CreateCmdName,
+		Short: params.CreateCmdName,
+		RunE: func(cmd *cobra.Command, args []string) error {
+			if err := viper.BindPFlags(cmd.Flags()); err != nil {
+				return err
+			}
+
+			if err := openshiftsnc.Create(
+				&maptContext.ContextArgs{
+					ProjectName:   viper.GetString(params.ProjectName),
+					BackedURL:     viper.GetString(params.BackedURL),
+					ResultsOutput: viper.GetString(params.ConnectionDetailsOutput),
+					Debug:         viper.IsSet(params.Debug),
+					DebugLevel:    viper.GetUint(params.DebugLevel),
+					Tags:          viper.GetStringMapString(params.Tags),
+				},
+				&sncAPI.OpenshiftSNCArgs{
+					ComputeRequest: params.ComputeRequestArgs(),
+					Version:        viper.GetString(ocpVersion),
+					Arch:           viper.GetString(params.LinuxArch),
+					PullSecretFile: viper.GetString(pullSecretFile),
+					Spot:           params.SpotArgs(),
+					Location:       viper.GetString(location),
+					Timeout:        viper.GetString(params.Timeout)}); err != nil {
+				logging.Error(err)
+			}
+			return nil
+		},
+	}
+	flagSet := pflag.NewFlagSet(params.CreateCmdName, pflag.ExitOnError)
+	flagSet.StringP(params.ConnectionDetailsOutput, "", "", params.ConnectionDetailsOutputDesc)
+	flagSet.StringP(ocpVersion, "", "", ocpVersionDesc)
+	flagSet.StringP(params.LinuxArch, "", params.LinuxArchDefault, params.LinuxArchDesc)
+	flagSet.StringP(pullSecretFile, "", "", pullSecretFileDesc)
+	flagSet.StringP(params.Timeout, "", "", params.TimeoutDesc)
+	flagSet.StringP(location, "", defaultLocation, locationDesc)
+	flagSet.StringToStringP(params.Tags, "", nil, params.TagsDesc)
+	params.AddComputeRequestFlags(flagSet)
+	params.AddSpotFlags(flagSet)
+	c.PersistentFlags().AddFlagSet(flagSet)
+	return c
+}
+
+func destroySNC() *cobra.Command {
+	c := &cobra.Command{
+		Use:   params.DestroyCmdName,
+		Short: params.DestroyCmdName,
+		RunE: func(cmd *cobra.Command, args []string) error {
+			if err := viper.BindPFlags(cmd.Flags()); err != nil {
+				return err
+			}
+
+			if err := openshiftsnc.Destroy(&maptContext.ContextArgs{
+				ProjectName: viper.GetString(params.ProjectName),
+				BackedURL:   viper.GetString(params.BackedURL),
+				Debug:       viper.IsSet(params.Debug),
+				DebugLevel:  viper.GetUint(params.DebugLevel),
+				Serverless:  viper.IsSet(params.Serverless),
+			}); err != nil {
+				logging.Error(err)
+			}
+			return nil
+		},
+	}
+	flagSet := pflag.NewFlagSet(params.DestroyCmdName, pflag.ExitOnError)
+	flagSet.Bool(params.Serverless, false, params.ServerlessDesc)
+	c.PersistentFlags().AddFlagSet(flagSet)
+	return c
+}

pkg/provider/api/openshift-snc/snc.go

@@ -24,6 +24,7 @@ var (
 )
 
 type OpenshiftSNCArgs struct {
+	Location       string
 	Prefix         string
 	ComputeRequest *cr.ComputeRequestArgs
 	Version        string

pkg/provider/azure/action/linux/linux.go

@@ -178,7 +178,6 @@ func (r *linuxRequest) deployer(ctx *pulumi.Context) error {
 			return fmt.Errorf("error creating RHEL Server on Azure: %v", err)
 		}
 	}
-
 	vm, err := virtualmachine.Create(ctx, r.mCtx,
 		&virtualmachine.VirtualMachineArgs{
 			Prefix:          *r.prefix,
@@ -194,7 +193,7 @@ func (r *linuxRequest) deployer(ctx *pulumi.Context) error {
 			AdminUsername: *r.username,
 			PrivateKey:    privateKey,
 			SpotPrice:     r.allocationData.Price,
-			Userdata:      userDataB64,
+			Userdata:      pulumi.String(userDataB64),
 			Location:      *r.allocationData.Location,
 		})
 	if err != nil {

pkg/provider/azure/action/openshift-snc/cloud-config

@@ -0,0 +1,35 @@
+#cloud-config
+runcmd:
+  - systemctl enable --now kubelet
+write_files:
+- path: /home/core/.ssh/authorized_keys
+  content: {{ .PubKey }}
+  owner: {{ .Username }}
+  permissions: '0600'
+- path: /opt/crc/id_rsa.pub
+  content: {{ .PubKey }}
+  owner: root:root
+  permissions: '0644'
+- content: |
+      CRC_CLOUD=1
+      CRC_NETWORK_MODE_USER=0
+  owner: root:root
+  path: /etc/sysconfig/crc-env
+  permissions: '0644'
+- path: /opt/crc/pull-secret
+  content: |
+      {{ .PullSecret }}
+  owner: root:root
+  permissions: '0644'
+- path: /opt/crc/pass_developer
+  content: '{{ .PassDeveloper }}'
+  owner: root:root
+  permissions: '0644'
+- path: /opt/crc/pass_kubeadmin
+  content: '{{ .PassKubeadmin }}'
+  owner: root:root
+  permissions: '0644'
+- path: /opt/crc/eip
+  content: '{{ .PublicIP }}'
+  owner: root:root
+  permissions: '0644'