SUP-1084 Add Cluster resource

buildkite/graphql/cluster.graphql

@@ -0,0 +1,70 @@
+fragment ClusterFields on Cluster {
+    id
+    uuid
+    name
+    description
+    emoji
+    color
+}
+
+query getCluster($orgSlug: ID!, $id: ID!) {
+    organization(slug: $orgSlug) {
+        cluster(id: $id) {
+            ...ClusterFields
+        }
+    }
+}
+
+# @genqlient(for: "ClusterCreateInput.description", pointer: true)
+# @genqlient(for: "ClusterCreateInput.emoji", pointer: true)
+# @genqlient(for: "ClusterCreateInput.color", pointer: true)
+mutation createCluster(
+  $organizationId: ID!
+  $name: String!
+  $description: String
+  $emoji: String
+  $color: String
+  ) {
+    clusterCreate(
+        input: { organizationId: $organizationId, name: $name, description: $description, emoji: $emoji, color: $color }
+    ) {
+        clientMutationId
+        cluster {
+            ...ClusterFields
+        }
+    }
+}
+
+# @genqlient(for: "ClusterUpdateInput.description", pointer: true)
+# @genqlient(for: "ClusterUpdateInput.emoji", pointer: true)
+# @genqlient(for: "ClusterUpdateInput.color", pointer: true)
+mutation updateCluster(
+    $organizationId: ID!
+    $id: ID!
+    $name: String
+    $description: String
+    $emoji: String
+    $color: String
+) {
+    clusterUpdate(
+        input: {
+            organizationId: $organizationId
+            id: $id
+            name: $name
+            description: $description
+            emoji: $emoji
+            color: $color
+        }
+    ) {
+        clientMutationId
+        cluster {
+            ...ClusterFields
+        }
+    }
+}
+
+mutation deleteCluster($organizationId: ID!, $id: ID!) {
+    clusterDelete(input: { organizationId: $organizationId, id: $id }) {
+        clientMutationId
+    }
+}

buildkite/provider.go

@@ -92,6 +92,7 @@ func (tf *terraformProvider) Metadata(ctx context.Context, req provider.Metadata
 func (*terraformProvider) Resources(context.Context) []func() resource.Resource {
 	return []func() resource.Resource{
 		NewAgentTokenResource,
+		newClusterResource,
 	}
 }
 

buildkite/resource_cluster.go

@@ -0,0 +1,216 @@
+package buildkite
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-framework/path"
+	"github.com/hashicorp/terraform-plugin-framework/resource"
+	resource_schema "github.com/hashicorp/terraform-plugin-framework/resource/schema"
+	"github.com/hashicorp/terraform-plugin-framework/resource/schema/planmodifier"
+	"github.com/hashicorp/terraform-plugin-framework/resource/schema/stringplanmodifier"
+	"github.com/hashicorp/terraform-plugin-framework/types"
+)
+
+type clusterResource struct {
+	client *Client
+}
+
+type clusterResourceModel struct {
+	ID          types.String `tfsdk:"id"`
+	Name        types.String `tfsdk:"name"`
+	Description types.String `tfsdk:"description"`
+	Emoji       types.String `tfsdk:"emoji"`
+	Color       types.String `tfsdk:"color"`
+	UUID        types.String `tfsdk:"uuid"`
+}
+
+func newClusterResource() resource.Resource {
+	return &clusterResource{}
+}
+
+func (c *clusterResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse) {
+	resp.TypeName = req.ProviderTypeName + "_cluster"
+}
+
+func (c *clusterResource) Configure(ctx context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse) {
+	if req.ProviderData == nil {
+		return
+	}
+
+	c.client = req.ProviderData.(*Client)
+}
+
+func (c *clusterResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse) {
+	resp.Schema = resource_schema.Schema{
+		MarkdownDescription: "A Cluster is a group of Agents that can be used to run your builds. " +
+			"Clusters are useful for grouping Agents by their capabilities, such as operating system, hardware, or location. ",
+		Attributes: map[string]resource_schema.Attribute{
+			"id": resource_schema.StringAttribute{
+				Computed: true,
+				PlanModifiers: []planmodifier.String{
+					stringplanmodifier.UseStateForUnknown(),
+				},
+			},
+			"uuid": resource_schema.StringAttribute{
+				Computed: true,
+				PlanModifiers: []planmodifier.String{
+					stringplanmodifier.UseStateForUnknown(),
+				},
+			},
+			"name": resource_schema.StringAttribute{
+				MarkdownDescription: "The name of the Cluster. Can only contain numbers and letters, no spaces or special characters.",
+				Required:            true,
+			},
+			"description": resource_schema.StringAttribute{
+				Optional:            true,
+				MarkdownDescription: "A description for the Cluster. Consider something short but clear on the Cluster's function.",
+			},
+			"emoji": resource_schema.StringAttribute{
+				Optional:            true,
+				MarkdownDescription: "An emoji to represent the Cluster. Accepts the format :buildkite:.",
+			},
+			"color": resource_schema.StringAttribute{
+				Optional:            true,
+				MarkdownDescription: "A color representation of the Cluster. Accepts hex codes, eg #BADA55.",
+			},
+		},
+	}
+}
+
+func (c *clusterResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
+	var state *clusterResourceModel
+	resp.Diagnostics.Append(req.Plan.Get(ctx, &state)...)
+
+	if resp.Diagnostics.HasError() {
+		return
+	}
+
+	r, err := createCluster(
+		c.client.genqlient,
+		c.client.organizationId,
+		state.Name.ValueString(),
+		state.Description.ValueString(),
+		state.Emoji.ValueString(),
+		state.Color.ValueString(),
+	)
+
+	if err != nil {
+		resp.Diagnostics.AddError(
+			"Unable to create Cluster",
+			fmt.Sprintf("Unable to create Cluster: %s", err.Error()),
+		)
+		return
+	}
+
+	state.ID = types.StringValue(r.ClusterCreate.Cluster.Id)
+	state.UUID = types.StringValue(r.ClusterCreate.Cluster.Uuid)
+
+	resp.Diagnostics.Append(resp.State.Set(ctx, &state)...)
+}
+
+func (c *clusterResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse) {
+	var state clusterResourceModel
+
+	resp.Diagnostics.Append(req.State.Get(ctx, &state)...)
+
+	if resp.Diagnostics.HasError() {
+		return
+	}
+
+	_, err := getCluster(c.client.genqlient, c.client.organization, state.UUID.ValueString())
+
+	if err != nil {
+		resp.Diagnostics.AddError(
+			"Unable to read Cluster",
+			fmt.Sprintf("Unable to read Cluster: %s", err.Error()),
+		)
+		return
+	}
+
+	resp.Diagnostics.Append(resp.State.Set(ctx, &state)...)
+}
+
+func (c *clusterResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse) {
+	var state, plan clusterResourceModel
+
+	resp.Diagnostics.Append(req.State.Get(ctx, &state)...)
+	resp.Diagnostics.Append(req.Plan.Get(ctx, &plan)...)
+
+	if resp.Diagnostics.HasError() {
+		return
+	}
+
+	id := state.ID.ValueString()
+
+	_, err := updateCluster(
+		c.client.genqlient,
+		c.client.organizationId,
+		id,
+		plan.Name.ValueString(),
+		plan.Description.ValueString(),
+		plan.Emoji.ValueString(),
+		plan.Color.ValueString(),
+	)
+
+	if err != nil {
+		resp.Diagnostics.AddError(
+			"Unable to update Cluster",
+			fmt.Sprintf("Unable to update Cluster: %s", err.Error()),
+		)
+		return
+	}
+
+	resp.Diagnostics.Append(resp.State.Set(ctx, &plan)...)
+}
+
+func (c *clusterResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse) {
+	var state clusterResourceModel
+
+	resp.Diagnostics.Append(req.State.Get(ctx, &state)...)
+
+	if resp.Diagnostics.HasError() {
+		return
+	}
+
+	_, err := deleteCluster(c.client.genqlient, c.client.organizationId, state.ID.ValueString())
+
+	if err != nil {
+		resp.Diagnostics.AddError(
+			"Unable to delete Cluster",
+			fmt.Sprintf("Unable to delete Cluster: %s", err.Error()),
+		)
+		return
+	}
+}
+
+func (c *clusterResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse) {
+	uuid := req.ID
+
+	if uuid == "" {
+		resp.Diagnostics.AddError(
+			"Unable to import Cluster",
+			"Unable to import Cluster, no UUID was provided",
+		)
+		return
+	}
+
+	cluster, err := getCluster(c.client.genqlient, c.client.organization, uuid)
+
+	if err != nil {
+		resp.Diagnostics.AddError(
+			"Unable to import Cluster",
+			fmt.Sprintf("Unable to import Cluster: %s", err.Error()),
+		)
+		return
+	}
+
+	id := cluster.Organization.Cluster.Id
+
+	resp.Diagnostics.Append(resp.State.SetAttribute(ctx, path.Root("id"), types.StringValue(id))...)
+	resp.Diagnostics.Append(resp.State.SetAttribute(ctx, path.Root("uuid"), uuid)...)
+	resp.Diagnostics.Append(resp.State.SetAttribute(ctx, path.Root("name"), types.StringValue(cluster.Organization.Cluster.Name))...)
+	resp.Diagnostics.Append(resp.State.SetAttribute(ctx, path.Root("description"), types.StringValue(cluster.Organization.Cluster.Description))...)
+	resp.Diagnostics.Append(resp.State.SetAttribute(ctx, path.Root("emoji"), types.StringValue(cluster.Organization.Cluster.Emoji))...)
+	resp.Diagnostics.Append(resp.State.SetAttribute(ctx, path.Root("color"), types.StringValue(cluster.Organization.Cluster.Color))...)
+}