Artifact [bbc520fc86]

Artifact bbc520fc862565a54e8e1601c4805a0820ff7f9ecc922149de9dac94ca0f734a:

• File internal/sync/sparse_prepared_cancel_test.go — part of check-in [632e7349e6] at 2026-10-21 01:03:54 on branch feat/submanifest-reader — fix(sync): isolate prepared fallback cache and cancellation

  Never share RID-keyed cache state across prepared service transactions: protocol-fatal responses can roll back after expansion while returning a nil Go error. Reject canceled contexts before acquiring a transaction and propagate observer cancellation instead of serving densely.

  Reproduce rollback, RID reuse and incorrect content under the replacement hash; verify cancellation and deadline responses do no dense work. Exercise newly shunned payload and basis suppression after prepared-proof invalidation. (user: [email protected], size: 1448) [annotate] [blame] [check-ins using] [more...]

package sync

import (
	"context"
	"errors"
	"fmt"
	"testing"
	"time"

	"github.com/danmestas/go-libfossil/internal/xfer"
)

// A canceled caller must not enter a bound transaction or fall back to dense
// inventory work, even when observer validation would also report staleness.
func TestPreparedSparseServiceCancellation(t *testing.T) {
	for _, deadline := range []bool{false, true} {
		t.Run(fmt.Sprint(deadline), func(t *testing.T) {
			r := setupSyncTestRepo(t)
			storeTestBlob(t, r, []byte("must not be served after cancellation"))
			service, err := prepareSparseService(context.Background(), r, HandleOpts{})
			if err != nil {
				t.Fatal(err)
			}
			defer service.Close()
			ctx, cancel := context.WithCancel(context.Background())
			want := context.Canceled
			if deadline {
				cancel()
				ctx, cancel = context.WithDeadline(context.Background(), time.Unix(1, 0))
				want = context.DeadlineExceeded
			}
			cancel()
			resp, applied, err := service.handle(ctx, &xfer.Message{Cards: preparedCloneCards()})
			if !errors.Is(err, want) || resp != nil || applied {
				t.Fatalf("cancellation became dense response: applied=%v resp=%v err=%v want=%v",
					applied, resp, err, want)
			}
			if err := r.Close(); err != nil {
				t.Fatal(err)
			}
			_, _, err = service.handle(ctx, &xfer.Message{Cards: preparedCloneCards()})
			if !errors.Is(err, want) {
				t.Fatalf("canceled call touched closed repository: %v", err)
			}
		})
	}
}