2021-02-09 11:53:33 +00:00
|
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
|
2021-01-25 15:35:22 +00:00
|
|
|
package roomsrv
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"net"
|
|
|
|
|
|
|
|
"go.cryptoscope.co/muxrpc/v2"
|
|
|
|
|
2021-02-09 16:38:51 +00:00
|
|
|
"github.com/ssb-ngi-pointer/go-ssb-room/internal/network"
|
2021-01-25 15:35:22 +00:00
|
|
|
)
|
|
|
|
|
2021-03-16 08:10:44 +00:00
|
|
|
// opens the shs listener for TCP connections
|
2021-01-25 15:35:22 +00:00
|
|
|
func (s *Server) initNetwork() error {
|
|
|
|
// muxrpc handler creation and authoratization decider
|
|
|
|
mkHandler := func(conn net.Conn) (muxrpc.Handler, error) {
|
|
|
|
s.closedMu.Lock()
|
|
|
|
defer s.closedMu.Unlock()
|
|
|
|
|
|
|
|
remote, err := network.GetFeedRefFromAddr(conn.RemoteAddr())
|
|
|
|
if err != nil {
|
|
|
|
return nil, fmt.Errorf("sbot: expected an address containing an shs-bs addr: %w", err)
|
|
|
|
}
|
2021-02-11 15:43:19 +00:00
|
|
|
|
2021-01-25 15:35:22 +00:00
|
|
|
if s.keyPair.Feed.Equal(remote) {
|
2021-03-11 17:40:33 +00:00
|
|
|
return &s.master, nil
|
2021-01-25 15:35:22 +00:00
|
|
|
}
|
|
|
|
|
2021-03-19 10:51:06 +00:00
|
|
|
if _, err := s.authorizer.GetByFeed(s.rootCtx, *remote); err == nil {
|
2021-03-11 17:40:33 +00:00
|
|
|
return &s.public, nil
|
2021-01-25 15:35:22 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return nil, fmt.Errorf("not authorized")
|
|
|
|
}
|
|
|
|
|
|
|
|
// tcp+shs
|
|
|
|
opts := network.Options{
|
|
|
|
Logger: s.logger,
|
|
|
|
Dialer: s.dialer,
|
|
|
|
ListenAddr: s.listenAddr,
|
|
|
|
KeyPair: s.keyPair,
|
|
|
|
AppKey: s.appKey[:],
|
|
|
|
MakeHandler: mkHandler,
|
|
|
|
ConnTracker: s.networkConnTracker,
|
|
|
|
BefreCryptoWrappers: s.preSecureWrappers,
|
|
|
|
AfterSecureWrappers: s.postSecureWrappers,
|
|
|
|
|
|
|
|
WebsocketAddr: s.wsAddr,
|
|
|
|
}
|
|
|
|
|
|
|
|
var err error
|
|
|
|
s.Network, err = network.New(opts)
|
|
|
|
if err != nil {
|
|
|
|
return fmt.Errorf("failed to create network node: %w", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|