fix: enable discover on oneonone channel

Signed-off-by: gfanton <8671905+gfanton@users.noreply.github.com>
berty · Mar 1, 2022 · 56097ce · 56097ce
1 parent f7c6baf
commit 56097ce
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/pubsub/oneonone/channel.go b/pubsub/oneonone/channel.go
@@ -42,7 +42,7 @@ func (c *channel) Connect(ctx context.Context, target peer.ID) error {
 	if _, ok := c.subs[target]; !ok {
 		c.logger.Debug(fmt.Sprintf("subscribing to %s", channelID))
 
-		sub, err := c.ipfs.PubSub().Subscribe(ctx, channelID)
+		sub, err := c.ipfs.PubSub().Subscribe(ctx, channelID, options.PubSub.Discover(true))
 		if err != nil {
 			c.muSubs.Unlock()
 			return errors.Wrap(err, "unable to subscribe to pubsub")
@@ -72,11 +72,7 @@ func (c *channel) sendHelloPacket(ctx context.Context, p peer.ID) error {
 	return nil
 }
 
-var sendcounter int64
-
 func (c *channel) Send(ctx context.Context, p peer.ID, data []byte) error {
-	sendcounter++
-	fmt.Printf("oneone counter send: %d - %s\n", sendcounter, string(data))
 	channelid := c.getOurChannelID(p)
 	err := c.ipfs.PubSub().Publish(ctx, channelid, data)
 	if err != nil {

diff --git a/pubsub/pubsubraw/pubsub.go b/pubsub/pubsubraw/pubsub.go
@@ -66,7 +66,7 @@ func (p *psTopic) WatchMessages(ctx context.Context) (<-chan *iface.EventPubSubM
 		return nil, err
 	}
 
-	ch := make(chan *iface.EventPubSubMessage, 128)
+	ch := make(chan *iface.EventPubSubMessage)
 	go func() {
 		defer close(ch)
 		for {