Skip to content

Commit

Permalink
fix test case
Browse files Browse the repository at this point in the history
  • Loading branch information
zhangchiqing committed Dec 22, 2023
1 parent 4fe1c15 commit 17b28f4
Show file tree
Hide file tree
Showing 4 changed files with 19 additions and 17 deletions.
2 changes: 1 addition & 1 deletion engine/access/rpc/backend/backend_accounts_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -376,7 +376,7 @@ func (s *BackendAccountsSuite) testGetAccountAtLatestBlock(ctx context.Context,

func (s *BackendAccountsSuite) testGetAccountAtBlockHeight(ctx context.Context, backend *backendAccounts, statusCode codes.Code) {
height := s.block.Header.Height
s.headers.On("ByHeight", height).Return(s.block.Header, nil).Once()
s.headers.On("BlockIDByHeight", height).Return(s.block.Header.ID(), nil).Once()

if statusCode == codes.OK {
actual, err := backend.GetAccountAtBlockHeight(ctx, s.account.Address, height)
Expand Down
20 changes: 11 additions & 9 deletions engine/consensus/approvals/testutil.go
Original file line number Diff line number Diff line change
Expand Up @@ -134,20 +134,22 @@ func (s *BaseAssignmentCollectorTestSuite) SetupTest() {
return realstorage.ErrNotFound
}
})
s.Headers.On("ByHeight", mock.Anything).Return(
func(height uint64) *flow.Header {
s.Headers.On("BlockIDByHeight", mock.Anything).Return(
func(height uint64) (flow.Identifier, error) {
if block, found := s.FinalizedAtHeight[height]; found {
return block
return block.ID(), nil
} else {
return nil
return flow.ZeroID, realstorage.ErrNotFound
}
},
func(height uint64) error {
_, found := s.FinalizedAtHeight[height]
if !found {
return realstorage.ErrNotFound
)
s.Headers.On("ByHeight", mock.Anything).Return(
func(height uint64) (*flow.Header, error) {
if block, found := s.FinalizedAtHeight[height]; found {
return block, nil
} else {
return nil, realstorage.ErrNotFound
}
return nil
},
)

Expand Down
8 changes: 4 additions & 4 deletions engine/execution/ingestion/loader/unexecuted_loader_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -200,7 +200,7 @@ func TestLoadingUnexecutedBlocks(t *testing.T) {
loader := loader.NewUnexecutedLoader(log, ps, headers, es)

// block C is the only finalized block, index its header by its height
headers.EXPECT().ByHeight(blockC.Header.Height).Return(blockC.Header, nil)
headers.EXPECT().BlockIDByHeight(blockC.Header.Height).Return(blockC.Header.ID(), nil)

es.ExecuteBlock(t, blockA)
es.ExecuteBlock(t, blockB)
Expand Down Expand Up @@ -238,7 +238,7 @@ func TestLoadingUnexecutedBlocks(t *testing.T) {
loader := loader.NewUnexecutedLoader(log, ps, headers, es)

// block C is finalized, index its header by its height
headers.EXPECT().ByHeight(blockC.Header.Height).Return(blockC.Header, nil)
headers.EXPECT().BlockIDByHeight(blockC.Header.Height).Return(blockC.Header.ID(), nil)

es.ExecuteBlock(t, blockA)
es.ExecuteBlock(t, blockB)
Expand Down Expand Up @@ -278,7 +278,7 @@ func TestLoadingUnexecutedBlocks(t *testing.T) {
loader := loader.NewUnexecutedLoader(log, ps, headers, es)

// block A is finalized, index its header by its height
headers.EXPECT().ByHeight(blockA.Header.Height).Return(blockA.Header, nil)
headers.EXPECT().BlockIDByHeight(blockA.Header.Height).Return(blockA.Header.ID(), nil)

es.ExecuteBlock(t, blockA)
es.ExecuteBlock(t, blockB)
Expand Down Expand Up @@ -346,7 +346,7 @@ func TestLoadingUnexecutedBlocks(t *testing.T) {
loader := loader.NewUnexecutedLoader(log, ps, headers, es)

// block C is finalized, index its header by its height
headers.EXPECT().ByHeight(blockC.Header.Height).Return(blockC.Header, nil)
headers.EXPECT().BlockIDByHeight(blockC.Header.Height).Return(blockC.Header.ID(), nil)

es.ExecuteBlock(t, blockA)
es.ExecuteBlock(t, blockB)
Expand Down
6 changes: 3 additions & 3 deletions engine/execution/ingestion/loader/unfinalized_loader_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,9 @@ func TestLoadingUnfinalizedBlocks(t *testing.T) {
es := new(stateMock.FinalizedExecutionState)
es.On("GetHighestFinalizedExecuted").Return(genesis.Header.Height)
headers := new(storage.Headers)
headers.On("ByHeight", blockA.Header.Height).Return(blockA.Header, nil)
headers.On("ByHeight", blockB.Header.Height).Return(blockB.Header, nil)
headers.On("ByHeight", blockC.Header.Height).Return(blockC.Header, nil)
headers.On("BlockIDByHeight", blockA.Header.Height).Return(blockA.Header.ID(), nil)
headers.On("BlockIDByHeight", blockB.Header.Height).Return(blockB.Header.ID(), nil)
headers.On("BlockIDByHeight", blockC.Header.Height).Return(blockC.Header.ID(), nil)

loader := loader.NewUnfinalizedLoader(unittest.Logger(), ps, headers, es)

Expand Down

0 comments on commit 17b28f4

Please sign in to comment.