Skip to content

feat(sql): add Pectra v1 and v2 tables and indexes #3110

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ohko4711 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

feat(sql): add Pectra v1 and v2 tables and indexes #3110

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
122 changes: 122 additions & 0 deletions db/migrations/20250822112108_add_pectra_v2_tables.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,122 @@
-- +goose Up
-- Pectra (Electra) upgrade database schema changes

-- +goose StatementBegin
SELECT 'adding committeebits column to blocks_attestations table';
ALTER TABLE blocks_attestations ADD COLUMN IF NOT EXISTS committeebits bytea;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating blocks_deposit_requests_v2 table';
CREATE TABLE IF NOT EXISTS blocks_deposit_requests_v2 (
slot_processed INT NOT NULL,
index_processed INT NOT NULL,
block_processed_root bytea NOT NULL,
pubkey bytea NOT NULL,
withdrawal_credentials bytea NOT NULL,
amount BIGINT NOT NULL,
signature bytea NOT NULL,
status VARCHAR(20) NOT NULL DEFAULT 'pending',
created_at TIMESTAMP DEFAULT NOW(),
PRIMARY KEY (slot_processed, index_processed)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating blocks_withdrawal_requests_v2 table';
CREATE TABLE IF NOT EXISTS blocks_withdrawal_requests_v2 (
slot_processed INT NOT NULL,
index_processed INT NOT NULL,
block_processed_root bytea NOT NULL,
source_address bytea NOT NULL,
validator_pubkey bytea NOT NULL,
amount BIGINT NOT NULL,
status VARCHAR(20) NOT NULL DEFAULT 'pending',
created_at TIMESTAMP DEFAULT NOW(),
PRIMARY KEY (slot_processed, index_processed)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating blocks_consolidation_requests_v2 table';
CREATE TABLE IF NOT EXISTS blocks_consolidation_requests_v2 (
slot_processed INT NOT NULL,
index_processed INT NOT NULL,
block_processed_root bytea NOT NULL,
source_pubkey bytea NOT NULL,
target_pubkey bytea NOT NULL,
amount_consolidated BIGINT NOT NULL DEFAULT 0,
status VARCHAR(20) NOT NULL DEFAULT 'pending',
created_at TIMESTAMP DEFAULT NOW(),
PRIMARY KEY (slot_processed, index_processed)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating blocks_switch_to_compounding_requests_v2 table';
CREATE TABLE IF NOT EXISTS blocks_switch_to_compounding_requests_v2 (
slot_processed INT NOT NULL,
index_processed INT NOT NULL,
block_processed_root bytea NOT NULL,
validator_pubkey bytea NOT NULL,
status VARCHAR(20) NOT NULL DEFAULT 'pending',
created_at TIMESTAMP DEFAULT NOW(),
PRIMARY KEY (slot_processed, index_processed)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for blocks_deposit_requests_v2';
CREATE INDEX IF NOT EXISTS idx_blocks_deposit_requests_v2_pubkey ON blocks_deposit_requests_v2 (pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_deposit_requests_v2_status ON blocks_deposit_requests_v2 (status);
CREATE INDEX IF NOT EXISTS idx_blocks_deposit_requests_v2_slot ON blocks_deposit_requests_v2 (slot_processed);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for blocks_withdrawal_requests_v2';
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_v2_pubkey ON blocks_withdrawal_requests_v2 (validator_pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_v2_address ON blocks_withdrawal_requests_v2 (source_address);
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_v2_status ON blocks_withdrawal_requests_v2 (status);
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_v2_slot ON blocks_withdrawal_requests_v2 (slot_processed);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for blocks_consolidation_requests_v2';
CREATE INDEX IF NOT EXISTS idx_blocks_consolidation_requests_v2_source_pubkey ON blocks_consolidation_requests_v2 (source_pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_consolidation_requests_v2_target_pubkey ON blocks_consolidation_requests_v2 (target_pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_consolidation_requests_v2_status ON blocks_consolidation_requests_v2 (status);
CREATE INDEX IF NOT EXISTS idx_blocks_consolidation_requests_v2_slot ON blocks_consolidation_requests_v2 (slot_processed);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for blocks_switch_to_compounding_requests_v2';
CREATE INDEX IF NOT EXISTS idx_blocks_switch_to_compounding_requests_v2_pubkey ON blocks_switch_to_compounding_requests_v2 (validator_pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_switch_to_compounding_requests_v2_status ON blocks_switch_to_compounding_requests_v2 (status);
CREATE INDEX IF NOT EXISTS idx_blocks_switch_to_compounding_requests_v2_slot ON blocks_switch_to_compounding_requests_v2 (slot_processed);
-- +goose StatementEnd

-- +goose Down
-- +goose StatementBegin
SELECT 'dropping blocks_switch_to_compounding_requests_v2 table';
DROP TABLE IF EXISTS blocks_switch_to_compounding_requests_v2;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'dropping blocks_consolidation_requests_v2 table';
DROP TABLE IF EXISTS blocks_consolidation_requests_v2;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'dropping blocks_withdrawal_requests_v2 table';
DROP TABLE IF EXISTS blocks_withdrawal_requests_v2;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'dropping blocks_deposit_requests_v2 table';
DROP TABLE IF EXISTS blocks_deposit_requests_v2;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'removing committeebits column from blocks_attestations table';
ALTER TABLE blocks_attestations DROP COLUMN IF EXISTS committeebits;
-- +goose StatementEnd
148 changes: 148 additions & 0 deletions db/migrations/20250822112109_add_pectra_v1_tables.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,148 @@
-- +goose Up
-- Missing Pectra (Electra) v1 tables

-- +goose StatementBegin
SELECT 'creating blocks_exit_requests table';
CREATE TABLE IF NOT EXISTS blocks_exit_requests (
block_slot INT NOT NULL,
block_index INT NOT NULL,
block_root bytea NOT NULL DEFAULT '',
validator_pubkey bytea NOT NULL,
status VARCHAR(20) NOT NULL DEFAULT 'pending',
reject_reason VARCHAR(255),
block_processed_root bytea,
slot_processed INT,
created_at TIMESTAMP DEFAULT NOW(),
PRIMARY KEY (block_slot, block_index)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating blocks_switch_to_compounding_requests table';
CREATE TABLE IF NOT EXISTS blocks_switch_to_compounding_requests (
block_slot INT NOT NULL,
block_index INT NOT NULL,
block_root bytea NOT NULL DEFAULT '',
validator_pubkey bytea NOT NULL,
request_index INT NOT NULL,
address bytea,
status VARCHAR(20) NOT NULL DEFAULT 'pending',
created_at TIMESTAMP DEFAULT NOW(),
PRIMARY KEY (block_slot, block_index)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for blocks_exit_requests';
CREATE INDEX IF NOT EXISTS idx_blocks_exit_requests_validator_pubkey ON blocks_exit_requests (validator_pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_exit_requests_status ON blocks_exit_requests (status);
CREATE INDEX IF NOT EXISTS idx_blocks_exit_requests_slot ON blocks_exit_requests (block_slot);
CREATE INDEX IF NOT EXISTS idx_blocks_exit_requests_block_processed_root ON blocks_exit_requests (block_processed_root);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for blocks_switch_to_compounding_requests';
CREATE INDEX IF NOT EXISTS idx_blocks_switch_to_compounding_requests_validator_pubkey ON blocks_switch_to_compounding_requests (validator_pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_switch_to_compounding_requests_status ON blocks_switch_to_compounding_requests (status);
CREATE INDEX IF NOT EXISTS idx_blocks_switch_to_compounding_requests_slot ON blocks_switch_to_compounding_requests (block_slot);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating blocks_withdrawal_requests table';
CREATE TABLE IF NOT EXISTS blocks_withdrawal_requests (
block_slot INT NOT NULL,
block_index INT NOT NULL,
block_root bytea NOT NULL DEFAULT '',
request_index INT NOT NULL,
source_address bytea,
validator_pubkey bytea NOT NULL,
amount BIGINT NOT NULL,
status VARCHAR(20) NOT NULL DEFAULT 'pending',
created_at TIMESTAMP DEFAULT NOW(),
PRIMARY KEY (block_slot, block_index)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating eth1_consolidation_requests table';
CREATE TABLE IF NOT EXISTS eth1_consolidation_requests (
tx_hash bytea NOT NULL,
tx_index INT NOT NULL,
itx_index INT NOT NULL,
block_number BIGINT NOT NULL,
block_ts TIMESTAMP NOT NULL,
from_address bytea NOT NULL,
fee BIGINT NOT NULL,
source_address bytea NOT NULL,
source_pubkey bytea NOT NULL,
target_pubkey bytea NOT NULL,
PRIMARY KEY (tx_hash, tx_index, itx_index)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for blocks_withdrawal_requests';
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_validator_pubkey ON blocks_withdrawal_requests (validator_pubkey);
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_source_address ON blocks_withdrawal_requests (source_address);
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_status ON blocks_withdrawal_requests (status);
CREATE INDEX IF NOT EXISTS idx_blocks_withdrawal_requests_slot ON blocks_withdrawal_requests (block_slot);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating eth1_withdrawal_requests table';
CREATE TABLE IF NOT EXISTS eth1_withdrawal_requests (
tx_hash bytea NOT NULL,
tx_index INT NOT NULL,
itx_index INT NOT NULL,
block_number BIGINT NOT NULL,
block_ts TIMESTAMP NOT NULL,
from_address bytea NOT NULL,
fee BIGINT NOT NULL,
source_address bytea NOT NULL,
validator_pubkey bytea NOT NULL,
amount BIGINT NOT NULL,
PRIMARY KEY (tx_hash, tx_index, itx_index)
);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for eth1_consolidation_requests';
CREATE INDEX IF NOT EXISTS idx_eth1_consolidation_requests_source_pubkey ON eth1_consolidation_requests (source_pubkey);
CREATE INDEX IF NOT EXISTS idx_eth1_consolidation_requests_target_pubkey ON eth1_consolidation_requests (target_pubkey);
CREATE INDEX IF NOT EXISTS idx_eth1_consolidation_requests_block_number ON eth1_consolidation_requests (block_number);
CREATE INDEX IF NOT EXISTS idx_eth1_consolidation_requests_block_ts ON eth1_consolidation_requests (block_ts);
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'creating indexes for eth1_withdrawal_requests';
CREATE INDEX IF NOT EXISTS idx_eth1_withdrawal_requests_validator_pubkey ON eth1_withdrawal_requests (validator_pubkey);
CREATE INDEX IF NOT EXISTS idx_eth1_withdrawal_requests_source_address ON eth1_withdrawal_requests (source_address);
CREATE INDEX IF NOT EXISTS idx_eth1_withdrawal_requests_block_number ON eth1_withdrawal_requests (block_number);
CREATE INDEX IF NOT EXISTS idx_eth1_withdrawal_requests_block_ts ON eth1_withdrawal_requests (block_ts);
-- +goose StatementEnd

-- +goose Down
-- +goose StatementBegin
SELECT 'dropping eth1_withdrawal_requests table';
DROP TABLE IF EXISTS eth1_withdrawal_requests;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'dropping eth1_consolidation_requests table';
DROP TABLE IF EXISTS eth1_consolidation_requests;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'dropping blocks_withdrawal_requests table';
DROP TABLE IF EXISTS blocks_withdrawal_requests;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'dropping blocks_switch_to_compounding_requests table';
DROP TABLE IF EXISTS blocks_switch_to_compounding_requests;
-- +goose StatementEnd

-- +goose StatementBegin
SELECT 'dropping blocks_exit_requests table';
DROP TABLE IF EXISTS blocks_exit_requests;
-- +goose StatementEnd