network

type AttestationsReceivedEvent struct {
	Commitment   *commitment.Commitment
	BlockIDs     models.BlockIDs
	Attestations *orderedmap.OrderedMap[slot.Index, *advancedset.AdvancedSet[*notarization.Attestation]]
	Source       identity.ID
}

type AttestationsRequestReceivedEvent struct {
	Commitment *commitment.Commitment
	EndIndex   slot.Index
	Source     identity.ID
}

type BlockReceivedEvent struct {
	Block  *models.Block
	Source identity.ID
}

type BlockRequestReceivedEvent struct {
	BlockID models.BlockID
	Source  identity.ID
}

type Endpoint interface {
	RegisterProtocol(protocolID string, newMessage func() proto.Message, handler func(identity.ID, proto.Message) error)

	UnregisterProtocol(protocolID string)

	Send(packet proto.Message, protocolID string, to ...identity.ID)
}

type ErrorEvent struct {
	Error  error
	Source identity.ID
}

type Events struct {
	BlockReceived                 *event.Event1[*BlockReceivedEvent]
	BlockRequestReceived          *event.Event1[*BlockRequestReceivedEvent]
	SlotCommitmentReceived        *event.Event1[*SlotCommitmentReceivedEvent]
	SlotCommitmentRequestReceived *event.Event1[*SlotCommitmentRequestReceivedEvent]
	AttestationsReceived          *event.Event1[*AttestationsReceivedEvent]
	AttestationsRequestReceived   *event.Event1[*AttestationsRequestReceivedEvent]
	Error                         *event.Event1[*ErrorEvent]

	event.Group[Events, *Events]
}

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

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

type Protocol struct {
	Events *Events
	// contains filtered or unexported fields
}

type SlotCommitmentReceivedEvent struct {
	Commitment *commitment.Commitment
	Source     identity.ID
}

type SlotCommitmentRequestReceivedEvent struct {
	CommitmentID commitment.ID
	Source       identity.ID
}