mirror of
https://github.com/edgelesssys/constellation.git
synced 2024-10-01 01:36:09 -04:00
202 lines
6.5 KiB
Go
202 lines
6.5 KiB
Go
|
/*
|
||
|
Copyright (c) Edgeless Systems GmbH
|
||
|
|
||
|
SPDX-License-Identifier: AGPL-3.0-only
|
||
|
*/
|
||
|
|
||
|
package provider
|
||
|
|
||
|
import (
|
||
|
"context"
|
||
|
"fmt"
|
||
|
"net/http"
|
||
|
|
||
|
"github.com/hashicorp/terraform-plugin-framework/path"
|
||
|
"github.com/hashicorp/terraform-plugin-framework/resource"
|
||
|
"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/stringdefault"
|
||
|
"github.com/hashicorp/terraform-plugin-framework/resource/schema/stringplanmodifier"
|
||
|
"github.com/hashicorp/terraform-plugin-framework/types"
|
||
|
"github.com/hashicorp/terraform-plugin-log/tflog"
|
||
|
)
|
||
|
|
||
|
// Ensure provider defined types fully satisfy framework interfaces.
|
||
|
var (
|
||
|
_ resource.Resource = &ExampleResource{}
|
||
|
_ resource.ResourceWithImportState = &ExampleResource{}
|
||
|
)
|
||
|
|
||
|
// NewExampleResource creates a new examplary resource.
|
||
|
func NewExampleResource() resource.Resource {
|
||
|
return &ExampleResource{}
|
||
|
}
|
||
|
|
||
|
// ExampleResource defines the resource implementation.
|
||
|
type ExampleResource struct {
|
||
|
client *http.Client
|
||
|
}
|
||
|
|
||
|
// ExampleResourceModel describes the resource data model.
|
||
|
type ExampleResourceModel struct {
|
||
|
ConfigurableAttribute types.String `tfsdk:"configurable_attribute"`
|
||
|
Defaulted types.String `tfsdk:"defaulted"`
|
||
|
ID types.String `tfsdk:"id"`
|
||
|
}
|
||
|
|
||
|
// Metadata returns the metadata of the resource.
|
||
|
func (r *ExampleResource) Metadata(_ context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse) {
|
||
|
resp.TypeName = req.ProviderTypeName + "_example"
|
||
|
}
|
||
|
|
||
|
// Schema returns the schema of the resource.
|
||
|
func (r *ExampleResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse) {
|
||
|
resp.Schema = schema.Schema{
|
||
|
// This description is used by the documentation generator and the language server.
|
||
|
MarkdownDescription: "Example resource",
|
||
|
|
||
|
Attributes: map[string]schema.Attribute{
|
||
|
"configurable_attribute": schema.StringAttribute{
|
||
|
MarkdownDescription: "Example configurable attribute",
|
||
|
Optional: true,
|
||
|
},
|
||
|
"defaulted": schema.StringAttribute{
|
||
|
MarkdownDescription: "Example configurable attribute with default value",
|
||
|
Optional: true,
|
||
|
Computed: true,
|
||
|
Default: stringdefault.StaticString("example value when not configured"),
|
||
|
},
|
||
|
"id": schema.StringAttribute{
|
||
|
Computed: true,
|
||
|
MarkdownDescription: "Example identifier",
|
||
|
PlanModifiers: []planmodifier.String{
|
||
|
stringplanmodifier.UseStateForUnknown(),
|
||
|
},
|
||
|
},
|
||
|
},
|
||
|
}
|
||
|
}
|
||
|
|
||
|
// Configure configures the resource.
|
||
|
func (r *ExampleResource) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse) {
|
||
|
// Prevent panic if the provider has not been configured.
|
||
|
if req.ProviderData == nil {
|
||
|
return
|
||
|
}
|
||
|
|
||
|
client, ok := req.ProviderData.(*http.Client)
|
||
|
|
||
|
if !ok {
|
||
|
resp.Diagnostics.AddError(
|
||
|
"Unexpected Resource Configure Type",
|
||
|
fmt.Sprintf("Expected *http.Client, got: %T. Please report this issue to the provider developers.", req.ProviderData),
|
||
|
)
|
||
|
|
||
|
return
|
||
|
}
|
||
|
|
||
|
r.client = client
|
||
|
}
|
||
|
|
||
|
// Create is called when the resource is created.
|
||
|
func (r *ExampleResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
|
||
|
var data ExampleResourceModel
|
||
|
|
||
|
// Read Terraform plan data into the model
|
||
|
resp.Diagnostics.Append(req.Plan.Get(ctx, &data)...)
|
||
|
|
||
|
if resp.Diagnostics.HasError() {
|
||
|
return
|
||
|
}
|
||
|
|
||
|
// If applicable, this is a great opportunity to initialize any necessary
|
||
|
// provider client data and make a call using it.
|
||
|
// httpResp, err := r.client.Do(httpReq)
|
||
|
// if err != nil {
|
||
|
// resp.Diagnostics.AddError("Client Error", fmt.Sprintf("Unable to create example, got error: %s", err))
|
||
|
// return
|
||
|
// }
|
||
|
|
||
|
// For the purposes of this example code, hardcoding a response value to
|
||
|
// save into the Terraform state.
|
||
|
data.ID = types.StringValue("example-id")
|
||
|
|
||
|
// Write logs using the tflog package
|
||
|
// Documentation: https://terraform.io/plugin/log
|
||
|
tflog.Trace(ctx, "created a resource")
|
||
|
|
||
|
// Save data into Terraform state
|
||
|
resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
|
||
|
}
|
||
|
|
||
|
// Read is called when the resource is read or refreshed.
|
||
|
func (r *ExampleResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse) {
|
||
|
var data ExampleResourceModel
|
||
|
|
||
|
// Read Terraform prior state data into the model
|
||
|
resp.Diagnostics.Append(req.State.Get(ctx, &data)...)
|
||
|
|
||
|
if resp.Diagnostics.HasError() {
|
||
|
return
|
||
|
}
|
||
|
|
||
|
// If applicable, this is a great opportunity to initialize any necessary
|
||
|
// provider client data and make a call using it.
|
||
|
// httpResp, err := r.client.Do(httpReq)
|
||
|
// if err != nil {
|
||
|
// resp.Diagnostics.AddError("Client Error", fmt.Sprintf("Unable to read example, got error: %s", err))
|
||
|
// return
|
||
|
// }
|
||
|
|
||
|
// Save updated data into Terraform state
|
||
|
resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
|
||
|
}
|
||
|
|
||
|
// Update is called when the resource is updated.
|
||
|
func (r *ExampleResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse) {
|
||
|
var data ExampleResourceModel
|
||
|
|
||
|
// Read Terraform plan data into the model
|
||
|
resp.Diagnostics.Append(req.Plan.Get(ctx, &data)...)
|
||
|
|
||
|
if resp.Diagnostics.HasError() {
|
||
|
return
|
||
|
}
|
||
|
|
||
|
// If applicable, this is a great opportunity to initialize any necessary
|
||
|
// provider client data and make a call using it.
|
||
|
// httpResp, err := r.client.Do(httpReq)
|
||
|
// if err != nil {
|
||
|
// resp.Diagnostics.AddError("Client Error", fmt.Sprintf("Unable to update example, got error: %s", err))
|
||
|
// return
|
||
|
// }
|
||
|
|
||
|
// Save updated data into Terraform state
|
||
|
resp.Diagnostics.Append(resp.State.Set(ctx, &data)...)
|
||
|
}
|
||
|
|
||
|
// Delete is called when the resource is destroyed.
|
||
|
func (r *ExampleResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse) {
|
||
|
var data ExampleResourceModel
|
||
|
|
||
|
// Read Terraform prior state data into the model
|
||
|
resp.Diagnostics.Append(req.State.Get(ctx, &data)...)
|
||
|
|
||
|
if resp.Diagnostics.HasError() {
|
||
|
return
|
||
|
}
|
||
|
|
||
|
// If applicable, this is a great opportunity to initialize any necessary
|
||
|
// provider client data and make a call using it.
|
||
|
// httpResp, err := r.client.Do(httpReq)
|
||
|
// if err != nil {
|
||
|
// resp.Diagnostics.AddError("Client Error", fmt.Sprintf("Unable to delete example, got error: %s", err))
|
||
|
// return
|
||
|
// }
|
||
|
}
|
||
|
|
||
|
// ImportState imports to the resource.
|
||
|
func (r *ExampleResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse) {
|
||
|
resource.ImportStatePassthroughID(ctx, path.Root("id"), req, resp)
|
||
|
}
|