interface.go

package p2p

import (
	"fmt"

	"github.com/libsv/go-p2p/chaincfg/chainhash"
	"github.com/libsv/go-p2p/wire"
)

var ErrPeerNetworkMismatch = fmt.Errorf("peer network mismatch")

type PeerManagerI interface {
	AnnounceTransaction(txHash *chainhash.Hash, peers []PeerI) []PeerI
	RequestTransaction(txHash *chainhash.Hash) PeerI
	AnnounceBlock(blockHash *chainhash.Hash, peers []PeerI) []PeerI
	RequestBlock(blockHash *chainhash.Hash) PeerI
	AddPeer(peer PeerI) error
	GetPeers() []PeerI
	Shutdown()
}

type PeerI interface {
	Connected() bool
	WriteMsg(msg wire.Message) error
	String() string
	AnnounceTransaction(txHash *chainhash.Hash)
	RequestTransaction(txHash *chainhash.Hash)
	AnnounceBlock(blockHash *chainhash.Hash)
	RequestBlock(blockHash *chainhash.Hash)
	Network() wire.BitcoinNet
	IsHealthy() bool
	IsUnhealthyCh() <-chan struct{}
	Shutdown()
	Restart()
}

type PeerHandlerI interface {
	HandleTransactionsGet(msgs []*wire.InvVect, peer PeerI) ([][]byte, error)
	HandleTransactionSent(msg *wire.MsgTx, peer PeerI) error
	HandleTransactionAnnouncement(msg *wire.InvVect, peer PeerI) error
	HandleTransactionRejection(rejMsg *wire.MsgReject, peer PeerI) error
	HandleTransaction(msg *wire.MsgTx, peer PeerI) error
	HandleBlockAnnouncement(msg *wire.InvVect, peer PeerI) error
	HandleBlock(msg wire.Message, peer PeerI) error
	HandleHeaders(msg *wire.MsgHeaders, peer PeerI) error
	HandleVersion(msg *wire.MsgVersion, peer PeerI) error
	HandleAddresses(msg *wire.MsgAddr, peer PeerI) error
}