From f9ccd7e021472d737defd5bdef5867ddf221008f Mon Sep 17 00:00:00 2001 From: Andrey Kolkov Date: Fri, 5 Mar 2021 15:33:10 +0400 Subject: [PATCH] Revert redis/subscriptions.go --- database/redis/subscription.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/database/redis/subscription.go b/database/redis/subscription.go index 28284e945..181d454f4 100644 --- a/database/redis/subscription.go +++ b/database/redis/subscription.go @@ -79,7 +79,7 @@ func (connector *DbConnector) updateSubscription(newSubscription *moira.Subscrip c := connector.pool.Get() defer c.Close() - c.Send("MULTI") //nolint + c.Send("MULTI") //nolint addSendSubscriptionRequest(c, *newSubscription, oldSubscription) //nolint _, err := c.Do("EXEC") if err != nil { @@ -156,13 +156,13 @@ func (connector *DbConnector) removeSubscription(subscription *moira.Subscriptio c := connector.pool.Get() defer c.Close() - c.Send("MULTI") //nolint + c.Send("MULTI") //nolint c.Send("SREM", userSubscriptionsKey(subscription.User), subscription.ID) //nolint for _, tag := range subscription.Tags { c.Send("SREM", tagSubscriptionKey(tag), subscription.ID) //nolint } c.Send("SREM", anyTagsSubscriptionsKey, subscription.ID) //nolint - c.Send("DEL", subscriptionKey(subscription.ID)) //nolint + c.Send("DEL", subscriptionKey(subscription.ID)) //nolint if _, err := c.Do("EXEC"); err != nil { return fmt.Errorf("failed to EXEC: %s", err.Error()) } @@ -243,7 +243,7 @@ func addSendSubscriptionRequest(c redis.Conn, subscription moira.SubscriptionDat } c.Send("SADD", userSubscriptionsKey(subscription.User), subscription.ID) //nolint - c.Send("SET", subscriptionKey(subscription.ID), bytes) //nolint + c.Send("SET", subscriptionKey(subscription.ID), bytes) //nolint return nil }