update

cmd/fireeth/tools_find_empty_reciepts.go → cmd/fireeth/tools_find_unknown_status.go

@@ -1,11 +1,12 @@
 package main
 
 import (
+	"bytes"
+	"encoding/json"
 	"fmt"
 	"io"
 
 	"github.com/streamingfast/bstream"
-	pbbstream "github.com/streamingfast/bstream/pb/sf/bstream/v1"
 	pbeth "github.com/streamingfast/firehose-ethereum/types/pb/sf/ethereum/type/v2"
 
 	"github.com/spf13/cobra"
@@ -16,9 +17,9 @@ import (
 
 func newScanForEmptyReceiptsCmd(logger *zap.Logger) *cobra.Command {
 	return &cobra.Command{
-		Use:   "scan-for-empty-receipts <src-blocks-store> <start-block> <stop-block>",
+		Use:   "find-unknown-status <src-blocks-store> <dst-store> <start-block> <stop-block>",
 		Short: "look for blocks with empty receipts",
-		Args:  cobra.ExactArgs(3),
+		Args:  cobra.ExactArgs(4),
 		RunE:  scanForEmptyReceiptsE(logger),
 	}
 }
@@ -32,8 +33,13 @@ func scanForEmptyReceiptsE(logger *zap.Logger) firecore.CommandExecutor {
 			return fmt.Errorf("unable to create source store: %w", err)
 		}
 
-		start := mustParseUint64(args[1])
-		stop := mustParseUint64(args[2])
+		outputStore, err := dstore.NewDBinStore(args[1])
+		if err != nil {
+			return fmt.Errorf("unable to create output store: %w", err)
+		}
+
+		start := mustParseUint64(args[2])
+		stop := mustParseUint64(args[3])
 
 		if stop <= start {
 			return fmt.Errorf("stop block must be greater than start block")
@@ -66,7 +72,7 @@ func scanForEmptyReceiptsE(logger *zap.Logger) firecore.CommandExecutor {
 				return fmt.Errorf("creating block reader: %w", err)
 			}
 
-			blocks := make([]*pbbstream.Block, 100)
+			blocks := make([]uint64, 100)
 			for {
 				block, err := br.Read()
 				if err == io.EOF {
@@ -81,12 +87,21 @@ func scanForEmptyReceiptsE(logger *zap.Logger) firecore.CommandExecutor {
 
 				for _, trace := range ethBlock.TransactionTraces {
 					if trace.Status == pbeth.TransactionTraceStatus_UNKNOWN {
-						blocks = append(blocks, block)
+						blocks = append(blocks, block.Number)
 						logger.Info("found block with empty receipt", zap.Uint64("block_num", ethBlock.Number))
 						break
 					}
 				}
 			}
+
+			if len(blocks) > 0 {
+				data, _ := json.Marshal(blocks)
+				err = outputStore.WriteObject(ctx, fmt.Sprintf("%010d_%d.json", startBlock, len(blocks)), bytes.NewBuffer(data))
+				if err != nil {
+					return fmt.Errorf("failed to write output file: %w", err)
+				}
+			}
+
 			return nil
 		})
 		if err != nil && err != io.EOF {