syncdaemon

type Backoff struct {
	Base    time.Duration
	Max     time.Duration
	Attempt int
}

type DaemonState struct {
	SchemaVersion  string `json:"schema_version"`
	Status         string `json:"status"`
	Target         string `json:"target"`
	PID            int    `json:"pid,omitempty"`
	DetectionMode  string `json:"detection_mode"`
	LocalDirty     bool   `json:"local_dirty"`
	LocalHash      string `json:"local_hash,omitempty"`
	RemoteRevision string `json:"remote_revision,omitempty"`
	LastPollAt     string `json:"last_poll_at,omitempty"`
	LastSyncAt     string `json:"last_sync_at,omitempty"`
	LastErrorCode  string `json:"last_error_code,omitempty"`
	NextRetryAt    string `json:"next_retry_at,omitempty"`
	Message        string `json:"message,omitempty"`
	StartedAt      string `json:"started_at,omitempty"`
	UpdatedAt      string `json:"updated_at"`
}

type DetectionMode string

type EventSink func(SyncDaemonEvent)

type Lock struct {
	Path string
	PID  int `json:"pid"`
}

type Loop struct {
	Repo         Repository
	Target       string
	Poller       RemotePoller
	Executor     SyncExecutor
	PollInterval time.Duration
	SyncTimeout  time.Duration
	Backoff      Backoff
	EventSink    EventSink
}

type RemotePoller interface {
	PollHead(ctx context.Context) (string, error)
}

type Repository struct{ Root string }

type RunRequest struct {
	VaultPath    string
	Target       string
	Yes          bool
	Once         bool
	PollInterval time.Duration
	SyncTimeout  time.Duration
	Mode         DetectionMode
}

type SyncDaemonEvent struct {
	SchemaVersion  string         `json:"schema_version"`
	Seq            int            `json:"seq,omitempty"`
	Type           string         `json:"type"`
	Status         string         `json:"status,omitempty"`
	Target         string         `json:"target,omitempty"`
	Path           string         `json:"path,omitempty"`
	ErrorCode      string         `json:"error_code,omitempty"`
	Message        string         `json:"message,omitempty"`
	Facts          map[string]any `json:"facts,omitempty"`
	CycleID        string         `json:"cycle_id,omitempty"`
	Trigger        string         `json:"trigger,omitempty"`
	Direction      string         `json:"direction,omitempty"`
	DurationMS     int64          `json:"duration_ms,omitempty"`
	LocalDirty     bool           `json:"local_dirty,omitempty"`
	RemoteRevision string         `json:"remote_revision,omitempty"`
	RevisionID     string         `json:"revision_id,omitempty"`
	SyncRunID      string         `json:"sync_run_id,omitempty"`
	RemoteWrite    bool           `json:"remote_write,omitempty"`
	LocalWrite     bool           `json:"local_write,omitempty"`
	CreatedAt      string         `json:"created_at"`
}

type SyncExecutor interface {
	Pull(ctx context.Context, remoteRevision string) error
	Push(ctx context.Context) (string, error)
}

type WatchEvent struct{ Path string }

type Watcher interface {
	Events() <-chan WatchEvent
	Errors() <-chan error
	Close() error
}