fix

block/pruning.go

@@ -15,20 +15,22 @@ func (m *Manager) PruneBlocks(retainHeight uint64) error {
 			gerrc.ErrInvalidArgument)
 	}
 
-	//
+	// prune blocks from blocksync store
 	err := m.P2PClient.RemoveBlocks(context.Background(), m.State.BaseHeight, retainHeight)
 	if err != nil {
 		m.logger.Error("pruning blocksync store", "retain_height", retainHeight, "err", err)
 	}
 
-	pruned, err := m.Store.PruneBlocks(m.State.BaseHeight, retainHeight)
+	// prune blocks from indexer store
+	err = m.indexerService.Prune(m.State.BaseHeight, retainHeight)
 	if err != nil {
-		return fmt.Errorf("pruning dymint store: %w", err)
+		m.logger.Error("pruning indexer", "retain_height", retainHeight, "err", err)
 	}
 
-	err = m.indexerService.Prune(int64(m.State.BaseHeight), int64(retainHeight))
+	// prune blocks from dymint store
+	pruned, err := m.Store.PruneBlocks(m.State.BaseHeight, retainHeight)
 	if err != nil {
-		return fmt.Errorf("pruning indexer: %w", err)
+		return fmt.Errorf("pruning dymint store: %w", err)
 	}
 
 	m.State.BaseHeight = retainHeight

indexers/blockindexer/kv/kv_test.go

@@ -153,7 +153,7 @@ func TestBlockIndexerPruning(t *testing.T) {
 	indexer := blockidxkv.New(prefixStore)
 	numBlocks := uint64(100)
 
-	// index block event data
+	// index block data
 	for i := uint64(1); i <= numBlocks; i++ {
 		indexer.Index(types.EventDataNewBlockHeader{
 			Header:           types.Header{Height: int64(i)},
@@ -167,7 +167,7 @@ func TestBlockIndexerPruning(t *testing.T) {
 	q := query.MustParse(queryString)
 	results, err := indexer.Search(context.Background(), q)
 	require.NoError(t, err)
-	require.Equal(t, numBlocks, len(results))
+	require.Equal(t, numBlocks, uint64(len(results)))
 
 	// prune indexer for all heights
 	pruned, err := indexer.Prune(1, numBlocks+1)