mirror of
https://github.com/tendermint/tendermint.git
synced 2026-01-07 05:46:32 +00:00
e198edf20e
The `NodeInfo` interface does not appear to serve any purpose at all, so I removed it and renamed the `DefaultNodeInfo` struct to `NodeInfo` (including the Protobuf representations). Let me know if this is actually needed for anything. Only the Protobuf rename is listed in the changelog, since we do not officially support API stability of the `p2p` package (according to `README.md`). The on-wire protocol remains compatible.
109 lines
3.1 KiB
Go
109 lines
3.1 KiB
Go
package core
|
|
|
|
import (
|
|
"errors"
|
|
"strings"
|
|
|
|
"github.com/tendermint/tendermint/p2p"
|
|
ctypes "github.com/tendermint/tendermint/rpc/core/types"
|
|
rpctypes "github.com/tendermint/tendermint/rpc/jsonrpc/types"
|
|
)
|
|
|
|
// NetInfo returns network info.
|
|
// More: https://docs.tendermint.com/master/rpc/#/Info/net_info
|
|
func NetInfo(ctx *rpctypes.Context) (*ctypes.ResultNetInfo, error) {
|
|
peersList := env.P2PPeers.Peers().List()
|
|
peers := make([]ctypes.Peer, 0, len(peersList))
|
|
for _, peer := range peersList {
|
|
peers = append(peers, ctypes.Peer{
|
|
NodeInfo: peer.NodeInfo(),
|
|
IsOutbound: peer.IsOutbound(),
|
|
ConnectionStatus: peer.Status(),
|
|
RemoteIP: peer.RemoteIP().String(),
|
|
})
|
|
}
|
|
// TODO: Should we include PersistentPeers and Seeds in here?
|
|
// PRO: useful info
|
|
// CON: privacy
|
|
return &ctypes.ResultNetInfo{
|
|
Listening: env.P2PTransport.IsListening(),
|
|
Listeners: env.P2PTransport.Listeners(),
|
|
NPeers: len(peers),
|
|
Peers: peers,
|
|
}, nil
|
|
}
|
|
|
|
// UnsafeDialSeeds dials the given seeds (comma-separated id@IP:PORT).
|
|
func UnsafeDialSeeds(ctx *rpctypes.Context, seeds []string) (*ctypes.ResultDialSeeds, error) {
|
|
if len(seeds) == 0 {
|
|
return &ctypes.ResultDialSeeds{}, errors.New("no seeds provided")
|
|
}
|
|
env.Logger.Info("DialSeeds", "seeds", seeds)
|
|
if err := env.P2PPeers.DialPeersAsync(seeds); err != nil {
|
|
return &ctypes.ResultDialSeeds{}, err
|
|
}
|
|
return &ctypes.ResultDialSeeds{Log: "Dialing seeds in progress. See /net_info for details"}, nil
|
|
}
|
|
|
|
// UnsafeDialPeers dials the given peers (comma-separated id@IP:PORT),
|
|
// optionally making them persistent.
|
|
func UnsafeDialPeers(ctx *rpctypes.Context, peers []string, persistent, unconditional, private bool) (
|
|
*ctypes.ResultDialPeers, error) {
|
|
if len(peers) == 0 {
|
|
return &ctypes.ResultDialPeers{}, errors.New("no peers provided")
|
|
}
|
|
|
|
ids, err := getIDs(peers)
|
|
if err != nil {
|
|
return &ctypes.ResultDialPeers{}, err
|
|
}
|
|
|
|
env.Logger.Info("DialPeers", "peers", peers, "persistent",
|
|
persistent, "unconditional", unconditional, "private", private)
|
|
|
|
if persistent {
|
|
if err := env.P2PPeers.AddPersistentPeers(peers); err != nil {
|
|
return &ctypes.ResultDialPeers{}, err
|
|
}
|
|
}
|
|
|
|
if private {
|
|
if err := env.P2PPeers.AddPrivatePeerIDs(ids); err != nil {
|
|
return &ctypes.ResultDialPeers{}, err
|
|
}
|
|
}
|
|
|
|
if unconditional {
|
|
if err := env.P2PPeers.AddUnconditionalPeerIDs(ids); err != nil {
|
|
return &ctypes.ResultDialPeers{}, err
|
|
}
|
|
}
|
|
|
|
if err := env.P2PPeers.DialPeersAsync(peers); err != nil {
|
|
return &ctypes.ResultDialPeers{}, err
|
|
}
|
|
|
|
return &ctypes.ResultDialPeers{Log: "Dialing peers in progress. See /net_info for details"}, nil
|
|
}
|
|
|
|
// Genesis returns genesis file.
|
|
// More: https://docs.tendermint.com/master/rpc/#/Info/genesis
|
|
func Genesis(ctx *rpctypes.Context) (*ctypes.ResultGenesis, error) {
|
|
return &ctypes.ResultGenesis{Genesis: env.GenDoc}, nil
|
|
}
|
|
|
|
func getIDs(peers []string) ([]string, error) {
|
|
ids := make([]string, 0, len(peers))
|
|
|
|
for _, peer := range peers {
|
|
|
|
spl := strings.Split(peer, "@")
|
|
if len(spl) != 2 {
|
|
return nil, p2p.ErrNetAddressNoID{Addr: peer}
|
|
}
|
|
ids = append(ids, spl[0])
|
|
|
|
}
|
|
return ids, nil
|
|
}
|