kaspad/network/rpc/handle_disconnect.go
stasatdaglabs 8a4ece1101
[NOD-1223] Reorganize project (#868)
* [NOD-1223] Move all network stuff into a new network package.

* [NOD-1223] Delete the unused package testutil.

* [NOD-1223] Move infrastructure stuff into a new instrastructure package.

* [NOD-1223] Move domain stuff into a new domain package.
2020-08-13 17:27:25 +03:00

23 lines
567 B
Go

package rpc
import (
"github.com/kaspanet/kaspad/network/rpc/model"
"github.com/kaspanet/kaspad/util/network"
)
// handleDisconnect handles disconnect commands.
func handleDisconnect(s *Server, cmd interface{}, closeChan <-chan struct{}) (interface{}, error) {
c := cmd.(*model.DisconnectCmd)
address, err := network.NormalizeAddress(c.Address, s.dag.Params.DefaultPort)
if err != nil {
return nil, &model.RPCError{
Code: model.ErrRPCInvalidParameter,
Message: err.Error(),
}
}
s.connectionManager.RemoveConnection(address)
return nil, nil
}