From c6aa2cf4a2341e7080553853c92c1dc48cb0a01c Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sun, 3 Mar 2024 11:26:44 -0500 Subject: [PATCH] fix: Get needs to actually return the entry --- service/default/registry.go | 22 ++++++++++------------ 1 file changed, 10 insertions(+), 12 deletions(-) diff --git a/service/default/registry.go b/service/default/registry.go index 7aa47ea..31a155b 100644 --- a/service/default/registry.go +++ b/service/default/registry.go @@ -240,21 +240,19 @@ func (r *RegistryServiceDefault) Get(pk []byte) (protocol.SignedRegistryEntry, e return res, nil } - if res == nil { - r.Logger().Debug("[registry] get (cached)", zap.String("key", keyString)) - for i := 0; i < 200; i++ { - time.Sleep(10 * time.Millisecond) - res, err := r.getFromDB(pk) - if err != nil { - return nil, err - } - if res != nil { - break - } + r.Logger().Debug("[registry] get (cached)", zap.String("key", keyString)) + for i := 0; i < 200; i++ { + time.Sleep(10 * time.Millisecond) + res, err = r.getFromDB(pk) + if err != nil { + return nil, err + } + if res != nil { + break } } - return nil, nil + return res, nil } func (r *RegistryServiceDefault) Listen(pk []byte, cb func(sre protocol.SignedRegistryEntry)) (func(), error) {