store

type FileInfo struct {
	Path    string
	IsDir   bool
	Size    int64
	ModTime time.Time
}

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

type GitHubStoreOption func(*gitHubStoreOptions)

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

type LocalStoreOption func(*LocalStore)

type ReadFSProvider interface {
	FS() fs.FS
}

type RemoteConfig struct {
	Storage      StorageMode   // Storage mode: "local", "remote", or auto-detect (NTN_STORAGE)
	URL          string        // Remote git repository URL (NTN_GIT_URL)
	Password     string        // Password/token for HTTPS auth (NTN_GIT_PASS)
	Branch       string        // Target branch (NTN_GIT_BRANCH)
	QueueBranch  string        // Separate branch for the queue (NTN_QUEUE_BRANCH), empty = disabled
	User         string        // Commit author name (NTN_GIT_USER)
	Email        string        // Commit author email (NTN_GIT_EMAIL)
	Commit       bool          // Enable automatic git commit (NTN_COMMIT)
	CommitPeriod time.Duration // Periodic commit interval during sync (NTN_COMMIT_PERIOD)
	Push         *bool         // Push to remote after commits (NTN_PUSH), nil means auto-detect
	Depth        int           // Shallow clone/fetch depth (NTN_GIT_DEPTH), 0 = full history
}

type RemoteStore interface {
	Store

	// Pull refreshes the local view from the remote. It is a no-op when
	// remote operations are not enabled.
	Pull(ctx context.Context) error

	// IsRemoteEnabled reports whether remote operations are configured.
	IsRemoteEnabled() bool

	// RemoteConfig returns the remote configuration backing this store.
	RemoteConfig() *RemoteConfig
}

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

type StorageMode string

type Store interface {
	// Read operations
	Read(ctx context.Context, path string) ([]byte, error)
	Exists(ctx context.Context, path string) (bool, error)
	List(ctx context.Context, dir string) ([]FileInfo, error)

	// Transaction management - all writes go through transactions
	BeginTx(ctx context.Context) (Transaction, error)

	// Remote operations
	Push(ctx context.Context) error

	// Concurrency control for external coordination (e.g., sync worker)
	Lock()
	Unlock()
}

type Transaction interface {
	// Write operations - applied immediately to filesystem
	Write(ctx context.Context, path string, content []byte) error
	WriteStream(ctx context.Context, path string, reader io.Reader) (int64, error)
	Delete(ctx context.Context, path string) error
	Mkdir(ctx context.Context, path string) error

	// Commit creates a git commit with all changes made in this transaction.
	// After commit, the transaction can continue to be used for more changes.
	Commit(ctx context.Context, message string) error

	// Rollback reverts all uncommitted changes and closes the transaction.
	Rollback(ctx context.Context) error
}

type WholeTreeChecker interface {
	// CheckWholeTreeSupported returns a non-nil error naming the storage mode
	// when the named command needs a whole-tree walk the store cannot provide.
	CheckWholeTreeSupported(command string) error
}