nandi/glean · f973feb

nandi/gleanpublic⑂ Fork 0

⑂ f973feb

Add in-memory profile caching with TTLUnverified

Julien Robert committed 2026-04-23T22:29:11+02:00 Browse files

f973feb parent: 486c824

modified internal/atproto/auth.go +18 -0 Viewed

@@ -6,6 +6,7 @@ import (
6	6	"net"
7	7	"net/http"
8	8	"os"
	9	+ "sync"
9	10	"time"
10	11
11	12	"github.com/bluesky-social/indigo/atproto/identity"
@@ -118,7 +119,23 @@ type Profile struct {
118	119	AvatarURL string
119	120	}
120	121
	122	+type profileEntry struct {
	123	+ profile Profile
	124	+ fetched time.Time
	125	+}
	126	+
	127	+var profileCache sync.Map
	128	+
	129	+const profileCacheTTL = 4 * time.Hour
	130	+
121	131	func ResolveProfile(ctx context.Context, did string) Profile {
	132	+ if cached, ok := profileCache.Load(did); ok {
	133	+ entry := cached.(*profileEntry)
	134	+ if time.Since(entry.fetched) < profileCacheTTL {
	135	+ return entry.profile
	136	+ }
	137	+ }
	138	+
122	139	ident, err := ResolveIdentity(ctx, did)
123	140	if err != nil {
124	141	return Profile{}
@@ -140,5 +157,6 @@ func ResolveProfile(ctx context.Context, did string) Profile {
140	157	p.DisplayName = dn
141	158	p.AvatarURL = avatar
142	159
	160	+ profileCache.Store(did, &profileEntry{profile: p, fetched: time.Now()})
143	161	return p
144	162	}

  	"net"
  	"net/http"
  	"os"
++	"sync"
  	"time"
  	"github.com/bluesky-social/indigo/atproto/identity"
  	AvatarURL   string
  }
++type profileEntry struct {
++	profile Profile
++	fetched time.Time
++}
++
++var profileCache sync.Map
++
++const profileCacheTTL = 4 * time.Hour
++
  func ResolveProfile(ctx context.Context, did string) Profile {
++	if cached, ok := profileCache.Load(did); ok {
++		entry := cached.(*profileEntry)
++		if time.Since(entry.fetched) < profileCacheTTL {
++			return entry.profile
++		}
++	}
++
  	ident, err := ResolveIdentity(ctx, did)
  	if err != nil {
  		return Profile{}
  	p.DisplayName = dn
  	p.AvatarURL = avatar
++	profileCache.Store(did, &profileEntry{profile: p, fetched: time.Now()})
  	return p
  }