Merge pull request #8 from initia-labs/fix/block-events-mode

Fix unmarshalling event mode in finalize block events

Author: SeUkKim

informative-indexer/db/finalize_block_event.go

@@ -43,17 +43,25 @@ type FinalizeBlockEvent struct {
 }
 
 func (f *FinalizeBlockEvent) Unmarshal(rows pgx.Rows) (map[string]interface{}, error) {
-	err := rows.Scan(&f.BlockHeight, &f.EventKey, &f.EventValue, &f.EventIndex, &f.Mode)
+	var modeStr string
+
+	err := rows.Scan(&f.BlockHeight, &f.EventKey, &f.EventValue, &f.EventIndex, &modeStr)
 	if err != nil {
 		return nil, err
 	}
 
+	mode, parseErr := ParseMode(modeStr)
+	if parseErr != nil {
+		return nil, parseErr
+	}
+	f.Mode = mode
+
 	row := map[string]interface{}{
 		"block_height": f.BlockHeight,
 		"event_key":    f.EventKey,
 		"event_value":  f.EventValue,
 		"event_index":  f.EventIndex,
-		"mode":         f.Mode,
+		"mode":         f.Mode.String(),
 	}
 
 	return row, nil

informative-indexer/prunner/prunner.go

@@ -97,7 +97,7 @@ func (p *Prunner) pruningTable(ctx context.Context, tableName string) error {
 
 	height, err := db.GetLatestBlockHeight(ctx, p.dbClient)
 	if err != nil {
-		return fmt.Errorf("DB: failedto get latest block height: %w", err)
+		return fmt.Errorf("DB: failed to get latest block height: %w", err)
 	}
 
 	pruningThreshold := height - p.config.PruningKeepBlock

informative-indexer/run.sh

@@ -58,6 +58,29 @@ task__flush() {
     --id 1
 }
 
+help__prune="prune <..args> : run prune"
+task__prune() {
+  local chain=$1
+
+  if [ -z "$chain" ]; then
+    echo "usage: $0 flush <chain>"
+    exit
+  fi
+
+  go build -o informative-indexer.bin .
+
+  source .env
+
+  ./informative-indexer.bin prune --db $DB_CONNECTION_STRING \
+    --backup-bucket-name ${chain}-local-core-informative-data-backup \
+    --backup-file-prefix events \
+    --pruning-keep-block 10 \
+    --pruning-block-interval 10 \
+    --pruning-interval 1 \
+    --chain $chain \
+    --environment local
+}
+
 list_all_helps() {
   compgen -v | egrep "^help__.*"
 }