From e9f46d7b14c1071eeceb0c37ea109ef314d94594 Mon Sep 17 00:00:00 2001 From: admin Date: Sun, 17 Aug 2025 11:47:21 +0300 Subject: [PATCH] feat: update product key generation to include compression in repository API --- internal/ozon/products/repository_api.go | 2 +- internal/wb/products/repository_api.go | 2 +- internal/ym/products/repository_api.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/ozon/products/repository_api.go b/internal/ozon/products/repository_api.go index dd145f5..936c8af 100644 --- a/internal/ozon/products/repository_api.go +++ b/internal/ozon/products/repository_api.go @@ -23,7 +23,7 @@ type apiRepository struct { } func GetProductsKey(identifier string) string { - return fmt.Sprintf("ozon:products:%s", identifier) + return fmt.Sprintf("ozon:products:%s:compressed", identifier) } func NewAPIRepository(marketplaceRepository marketplace.Repository) Repository { diff --git a/internal/wb/products/repository_api.go b/internal/wb/products/repository_api.go index 9e87a90..37b137a 100644 --- a/internal/wb/products/repository_api.go +++ b/internal/wb/products/repository_api.go @@ -26,7 +26,7 @@ type apiRepository struct { } func GetProductsKey(identifier string) string { - return fmt.Sprintf("wb:products:%s", identifier) + return fmt.Sprintf("wb:products:%s:compressed", identifier) } func (a apiRepository) ParseMarketplace(ctx context.Context, marketplaceId int) (*marketplace.Marketplace, string, error) { diff --git a/internal/ym/products/repository_api.go b/internal/ym/products/repository_api.go index 057c323..bbb1f95 100644 --- a/internal/ym/products/repository_api.go +++ b/internal/ym/products/repository_api.go @@ -40,7 +40,7 @@ func NewAPIRepository(marketplaceRepository marketplace.Repository) Repository { } func GetProductKey(identifier string) string { - return fmt.Sprintf("ym:products:%s", identifier) + return fmt.Sprintf("ym:products:%s:compressed", identifier) } // getBusinessID retrieves the business ID for a given marketplace by looking up the campaign