From 686c1088a98f20a66737dd438383af57171ddbd5 Mon Sep 17 00:00:00 2001 From: Maxim Lebedev Date: Wed, 20 Dec 2023 07:34:06 +0600 Subject: [PATCH] :card_file_box: Fixed subscription memory repository Delete signature --- .../subscription/repository/memory/memory_subscription.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/subscription/repository/memory/memory_subscription.go b/internal/subscription/repository/memory/memory_subscription.go index 273353e..2bab67a 100644 --- a/internal/subscription/repository/memory/memory_subscription.go +++ b/internal/subscription/repository/memory/memory_subscription.go @@ -39,13 +39,13 @@ func (repo *memorySubscriptionRepository) Create(ctx context.Context, suid domai return nil } -func (repo *memorySubscriptionRepository) Delete(ctx context.Context, suid domain.SUID) error { +func (repo *memorySubscriptionRepository) Delete(ctx context.Context, suid domain.SUID) (bool, error) { if _, err := repo.Get(ctx, suid); err != nil { if !errors.Is(err, subscription.ErrNotExist) { - return fmt.Errorf("cannot delete subscription: %w", err) + return false, fmt.Errorf("cannot delete subscription: %w", err) } - return nil + return false, nil } repo.mutex.Lock() @@ -53,7 +53,7 @@ func (repo *memorySubscriptionRepository) Delete(ctx context.Context, suid domai delete(repo.subscriptions, suid) - return nil + return true, nil } func (repo *memorySubscriptionRepository) Get(_ context.Context, suid domain.SUID) (*domain.Subscription, error) {