kalipso/pentapass
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix pubsub broadcast validation error

Browse Source
This commit is contained in:
kalipso
2024-10-10 14:50:11 +02:00
parent 817a14704b
commit b19eb8f422
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/storage/vault.go
View File

@@ -211,7 +211,7 @@ func CreateVault(ID string, storageHandler *StorageHandler) (*Vault, error) {
ID, //== topicName ID, //== topicName
func(ctx context.Context, id peer.ID, msg *pubsub.Message) bool { func(ctx context.Context, id peer.ID, msg *pubsub.Message) bool {
if id == storageHandler.Host.ID() { if id == storageHandler.Host.ID() {
return false return true
} }
Logger.Debugf("PubSubmsg TOPIC: %s, PEER: %s\n", ID, id) Logger.Debugf("PubSubmsg TOPIC: %s, PEER: %s\n", ID, id)