Fix rpc pending blocks (#981)

Remove pending block from validation. Check for nilpointer

executor/extension/statedb/temporary_archive_prepper.go

@@ -19,7 +19,7 @@ type temporaryArchivePrepper struct {
 
 // PreTransaction creates temporary archive that is released after transaction is executed.
 func (r *temporaryArchivePrepper) PreTransaction(state executor.State[*rpc.RequestAndResults], ctx *executor.Context) error {
-	block := findBlockNumber(state.Data) // save the block for progress tracker
+	block := findBlockNumber(state.Data)
 
 	var err error
 	ctx.Archive, err = ctx.State.GetArchiveState(block)
@@ -54,6 +54,8 @@ func findBlockNumber(data *rpc.RequestAndResults) uint64 {
 
 	switch str {
 	case "pending":
+		// validation for pending requests does not work, skip them
+		data.SkipValidation = true
 		// pending should be treated as latest
 		fallthrough
 	case "latest":

executor/extension/statedb/temporary_archive_prepper_test.go

@@ -0,0 +1,43 @@
+package statedb
+
+import (
+	"encoding/json"
+	"testing"
+
+	"github.com/Fantom-foundation/Aida/executor"
+	"github.com/Fantom-foundation/Aida/rpc"
+	"github.com/Fantom-foundation/Aida/state"
+	"go.uber.org/mock/gomock"
+)
+
+func TestTemporaryArchivePrepper_PreTransactionMarksPendingBlockAsSkipValidation(t *testing.T) {
+	ctrl := gomock.NewController(t)
+	db := state.NewMockStateDB(ctrl)
+	ext := MakeTemporaryArchivePrepper()
+
+	db.EXPECT().GetArchiveState(uint64(10)).Return(nil, nil)
+
+	st := executor.State[*rpc.RequestAndResults]{Block: 10, Transaction: 0, Data: data}
+	ctx := &executor.Context{State: db}
+	err := ext.PreTransaction(st, ctx)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if !data.SkipValidation {
+		t.Fatal("SkipValidation must be true")
+	}
+}
+
+var data = &rpc.RequestAndResults{
+	Query: &rpc.Body{
+		Params: []interface{}{"test", "pending"},
+	},
+	Response: &rpc.Response{
+		Version:   "2.0",
+		ID:        json.RawMessage{1},
+		BlockID:   10,
+		Timestamp: 10,
+	},
+	SkipValidation: false,
+}

executor/extension/validator/rpc_comparator.go

@@ -95,6 +95,11 @@ type rpcComparator struct {
 func (c *rpcComparator) PostTransaction(state executor.State[*rpc.RequestAndResults], ctx *executor.Context) error {
 	c.totalNumberOfRequests++
 
+	// pending block numbers are not validatable
+	if state.Data.SkipValidation || state.Data.StateDB == nil {
+		return nil
+	}
+
 	compareErr := compare(state)
 	if compareErr != nil {
 		// lot errors are recorded wrongly, for this case we resend the request and compare it again

rpc/request.go

@@ -4,12 +4,13 @@ import "encoding/json"
 
 // RequestAndResults encapsulates request query and response for post-processing.
 type RequestAndResults struct {
-	Query       *Body
-	Response    *Response
-	Error       *ErrorResponse
-	ParamsRaw   []byte
-	ResponseRaw []byte
-	StateDB     *StateDBData
+	Query          *Body
+	Response       *Response
+	Error          *ErrorResponse
+	ParamsRaw      []byte
+	ResponseRaw    []byte
+	StateDB        *StateDBData
+	SkipValidation bool
 }
 
 // Body represents a decoded payload of a balancer.