fix(jsonrpc): impose the same listed items limit for all requests in a batch

Author: renatomaia

internal/jsonrpc/batchcalls_test.go

@@ -98,7 +98,7 @@ func TestJSONRPCBatchRejectsMoreThanMaximumBeforeDispatch(t *testing.T) {
 	s := newBatchTestService()
 	var calls atomic.Int32
 	const method = "test_batch_cap"
-	withTestRPCHandler(t, method, func(_ *Service, _ *http.Request, _ RPCRequest) (any, error) {
+	withTestRPCHandler(t, method, func(_ *Service, _ *uint64, _ *http.Request, _ RPCRequest) (any, error) {
 		calls.Add(1)
 		return true, nil
 	})
@@ -215,7 +215,7 @@ func TestJSONRPCBatchReplacesResponsesAtCumulativeResponseBudget(t *testing.T) {
 	var calls atomic.Int32
 	const method = "test_large_batch_result"
 	largeResult := strings.Repeat("x", testLargeResultSize)
-	withTestRPCHandler(t, method, func(_ *Service, _ *http.Request, _ RPCRequest) (any, error) {
+	withTestRPCHandler(t, method, func(_ *Service, _ *uint64, _ *http.Request, _ RPCRequest) (any, error) {
 		calls.Add(1)
 		return largeResult, nil
 	})
@@ -254,7 +254,7 @@ func TestJSONRPCBatchStopsBetweenEntriesWhenContextIsCanceled(t *testing.T) {
 	s.Logger = slog.New(slog.NewJSONHandler(&logs, &slog.HandlerOptions{Level: slog.LevelDebug}))
 	ctx, cancel := context.WithCancel(context.Background())
 	const method = "test_cancel_batch"
-	withTestRPCHandler(t, method, func(_ *Service, _ *http.Request, _ RPCRequest) (any, error) {
+	withTestRPCHandler(t, method, func(_ *Service, _ *uint64, _ *http.Request, _ RPCRequest) (any, error) {
 		calls.Add(1)
 		cancel()
 		return true, nil
@@ -287,7 +287,7 @@ func TestJSONRPCBatchReturnsErrorsForIDDRequestsAfterDeadline(t *testing.T) {
 	s := newBatchTestService()
 	var calls atomic.Int32
 	const method = "test_deadline_batch"
-	withTestRPCHandler(t, method, func(_ *Service, _ *http.Request, _ RPCRequest) (any, error) {
+	withTestRPCHandler(t, method, func(_ *Service, _ *uint64, _ *http.Request, _ RPCRequest) (any, error) {
 		calls.Add(1)
 		return true, nil
 	})
@@ -331,7 +331,7 @@ func TestJSONRPCBatchUsesOneAdmissionPermit(t *testing.T) {
 	}
 	var nestedAcquisitions atomic.Int32
 	const method = "test_batch_admission"
-	withTestRPCHandler(t, method, func(s *Service, _ *http.Request, _ RPCRequest) (any, error) {
+	withTestRPCHandler(t, method, func(s *Service, _ *uint64, _ *http.Request, _ RPCRequest) (any, error) {
 		if s.admission.TryAcquire() {
 			nestedAcquisitions.Add(1)
 			s.admission.Release()