Merge pull request #99 from UniqueNetwork/release/v1.6.3

Release/v1.6.3

Author: sswebcoder

lib/blockDB.js

@@ -48,6 +48,7 @@ async function save({
     'total_issuance',
     'timestamp',
     'need_rescan',
+    'total_extrinsics',
   ],
   transaction = null,
 }) {
@@ -78,6 +79,7 @@ async function save({
         new_accounts: block.newAccounts,
         total_issuance: block.totalIssuance,
         timestamp: block.timestamp,
+        total_extrinsics: block.extrinsics?.length,
         need_rescan: false,
       },
       transaction,

sequelize/migrations/20220602130519-block_add_total_extrinsics.js

@@ -0,0 +1,14 @@
+'use strict';
+
+module.exports = {
+  async up (queryInterface, Sequelize) {
+    await queryInterface.addColumn('block', 'total_extrinsics', {
+      type: Sequelize.DataTypes.INTEGER,
+      allowNull: true,
+    });
+  },
+
+  async down (queryInterface, Sequelize) {
+    await queryInterface.removeColumn('block', 'total_extrinsics');
+  },
+};

sequelize/migrations/20220602132501-block_update_total_extrinsics.js

@@ -0,0 +1,36 @@
+'use strict';
+
+module.exports = {
+  async up (queryInterface, Sequelize) {
+    const transaction = await queryInterface.sequelize.transaction();
+
+    try {
+      await queryInterface.sequelize.query(
+        `update block b
+          set total_extrinsics = (select count(*) from extrinsic e where e.block_number = b.block_number);
+        `,
+        { transaction },
+      );
+
+      await queryInterface.changeColumn(
+        'block',
+        'total_extrinsics',
+        {
+          type: Sequelize.DataTypes.INTEGER,
+          defaultValue: 0,
+        },
+        {
+          transaction,
+        },
+      );
+
+      await transaction.commit();
+    } catch (err) {
+      console.error(err);
+      await transaction.rollback();
+      throw err;
+    }
+  },
+
+  async down (queryInterface, Sequelize) {},
+};

sequelize/migrations/20220602135324-alter_view_last_block.js

@@ -0,0 +1,53 @@
+'use strict';
+
+module.exports = {
+  async up (queryInterface, Sequelize) {
+    const transaction = await queryInterface.sequelize.transaction();
+
+    try {
+      await queryInterface.sequelize.query(`DROP VIEW public.view_last_block;`, { transaction });
+
+      await queryInterface.sequelize.query(`
+      CREATE OR REPLACE VIEW public.view_last_block
+      AS SELECT block.block_number,
+        block.total_events AS event_count,
+        block.total_extrinsics AS extrinsic_count,
+        block."timestamp"
+      FROM block
+      ORDER BY block.block_number DESC;
+      `, { transaction });
+
+      await transaction.commit();
+    } catch (err) {
+      console.error(err);
+      await transaction.rollback();
+      throw err;
+    }
+  },
+
+  async down(queryInterface, Sequelize) {
+    const transaction = await queryInterface.sequelize.transaction();
+
+    try {
+      await queryInterface.sequelize.query(`DROP VIEW public.view_last_block;`, { transaction });
+
+      await queryInterface.sequelize.query(`
+        CREATE OR REPLACE VIEW public.view_last_block
+        AS SELECT block.block_number,
+            vceb.count_block_number AS event_count,
+            v.count_extrinsic AS extrinsic_count,
+            block."timestamp"
+          FROM block
+            LEFT JOIN view_count_event_block vceb ON block.block_number = vceb.block_number
+            LEFT JOIN view_count_extrinsic_block v ON block.block_number = v.block_number
+          ORDER BY block.block_number DESC;
+      `, { transaction });
+
+      await transaction.commit();
+    } catch (err) {
+      console.error(err);
+      await transaction.rollback();
+      throw err;
+    }
+  },
+};

sequelize/migrations/20220606065033-alter_view_last_block_optimization.js

@@ -0,0 +1,50 @@
+'use strict';
+
+module.exports = {
+  async up (queryInterface, Sequelize) {
+    const transaction = await queryInterface.sequelize.transaction();
+
+    try {
+      await queryInterface.sequelize.query(`DROP VIEW public.view_last_block;`, { transaction });
+
+      await queryInterface.sequelize.query(`
+      CREATE OR REPLACE VIEW public.view_last_block
+      AS SELECT block.block_number,
+        block.total_events AS event_count,
+        block.total_extrinsics AS extrinsic_count,
+        block."timestamp"
+      FROM block;
+      `, { transaction });
+
+      await transaction.commit();
+    } catch (err) {
+      console.error(err);
+      await transaction.rollback();
+      throw err;
+    }
+  },
+
+  async down (queryInterface, Sequelize) {
+    const transaction = await queryInterface.sequelize.transaction();
+
+    try {
+      await queryInterface.sequelize.query(`DROP VIEW public.view_last_block;`, { transaction });
+
+      await queryInterface.sequelize.query(`
+      CREATE OR REPLACE VIEW public.view_last_block
+      AS SELECT block.block_number,
+        block.total_events AS event_count,
+        block.total_extrinsics AS extrinsic_count,
+        block."timestamp"
+      FROM block
+      ORDER BY block.block_number DESC;
+      `, { transaction });
+
+      await transaction.commit();
+    } catch (err) {
+      console.error(err);
+      await transaction.rollback();
+      throw err;
+    }
+  }
+};