Mirrors/yggmail
1
0
Fork 0
mirror of https://github.com/neilalexander/yggmail.git synced 2026-05-08 12:56:27 +03:00
Code Issues Packages Projects Releases Wiki Activity

User-facing command lines

Browse Source
This commit is contained in:
Neil Alexander
2021-07-09 18:42:52 +01:00
parent eb8b2d5822
commit 4b2f955f69
3 changed files with 35 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
internal/transport/yggdrasil.go
View File

@@ -19,7 +19,7 @@ type YggdrasilTransport struct {
Sessions *utp.Socket
}
func NewYggdrasilTransport(log *log.Logger, sk ed25519.PrivateKey, pk ed25519.PublicKey, peer string) (*YggdrasilTransport, error) {
func NewYggdrasilTransport(log *log.Logger, sk ed25519.PrivateKey, pk ed25519.PublicKey, peer string, mcast bool) (*YggdrasilTransport, error) {
config := &config.NodeConfig{
PublicKey: hex.EncodeToString(pk),
PrivateKey: hex.EncodeToString(sk),
@@ -33,6 +33,7 @@ func NewYggdrasilTransport(log *log.Logger, sk ed25519.PrivateKey, pk ed25519.Pu
NodeInfo: map[string]interface{}{
"name": "Yggmail",
},
NodeInfoPrivacy: true,
}
if peer != "" {
config.Peers = append(config.Peers, peer)
@@ -45,12 +46,14 @@ func NewYggdrasilTransport(log *log.Logger, sk ed25519.PrivateKey, pk ed25519.Pu
if err := core.Start(config, glog); err != nil {
return nil, fmt.Errorf("core.Start: %w", err)
}
multicast := &multicast.Multicast{}
if err := multicast.Init(core, config, glog, nil); err != nil {
return nil, fmt.Errorf("multicast.Init: %w", err)
}
if err := multicast.Start(); err != nil {
return nil, fmt.Errorf("multicast.Start: %w", err)
if mcast {
multicast := &multicast.Multicast{}
if err := multicast.Init(core, config, glog, nil); err != nil {
return nil, fmt.Errorf("multicast.Init: %w", err)
}
if err := multicast.Start(); err != nil {
return nil, fmt.Errorf("multicast.Start: %w", err)
}
}
us, err := utp.NewSocketFromPacketConnNoClose(core)
if err != nil {