package resources_gen

import (
	"context"
	"strings"

	"terraform-provider-nubes/internal/core"
	"terraform-provider-nubes/internal/resources_core"

	"github.com/hashicorp/terraform-plugin-framework/resource"
	"github.com/hashicorp/terraform-plugin-framework/resource/schema"
	"github.com/hashicorp/terraform-plugin-framework/resource/schema/booldefault"
	"github.com/hashicorp/terraform-plugin-framework/types"
)

// Code generated by tools/gen_v2. DO NOT EDIT.
// Service: lucee
// Action: restart

var _ resource.Resource = &LuceeRestartResource{}

// LuceeRestartResource triggers a one-time action.
type LuceeRestartResource struct {
	client *core.UniversalClient
}

type LuceeRestartModel struct {
	ID                    types.String `tfsdk:"id"`
	LuceeID               types.String `tfsdk:"lucee_id"`
	RunID                 types.String `tfsdk:"run_id"`
	AdoptExistingOnCreate types.Bool   `tfsdk:"adopt_existing_on_create"`
	OperationTimeout      types.String `tfsdk:"operation_timeout"`
	LogLevel              types.String `tfsdk:"log_level"`
}

func NewLuceeRestartResource() resource.Resource {
	return &LuceeRestartResource{}
}

func (r *LuceeRestartResource) Metadata(ctx context.Context, req resource.MetadataRequest, resp *resource.MetadataResponse) {
	resp.TypeName = req.ProviderTypeName + "_lucee_restart"
}

func (r *LuceeRestartResource) Schema(ctx context.Context, req resource.SchemaRequest, resp *resource.SchemaResponse) {
	attrs := map[string]schema.Attribute{
		"id":                       schema.StringAttribute{Computed: true},
		"lucee_id":                 schema.StringAttribute{Required: true},
		"run_id":                   schema.StringAttribute{Required: true},
		"adopt_existing_on_create": schema.BoolAttribute{Optional: true, Computed: true, Default: booldefault.StaticBool(false)},
		"operation_timeout":        schema.StringAttribute{Optional: true},
		"log_level":                schema.StringAttribute{Optional: true, MarkdownDescription: "Operation stages log level: none (default), info, debug. Overrides provider-level log_level."},
	}
	resp.Schema = schema.Schema{Attributes: attrs}
}

func (r *LuceeRestartResource) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
	var plan LuceeRestartModel
	resp.Diagnostics.Append(req.Plan.Get(ctx, &plan)...)
	if resp.Diagnostics.HasError() {
		return
	}

	instanceUID := strings.TrimSpace(plan.LuceeID.ValueString())
	runID := strings.TrimSpace(plan.RunID.ValueString())
	if instanceUID == "" || runID == "" {
		resp.Diagnostics.AddError("Ошибка клиента", "отсутствует идентификатор экземпляра или run_id")
		return
	}

	params := map[string]string{}

	operationTimeout := ""
	if !plan.OperationTimeout.IsNull() && !plan.OperationTimeout.IsUnknown() {
		operationTimeout = plan.OperationTimeout.ValueString()
	}
	if !plan.LogLevel.IsNull() && !plan.LogLevel.IsUnknown() {
		ctx = core.CtxWithLogLevel(ctx, plan.LogLevel.ValueString())
	}
	if err := resources_core.RunOperationByCodeWithTimeout(ctx, r.client, instanceUID, "restart", params, operationTimeout); err != nil {
		resp.Diagnostics.AddError("Ошибка клиента", err.Error())
		return
	}

	plan.ID = types.StringValue(resources_core.BuildActionID(instanceUID, "restart", runID))
	resp.Diagnostics.Append(resp.State.Set(ctx, &plan)...)
}

func (r *LuceeRestartResource) Read(ctx context.Context, req resource.ReadRequest, resp *resource.ReadResponse) {
	var state LuceeRestartModel
	resp.Diagnostics.Append(req.State.Get(ctx, &state)...)
	if resp.Diagnostics.HasError() {
		return
	}
	resp.Diagnostics.Append(resp.State.Set(ctx, &state)...)
}

func (r *LuceeRestartResource) Update(ctx context.Context, req resource.UpdateRequest, resp *resource.UpdateResponse) {
	var plan LuceeRestartModel
	resp.Diagnostics.Append(req.Plan.Get(ctx, &plan)...)
	if resp.Diagnostics.HasError() {
		return
	}

	instanceUID := strings.TrimSpace(plan.LuceeID.ValueString())
	runID := strings.TrimSpace(plan.RunID.ValueString())
	if instanceUID == "" || runID == "" {
		resp.Diagnostics.AddError("Ошибка клиента", "отсутствует идентификатор экземпляра или run_id")
		return
	}

	params := map[string]string{}

	if err := resources_core.RunOperationByCode(ctx, r.client, instanceUID, "restart", params); err != nil {
		resp.Diagnostics.AddError("Ошибка клиента", err.Error())
		return
	}

	plan.ID = types.StringValue(resources_core.BuildActionID(instanceUID, "restart", runID))
	resp.Diagnostics.Append(resp.State.Set(ctx, &plan)...)
}

func (r *LuceeRestartResource) Delete(ctx context.Context, req resource.DeleteRequest, resp *resource.DeleteResponse) {
	// No-op: removing the resource does not trigger a remote action.
}

func (r *LuceeRestartResource) Configure(_ context.Context, req resource.ConfigureRequest, resp *resource.ConfigureResponse) {
	if req.ProviderData == nil {
		return
	}
	client, ok := req.ProviderData.(*core.UniversalClient)
	if !ok {
		resp.Diagnostics.AddError("Error", "Invalid client type")
		return
	}
	r.client = client
}