Artifact [33def963ef]

Artifact 33def963efed22e03b5cdc2fd51a2a9cbfcff17e5f5f43d9f1971cf2c2f3957e:

• File leaf/agent/serve_http_test.go — part of check-in [eda7960b81] at 2026-04-23 19:23:42 on branch trunk — rename module to github.com/danmestas/EdgeSync

  Fix the case-sensitive module path to match the actual GitHub repo URL (danmestas/EdgeSync). Remove tracked leaf/leaf binary and ignore .claude/skills/ scratchpad dirs. (user: [email protected], size: 1587) [annotate] [blame] [check-ins using] [more...]

package agent

import (
	"context"
	"io"
	"net"
	"net/http"
	"strings"
	"testing"
	"time"

	libfossil "github.com/danmestas/libfossil"
	_ "github.com/danmestas/libfossil/db/driver/modernc"
	"github.com/danmestas/libfossil/simio"
)

func TestServeHTTPHealthz(t *testing.T) {
	r := newTestRepo(t)
	transport := &mockTransport{}
	addr := freeAddr(t)

	a := NewFromParts(Config{
		RepoPath:      r.Path(),
		ServeHTTPAddr: addr,
		Clock:         simio.RealClock{},
	}, r, transport, "test-project", "test-server")

	if err := a.Start(); err != nil {
		t.Fatal(err)
	}
	defer a.Stop()
	time.Sleep(100 * time.Millisecond)

	resp, err := http.Get("http://" + addr + "/healthz")
	if err != nil {
		t.Fatal(err)
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusOK {
		t.Fatalf("healthz: got status %d, want 200", resp.StatusCode)
	}
	body, err := io.ReadAll(resp.Body)
	if err != nil {
		t.Fatal(err)
	}
	if !strings.Contains(string(body), "ok") {
		t.Fatalf("healthz: body %q does not contain 'ok'", body)
	}
}

func freeAddr(t *testing.T) string {
	t.Helper()
	ln, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		t.Fatal(err)
	}
	addr := ln.Addr().String()
	ln.Close()
	return addr
}

func newTestRepo(t *testing.T) *libfossil.Repo {
	t.Helper()
	path := t.TempDir() + "/test.fossil"
	r, err := libfossil.Create(path, libfossil.CreateOpts{User: "test"})
	if err != nil {
		t.Fatal(err)
	}
	t.Cleanup(func() { r.Close() })
	return r
}

type mockTransport struct{}

func (m *mockTransport) RoundTrip(_ context.Context, _ []byte) ([]byte, error) {
	return []byte{}, nil
}