Skip to content
This repository was archived by the owner on Mar 28, 2023. It is now read-only.

Commit f6cea9b

Browse files
committed
Updated comments
1 parent a447528 commit f6cea9b

File tree

3 files changed

+9
-1
lines changed

3 files changed

+9
-1
lines changed

core/net.go

+1
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ func (n *OpenBazaarNode) sendMessage(peerID string, k *libp2p.PubKey, message pb
5858
return nil
5959
}
6060

61+
// SendRelayedMessage - send message through web relay manager to recipient
6162
func (n *OpenBazaarNode) SendRelayedMessage(p peer.ID, k *libp2p.PubKey, m *pb.Message) error {
6263
messageBytes, err := n.getMessageBytes(m)
6364
if err != nil {

net/web_relay_manager.go

+7-1
Original file line numberDiff line numberDiff line change
@@ -17,38 +17,44 @@ import (
1717
"github.com/gorilla/websocket"
1818
)
1919

20+
// WebRelayManager - manages connections to web relay servers
2021
type WebRelayManager struct {
2122
webrelays []string
2223
peerID string
2324
connections []*websocket.Conn
2425
obService NetworkService
2526
}
2627

28+
// EncryptedMessage - message envelope for relay messages
2729
type EncryptedMessage struct {
2830
Message string `json:"encryptedMessage"`
2931
Recipient string `json:"recipient"`
3032
}
3133

34+
// TypedMessage - generic typed message for transport
3235
type TypedMessage struct {
3336
Type string
3437
Data json.RawMessage
3538
}
3639

40+
// SubscribeMessage - authentication message for web relay server
3741
type SubscribeMessage struct {
3842
UserID string `json:"userID"`
3943
SubscriptionKey string `json:"subscriptionKey"`
4044
}
4145

46+
// SubscribeResponse - for marshaling authN response from web relay server
4247
type SubscribeResponse struct {
4348
Subscribe string `json:"subscribe"`
4449
}
4550

51+
// NewWebRelayManager - creates a web relay manager to maintain connections
4652
func NewWebRelayManager(webrelays []string, sender string) *WebRelayManager {
4753
return &WebRelayManager{webrelays, sender, nil, nil}
4854
}
4955

56+
// ConnectToRelays - initiate websocket connections to the relay servers configured
5057
func (wrm *WebRelayManager) ConnectToRelays(service NetworkService) {
51-
5258
// Set WRM service
5359
wrm.obService = service
5460

schema/configuration.go

+1
Original file line numberDiff line numberDiff line change
@@ -415,6 +415,7 @@ func GetRepublishInterval(cfgBytes []byte) (time.Duration, error) {
415415
return d, nil
416416
}
417417

418+
// GetWebRelays - retrieves web relay server addresses from config file
418419
func GetWebRelays(cfgBytes []byte) ([]string, error) {
419420
var cfgIface interface{}
420421
err := json.Unmarshal(cfgBytes, &cfgIface)

0 commit comments

Comments
 (0)