fix: remove unneeded listeners that cleared caches (#884)

* fix: remove unneeded listeners that cleared caches

* lint

* remove websocket listener too, not functional since v2

Author: arcoraven

src/server/index.ts

@@ -8,7 +8,6 @@ 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/update-tx-listener";
 import { withAdminRoutes } from "./middleware/admin-routes";
 import { withAuth } from "./middleware/auth";
 import { withCors } from "./middleware/cors";
@@ -132,6 +131,5 @@ export const initServer = async () => {
   });
 
   writeOpenApiToFile(server);
-  await updateTxListener();
-  await clearCacheCron("server");
+  await clearCacheCron();
 };

src/server/listeners/update-tx-listener.ts

@@ -47,7 +47,7 @@ export async function updateCacheConfiguration(fastify: FastifyInstance) {
       await updateConfiguration({ ...req.body });
       const config = await getConfig(false);
       // restarting cache cron with updated cron schedule
-      await clearCacheCron("server");
+      await clearCacheCron();
       res.status(StatusCodes.OK).send({
         result: {
           clearCacheCronSchedule: config.clearCacheCronSchedule,

src/server/routes/configuration/cache/update.ts

@@ -1,14 +1,11 @@
-import type { env } from "../env";
 import { accessTokenCache } from "./access-token";
 import { invalidateConfig } from "./get-config";
 import { sdkCache } from "./get-sdk";
 import { walletsCache } from "./get-wallet";
 import { webhookCache } from "./get-webhook";
 import { keypairCache } from "./keypair";
 
-export const clearCache = async (
-  _service: (typeof env)["LOG_SERVICES"][0],
-): Promise<void> => {
+export const clearCache = async (): Promise<void> => {
   invalidateConfig();
   webhookCache.clear();
   sdkCache.clear();

src/shared/utils/cache/clear-cache.ts

@@ -1,13 +1,10 @@
 import { CronJob } from "cron";
 import { clearCache } from "../cache/clear-cache";
 import { getConfig } from "../cache/get-config";
-import type { env } from "../env";
 
 let task: CronJob;
 
-export const clearCacheCron = async (
-  service: (typeof env)["LOG_SERVICES"][0],
-) => {
+export const clearCacheCron = async () => {
   const config = await getConfig();
 
   if (!config.clearCacheCronSchedule) {
@@ -20,7 +17,7 @@ export const clearCacheCron = async (
   }
 
   task = new CronJob(config.clearCacheCronSchedule, async () => {
-    await clearCache(service);
+    await clearCache();
   });
   task.start();
 };

src/shared/utils/cron/clear-cache-cron.ts

@@ -1,12 +1,4 @@
 import { chainIndexerListener } from "./listeners/chain-indexer-listener";
-import {
-  newConfigurationListener,
-  updatedConfigurationListener,
-} from "./listeners/config-listener";
-import {
-  newWebhooksListener,
-  updatedWebhooksListener,
-} 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";
@@ -31,14 +23,6 @@ export const initWorker = async () => {
   await initNonceResyncWorker();
   await initWalletSubscriptionWorker();
 
-  // Listen for new & updated configuration data.
-  await newConfigurationListener();
-  await updatedConfigurationListener();
-
-  // Listen for new & updated webhooks data.
-  await newWebhooksListener();
-  await updatedWebhooksListener();
-
   // Contract subscriptions.
   await chainIndexerListener();
 };