chore(cleanup): remove v1 migration worker (#801)

* remove migrate postgres worker

* undo sdk

* lint

* lint

Author: arcoraven

src/index.ts

@@ -5,7 +5,6 @@ import { logger } from "./utils/logger";
 import "./utils/tracer";
 import { initWorker } from "./worker";
 import { CancelRecycledNoncesQueue } from "./worker/queues/cancelRecycledNoncesQueue";
-import { MigratePostgresTransactionsQueue } from "./worker/queues/migratePostgresTransactionsQueue";
 import { MineTransactionQueue } from "./worker/queues/mineTransactionQueue";
 import { NonceResyncQueue } from "./worker/queues/nonceResyncQueue";
 import { ProcessEventsLogQueue } from "./worker/queues/processEventLogsQueue";
@@ -69,7 +68,6 @@ const gracefulShutdown = async (signal: NodeJS.Signals) => {
   await MineTransactionQueue.q.close();
   await CancelRecycledNoncesQueue.q.close();
   await PruneTransactionsQueue.q.close();
-  await MigratePostgresTransactionsQueue.q.close();
   await NonceResyncQueue.q.close();
 
   process.exit(0);

src/server/middleware/adminRoutes.ts

@@ -7,7 +7,6 @@ import { StatusCodes } from "http-status-codes";
 import { timingSafeEqual } from "node:crypto";
 import { env } from "../../utils/env";
 import { CancelRecycledNoncesQueue } from "../../worker/queues/cancelRecycledNoncesQueue";
-import { MigratePostgresTransactionsQueue } from "../../worker/queues/migratePostgresTransactionsQueue";
 import { MineTransactionQueue } from "../../worker/queues/mineTransactionQueue";
 import { NonceHealthCheckQueue } from "../../worker/queues/nonceHealthCheckQueue";
 import { NonceResyncQueue } from "../../worker/queues/nonceResyncQueue";
@@ -30,7 +29,6 @@ const QUEUES: Queue[] = [
   MineTransactionQueue.q,
   CancelRecycledNoncesQueue.q,
   PruneTransactionsQueue.q,
-  MigratePostgresTransactionsQueue.q,
   NonceResyncQueue.q,
   NonceHealthCheckQueue.q,
 ];

src/worker/index.ts

@@ -8,7 +8,6 @@ import {
   updatedWebhooksListener,
 } from "./listeners/webhookListener";
 import { initCancelRecycledNoncesWorker } from "./tasks/cancelRecycledNoncesWorker";
-import { initMigratePostgresTransactionsWorker } from "./tasks/migratePostgresTransactionsWorker";
 import { initMineTransactionWorker } from "./tasks/mineTransactionWorker";
 import { initNonceHealthCheckWorker } from "./tasks/nonceHealthCheckWorker";
 import { initNonceResyncWorker } from "./tasks/nonceResyncWorker";
@@ -29,8 +28,6 @@ export const initWorker = async () => {
 
   initNonceHealthCheckWorker();
 
-  await initMigratePostgresTransactionsWorker();
-
   await initNonceResyncWorker();
 
   // Listen for new & updated configuration data.