Browse Source

change out event type for psql indexer

pull/7983/head
William Banfield 3 years ago
parent
commit
1eac8534a0
3 changed files with 6 additions and 12 deletions
  1. +1
    -1
      internal/state/indexer/block/kv/kv.go
  2. +2
    -11
      internal/state/indexer/sink/psql/psql_test.go
  3. +3
    -0
      types/events.go

+ 1
- 1
internal/state/indexer/block/kv/kv.go View File

@ -65,7 +65,7 @@ func (idx *BlockerIndexer) Index(bh types.EventDataNewBlockHeader) error {
}
// 2. index FinalizeBlock events
if err := idx.indexEvents(batch, bh.ResultFinalizeBlock.BlockEvents, "finalize_block", height); err != nil {
if err := idx.indexEvents(batch, bh.ResultFinalizeBlock.BlockEvents, types.EventTypeFinalizeBlock, height); err != nil {
return fmt.Errorf("failed to index FinalizeBlock events: %w", err)
}


+ 2
- 11
internal/state/indexer/sink/psql/psql_test.go View File

@ -314,20 +314,11 @@ SELECT height FROM `+tableBlocks+` WHERE height = $1;
if err := testDB().QueryRow(`
SELECT type, height, chain_id FROM `+viewBlockEvents+`
WHERE height = $1 AND type = $2 AND chain_id = $3;
`, height, types.EventTypeBeginBlock, chainID).Err(); err == sql.ErrNoRows {
t.Errorf("No %q event found for height=%d", types.EventTypeBeginBlock, height)
`, height, types.EventTypeFinalizeBlock, chainID).Scan(&[]byte{}); err == sql.ErrNoRows {
t.Errorf("No %q event found for height=%d", types.EventTypeFinalizeBlock, height)
} else if err != nil {
t.Fatalf("Database query failed: %c", err)
}
if err := testDB().QueryRow(`
SELECT type, height, chain_id FROM `+viewBlockEvents+`
WHERE height = $1 AND type = $2 AND chain_id = $3;
`, height, types.EventTypeEndBlock, chainID).Err(); err == sql.ErrNoRows {
t.Errorf("No %q event found for height=%d", types.EventTypeEndBlock, height)
} else if err != nil {
t.Fatalf("Database query failed: %v", err)
}
}
// verifyNotImplemented calls f and verifies that it returns both a


+ 3
- 0
types/events.go View File

@ -272,6 +272,9 @@ const (
// BlockHeightKey is a reserved key used for indexing FinalizeBlock events.
BlockHeightKey = "block.height"
// is a reserved key used for indexing FinalizeBlock events.
EventTypeFinalizeBlock = "finalize_block"
)
var (


Loading…
Cancel
Save