From b19eb8f4227c4e99c964dfc637befe35a17744f4 Mon Sep 17 00:00:00 2001 From: kalipso Date: Thu, 10 Oct 2024 14:50:11 +0200 Subject: [PATCH] fix pubsub broadcast validation error --- internal/storage/vault.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/storage/vault.go b/internal/storage/vault.go index b858628..81a50de 100644 --- a/internal/storage/vault.go +++ b/internal/storage/vault.go @@ -211,7 +211,7 @@ func CreateVault(ID string, storageHandler *StorageHandler) (*Vault, error) { ID, //== topicName func(ctx context.Context, id peer.ID, msg *pubsub.Message) bool { if id == storageHandler.Host.ID() { - return false + return true } Logger.Debugf("PubSubmsg TOPIC: %s, PEER: %s\n", ID, id)