feat(network): subscribe to conversations on node init

Signed-off-by: Godefroy Ponsinet <godefroy.ponsinet@outlook.com>

core/node/network.go

@@ -3,6 +3,7 @@ package node
 import (
 	"context"
 
+	"berty.tech/core/entity"
 	"berty.tech/core/network"
 	"go.uber.org/zap"
 )
@@ -26,7 +27,22 @@ func (n *Node) UseNetworkDriver(driver network.Driver) error {
 			zap.Error(err),
 		)
 	}
+
 	// FIXME: subscribe to every owned device IDs
-	// FIXME: subscribe to every joined conversations
+	// var devices []entity.Device
+	// n.sql.Table("device").Select("id").Find(&devices)
+	// for _, device := range devices {
+	// 	if err := n.networkDriver.Join(context.Background(), device.ID); err != nil {
+	// 		logger().Warn(err.Error())
+	// 	}
+	// }
+
+	var conversations []entity.Conversation
+	n.sql.Table("conversation").Select("id").Find(&conversations)
+	for _, conversation := range conversations {
+		if err := n.networkDriver.Join(context.Background(), conversation.ID); err != nil {
+			logger().Warn(err.Error())
+		}
+	}
 	return nil
 }