mirror of
https://github.com/logos-messaging/logos-messaging-go.git
synced 2026-01-11 10:23:08 +00:00
feat: add dns-discovery flags to wakunode and chat2 example
This commit is contained in:
parent
70efcd72f3
commit
ebcbff62eb
@ -176,6 +176,25 @@ func main() {
|
||||
}
|
||||
}
|
||||
|
||||
enableDiscovery := *dnsDiscoveryFlag
|
||||
dnsDiscoveryUrl := *dnsDiscoveryUrlFlag
|
||||
dnsDiscoveryNameServer := *dnsDiscoveryNameServerFlag
|
||||
|
||||
if enableDiscovery && dnsDiscoveryUrl != "" {
|
||||
ui.displayMessage(fmt.Sprintf("attempting DNS discovery with %s", dnsDiscoveryUrl))
|
||||
multiaddresses, err := discovery.RetrieveNodes(ctx, dnsDiscoveryUrl, discovery.WithNameserver(dnsDiscoveryNameServer))
|
||||
if err != nil {
|
||||
ui.displayMessage("DNS discovery error: " + err.Error())
|
||||
} else {
|
||||
for _, m := range multiaddresses {
|
||||
err = wakuNode.DialPeerWithMultiAddress(m)
|
||||
if err != nil {
|
||||
ui.displayMessage("error dialing peer: " + err.Error())
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if len(storenode) == 0 {
|
||||
ui.displayMessage(fmt.Sprintf("No store node configured. Choosing one at random from %s fleet...", *fleetFlag))
|
||||
storenode = getRandomFleetNode(fleetData, *fleetFlag)
|
||||
|
||||
@ -100,6 +100,9 @@ var rootCmd = &cobra.Command{
|
||||
prvKey, err := crypto.HexToECDSA(key)
|
||||
checkError(err, "error converting key into valid ecdsa key")
|
||||
|
||||
// TODO: this ENR record might be necessary later for DNS discovery
|
||||
// enr := enode.NewV4(&prvKey.PublicKey, hostAddr.IP, hostAddr.Port, 0)
|
||||
|
||||
if dbPath == "" && useDB {
|
||||
checkError(errors.New("dbpath can't be null"), "")
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user