chore(refactor): Rename /worker folder to kebab-case

arcoraven · arcoraven · commit b36a2adee5af · 2024-12-10T15:48:37.000+08:00
diff --git a/renamer.ts b/renamer.ts
@@ -141,5 +141,5 @@ function getAllFiles(rootDir: string, extensions: RegExp): string[] {
 }
 
 // Run the script
-const projectRoot = path.resolve("./src/shared/utils"); // Change as needed
+const projectRoot = path.resolve("./src/worker"); // Change as needed
 processFilesAndFolders(projectRoot);
diff --git a/src/index.ts b/src/index.ts
@@ -5,14 +5,14 @@ import { initServer } from "./server";
 import { env } from "./shared/utils/env";
 import { logger } from "./shared/utils/logger";
 import { initWorker } from "./worker";
-import { CancelRecycledNoncesQueue } from "./worker/queues/cancelRecycledNoncesQueue";
-import { MineTransactionQueue } from "./worker/queues/mineTransactionQueue";
-import { NonceResyncQueue } from "./worker/queues/nonceResyncQueue";
-import { ProcessEventsLogQueue } from "./worker/queues/processEventLogsQueue";
-import { ProcessTransactionReceiptsQueue } from "./worker/queues/processTransactionReceiptsQueue";
-import { PruneTransactionsQueue } from "./worker/queues/pruneTransactionsQueue";
-import { SendTransactionQueue } from "./worker/queues/sendTransactionQueue";
-import { SendWebhookQueue } from "./worker/queues/sendWebhookQueue";
+import { CancelRecycledNoncesQueue } from "./worker/queues/cancel-recycled-nonces-queue";
+import { MineTransactionQueue } from "./worker/queues/mine-transaction-queue";
+import { NonceResyncQueue } from "./worker/queues/nonce-resync-queue";
+import { ProcessEventsLogQueue } from "./worker/queues/process-event-logs-queue";
+import { ProcessTransactionReceiptsQueue } from "./worker/queues/process-transaction-receipts-queue";
+import { PruneTransactionsQueue } from "./worker/queues/prune-transactions-queue";
+import { SendTransactionQueue } from "./worker/queues/send-transaction-queue";
+import { SendWebhookQueue } from "./worker/queues/send-webhook-queue";
 
 const main = async () => {
   if (env.ENGINE_MODE === "server_only") {
diff --git a/src/server/middleware/adminRoutes.ts b/src/server/middleware/adminRoutes.ts
@@ -6,15 +6,15 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { timingSafeEqual } from "node:crypto";
 import { env } from "../../shared/utils/env";
-import { CancelRecycledNoncesQueue } from "../../worker/queues/cancelRecycledNoncesQueue";
-import { MineTransactionQueue } from "../../worker/queues/mineTransactionQueue";
-import { NonceHealthCheckQueue } from "../../worker/queues/nonceHealthCheckQueue";
-import { NonceResyncQueue } from "../../worker/queues/nonceResyncQueue";
-import { ProcessEventsLogQueue } from "../../worker/queues/processEventLogsQueue";
-import { ProcessTransactionReceiptsQueue } from "../../worker/queues/processTransactionReceiptsQueue";
-import { PruneTransactionsQueue } from "../../worker/queues/pruneTransactionsQueue";
-import { SendTransactionQueue } from "../../worker/queues/sendTransactionQueue";
-import { SendWebhookQueue } from "../../worker/queues/sendWebhookQueue";
+import { CancelRecycledNoncesQueue } from "../../worker/queues/cancel-recycled-nonces-queue";
+import { MineTransactionQueue } from "../../worker/queues/mine-transaction-queue";
+import { NonceHealthCheckQueue } from "../../worker/queues/nonce-health-check-queue";
+import { NonceResyncQueue } from "../../worker/queues/nonce-resync-queue";
+import { ProcessEventsLogQueue } from "../../worker/queues/process-event-logs-queue";
+import { ProcessTransactionReceiptsQueue } from "../../worker/queues/process-transaction-receipts-queue";
+import { PruneTransactionsQueue } from "../../worker/queues/prune-transactions-queue";
+import { SendTransactionQueue } from "../../worker/queues/send-transaction-queue";
+import { SendWebhookQueue } from "../../worker/queues/send-webhook-queue";
 
 export const ADMIN_QUEUES_BASEPATH = "/admin/queues";
 const ADMIN_ROUTES_USERNAME = "admin";
diff --git a/src/server/routes/admin/transaction.ts b/src/server/routes/admin/transaction.ts
@@ -7,8 +7,8 @@ import { TransactionDB } from "../../../shared/db/transactions/db";
 import { getConfig } from "../../../shared/utils/cache/get-config";
 import { maybeDate } from "../../../shared/utils/primitive-types";
 import { redis } from "../../../shared/utils/redis/redis";
-import { MineTransactionQueue } from "../../../worker/queues/mineTransactionQueue";
-import { SendTransactionQueue } from "../../../worker/queues/sendTransactionQueue";
+import { MineTransactionQueue } from "../../../worker/queues/mine-transaction-queue";
+import { SendTransactionQueue } from "../../../worker/queues/send-transaction-queue";
 import { createCustomError } from "../../middleware/error";
 import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
 
diff --git a/src/server/routes/system/queue.ts b/src/server/routes/system/queue.ts
@@ -4,8 +4,8 @@ import { StatusCodes } from "http-status-codes";
 import { TransactionDB } from "../../../shared/db/transactions/db";
 import { getPercentile } from "../../../shared/utils/math";
 import type { MinedTransaction } from "../../../shared/utils/transaction/types";
-import { MineTransactionQueue } from "../../../worker/queues/mineTransactionQueue";
-import { SendTransactionQueue } from "../../../worker/queues/sendTransactionQueue";
+import { MineTransactionQueue } from "../../../worker/queues/mine-transaction-queue";
+import { SendTransactionQueue } from "../../../worker/queues/send-transaction-queue";
 import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
 
 const responseBodySchema = Type.Object({
diff --git a/src/server/routes/transaction/cancel.ts b/src/server/routes/transaction/cancel.ts
@@ -10,7 +10,7 @@ import { sendCancellationTransaction } from "../../../shared/utils/transaction/c
 import type { CancelledTransaction } from "../../../shared/utils/transaction/types";
 import { enqueueTransactionWebhook } from "../../../shared/utils/transaction/webhook";
 import { reportUsage } from "../../../shared/utils/usage";
-import { SendTransactionQueue } from "../../../worker/queues/sendTransactionQueue";
+import { SendTransactionQueue } from "../../../worker/queues/send-transaction-queue";
 import { createCustomError } from "../../middleware/error";
 import { TransactionHashSchema } from "../../schemas/address";
 import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
diff --git a/src/server/routes/transaction/retry-failed.ts b/src/server/routes/transaction/retry-failed.ts
@@ -7,8 +7,8 @@ import {
   getReceiptForUserOp,
 } from "../../../shared/lib/transaction/get-transaction-receipt";
 import type { QueuedTransaction } from "../../../shared/utils/transaction/types";
-import { MineTransactionQueue } from "../../../worker/queues/mineTransactionQueue";
-import { SendTransactionQueue } from "../../../worker/queues/sendTransactionQueue";
+import { MineTransactionQueue } from "../../../worker/queues/mine-transaction-queue";
+import { SendTransactionQueue } from "../../../worker/queues/send-transaction-queue";
 import { createCustomError } from "../../middleware/error";
 import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
 
diff --git a/src/server/routes/transaction/retry.ts b/src/server/routes/transaction/retry.ts
@@ -4,7 +4,7 @@ import { StatusCodes } from "http-status-codes";
 import { TransactionDB } from "../../../shared/db/transactions/db";
 import { maybeBigInt } from "../../../shared/utils/primitive-types";
 import type { SentTransaction } from "../../../shared/utils/transaction/types";
-import { SendTransactionQueue } from "../../../worker/queues/sendTransactionQueue";
+import { SendTransactionQueue } from "../../../worker/queues/send-transaction-queue";
 import { createCustomError } from "../../middleware/error";
 import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
 
diff --git a/src/server/routes/transaction/sync-retry.ts b/src/server/routes/transaction/sync-retry.ts
@@ -14,7 +14,7 @@ import {
 import { thirdwebClient } from "../../../shared/utils/sdk";
 import type { SentTransaction } from "../../../shared/utils/transaction/types";
 import { enqueueTransactionWebhook } from "../../../shared/utils/transaction/webhook";
-import { MineTransactionQueue } from "../../../worker/queues/mineTransactionQueue";
+import { MineTransactionQueue } from "../../../worker/queues/mine-transaction-queue";
 import { createCustomError } from "../../middleware/error";
 import { TransactionHashSchema } from "../../schemas/address";
 import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
diff --git a/src/shared/utils/transaction/insert-transaction.ts b/src/shared/utils/transaction/insert-transaction.ts
@@ -8,7 +8,7 @@ import {
 } from "../../../shared/db/wallets/get-wallet-details";
 import { doesChainSupportService } from "../../lib/chain/chain-capabilities";
 import { createCustomError } from "../../../server/middleware/error";
-import { SendTransactionQueue } from "../../../worker/queues/sendTransactionQueue";
+import { SendTransactionQueue } from "../../../worker/queues/send-transaction-queue";
 import { getChecksumAddress } from "../primitive-types";
 import { recordMetrics } from "../prometheus";
 import { reportUsage } from "../usage";
diff --git a/src/shared/utils/transaction/webhook.ts b/src/shared/utils/transaction/webhook.ts
@@ -1,5 +1,5 @@
 import { WebhooksEventTypes } from "../../schemas/webhooks";
-import { SendWebhookQueue } from "../../../worker/queues/sendWebhookQueue";
+import { SendWebhookQueue } from "../../../worker/queues/send-webhook-queue";
 import type { AnyTransaction } from "./types";
 
 export const enqueueTransactionWebhook = async (
diff --git a/src/worker/index.ts b/src/worker/index.ts
@@ -1,21 +1,21 @@
-import { chainIndexerListener } from "./listeners/chainIndexerListener";
+import { chainIndexerListener } from "./listeners/chain-indexer-listener";
 import {
   newConfigurationListener,
   updatedConfigurationListener,
-} from "./listeners/configListener";
+} from "./listeners/config-listener";
 import {
   newWebhooksListener,
   updatedWebhooksListener,
-} from "./listeners/webhookListener";
-import { initCancelRecycledNoncesWorker } from "./tasks/cancelRecycledNoncesWorker";
-import { initMineTransactionWorker } from "./tasks/mineTransactionWorker";
-import { initNonceHealthCheckWorker } from "./tasks/nonceHealthCheckWorker";
-import { initNonceResyncWorker } from "./tasks/nonceResyncWorker";
-import { initProcessEventLogsWorker } from "./tasks/processEventLogsWorker";
-import { initProcessTransactionReceiptsWorker } from "./tasks/processTransactionReceiptsWorker";
-import { initPruneTransactionsWorker } from "./tasks/pruneTransactionsWorker";
-import { initSendTransactionWorker } from "./tasks/sendTransactionWorker";
-import { initSendWebhookWorker } from "./tasks/sendWebhookWorker";
+} from "./listeners/webhook-listener";
+import { initCancelRecycledNoncesWorker } from "./tasks/cancel-recycled-nonces-worker";
+import { initMineTransactionWorker } from "./tasks/mine-transaction-worker";
+import { initNonceHealthCheckWorker } from "./tasks/nonce-health-check-worker";
+import { initNonceResyncWorker } from "./tasks/nonce-resync-worker";
+import { initProcessEventLogsWorker } from "./tasks/process-event-logs-worker";
+import { initProcessTransactionReceiptsWorker } from "./tasks/process-transaction-receipts-worker";
+import { initPruneTransactionsWorker } from "./tasks/prune-transactions-worker";
+import { initSendTransactionWorker } from "./tasks/send-transaction-worker";
+import { initSendWebhookWorker } from "./tasks/send-webhook-worker";
 
 export const initWorker = async () => {
   initCancelRecycledNoncesWorker();
diff --git a/src/worker/indexers/chain-indexer-registry.ts b/src/worker/indexers/chain-indexer-registry.ts
@@ -1,7 +1,7 @@
 import cron from "node-cron";
 import { getBlockTimeSeconds } from "../../shared/utils/indexer/get-block-time";
 import { logger } from "../../shared/utils/logger";
-import { handleContractSubscriptions } from "../tasks/chainIndexer";
+import { handleContractSubscriptions } from "../tasks/chain-indexer";
 
 // @TODO: Move all worker logic to Bullmq to better handle multiple hosts.
 export const INDEXER_REGISTRY = {} as Record<number, cron.ScheduledTask>;
diff --git a/src/worker/listeners/chain-indexer-listener.ts b/src/worker/listeners/chain-indexer-listener.ts
@@ -1,7 +1,7 @@
 import cron from "node-cron";
 import { getConfig } from "../../shared/utils/cache/get-config";
 import { logger } from "../../shared/utils/logger";
-import { manageChainIndexers } from "../tasks/manageChainIndexers";
+import { manageChainIndexers } from "../tasks/manage-chain-indexers";
 
 let processChainIndexerStarted = false;
 let task: cron.ScheduledTask;
diff --git a/src/worker/listeners/config-listener.ts b/src/worker/listeners/config-listener.ts
@@ -2,7 +2,7 @@ import { knex } from "../../shared/db/client";
 import { getConfig } from "../../shared/utils/cache/get-config";
 import { clearCacheCron } from "../../shared/utils/cron/clear-cache-cron";
 import { logger } from "../../shared/utils/logger";
-import { chainIndexerListener } from "./chainIndexerListener";
+import { chainIndexerListener } from "./chain-indexer-listener";
 
 export const newConfigurationListener = async (): Promise<void> => {
   logger({
diff --git a/src/worker/listeners/webhook-listener.ts b/src/worker/listeners/webhook-listener.ts
diff --git a/src/worker/queues/cancel-recycled-nonces-queue.ts b/src/worker/queues/cancel-recycled-nonces-queue.ts
diff --git a/src/worker/queues/mine-transaction-queue.ts b/src/worker/queues/mine-transaction-queue.ts
diff --git a/src/worker/queues/nonce-health-check-queue.ts b/src/worker/queues/nonce-health-check-queue.ts
diff --git a/src/worker/queues/nonce-resync-queue.ts b/src/worker/queues/nonce-resync-queue.ts
diff --git a/src/worker/queues/process-event-logs-queue.ts b/src/worker/queues/process-event-logs-queue.ts
diff --git a/src/worker/queues/process-transaction-receipts-queue.ts b/src/worker/queues/process-transaction-receipts-queue.ts
diff --git a/src/worker/queues/prune-transactions-queue.ts b/src/worker/queues/prune-transactions-queue.ts
diff --git a/src/worker/queues/send-transaction-queue.ts b/src/worker/queues/send-transaction-queue.ts
diff --git a/src/worker/queues/send-webhook-queue.ts b/src/worker/queues/send-webhook-queue.ts
diff --git a/src/worker/tasks/cancel-recycled-nonces-worker.ts b/src/worker/tasks/cancel-recycled-nonces-worker.ts
@@ -5,7 +5,7 @@ import { isNonceAlreadyUsedError } from "../../shared/utils/error";
 import { logger } from "../../shared/utils/logger";
 import { redis } from "../../shared/utils/redis/redis";
 import { sendCancellationTransaction } from "../../shared/utils/transaction/cancel-transaction";
-import { CancelRecycledNoncesQueue } from "../queues/cancelRecycledNoncesQueue";
+import { CancelRecycledNoncesQueue } from "../queues/cancel-recycled-nonces-queue";
 import { logWorkerExceptions } from "../queues/queues";
 
 // Must be explicitly called for the worker to run on this host.
diff --git a/src/worker/tasks/chain-indexer.ts b/src/worker/tasks/chain-indexer.ts
@@ -11,8 +11,8 @@ import { getContractSubscriptionsByChainId } from "../../shared/db/contract-subs
 import { getChain } from "../../shared/utils/chain";
 import { logger } from "../../shared/utils/logger";
 import { thirdwebClient } from "../../shared/utils/sdk";
-import { ProcessEventsLogQueue } from "../queues/processEventLogsQueue";
-import { ProcessTransactionReceiptsQueue } from "../queues/processTransactionReceiptsQueue";
+import { ProcessEventsLogQueue } from "../queues/process-event-logs-queue";
+import { ProcessTransactionReceiptsQueue } from "../queues/process-transaction-receipts-queue";
 
 // A reasonable block range that is within RPC limits.
 // The minimum job time is 1 second, so this value should higher than the # blocks per second
diff --git a/src/worker/tasks/manage-chain-indexers.ts b/src/worker/tasks/manage-chain-indexers.ts
@@ -3,7 +3,7 @@ import {
   INDEXER_REGISTRY,
   addChainIndexer,
   removeChainIndexer,
-} from "../indexers/chainIndexerRegistry";
+} from "../indexers/chain-indexer-registry";
 
 export const manageChainIndexers = async () => {
   const chainIdsToIndex = await getContractSubscriptionsUniqueChainIds();
diff --git a/src/worker/tasks/mine-transaction-worker.ts b/src/worker/tasks/mine-transaction-worker.ts
@@ -41,9 +41,9 @@ import { reportUsage } from "../../shared/utils/usage";
 import {
   MineTransactionQueue,
   type MineTransactionData,
-} from "../queues/mineTransactionQueue";
-import { SendTransactionQueue } from "../queues/sendTransactionQueue";
-import { SendWebhookQueue } from "../queues/sendWebhookQueue";
+} from "../queues/mine-transaction-queue";
+import { SendTransactionQueue } from "../queues/send-transaction-queue";
+import { SendWebhookQueue } from "../queues/send-webhook-queue";
 
 /**
  * Check if the submitted transaction or userOp is mined onchain.
diff --git a/src/worker/tasks/nonce-health-check-worker.ts b/src/worker/tasks/nonce-health-check-worker.ts
@@ -7,7 +7,7 @@ import {
 import { getLastUsedOnchainNonce } from "../../server/routes/admin/nonces";
 import { logger } from "../../shared/utils/logger";
 import { redis } from "../../shared/utils/redis/redis";
-import { NonceHealthCheckQueue } from "../queues/nonceHealthCheckQueue";
+import { NonceHealthCheckQueue } from "../queues/nonce-health-check-queue";
 import { logWorkerExceptions } from "../queues/queues";
 
 // Configuration
diff --git a/src/worker/tasks/nonce-resync-worker.ts b/src/worker/tasks/nonce-resync-worker.ts
@@ -12,7 +12,7 @@ import { prettifyError } from "../../shared/utils/error";
 import { logger } from "../../shared/utils/logger";
 import { redis } from "../../shared/utils/redis/redis";
 import { thirdwebClient } from "../../shared/utils/sdk";
-import { NonceResyncQueue } from "../queues/nonceResyncQueue";
+import { NonceResyncQueue } from "../queues/nonce-resync-queue";
 import { logWorkerExceptions } from "../queues/queues";
 
 // Must be explicitly called for the worker to run on this host.
diff --git a/src/worker/tasks/process-event-logs-worker.ts b/src/worker/tasks/process-event-logs-worker.ts
@@ -26,9 +26,9 @@ import { thirdwebClient } from "../../shared/utils/sdk";
 import {
   type EnqueueProcessEventLogsData,
   ProcessEventsLogQueue,
-} from "../queues/processEventLogsQueue";
+} from "../queues/process-event-logs-queue";
 import { logWorkerExceptions } from "../queues/queues";
-import { SendWebhookQueue } from "../queues/sendWebhookQueue";
+import { SendWebhookQueue } from "../queues/send-webhook-queue";
 
 const handler: Processor<any, void, string> = async (job: Job<string>) => {
   const {
diff --git a/src/worker/tasks/process-transaction-receipts-worker.ts b/src/worker/tasks/process-transaction-receipts-worker.ts
@@ -22,10 +22,10 @@ import { thirdwebClient } from "../../shared/utils/sdk";
 import {
   ProcessTransactionReceiptsQueue,
   type EnqueueProcessTransactionReceiptsData,
-} from "../queues/processTransactionReceiptsQueue";
+} from "../queues/process-transaction-receipts-queue";
 import { logWorkerExceptions } from "../queues/queues";
-import { SendWebhookQueue } from "../queues/sendWebhookQueue";
-import { getWebhooksByContractAddresses } from "./processEventLogsWorker";
+import { SendWebhookQueue } from "../queues/send-webhook-queue";
+import { getWebhooksByContractAddresses } from "./process-event-logs-worker";
 
 const handler: Processor<any, void, string> = async (job: Job<string>) => {
   const {
diff --git a/src/worker/tasks/prune-transactions-worker.ts b/src/worker/tasks/prune-transactions-worker.ts
@@ -3,7 +3,7 @@ import { TransactionDB } from "../../shared/db/transactions/db";
 import { pruneNonceMaps } from "../../shared/db/wallets/nonce-map";
 import { env } from "../../shared/utils/env";
 import { redis } from "../../shared/utils/redis/redis";
-import { PruneTransactionsQueue } from "../queues/pruneTransactionsQueue";
+import { PruneTransactionsQueue } from "../queues/prune-transactions-queue";
 import { logWorkerExceptions } from "../queues/queues";
 
 const handler: Processor<any, void, string> = async (job: Job<string>) => {
diff --git a/src/worker/tasks/send-transaction-worker.ts b/src/worker/tasks/send-transaction-worker.ts
@@ -52,12 +52,12 @@ import type {
 } from "../../shared/utils/transaction/types";
 import { enqueueTransactionWebhook } from "../../shared/utils/transaction/webhook";
 import { reportUsage } from "../../shared/utils/usage";
-import { MineTransactionQueue } from "../queues/mineTransactionQueue";
+import { MineTransactionQueue } from "../queues/mine-transaction-queue";
 import { logWorkerExceptions } from "../queues/queues";
 import {
   SendTransactionQueue,
   type SendTransactionData,
-} from "../queues/sendTransactionQueue";
+} from "../queues/send-transaction-queue";
 
 /**
  * Submit a transaction to RPC (EOA transactions) or bundler (userOps).
diff --git a/src/worker/tasks/send-webhook-worker.ts b/src/worker/tasks/send-webhook-worker.ts
@@ -18,7 +18,7 @@ import {
   sendWebhookRequest,
   type WebhookResponse,
 } from "../../shared/utils/webhook";
-import { SendWebhookQueue, type WebhookJob } from "../queues/sendWebhookQueue";
+import { SendWebhookQueue, type WebhookJob } from "../queues/send-webhook-queue";
 
 const handler: Processor<any, void, string> = async (job: Job<string>) => {
   const { data, webhook } = superjson.parse<WebhookJob>(job.data);

Original file line number	Diff line number	Diff line change
`@@ -141,5 +141,5 @@ function getAllFiles(rootDir: string, extensions: RegExp): string[] {`
`141`	`141`	`}`
`142`	`142`
`143`	`143`	`// Run the script`
`144`		`-const projectRoot = path.resolve("./src/shared/utils"); // Change as needed`
	`144`	`+const projectRoot = path.resolve("./src/worker"); // Change as needed`
`145`	`145`	`processFilesAndFolders(projectRoot);`