package node import ( "github.com/ethereum/go-ethereum/rpc" "github.com/harmony-one/harmony/core/types" "github.com/harmony-one/harmony/hmy" hmy_rpc "github.com/harmony-one/harmony/rpc" "github.com/harmony-one/harmony/rpc/filters" "github.com/libp2p/go-libp2p-core/peer" ) // IsCurrentlyLeader exposes if node is currently the leader node func (node *Node) IsCurrentlyLeader() bool { return node.Consensus.IsLeader() } // PeerConnectivity .. func (node *Node) PeerConnectivity() (int, int, int) { return node.host.C() } // ListPeer return list of peers for a certain topic func (node *Node) ListPeer(topic string) []peer.ID { return node.host.ListPeer(topic) } // ListTopic return list of topics the node subscribed func (node *Node) ListTopic() []string { return node.host.ListTopic() } // ListBlockedPeer return list of blocked peers func (node *Node) ListBlockedPeer() []peer.ID { return node.host.ListBlockedPeer() } // PendingCXReceipts returns node.pendingCXReceiptsProof func (node *Node) PendingCXReceipts() []*types.CXReceiptsProof { cxReceipts := make([]*types.CXReceiptsProof, len(node.pendingCXReceipts)) i := 0 for _, cxReceipt := range node.pendingCXReceipts { cxReceipts[i] = cxReceipt i++ } return cxReceipts } // ReportStakingErrorSink is the report of failed staking transactions this node has (held in memory only) func (node *Node) ReportStakingErrorSink() types.TransactionErrorReports { return node.TransactionErrorSink.StakingReport() } // GetNodeBootTime .. func (node *Node) GetNodeBootTime() int64 { return node.unixTimeAtNodeStart } // ReportPlainErrorSink is the report of failed transactions this node has (held in memory only) func (node *Node) ReportPlainErrorSink() types.TransactionErrorReports { return node.TransactionErrorSink.PlainReport() } // StartRPC start RPC service func (node *Node) StartRPC() error { harmony := hmy.New(node, node.TxPool, node.CxPool, node.Consensus.ShardID) // Gather all the possible APIs to surface apis := node.APIs(harmony) for _, service := range node.serviceManager.GetServices() { apis = append(apis, service.APIs()...) } return hmy_rpc.StartServers(harmony, apis, node.NodeConfig.RPCServer) } // StopRPC stop RPC service func (node *Node) StopRPC() error { return hmy_rpc.StopServers() } // APIs return the collection of local RPC services. // NOTE, some of these services probably need to be moved to somewhere else. func (node *Node) APIs(harmony *hmy.Harmony) []rpc.API { // Append all the local APIs and return return []rpc.API{ hmy_rpc.NewPublicNetAPI(node.host, harmony.ChainID, hmy_rpc.V1), hmy_rpc.NewPublicNetAPI(node.host, harmony.ChainID, hmy_rpc.V2), { Namespace: "hmy", Version: hmy_rpc.APIVersion, Service: filters.NewPublicFilterAPI(harmony, false), Public: true, }, } }