use luastate for statesql

chain/chainhandle.go

@@ -686,7 +686,7 @@ func (e *blockExecutor) execute() error {
 			return err
 		}
 
-		if err := contract.SaveRecoveryPoint(e.BlockState); err != nil {
+		if err := contract.SaveRecoveryPoint(e.BlockState.LuaStateDB); err != nil {
 			return err
 		}
 

contract/statesql.go

@@ -16,7 +16,7 @@ import (
 
 	"github.com/aergoio/aergo-lib/log"
 	"github.com/aergoio/aergo/v2/internal/enc/base58"
-	"github.com/aergoio/aergo/v2/state"
+	"github.com/aergoio/aergo/v2/state/statedb"
 	"github.com/aergoio/aergo/v2/types"
 )
 
@@ -126,7 +126,7 @@ func CloseDatabase() {
 	}
 }
 
-func SaveRecoveryPoint(bs *state.BlockState) error {
+func SaveRecoveryPoint(luaState *statedb.StateDB) error {
 	defer CloseDatabase()
 
 	for id, db := range database.DBs {
@@ -145,13 +145,13 @@ func SaveRecoveryPoint(bs *state.BlockState) error {
 				if sqlLgr.IsDebugEnabled() {
 					sqlLgr.Debug().Str("db_name", id).Uint64("commit_id", rp).Msg("save recovery point")
 				}
-				receiverState, err := bs.LuaStateDB.GetAccountState(db.accountID)
+				receiverState, err := luaState.GetAccountState(db.accountID)
 				if err != nil {
 					return err
 				}
 				receiverChange := receiverState.Clone()
 				receiverChange.SqlRecoveryPoint = uint64(rp)
-				err = bs.LuaStateDB.PutState(db.accountID, receiverChange)
+				err = luaState.PutState(db.accountID, receiverChange)
 				if err != nil {
 					return err
 				}

contract/vm_direct/vm_direct.go

@@ -330,7 +330,7 @@ func (e *blockExecutor) execute() error {
 		return err
 	}
 
-	if err := contract.SaveRecoveryPoint(e.BlockState); err != nil {
+	if err := contract.SaveRecoveryPoint(e.BlockState.LuaStateDB); err != nil {
 		return err
 	}
 

contract/vm_dummy/vm_dummy.go

@@ -637,7 +637,7 @@ func (bc *DummyChain) ConnectBlock(txs ...LuaTxTester) error {
 			return err
 		}
 	}
-	err := contract.SaveRecoveryPoint(blockState)
+	err := contract.SaveRecoveryPoint(blockState.LuaStateDB)
 	if err != nil {
 		return err
 	}