Artifact [e25695e182]

Artifact e25695e1825c13bdefc9b06a64265779bccab1d8faf02dbadd061b76817be465:

• File leaf/telemetry/checkout_observer.go — part of check-in [38efed7a12] at 2026-08-12 20:50:57 on branch main — chore(deps): migrate to go-libfossil v0.9.0 (#195)

  * chore(deps): migrate to go-libfossil v0.9.0 (renamed module path)

  - import path danmestas/libfossil → danmestas/go-libfossil everywhere - CloneOpts.ProjectCode removed upstream; assert via CloneResult instead - Timeline now takes TimelineOpts (cursor pagination, newest-first) - testutil.HasFossil removed; check FossilBinary() != ""

  * ci: retrigger checks

  ---------

  Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> (user: [email protected], size: 2440) [annotate] [blame] [check-ins using]

//go:build !wasip1 && !js

package telemetry

import (
	libfossil "github.com/danmestas/go-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)
	}
}