install operator via helm on a byok cluster

Author: floreks

go.mod

@@ -13,6 +13,8 @@ require (
 	github.com/pluralsh/plural-cli v0.8.1-0.20231114161007-183eafb99b03
 	github.com/pluralsh/polly v0.1.4
 	github.com/samber/lo v1.38.1
+	github.com/sirupsen/logrus v1.9.3
+	helm.sh/helm/v3 v3.11.2
 	k8s.io/apimachinery v0.26.4
 	k8s.io/client-go v0.26.4
 )
@@ -254,7 +256,6 @@ require (
 	github.com/sergi/go-diff v1.3.1 // indirect
 	github.com/shazow/go-diff v0.0.0-20160112020656-b6b7b6733b8c // indirect
 	github.com/shopspring/decimal v1.3.1 // indirect
-	github.com/sirupsen/logrus v1.9.3 // indirect
 	github.com/sivchari/containedctx v1.0.3 // indirect
 	github.com/sivchari/nosnakecase v1.7.0 // indirect
 	github.com/sivchari/tenv v1.7.1 // indirect
@@ -324,7 +325,6 @@ require (
 	gopkg.in/warnings.v0 v0.1.2 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
-	helm.sh/helm/v3 v3.11.2 // indirect
 	honnef.co/go/tools v0.4.6 // indirect
 	k8s.io/api v0.26.4 // indirect
 	k8s.io/apiextensions-apiserver v0.26.1 // indirect

internal/datasource/cluster.go

@@ -69,7 +69,7 @@ func (d *clusterDataSource) Configure(_ context.Context, req datasource.Configur
 		return
 	}
 
-	c, ok := req.ProviderData.(*client.Client)
+	data, ok := req.ProviderData.(*model.ProviderData)
 	if !ok {
 		resp.Diagnostics.AddError(
 			"Unexpected Cluster Resource Configure Type",
@@ -78,7 +78,7 @@ func (d *clusterDataSource) Configure(_ context.Context, req datasource.Configur
 		return
 	}
 
-	d.client = c
+	d.client = data.Client
 }
 
 func (d *clusterDataSource) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse) {

internal/datasource/gitrepository.go

@@ -14,6 +14,7 @@ import (
 	"github.com/samber/lo"
 
 	"terraform-provider-plural/internal/client"
+	"terraform-provider-plural/internal/model"
 )
 
 func NewGitRepositoryDataSource() datasource.DataSource {
@@ -90,8 +91,7 @@ func (r *GitRepositoryDataSource) Configure(_ context.Context, req datasource.Co
 		return
 	}
 
-	c, ok := req.ProviderData.(*client.Client)
-
+	data, ok := req.ProviderData.(*model.ProviderData)
 	if !ok {
 		resp.Diagnostics.AddError(
 			"Unexpected GitRepository Resource Configure Type",
@@ -101,7 +101,7 @@ func (r *GitRepositoryDataSource) Configure(_ context.Context, req datasource.Co
 		return
 	}
 
-	r.client = c
+	r.client = data.Client
 }
 
 func (r *GitRepositoryDataSource) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse) {

internal/model/cluster.go

@@ -0,0 +1,40 @@
+package model
+
+import "github.com/hashicorp/terraform-plugin-framework/types"
+
+// Cluster describes the cluster resource and data source model.
+type Cluster struct {
+	Id         types.String `tfsdk:"id"`
+	InseredAt  types.String `tfsdk:"inserted_at"`
+	Name       types.String `tfsdk:"name"`
+	Handle     types.String `tfsdk:"handle"`
+	Cloud      types.String `tfsdk:"cloud"`
+	Protect    types.Bool   `tfsdk:"protect"`
+	Tags       types.Map    `tfsdk:"tags"`
+	Kubeconfig Kubeconfig   `tfsdk:"kubeconfig"`
+}
+
+type Kubeconfig struct {
+	Host                  types.String    `tfsdk:"host"`
+	Username              types.String    `tfsdk:"username"`
+	Password              types.String    `tfsdk:"password"`
+	Insecure              types.Bool      `tfsdk:"insecure"`
+	TlsServerName         types.String    `tfsdk:"tls_server_name"`
+	ClientCertificate     types.String    `tfsdk:"client_certificate"`
+	ClientKey             types.String    `tfsdk:"client_key"`
+	ClusterCACertificate  types.String    `tfsdk:"cluster_ca_certificate"`
+	ConfigPath            types.String    `tfsdk:"config_path"`
+	ConfigContext         types.String    `tfsdk:"config_context"`
+	ConfigContextAuthInfo types.String    `tfsdk:"config_context_auth_info"`
+	ConfigContextCluster  types.String    `tfsdk:"config_context_cluster"`
+	Token                 types.String    `tfsdk:"token"`
+	ProxyURL              types.String    `tfsdk:"proxy_url"`
+	Exec                  *KubeconfigExec `tfsdk:"exec"`
+}
+
+type KubeconfigExec struct {
+	Command    types.String `tfsdk:"command"`
+	Args       types.String `tfsdk:"args"`
+	Env        types.String `tfsdk:"env"`
+	APIVersion types.String `tfsdk:"api_version"`
+}

internal/model/model.go

@@ -0,0 +1,17 @@
+package model
+
+import (
+	internalclient "terraform-provider-plural/internal/client"
+)
+
+type ProviderData struct {
+	Client     *internalclient.Client
+	ConsoleUrl string
+}
+
+func NewProviderData(client *internalclient.Client, consoleUrl string) *ProviderData {
+	return &ProviderData{
+		Client:     client,
+		ConsoleUrl: consoleUrl,
+	}
+}

internal/model/provider.go

@@ -9,6 +9,7 @@ import (
 
 	internalclient "terraform-provider-plural/internal/client"
 	ds "terraform-provider-plural/internal/datasource"
+	"terraform-provider-plural/internal/model"
 	r "terraform-provider-plural/internal/resource"
 
 	"github.com/hashicorp/terraform-plugin-framework-validators/boolvalidator"
@@ -158,8 +159,8 @@ func (p *PluralProvider) Configure(ctx context.Context, req provider.ConfigureRe
 
 	internalClient := internalclient.NewClient(consoleClient)
 
-	resp.ResourceData = internalClient
-	resp.DataSourceData = internalClient
+	resp.ResourceData = model.NewProviderData(internalClient, consoleUrl)
+	resp.DataSourceData = model.NewProviderData(internalClient, consoleUrl)
 }
 
 func (p *PluralProvider) Resources(_ context.Context) []func() resource.Resource {

internal/provider/provider.go

@@ -4,6 +4,8 @@ import (
 	"context"
 	"fmt"
 
+	"github.com/hashicorp/terraform-plugin-framework/resource/schema/booldefault"
+
 	"terraform-provider-plural/internal/client"
 	"terraform-provider-plural/internal/model"
 
@@ -28,7 +30,8 @@ func NewClusterResource() resource.Resource {
 
 // ClusterResource defines the cluster resource implementation.
 type clusterResource struct {
-	client *client.Client
+	client     *client.Client
+	consoleUrl string
 }
 
 func (r *clusterResource) Metadata(_ context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse) {
@@ -67,6 +70,8 @@ func (r *clusterResource) Schema(_ context.Context, _ resource.SchemaRequest, re
 			"protect": schema.BoolAttribute{
 				MarkdownDescription: "If set to `true` then this cluster cannot be deleted.",
 				Optional:            true,
+				Computed:            true,
+				Default:             booldefault.StaticBool(false),
 			},
 			"tags": schema.MapAttribute{
 				MarkdownDescription: "Key-value tags used to filter clusters.",
@@ -83,7 +88,7 @@ func (r *clusterResource) Configure(_ context.Context, req resource.ConfigureReq
 		return
 	}
 
-	c, ok := req.ProviderData.(*client.Client)
+	data, ok := req.ProviderData.(*model.ProviderData)
 	if !ok {
 		resp.Diagnostics.AddError(
 			"Unexpected Cluster Resource Configure Type",
@@ -92,7 +97,8 @@ func (r *clusterResource) Configure(_ context.Context, req resource.ConfigureReq
 		return
 	}
 
-	r.client = c
+	r.client = data.Client
+	r.consoleUrl = data.ConsoleUrl
 }
 
 func (r *clusterResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
@@ -127,10 +133,11 @@ func (r *clusterResource) Create(ctx context.Context, req resource.CreateRequest
 			return
 		}
 
-		// TODO:
-		//   deployToken := *cluster.CreateCluster.DeployToken
-		//   url := fmt.Sprintf("%s/ext/gql", p.ConsoleClient.Url())
-		//   p.doInstallOperator(url, deployToken)
+		err = doInstallOperator(ctx, data.Kubeconfig, r.consoleUrl, *cluster.CreateCluster.DeployToken)
+		if err != nil {
+			resp.Diagnostics.AddError("Client Error", fmt.Sprintf("Unable to install operator, got error: %s", err))
+			return
+		}
 
 		tflog.Trace(ctx, "installed the cluster operator")
 	}