-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: adding sensor and agent resources (#7)
- Loading branch information
1 parent
b13e7ef
commit 0062003
Showing
12 changed files
with
681 additions
and
24 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,191 @@ | ||
| package resources | ||
|
|
||
| import ( | ||
| "context" | ||
|
|
||
| // "github.com/aruba-uxi/configuration-api-terraform-provider/pkg/config-api-client" | ||
| "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/stringplanmodifier" | ||
| "github.com/hashicorp/terraform-plugin-framework/types" | ||
| ) | ||
|
|
||
| // Ensure the implementation satisfies the expected interfaces. | ||
| var ( | ||
| _ resource.Resource = &agentResource{} | ||
| _ resource.ResourceWithConfigure = &agentResource{} | ||
| ) | ||
|
|
||
| type agentResourceModel struct { | ||
| ID types.String `tfsdk:"id"` | ||
| Name types.String `tfsdk:"name"` | ||
| Notes types.String `tfsdk:"notes"` | ||
| PCapMode types.String `tfsdk:"pcap_mode"` | ||
| } | ||
|
|
||
| // TODO: Switch this to use the Client Model when that becomes available | ||
| type AgentResponseModel struct { | ||
| UID string | ||
| Serial string | ||
| Name string | ||
| ModelNumber string | ||
| WifiMacAddress string | ||
| EthernetMacAddress string | ||
| Notes string | ||
| PCapMode string | ||
| } | ||
|
|
||
| // TODO: Switch this to use the Client Model when that becomes available | ||
| type AgentUpdateRequestModel struct { | ||
| Name string | ||
| Notes string | ||
| PCapMode string | ||
| } | ||
|
|
||
| func NewAgentResource() resource.Resource { | ||
| return &agentResource{} | ||
| } | ||
|
|
||
| type agentResource struct{} | ||
|
|
||
| func (r *agentResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse) { | ||
| resp.TypeName = req.ProviderTypeName + "_agent" | ||
| } | ||
|
|
||
| func (r *agentResource) Schema(_ context.Context, _ resource.SchemaRequest, resp *resource.SchemaResponse) { | ||
| resp.Schema = schema.Schema{ | ||
| Attributes: map[string]schema.Attribute{ | ||
| "id": schema.StringAttribute{ | ||
| Computed: true, | ||
| PlanModifiers: []planmodifier.String{ | ||
| stringplanmodifier.UseStateForUnknown(), | ||
| }, | ||
| }, | ||
| "name": schema.StringAttribute{ | ||
| Required: true, | ||
| }, | ||
| "notes": schema.StringAttribute{ | ||
| Optional: true, | ||
| }, | ||
| "pcap_mode": schema.StringAttribute{ | ||
| Optional: true, | ||
| }, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| func (r *agentResource) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse) { | ||
|
|
||
| } | ||
|
|
||
| func (r *agentResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) { | ||
| // Retrieve values from plan | ||
| var plan agentResourceModel | ||
| diags := req.Plan.Get(ctx, &plan) | ||
| diags.AddError("operation not supported", "creating an agent is not supported; agents can only be imported") | ||
| resp.Diagnostics.Append(diags...) | ||
| } | ||
|
|
||
| func (r *agentResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse) { | ||
| // Get current state | ||
| var state agentResourceModel | ||
| diags := req.State.Get(ctx, &state) | ||
| resp.Diagnostics.Append(diags...) | ||
| if resp.Diagnostics.HasError() { | ||
| return | ||
| } | ||
|
|
||
| response := GetAgent() | ||
|
|
||
| // Update state from client response | ||
| state.Name = types.StringValue(response.Name) | ||
| state.Notes = types.StringValue(response.Notes) | ||
| state.PCapMode = types.StringValue(response.PCapMode) | ||
|
|
||
| // Set refreshed state | ||
| diags = resp.State.Set(ctx, &state) | ||
| resp.Diagnostics.Append(diags...) | ||
| if resp.Diagnostics.HasError() { | ||
| return | ||
| } | ||
| } | ||
|
|
||
| func (r *agentResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse) { | ||
| // Retrieve values from plan | ||
| var plan agentResourceModel | ||
| diags := req.Plan.Get(ctx, &plan) | ||
| resp.Diagnostics.Append(diags...) | ||
| if resp.Diagnostics.HasError() { | ||
| return | ||
| } | ||
|
|
||
| // Update existing order | ||
| response := UpdateAgent(AgentUpdateRequestModel{ | ||
| Name: plan.Name.ValueString(), | ||
| Notes: plan.Notes.ValueString(), | ||
| PCapMode: plan.PCapMode.ValueString(), | ||
| }) | ||
|
|
||
| // Update resource state with updated items | ||
| plan.Name = types.StringValue(response.Name) | ||
| plan.Notes = types.StringValue(response.Notes) | ||
| plan.PCapMode = types.StringValue(response.PCapMode) | ||
|
|
||
| // Set state to fully populated data | ||
| diags = resp.State.Set(ctx, plan) | ||
| resp.Diagnostics.Append(diags...) | ||
| if resp.Diagnostics.HasError() { | ||
| return | ||
| } | ||
| } | ||
|
|
||
| func (r *agentResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse) { | ||
| // Retrieve values from state | ||
| var state agentResourceModel | ||
| diags := req.State.Get(ctx, &state) | ||
| resp.Diagnostics.Append(diags...) | ||
| if resp.Diagnostics.HasError() { | ||
| return | ||
| } | ||
|
|
||
| // Delete existing agent using client here | ||
| // err := r.client.DeleteOrder(state.ID.ValueString()) | ||
| } | ||
|
|
||
| func (r *agentResource) ImportState(ctx context.Context, req resource.ImportStateRequest, resp *resource.ImportStateResponse) { | ||
| resource.ImportStatePassthroughID(ctx, path.Root("id"), req, resp) | ||
| } | ||
|
|
||
| // Get the agent using the configuration-api client | ||
| var GetAgent = func() AgentResponseModel { | ||
| // TODO: Query the agent using the client | ||
|
|
||
| return AgentResponseModel{ | ||
| UID: "mock_uid", | ||
| Serial: "mock_serial", | ||
| Name: "mock_name", | ||
| ModelNumber: "mock_model_number", | ||
| WifiMacAddress: "mock_wifi_mac_address", | ||
| EthernetMacAddress: "mock_ethernet_mac_address", | ||
| Notes: "mock_notes", | ||
| PCapMode: "mock_pcap_mode", | ||
| } | ||
| } | ||
|
|
||
| // Update the agent using the configuration-api client | ||
| var UpdateAgent = func(request AgentUpdateRequestModel) AgentResponseModel { | ||
| // TODO: Query the agent using the client | ||
|
|
||
| return AgentResponseModel{ | ||
| UID: "mock_uid", | ||
| Serial: "mock_serial", | ||
| Name: request.Name, | ||
| ModelNumber: "mock_model_number", | ||
| WifiMacAddress: "mock_wifi_mac_address", | ||
| EthernetMacAddress: "mock_ethernet_mac_address", | ||
| Notes: request.Notes, | ||
| PCapMode: request.PCapMode, | ||
| } | ||
| } |
Oops, something went wrong.