fixup embeds, add jaeger tracing, some optimizations

backend/backend.go

···
+package backend
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"strings"
+	"sync"
+
+	"github.com/bluesky-social/indigo/atproto/syntax"
+	"github.com/bluesky-social/indigo/util"
+	lru "github.com/hashicorp/golang-lru/v2"
+	"github.com/jackc/pgx/v5"
+	"github.com/jackc/pgx/v5/pgconn"
+	"github.com/jackc/pgx/v5/pgxpool"
+	. "github.com/whyrusleeping/konbini/models"
+	"github.com/whyrusleeping/market/models"
+	"gorm.io/gorm"
+	"gorm.io/gorm/logger"
+)
+
+// PostgresBackend handles database operations
+type PostgresBackend struct {
+	db      *gorm.DB
+	pgx     *pgxpool.Pool
+	tracker RecordTracker
+
+	relevantDids map[string]bool
+	rdLk         sync.Mutex
+
+	revCache *lru.TwoQueueCache[uint, string]
+
+	repoCache *lru.TwoQueueCache[string, *Repo]
+	reposLk   sync.Mutex
+
+	postInfoCache *lru.TwoQueueCache[string, cachedPostInfo]
+}
+
+type cachedPostInfo struct {
+	ID     uint
+	Author uint
+}
+
+// NewPostgresBackend creates a new PostgresBackend
+func NewPostgresBackend(db *gorm.DB, pgx *pgxpool.Pool, tracker RecordTracker) (*PostgresBackend, error) {
+	rc, err := lru.New2Q[string, *Repo](1_000_000)
+	if err != nil {
+		return nil, err
+	}
+	pc, err := lru.New2Q[string, cachedPostInfo](1_000_000)
+	if err != nil {
+		return nil, err
+	}
+	revc, err := lru.New2Q[uint, string](1_000_000)
+	if err != nil {
+		return nil, err
+	}
+
+	return &PostgresBackend{
+		db:            db,
+		pgx:           pgx,
+		tracker:       tracker,
+		relevantDids:  make(map[string]bool),
+		repoCache:     rc,
+		postInfoCache: pc,
+		revCache:      revc,
+	}, nil
+}
+
+// TrackMissingRecord implements the RecordTracker interface
+func (b *PostgresBackend) TrackMissingRecord(identifier string, wait bool) {
+	if b.tracker != nil {
+		b.tracker.TrackMissingRecord(identifier, wait)
+	}
+}
+
+// DidToID converts a DID to a database ID
+func (b *PostgresBackend) DidToID(ctx context.Context, did string) (uint, error) {
+	r, err := b.getOrCreateRepo(ctx, did)
+	if err != nil {
+		return 0, err
+	}
+	return r.ID, nil
+}
+
+func (b *PostgresBackend) getOrCreateRepo(ctx context.Context, did string) (*Repo, error) {
+	r, ok := b.repoCache.Get(did)
+	if !ok {
+		b.reposLk.Lock()
+
+		r, ok = b.repoCache.Get(did)
+		if !ok {
+			r = &Repo{}
+			r.Did = did
+			b.repoCache.Add(did, r)
+		}
+
+		b.reposLk.Unlock()
+	}
+
+	r.Lk.Lock()
+	defer r.Lk.Unlock()
+	if r.Setup {
+		return r, nil
+	}
+
+	row := b.pgx.QueryRow(ctx, "SELECT id, created_at, did FROM repos WHERE did = $1", did)
+
+	err := row.Scan(&r.ID, &r.CreatedAt, &r.Did)
+	if err == nil {
+		// found it!
+		r.Setup = true
+		return r, nil
+	}
+
+	if err != pgx.ErrNoRows {
+		return nil, err
+	}
+
+	r.Did = did
+	if err := b.db.Create(r).Error; err != nil {
+		return nil, err
+	}
+
+	r.Setup = true
+
+	return r, nil
+}
+
+func (b *PostgresBackend) getOrCreateList(ctx context.Context, uri string) (*List, error) {
+	puri, err := util.ParseAtUri(uri)
+	if err != nil {
+		return nil, err
+	}
+
+	r, err := b.getOrCreateRepo(ctx, puri.Did)
+	if err != nil {
+		return nil, err
+	}
+
+	// TODO: needs upsert treatment when we actually find the list
+	var list List
+	if err := b.db.FirstOrCreate(&list, map[string]any{
+		"author": r.ID,
+		"rkey":   puri.Rkey,
+	}).Error; err != nil {
+		return nil, err
+	}
+	return &list, nil
+}
+
+func (b *PostgresBackend) postIDForUri(ctx context.Context, uri string) (uint, error) {
+	// getPostByUri implicitly fills the cache
+	p, err := b.postInfoForUri(ctx, uri)
+	if err != nil {
+		return 0, err
+	}
+
+	return p.ID, nil
+}
+
+func (b *PostgresBackend) postInfoForUri(ctx context.Context, uri string) (cachedPostInfo, error) {
+	v, ok := b.postInfoCache.Get(uri)
+	if ok {
+		return v, nil
+	}
+
+	// getPostByUri implicitly fills the cache
+	p, err := b.getOrCreatePostBare(ctx, uri)
+	if err != nil {
+		return cachedPostInfo{}, err
+	}
+
+	return cachedPostInfo{ID: p.ID, Author: p.Author}, nil
+}
+
+func (b *PostgresBackend) tryLoadPostInfo(ctx context.Context, uid uint, rkey string) (*Post, error) {
+	var p Post
+	q := "SELECT id, author FROM posts WHERE author = $1 AND rkey = $2"
+	if err := b.pgx.QueryRow(ctx, q, uid, rkey).Scan(&p.ID, &p.Author); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return nil, nil
+		}
+		return nil, err
+	}
+
+	return &p, nil
+}
+
+func (b *PostgresBackend) getOrCreatePostBare(ctx context.Context, uri string) (*Post, error) {
+	puri, err := util.ParseAtUri(uri)
+	if err != nil {
+		return nil, err
+	}
+
+	r, err := b.getOrCreateRepo(ctx, puri.Did)
+	if err != nil {
+		return nil, err
+	}
+
+	post, err := b.tryLoadPostInfo(ctx, r.ID, puri.Rkey)
+	if err != nil {
+		return nil, err
+	}
+
+	if post == nil {
+		post = &Post{
+			Rkey:     puri.Rkey,
+			Author:   r.ID,
+			NotFound: true,
+		}
+
+		err := b.pgx.QueryRow(ctx, "INSERT INTO posts (rkey, author, not_found) VALUES ($1, $2, $3) RETURNING id", puri.Rkey, r.ID, true).Scan(&post.ID)
+		if err != nil {
+			pgErr, ok := err.(*pgconn.PgError)
+			if !ok || pgErr.Code != "23505" {
+				return nil, err
+			}
+
+			out, err := b.tryLoadPostInfo(ctx, r.ID, puri.Rkey)
+			if err != nil {
+				return nil, fmt.Errorf("got duplicate post and still couldnt find it: %w", err)
+			}
+			if out == nil {
+				return nil, fmt.Errorf("postgres is lying to us: %d %s", r.ID, puri.Rkey)
+			}
+
+			post = out
+		}
+
+	}
+
+	b.postInfoCache.Add(uri, cachedPostInfo{
+		ID:     post.ID,
+		Author: post.Author,
+	})
+
+	return post, nil
+}
+
+func (b *PostgresBackend) getPostByUri(ctx context.Context, uri string, fields string) (*Post, error) {
+	puri, err := util.ParseAtUri(uri)
+	if err != nil {
+		return nil, err
+	}
+
+	r, err := b.getOrCreateRepo(ctx, puri.Did)
+	if err != nil {
+		return nil, err
+	}
+
+	q := "SELECT " + fields + " FROM posts WHERE author = ? AND rkey = ?"
+
+	var post Post
+	if err := b.db.Raw(q, r.ID, puri.Rkey).Scan(&post).Error; err != nil {
+		return nil, err
+	}
+
+	if post.ID == 0 {
+		post.Rkey = puri.Rkey
+		post.Author = r.ID
+		post.NotFound = true
+
+		if err := b.db.Session(&gorm.Session{
+			Logger: logger.Default.LogMode(logger.Silent),
+		}).Create(&post).Error; err != nil {
+			if !errors.Is(err, gorm.ErrDuplicatedKey) {
+				return nil, err
+			}
+			if err := b.db.Find(&post, "author = ? AND rkey = ?", r.ID, puri.Rkey).Error; err != nil {
+				return nil, fmt.Errorf("got duplicate post and still couldnt find it: %w", err)
+			}
+		}
+
+	}
+
+	b.postInfoCache.Add(uri, cachedPostInfo{
+		ID:     post.ID,
+		Author: post.Author,
+	})
+
+	return &post, nil
+}
+
+func (b *PostgresBackend) revForRepo(rr *Repo) (string, error) {
+	lrev, ok := b.revCache.Get(rr.ID)
+	if ok {
+		return lrev, nil
+	}
+
+	var rev string
+	if err := b.pgx.QueryRow(context.TODO(), "SELECT COALESCE(rev, '') FROM sync_infos WHERE repo = $1", rr.ID).Scan(&rev); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return "", nil
+		}
+		return "", err
+	}
+
+	if rev != "" {
+		b.revCache.Add(rr.ID, rev)
+	}
+	return rev, nil
+}
+
+func (b *PostgresBackend) addRelevantDid(did string) {
+	b.rdLk.Lock()
+	defer b.rdLk.Unlock()
+	b.relevantDids[did] = true
+}
+
+func (b *PostgresBackend) didIsRelevant(did string) bool {
+	b.rdLk.Lock()
+	defer b.rdLk.Unlock()
+	return b.relevantDids[did]
+}
+
+func (b *PostgresBackend) anyRelevantIdents(idents ...string) bool {
+	for _, id := range idents {
+		if strings.HasPrefix(id, "did:") {
+			if b.didIsRelevant(id) {
+				return true
+			}
+		} else if strings.HasPrefix(id, "at://") {
+			puri, err := syntax.ParseATURI(id)
+			if err != nil {
+				continue
+			}
+
+			if b.didIsRelevant(puri.Authority().String()) {
+				return true
+			}
+		}
+	}
+
+	return false
+}
+
+func (b *PostgresBackend) getRepoByID(ctx context.Context, id uint) (*models.Repo, error) {
+	var r models.Repo
+	if err := b.db.Find(&r, "id = ?", id).Error; err != nil {
+		return nil, err
+	}
+
+	return &r, nil
+}
+
+func (b *PostgresBackend) checkPostExists(ctx context.Context, repo *Repo, rkey string) (bool, error) {
+	var id uint
+	var notfound bool
+	if err := b.pgx.QueryRow(ctx, "SELECT id, not_found FROM posts WHERE author = $1 AND rkey = $2", repo.ID, rkey).Scan(&id, &notfound); err != nil {
+		if errors.Is(err, pgx.ErrNoRows) {
+			return false, nil
+		}
+		return false, err
+	}
+
+	if id != 0 && !notfound {
+		return true, nil
+	}
+
+	return false, nil
+}

backend/interface.go

···
+package backend
+
+// RecordTracker is an interface for tracking missing records that need to be fetched
+type RecordTracker interface {
+	// TrackMissingRecord queues a missing record for fetching
+	// identifier can be:
+	//  - A DID (e.g., "did:plc:...") for actors/profiles
+	//  - An AT-URI (e.g., "at://did:plc:.../app.bsky.feed.post/...") for posts
+	//  - An AT-URI (e.g., "at://did:plc:.../app.bsky.feed.generator/...") for feed generators
+	// wait: if true, blocks until the record is fetched
+	TrackMissingRecord(identifier string, wait bool)
+}

go.mod

···
 
 require (
 	github.com/bluesky-social/indigo v0.0.0-20250909204019-c5eaa30f683f
-	github.com/golang-jwt/jwt/v5 v5.2.2
 	github.com/gorilla/websocket v1.5.1
 	github.com/hashicorp/golang-lru/v2 v2.0.7
 	github.com/ipfs/go-cid v0.4.1
 	github.com/jackc/pgx/v5 v5.6.0
 	github.com/labstack/echo/v4 v4.11.3
 	github.com/labstack/gommon v0.4.1
+	github.com/lestrrat-go/jwx/v2 v2.0.12
+	github.com/multiformats/go-multihash v0.2.3
 	github.com/prometheus/client_golang v1.19.1
 	github.com/urfave/cli/v2 v2.27.7
+	github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e
 	github.com/whyrusleeping/market v0.0.0-20250711215409-cc684a207f15
+	go.opentelemetry.io/otel v1.34.0
+	go.opentelemetry.io/otel/exporters/jaeger v1.17.0
+	go.opentelemetry.io/otel/sdk v1.34.0
 	gorm.io/gorm v1.31.0
 )
 
···
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/cpuguy83/go-md2man/v2 v2.0.7 // indirect
 	github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0 // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/felixge/httpsnoop v1.0.4 // indirect
 	github.com/go-logr/logr v1.4.2 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/go-redis/cache/v9 v9.0.0 // indirect
 	github.com/goccy/go-json v0.10.5 // indirect
 	github.com/gogo/protobuf v1.3.2 // indirect
 	github.com/golang-jwt/jwt v3.2.2+incompatible // indirect
···
 	github.com/jbenet/goprocess v0.1.4 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
+	github.com/klauspost/compress v1.17.3 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.7 // indirect
 	github.com/lestrrat-go/blackmagic v1.0.1 // indirect
 	github.com/lestrrat-go/httpcc v1.0.1 // indirect
 	github.com/lestrrat-go/httprc v1.0.4 // indirect
 	github.com/lestrrat-go/iter v1.0.2 // indirect
-	github.com/lestrrat-go/jwx/v2 v2.0.12 // indirect
 	github.com/lestrrat-go/option v1.0.1 // indirect
 	github.com/libp2p/go-libp2p v0.25.1 // indirect
 	github.com/mattn/go-colorable v0.1.13 // indirect
···
 	github.com/multiformats/go-base36 v0.2.0 // indirect
 	github.com/multiformats/go-multiaddr v0.8.0 // indirect
 	github.com/multiformats/go-multibase v0.2.0 // indirect
-	github.com/multiformats/go-multihash v0.2.3 // indirect
 	github.com/multiformats/go-varint v0.0.7 // indirect
 	github.com/opentracing/opentracing-go v1.2.0 // indirect
 	github.com/orandin/slog-gorm v1.3.2 // indirect
···
 	github.com/prometheus/client_model v0.6.1 // indirect
 	github.com/prometheus/common v0.48.0 // indirect
 	github.com/prometheus/procfs v0.12.0 // indirect
+	github.com/redis/go-redis/v9 v9.3.0 // indirect
 	github.com/russross/blackfriday/v2 v2.1.0 // indirect
 	github.com/segmentio/asm v1.2.0 // indirect
 	github.com/spaolacci/murmur3 v1.1.0 // indirect
 	github.com/valyala/bytebufferpool v1.0.0 // indirect
 	github.com/valyala/fasttemplate v1.2.2 // indirect
-	github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e // indirect
+	github.com/vmihailenco/go-tinylfu v0.2.2 // indirect
+	github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
+	github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
 	github.com/whyrusleeping/go-did v0.0.0-20230824162731-404d1707d5d6 // indirect
 	github.com/xrash/smetrics v0.0.0-20240521201337-686a1a2994c1 // indirect
 	gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b // indirect
 	gitlab.com/yawning/tuplehash v0.0.0-20230713102510-df83abbf9a02 // indirect
 	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
 	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.58.0 // indirect
-	go.opentelemetry.io/otel v1.34.0 // indirect
 	go.opentelemetry.io/otel/metric v1.34.0 // indirect
 	go.opentelemetry.io/otel/trace v1.34.0 // indirect
 	go.uber.org/atomic v1.11.0 // indirect

go.sum

···
 github.com/bluesky-social/indigo v0.0.0-20250909204019-c5eaa30f683f/go.mod h1:n6QE1NDPFoi7PRbMUZmc2y7FibCqiVU4ePpsvhHUBR8=
 github.com/bradfitz/gomemcache v0.0.0-20230905024940-24af94b03874 h1:N7oVaKyGp8bttX0bfZGmcGkjz7DLQXhAn3DNd3T0ous=
 github.com/bradfitz/gomemcache v0.0.0-20230905024940-24af94b03874/go.mod h1:r5xuitiExdLAJ09PR7vBVENGvp4ZuTBeWTGtxuX3K+c=
+github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
+github.com/bsm/ginkgo/v2 v2.12.0/go.mod h1:SwYbGRRDovPVboqFv0tPTcG1sN61LM1Z4ARdbAV9g4c=
+github.com/bsm/gomega v1.27.10 h1:yeMWxP2pV2fG3FgAODIY8EiRE3dy0aeFYt4l7wh6yKA=
+github.com/bsm/gomega v1.27.10/go.mod h1:JyEr/xRbxbtgWNi8tIEVPUYZ5Dzef52k01W3YH0H+O0=
 github.com/carlmjohnson/versioninfo v0.22.5 h1:O00sjOLUAFxYQjlN/bzYTuZiS0y6fWDQjMRvwtKgwwc=
 github.com/carlmjohnson/versioninfo v0.22.5/go.mod h1:QT9mph3wcVfISUKd0i9sZfVrPviHuSF+cUtLjm2WSf8=
+github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
 github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
+github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
+github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
 github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=
 github.com/cpuguy83/go-md2man/v2 v2.0.7 h1:zbFlGlXEAKlwXpmvle3d8Oe3YnkKIK4xSRTd3sHPnBo=
 github.com/cpuguy83/go-md2man/v2 v2.0.7/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g=
+github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/cskr/pubsub v1.0.2 h1:vlOzMhl6PFn60gRlTQQsIfVwaPB/B/8MziK8FhEPt/0=
 github.com/cskr/pubsub v1.0.2/go.mod h1:/8MzYXk/NJAz782G8RPkFzXTZVu63VotefPnR9TIRis=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
···
 github.com/decred/dcrd/crypto/blake256 v1.0.1/go.mod h1:2OfgNZ5wDpcsFmHmCK5gZTPcCXqlm2ArzUIkw9czNJo=
 github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0 h1:8UrgZ3GkP4i/CLijOJx79Yu+etlyjdBU4sfcs2WYQMs=
 github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0/go.mod h1:v57UDF4pDQJcEfFUCRop3lJL149eHGSe9Jvczhzjo/0=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
 github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
 github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
 github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
 github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=
+github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
+github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
+github.com/fsnotify/fsnotify v1.5.4 h1:jRbGcIw6P2Meqdwuo0H1p6JVLbL5DHKAKlYndzMwVZI=
+github.com/fsnotify/fsnotify v1.5.4/go.mod h1:OVB6XrOHzAwXMpEM7uPOzcehqUV2UqJxmVXmkdnm1bU=
 github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
+github.com/go-logr/logr v1.2.3/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
 github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
 github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
 github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
 github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
+github.com/go-redis/cache/v9 v9.0.0 h1:0thdtFo0xJi0/WXbRVu8B066z8OvVymXTJGaXrVWnN0=
+github.com/go-redis/cache/v9 v9.0.0/go.mod h1:cMwi1N8ASBOufbIvk7cdXe2PbPjK/WMRL95FFHWsSgI=
 github.com/go-redis/redis v6.15.9+incompatible h1:K0pv1D7EQUjfyoMql+r/jZqCLizCGKFlFgcHWWmHQjg=
 github.com/go-redis/redis v6.15.9+incompatible/go.mod h1:NAIEuMOZ/fxfXJIrKDQDz8wamY7mA7PouImQ2Jvg6kA=
+github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg7847qk6SyHyPtNmDHnmrv/HOrqktSC+C9fM+CJOE=
 github.com/go-yaml/yaml v2.1.0+incompatible/go.mod h1:w2MrLa16VYP0jy6N7M5kHaCkaLENm+P+Tv+MfurjSw0=
 github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
 github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4=
···
 github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
 github.com/golang-jwt/jwt v3.2.2+incompatible h1:IfV12K8xAKAnZqdXVzCZ+TOjboZ2keLg81eXfW3O+oY=
 github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
-github.com/golang-jwt/jwt/v5 v5.2.2 h1:Rl4B7itRWVtYIHFrSNd7vhTiz9UpLdi6gZhZ3wEeDy8=
-github.com/golang-jwt/jwt/v5 v5.2.2/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
+github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
+github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
+github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
+github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=
+github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w=
+github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0=
+github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI=
+github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
+github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
+github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
+github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
+github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
 github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/gopacket v1.1.19 h1:ves8RnFZPGiFnTS0uPQStjwru6uO6h+nlr9j6fL7kF8=
 github.com/google/gopacket v1.1.19/go.mod h1:iJ8V8n6KS+z2U1A8pUwu8bW5SyEMkXJB8Yo/Vo+TKTo=
+github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
 github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
···
 github.com/hashicorp/golang-lru/arc/v2 v2.0.6/go.mod h1:cfdDIX05DWvYV6/shsxDfa/OVcRieOt+q4FnM8x+Xno=
 github.com/hashicorp/golang-lru/v2 v2.0.7 h1:a+bsQ5rvGLjzHuww6tVxozPZFVghXaHOwFs4luLUK2k=
 github.com/hashicorp/golang-lru/v2 v2.0.7/go.mod h1:QeFd9opnmA6QUJc5vARoKUSoFhyfM2/ZepoAG6RGpeM=
+github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
 github.com/huin/goupnp v1.0.3 h1:N8No57ls+MnjlB+JPiCVSOyy/ot7MJTqlo7rn+NYSqQ=
 github.com/huin/goupnp v1.0.3/go.mod h1:ZxNlw5WqJj6wSsRK5+YfflQGXYfccj5VgQsMNixHM7Y=
+github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
 github.com/ipfs/bbloom v0.0.4 h1:Gi+8EGJ2y5qiD5FbsbpX/TMNcJw8gSqr7eyjHa4Fhvs=
 github.com/ipfs/bbloom v0.0.4/go.mod h1:cS9YprKXpoZ9lT0n/Mw/a6/aFV6DTjTLYHeA+gyqMG0=
 github.com/ipfs/go-bitswap v0.11.0 h1:j1WVvhDX1yhG32NTC9xfxnqycqYIlhzEzLXG/cU1HyQ=
···
 github.com/jtolds/gls v4.20.0+incompatible/go.mod h1:QJZ7F/aHp+rZTRtaJ1ow/lLfFfVYBRgL+9YlvaHOwJU=
 github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
+github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk=
+github.com/klauspost/compress v1.17.3 h1:qkRjuerhUU1EmXLYGkSH6EZL+vPSxIrYjLNAK4slzwA=
+github.com/klauspost/compress v1.17.3/go.mod h1:/dCuZOvVtNoHsyb+cuJD3itjs3NbnF6KH9zAO4BDxPM=
 github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM=
 github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws=
 github.com/koron/go-ssdp v0.0.3 h1:JivLMY45N76b4p/vsWGOKewBQu6uf39y8l+AQ7sDKx8=
 github.com/koron/go-ssdp v0.0.3/go.mod h1:b2MxI6yh02pKrsyNoQUsk4+YNikaGhe4894J+Q5lDvA=
 github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
+github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
···
 github.com/multiformats/go-multistream v0.4.1/go.mod h1:Mz5eykRVAjJWckE2U78c6xqdtyNUEhKSM0Lwar2p77Q=
 github.com/multiformats/go-varint v0.0.7 h1:sWSGR+f/eu5ABZA2ZpYKBILXTTs9JWpdEM/nEGOHFS8=
 github.com/multiformats/go-varint v0.0.7/go.mod h1:r8PUYw/fD/SjBCiKOoDlGF6QawOELpZAu9eioSos/OU=
+github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
+github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE=
+github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=
+github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
+github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk=
+github.com/onsi/ginkgo v1.16.4/go.mod h1:dX+/inL/fNMqNlz0e9LfyB9TswhZpCVdJM/Z6Vvnwo0=
+github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE=
+github.com/onsi/ginkgo v1.16.5/go.mod h1:+E8gABHa3K6zRBolWtd+ROzc/U5bkGt0FwiG042wbpU=
+github.com/onsi/ginkgo/v2 v2.1.3/go.mod h1:vw5CSIxN1JObi/U8gcbwft7ZxR2dgaR70JSE3/PpL4c=
+github.com/onsi/ginkgo/v2 v2.1.4/go.mod h1:um6tUpWM/cxCK3/FK8BXqEiUMUwRgSM4JXG47RKZmLU=
+github.com/onsi/ginkgo/v2 v2.1.6/go.mod h1:MEH45j8TBi6u9BMogfbp0stKC5cdGjumZj5Y7AG4VIk=
+github.com/onsi/ginkgo/v2 v2.3.0/go.mod h1:Eew0uilEqZmIEZr8JrvYlvOM7Rr6xzTmMV8AyFNU9d0=
+github.com/onsi/ginkgo/v2 v2.4.0/go.mod h1:iHkDK1fKGcBoEHT5W7YBq4RFWaQulw+caOMkAt4OrFo=
+github.com/onsi/ginkgo/v2 v2.5.0/go.mod h1:Luc4sArBICYCS8THh8v3i3i5CuSZO+RaQRaJoeNwomw=
+github.com/onsi/ginkgo/v2 v2.7.0/go.mod h1:yjiuMwPokqY1XauOgju45q3sJt6VzQ/Fict1LFVcsAo=
+github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY=
+github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo=
+github.com/onsi/gomega v1.17.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
+github.com/onsi/gomega v1.19.0/go.mod h1:LY+I3pBVzYsTBU1AnDwOSxaYi9WoWiqgwooUqq9yPro=
+github.com/onsi/gomega v1.20.1/go.mod h1:DtrZpjmvpn2mPm4YWQa0/ALMDj9v4YxLgojwPeREyVo=
+github.com/onsi/gomega v1.21.1/go.mod h1:iYAIXgPSaDHak0LCMA+AWBpIKBr8WZicMxnE8luStNc=
+github.com/onsi/gomega v1.22.1/go.mod h1:x6n7VNe4hw0vkyYUM4mjIXx3JbLiPaBPNgB7PRQ1tuM=
+github.com/onsi/gomega v1.24.0/go.mod h1:Z/NWtiqwBrwUt4/2loMmHL63EDLnYHmVbuBpDr2vQAg=
+github.com/onsi/gomega v1.24.1/go.mod h1:3AOiACssS3/MajrniINInwbfOOtfZvplPzuRSmvt1jM=
+github.com/onsi/gomega v1.25.0 h1:Vw7br2PCDYijJHSfBOWhov+8cAnUf8MfMaIOV323l6Y=
+github.com/onsi/gomega v1.25.0/go.mod h1:r+zV744Re+DiYCIPRlYOTxn0YkOLcAnW8k1xXdMPGhM=
 github.com/opentracing/opentracing-go v1.2.0 h1:uEJPy/1a5RIPAJ0Ov+OIO8OxWu77jEv+1B0VhjKrZUs=
 github.com/opentracing/opentracing-go v1.2.0/go.mod h1:GxEUsuufX4nBwe+T+Wl9TAgYrxe9dPLANfrWvHYVTgc=
 github.com/orandin/slog-gorm v1.3.2 h1:C0lKDQPAx/pF+8K2HL7bdShPwOEJpPM0Bn80zTzxU1g=
···
 github.com/prometheus/common v0.48.0/go.mod h1:0/KsvlIEfPQCQ5I2iNSAWKPZziNCvRs5EC6ILDTlAPc=
 github.com/prometheus/procfs v0.12.0 h1:jluTpSng7V9hY0O2R9DzzJHYb2xULk9VTR1V1R/k6Bo=
 github.com/prometheus/procfs v0.12.0/go.mod h1:pcuDEFsWDnvcgNzo4EEweacyhjeA9Zk3cnaOZAZEfOo=
+github.com/redis/go-redis/v9 v9.0.0-rc.4/go.mod h1:Vo3EsyWnicKnSKCA7HhgnvnyA74wOA69Cd2Meli5mmA=
+github.com/redis/go-redis/v9 v9.3.0 h1:RiVDjmig62jIWp7Kk4XVLs0hzV6pI3PyTnnL0cnn0u0=
+github.com/redis/go-redis/v9 v9.3.0/go.mod h1:hdY0cQFCN4fnSYT6TkisLufl/4W5UIXyv0b/CLO2V2M=
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
+github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc=
 github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
 github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
 github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
···
 github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0 h1:1zr/of2m5FGMsad5YfcqgdqdWrIhu+EBEJRhR1U7z/c=
 github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
 github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
···
 github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc=
 github.com/valyala/fasttemplate v1.2.2 h1:lxLXG0uE3Qnshl9QyaK6XJxMXlQZELvChBOCmQD0Loo=
 github.com/valyala/fasttemplate v1.2.2/go.mod h1:KHLXt3tVN2HBp8eijSv/kGJopbvo7S+qRAEEKiv+SiQ=
+github.com/vmihailenco/go-tinylfu v0.2.2 h1:H1eiG6HM36iniK6+21n9LLpzx1G9R3DJa2UjUjbynsI=
+github.com/vmihailenco/go-tinylfu v0.2.2/go.mod h1:CutYi2Q9puTxfcolkliPq4npPuofg9N9t8JVrjzwa3Q=
+github.com/vmihailenco/msgpack/v5 v5.3.4/go.mod h1:7xyJ9e+0+9SaZT0Wt1RGleJXzli6Q/V5KbhBonMG9jc=
+github.com/vmihailenco/msgpack/v5 v5.4.1 h1:cQriyiUvjTwOHg8QZaPihLWeRAAVoCpE00IUPn0Bjt8=
+github.com/vmihailenco/msgpack/v5 v5.4.1/go.mod h1:GaZTsDaehaPpQVyxrf5mtQlH+pc21PIudVV/E3rRQok=
+github.com/vmihailenco/tagparser/v2 v2.0.0 h1:y09buUbR+b5aycVFQs/g70pqKVZNBmxwAhO7/IwNM9g=
+github.com/vmihailenco/tagparser/v2 v2.0.0/go.mod h1:Wri+At7QHww0WTrCBeu4J6bNtoV6mEfg5OIWRZA9qds=
 github.com/warpfork/go-testmark v0.12.1 h1:rMgCpJfwy1sJ50x0M0NgyphxYYPMOODIJHhsXyEHU0s=
 github.com/warpfork/go-testmark v0.12.1/go.mod h1:kHwy7wfvGSPh1rQJYKayD4AbtNaeyZdcGi9tNJTaa5Y=
 github.com/warpfork/go-wish v0.0.0-20220906213052-39a1cc7a02d0 h1:GDDkbFiaK8jsSDJfjId/PEGEShv6ugrt4kYsC5UIDaQ=
···
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
+github.com/yuin/goldmark v1.4.1/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
 github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
 gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b h1:CzigHMRySiX3drau9C6Q5CAbNIApmLdat5jPMqChvDA=
 gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b/go.mod h1:/y/V339mxv2sZmYYR64O07VuCpdNZqCTwO8ZcouTMI8=
···
 go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.58.0/go.mod h1:umTcuxiv1n/s/S6/c2AT/g2CQ7u5C59sHDNmfSwgz7Q=
 go.opentelemetry.io/otel v1.34.0 h1:zRLXxLCgL1WyKsPVrgbSdMN4c0FMkDAskSTQP+0hdUY=
 go.opentelemetry.io/otel v1.34.0/go.mod h1:OWFPOQ+h4G8xpyjgqo4SxJYdDQ/qmRH+wivy7zzx9oI=
+go.opentelemetry.io/otel/exporters/jaeger v1.17.0 h1:D7UpUy2Xc2wsi1Ras6V40q806WM07rqoCWzXu7Sqy+4=
+go.opentelemetry.io/otel/exporters/jaeger v1.17.0/go.mod h1:nPCqOnEH9rNLKqH/+rrUjiMzHJdV1BlpKcTwRTyKkKI=
 go.opentelemetry.io/otel/metric v1.34.0 h1:+eTR3U0MyfWjRDhmFMxe2SsW64QrZ84AOhvqS7Y+PoQ=
 go.opentelemetry.io/otel/metric v1.34.0/go.mod h1:CEDrp0fy2D0MvkXE+dPV7cMi8tWZwX3dmaIhwPOaqHE=
+go.opentelemetry.io/otel/sdk v1.34.0 h1:95zS4k/2GOy069d321O8jWgYsW3MzVV+KuSPKp7Wr1A=
+go.opentelemetry.io/otel/sdk v1.34.0/go.mod h1:0e/pNiaMAqaykJGKbi+tSjWfNNHMTxoC9qANsCzbyxU=
 go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC8mh/k=
 go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE=
 go.uber.org/atomic v1.6.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
···
 golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
 golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
 golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
+golang.org/x/crypto v0.1.0/go.mod h1:RecgLatLF4+eUMCP1PoPZQb+cVrJcOPbHkTkbkB9sbw=
 golang.org/x/crypto v0.12.0/go.mod h1:NF0Gs7EO5K4qLn+Ylc+fih8BSTeIjAP05siRnAh98yw=
 golang.org/x/crypto v0.32.0 h1:euUpcYgM8WcP71gNpTqQCn6rC2t6ULUPiOzfWaXVVfc=
 golang.org/x/crypto v0.32.0/go.mod h1:ZnnJkOaASj8g0AjIduWNlq2NRxL0PlBrbKVyZ6V/Ugc=
···
 golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
 golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
 golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
+golang.org/x/mod v0.6.0-dev.0.20220106191415-9b9b3d81d5e3/go.mod h1:3p9vT2HGsQu2K1YbXdKPJLVgG5VJdoTa1poYQBtP1AY=
 golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
+golang.org/x/mod v0.6.0/go.mod h1:4mET923SAdbXp2ki8ey+zGs1SLqsuM2Y0uvdZR/fUNI=
+golang.org/x/mod v0.7.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
 golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
 golang.org/x/mod v0.22.0 h1:D4nJWe9zXqHOmWqj4VMOJhvzj7bEZg4wEYa759z1pH4=
 golang.org/x/mod v0.22.0/go.mod h1:6SkKJ3Xj0I0BrPOZoBy3bdMptDDU9oJrpohJ3eWZ1fY=
+golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
 golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200520004742-59133d7f0dd7/go.mod h1:qpuaurCH72eLCgpAm/N6yyVIVM9cpaDIP3A8BGJEC5A=
 golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
 golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
 golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM=
+golang.org/x/net v0.0.0-20210428140749-89ef3d95e781/go.mod h1:OJAsFXCWl8Ukc7SiCT/9KSuxbyM7479/AVlXFRxuMCk=
+golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
+golang.org/x/net v0.0.0-20220225172249-27dd8689420f/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
+golang.org/x/net v0.0.0-20220425223048-2871e0cb64e4/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
 golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
+golang.org/x/net v0.1.0/go.mod h1:Cx3nUiGt4eDBEyega/BKRp+/AlGL8hYe7U9odMt2Cco=
+golang.org/x/net v0.2.0/go.mod h1:KqCZLdyyvdV855qA2rE3GC2aiw5xGR5TEjj8smXukLY=
+golang.org/x/net v0.3.0/go.mod h1:MBQ8lrhLObU/6UmLb4fmbmk5OcyYmqtbGd/9yIeKjEE=
+golang.org/x/net v0.5.0/go.mod h1:DivGGAXEgPSlEBzxGzZI+ZLohi+xUj054jfeKui00ws=
 golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
 golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg=
 golang.org/x/net v0.34.0 h1:Mb7Mrk043xzHgnRM88suvJFwzVrRfHEHJEl5/71CKw0=
 golang.org/x/net v0.34.0/go.mod h1:di0qlW3YNM5oh6GqDGQr92MyTozJPmybPK4Ev/Gm31k=
+golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
···
 golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.10.0 h1:3NQrjDixjgGwUOCaF8w2+VYHv0Ve/vGYSbdkTa98gmQ=
 golang.org/x/sync v0.10.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191204072324-ce4227a45e2e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210112080510-489259a85091/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20211019181941-9d821ace8654/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220319134239-a9b59b0215f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220412211240-33da011f77ad/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220422013727-9388b58f7150/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.2.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.3.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.4.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
···
 golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
+golang.org/x/term v0.1.0/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
+golang.org/x/term v0.2.0/go.mod h1:TVmDHMZPmdnySmBfhjOoOdhjzdE1h4u1VwSiw2l1Nuc=
+golang.org/x/term v0.3.0/go.mod h1:q750SLmJuPmVoN1blW3UFBPREJfb1KmY3vwxfr+nFDA=
+golang.org/x/term v0.4.0/go.mod h1:9P2UbLfCdcvo3p/nzKvsmas4TnlujnuoV9hGgYzW1lQ=
 golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
 golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo=
 golang.org/x/term v0.11.0/go.mod h1:zC9APTIj3jG3FdV/Ons+XE1riIZXG4aZ4GTHiPZJPIU=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/text v0.4.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
+golang.org/x/text v0.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
+golang.org/x/text v0.6.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
 golang.org/x/text v0.12.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
···
 golang.org/x/tools v0.0.0-20191029190741-b9c20aec41a5/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.0.0-20200619180055-7c47624df98f/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20201224043029-2b0845dc783e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
 golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
 golang.org/x/tools v0.1.5/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=
+golang.org/x/tools v0.1.10/go.mod h1:Uh6Zz+xoGYZom868N8YTex3t7RhtHDBrE8Gzo9bV56E=
 golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
+golang.org/x/tools v0.2.0/go.mod h1:y4OqIKeOV/fWJetJ8bXPU1sEVniLMIyDAZWeHdV+NTA=
+golang.org/x/tools v0.4.0/go.mod h1:UE5sM2OK9E/d67R0ANs2xJizIymRP5gJU295PvKXxjQ=
 golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
 golang.org/x/tools v0.29.0 h1:Xx0h3TtM9rzQpQuR4dKLrdglAmCEN5Oi+P74JdhdzXE=
 golang.org/x/tools v0.29.0/go.mod h1:KMQVMRsVxU6nHCFXrBPhDB8XncLNLM0lIy/F14RP588=
···
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da h1:noIWHXmPHxILtqtCOPIhSt0ABwskkZKjD3bXGnZGpNY=
 golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da/go.mod h1:NDW/Ps6MPRej6fsCIbMTohpP40sJ/P/vI1MoTEGwX90=
+google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
+google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
+google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
+google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE=
+google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo=
+google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
+google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
+google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
+google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
 google.golang.org/protobuf v1.36.4 h1:6A3ZDJHn/eNqc1i+IdefRzy/9PokBTPvcqMySR7NNIM=
 google.golang.org/protobuf v1.36.4/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
 gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
+gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
+gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7/go.mod h1:dt/ZhP58zS4L8KSrWDmTeBkI65Dw0HsyUHuEVlX15mw=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
 gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

hydration/actor.go

···
 
 // HydrateActor hydrates full actor information
 func (h *Hydrator) HydrateActor(ctx context.Context, did string) (*ActorInfo, error) {
+	ctx, span := tracer.Start(ctx, "hydrateActor")
+	defer span.End()
+
 	// Look up handle
 	resp, err := h.dir.LookupDID(ctx, syntax.DID(did))
 	if err != nil {

hydration/hydrator.go

···
 
 import (
 	"github.com/bluesky-social/indigo/atproto/identity"
+	"github.com/whyrusleeping/konbini/backend"
 	"gorm.io/gorm"
 )
 
 // Hydrator handles data hydration from the database
 type Hydrator struct {
-	db  *gorm.DB
-	dir identity.Directory
-
-	missingRecordCallback func(string, bool)
+	db      *gorm.DB
+	dir     identity.Directory
+	backend backend.RecordTracker
 }
 
 // NewHydrator creates a new Hydrator
-func NewHydrator(db *gorm.DB, dir identity.Directory) *Hydrator {
+func NewHydrator(db *gorm.DB, dir identity.Directory, backend backend.RecordTracker) *Hydrator {
 	return &Hydrator{
-		db:  db,
-		dir: dir,
+		db:      db,
+		dir:     dir,
+		backend: backend,
 	}
 }
 
-// SetMissingRecordCallback sets the callback for when a record is missing
-// The callback receives an identifier which can be:
-// - A DID (e.g., "did:plc:...") for actors/profiles
-// - An AT-URI (e.g., "at://did:plc:.../app.bsky.feed.post/...") for posts
-// - An AT-URI (e.g., "at://did:plc:.../app.bsky.feed.generator/...") for feed generators
-func (h *Hydrator) SetMissingRecordCallback(fn func(string, bool)) {
-	h.missingRecordCallback = fn
-}
-
 // AddMissingRecord reports a missing record that needs to be fetched
 func (h *Hydrator) AddMissingRecord(identifier string, wait bool) {
-	if h.missingRecordCallback != nil {
-		h.missingRecordCallback(identifier, wait)
+	if h.backend != nil {
+		h.backend.TrackMissingRecord(identifier, wait)
 	}
 }
 

hydration/post.go

···
 	"context"
 	"fmt"
 	"log/slog"
+	"sync"
 
 	"github.com/bluesky-social/indigo/api/bsky"
+	"github.com/bluesky-social/indigo/lex/util"
+	"go.opentelemetry.io/otel"
 )
+
+var tracer = otel.Tracer("hydrator")
 
 // PostInfo contains hydrated post information
 type PostInfo struct {
···
 	RepostCount int
 	ReplyCount  int
 	ViewerLike  string // URI of viewer's like, if any
+
+	EmbedInfo *bsky.FeedDefs_PostView_Embed
 }
 
 const fakeCid = "bafyreiapw4hagb5ehqgoeho4v23vf7fhlqey4b7xvjpy76krgkqx7xlolu"
 
 // HydratePost hydrates a single post by URI
 func (h *Hydrator) HydratePost(ctx context.Context, uri string, viewerDID string) (*PostInfo, error) {
+	ctx, span := tracer.Start(ctx, "hydratePost")
+	defer span.End()
+
 	// Query post from database
 	var dbPost struct {
 		ID         uint
···
 		return nil, fmt.Errorf("failed to unmarshal post: %w", err)
 	}
 
+	var wg sync.WaitGroup
+
 	// Get author DID
 	var authorDID string
-	h.db.Raw("SELECT did FROM repos WHERE id = ?", dbPost.AuthorID).Scan(&authorDID)
+	var likes, reposts, replies int
+
+	wg.Go(func() {
+		h.db.Raw("SELECT did FROM repos WHERE id = ?", dbPost.AuthorID).Scan(&authorDID)
+	})
 
 	// Get engagement counts
-	var likes, reposts, replies int
-	h.db.Raw("SELECT COUNT(*) FROM likes WHERE subject = ?", dbPost.ID).Scan(&likes)
-	h.db.Raw("SELECT COUNT(*) FROM reposts WHERE subject = ?", dbPost.ID).Scan(&reposts)
-	h.db.Raw("SELECT COUNT(*) FROM posts WHERE reply_to = ?", dbPost.ID).Scan(&replies)
+	wg.Go(func() {
+		h.db.Raw("SELECT COUNT(*) FROM likes WHERE subject = ?", dbPost.ID).Scan(&likes)
+	})
+	wg.Go(func() {
+		h.db.Raw("SELECT COUNT(*) FROM reposts WHERE subject = ?", dbPost.ID).Scan(&reposts)
+	})
+	wg.Go(func() {
+		h.db.Raw("SELECT COUNT(*) FROM posts WHERE reply_to = ?", dbPost.ID).Scan(&replies)
+	})
+
+	wg.Wait()
 
 	info := &PostInfo{
 		URI:         uri,
···
 		}
 	}
 
+	// Hydrate embed
+	if feedPost.Embed != nil {
+		info.EmbedInfo = h.formatEmbed(ctx, feedPost.Embed, authorDID, viewerDID)
+	}
+
 	return info, nil
 }
 
···
 	}
 	return ""
 }
+
+func (h *Hydrator) formatEmbed(ctx context.Context, embed *bsky.FeedPost_Embed, authorDID string, viewerDID string) *bsky.FeedDefs_PostView_Embed {
+	if embed == nil {
+		return nil
+	}
+
+	result := &bsky.FeedDefs_PostView_Embed{}
+
+	// Handle images
+	if embed.EmbedImages != nil {
+		viewImages := make([]*bsky.EmbedImages_ViewImage, len(embed.EmbedImages.Images))
+		for i, img := range embed.EmbedImages.Images {
+			// Convert blob to CDN URLs
+			fullsize := ""
+			thumb := ""
+			if img.Image != nil {
+				// CDN URL format for feed images
+				cid := img.Image.Ref.String()
+				fullsize = fmt.Sprintf("https://cdn.bsky.app/img/feed_fullsize/plain/%s/%s@jpeg", authorDID, cid)
+				thumb = fmt.Sprintf("https://cdn.bsky.app/img/feed_thumbnail/plain/%s/%s@jpeg", authorDID, cid)
+			}
+
+			viewImages[i] = &bsky.EmbedImages_ViewImage{
+				Alt:         img.Alt,
+				AspectRatio: img.AspectRatio,
+				Fullsize:    fullsize,
+				Thumb:       thumb,
+			}
+		}
+		result.EmbedImages_View = &bsky.EmbedImages_View{
+			LexiconTypeID: "app.bsky.embed.images#view",
+			Images:        viewImages,
+		}
+		return result
+	}
+
+	// Handle external links
+	if embed.EmbedExternal != nil && embed.EmbedExternal.External != nil {
+		// Convert blob thumb to CDN URL if present
+		var thumbURL *string
+		if embed.EmbedExternal.External.Thumb != nil {
+			// CDN URL for external link thumbnails
+			cid := embed.EmbedExternal.External.Thumb.Ref.String()
+			url := fmt.Sprintf("https://cdn.bsky.app/img/feed_thumbnail/plain/%s/%s@jpeg", authorDID, cid)
+			thumbURL = &url
+		}
+
+		result.EmbedExternal_View = &bsky.EmbedExternal_View{
+			LexiconTypeID: "app.bsky.embed.external#view",
+			External: &bsky.EmbedExternal_ViewExternal{
+				Uri:         embed.EmbedExternal.External.Uri,
+				Title:       embed.EmbedExternal.External.Title,
+				Description: embed.EmbedExternal.External.Description,
+				Thumb:       thumbURL,
+			},
+		}
+		return result
+	}
+
+	// Handle video
+	if embed.EmbedVideo != nil && embed.EmbedVideo.Video != nil {
+		cid := embed.EmbedVideo.Video.Ref.String()
+		// URL-encode the DID (replace : with %3A)
+		encodedDID := ""
+		for _, ch := range authorDID {
+			if ch == ':' {
+				encodedDID += "%3A"
+			} else {
+				encodedDID += string(ch)
+			}
+		}
+
+		playlist := fmt.Sprintf("https://video.bsky.app/watch/%s/%s/playlist.m3u8", encodedDID, cid)
+		thumbnail := fmt.Sprintf("https://video.bsky.app/watch/%s/%s/thumbnail.jpg", encodedDID, cid)
+
+		result.EmbedVideo_View = &bsky.EmbedVideo_View{
+			LexiconTypeID: "app.bsky.embed.video#view",
+			Cid:           cid,
+			Playlist:      playlist,
+			Thumbnail:     &thumbnail,
+			Alt:           embed.EmbedVideo.Alt,
+			AspectRatio:   embed.EmbedVideo.AspectRatio,
+		}
+		return result
+	}
+
+	// Handle record (quote posts, etc.)
+	if embed.EmbedRecord != nil && embed.EmbedRecord.Record != nil {
+		rec := embed.EmbedRecord.Record
+
+		result.EmbedRecord_View = &bsky.EmbedRecord_View{
+			LexiconTypeID: "app.bsky.embed.record#view",
+			Record:        h.hydrateEmbeddedRecord(ctx, rec.Uri, viewerDID),
+		}
+		return result
+	}
+
+	// Handle record with media (quote post with images/external)
+	if embed.EmbedRecordWithMedia != nil {
+		recordView := &bsky.EmbedRecordWithMedia_View{
+			LexiconTypeID: "app.bsky.embed.recordWithMedia#view",
+		}
+
+		// Hydrate the record part
+		if embed.EmbedRecordWithMedia.Record != nil && embed.EmbedRecordWithMedia.Record.Record != nil {
+			recordView.Record = &bsky.EmbedRecord_View{
+				LexiconTypeID: "app.bsky.embed.record#view",
+				Record:        h.hydrateEmbeddedRecord(ctx, embed.EmbedRecordWithMedia.Record.Record.Uri, viewerDID),
+			}
+		}
+
+		// Hydrate the media part (images or external)
+		if embed.EmbedRecordWithMedia.Media != nil {
+			if embed.EmbedRecordWithMedia.Media.EmbedImages != nil {
+				viewImages := make([]*bsky.EmbedImages_ViewImage, len(embed.EmbedRecordWithMedia.Media.EmbedImages.Images))
+				for i, img := range embed.EmbedRecordWithMedia.Media.EmbedImages.Images {
+					fullsize := ""
+					thumb := ""
+					if img.Image != nil {
+						cid := img.Image.Ref.String()
+						fullsize = fmt.Sprintf("https://cdn.bsky.app/img/feed_fullsize/plain/%s/%s@jpeg", authorDID, cid)
+						thumb = fmt.Sprintf("https://cdn.bsky.app/img/feed_thumbnail/plain/%s/%s@jpeg", authorDID, cid)
+					}
+
+					viewImages[i] = &bsky.EmbedImages_ViewImage{
+						Alt:         img.Alt,
+						AspectRatio: img.AspectRatio,
+						Fullsize:    fullsize,
+						Thumb:       thumb,
+					}
+				}
+				recordView.Media = &bsky.EmbedRecordWithMedia_View_Media{
+					EmbedImages_View: &bsky.EmbedImages_View{
+						LexiconTypeID: "app.bsky.embed.images#view",
+						Images:        viewImages,
+					},
+				}
+			} else if embed.EmbedRecordWithMedia.Media.EmbedExternal != nil && embed.EmbedRecordWithMedia.Media.EmbedExternal.External != nil {
+				var thumbURL *string
+				if embed.EmbedRecordWithMedia.Media.EmbedExternal.External.Thumb != nil {
+					cid := embed.EmbedRecordWithMedia.Media.EmbedExternal.External.Thumb.Ref.String()
+					url := fmt.Sprintf("https://cdn.bsky.app/img/feed_thumbnail/plain/%s/%s@jpeg", authorDID, cid)
+					thumbURL = &url
+				}
+
+				recordView.Media = &bsky.EmbedRecordWithMedia_View_Media{
+					EmbedExternal_View: &bsky.EmbedExternal_View{
+						LexiconTypeID: "app.bsky.embed.external#view",
+						External: &bsky.EmbedExternal_ViewExternal{
+							Uri:         embed.EmbedRecordWithMedia.Media.EmbedExternal.External.Uri,
+							Title:       embed.EmbedRecordWithMedia.Media.EmbedExternal.External.Title,
+							Description: embed.EmbedRecordWithMedia.Media.EmbedExternal.External.Description,
+							Thumb:       thumbURL,
+						},
+					},
+				}
+			} else if embed.EmbedRecordWithMedia.Media.EmbedVideo != nil && embed.EmbedRecordWithMedia.Media.EmbedVideo.Video != nil {
+				cid := embed.EmbedRecordWithMedia.Media.EmbedVideo.Video.Ref.String()
+				// URL-encode the DID (replace : with %3A)
+				encodedDID := ""
+				for _, ch := range authorDID {
+					if ch == ':' {
+						encodedDID += "%3A"
+					} else {
+						encodedDID += string(ch)
+					}
+				}
+
+				playlist := fmt.Sprintf("https://video.bsky.app/watch/%s/%s/playlist.m3u8", encodedDID, cid)
+				thumbnail := fmt.Sprintf("https://video.bsky.app/watch/%s/%s/thumbnail.jpg", encodedDID, cid)
+
+				recordView.Media = &bsky.EmbedRecordWithMedia_View_Media{
+					EmbedVideo_View: &bsky.EmbedVideo_View{
+						LexiconTypeID: "app.bsky.embed.video#view",
+						Cid:           cid,
+						Playlist:      playlist,
+						Thumbnail:     &thumbnail,
+						Alt:           embed.EmbedRecordWithMedia.Media.EmbedVideo.Alt,
+						AspectRatio:   embed.EmbedRecordWithMedia.Media.EmbedVideo.AspectRatio,
+					},
+				}
+			}
+		}
+
+		result.EmbedRecordWithMedia_View = recordView
+		return result
+	}
+
+	return nil
+}
+
+// hydrateEmbeddedRecord hydrates an embedded record (for quote posts, etc.)
+func (h *Hydrator) hydrateEmbeddedRecord(ctx context.Context, uri string, viewerDID string) *bsky.EmbedRecord_View_Record {
+	// Check if it's a post URI
+	if !isPostURI(uri) {
+		// Could be a feed generator, list, labeler, or starter pack
+		// For now, return not found for non-post embeds
+		return &bsky.EmbedRecord_View_Record{
+			EmbedRecord_ViewNotFound: &bsky.EmbedRecord_ViewNotFound{
+				LexiconTypeID: "app.bsky.embed.record#viewNotFound",
+				Uri:           uri,
+			},
+		}
+	}
+
+	// Try to hydrate the post
+	quotedPost, err := h.HydratePost(ctx, uri, viewerDID)
+	if err != nil {
+		// Post not found
+		return &bsky.EmbedRecord_View_Record{
+			EmbedRecord_ViewNotFound: &bsky.EmbedRecord_ViewNotFound{
+				LexiconTypeID: "app.bsky.embed.record#viewNotFound",
+				Uri:           uri,
+				NotFound:      true,
+			},
+		}
+	}
+
+	// Hydrate the author
+	authorInfo, err := h.HydrateActor(ctx, quotedPost.Author)
+	if err != nil {
+		// Author not found, treat as not found
+		return &bsky.EmbedRecord_View_Record{
+			EmbedRecord_ViewNotFound: &bsky.EmbedRecord_ViewNotFound{
+				LexiconTypeID: "app.bsky.embed.record#viewNotFound",
+				Uri:           uri,
+				NotFound:      true,
+			},
+		}
+	}
+
+	// TODO: Check if viewer has blocked or is blocked by the author
+	// For now, just return the record view
+
+	// Build the author profile view
+	authorView := &bsky.ActorDefs_ProfileViewBasic{
+		Did:    authorInfo.DID,
+		Handle: authorInfo.Handle,
+	}
+	if authorInfo.Profile != nil {
+		if authorInfo.Profile.DisplayName != nil && *authorInfo.Profile.DisplayName != "" {
+			authorView.DisplayName = authorInfo.Profile.DisplayName
+		}
+		if authorInfo.Profile.Avatar != nil {
+			avatarURL := fmt.Sprintf("https://cdn.bsky.app/img/avatar_thumbnail/plain/%s/%s@jpeg", authorInfo.DID, authorInfo.Profile.Avatar.Ref.String())
+			authorView.Avatar = &avatarURL
+		}
+	}
+
+	// Build the embedded post view
+	embedView := &bsky.EmbedRecord_ViewRecord{
+		LexiconTypeID: "app.bsky.embed.record#viewRecord",
+		Uri:           quotedPost.URI,
+		Cid:           quotedPost.Cid,
+		Author:        authorView,
+		Value: &util.LexiconTypeDecoder{
+			Val: quotedPost.Post,
+		},
+		IndexedAt: quotedPost.Post.CreatedAt,
+	}
+
+	// Add engagement counts
+	if quotedPost.LikeCount > 0 {
+		lc := int64(quotedPost.LikeCount)
+		embedView.LikeCount = &lc
+	}
+	if quotedPost.RepostCount > 0 {
+		rc := int64(quotedPost.RepostCount)
+		embedView.RepostCount = &rc
+	}
+	if quotedPost.ReplyCount > 0 {
+		rpc := int64(quotedPost.ReplyCount)
+		embedView.ReplyCount = &rpc
+	}
+
+	// Note: We don't recursively hydrate embeds for quoted posts to avoid deep nesting
+	// The official app also doesn't show embeds within quoted posts
+
+	return &bsky.EmbedRecord_View_Record{
+		EmbedRecord_ViewRecord: embedView,
+	}
+}
+
+// isPostURI checks if a URI is a post URI
+func isPostURI(uri string) bool {
+	return len(uri) > 5 && uri[:5] == "at://" && (
+	// Check if it contains /app.bsky.feed.post/
+	len(uri) > 25 && uri[len(uri)-25:len(uri)-12] == "/app.bsky.feed.post/" ||
+		// More flexible check
+		contains(uri, "/app.bsky.feed.post/"))
+}
+
+// contains checks if a string contains a substring
+func contains(s, substr string) bool {
+	for i := 0; i <= len(s)-len(substr); i++ {
+		if s[i:i+len(substr)] == substr {
+			return true
+		}
+	}
+	return false
+}

main.go

···
 
 	"github.com/bluesky-social/indigo/api/atproto"
 	"github.com/bluesky-social/indigo/atproto/identity"
+	"github.com/bluesky-social/indigo/atproto/identity/redisdir"
 	"github.com/bluesky-social/indigo/atproto/syntax"
 	"github.com/bluesky-social/indigo/cmd/relay/stream"
 	"github.com/bluesky-social/indigo/cmd/relay/stream/schedulers/parallel"
···
 	"github.com/prometheus/client_golang/prometheus/promauto"
 	"github.com/urfave/cli/v2"
 	"github.com/whyrusleeping/konbini/xrpc"
+	"go.opentelemetry.io/otel"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/exporters/jaeger"
+	"go.opentelemetry.io/otel/sdk/resource"
+	tracesdk "go.opentelemetry.io/otel/sdk/trace"
+	semconv "go.opentelemetry.io/otel/semconv/v1.20.0"
 	"gorm.io/gorm/logger"
 
 	. "github.com/whyrusleeping/konbini/models"
···
 			Name:    "db-url",
 			EnvVars: []string{"DATABASE_URL"},
 		},
+		&cli.BoolFlag{
+			Name: "jaeger",
+		},
 		&cli.StringFlag{
 			Name: "handle",
 		},
 		&cli.IntFlag{
 			Name:  "max-db-connections",
 			Value: runtime.NumCPU(),
+		},
+		&cli.StringFlag{
+			Name: "redis-url",
 		},
 	}
 	app.Action = func(cctx *cli.Context) error {
···
 			Colorful:                  true,
 		})
 
+		if cctx.Bool("jaeger") {
+			// Use Jaeger native exporter sending to port 14268
+			jaegerUrl := "http://localhost:14268/api/traces"
+			exp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(jaegerUrl)))
+			if err != nil {
+				return err
+			}
+
+			env := os.Getenv("ENV")
+			if env == "" {
+				env = "development"
+			}
+
+			tp := tracesdk.NewTracerProvider(
+				// Always be sure to batch in production.
+				tracesdk.WithBatcher(exp),
+				// Record information about this application in a Resource.
+				tracesdk.WithResource(resource.NewWithAttributes(
+					semconv.SchemaURL,
+					semconv.ServiceNameKey.String("konbini"),
+					attribute.String("env", env),         // DataDog
+					attribute.String("environment", env), // Others
+					attribute.Int64("ID", 1),
+				)),
+			)
+
+			otel.SetTracerProvider(tp)
+		}
+
 		db.AutoMigrate(Repo{})
 		db.AutoMigrate(Post{})
 		db.AutoMigrate(Follow{})
···
 		password := os.Getenv("BSKY_PASSWORD")
 
 		dir := identity.DefaultDirectory()
+
+		if redisURL := cctx.String("redis-url"); redisURL != "" {
+			rdir, err := redisdir.NewRedisDirectory(dir, redisURL, time.Minute, time.Second*10, time.Second*10, 100_000)
+			if err != nil {
+				return err
+			}
+			dir = rdir
+		}
 
 		resp, err := dir.LookupHandle(ctx, syntax.Handle(handle))
 		if err != nil {

views/feed.go

···
 		}
 	}
 
-	// Add embed handling
-	if post.Post.Embed != nil {
-		view.Embed = formatEmbed(post.Post.Embed, post.Author)
+	// Add embed if it was hydrated
+	if post.EmbedInfo != nil {
+		view.Embed = post.EmbedInfo
 	}
 
 	return view
···
 	// For now leaving them as interface{} to be handled by handlers
 
 	return view
-}
-
-func formatEmbed(embed *bsky.FeedPost_Embed, authorDID string) *bsky.FeedDefs_PostView_Embed {
-	if embed == nil {
-		return nil
-	}
-
-	result := &bsky.FeedDefs_PostView_Embed{}
-
-	// Handle images
-	if embed.EmbedImages != nil {
-		viewImages := make([]*bsky.EmbedImages_ViewImage, len(embed.EmbedImages.Images))
-		for i, img := range embed.EmbedImages.Images {
-			// Convert blob to CDN URLs
-			fullsize := ""
-			thumb := ""
-			if img.Image != nil {
-				// CDN URL format for feed images
-				cid := img.Image.Ref.String()
-				fullsize = fmt.Sprintf("https://cdn.bsky.app/img/feed_fullsize/plain/%s/%s@jpeg", authorDID, cid)
-				thumb = fmt.Sprintf("https://cdn.bsky.app/img/feed_thumbnail/plain/%s/%s@jpeg", authorDID, cid)
-			}
-
-			viewImages[i] = &bsky.EmbedImages_ViewImage{
-				Alt:         img.Alt,
-				AspectRatio: img.AspectRatio,
-				Fullsize:    fullsize,
-				Thumb:       thumb,
-			}
-		}
-		result.EmbedImages_View = &bsky.EmbedImages_View{
-			LexiconTypeID: "app.bsky.embed.images#view",
-			Images:        viewImages,
-		}
-		return result
-	}
-
-	// Handle external links
-	if embed.EmbedExternal != nil && embed.EmbedExternal.External != nil {
-		// Convert blob thumb to CDN URL if present
-		var thumbURL *string
-		if embed.EmbedExternal.External.Thumb != nil {
-			// CDN URL for external link thumbnails
-			cid := embed.EmbedExternal.External.Thumb.Ref.String()
-			url := fmt.Sprintf("https://cdn.bsky.app/img/feed_thumbnail/plain/%s/%s@jpeg", authorDID, cid)
-			thumbURL = &url
-		}
-
-		result.EmbedExternal_View = &bsky.EmbedExternal_View{
-			LexiconTypeID: "app.bsky.embed.external#view",
-			External: &bsky.EmbedExternal_ViewExternal{
-				Uri:         embed.EmbedExternal.External.Uri,
-				Title:       embed.EmbedExternal.External.Title,
-				Description: embed.EmbedExternal.External.Description,
-				Thumb:       thumbURL,
-			},
-		}
-		return result
-	}
-
-	// Handle video
-	if embed.EmbedVideo != nil {
-		// TODO: Implement video embed view
-		// This would require converting video blob to CDN URLs and playlist URLs
-		return nil
-	}
-
-	// Handle record (quote posts, etc.)
-	if embed.EmbedRecord != nil {
-		// TODO: Implement record embed view
-		// This requires hydrating the embedded record, which is complex
-		// For now, return nil to skip these embeds
-		return nil
-	}
-
-	// Handle record with media (quote post with images/external)
-	if embed.EmbedRecordWithMedia != nil {
-		// TODO: Implement record with media embed view
-		// This combines record hydration with media conversion
-		return nil
-	}
-
-	return nil
 }
 
 // GeneratorView builds a feed generator view (app.bsky.feed.defs#generatorView)

xrpc/feed/getAuthorFeed.go

···
 	"log/slog"
 	"net/http"
 	"strconv"
+	"strings"
 	"sync"
 	"time"
 
···
 }
 
 func hydratePostRows(ctx context.Context, hydrator *hydration.Hydrator, viewer string, rows []postRow) []*bsky.FeedDefs_FeedViewPost {
+	ctx, span := tracer.Start(ctx, "hydratePostRows")
+	defer span.End()
+
 	// Hydrate posts
 	var wg sync.WaitGroup
 
···
 
 			postInfo, err := hydrator.HydratePost(ctx, row.URI, viewer)
 			if err != nil {
-				slog.Error("failed to hydrate post", "uri", row.URI, "error", err)
-				return
+				if strings.Contains(err.Error(), "post not found") {
+					hydrator.AddMissingRecord(row.URI, true)
+					postInfo, err = hydrator.HydratePost(ctx, row.URI, viewer)
+					if err != nil {
+						slog.Error("failed to hydrate post after fetch missing", "uri", row.URI, "error", err)
+						return
+					}
+				} else {
+					slog.Warn("failed to hydrate post", "uri", row.URI, "error", err)
+					return
+				}
 			}
 
-			// Hydrate author
 			authorInfo, err := hydrator.HydrateActor(ctx, postInfo.Author)
 			if err != nil {
-				slog.Error("failed to hydrate actor", "actor", postInfo.Author, "error", err)
+				hydrator.AddMissingRecord(postInfo.Author, false)
+				slog.Warn("failed to hydrate author", "did", postInfo.Author, "error", err)
 				return
 			}
 

xrpc/feed/getFeed.go

···
 	}
 
 	// Hydrate the posts from the skeleton
-	posts := make([]*bsky.FeedDefs_FeedViewPost, 0, len(skeleton.Feed))
+	posts := make([]*bsky.FeedDefs_FeedViewPost, len(skeleton.Feed))
 	var wg sync.WaitGroup
 	for i := range skeleton.Feed {
 		wg.Add(1)
···
 
 			authorInfo, err := hydrator.HydrateActor(ctx, postInfo.Author)
 			if err != nil {
+				hydrator.AddMissingRecord(postInfo.Author, false)
 				slog.Warn("failed to hydrate author", "did", postInfo.Author, "error", err)
 				return
 			}

xrpc/feed/getTimeline.go

···
 package feed
 
 import (
+	"context"
 	"net/http"
 	"strconv"
 	"time"
 
 	"github.com/labstack/echo/v4"
 	"github.com/whyrusleeping/konbini/hydration"
+	"go.opentelemetry.io/otel"
 	"gorm.io/gorm"
 )
+
+var tracer = otel.Tracer("xrpc/feed")
 
 // HandleGetTimeline implements app.bsky.feed.getTimeline
 func HandleGetTimeline(c echo.Context, db *gorm.DB, hydrator *hydration.Hydrator) error {
+	ctx := c.Request().Context()
+	ctx, span := tracer.Start(ctx, "getTimeline")
+	defer span.End()
+
 	viewer := getUserDID(c)
 	if viewer == "" {
 		return c.JSON(http.StatusUnauthorized, map[string]any{
···
 		}
 	}
 
-	ctx := c.Request().Context()
-
 	// Get viewer's repo ID
 	var viewerRepoID uint
 	if err := db.Raw("SELECT id FROM repos WHERE did = ?", viewer).Scan(&viewerRepoID).Error; err != nil {
···
 	}
 
 	// Query posts from followed users
-	var rows []postRow
-	err := db.Raw(`
-		SELECT
-			'at://' || r.did || '/app.bsky.feed.post/' || p.rkey as uri,
-			p.author as author_id
-		FROM posts p
-		JOIN repos r ON r.id = p.author
-		WHERE p.reply_to = 0
-		AND p.author IN (SELECT subject FROM follows WHERE author = ?)
-		AND p.created < ?
-		AND p.not_found = false
-		ORDER BY p.created DESC
-		LIMIT ?
-	`, viewerRepoID, cursor, limit).Scan(&rows).Error
 
+	rows, err := getTimelinePosts(ctx, db, viewerRepoID, cursor, limit)
 	if err != nil {
 		return c.JSON(http.StatusInternalServerError, map[string]any{
 			"error":   "InternalError",
···
 		"cursor": nextCursor,
 	})
 }
+
+func getTimelinePosts(ctx context.Context, db *gorm.DB, uid uint, cursor time.Time, limit int) ([]postRow, error) {
+	ctx, span := tracer.Start(ctx, "getTimelineQuery")
+	defer span.End()
+
+	var rows []postRow
+	err := db.Raw(`
+		SELECT
+			'at://' || r.did || '/app.bsky.feed.post/' || p.rkey as uri,
+			p.author as author_id
+		FROM posts p
+		JOIN repos r ON r.id = p.author
+		WHERE p.reply_to = 0
+		AND p.author IN (SELECT subject FROM follows WHERE author = ?)
+		AND p.created < ?
+		AND p.not_found = false
+		ORDER BY p.created DESC
+		LIMIT ?
+	`, uid, cursor, limit).Scan(&rows).Error
+
+	if err != nil {
+		return nil, err
+	}
+	return rows, nil
+}

xrpc/server.go

···
 		db:       db,
 		dir:      dir,
 		backend:  backend,
-		hydrator: hydration.NewHydrator(db, dir),
+		hydrator: hydration.NewHydrator(db, dir, backend),
 	}
-
-	s.hydrator.SetMissingRecordCallback(backend.TrackMissingRecord)
 
 	// Register XRPC endpoints
 	s.registerEndpoints()