forked from iotaledger/goshimmer
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Feat/mana autopeering (iotaledger#1045)
* upgrade hive * Integrate mana with autopeering * adjust R parameter * Increase R parameter to 40 * Update hive.go * Fix import cycle * update hive * Expose ManaScaleFactor * Fix linter warnings * Address review * Address review comments * Change parameters definition * Fix typo
- Loading branch information
Showing
18 changed files
with
189 additions
and
130 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,101 @@ | ||
| package discovery | ||
|
|
||
| import ( | ||
| "errors" | ||
| "fmt" | ||
| "net" | ||
| "strings" | ||
| "sync" | ||
|
|
||
| "github.com/iotaledger/hive.go/autopeering/discover" | ||
| "github.com/iotaledger/hive.go/autopeering/peer" | ||
| "github.com/iotaledger/hive.go/autopeering/peer/service" | ||
| "github.com/iotaledger/hive.go/crypto/ed25519" | ||
| "github.com/iotaledger/hive.go/identity" | ||
| "github.com/iotaledger/hive.go/logger" | ||
| "github.com/mr-tron/base58" | ||
|
|
||
| "github.com/iotaledger/goshimmer/plugins/autopeering/local" | ||
| ) | ||
|
|
||
| // autopeering constants | ||
| const ( | ||
| ProtocolVersion = 0 // update on protocol changes | ||
|
|
||
| // PluginName is the name of the autopeering plugin. | ||
| PluginName = "Autopeering" | ||
|
|
||
| entryNodeParts = 2 | ||
| ) | ||
|
|
||
| var ( | ||
| // ErrParsingEntryNode is returned for an invalid entry node. | ||
| ErrParsingEntryNode = errors.New("cannot parse entry node") | ||
|
|
||
| // the peer discovery protocol | ||
| peerDisc *discover.Protocol | ||
| peerDiscOnce sync.Once | ||
|
|
||
| networkVersion uint32 | ||
| ) | ||
|
|
||
| // Discovery returns the peer discovery instance. | ||
| func Discovery() *discover.Protocol { | ||
| peerDiscOnce.Do(createPeerDisc) | ||
| return peerDisc | ||
| } | ||
|
|
||
| func createPeerDisc() { | ||
| // assure that the logger is available | ||
| log := logger.NewLogger(PluginName).Named("disc") | ||
|
|
||
| networkVersion = uint32(Parameters.NetworkVersion) | ||
|
|
||
| entryNodes, err := parseEntryNodes() | ||
| if err != nil { | ||
| log.Errorf("Invalid entry nodes; ignoring: %v", err) | ||
| } | ||
| log.Debugf("Entry nodes: %v", entryNodes) | ||
|
|
||
| peerDisc = discover.New(local.GetInstance(), ProtocolVersion, NetworkVersion(), | ||
| discover.Logger(log), | ||
| discover.MasterPeers(entryNodes), | ||
| ) | ||
| } | ||
|
|
||
| func parseEntryNodes() (result []*peer.Peer, err error) { | ||
| for _, entryNodeDefinition := range Parameters.EntryNodes { | ||
| if entryNodeDefinition == "" { | ||
| continue | ||
| } | ||
|
|
||
| parts := strings.Split(entryNodeDefinition, "@") | ||
| if len(parts) != entryNodeParts { | ||
| return nil, fmt.Errorf("%w: entry node information must contains %d parts, is %d", ErrParsingEntryNode, entryNodeParts, len(parts)) | ||
| } | ||
| pubKey, err := base58.Decode(parts[0]) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("%w: invalid public key: %s", ErrParsingEntryNode, err) | ||
| } | ||
| addr, err := net.ResolveUDPAddr("udp", parts[1]) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("%w: host cannot be resolved: %s", ErrParsingEntryNode, err) | ||
| } | ||
| publicKey, _, err := ed25519.PublicKeyFromBytes(pubKey) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| services := service.New() | ||
| services.Update(service.PeeringKey, addr.Network(), addr.Port) | ||
|
|
||
| result = append(result, peer.NewPeer(identity.New(publicKey), addr.IP, services)) | ||
| } | ||
|
|
||
| return result, nil | ||
| } | ||
|
|
||
| // NetworkVersion returns the network version of the autopeering. | ||
| func NetworkVersion() uint32 { | ||
| return networkVersion | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,16 @@ | ||
| package discovery | ||
|
|
||
| import "github.com/iotaledger/hive.go/configuration" | ||
|
|
||
| // Parameters contains the configuration parameters used by the message layer. | ||
| var Parameters = struct { | ||
| // NetworkVersion defines the config flag of the network version. | ||
| NetworkVersion int `default:"22" usage:"autopeering network version"` | ||
|
|
||
| // EntryNodes defines the config flag of the entry nodes. | ||
| EntryNodes []string `default:"[email protected]:15626,5EDH4uY78EA6wrBkHHAVBWBMDt7EcksRq6pjzipoW15B@entryshimmer.tanglebay.com:14646" usage:"list of trusted entry nodes for auto peering"` | ||
| }{} | ||
|
|
||
| func init() { | ||
| configuration.BindParameters(&Parameters, "autopeering") | ||
| } |
Oops, something went wrong.