Listening to websocket for incomings

Fix peer ID

Fix peer ID

Author: hoffmabc

core/net.go

@@ -106,7 +106,7 @@ func (n *OpenBazaarNode) SendOfflineMessage(p peer.ID, k *libp2p.PubKey, m *pb.M
 	// Base64 encode
 	encodedCipherText := base64.StdEncoding.EncodeToString(relayciphertext)
 
-	n.WebRelayManager.SendRelayMessage(encodedCipherText, p.String())
+	n.WebRelayManager.SendRelayMessage(encodedCipherText, p.Pretty())
 
 	// TODO: this function blocks if the recipient's public key is not on the local machine
 	ciphertext, cerr := n.EncryptMessage(p, k, messageBytes)

net/web_relay_manager.go

@@ -86,6 +86,7 @@ func connectToServer(relay string, sender string) (*websocket.Conn, error) {
 
 	socketmessage, _ := json.Marshal(typedmessage)
 
+	fmt.Println(string(socketmessage))
 	// Connect to websocket server
 	fmt.Printf("Connecting to relay server: %s\n", relay)
 
@@ -103,6 +104,25 @@ func connectToServer(relay string, sender string) (*websocket.Conn, error) {
 
 	fmt.Printf("Successfully connected and subscribed to: %s\n", relay)
 
+	go func() {
+		for {
+			// read in a message
+			_, p, err := c.ReadMessage()
+			if err != nil {
+				fmt.Println(err)
+				//return nil, err
+			}
+			// print out that message for clarity
+			fmt.Printf("Received incoming message from relay: %s\n", string(p))
+
+			//if err := c.WriteMessage(messageType, p); err != nil {
+			//	fmt.Println(err)
+			//	//return nil, err
+			//}
+
+		}
+	}()
+
 	return c, nil
 }