Artifact [00fb6e52dd]

Artifact 00fb6e52dda4f64aa726f997bddee18c3bd0bbef57e79095b96579c60f814d41:

• File leaf/agent/serve_http.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: 1942) [annotate] [blame] [check-ins using] [more...]

package agent

import (
	"context"
	"encoding/json"
	"fmt"
	"net"
	"net/http"

	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
)

// serveHTTP starts an HTTP server with the xfer handler and operational
// endpoints (/healthz). Blocks until ctx is cancelled.
func (a *Agent) serveHTTP(ctx context.Context) error {
	if a.config.ServeHTTPAddr == "" {
		panic("agent.serveHTTP: ServeHTTPAddr must not be empty")
	}

	mux := http.NewServeMux()
	mux.HandleFunc("/healthz", healthzHandler)
	if a.config.IrohEnabled {
		mux.HandleFunc("/iroh/status", a.irohStatusHandler)
	}
	mux.Handle("/", a.repo.XferHandler())

	handler := otelhttp.NewMiddleware("edgesync-leaf-http")(mux)
	srv := &http.Server{Handler: handler}

	ln, err := net.Listen("tcp", a.config.ServeHTTPAddr)
	if err != nil {
		return fmt.Errorf("agent: serve-http: listen: %w", err)
	}

	go func() {
		<-ctx.Done()
		srv.Close()
	}()

	err = srv.Serve(ln)
	if err == http.ErrServerClosed {
		return nil
	}
	return err
}

// healthzHandler returns 200 OK for container health checks.
func healthzHandler(w http.ResponseWriter, _ *http.Request) {
	w.Header().Set("Content-Type", "application/json")
	w.WriteHeader(http.StatusOK)
	fmt.Fprint(w, `{"status":"ok"}`)
}

// irohStatusHandler returns the iroh sidecar status.
func (a *Agent) irohStatusHandler(w http.ResponseWriter, _ *http.Request) {
	alive := a.irohSidecar != nil && !a.irohSidecarExited()

	w.Header().Set("Content-Type", "application/json")
	json.NewEncoder(w).Encode(map[string]any{
		"enabled":     true,
		"endpoint_id": a.irohEndpointID,
		"peers":       a.config.IrohPeers,
		"sidecar":     map[string]any{"alive": alive},
	})
}

// irohSidecarExited returns true if the sidecar process has exited.
func (a *Agent) irohSidecarExited() bool {
	if a.irohSidecar == nil || a.irohSidecar.exited == nil {
		return true
	}
	select {
	case <-a.irohSidecar.exited:
		return true
	default:
		return false
	}
}