chore: remove workers

packages/graphql/package.json

@@ -74,7 +74,6 @@
     "npm-run-all": "^4.1.5",
     "pg": "^8.11.5",
     "pg-boss": "9.0.3",
-    "piscina": "4.4.0",
     "pm2": "5.3.1",
     "shallow-equal-object": "1.1.1",
     "tai64": "^1.0.0",

packages/graphql/src/application/uc/RunTransactionsWorker.ts → packages/graphql/src/application/uc/AddTransactions.ts

@@ -11,12 +11,11 @@ import type { TransactionEntity } from '~/domain/Transaction/TransactionEntity';
 import { TransactionRepository } from '~/domain/Transaction/TransactionRepository';
 import type { GQLBlock } from '~/graphql/generated/sdk';
 import { db } from '~/infra/database/Db';
-import type { QueueData } from '~/infra/queue/Queue';
 import type { SyncTransactionEvent } from './SyncTransactions';
 
 type Input = SyncTransactionEvent[];
 
-export class RunTransactionsWorker {
+export class AddTransactions {
   async execute(input: Input) {
     await Promise.all(input.map((event) => this.syncTransaction(event)));
   }
@@ -135,11 +134,11 @@ export class RunTransactionsWorker {
   }
 }
 
-export const runTransactionsWorker = async ({ data }: QueueData<Input>) => {
+export const addTransactions = async (data: Input) => {
   await db.connect();
   try {
-    const syncTransactions = new RunTransactionsWorker();
-    await syncTransactions.execute(data);
+    const { execute } = new AddTransactions();
+    await execute(data);
   } catch (error) {
     console.error(error);
     throw new Error('Sync transactions', {

packages/graphql/src/application/uc/SyncTransactions.ts

@@ -2,7 +2,7 @@ import c from 'chalk';
 import { uniqBy } from 'lodash';
 import type { GQLBlock } from '~/graphql/generated/sdk';
 import type { QueueData, QueueInputs, QueueNames } from '~/infra/queue/Queue';
-import { pool } from '~/infra/worker/WorkerPool';
+import { addTransactions } from './AddTransactions';
 
 type Input = QueueInputs[QueueNames.SYNC_TRANSACTIONS];
 export type SyncTransactionEvent = {
@@ -28,7 +28,7 @@ export class SyncTransactions {
       const toBlock = blocks[blocks.length - 1].header.height;
       const msg = `# Syncing ${events.length} transactions from ${fromBlock} to ${toBlock}`;
       console.log(c.gray(msg));
-      await pool.run({ data: events });
+      await addTransactions(events);
     }
   }
 }

packages/graphql/src/domain/Block/BlockRepository.ts

@@ -12,6 +12,19 @@ import { BlockEntity } from './BlockEntity';
 import { type BlockItem, BlocksTable } from './BlockModel';
 
 export class BlockRepository {
+  async findByHash(blockHash: string) {
+    const first = await db.connection().query.BlocksTable.findFirst({
+      where: eq(BlocksTable.blockHash, blockHash),
+      with: {
+        transactions: true,
+      },
+    });
+
+    if (!first) return null;
+    const { transactions, ...block } = first;
+    return BlockEntity.create(block, transactions);
+  }
+
   async findByHeight(height: number) {
     const first = await db.connection().query.BlocksTable.findFirst({
       where: eq(BlocksTable._id, height),