chore: consolidate db migrations

src/migrations/1591291822107_mempool_txs.ts

@@ -90,6 +90,11 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
 
     // `coinbase` tx types
     coinbase_payload: 'bytea',
+    tx_size: {
+      type: 'integer',
+      notNull: true,
+      expressionGenerated: 'length(raw_tx)'
+    }
   });
 
   pgm.createIndex('mempool_txs', 'tx_id', { method: 'hash' });
@@ -100,6 +105,9 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
   pgm.createIndex('mempool_txs', 'sponsor_address', { method: 'hash' });
   pgm.createIndex('mempool_txs', 'token_transfer_recipient_address', { method: 'hash' });
   pgm.createIndex('mempool_txs', [{ name: 'receipt_time', sort: 'DESC' }]);
+  pgm.createIndex('mempool_txs', ['type_id', 'receipt_block_height'], { where: 'pruned = false'});
+  pgm.createIndex('mempool_txs', ['type_id', 'fee_rate'], { where: 'pruned = false'});
+  pgm.createIndex('mempool_txs', ['type_id', 'tx_size'], { where: 'pruned = false'});
 
   pgm.addConstraint('mempool_txs', 'unique_tx_id', `UNIQUE(tx_id)`);
 

src/migrations/1621511823100_token_metadata_queue.ts

@@ -28,6 +28,11 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
     processed: {
       type: 'boolean',
       notNull: true,
+    },
+    retry_count: {
+      type: 'integer',
+      notNull: true,
+      default: 0,
     }
   });
 

src/migrations/1636130197558_nft_custody.ts

@@ -26,5 +26,6 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
   `);
 
   pgm.createIndex('nft_custody', ['recipient', 'asset_identifier']);
-  pgm.createIndex('nft_custody', 'asset_identifier');
+  pgm.createIndex('nft_custody', ['asset_identifier', 'value'], { unique: true });
+  pgm.createIndex('nft_custody', 'value');
 }

src/migrations/1640037852136_nft_custody_unanchored.ts

@@ -30,5 +30,6 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
   `);
 
   pgm.createIndex('nft_custody_unanchored', ['recipient', 'asset_identifier']);
-  pgm.createIndex('nft_custody_unanchored', 'asset_identifier');
+  pgm.createIndex('nft_custody_unanchored', ['asset_identifier', 'value'], { unique: true });
+  pgm.createIndex('nft_custody_unanchored', 'value');
 }

src/migrations/1643755236533_chain_tip.ts

@@ -40,5 +40,8 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
     LEFT JOIN microblock_count ON TRUE
     LEFT JOIN tx_count ON TRUE
     LEFT JOIN tx_count_unanchored ON TRUE
+    LIMIT 1
   `);
+
+  pgm.createIndex('chain_tip', 'block_height', { unique: true });
 }

src/migrations/1647573802137_mempool_digest.ts

@@ -31,8 +31,11 @@ export async function up(pgm: MigrationBuilder): Promise<void> {
     // extension which might not be possible for some users.
     pgm.createMaterializedView('mempool_digest', {}, `SELECT NULL AS digest`);
   }
+
+  pgm.createIndex('mempool_digest', 'digest', { unique: true });
 }
 
 export async function down(pgm: MigrationBuilder): Promise<void> {
+  pgm.dropIndex('mempool_digest', 'digest', { unique: true, ifExists: true });
   pgm.dropMaterializedView('mempool_digest');
 }