From 81f3a0d0f2f4231a136d222b38ce0642dd4ffc74 Mon Sep 17 00:00:00 2001 From: Igor Sirotin Date: Thu, 25 Jul 2024 18:21:21 +0100 Subject: [PATCH] fix_: make StoreNodeRequestManager filters ephemeral --- protocol/messenger_store_node_request_manager.go | 2 ++ protocol/transport/filters_manager.go | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/protocol/messenger_store_node_request_manager.go b/protocol/messenger_store_node_request_manager.go index 0dbf9bece..0bd6642cd 100644 --- a/protocol/messenger_store_node_request_manager.go +++ b/protocol/messenger_store_node_request_manager.go @@ -279,6 +279,8 @@ func (m *StoreNodeRequestManager) getFilter(requestType storeNodeRequestType, da return nil, false, fmt.Errorf("invalid store node request type: %d", requestType) } + filter.Ephemeral = true + return filter, true, nil } diff --git a/protocol/transport/filters_manager.go b/protocol/transport/filters_manager.go index 735110658..5393d63bf 100644 --- a/protocol/transport/filters_manager.go +++ b/protocol/transport/filters_manager.go @@ -543,7 +543,7 @@ func (f *FiltersManager) LoadPublic(chatID string, pubsubTopic string) (*Filter, f.logger.Debug("updating pubsub topic for filter", zap.String("chatID", chatID), zap.String("type", "public"), - zap.String("oldTOpic", chat.PubsubTopic), + zap.String("oldTopic", chat.PubsubTopic), zap.String("newTopic", pubsubTopic), ) chat.PubsubTopic = pubsubTopic