aboutsummaryrefslogtreecommitdiff
path: root/hotline/server.go
diff options
context:
space:
mode:
authorJeff Halter <868228+jhalter@users.noreply.github.com>2022-06-07 16:03:25 -0700
committerJeff Halter <868228+jhalter@users.noreply.github.com>2022-06-07 16:03:25 -0700
commitaeec10158441af3cef925ca55e531a4d5517d5ec (patch)
tree8b95f1cdd61ffd4b1b9e97406da6bed6e24e74ae /hotline/server.go
parentfca1ebde1d6a552ce6e4e995fc12c73450af218b (diff)
Backfill tests and clean up
Diffstat (limited to 'hotline/server.go')
-rw-r--r--hotline/server.go21
1 files changed, 7 insertions, 14 deletions
diff --git a/hotline/server.go b/hotline/server.go
index d5da458..768433b 100644
--- a/hotline/server.go
+++ b/hotline/server.go
@@ -65,7 +65,12 @@ type PrivateChat struct {
}
func (s *Server) ListenAndServe(ctx context.Context, cancelRoot context.CancelFunc) error {
- s.Logger.Infow("Hotline server started", "version", VERSION)
+ s.Logger.Infow("Hotline server started",
+ "version", VERSION,
+ "API port", fmt.Sprintf(":%v", s.Port),
+ "Transfer port", fmt.Sprintf(":%v", s.Port+1),
+ )
+
var wg sync.WaitGroup
wg.Add(1)
@@ -79,13 +84,7 @@ func (s *Server) ListenAndServe(ctx context.Context, cancelRoot context.CancelFu
return nil
}
-func (s *Server) APIPort() int {
- return s.APIListener.Addr().(*net.TCPAddr).Port
-}
-
func (s *Server) ServeFileTransfers(ln net.Listener) error {
- s.Logger.Infow("Hotline file transfer server started", "Addr", fmt.Sprintf(":%v", s.Port+1))
-
for {
conn, err := ln.Accept()
if err != nil {
@@ -138,7 +137,6 @@ func (s *Server) sendTransaction(t Transaction) error {
}
func (s *Server) Serve(ctx context.Context, cancelRoot context.CancelFunc, ln net.Listener) error {
- s.Logger.Infow("Hotline server started", "Addr", fmt.Sprintf(":%v", s.Port))
for {
conn, err := ln.Accept()
@@ -195,11 +193,7 @@ func NewServer(configDir, netInterface string, netPort int, logger *zap.SugaredL
}
server.APIListener = ln
- if netPort != 0 {
- netPort += 1
- }
-
- ln2, err := net.Listen("tcp", fmt.Sprintf("%s:%v", netInterface, netPort))
+ ln2, err := net.Listen("tcp", fmt.Sprintf("%s:%v", netInterface, netPort+1))
server.FileListener = ln2
if err != nil {
return nil, err
@@ -210,7 +204,6 @@ func NewServer(configDir, netInterface string, netPort int, logger *zap.SugaredL
return nil, err
}
- server.Logger.Debugw("Loading Agreement", "path", configDir+agreementFile)
if server.Agreement, err = os.ReadFile(configDir + agreementFile); err != nil {
return nil, err
}