feat(backend): create materialized views for staking pools (#614)

apps/api/src/services/kitwallet.ts

@@ -168,9 +168,7 @@ const pools = catchAsync(async (_req: Request, res: Response) => {
     SELECT
       account_id
     FROM
-      accounts
-    WHERE
-      account_id LIKE ANY (${POOLS})
+      staking_pools
   `;
 
   return res.status(200).json(pools.map(({ account_id }) => account_id));

apps/backend/migrations/20241108151848_staking_pools.js

@@ -0,0 +1,7 @@
+import { upSQL } from 'knex-migrate-sql-file';
+
+export async function up(knex) {
+  await upSQL(knex);
+}
+
+export function down() {}

apps/backend/migrations/20241108151848_staking_pools.up.sql

@@ -0,0 +1,17 @@
+CREATE MATERIALIZED VIEW staking_pools AS
+SELECT
+  account_id
+FROM
+  accounts
+WHERE
+  account_id LIKE ANY (
+    ARRAY[
+      '%.poolv1.near',
+      '%.pool.near',
+      '%.pool.%.m0',
+      '%.factory01.littlefarm.testnet',
+      '%.factory.colorpalette.testnet'
+    ]
+  );
+
+CREATE UNIQUE INDEX ON staking_pools (account_id);

apps/backend/src/jobs/refresh-views.ts

@@ -23,6 +23,14 @@ import sentry from '#libs/sentry';
     logger.error(error);
     await sleep(1000);
   }
+
+  try {
+    await knex.raw('REFRESH MATERIALIZED VIEW CONCURRENTLY staking_pools');
+  } catch (error) {
+    sentry.captureException(error);
+    logger.error(error);
+    await sleep(1000);
+  }
   logger.info({ action: 'job ended', job: 'refresh-views' });
 
   if (parentPort) {