oppi.li
+5
-5
atproto/identity/redisdir/redis_directory.go
+5
-5
atproto/identity/redisdir/redis_directory.go
···
273
273
}
274
274
275
275
func (d *RedisDirectory) LookupDID(ctx context.Context, did syntax.DID) (*identity.Identity, error) {
276
-
id, _, err := d.lookupDIDWithCacheState(ctx, did)
276
+
id, _, err := d.LookupDIDWithCacheState(ctx, did)
277
277
return id, err
278
278
}
279
279
280
-
func (d *RedisDirectory) lookupDIDWithCacheState(ctx context.Context, did syntax.DID) (*identity.Identity, bool, error) {
280
+
func (d *RedisDirectory) LookupDIDWithCacheState(ctx context.Context, did syntax.DID) (*identity.Identity, bool, error) {
281
281
start := time.Now()
282
282
var entry identityEntry
283
283
err := d.identityCache.Get(ctx, redisDirPrefix+did.String(), &entry)
···
340
340
}
341
341
342
342
func (d *RedisDirectory) LookupHandle(ctx context.Context, h syntax.Handle) (*identity.Identity, error) {
343
-
ident, _, err := d.lookupHandleWithCacheState(ctx, h)
343
+
ident, _, err := d.LookupHandleWithCacheState(ctx, h)
344
344
return ident, err
345
345
}
346
346
347
-
func (d *RedisDirectory) lookupHandleWithCacheState(ctx context.Context, h syntax.Handle) (*identity.Identity, bool, error) {
347
+
func (d *RedisDirectory) LookupHandleWithCacheState(ctx context.Context, h syntax.Handle) (*identity.Identity, bool, error) {
348
348
h = h.Normalize()
349
349
did, err := d.ResolveHandle(ctx, h)
350
350
if err != nil {
351
351
return nil, false, err
352
352
}
353
-
ident, hit, err := d.lookupDIDWithCacheState(ctx, did)
353
+
ident, hit, err := d.LookupDIDWithCacheState(ctx, did)
354
354
if err != nil {
355
355
return nil, hit, err
356
356
}