state

type ActionHistory struct {
	Intent    models.Intent `yaml:"intent" json:"intent"` // e.g. "weaver block node init"
	Inputs    any           `yaml:"inputs" json:"inputs"` // inputs used for this intent; any marshallable value is accepted (e.g. models.UserInputs[T])
	Timestamp htime.Time    `yaml:"timestamp" json:"timestamp"`
}

type BlockNodeState struct {
	ReleaseInfo HelmReleaseInfo         `yaml:",inline" json:",inline"`
	Storage     models.BlockNodeStorage `yaml:"storage" json:"storage"`
	LastSync    htime.Time              `yaml:"lastSync,omitempty" json:"lastSync,omitempty"` // last time state was reconciled
}

type ClusterNodeState struct {
	Name        string           `yaml:"name" json:"name"`
	Role        string           `yaml:"role" json:"role"` // e.g. "master", "worker"
	Ready       bool             `yaml:"ready" json:"ready"`
	KubeletVer  string           `yaml:"kubeletVersion" json:"kubeletVersion"`
	Labels      models.StringMap `yaml:"labels,omitempty" json:"labels,omitempty"`
	Annotations models.StringMap `yaml:"annotations,omitempty" json:"annotations,omitempty"`
	LastSync    htime.Time       `yaml:"lastSync,omitempty" json:"lastSync,omitempty"` // last time state was reconciled
}

type ClusterState struct {
	models.ClusterInfo
	Created  bool       `yaml:"created" json:"created"`                       // whether the cluster was created by the provisioner
	LastSync htime.Time `yaml:"lastSync,omitempty" json:"lastSync,omitempty"` // last time state was reconciled
}

type HardwareState struct {
	Type     string           `yaml:"type" json:"type"`                       // e.g. "CPU", "RAM", "Disk"
	Info     string           `yaml:"info" json:"info"`                       // e.g. "Intel i7", "16GB", "1TB SSD"
	Count    int              `yaml:"count,omitempty" json:"count,omitempty"` // e.g. number of CPUs
	Size     string           `yaml:"size,omitempty" json:"size,omitempty"`   // e.g. size for RAM or Disk
	Metadata models.StringMap `yaml:"metadata,omitempty" json:"metadata,omitempty"`
	LastSync htime.Time       `yaml:"lastSync,omitempty" json:"lastSync,omitempty"` // last time state was reconciled
}

type HelmReleaseInfo struct {
	Name         string         `yaml:"name"             json:"name"`
	ChartVersion string         `yaml:"version"          json:"version"`    // Helm chart version; yaml key "version" preserved for on-disk compatibility
	AppVersion   string         `yaml:"appVersion"       json:"appVersion"` // version of the application packaged inside the chart (Metadata.AppVersion)
	Namespace    string         `yaml:"namespace"        json:"namespace"`
	ChartRef     string         `yaml:"chartRef"         json:"chartRef"` // e.g. "oci://ghcr.io/hedera/solo-weaver-block-node" needs to match deployed chart
	ChartName    string         `yaml:"chartName"        json:"chartName"`
	Status       release.Status `yaml:"status,omitempty" json:"status,omitempty"` // current state of the release
	// FirstDeployed is when the release was first deployed.
	FirstDeployed htime.Time `yaml:"firstDeployed,omitempty" json:"first_deployed,omitempty"`
	// LastDeployed is when the release was last deployed.
	LastDeployed htime.Time `yaml:"lastDeployed,omitempty" json:"last_deployed,omitempty"`
	// DeletedAt tracks when this release was deleted.
	DeletedAt htime.Time `yaml:"deletedAt,omitempty" json:"deletedAt,omitempty"`
}

type HelmReleaseSchemaV2Migration struct {
	// contains filtered or unexported fields
}

type MachineState struct {
	Software map[string]SoftwareState `yaml:"software" json:"software"`
	Hardware map[string]HardwareState `yaml:"hardware" json:"hardware"`                     // e.g. CPU, RAM, Disk info
	LastSync htime.Time               `yaml:"lastSync,omitempty" json:"lastSync,omitempty"` // last time state was reconciled
}

type Manager interface {
	Reader
	Writer
	Persister
}

type ManagerOption func(*stateManager) error

type Persister interface {
	// Refresh reloads the persisted state from disk, overwriting in-memory state.
	Refresh() error
	// FileManager returns the underlying file-system abstraction.
	FileManager() fsx.Manager
}

type ProvisionerInfo struct {
	Version    string `yaml:"version" json:"version"`
	Commit     string `yaml:"commit" json:"commit"`
	GoVersion  string `yaml:"goversion" json:"goversion"`
	Executable string `yaml:"executable" json:"executable"` // location of the executable
}

type Reader interface {
	// State returns a snapshot of the current in-memory state.
	State() State
	// HasPersistedState reports whether a state file already exists on disk.
	HasPersistedState() (os.FileInfo, bool, error)
}

type SoftwareState struct {
	Name       string           `yaml:"name" json:"name"`
	Version    string           `yaml:"version" json:"version"`
	Installed  bool             `yaml:"installed" json:"installed"`
	Configured bool             `yaml:"configured" json:"configured"`
	Metadata   models.StringMap `yaml:"metadata,omitempty" json:"metadata,omitempty"`
	LastSync   htime.Time       `yaml:"lastSync,omitempty" json:"lastSync,omitempty"` // last time state was reconciled
}

type State struct {
	// Envelope — excluded from hash; never add domain data here
	Hash      string     `yaml:"hash,omitempty"     json:"hash,omitempty"`     // digest of StateRecord
	HashAlgo  string     `yaml:"hashAlgo,omitempty" json:"hashAlgo,omitempty"` // algorithm used for Hash (e.g. "sha256")
	StateFile string     `yaml:"stateFile"          json:"stateFile"`          // path to the state file on disk
	LastSync  htime.Time `yaml:"lastSync,omitempty" json:"lastSync,omitempty"` // last time state was flushed to disk

	// Domain content — serialised as a nested "state" object for readability.
	// The named YAML/JSON tag does not affect Go field promotion: state.Version,
	// state.MachineState, etc. all still resolve directly.
	StateRecord `yaml:"state" json:"state"`
}

type StateRecord struct {
	Version          string          `yaml:"version" json:"version"`
	ProvisionerState ProvisionerInfo `yaml:"provisioner" json:"provisioner"`
	MachineState     MachineState    `yaml:"machineState" json:"machineState"`
	ClusterState     ClusterState    `yaml:"clusterState" json:"clusterState"`
	BlockNodeState   BlockNodeState  `yaml:"blockNodeState" json:"blockNodeState"`
	LastAction       ActionHistory   `yaml:"lastAction,omitempty" json:"lastAction,omitempty"` // last action performed, used for tracking and debugging
}

type UnifiedStateMigration struct {
	// contains filtered or unexported fields
}

type Writer interface {
	// Set replaces the entire in-memory state and returns the Writer for chaining.
	Set(s State) Writer
	// AddActionHistory appends an entry to the pending action log and updates
	// State.LastAction. Entries are flushed to disk on the next Flush() call.
	// Returns the Writer for chaining.
	AddActionHistory(entry ActionHistory) Writer
	// FlushState persists the current state without flushing the action history.
	FlushState() error
	// FlushActionHistory persists only the pending action history to disk without flushing the full state.
	FlushActionHistory() error
	// FlushAll persists both state and action history
	FlushAll() error
}