Method shimQueryBlocks

erpc/query_shim.go:17–52

(ctx context.Context, req *evm.QueryBlocksRequest, fromBlock, toBlock uint64, onPage func(proto.Message) error)

)

func (qe *EvmQueryExecutor) shimQueryBlocks(ctx context.Context, req *evm.QueryBlocksRequest, fromBlock, toBlock uint64, onPage func(proto.Message) error) error {
	_, shimSpan := common.StartDetailSpan(ctx, "Query.ShimBlocks")
	defer shimSpan.End()

	order := req.GetOrder()
	limit := queryLimit(req.GetLimit())
	qe.logger.Debug().Uint64("fromBlock", fromBlock).Uint64("toBlock", toBlock).Uint32("limit", limit).Msgf("starting shimQueryBlocks")

	blocks := make([]*evm.BlockHeader, 0, limit)
	var last *evm.BlockHeader
	var cursor *evm.CursorBlock
	iter := newBlockIterator(fromBlock, toBlock, order)
	for iter.Next() {
		header, _, err := qe.fetchBlockViaForward(ctx, iter.Value(), false)
		if err != nil {
			return err
		}
		if header == nil {
			continue
		}
		last = header
		blocks = append(blocks, projectBlockForResponse(header, req.BlockFields))
		if len(blocks) >= int(limit) {
			if iter.HasMore() {
				cursor = cursorFromBlock(last)
			}
			break
		}
	}
	return onPage(&evm.QueryBlocksResponse{
		Blocks:      blocks,
		FromBlock:   cursorFromNumber(fromBlock),
		ToBlock:     cursorFromNumber(toBlock),
		CursorBlock: cursor,
	})
}

func (qe *EvmQueryExecutor) shimQueryTransactions(ctx context.Context, req *evm.QueryTransactionsRequest, fromBlock, toBlock uint64, onPage func(proto.Message) error) error {
	_, shimSpan := common.StartDetailSpan(ctx, "Query.ShimTransactions")