fix_: make StoreNodeRequestManager filters ephemeral
This commit is contained in:
parent
b36ddda6ed
commit
81f3a0d0f2
|
@ -279,6 +279,8 @@ func (m *StoreNodeRequestManager) getFilter(requestType storeNodeRequestType, da
|
||||||
return nil, false, fmt.Errorf("invalid store node request type: %d", requestType)
|
return nil, false, fmt.Errorf("invalid store node request type: %d", requestType)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
filter.Ephemeral = true
|
||||||
|
|
||||||
return filter, true, nil
|
return filter, true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -543,7 +543,7 @@ func (f *FiltersManager) LoadPublic(chatID string, pubsubTopic string) (*Filter,
|
||||||
f.logger.Debug("updating pubsub topic for filter",
|
f.logger.Debug("updating pubsub topic for filter",
|
||||||
zap.String("chatID", chatID),
|
zap.String("chatID", chatID),
|
||||||
zap.String("type", "public"),
|
zap.String("type", "public"),
|
||||||
zap.String("oldTOpic", chat.PubsubTopic),
|
zap.String("oldTopic", chat.PubsubTopic),
|
||||||
zap.String("newTopic", pubsubTopic),
|
zap.String("newTopic", pubsubTopic),
|
||||||
)
|
)
|
||||||
chat.PubsubTopic = pubsubTopic
|
chat.PubsubTopic = pubsubTopic
|
||||||
|
|
Loading…
Reference in New Issue