feat: [AH-2845]: add cache for registry UUID

registry/app/services/refcache/reg_finder.go

@@ -22,11 +22,14 @@ import (
 	"github.com/harness/gitness/app/store/cache"
 	"github.com/harness/gitness/registry/app/store"
 	"github.com/harness/gitness/registry/types"
+
+	"github.com/google/uuid"
 )
 
 type RegistryFinder interface {
 	MarkChanged(ctx context.Context, reg *types.Registry)
 	FindByID(ctx context.Context, repoID int64) (*types.Registry, error)
+	FindByUUID(ctx context.Context, repoUUID uuid.UUID) (*types.Registry, error)
 	FindByRootRef(ctx context.Context, rootParentRef string, regIdentifier string) (
 		*types.Registry,
 		error,
@@ -42,6 +45,7 @@ type RegistryFinder interface {
 type registryFinder struct {
 	inner               store.RegistryRepository
 	regIDCache          store.RegistryIDCache
+	regUUIDCache        store.RegistryUUIDCache
 	regRootRefCache     store.RegistryRootRefCache
 	spaceFinder         refcache.SpaceFinder
 	evictor             cache.Evictor[*types.Registry]
@@ -51,6 +55,7 @@ type registryFinder struct {
 func NewRegistryFinder(
 	registryRepository store.RegistryRepository,
 	regIDCache store.RegistryIDCache,
+	regUUIDCache store.RegistryUUIDCache,
 	regRootRefCache store.RegistryRootRefCache,
 	evictor cache.Evictor[*types.Registry],
 	spaceFinder refcache.SpaceFinder,
@@ -59,6 +64,7 @@ func NewRegistryFinder(
 	return registryFinder{
 		inner:               registryRepository,
 		regIDCache:          regIDCache,
+		regUUIDCache:        regUUIDCache,
 		regRootRefCache:     regRootRefCache,
 		evictor:             evictor,
 		spaceFinder:         spaceFinder,
@@ -82,6 +88,10 @@ func (r registryFinder) FindByID(ctx context.Context, repoID int64) (*types.Regi
 	return r.regIDCache.Get(ctx, repoID)
 }
 
+func (r registryFinder) FindByUUID(ctx context.Context, repoUUID uuid.UUID) (*types.Registry, error) {
+	return r.regUUIDCache.Get(ctx, repoUUID.String())
+}
+
 func (r registryFinder) FindByRootRef(ctx context.Context, rootParentRef string, regIdentifier string) (
 	*types.Registry,
 	error,

registry/app/services/refcache/wire.go

@@ -26,12 +26,21 @@ import (
 func ProvideRegistryFinder(
 	registryRepository store.RegistryRepository,
 	regIDCache store.RegistryIDCache,
+	regUUIDCache store.RegistryUUIDCache,
 	regRootRefCache store.RegistryRootRefCache,
 	evictor cache.Evictor[*types.Registry],
 	spaceFinder refcache.SpaceFinder,
 	upstreamProxyFinder UpstreamProxyFinder,
 ) RegistryFinder {
-	return NewRegistryFinder(registryRepository, regIDCache, regRootRefCache, evictor, spaceFinder, upstreamProxyFinder)
+	return NewRegistryFinder(
+		registryRepository,
+		regIDCache,
+		regUUIDCache,
+		regRootRefCache,
+		evictor,
+		spaceFinder,
+		upstreamProxyFinder,
+	)
 }
 
 func ProvideUpstreamProxyFinder(

registry/app/store/cache.go

@@ -22,5 +22,6 @@ import (
 type (
 	RegistryIDCache              cache.Cache[int64, *types.Registry]
 	RegistryRootRefCache         cache.Cache[types.RegistryRootRefCacheKey, int64]
+	RegistryUUIDCache            cache.Cache[string, *types.Registry]
 	UpstreamProxyRegistryIDCache cache.Cache[int64, *types.UpstreamProxy]
 )

registry/app/store/cache/reg_uuid.go

@@ -0,0 +1,55 @@
+// Copyright 2023 Harness, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package cache
+
+import (
+	"context"
+	"fmt"
+	"time"
+
+	cache2 "github.com/harness/gitness/app/store/cache"
+	"github.com/harness/gitness/cache"
+	"github.com/harness/gitness/registry/app/store"
+	"github.com/harness/gitness/registry/types"
+)
+
+func NewRegistryUUIDCache(
+	appCtx context.Context,
+	regSource store.RegistryRepository,
+	evictorRepo cache2.Evictor[*types.Registry],
+	dur time.Duration,
+) store.RegistryUUIDCache {
+	c := cache.New[string, *types.Registry](registryUUIDCacheGetter{regSource: regSource}, dur)
+
+	evictorRepo.Subscribe(appCtx, func(repoCore *types.Registry) error {
+		c.Evict(appCtx, repoCore.UUID)
+		return nil
+	})
+
+	return c
+}
+
+type registryUUIDCacheGetter struct {
+	regSource store.RegistryRepository
+}
+
+func (c registryUUIDCacheGetter) Find(ctx context.Context, repoUUID string) (*types.Registry, error) {
+	repo, err := c.regSource.GetByUUID(ctx, repoUUID)
+	if err != nil {
+		return nil, fmt.Errorf("failed to find repo by UUID: %w", err)
+	}
+
+	return repo, nil
+}

registry/app/store/cache/wire.go

@@ -61,6 +61,14 @@ func ProvideRegRootRefCache(
 	return NewRegistryRootRefCache(appCtx, regSource, evictorRepo, registryCacheDuration)
 }
 
+func ProvideRegistryUUIDCache(
+	appCtx context.Context,
+	regSource store.RegistryRepository,
+	evictorRepo cache.Evictor[*types.Registry],
+) store.RegistryUUIDCache {
+	return NewRegistryUUIDCache(appCtx, regSource, evictorRepo, registryCacheDuration)
+}
+
 func ProvideUpstreamProxyRegistryIDCache(
 	appCtx context.Context,
 	upstreamProxySource store.UpstreamProxyConfigRepository,
@@ -74,5 +82,6 @@ var WireSet = wire.NewSet(
 	ProvideEvictorUpstreamProxy,
 	ProvideRegRootRefCache,
 	ProvideRegistryIDCache,
+	ProvideRegistryUUIDCache,
 	ProvideUpstreamProxyRegistryIDCache,
 )