chore(refactor): kebab-case /worker folder

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/server"); // Change as needed
 processFilesAndFolders(projectRoot);

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") {

src/server/index.ts

@@ -8,17 +8,17 @@ import { env } from "../shared/utils/env";
 import { logger } from "../shared/utils/logger";
 import { metricsServer } from "../shared/utils/prometheus";
 import { withServerUsageReporting } from "../shared/utils/usage";
-import { updateTxListener } from "./listeners/updateTxListener";
-import { withAdminRoutes } from "./middleware/adminRoutes";
+import { updateTxListener } from "./listeners/update-tx-listener";
+import { withAdminRoutes } from "./middleware/admin-routes";
 import { withAuth } from "./middleware/auth";
 import { withCors } from "./middleware/cors";
-import { withEnforceEngineMode } from "./middleware/engineMode";
+import { withEnforceEngineMode } from "./middleware/engine-mode";
 import { withErrorHandler } from "./middleware/error";
 import { withRequestLogs } from "./middleware/logs";
-import { withOpenApi } from "./middleware/openApi";
+import { withOpenApi } from "./middleware/open-api";
 import { withPrometheus } from "./middleware/prometheus";
-import { withRateLimit } from "./middleware/rateLimit";
-import { withSecurityHeaders } from "./middleware/securityHeaders";
+import { withRateLimit } from "./middleware/rate-limit";
+import { withSecurityHeaders } from "./middleware/security-headers";
 import { withWebSocket } from "./middleware/websocket";
 import { withRoutes } from "./routes";
 import { writeOpenApiToFile } from "./utils/openapi";

src/server/middleware/adminRoutes.ts → src/server/middleware/admin-routes.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";

src/server/middleware/auth.ts

@@ -24,8 +24,8 @@ import { env } from "../../shared/utils/env";
 import { logger } from "../../shared/utils/logger";
 import { sendWebhookRequest } from "../../shared/utils/webhook";
 import { Permission } from "../../shared/schemas/auth";
-import { ADMIN_QUEUES_BASEPATH } from "./adminRoutes";
-import { OPENAPI_ROUTES } from "./openApi";
+import { ADMIN_QUEUES_BASEPATH } from "./admin-routes";
+import { OPENAPI_ROUTES } from "./open-api";
 
 export type TAuthData = never;
 export type TAuthSession = { permissions: string };

src/server/middleware/cors.ts

@@ -1,6 +1,6 @@
 import type { FastifyInstance } from "fastify";
 import { getConfig } from "../../shared/utils/cache/get-config";
-import { ADMIN_QUEUES_BASEPATH } from "./adminRoutes";
+import { ADMIN_QUEUES_BASEPATH } from "./admin-routes";
 
 const STANDARD_METHODS = "GET,POST,DELETE,PUT,PATCH,HEAD,PUT,PATCH,POST,DELETE";
 const DEFAULT_ALLOWED_HEADERS = [

src/server/middleware/logs.ts

@@ -1,8 +1,8 @@
 import type { FastifyInstance } from "fastify";
 import { stringify } from "thirdweb/utils";
 import { logger } from "../../shared/utils/logger";
-import { ADMIN_QUEUES_BASEPATH } from "./adminRoutes";
-import { OPENAPI_ROUTES } from "./openApi";
+import { ADMIN_QUEUES_BASEPATH } from "./admin-routes";
+import { OPENAPI_ROUTES } from "./open-api";
 
 const SKIP_LOG_PATHS = new Set([
   "",

src/server/middleware/rateLimit.ts → src/server/middleware/rate-limit.ts

@@ -3,7 +3,7 @@ import { StatusCodes } from "http-status-codes";
 import { env } from "../../shared/utils/env";
 import { redis } from "../../shared/utils/redis/redis";
 import { createCustomError } from "./error";
-import { OPENAPI_ROUTES } from "./openApi";
+import { OPENAPI_ROUTES } from "./open-api";
 
 const SKIP_RATELIMIT_PATHS = ["/", ...OPENAPI_ROUTES];
 

src/server/routes/admin/nonces.ts

@@ -17,7 +17,7 @@ import { getChain } from "../../../shared/utils/chain";
 import { redis } from "../../../shared/utils/redis/redis";
 import { thirdwebClient } from "../../../shared/utils/sdk";
 import { AddressSchema } from "../../schemas/address";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 import { walletWithAddressParamSchema } from "../../schemas/wallet";
 
 export const responseBodySchema = Type.Object({

src/server/routes/admin/transaction.ts

@@ -7,10 +7,10 @@ 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";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 
 const requestSchema = Type.Object({
   queueId: Type.String({

src/server/routes/auth/access-tokens/create.ts

@@ -8,8 +8,8 @@ import { createToken } from "../../../../shared/db/tokens/create-token";
 import { accessTokenCache } from "../../../../shared/utils/cache/access-token";
 import { getConfig } from "../../../../shared/utils/cache/get-config";
 import { env } from "../../../../shared/utils/env";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
-import { AccessTokenSchema } from "./getAll";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
+import { AccessTokenSchema } from "./get-all";
 
 const requestBodySchema = Type.Object({
   label: Type.Optional(Type.String()),

src/server/routes/auth/access-tokens/getAll.ts → src/server/routes/auth/access-tokens/get-all.ts

@@ -3,7 +3,7 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { getAccessTokens } from "../../../../shared/db/tokens/get-access-tokens";
 import { AddressSchema } from "../../../schemas/address";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 export const AccessTokenSchema = Type.Object({
   id: Type.String(),

src/server/routes/auth/access-tokens/revoke.ts

@@ -3,7 +3,7 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { revokeToken } from "../../../../shared/db/tokens/revoke-token";
 import { accessTokenCache } from "../../../../shared/utils/cache/access-token";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const requestBodySchema = Type.Object({
   id: Type.String(),

src/server/routes/auth/access-tokens/update.ts

@@ -3,7 +3,7 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { updateToken } from "../../../../shared/db/tokens/update-token";
 import { accessTokenCache } from "../../../../shared/utils/cache/access-token";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const requestBodySchema = Type.Object({
   id: Type.String(),

src/server/routes/auth/keypair/add.ts

@@ -10,7 +10,7 @@ import {
   KeypairSchema,
   toKeypairSchema,
 } from "../../../../shared/schemas/keypair";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const requestBodySchema = Type.Object({
   publicKey: Type.String({

src/server/routes/auth/keypair/list.ts

@@ -6,7 +6,7 @@ import {
   KeypairSchema,
   toKeypairSchema,
 } from "../../../../shared/schemas/keypair";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const responseBodySchema = Type.Object({
   result: Type.Array(KeypairSchema),

src/server/routes/auth/keypair/remove.ts

@@ -3,7 +3,7 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { deleteKeypair } from "../../../../shared/db/keypair/delete";
 import { keypairCache } from "../../../../shared/utils/cache/keypair";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const requestBodySchema = Type.Object({
   hash: Type.String(),

src/server/routes/auth/permissions/getAll.ts → src/server/routes/auth/permissions/get-all.ts

@@ -3,7 +3,7 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { prisma } from "../../../../shared/db/client";
 import { AddressSchema } from "../../../schemas/address";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const responseBodySchema = Type.Object({
   result: Type.Array(

src/server/routes/auth/permissions/grant.ts

@@ -4,7 +4,7 @@ import { StatusCodes } from "http-status-codes";
 import { updatePermissions } from "../../../../shared/db/permissions/update-permissions";
 import { AddressSchema } from "../../../schemas/address";
 import { permissionsSchema } from "../../../../shared/schemas/auth";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const requestBodySchema = Type.Object({
   walletAddress: AddressSchema,

src/server/routes/auth/permissions/revoke.ts

@@ -3,7 +3,7 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import { deletePermissions } from "../../../../shared/db/permissions/delete-permissions";
 import { AddressSchema } from "../../../schemas/address";
-import { standardResponseSchema } from "../../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../../schemas/shared-api-schemas";
 
 const requestBodySchema = Type.Object({
   walletAddress: AddressSchema,

src/server/routes/backend-wallet/cancel-nonces.ts

@@ -9,7 +9,7 @@ import { sendCancellationTransaction } from "../../../shared/utils/transaction/c
 import {
   requestQuerystringSchema,
   standardResponseSchema,
-} from "../../schemas/sharedApiSchemas";
+} from "../../schemas/shared-api-schemas";
 import {
   walletChainParamSchema,
   walletHeaderSchema,

src/server/routes/backend-wallet/create.ts

@@ -10,21 +10,21 @@ import { WalletType } from "../../../shared/schemas/wallet";
 import { getConfig } from "../../../shared/utils/cache/get-config";
 import { createCustomError } from "../../middleware/error";
 import { AddressSchema } from "../../schemas/address";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 import {
   CreateAwsKmsWalletError,
   createAwsKmsWalletDetails,
-} from "../../utils/wallets/createAwsKmsWallet";
+} from "../../utils/wallets/create-aws-kms-wallet";
 import {
   CreateGcpKmsWalletError,
   createGcpKmsWalletDetails,
-} from "../../utils/wallets/createGcpKmsWallet";
-import { createLocalWalletDetails } from "../../utils/wallets/createLocalWallet";
+} from "../../utils/wallets/create-gcp-kms-wallet";
+import { createLocalWalletDetails } from "../../utils/wallets/create-local-wallet";
 import {
   createSmartAwsWalletDetails,
   createSmartGcpWalletDetails,
   createSmartLocalWalletDetails,
-} from "../../utils/wallets/createSmartWallet";
+} from "../../utils/wallets/create-smart-wallet";
 
 const requestBodySchema = Type.Object({
   label: Type.Optional(Type.String()),

src/server/routes/backend-wallet/getAll.ts → src/server/routes/backend-wallet/get-all.ts

@@ -5,7 +5,7 @@ import { getAllWallets } from "../../../shared/db/wallets/get-all-wallets";
 import {
   standardResponseSchema,
   walletDetailsSchema,
-} from "../../schemas/sharedApiSchemas";
+} from "../../schemas/shared-api-schemas";
 
 const QuerySchema = Type.Object({
   page: Type.Integer({

src/server/routes/backend-wallet/getBalance.ts → src/server/routes/backend-wallet/get-balance.ts

@@ -6,7 +6,7 @@ import { AddressSchema } from "../../schemas/address";
 import {
   currencyValueSchema,
   standardResponseSchema,
-} from "../../schemas/sharedApiSchemas";
+} from "../../schemas/shared-api-schemas";
 import { walletWithAddressParamSchema } from "../../schemas/wallet";
 import { getChainIdFromChain } from "../../utils/chain";
 

src/server/routes/backend-wallet/getNonce.ts → src/server/routes/backend-wallet/get-nonce.ts

@@ -3,7 +3,7 @@ import type { FastifyInstance } from "fastify";
 import { StatusCodes } from "http-status-codes";
 import type { Address } from "thirdweb";
 import { inspectNonce } from "../../../shared/db/wallets/wallet-nonce";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 import { walletWithAddressParamSchema } from "../../schemas/wallet";
 import { getChainIdFromChain } from "../../utils/chain";
 

src/server/routes/backend-wallet/getTransactionsByNonce.ts → src/server/routes/backend-wallet/get-transactions-by-nonce.ts

@@ -5,7 +5,7 @@ import { TransactionDB } from "../../../shared/db/transactions/db";
 import { getNonceMap } from "../../../shared/db/wallets/nonce-map";
 import { normalizeAddress } from "../../../shared/utils/primitive-types";
 import type { AnyTransaction } from "../../../shared/utils/transaction/types";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 import {
   TransactionSchema,
   toTransactionSchema,

src/server/routes/backend-wallet/getTransactions.ts → src/server/routes/backend-wallet/get-transactions.ts

@@ -4,7 +4,7 @@ import { StatusCodes } from "http-status-codes";
 import { getAddress } from "thirdweb";
 import { TransactionDB } from "../../../shared/db/transactions/db";
 import { PaginationSchema } from "../../schemas/pagination";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 import {
   TransactionSchema,
   toTransactionSchema,

src/server/routes/backend-wallet/import.ts

@@ -4,11 +4,11 @@ import { StatusCodes } from "http-status-codes";
 import { getConfig } from "../../../shared/utils/cache/get-config";
 import { createCustomError } from "../../middleware/error";
 import { AddressSchema } from "../../schemas/address";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
-import { getGcpKmsResourcePath } from "../../utils/wallets/gcpKmsResourcePath";
-import { importAwsKmsWallet } from "../../utils/wallets/importAwsKmsWallet";
-import { importGcpKmsWallet } from "../../utils/wallets/importGcpKmsWallet";
-import { importLocalWallet } from "../../utils/wallets/importLocalWallet";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
+import { getGcpKmsResourcePath } from "../../utils/wallets/gcp-kms-resource-path";
+import { importAwsKmsWallet } from "../../utils/wallets/import-aws-kms-wallet";
+import { importGcpKmsWallet } from "../../utils/wallets/import-gcp-kms-wallet";
+import { importLocalWallet } from "../../utils/wallets/import-local-wallet";
 
 const RequestBodySchema = Type.Intersect([
   Type.Object({

src/server/routes/backend-wallet/remove.ts

@@ -4,7 +4,7 @@ import { StatusCodes } from "http-status-codes";
 import type { Address } from "thirdweb";
 import { deleteWalletDetails } from "../../../shared/db/wallets/delete-wallet-details";
 import { AddressSchema } from "../../schemas/address";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 
 const requestParamSchema = Type.Object({
   walletAddress: AddressSchema,

src/server/routes/backend-wallet/reset-nonces.ts

@@ -8,7 +8,7 @@ import {
   syncLatestNonceFromOnchain,
 } from "../../../shared/db/wallets/wallet-nonce";
 import { AddressSchema } from "../../schemas/address";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
 
 const requestBodySchema = Type.Object({
   chainId: Type.Optional(

src/server/routes/backend-wallet/sendTransactionBatch.ts → src/server/routes/backend-wallet/send-transaction-batch.ts

@@ -4,14 +4,14 @@ import { StatusCodes } from "http-status-codes";
 import type { Address, Hex } from "thirdweb";
 import { insertTransaction } from "../../../shared/utils/transaction/insert-transaction";
 import { AddressSchema } from "../../schemas/address";
-import { standardResponseSchema } from "../../schemas/sharedApiSchemas";
-import { txOverridesWithValueSchema } from "../../schemas/txOverrides";
+import { standardResponseSchema } from "../../schemas/shared-api-schemas";
+import { txOverridesWithValueSchema } from "../../schemas/tx-overrides";
 import {
   walletChainParamSchema,
   walletHeaderSchema,
 } from "../../schemas/wallet";
 import { getChainIdFromChain } from "../../utils/chain";
-import { parseTransactionOverrides } from "../../utils/transactionOverrides";
+import { parseTransactionOverrides } from "../../utils/transaction-overrides";
 
 const requestBodySchema = Type.Array(
   Type.Object({

src/server/routes/backend-wallet/sendTransaction.ts → src/server/routes/backend-wallet/send-transaction.ts

@@ -8,15 +8,15 @@ import {
   requestQuerystringSchema,
   standardResponseSchema,
   transactionWritesResponseSchema,
-} from "../../schemas/sharedApiSchemas";
-import { txOverridesSchema } from "../../schemas/txOverrides";
+} from "../../schemas/shared-api-schemas";
+import { txOverridesSchema } from "../../schemas/tx-overrides";
 import {
   maybeAddress,
   walletChainParamSchema,
   walletWithAAHeaderSchema,
 } from "../../schemas/wallet";
 import { getChainIdFromChain } from "../../utils/chain";
-import { parseTransactionOverrides } from "../../utils/transactionOverrides";
+import { parseTransactionOverrides } from "../../utils/transaction-overrides";
 
 const requestBodySchema = Type.Object({
   toAddress: Type.Optional(AddressSchema),