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: refresh materialized views concurrently in new pg format (#1324)

Browse Source
This commit is contained in:
Rafael Cárdenas
2022-09-20 16:18:20 -05:00
committed by GitHub
parent 4a9184a082
commit 20b284fa38
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/datastore/pg-write-store.ts
View File

@@ -134,9 +134,10 @@ export class PgWriteStore extends PgStore {
}
async getChainTip(
sql: PgSqlClient
sql: PgSqlClient,
useMaterializedView = true
): Promise<{ blockHeight: number; blockHash: string; indexBlockHash: string }> {
if (!this.isEventReplay) {
if (!this.isEventReplay && useMaterializedView) {
return super.getChainTip(sql);
}
// The `chain_tip` materialized view is not available during event replay.
@@ -188,7 +189,7 @@ export class PgWriteStore extends PgStore {
const tokenMetadataQueueEntries: DbTokenMetadataQueueEntry[] = [];
let garbageCollectedMempoolTxs: string[] = [];
await this.sql.begin(async sql => {
const chainTip = await this.getChainTip(sql);
const chainTip = await this.getChainTip(sql, false);
await this.handleReorg(sql, data.block, chainTip.blockHeight);
// If the incoming block is not of greater height than current chain tip, then store data as non-canonical.
const isCanonical = data.block.block_height > chainTip.blockHeight;
@@ -532,7 +533,7 @@ export class PgWriteStore extends PgStore {
// Sanity check: ensure incoming microblocks have a `parent_index_block_hash` that matches the API's
// current known canonical chain tip. We assume this holds true so incoming microblock data is always
// treated as being built off the current canonical anchor block.
const chainTip = await this.getChainTip(sql);
const chainTip = await this.getChainTip(sql, false);
const nonCanonicalMicroblock = data.microblocks.find(
mb => mb.parent_index_block_hash !== chainTip.indexBlockHash
);
@@ -1270,7 +1271,7 @@ export class PgWriteStore extends PgStore {
async updateMempoolTxs({ mempoolTxs: txs }: { mempoolTxs: DbMempoolTx[] }): Promise<void> {
const updatedTxs: DbMempoolTx[] = [];
await this.sql.begin(async sql => {
const chainTip = await this.getChainTip(sql);
const chainTip = await this.getChainTip(sql, false);
for (const tx of txs) {
const values: MempoolTxInsertValues = {
pruned: tx.pruned,
@@ -2441,7 +2442,7 @@ export class PgWriteStore extends PgStore {
if (this.isEventReplay && skipDuringEventReplay) {
return;
}
await sql`REFRESH MATERIALIZED VIEW ${sql(viewName)}`;
await sql`REFRESH MATERIALIZED VIEW ${isProdEnv ? sql`CONCURRENTLY` : sql``} ${sql(viewName)}`;
}
/**