git

type ClaimOrigin interface {
	ListRefs(ctx context.Context, pattern string) ([]RemoteRef, error)
	FetchCommits(ctx context.Context, shas []string) error
	ReadCommitMessage(ctx context.Context, sha string) ([]byte, error)
}

type ClaimRef struct {
	Ref        string `json:"ref"`
	SHA        string `json:"sha"`
	Cluster    string `json:"cluster"`
	TaskID     string `json:"task_id"`
	LeaseUntil string `json:"lease_until"`
}

type ClaimRefRequest struct {
	ExpectedSHA string `json:"expected_sha"`
	Cluster     string `json:"cluster"`
	TaskID      string `json:"task_id"`
	LeaseUntil  string `json:"lease_until"`
}

type CoalesceConfig struct {
	Enabled  bool
	Delay    time.Duration
	MaxDelay time.Duration
}

type ConflictResolver interface {
	Resolve(ctx context.Context, conflictedPaths []string) error
}

type Git interface {
	WriteFile(ctx context.Context, path string, content []byte) error
	// WriteFileIfAbsent writes content to path only when no file exists there
	// yet. It returns ErrFileExists (via errors.Is) when path is occupied, and
	// performs no repository modification in that case.
	WriteFileIfAbsent(ctx context.Context, path string, content []byte) error
	DeleteFile(ctx context.Context, path string) error
	ReadFile(ctx context.Context, path string) ([]byte, error)
	ListFiles(ctx context.Context, pattern string) ([]string, error)
	Pull(ctx context.Context) error
	Status(ctx context.Context) (Status, error)
	Clone(ctx context.Context, remoteURL RemoteURL) error
	ConfigureUser(ctx context.Context, name string, email string) error
	ConfigurePackMemory(ctx context.Context) error
	// ConfigureClaimMirror configures the clone's origin fetch to carry the claim
	// namespace into refs/claim-mirror/* and enables remote.origin.prune. It is
	// idempotent and must never abort startup on failure.
	ConfigureClaimMirror(ctx context.Context) error
	Init(ctx context.Context) error
	// ListClaimRefs returns the claim refs under refs/<prefix>. A fresh local
	// claim mirror answers without touching the network; a stale, absent,
	// unconfigured or object-missing mirror falls back to the live origin path.
	// The response contract is identical on both paths.
	ListClaimRefs(ctx context.Context, prefix string) ([]ClaimRef, error)
	// PutClaimRef creates or renews refs/<key> with the origin's compare-and-swap.
	// It returns the new commit sha. A lease mismatch returns ErrRefConflict.
	PutClaimRef(ctx context.Context, key string, request ClaimRefRequest) (string, error)
	// DeleteClaimRef deletes refs/<key> with the origin's compare-and-swap.
	// A lease mismatch or an absent ref returns ErrRefConflict.
	DeleteClaimRef(ctx context.Context, key string, expectedSHA string) error
	// FlushPending commits and pushes the pending write set. A no-op when the set is empty.
	FlushPending(ctx context.Context) error
	// FlushPendingIfDue flushes only when the pending set is non-empty and either
	// the trailing delay or the max-delay has elapsed.
	FlushPendingIfDue(ctx context.Context) error
	// RecoverPendingWrites commits and pushes paths left staged in the index by a
	// crash, before the HTTP server starts serving. A no-op when nothing is staged.
	RecoverPendingWrites(ctx context.Context) error
}

type GitOption func(*GitOptions)

type GitOptions struct {
	Coalesce CoalesceConfig
	// ClaimMirrorPullInterval is the configured pull interval. The claim-mirror
	// staleness bound is derived from it (twice the interval, floor 60 s).
	// Zero uses the floor.
	ClaimMirrorPullInterval libtime.Duration
}

type RebaseConflictError struct {
	Path string // conflicted file path, from "CONFLICT (content): Merge conflict in <path>"
}

type RemoteRef struct {
	SHA string
	Ref string
}

type RemoteURL string

type SSHKeyPath string

type Side struct {
	Content       string
	CommitterTime time.Time
}

type Status struct {
	// Clean is true when the working tree has no uncommitted changes.
	Clean bool
	// NoPushPending is true when there are no commits ahead of the remote.
	NoPushPending bool
}

type VaultAPIMergeClient interface {
	Merge(ctx context.Context, path string, base, ours, theirs Side) (VaultAPIMergeResult, error)
}

type VaultAPIMergeResult struct {
	Result string `json:"result"`
	Reason string `json:"reason"`
	// Content carries the merged bytes. The resolver asks vault-api not to apply
	// the merge, because this process is mid-pull holding the repository mutex:
	// a write back through git-rest's own API waits on the lock the pull holds,
	// and the request never returns.
	Content string `json:"content"`
}