stacksync

type Apply func(ctx context.Context, rec store.StackSyncRecord, files []File, commit string) (ApplyOutcome, error)

type ApplyOutcome struct {
	Revision        int
	PendingApproval bool
}

type CodedError struct {
	Code string
	Msg  string
	// Detail is a file:line at most, never a value from the repository.
	Detail string
}

type Emit func(ctx context.Context, typ string, rec store.StackSyncRecord, st store.StackSyncStatus)

type Fetch func(ctx context.Context, rec store.StackSyncRecord) (dir, commit string, cleanup func(), err error)

type File struct {
	Name    string
	Content string
}

type Limits struct {
	Tick         time.Duration
	MinInterval  time.Duration
	FetchTimeout time.Duration
	MaxRepoBytes int64
	MaxFileBytes int64
	MaxFiles     int
	// MinFreeBytes refuses a fetch while the free disk is below it; 0 skips the probe.
	MinFreeBytes int64
}

type Plan func(ctx context.Context, rec store.StackSyncRecord, files []File) (iac.Plan, error)

type Store interface {
	ListEnabledStackSyncs(ctx context.Context) ([]store.StackSyncRecord, error)
	SetStackSyncStatus(ctx context.Context, stackID string, st store.StackSyncStatus) error
}

type Syncer struct {
	Store Store
	Fetch Fetch
	Plan  Plan
	Emit  Emit
	// Apply is nil on a plan only control plane; a stack must also set apply.
	Apply Apply
	// FreeBytes probes the disk a fetch writes to; an error refuses the fetch.
	FreeBytes func(ctx context.Context) (int64, error)
	Limits    func(ctx context.Context) Limits
	Logger    *slog.Logger
	Now       func() time.Time
	// contains filtered or unexported fields
}