remover opensearchMigrationClient

planetarium · Jan 2, 2025 · 51b662b · 51b662b
1 parent a449a05
commit 51b662b
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 54 deletions.
diff --git a/bridge/src/index.ts b/bridge/src/index.ts
@@ -97,9 +97,7 @@ process.on("uncaughtException", console.error);
   const SLACK_WEB_TOKEN: string = Configuration.get("SLACK_WEB_TOKEN");
   const FAILURE_SUBSCRIBERS: string = Configuration.get("FAILURE_SUBSCRIBERS");
   const OPENSEARCH_ENDPOINT: string = Configuration.get("OPENSEARCH_ENDPOINT");
-  const OPENSEARCH_ENDPOINT_MIGRATION: string = Configuration.get(
-    "OPENSEARCH_ENDPOINT_MIGRATION"
-  );
+
   const OPENSEARCH_AUTH: string = Configuration.get("OPENSEARCH_AUTH");
   const OPENSEARCH_INDEX: string =
     Configuration.get("OPENSEARCH_INDEX", false) || "9c-eth-bridge";
@@ -241,12 +239,6 @@ process.on("uncaughtException", console.error);
     OPENSEARCH_INDEX
   );
 
-  const opensearchMigrationClient = new OpenSearchClient(
-    OPENSEARCH_ENDPOINT_MIGRATION,
-    OPENSEARCH_AUTH,
-    OPENSEARCH_INDEX
-  );
-
   const GRAPHQL_REQUEST_RETRY = 5;
   const JWT_SECRET_KEY = Configuration.get("JWT_SECRET_KEY");
   const headlessGraphQLCLient = new HeadlessGraphQLClient(
@@ -352,8 +344,7 @@ process.on("uncaughtException", console.error);
     BSCSCAN_ROOT_URL,
     integration,
     multiPlanetary,
-    FAILURE_SUBSCRIBERS,
-    opensearchMigrationClient
+    FAILURE_SUBSCRIBERS
   );
   const ethereumBurnEventMonitor = new BscBurnEventMonitor(
     provider,

diff --git a/bridge/src/observers/burn-event-observer.ts b/bridge/src/observers/burn-event-observer.ts
@@ -37,7 +37,6 @@ export class BscBurnEventObserver
   private readonly _integration: Integration;
   private readonly _multiPlanetary: MultiPlanetary;
   private readonly _failureSubscribers: string;
-  private readonly _opensearchMigrationClient: OpenSearchClient;
 
   constructor(
     ncgTransfer: INCGTransfer,
@@ -52,8 +51,7 @@ export class BscBurnEventObserver
     etherscanUrl: string,
     integration: Integration,
     multiPlanetary: MultiPlanetary,
-    failureSubscribers: string,
-    opensearchMigrationClient: OpenSearchClient
+    failureSubscribers: string
   ) {
     this._ncgTransfer = ncgTransfer;
     this._slackMessageSender = slackMessageSender;
@@ -68,7 +66,6 @@ export class BscBurnEventObserver
     this._integration = integration;
     this._multiPlanetary = multiPlanetary;
     this._failureSubscribers = failureSubscribers;
-    this._opensearchMigrationClient = opensearchMigrationClient;
   }
 
   async notify(data: {
@@ -120,15 +117,6 @@ export class BscBurnEventObserver
           amount: amountString,
           network: "BSC",
         });
-        this._opensearchMigrationClient.to_opensearch("error", {
-          content: "wNCG -> NCG request failure",
-          cause: "Exchange history exist",
-          ethereumTxId: transactionHash,
-          sender: sender,
-          recipient: user9cAddress,
-          amount: amountString,
-          network: "BSC",
-        });
         continue;
       }
 
@@ -207,16 +195,6 @@ export class BscBurnEventObserver
           planetName: requestPlanetName,
           network: "BSC",
         });
-        await this._opensearchMigrationClient.to_opensearch("info", {
-          content: "wNCG -> NCG request success",
-          libplanetTxId: nineChroniclesTxId,
-          ethereumTxId: transactionHash,
-          sender: sender,
-          recipient: user9cAddress,
-          amount: amount.toNumber(),
-          planetName: requestPlanetName,
-          network: "BSC",
-        });
         console.log("Transferred", nineChroniclesTxId);
       } catch (e) {
         const slackMsgRes = await this._slackMessageSender.sendMessage(
@@ -261,16 +239,6 @@ export class BscBurnEventObserver
           planetName: requestPlanetName,
           network: "BSC",
         });
-        await this._opensearchMigrationClient.to_opensearch("error", {
-          content: "wNCG -> NCG request failure",
-          cause: String(e),
-          ethereumTxId: transactionHash,
-          sender: sender,
-          recipient: user9cAddress,
-          amount: amount.toNumber(),
-          planetName: requestPlanetName,
-          network: "BSC",
-        });
         await this._integration.error(
           "Unexpected error during unwrapping NCG",
           {

diff --git a/bridge/test/observers/burn-event-observer.spec.ts b/bridge/test/observers/burn-event-observer.spec.ts
@@ -73,14 +73,6 @@ describe(BscBurnEventObserver.name, () => {
     to_opensearch: ReturnType<typeof jest.fn>;
   };
 
-  const mockOpenSearchMigrationClient = new OpenSearchClient(
-    "https://www.random-url.com",
-    "auth",
-    "9c-eth-bridge"
-  ) as OpenSearchClient & {
-    to_opensearch: ReturnType<typeof jest.fn>;
-  };
-
   const mockMonitorStateStore: jest.Mocked<IMonitorStateStore> = {
     load: jest.fn(),
     store: jest.fn(),
@@ -158,8 +150,7 @@ describe(BscBurnEventObserver.name, () => {
     "https://ropsten.etherscan.io",
     mockIntegration,
     multiPlanetary,
-    failureSubscribers,
-    mockOpenSearchMigrationClient
+    failureSubscribers
   );
 
   describe(BscBurnEventObserver.prototype.notify.name, () => {