status-im
/
go-nwaku
mirror of https://github.com/status-im/go-nwaku.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Disable fleet checks 

Context timeouts, not directly used right now
This commit is contained in:
Oskar Thoren 2021-06-10 20:35:00 +08:00
parent a4ee858607
commit eb5a9d62d2
No known key found for this signature in database
GPG Key ID: B2ECCFD3BC2EF77E
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/chat2/main.go
View File

@ -114,14 +114,16 @@ func main() {
staticnode := *staticNodeFlag staticnode := *staticNodeFlag
storenode := *storeNodeFlag storenode := *storeNodeFlag
var fleetData []byte //var fleetData []byte
if len(staticnode) == 0 || len(storenode) == 0 { if len(staticnode) == 0 || len(storenode) == 0 {
fleetData = getFleetData() // XXX Context timeouts
//fleetData = getFleetData()
} }
if len(staticnode) == 0 { if len(staticnode) == 0 {
ui.displayMessage(fmt.Sprintf("No static peers configured. Choosing one at random from %s fleet...", *fleetFlag)) ui.displayMessage(fmt.Sprintf("No static peers configured. Choosing one at random from %s fleet...", *fleetFlag))
staticnode = getRandomFleetNode(fleetData, *fleetFlag) // XXX Disable for now
//staticnode = getRandomFleetNode(fleetData, *fleetFlag)
} }
// TODO Call with JSON RPC // TODO Call with JSON RPC

6
go-waku/examples/chat2/main.go
View File

@ -104,7 +104,8 @@ func main() {
if len(staticnode) == 0 { if len(staticnode) == 0 {
ui.displayMessage(fmt.Sprintf("No static peers configured. Choosing one at random from %s fleet...", *fleetFlag)) ui.displayMessage(fmt.Sprintf("No static peers configured. Choosing one at random from %s fleet...", *fleetFlag))
staticnode = getRandomFleetNode(fleetData, *fleetFlag) // XXX Do via RPC
//staticnode = getRandomFleetNode(fleetData, *fleetFlag)
} }
err = wakuNode.DialPeer(staticnode) err = wakuNode.DialPeer(staticnode)
@ -118,7 +119,8 @@ func main() {
if len(storenode) == 0 { if len(storenode) == 0 {
ui.displayMessage(fmt.Sprintf("No store node configured. Choosing one at random from %s fleet...", *fleetFlag)) ui.displayMessage(fmt.Sprintf("No store node configured. Choosing one at random from %s fleet...", *fleetFlag))
storenode = getRandomFleetNode(fleetData, *fleetFlag) // XXX Do via RPC
// storenode = getRandomFleetNode(fleetData, *fleetFlag)
} }
storeNodeId, err := wakuNode.AddStorePeer(storenode) storeNodeId, err := wakuNode.AddStorePeer(storenode)