forked from extern/smegmesh
89 lines
2.2 KiB
Go
89 lines
2.2 KiB
Go
package crdt
|
|
|
|
import (
|
|
"fmt"
|
|
"hash/fnv"
|
|
|
|
"github.com/tim-beatham/smegmesh/pkg/conf"
|
|
"github.com/tim-beatham/smegmesh/pkg/lib"
|
|
"github.com/tim-beatham/smegmesh/pkg/mesh"
|
|
)
|
|
|
|
// TwoPhaseMapFactory: instantiate a new twophasemap
|
|
// datastore
|
|
type TwoPhaseMapFactory struct {
|
|
Config *conf.DaemonConfiguration
|
|
}
|
|
|
|
// CreateMesh: create a new mesh network
|
|
func (f *TwoPhaseMapFactory) CreateMesh(params *mesh.MeshProviderFactoryParams) (mesh.MeshProvider, error) {
|
|
return &TwoPhaseStoreMeshManager{
|
|
MeshId: params.MeshId,
|
|
IfName: params.DevName,
|
|
Client: params.Client,
|
|
Conf: params.Conf,
|
|
DaemonConf: params.DaemonConf,
|
|
store: NewTwoPhaseMap[string, MeshNode](params.NodeID, func(s string) uint64 {
|
|
h := fnv.New64a()
|
|
h.Write([]byte(s))
|
|
return h.Sum64()
|
|
}, uint64(3*f.Config.Heartbeat)),
|
|
}, nil
|
|
}
|
|
|
|
// MeshNodeFactory: create a new node in the mesh network
|
|
type MeshNodeFactory struct {
|
|
Config conf.DaemonConfiguration
|
|
}
|
|
|
|
// Build: build a new mesh network
|
|
func (f *MeshNodeFactory) Build(params *mesh.MeshNodeFactoryParams) mesh.MeshNode {
|
|
hostName := f.getAddress(params)
|
|
|
|
grpcEndpoint := fmt.Sprintf("%s:%d", hostName, f.Config.GrpcPort)
|
|
wgEndpoint := fmt.Sprintf("%s:%d", hostName, params.WgPort)
|
|
|
|
if *params.MeshConfig.Role == conf.CLIENT_ROLE {
|
|
grpcEndpoint = "-"
|
|
wgEndpoint = "-"
|
|
}
|
|
|
|
return &MeshNode{
|
|
HostEndpoint: grpcEndpoint,
|
|
PublicKey: params.PublicKey.String(),
|
|
WgEndpoint: wgEndpoint,
|
|
WgHost: fmt.Sprintf("%s/128", params.NodeIP.String()),
|
|
Routes: make(map[string]Route),
|
|
Description: "",
|
|
Alias: "",
|
|
Type: string(*params.MeshConfig.Role),
|
|
}
|
|
}
|
|
|
|
// getAddress returns the routable address of the machine.
|
|
func (f *MeshNodeFactory) getAddress(params *mesh.MeshNodeFactoryParams) string {
|
|
var hostName string = ""
|
|
|
|
if params.Endpoint != "" {
|
|
hostName = params.Endpoint
|
|
} else if params.MeshConfig.Endpoint != nil && len(*params.MeshConfig.Endpoint) != 0 {
|
|
hostName = *params.MeshConfig.Endpoint
|
|
} else {
|
|
ipFunc := lib.GetPublicIP
|
|
|
|
if *params.MeshConfig.IPDiscovery == conf.OUTGOING_IP_DISCOVERY {
|
|
ipFunc = lib.GetOutboundIP
|
|
}
|
|
|
|
ip, err := ipFunc()
|
|
|
|
if err != nil {
|
|
return ""
|
|
}
|
|
|
|
hostName = ip.String()
|
|
}
|
|
|
|
return hostName
|
|
}
|