kylefang/stacks-blockchain-api
1
0
Fork 0
mirror of https://github.com/alexgo-io/stacks-blockchain-api.git synced 2026-01-12 22:43:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: consolidate latest_conrtact_txs materialized view into one migration

Browse Source
This commit is contained in:
Rafael Cárdenas
2021-12-16 10:31:38 -06:00
committed by GitHub
parent fbe2337b88
commit 949a96d3fa
2 changed files with 16 additions and 147 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/migrations/1636741389602_latest_contract_txs.ts
View File

@@ -48,10 +48,25 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
PARTITION BY contract_id
ORDER BY block_height DESC, microblock_sequence DESC, tx_index DESC
) AS r,
COUNT(*) OVER (
PARTITION BY contract_id
)::integer AS count,
contract_txs.*
FROM contract_txs
)
SELECT numbered_txs.contract_id, txs.*
SELECT
numbered_txs.contract_id,
txs.*,
CASE
WHEN txs.type_id = 2 THEN (
SELECT abi
FROM smart_contracts
WHERE smart_contracts.contract_id = txs.contract_call_contract_id
ORDER BY abi != 'null' DESC, canonical DESC, microblock_canonical DESC, block_height DESC
LIMIT 1
)
END as abi,
numbered_txs.count
FROM numbered_txs
INNER JOIN txs USING (tx_id)
WHERE numbered_txs.r <= 50

146
src/migrations/1639152689764_latest_contract_txs_abi.ts
View File

@@ -1,146 +0,0 @@
/* eslint-disable @typescript-eslint/camelcase */
import { MigrationBuilder, ColumnDefinitions } from 'node-pg-migrate';
export const shorthands: ColumnDefinitions | undefined = undefined;
export async function up(pgm: MigrationBuilder): Promise<void> {
pgm.dropMaterializedView('latest_contract_txs', { ifExists: true, cascade: true });
pgm.createMaterializedView('latest_contract_txs', {}, `
WITH contract_txs AS (
SELECT
contract_call_contract_id AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
contract_call_contract_id IS NOT NULL
AND canonical = TRUE
AND microblock_canonical = TRUE
UNION
SELECT
smart_contract_contract_id AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
smart_contract_contract_id IS NOT NULL
AND canonical = TRUE
AND microblock_canonical = TRUE
UNION
SELECT
sender_address AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
sender_address LIKE '%.%'
AND canonical = TRUE
AND microblock_canonical = TRUE
UNION
SELECT
token_transfer_recipient_address AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
token_transfer_recipient_address LIKE '%.%'
AND canonical = TRUE
AND microblock_canonical = TRUE
),
numbered_txs AS (
SELECT
ROW_NUMBER() OVER (
PARTITION BY contract_id
ORDER BY block_height DESC, microblock_sequence DESC, tx_index DESC
) AS r,
COUNT(*) OVER (
PARTITION BY contract_id
)::integer AS count,
contract_txs.*
FROM contract_txs
)
SELECT
numbered_txs.contract_id,
txs.*,
CASE
WHEN txs.type_id = 2 THEN (
SELECT abi
FROM smart_contracts
WHERE smart_contracts.contract_id = txs.contract_call_contract_id
ORDER BY abi != 'null' DESC, canonical DESC, microblock_canonical DESC, block_height DESC
LIMIT 1
)
END as abi,
numbered_txs.count
FROM numbered_txs
INNER JOIN txs USING (tx_id)
WHERE numbered_txs.r <= 50
`);
pgm.createIndex('latest_contract_txs', 'contract_id');
pgm.createIndex('latest_contract_txs', [
{ name: 'block_height', sort: 'DESC' },
{ name: 'microblock_sequence', sort: 'DESC'},
{ name: 'tx_index', sort: 'DESC' }
]);
}
export async function down(pgm: MigrationBuilder): Promise<void> {
// Go back to the previous materialized view version, otherwise `pgm` complains it can't infer the down migration.
pgm.dropMaterializedView('latest_contract_txs', { ifExists: true, cascade: true });
pgm.createMaterializedView('latest_contract_txs', {}, `
WITH contract_txs AS (
SELECT
contract_call_contract_id AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
contract_call_contract_id IS NOT NULL
AND canonical = TRUE
AND microblock_canonical = TRUE
UNION
SELECT
smart_contract_contract_id AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
smart_contract_contract_id IS NOT NULL
AND canonical = TRUE
AND microblock_canonical = TRUE
UNION
SELECT
sender_address AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
sender_address LIKE '%.%'
AND canonical = TRUE
AND microblock_canonical = TRUE
UNION
SELECT
token_transfer_recipient_address AS contract_id, tx_id,
block_height, microblock_sequence, tx_index
FROM txs
WHERE
token_transfer_recipient_address LIKE '%.%'
AND canonical = TRUE
AND microblock_canonical = TRUE
),
numbered_txs AS (
SELECT
ROW_NUMBER() OVER (
PARTITION BY contract_id
ORDER BY block_height DESC, microblock_sequence DESC, tx_index DESC
) AS r,
contract_txs.*
FROM contract_txs
)
SELECT numbered_txs.contract_id, txs.*
FROM numbered_txs
INNER JOIN txs USING (tx_id)
WHERE numbered_txs.r <= 50
`);
pgm.createIndex('latest_contract_txs', 'contract_id');
pgm.createIndex('latest_contract_txs', [
{ name: 'block_height', sort: 'DESC' },
{ name: 'microblock_sequence', sort: 'DESC'},
{ name: 'tx_index', sort: 'DESC' }
]);
}