p2p

type AuthToken struct {
	PeerId    crypto.Hash
	Timestamp uint64
	IsRelayer bool
	Data      []byte
}

type ChanMsg struct {
	// contains filtered or unexported fields
}

type Client interface {
	RemoteAddr() net.Addr
	Receive() (*TransportMessage, error)
	Send([]byte) error
	Close(string)
}

type MetricPool struct {
	PeerMessageTypePing               uint32 `json:"ping"`
	PeerMessageTypeAuthentication     uint32 `json:"authentication"`
	PeerMessageTypeGraph              uint32 `json:"graph"`
	PeerMessageTypeSnapshotConfirm    uint32 `json:"snapshot-confirm"`
	PeerMessageTypeTransactionRequest uint32 `json:"transaction-request"`
	PeerMessageTypeTransaction        uint32 `json:"transaction"`

	PeerMessageTypeSnapshotAnnouncement uint32 `json:"snapshot-announcement"`
	PeerMessageTypeSnapshotCommitment   uint32 `json:"snapshot-commitment"`
	PeerMessageTypeTransactionChallenge uint32 `json:"transaciton-challenge"`
	PeerMessageTypeSnapshotResponse     uint32 `json:"snapshot-response"`
	PeerMessageTypeSnapshotFinalization uint32 `json:"snapshot-finalization"`
	PeerMessageTypePreCommitments       uint32 `json:"commitments"`
	PeerMessageTypeFullChallenge        uint32 `json:"full-challenge"`
	PeerMessageTypeTransactionBundle    uint32 `json:"transaction-bundle"`

	PeerMessageTypeBatchSnapshotAnnouncement uint32 `json:"batch-snapshot-announcement"`
	PeerMessageTypeBatchSnapshotCommitment   uint32 `json:"batch-snapshot-commitment"`
	PeerMessageTypeBatchTransactionChallenge uint32 `json:"batch-transaction-challenge"`
	PeerMessageTypeBatchFullChallenge        uint32 `json:"batch-full-challenge"`
	PeerMessageTypeBatchSnapshotFinalization uint32 `json:"batch-snapshot-finalization"`

	PeerMessageTypeRelay uint32 `json:"relay"`
	// contains filtered or unexported fields
}

type Peer struct {
	IdForNetwork crypto.Hash
	Address      string
	// contains filtered or unexported fields
}

type PeerMessage struct {
	Type            uint8
	Snapshot        *common.Snapshot
	SnapshotHash    crypto.Hash
	Transactions    []*common.VersionedTransaction
	TransactionHash crypto.Hash
	Cosi            crypto.CosiSignature
	Commitment      crypto.Key
	Challenge       crypto.Key
	Response        [32]byte
	WantTxs         []crypto.Hash
	Commitments     []*crypto.Key
	Graph           []*SyncPoint
	Data            []byte
	// contains filtered or unexported fields
}

type QuicClient struct {
	// contains filtered or unexported fields
}

type QuicRelayer struct {
	// contains filtered or unexported fields
}

type SyncHandle interface {
	GetCacheStore() *ristretto.Cache[[]byte, any]
	SignData(data []byte) crypto.Signature
	BuildAuthenticationMessage(relayerId crypto.Hash) []byte
	AuthenticateAs(recipientId crypto.Hash, msg []byte, timeoutSec int64) (*AuthToken, error)
	BuildGraph() []*SyncPoint
	UpdateSyncPoint(peerId crypto.Hash, points []*SyncPoint, data []byte, sig *crypto.Signature) error
	ReadAllNodesWithoutState() []crypto.Hash
	ReadSnapshotsSinceTopology(offset, count uint64) ([]*common.SnapshotWithTopologicalOrder, error)
	ReadSnapshotsForNodeRound(nodeIdWithNetwork crypto.Hash, round uint64) ([]*common.SnapshotWithTopologicalOrder, error)
	SendTransactionToPeer(peerId, tx crypto.Hash) error
	CachePutTransaction(peerId crypto.Hash, ver *common.VersionedTransaction) error
	CosiQueueExternalAnnouncement(peerId crypto.Hash, s *common.Snapshot, R *crypto.Key, sig *crypto.Signature) error
	CosiAggregateSelfCommitments(peerId crypto.Hash, snap crypto.Hash, commitment *crypto.Key, wantTxs []crypto.Hash, data []byte, sig *crypto.Signature) error
	CosiQueueExternalChallenge(peerId crypto.Hash, snap crypto.Hash, cosi *crypto.CosiSignature, txs []*common.VersionedTransaction) error
	CosiQueueExternalFullChallenge(peerId crypto.Hash, s *common.Snapshot, commitment, challenge *crypto.Key, cosi *crypto.CosiSignature, txs []*common.VersionedTransaction) error
	CosiAggregateSelfResponses(peerId crypto.Hash, snap crypto.Hash, response *[32]byte) error
	VerifyAndQueueAppendSnapshotFinalization(peerId crypto.Hash, s *common.Snapshot) error
	CosiQueueExternalPreCommitments(peerId crypto.Hash, commitments []*crypto.Key, data []byte, sig *crypto.Signature) error
}

type SyncPoint struct {
	NodeId crypto.Hash `json:"node"`
	Number uint64      `json:"round"`
	Hash   crypto.Hash `json:"hash"`
	Pool   any         `json:"pool"`
}

type Transport interface {
	Listen() error
	Dial(ctx context.Context) (Client, error)
	Accept(ctx context.Context) (Client, error)
	Close() error
}

type TransportMessage struct {
	Version uint8
	Size    uint32
	Data    []byte
}