From 9a0d2f59481e666956849391a0c0553f50f528a0 Mon Sep 17 00:00:00 2001
From: Lukasz Zimnoch <lukasz.zimnoch@keep.network>
Date: Fri, 1 May 2020 10:38:06 +0200
Subject: [PATCH] Move counter incrementing before announce

---
 pubsub.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/pubsub.go b/pubsub.go
index c96cd8a..50bb2a1 100644
--- a/pubsub.go
+++ b/pubsub.go
@@ -667,15 +667,15 @@ func (p *PubSub) handleAddSubscription(req *addSubReq) {
 func (p *PubSub) handleAddRelay(req *addRelayReq) {
 	topic := req.topic
 
+	p.myRelays[topic]++
+
 	// announce we want this topic if neither relays nor subs exist so far
-	if p.myRelays[topic] == 0 && len(p.mySubs[topic]) == 0 {
+	if p.myRelays[topic] == 1 && len(p.mySubs[topic]) == 0 {
 		p.disc.Advertise(topic)
 		p.announce(topic, true)
 		p.rt.Join(topic)
 	}
 
-	p.myRelays[topic]++
-
 	req.resp <- func() {
 		select {
 		case p.rmRelay <- topic: