remove unnecessary port parameter

This commit is contained in:
alan 2025-01-07 21:35:21 +08:00
parent 5065e6c935
commit 80d3dad39c

View file

@ -395,7 +395,8 @@ func (n *Node) startRPC() error {
batchResponseSizeLimit: n.config.BatchResponseMaxSize, batchResponseSizeLimit: n.config.BatchResponseMaxSize,
} }
initHttp := func(server *httpServer, port int) error { initHttp := func(server *httpServer) error {
port := n.config.HTTPPort
if err := server.setListenAddr(n.config.HTTPHost, port); err != nil { if err := server.setListenAddr(n.config.HTTPHost, port); err != nil {
return err return err
} }
@ -412,7 +413,8 @@ func (n *Node) startRPC() error {
return nil return nil
} }
initWS := func(port int) error { initWS := func() error {
port := n.config.WSPort
server := n.wsServerForPort(port, false) server := n.wsServerForPort(port, false)
if err := server.setListenAddr(n.config.WSHost, port); err != nil { if err := server.setListenAddr(n.config.WSHost, port); err != nil {
return err return err
@ -429,7 +431,8 @@ func (n *Node) startRPC() error {
return nil return nil
} }
initAuth := func(port int, secret []byte) error { initAuth := func(secret []byte) error {
port := n.config.AuthPort
// Enable auth via HTTP // Enable auth via HTTP
server := n.httpAuth server := n.httpAuth
if err := server.setListenAddr(n.config.AuthAddr, port); err != nil { if err := server.setListenAddr(n.config.AuthAddr, port); err != nil {
@ -473,14 +476,14 @@ func (n *Node) startRPC() error {
// Set up HTTP. // Set up HTTP.
if n.config.HTTPHost != "" { if n.config.HTTPHost != "" {
// Configure legacy unauthenticated HTTP. // Configure legacy unauthenticated HTTP.
if err := initHttp(n.http, n.config.HTTPPort); err != nil { if err := initHttp(n.http); err != nil {
return err return err
} }
} }
// Configure WebSocket. // Configure WebSocket.
if n.config.WSHost != "" { if n.config.WSHost != "" {
// legacy unauthenticated // legacy unauthenticated
if err := initWS(n.config.WSPort); err != nil { if err := initWS(); err != nil {
return err return err
} }
} }
@ -490,7 +493,7 @@ func (n *Node) startRPC() error {
if err != nil { if err != nil {
return err return err
} }
if err := initAuth(n.config.AuthPort, jwtSecret); err != nil { if err := initAuth(jwtSecret); err != nil {
return err return err
} }
} }