Artifact [80dd93c305]

Artifact 80dd93c3051307f5cd102fee5827d569c15b52b8fe79451d1bafbd742db17dbe:

• File hub/commit.go — part of check-in [ad1d55f5b9] at 2026-05-04 22:05:56 on branch trunk — feat: close three gaps blocking bones go.mod libfossil drop (#137) (#138)

  * feat(leaf/agent): clone-if-absent via Config.CloneFromHubURL (#137 gap A)

  Adds agent.Config.CloneFromHubURL — when set and Config.RepoPath does not yet exist on disk, agent.New clones the leaf repo from the hub HTTP URL before opening it. Matching project-codes between leaf and hub are required for downstream NATS sync subjects to align, so callers that need to bootstrap a leaf against an existing hub no longer have to import libfossil directly for the pre-agent clone step.

  Also exposes agent.CloneRepo(ctx, repoPath, hubURL) as a standalone helper for callers that need a clone independent of agent construction.

  Existing behavior is preserved: when CloneFromHubURL is empty, agent.New errors on missing RepoPath as before (covered by TestAgentNew_RejectsMissingRepoWithoutCloneURL).

  Closes part of #137 (gap A — bones internal/coord/leaf.go).

  * feat(hub): subscribe to fossil-sync NATS subject in NewHub (#137 gap B)

  NewHub now connects a local NATS client to its embedded server and subscribes to "fossil.<project-code>.sync" so peer leaf agents can push xfer requests to the hub over NATS — alongside the existing HTTP path. Previously, achieving this required running a leaf-agent in serve mode on top of the hub (Pull=false, Push=false, Autosync=AutosyncOff, ServeNATSEnabled=true), which transitively pulled libfossil into the consumer's import graph.

  The subscriber is enabled by default. Read-only HTTP-only mirrors that shouldn't accept NATS pushes can opt out via Config.DisableFossilSyncOverNATS.

  Note on naming: the issue brief proposed Config.ServeFossilSyncOverNATS defaulting to true. Go bool zero-value semantics make default-true awkward without pointers, so the inverted-name shape (DisableX, defaults false = enabled) was used instead.

  Closes part of #137 (gap B — bones internal/coord/hub.go).

  * feat(hub): FileToCommit.Perm + CommitOpts.Time pass-through (#137 gap C)

  Adds two additive fields to the public hub commit surface so consumers no longer need libfossil-direct access to preserve executable bits or seed reproducible commit timestamps:

  - hub.FileToCommit.Perm — "x" marks the file executable on the resulting manifest's F-card. Empty preserves prior behavior. Other libfossil perm markers pass through verbatim. - hub.CommitOpts.Time — explicit commit timestamp; zero defaults to time.Now().UTC() at commit time, matching the prior behavior.

  Tests cover round-tripping the executable bit via libfossil.Repo.ListFiles, honoring an explicit time via Timeline, and falling back to "now" on the zero value.

  Closes part of #137 (gap C — bones internal/hub/hub.go seed path).

  * ci: include #137 sim tests in the serve-tests allowlist

  Adds TestAgentNew_ and TestHubNATSFossilSync_ to the sim serve-tests regex in both Makefile and test.yml so the new clone-if-absent and hub-NATS-subscriber tests actually run in CI alongside TestHubLeafE2E. (user: [email protected], size: 1556) [annotate] [blame] [check-ins using]

package hub

import (
	"context"
	"time"
)

// RevID is an opaque commit handle.
type RevID string

// FileToCommit names a file and its content for inclusion in a commit.
type FileToCommit struct {
	Name    string
	Content []byte

	// Perm is the libfossil-style file permission marker. The empty string
	// means default (regular file); "x" marks the file executable so the
	// resulting manifest's F-card carries the executable bit. Other libfossil
	// perm markers (e.g. "l" for symlinks) are passed through verbatim.
	Perm string
}

// CommitOpts configures Hub.Commit / Repo.Commit.
type CommitOpts struct {
	Files   []FileToCommit
	Message string
	Author  string // fossil user; required

	// Time is the commit timestamp. The zero value defaults to time.Now().UTC()
	// at commit time; callers that need reproducible seeded commits (e.g. a
	// production daemon bootstrapping a hub repo from on-disk content) should
	// pass an explicit value.
	Time time.Time
}

// Commit commits a set of files to the hub repo.
func (h *Hub) Commit(ctx context.Context, opts CommitOpts) (RevID, error) {
	return h.repo.Commit(ctx, opts)
}

// Read returns the contents of path at the current trunk tip.
func (h *Hub) Read(ctx context.Context, path string) ([]byte, error) {
	return h.repo.Read(ctx, path)
}

// ReadAt returns the contents of path at rev. rev may be a branch name
// (e.g. "trunk"), a tag, or a RevID returned from Commit.
func (h *Hub) ReadAt(ctx context.Context, rev RevID, path string) ([]byte, error) {
	return h.repo.ReadAt(ctx, rev, path)
}