drift

type Checker interface {
	// CheckDrift checks the drift of all resources in the blueprint
	// with the given instance ID.
	// This will always check the drift with the upstream provider,
	// the state container can be used to retrieve the last known
	// drift state that was previously checked.
	// In most cases, this method will persist the results of the
	// drift check with the configured state container.
	// This returns a map of resource IDs to their drift state ONLY
	// if the resource has drifted from the last known state.
	CheckDrift(
		ctx context.Context,
		instanceID string,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) (map[string]*state.ResourceDriftState, error)
	// CheckResourceDrift checks the drift of a single resource
	// with the given instance ID and resource ID.
	// This will always check the drift with the upstream provider,
	// the state container can be used to retrieve the last known
	// drift state that was previously checked.
	// In most cases, this method will persist the results of the
	// drift check with the configured state container.
	// This will return nil if the resource has not drifted from
	// the last known state.
	CheckResourceDrift(
		ctx context.Context,
		instanceID string,
		instanceName string,
		resourceID string,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) (*state.ResourceDriftState, error)
	// CheckInterruptedResources detects interrupted resources and determines
	// their actual state from the cloud, but does NOT update persisted state.
	// Returns results for user review before applying reconciliation.
	// This is typically called during change staging to allow users to
	// review and approve state updates for resources that were interrupted
	// during a previous deployment.
	CheckInterruptedResources(
		ctx context.Context,
		instanceID string,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) ([]ReconcileResult, error)
	// ApplyReconciliation updates persisted state based on reconcile results.
	// This should be called after the user approves the reconciliation.
	ApplyReconciliation(
		ctx context.Context,
		results []ReconcileResult,
	) error
	// CheckLinkDrift checks drift for a single link.
	// Uses ResourceDataMappings to compare link.Data against resource external state.
	// Also checks intermediary resources via GetIntermediaryExternalState.
	// This will persist the results of the drift check with the configured state container.
	// Returns nil if the link has not drifted.
	CheckLinkDrift(
		ctx context.Context,
		instanceID string,
		linkID string,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) (*state.LinkDriftState, error)
	// CheckAllLinkDrift checks drift for all links in an instance.
	// Uses ResourceDataMappings to compare link.Data against resource external state.
	// Also checks intermediary resources via GetIntermediaryExternalState.
	// This will persist the results of the drift check with the configured state container.
	// Returns a map of link IDs to their drift state ONLY if the link has drifted.
	CheckAllLinkDrift(
		ctx context.Context,
		instanceID string,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) (map[string]*state.LinkDriftState, error)

	// CheckDriftWithState is like CheckDrift but accepts pre-fetched instance state.
	// Use this to avoid redundant state fetches when the caller already has the state.
	CheckDriftWithState(
		ctx context.Context,
		instanceState *state.InstanceState,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) (map[string]*state.ResourceDriftState, error)
	// CheckInterruptedResourcesWithState is like CheckInterruptedResources but accepts
	// pre-fetched instance state.
	CheckInterruptedResourcesWithState(
		ctx context.Context,
		instanceState *state.InstanceState,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) ([]ReconcileResult, error)
	// CheckAllLinkDriftWithState is like CheckAllLinkDrift but accepts pre-fetched
	// instance state.
	CheckAllLinkDriftWithState(
		ctx context.Context,
		instanceState *state.InstanceState,
		params core.BlueprintParams,
		taggingConfig *provider.TaggingConfig,
	) (map[string]*state.LinkDriftState, error)
}

type ReconcileResult struct {
	// ResourceID is the unique identifier for the resource.
	ResourceID string
	// ResourceName is the logical name of the resource.
	ResourceName string
	// ResourceType is the type of the resource (e.g., "aws/s3Bucket").
	ResourceType string
	// OldStatus is the status the resource had before reconciliation
	// (typically an interrupted status).
	OldStatus core.PreciseResourceStatus
	// NewStatus is the status determined from fetching external state.
	// This will be the actual status of the resource (e.g., created, create_failed).
	NewStatus core.PreciseResourceStatus
	// ExternalState contains the actual cloud state if the resource exists.
	// This will be nil if the resource doesn't exist in the cloud.
	ExternalState *core.MappingNode
	// PersistedState contains what we had in our state before interruption.
	PersistedState *core.MappingNode
	// StateChanges shows the diff between persisted and external state.
	// Generated using the same change detection as drift checking.
	StateChanges *provider.Changes
}