mapt/pkg/provider/openshift/action/rhoai/rhoai.go at 132edf343465bfa247e99ec48cd843cb7bfff894 · redhat-developer/mapt · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
package rhoai

import (
	"fmt"
	"os"

	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
	"github.com/redhat-developer/mapt/pkg/manager"
	mc "github.com/redhat-developer/mapt/pkg/manager/context"
	"github.com/redhat-developer/mapt/pkg/provider/openshift"
	"github.com/redhat-developer/mapt/pkg/provider/openshift/profile"
	"github.com/redhat-developer/mapt/pkg/util/logging"
)

const (
	StackName     = "stackOpenshiftRHOAI"
	defaultPrefix = "rhoai"
)

type RHOAIArgs struct {
	KubeconfigPath string
	Profiles       []string
	Prefix         string
}

type rhoaiRequest struct {
	mCtx           *mc.Context
	prefix         string
	kubeconfigPath string
	profiles       []string
}

func Create(mCtxArgs *mc.ContextArgs, args *RHOAIArgs) error {
	mCtx, err := mc.Init(mCtxArgs, openshift.Provider())
	if err != nil {
		return err
	}
	if err := profile.Validate(args.Profiles); err != nil {
		return err
	}
	prefix := args.Prefix
	if prefix == "" {
		prefix = defaultPrefix
	}
	r := &rhoaiRequest{
		mCtx:           mCtx,
		prefix:         prefix,
		kubeconfigPath: args.KubeconfigPath,
		profiles:       args.Profiles,
	}
	return r.deploy()
}

func Destroy(mCtxArgs *mc.ContextArgs) error {
	logging.Debug("Run openshift rhoai destroy")
	mCtx, err := mc.Init(mCtxArgs, openshift.Provider())
	if err != nil {
		return err
	}
	return openshift.DestroyStack(mCtx, StackName)
}

func (r *rhoaiRequest) deploy() error {
	cs := manager.Stack{
		StackName:           r.mCtx.StackNameByProject(StackName),
		ProjectName:         r.mCtx.ProjectName(),
		BackedURL:           r.mCtx.BackedURL(),
		ProviderCredentials: openshift.NoCredentials,
		DeployFunc:          r.pulumiProgram,
	}
	_, err := manager.UpStack(r.mCtx, cs)
	if err != nil {
		return fmt.Errorf("stack creation failed: %w", err)
	}
	return nil
}

func (r *rhoaiRequest) pulumiProgram(ctx *pulumi.Context) error {
	kcBytes, err := os.ReadFile(r.kubeconfigPath)
	if err != nil {
		return fmt.Errorf("reading kubeconfig from %s: %w", r.kubeconfigPath, err)
	}
	kubeconfig := pulumi.String(string(kcBytes)).ToStringOutput()

	k8sProvider, err := profile.NewK8sProvider(ctx, "k8s-provider", kubeconfig)
	if err != nil {
		return err
	}

	return profile.Deploy(ctx, r.profiles, &profile.DeployArgs{
		K8sProvider: k8sProvider,
		Kubeconfig:  kubeconfig,
		Prefix:      r.prefix,
	})
}