database

type Approval struct {
	ID         int64
	ManifestID int64
	Decision   string
	Username   string
	Reason     string
	CreatedAt  time.Time
}

type ManifestRecord struct {
	ID            int64
	ServerID      int64
	Hash          string
	CanonicalJSON string
	State         string
	DiffJSON      string // "" if no prior baseline existed
	CreatedAt     time.Time
}

type OutboxRow struct {
	ID            int64
	EventType     string
	ManifestID    int64
	Attempts      int
	NextAttemptAt time.Time
	DeliveredAt   *time.Time // nil until a 2xx has been observed
	LastError     string
	CreatedAt     time.Time
}

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

type Server struct {
	ID        int64
	Name      string
	Endpoint  string
	CreatedAt time.Time
}

type Store interface {
	CreateServer(ctx context.Context, name, endpoint string) (*Server, error)
	GetServerByName(ctx context.Context, name string) (*Server, error)
	GetServerByID(ctx context.Context, id int64) (*Server, error)
	ListServers(ctx context.Context) ([]Server, error)

	InsertManifest(ctx context.Context, m *ManifestRecord) (int64, error)
	GetManifestByHash(ctx context.Context, serverID int64, hash string) (*ManifestRecord, error)
	GetManifestByID(ctx context.Context, id int64) (*ManifestRecord, error)
	GetApprovedManifest(ctx context.Context, serverID int64) (*ManifestRecord, error)
	ListPendingManifests(ctx context.Context) ([]ManifestRecord, error)
	UpdateManifestState(ctx context.Context, id int64, newState string) error

	InsertApproval(ctx context.Context, a *Approval) (int64, error)
	ListApprovalsForManifest(ctx context.Context, manifestID int64) ([]Approval, error)

	// Notification outbox. EnqueueNotification is deliberately a plain
	// INSERT with no network or filesystem work of its own, so it can be
	// called inside the transaction that records a manifest without
	// lengthening it measurably. Nothing else in this interface may be
	// added to that transaction.
	EnqueueNotification(ctx context.Context, eventType string, manifestID int64) (int64, error)
	DueNotifications(ctx context.Context, now time.Time, maxAttempts, limit int) ([]OutboxRow, error)
	MarkNotificationDelivered(ctx context.Context, id int64, now time.Time) error
	MarkNotificationFailed(ctx context.Context, id int64, nextAttempt time.Time, lastError string) error
	ListUndeliveredNotifications(ctx context.Context, minAttempts int) ([]OutboxRow, error)

	WithTx(ctx context.Context, fn func(Store) error) error
}