Method queryTransfers

erpc/query_executor.go:176–207

(ctx context.Context, req *evm.QueryTransfersRequest, onPage func(proto.Message) error)

}

func (qe *EvmQueryExecutor) queryTransfers(ctx context.Context, req *evm.QueryTransfersRequest, onPage func(proto.Message) error) error {
	ctx, span := common.StartDetailSpan(ctx, "Query.Execute",
		trace.WithAttributes(attribute.String("query.method", "eth_queryTransfers")),
	)
	defer span.End()

	fromBlock, toBlock, err := qe.resolveQueryBounds(ctx, req.GetFromBlock(), req.GetToBlock(), req.GetOrder(), req.GetCursor())
	if err != nil {
		common.SetTraceSpanError(span, err)
		return err
	}

	span.SetAttributes(
		attribute.Int64("query.fromBlock", int64(fromBlock)),
		attribute.Int64("query.toBlock", int64(toBlock)),
	)
	qe.logger.Debug().Uint64("fromBlock", fromBlock).Uint64("toBlock", toBlock).Msgf("resolved query bounds for eth_queryTransfers")

	handled, err := qe.tryQueryUpstreams(ctx, "eth_queryTransfers", func(ups common.Upstream) error {
		return qe.pipeThroughQueryTransfers(ctx, ups, req, onPage)
	})
	if handled {
		if err != nil {
			common.SetTraceSpanError(span, err)
		}
		return err
	}

	qe.logger.Debug().Msgf("no native upstream available, using shim for eth_queryTransfers")
	span.SetAttributes(attribute.String("query.path", "shim"))
	return qe.shimQueryTransfers(ctx, req, fromBlock, toBlock, onPage)
}

func (qe *EvmQueryExecutor) tryQueryUpstreams(
	ctx context.Context,