Configure web relays from config file

Author: hoffmabc

cmd/start.go

@@ -240,6 +240,11 @@ func (x *Start) Execute(args []string) error {
 		log.Error("scan data sharing config:", err)
 		return err
 	}
+	webRelays, err := schema.GetWebRelays(configFile)
+	if err != nil {
+		log.Error("scan web relays config:", err)
+		return err
+	}
 	dropboxToken, err := schema.GetDropboxApiToken(configFile)
 	if err != nil {
 		log.Error("scan dropbox api token:", err)
@@ -587,6 +592,8 @@ func (x *Start) Execute(args []string) error {
 	subscriber := ipfs.NewPubsubSubscriber(context.Background(), nd.PeerHost, nd.Routing, nd.Repo.Datastore(), nd.PubSub)
 	ps := ipfs.Pubsub{Publisher: publisher, Subscriber: subscriber}
 
+	wm := obnet.NewWebRelayManager(webRelays, identity.PeerID)
+
 	// OpenBazaar node setup
 	core.Node = &core.OpenBazaarNode{
 		AcceptStoreRequests:           dataSharing.AcceptStoreRequests,
@@ -599,6 +606,7 @@ func (x *Start) Execute(args []string) error {
 		OfflineMessageFailoverTimeout: 30 * time.Second,
 		Pubsub:                        ps,
 		PushNodes:                     pushNodes,
+		WebRelayManager:			   wm,
 		RegressionTestEnable:          x.Regtest,
 		RepoPath:                      repoPath,
 		RootHash:                      string(ourIpnsRecord.Value),

mobile/node.go

@@ -155,6 +155,11 @@ func NewNodeWithConfig(config *NodeConfig, password string, mnemonic string) (*N
 		return nil, err
 	}
 
+	webRelays, err := apiSchema.GetWebRelays(configFile)
+	if err != nil {
+		return nil, err
+	}
+
 	walletsConfig, err := apiSchema.GetWalletsConfig(configFile)
 	if err != nil {
 		return nil, err
@@ -279,6 +284,8 @@ func NewNodeWithConfig(config *NodeConfig, password string, mnemonic string) (*N
 		pushNodes = append(pushNodes, p)
 	}
 
+	wm := obnet.NewWebRelayManager(webRelays, identity.PeerID)
+
 	// OpenBazaar node setup
 	node := &core.OpenBazaarNode{
 		BanManager:                    bm,
@@ -287,6 +294,7 @@ func NewNodeWithConfig(config *NodeConfig, password string, mnemonic string) (*N
 		Multiwallet:                   mw,
 		OfflineMessageFailoverTimeout: 5 * time.Second,
 		PushNodes:                     pushNodes,
+		WebRelayManager:			   wm,
 		RepoPath:                      config.RepoPath,
 		UserAgent:                     core.USERAGENT,
 		IPNSQuorumSize:                uint(ipnsExtraConfig.DHTQuorumSize),