WIP: request result simulation

clients/consensus/chainspec.go

@@ -20,44 +20,51 @@ type ForkVersion struct {
 
 // https://github.com/ethereum/consensus-specs/blob/dev/configs/mainnet.yaml
 type ChainSpec struct {
-	PresetBase                         string            `yaml:"PRESET_BASE"`
-	ConfigName                         string            `yaml:"CONFIG_NAME" check-if:"false"`
-	MinGenesisTime                     time.Time         `yaml:"MIN_GENESIS_TIME"`
-	GenesisForkVersion                 phase0.Version    `yaml:"GENESIS_FORK_VERSION"`
-	AltairForkVersion                  phase0.Version    `yaml:"ALTAIR_FORK_VERSION"`
-	AltairForkEpoch                    *uint64           `yaml:"ALTAIR_FORK_EPOCH"`
-	BellatrixForkVersion               phase0.Version    `yaml:"BELLATRIX_FORK_VERSION"`
-	BellatrixForkEpoch                 *uint64           `yaml:"BELLATRIX_FORK_EPOCH"`
-	CapellaForkVersion                 phase0.Version    `yaml:"CAPELLA_FORK_VERSION"`
-	CapellaForkEpoch                   *uint64           `yaml:"CAPELLA_FORK_EPOCH"`
-	DenebForkVersion                   phase0.Version    `yaml:"DENEB_FORK_VERSION"`
-	DenebForkEpoch                     *uint64           `yaml:"DENEB_FORK_EPOCH"`
-	ElectraForkVersion                 phase0.Version    `yaml:"ELECTRA_FORK_VERSION" check-if-fork:"ElectraForkEpoch"`
-	ElectraForkEpoch                   *uint64           `yaml:"ELECTRA_FORK_EPOCH"`
-	Eip7594ForkVersion                 phase0.Version    `yaml:"EIP7594_FORK_VERSION" check-if-fork:"Eip7594ForkEpoch"`
-	Eip7594ForkEpoch                   *uint64           `yaml:"EIP7594_FORK_EPOCH"`
-	SecondsPerSlot                     time.Duration     `yaml:"SECONDS_PER_SLOT"`
-	SlotsPerEpoch                      uint64            `yaml:"SLOTS_PER_EPOCH"`
-	EpochsPerHistoricalVector          uint64            `yaml:"EPOCHS_PER_HISTORICAL_VECTOR"`
-	EpochsPerSlashingVector            uint64            `yaml:"EPOCHS_PER_SLASHINGS_VECTOR"`
-	EpochsPerSyncCommitteePeriod       uint64            `yaml:"EPOCHS_PER_SYNC_COMMITTEE_PERIOD"`
-	MinSeedLookahead                   uint64            `yaml:"MIN_SEED_LOOKAHEAD"`
-	ShuffleRoundCount                  uint64            `yaml:"SHUFFLE_ROUND_COUNT"`
-	MaxEffectiveBalance                uint64            `yaml:"MAX_EFFECTIVE_BALANCE"`
-	MaxEffectiveBalanceElectra         uint64            `yaml:"MAX_EFFECTIVE_BALANCE_ELECTRA" check-if-fork:"ElectraForkEpoch"`
-	TargetCommitteeSize                uint64            `yaml:"TARGET_COMMITTEE_SIZE"`
-	MaxCommitteesPerSlot               uint64            `yaml:"MAX_COMMITTEES_PER_SLOT"`
-	MinPerEpochChurnLimit              uint64            `yaml:"MIN_PER_EPOCH_CHURN_LIMIT"`
-	ChurnLimitQuotient                 uint64            `yaml:"CHURN_LIMIT_QUOTIENT"`
-	DomainBeaconProposer               phase0.DomainType `yaml:"DOMAIN_BEACON_PROPOSER"`
-	DomainBeaconAttester               phase0.DomainType `yaml:"DOMAIN_BEACON_ATTESTER"`
-	DomainSyncCommittee                phase0.DomainType `yaml:"DOMAIN_SYNC_COMMITTEE"`
-	SyncCommitteeSize                  uint64            `yaml:"SYNC_COMMITTEE_SIZE"`
-	DepositContractAddress             []byte            `yaml:"DEPOSIT_CONTRACT_ADDRESS"`
-	MaxConsolidationRequestsPerPayload uint64            `yaml:"MAX_CONSOLIDATION_REQUESTS_PER_PAYLOAD" check-if-fork:"ElectraForkEpoch"`
-	MaxWithdrawalRequestsPerPayload    uint64            `yaml:"MAX_WITHDRAWAL_REQUESTS_PER_PAYLOAD"    check-if-fork:"ElectraForkEpoch"`
-	DepositChainId                     uint64            `yaml:"DEPOSIT_CHAIN_ID"`
-	MinActivationBalance               uint64            `yaml:"MIN_ACTIVATION_BALANCE"`
+	PresetBase                            string            `yaml:"PRESET_BASE"`
+	ConfigName                            string            `yaml:"CONFIG_NAME" check-if:"false"`
+	MinGenesisTime                        time.Time         `yaml:"MIN_GENESIS_TIME"`
+	GenesisForkVersion                    phase0.Version    `yaml:"GENESIS_FORK_VERSION"`
+	AltairForkVersion                     phase0.Version    `yaml:"ALTAIR_FORK_VERSION"`
+	AltairForkEpoch                       *uint64           `yaml:"ALTAIR_FORK_EPOCH"`
+	BellatrixForkVersion                  phase0.Version    `yaml:"BELLATRIX_FORK_VERSION"`
+	BellatrixForkEpoch                    *uint64           `yaml:"BELLATRIX_FORK_EPOCH"`
+	CapellaForkVersion                    phase0.Version    `yaml:"CAPELLA_FORK_VERSION"`
+	CapellaForkEpoch                      *uint64           `yaml:"CAPELLA_FORK_EPOCH"`
+	DenebForkVersion                      phase0.Version    `yaml:"DENEB_FORK_VERSION"`
+	DenebForkEpoch                        *uint64           `yaml:"DENEB_FORK_EPOCH"`
+	ElectraForkVersion                    phase0.Version    `yaml:"ELECTRA_FORK_VERSION" check-if-fork:"ElectraForkEpoch"`
+	ElectraForkEpoch                      *uint64           `yaml:"ELECTRA_FORK_EPOCH"   check-if-fork:"ElectraForkEpoch"`
+	Eip7594ForkVersion                    phase0.Version    `yaml:"EIP7594_FORK_VERSION" check-if-fork:"Eip7594ForkEpoch"`
+	Eip7594ForkEpoch                      *uint64           `yaml:"EIP7594_FORK_EPOCH"   check-if-fork:"Eip7594ForkEpoch"`
+	SecondsPerSlot                        time.Duration     `yaml:"SECONDS_PER_SLOT"`
+	SlotsPerEpoch                         uint64            `yaml:"SLOTS_PER_EPOCH"`
+	EpochsPerHistoricalVector             uint64            `yaml:"EPOCHS_PER_HISTORICAL_VECTOR"`
+	EpochsPerSlashingVector               uint64            `yaml:"EPOCHS_PER_SLASHINGS_VECTOR"`
+	EpochsPerSyncCommitteePeriod          uint64            `yaml:"EPOCHS_PER_SYNC_COMMITTEE_PERIOD"`
+	MinSeedLookahead                      uint64            `yaml:"MIN_SEED_LOOKAHEAD"`
+	ShuffleRoundCount                     uint64            `yaml:"SHUFFLE_ROUND_COUNT"`
+	MaxEffectiveBalance                   uint64            `yaml:"MAX_EFFECTIVE_BALANCE"`
+	MaxEffectiveBalanceElectra            uint64            `yaml:"MAX_EFFECTIVE_BALANCE_ELECTRA" check-if-fork:"ElectraForkEpoch"`
+	TargetCommitteeSize                   uint64            `yaml:"TARGET_COMMITTEE_SIZE"`
+	MaxCommitteesPerSlot                  uint64            `yaml:"MAX_COMMITTEES_PER_SLOT"`
+	MinPerEpochChurnLimit                 uint64            `yaml:"MIN_PER_EPOCH_CHURN_LIMIT"`
+	ChurnLimitQuotient                    uint64            `yaml:"CHURN_LIMIT_QUOTIENT"`
+	DomainBeaconProposer                  phase0.DomainType `yaml:"DOMAIN_BEACON_PROPOSER"`
+	DomainBeaconAttester                  phase0.DomainType `yaml:"DOMAIN_BEACON_ATTESTER"`
+	DomainSyncCommittee                   phase0.DomainType `yaml:"DOMAIN_SYNC_COMMITTEE"`
+	SyncCommitteeSize                     uint64            `yaml:"SYNC_COMMITTEE_SIZE"`
+	DepositContractAddress                []byte            `yaml:"DEPOSIT_CONTRACT_ADDRESS"`
+	MaxConsolidationRequestsPerPayload    uint64            `yaml:"MAX_CONSOLIDATION_REQUESTS_PER_PAYLOAD" check-if-fork:"ElectraForkEpoch"`
+	MaxWithdrawalRequestsPerPayload       uint64            `yaml:"MAX_WITHDRAWAL_REQUESTS_PER_PAYLOAD"    check-if-fork:"ElectraForkEpoch"`
+	DepositChainId                        uint64            `yaml:"DEPOSIT_CHAIN_ID"`
+	MinActivationBalance                  uint64            `yaml:"MIN_ACTIVATION_BALANCE"`
+	MaxPendingPartialsPerWithdrawalsSweep uint64            `yaml:"MAX_PENDING_PARTIALS_PER_WITHDRAWALS_SWEEP" check-if-fork:"ElectraForkEpoch"`
+	PendingPartialWithdrawalsLimit        uint64            `yaml:"PENDING_PARTIAL_WITHDRAWALS_LIMIT"          check-if-fork:"ElectraForkEpoch"`
+	PendingConsolidationsLimit            uint64            `yaml:"PENDING_CONSOLIDATIONS_LIMIT"               check-if-fork:"ElectraForkEpoch"`
+	MinPerEpochChurnLimitElectra          uint64            `yaml:"MIN_PER_EPOCH_CHURN_LIMIT_ELECTRA"          check-if-fork:"ElectraForkEpoch"`
+	MaxPerEpochActivationExitChurnLimit   uint64            `yaml:"MAX_PER_EPOCH_ACTIVATION_EXIT_CHURN_LIMIT"  check-if-fork:"ElectraForkEpoch"`
+	EffectiveBalanceIncrement             uint64            `yaml:"EFFECTIVE_BALANCE_INCREMENT"`
+	ShardCommitteePeriod                  uint64            `yaml:"SHARD_COMMITTEE_PERIOD"`
 
 	// EIP7594: PeerDAS
 	NumberOfColumns              *uint64 `yaml:"NUMBER_OF_COLUMNS"                check-if-fork:"Eip7594ForkEpoch"`

db/consolidation_request_txs.go

@@ -53,7 +53,7 @@ func InsertConsolidationRequestTxs(consolidationTxs []*dbtypes.ConsolidationRequ
 		argIdx += fieldCount
 	}
 	fmt.Fprint(&sql, EngineQuery(map[dbtypes.DBEngineType]string{
-		dbtypes.DBEnginePgsql:  " ON CONFLICT (block_root, block_index) DO UPDATE SET source_index = excluded.source_index, target_index = excluded.target_index, fork_id = excluded.fork_id",
+		dbtypes.DBEnginePgsql:  " ON CONFLICT (block_root, block_index) DO UPDATE SET source_index = excluded.source_index, target_index = excluded.target_index, dequeue_block = excluded.dequeue_block, fork_id = excluded.fork_id",
 		dbtypes.DBEngineSqlite: "",
 	}))
 

db/consolidation_requests.go

@@ -15,11 +15,11 @@ func InsertConsolidationRequests(consolidations []*dbtypes.ConsolidationRequest,
 			dbtypes.DBEnginePgsql:  "INSERT INTO consolidation_requests ",
 			dbtypes.DBEngineSqlite: "INSERT OR REPLACE INTO consolidation_requests ",
 		}),
-		"(slot_number, slot_root, slot_index, orphaned, fork_id, source_address, source_index, source_pubkey, target_index, target_pubkey, tx_hash, block_number)",
+		"(slot_number, slot_root, slot_index, orphaned, fork_id, source_address, source_index, source_pubkey, target_index, target_pubkey, tx_hash, block_number, result)",
 		" VALUES ",
 	)
 	argIdx := 0
-	fieldCount := 12
+	fieldCount := 13
 
 	args := make([]interface{}, len(consolidations)*fieldCount)
 	for i, consolidation := range consolidations {
@@ -47,10 +47,11 @@ func InsertConsolidationRequests(consolidations []*dbtypes.ConsolidationRequest,
 		args[argIdx+9] = consolidation.TargetPubkey[:]
 		args[argIdx+10] = consolidation.TxHash[:]
 		args[argIdx+11] = consolidation.BlockNumber
+		args[argIdx+12] = consolidation.Result
 		argIdx += fieldCount
 	}
 	fmt.Fprint(&sql, EngineQuery(map[dbtypes.DBEngineType]string{
-		dbtypes.DBEnginePgsql:  " ON CONFLICT (slot_root, slot_index) DO UPDATE SET orphaned = excluded.orphaned, fork_id = excluded.fork_id",
+		dbtypes.DBEnginePgsql:  " ON CONFLICT (slot_root, slot_index) DO UPDATE SET orphaned = excluded.orphaned, fork_id = excluded.fork_id, result = excluded.result",
 		dbtypes.DBEngineSqlite: "",
 	}))
 	_, err := tx.Exec(sql.String(), args...)
@@ -66,7 +67,7 @@ func GetConsolidationRequestsFiltered(offset uint64, limit uint32, canonicalFork
 	fmt.Fprint(&sql, `
 	WITH cte AS (
 		SELECT
-			slot_number, slot_root, slot_index, orphaned, fork_id, source_address, source_index, source_pubkey, target_index, target_pubkey, tx_hash, block_number
+			slot_number, slot_root, slot_index, orphaned, fork_id, source_address, source_index, source_pubkey, target_index, target_pubkey, tx_hash, block_number, result
 		FROM consolidation_requests
 	`)
 
@@ -173,7 +174,8 @@ func GetConsolidationRequestsFiltered(offset uint64, limit uint32, canonicalFork
 		0 AS target_index,
 		null AS target_pubkey,
 		null AS tx_hash,
-		0 AS block_number
+		0 AS block_number,
+		0 AS result
 	FROM cte
 	UNION ALL SELECT * FROM (
 	SELECT * FROM cte

db/schema/pgsql/20241216124511_validator-set.sql

@@ -0,0 +1,24 @@
+-- +goose Up
+-- +goose StatementBegin
+
+CREATE TABLE IF NOT EXISTS public."validators" (
+    validator_index BIGINT NOT NULL,
+    pubkey bytea NOT NULL,
+    withdrawal_credentials bytea NOT NULL,
+    effective_balance BIGINT NOT NULL,
+    slashed BOOLEAN NOT NULL,
+    activation_eligibility_epoch BIGINT NOT NULL,
+    activation_epoch BIGINT NOT NULL,
+    exit_epoch BIGINT NOT NULL,
+    withdrawable_epoch BIGINT NOT NULL,
+    CONSTRAINT validators_pkey PRIMARY KEY (validator_index)
+);
+
+CREATE INDEX IF NOT EXISTS "validators_pubkey_idx"
+    ON public."validators" ("pubkey");
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+SELECT 'NOT SUPPORTED';
+-- +goose StatementEnd

db/schema/pgsql/20250207221132_request-results.sql

@@ -0,0 +1,14 @@
+-- +goose Up
+-- +goose StatementBegin
+
+ALTER TABLE public."consolidation_requests"
+    ADD "result" smallint NOT NULL DEFAULT 0;
+
+ALTER TABLE public."withdrawal_requests"
+    ADD "result" smallint NOT NULL DEFAULT 0;
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+SELECT 'NOT SUPPORTED';
+-- +goose StatementEnd

db/schema/sqlite/20241216124511_validator-set.sql

@@ -0,0 +1,24 @@
+-- +goose Up
+-- +goose StatementBegin
+
+CREATE TABLE IF NOT EXISTS "validators" (
+    validator_index BIGINT NOT NULL,
+    pubkey BLOB NOT NULL,
+    withdrawal_credentials BLOB NOT NULL,
+    effective_balance BIGINT NOT NULL,
+    slashed BOOLEAN NOT NULL,
+    activation_eligibility_epoch BIGINT NOT NULL,
+    activation_epoch BIGINT NOT NULL,
+    exit_epoch BIGINT NOT NULL,
+    withdrawable_epoch BIGINT NOT NULL,
+    PRIMARY KEY (validator_index)
+);
+
+CREATE INDEX IF NOT EXISTS "validators_pubkey_idx"
+    ON "validators" ("pubkey");
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+SELECT 'NOT SUPPORTED';
+-- +goose StatementEnd

db/schema/sqlite/20250207221132_request-results.sql

@@ -0,0 +1,14 @@
+-- +goose Up
+-- +goose StatementBegin
+
+ALTER TABLE "consolidation_requests"
+    ADD "result" TINYINT NOT NULL DEFAULT 0;
+
+ALTER TABLE "withdrawal_requests"
+    ADD "result" TINYINT NOT NULL DEFAULT 0;
+
+-- +goose StatementEnd
+-- +goose Down
+-- +goose StatementBegin
+SELECT 'NOT SUPPORTED';
+-- +goose StatementEnd