109 lines
2.3 KiB
Go
109 lines
2.3 KiB
Go
package protocols
|
|
|
|
import (
|
|
"crypto/ed25519"
|
|
"fmt"
|
|
s5config "git.lumeweb.com/LumeWeb/libs5-go/config"
|
|
s5ed "git.lumeweb.com/LumeWeb/libs5-go/ed25519"
|
|
s5interfaces "git.lumeweb.com/LumeWeb/libs5-go/interfaces"
|
|
s5node "git.lumeweb.com/LumeWeb/libs5-go/node"
|
|
"git.lumeweb.com/LumeWeb/portal/interfaces"
|
|
"git.lumeweb.com/LumeWeb/portal/protocols/s5"
|
|
bolt "go.etcd.io/bbolt"
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
var (
|
|
_ interfaces.Protocol = (*S5Protocol)(nil)
|
|
)
|
|
|
|
type S5Protocol struct {
|
|
node s5interfaces.Node
|
|
portal interfaces.Portal
|
|
}
|
|
|
|
func NewS5Protocol() *S5Protocol {
|
|
return &S5Protocol{}
|
|
}
|
|
|
|
func (s *S5Protocol) Initialize(portal interfaces.Portal) error {
|
|
s.portal = portal
|
|
|
|
logger := portal.Logger()
|
|
config := portal.Config()
|
|
|
|
cfg := &s5config.NodeConfig{
|
|
P2P: s5config.P2PConfig{
|
|
Network: "",
|
|
Peers: s5config.PeersConfig{Initial: []string{}},
|
|
},
|
|
KeyPair: s5ed.New(portal.Identity()),
|
|
DB: nil,
|
|
Logger: portal.Logger().Named("s5"),
|
|
HTTP: s5config.HTTPConfig{},
|
|
}
|
|
|
|
pconfig := config.Sub("protocol.s5")
|
|
|
|
if pconfig == nil {
|
|
logger.Fatal("Missing protocol.s5 config")
|
|
}
|
|
|
|
err := pconfig.Unmarshal(cfg)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
cfg.HTTP.API.Domain = fmt.Sprintf("s5.%s", config.GetString("core.domain"))
|
|
|
|
if config.IsSet("core.externalPort") {
|
|
cfg.HTTP.API.Port = config.GetUint("core.externalPort")
|
|
} else {
|
|
cfg.HTTP.API.Port = config.GetUint("core.port")
|
|
}
|
|
|
|
dbPath := pconfig.GetString("dbPath")
|
|
|
|
if dbPath == "" {
|
|
logger.Fatal("protocol.s5.dbPath is required")
|
|
}
|
|
|
|
_, p, err := ed25519.GenerateKey(nil)
|
|
if err != nil {
|
|
logger.Fatal("Failed to generate key", zap.Error(err))
|
|
}
|
|
|
|
cfg.KeyPair = s5ed.New(p)
|
|
|
|
db, err := bolt.Open(dbPath, 0600, nil)
|
|
if err != nil {
|
|
logger.Fatal("Failed to open db", zap.Error(err))
|
|
}
|
|
|
|
cfg.DB = db
|
|
|
|
s.node = s5node.NewNode(cfg)
|
|
s.node.Services().HTTP().SetHttpHandler(s5.NewHttpHandler(s.portal))
|
|
|
|
return nil
|
|
}
|
|
func (s *S5Protocol) Start() error {
|
|
err := s.node.Start()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
identity, err := s.node.Services().P2P().NodeId().ToString()
|
|
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
s.portal.Logger().Info("S5 protocol started", zap.String("identity", identity), zap.String("network", s.node.NetworkId()), zap.String("domain", s.node.Config().HTTP.API.Domain))
|
|
|
|
return nil
|
|
}
|
|
func (s *S5Protocol) Node() s5interfaces.Node {
|
|
return s.node
|
|
}
|