Skip to content

Commit 72d7e1f

Browse files
committed
update ListStorageProviders cache
1 parent 94538fe commit 72d7e1f

1 file changed

Lines changed: 7 additions & 2 deletions

File tree

internal/grpc/services/gateway/storageprovidercache.go

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,16 +42,21 @@ type cachedRegistryClient struct {
4242

4343
func (c *cachedRegistryClient) ListStorageProviders(ctx context.Context, in *registry.ListStorageProvidersRequest, opts ...grpc.CallOption) (*registry.ListStorageProvidersResponse, error) {
4444
spaceID := utils.ReadPlainFromOpaque(in.GetOpaque(), "space_id")
45+
resourceID := spaceID
4546
if storageID := utils.ReadPlainFromOpaque(in.GetOpaque(), "storage_id"); storageID != "" {
46-
spaceID = storagespace.FormatStorageID(storageID, spaceID)
47+
if spaceID != "" {
48+
resourceID = storagespace.FormatStorageID(storageID, spaceID)
49+
} else {
50+
resourceID = storageID
51+
}
4752
}
4853

4954
u, ok := ctxpkg.ContextGetUser(ctx)
5055
if !ok {
5156
return nil, errors.New("user not found in context")
5257
}
5358

54-
key := c.cache.GetKey(u.GetId(), spaceID)
59+
key := c.cache.GetKey(u.GetId(), resourceID)
5560
if key != "" {
5661
s := &registry.ListStorageProvidersResponse{}
5762
if err := c.cache.PullFromCache(key, s); err == nil {

0 commit comments

Comments
 (0)