Skip to content

fix: optimize queries to prune and restore mempool rbf txs #2327

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

Merged
rafaelcr merged 1 commit into from
Jul 22, 2025
Merged

fix: optimize queries to prune and restore mempool rbf txs #2327

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
60 changes: 40 additions & 20 deletions src/datastore/pg-write-store.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2961,17 +2961,27 @@ export class PgWriteStore extends PgStore {
t.nonce,
]);
const updatedRows = await sql<{ tx_id: string }[]>`
WITH input_data (tx_id, sender_address, sponsor_address, sponsored, nonce)
AS (VALUES ${sql(inputData)}),
affected_mempool_tx_ids AS (
WITH input_data (tx_id, sender_address, sponsor_address, sponsored, nonce) AS (
VALUES ${sql(inputData)}
),
sponsored_inputs AS (SELECT * FROM input_data WHERE sponsored::boolean),
non_sponsored_inputs AS (SELECT * FROM input_data WHERE NOT sponsored::boolean),
affected_sponsored AS (
SELECT m.tx_id
FROM mempool_txs m
INNER JOIN sponsored_inputs i ON m.nonce = i.nonce::int
AND (m.sponsor_address = i.sponsor_address OR m.sender_address = i.sponsor_address)
),
affected_non_sponsored AS (
SELECT m.tx_id
FROM mempool_txs AS m
INNER JOIN input_data AS i
ON m.nonce = i.nonce::int
AND (CASE i.sponsored::boolean
WHEN true THEN (m.sponsor_address = i.sponsor_address OR m.sender_address = i.sponsor_address)
ELSE (m.sponsor_address = i.sender_address OR m.sender_address = i.sender_address)
END)
FROM mempool_txs m
INNER JOIN non_sponsored_inputs i ON m.nonce = i.nonce::int
AND (m.sponsor_address = i.sender_address OR m.sender_address = i.sender_address)
),
affected_mempool_tx_ids AS (
SELECT tx_id FROM affected_sponsored
UNION
SELECT tx_id FROM affected_non_sponsored
UNION
SELECT tx_id::bytea FROM input_data
),
Expand Down Expand Up @@ -3046,17 +3056,27 @@ export class PgWriteStore extends PgStore {
t.nonce,
]);
const updateResults = await sql<{ tx_id: string }[]>`
WITH input_data (tx_id, sender_address, sponsor_address, sponsored, nonce)
AS (VALUES ${sql(inputData)}),
affected_mempool_tx_ids AS (
WITH input_data (tx_id, sender_address, sponsor_address, sponsored, nonce) AS (
VALUES ${sql(inputData)}
),
sponsored_inputs AS (SELECT * FROM input_data WHERE sponsored::boolean),
non_sponsored_inputs AS (SELECT * FROM input_data WHERE NOT sponsored::boolean),
affected_sponsored AS (
SELECT m.tx_id
FROM mempool_txs m
INNER JOIN sponsored_inputs i ON m.nonce = i.nonce::int
AND (m.sponsor_address = i.sponsor_address OR m.sender_address = i.sponsor_address)
),
affected_non_sponsored AS (
SELECT m.tx_id
FROM mempool_txs AS m
INNER JOIN input_data AS i
ON m.nonce = i.nonce::int
AND (CASE i.sponsored::boolean
WHEN true THEN (m.sponsor_address = i.sponsor_address OR m.sender_address = i.sponsor_address)
ELSE (m.sponsor_address = i.sender_address OR m.sender_address = i.sender_address)
END)
FROM mempool_txs m
INNER JOIN non_sponsored_inputs i ON m.nonce = i.nonce::int
AND (m.sponsor_address = i.sender_address OR m.sender_address = i.sender_address)
),
affected_mempool_tx_ids AS (
SELECT tx_id FROM affected_sponsored
UNION
SELECT tx_id FROM affected_non_sponsored
UNION
SELECT tx_id::bytea FROM input_data
),
Expand Down