pickup

type MessageRetrievalComms interface {
	GetHost(hostId *id.ID) (*connect.Host, bool)
	RequestMessages(host *connect.Host, message *pb.GetMessages) (
		*pb.GetMessagesResponse, error)
	RequestBatchMessages(host *connect.Host,
		message *pb.GetMessagesBatch) (*pb.GetMessagesResponseBatch, error)
}

type Params struct {
	// Number of worker threads for retrieving messages from gateways
	NumMessageRetrievalWorkers uint

	// Length of round lookup channel buffer
	LookupRoundsBufferLen uint

	// Maximum number of times a historical round lookup will be attempted
	MaxHistoricalRoundsRetries uint

	// Interval between checking for rounds in UncheckedRoundStore due for a
	// message retrieval retry
	UncheckRoundPeriod time.Duration

	// Toggles if message pickup retrying mechanism if forced
	// by intentionally not looking up messages
	ForceMessagePickupRetry bool

	// Duration to wait before sending on a round times out and a new round is
	// tried
	SendTimeout time.Duration

	// Toggles if historical rounds should always be used
	ForceHistoricalRounds bool

	BatchMessageRetrieval bool
	MaxBatchSize          int
	BatchDelay            int
	BatchPickupTimeout    int
}

type Pickup interface {
	StartProcessors() stoppable.Stoppable
	GetMessagesFromRound(roundID id.Round, identity receptionID.EphemeralIdentity)
}

type RoundGetter interface {
	GetRound(id id.Round) (*pb.RoundInfo, error)
}