Artifact [481a867f57]

Artifact 481a867f57d0b39e8cfe0eaf492f7761bf7ec91ceeb0e686c7e088f97d096c3b:

• File leaf/telemetry/checkout_observer.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: 2437) [annotate] [blame] [check-ins using] [more...]

//go:build !wasip1 && !js

package telemetry

import (
	libfossil "github.com/danmestas/libfossil"
	"go.opentelemetry.io/otel"
	"go.opentelemetry.io/otel/attribute"
	"go.opentelemetry.io/otel/trace"
)

// CheckoutOTelObserver implements libfossil.CheckoutObserver using OpenTelemetry spans.
type CheckoutOTelObserver struct {
	tracer trace.Tracer
	span   trace.Span
}

// NewCheckoutOTelObserver creates a CheckoutOTelObserver. Pass nil for tp
// to use the globally registered TracerProvider.
func NewCheckoutOTelObserver(tp trace.TracerProvider) *CheckoutOTelObserver {
	if tp == nil {
		tp = otel.GetTracerProvider()
	}
	return &CheckoutOTelObserver{
		tracer: tp.Tracer(instrumentationName),
	}
}

func (o *CheckoutOTelObserver) ExtractStarted(e libfossil.ExtractStart) {
	_, o.span = o.tracer.Start(nil, "checkout.extract",
		trace.WithAttributes(
			attribute.Int64("checkout.target_rid", e.RID),
			attribute.String("checkout.dir", e.Dir),
		),
	)
}

func (o *CheckoutOTelObserver) ExtractFileCompleted(name string, change libfossil.UpdateChange) {
	if o.span != nil {
		o.span.AddEvent("checkout.file", trace.WithAttributes(
			attribute.String("checkout.file.name", name),
			attribute.String("checkout.file.change", string(change)),
		))
	}
}

func (o *CheckoutOTelObserver) ExtractCompleted(e libfossil.ExtractEnd) {
	if o.span != nil {
		o.span.SetAttributes(
			attribute.Int("checkout.files_written", e.FilesWritten),
		)
		o.span.End()
		o.span = nil
	}
}

func (o *CheckoutOTelObserver) ScanStarted(dir string) {
	_, o.span = o.tracer.Start(nil, "checkout.scan")
}

func (o *CheckoutOTelObserver) ScanCompleted(e libfossil.ScanEnd) {
	if o.span != nil {
		o.span.SetAttributes(
			attribute.Int("checkout.scan.files_scanned", e.FilesScanned),
		)
		o.span.End()
		o.span = nil
	}
}

func (o *CheckoutOTelObserver) CommitStarted(e libfossil.CommitStart) {
	_, o.span = o.tracer.Start(nil, "checkout.commit",
		trace.WithAttributes(
			attribute.Int("checkout.commit.files", e.Files),
			attribute.String("checkout.commit.user", e.User),
		),
	)
}

func (o *CheckoutOTelObserver) CommitCompleted(e libfossil.CommitEnd) {
	if o.span != nil {
		o.span.SetAttributes(
			attribute.String("checkout.commit.uuid", e.UUID),
			attribute.Int64("checkout.commit.rid", e.RID),
		)
		o.span.End()
		o.span = nil
	}
}

func (o *CheckoutOTelObserver) Error(err error) {
	if err != nil && o.span != nil {
		o.span.RecordError(err)
	}
}