chore: run turbo fix

This commit fixes formatting & linting issues caused by reconfiguring prettier &
eslint in the prior commit

Author: cprussin

apps/hermes/client/js/src/HermesClient.ts

@@ -63,7 +63,7 @@ export class HermesClient {
     schema: z.ZodSchema<ResponseData>,
     options?: RequestInit,
     retries = this.httpRetries,
-    backoff = 100 + Math.floor(Math.random() * 100) // Adding randomness to the initial backoff to avoid "thundering herd" scenario where a lot of clients that get kicked off all at the same time (say some script or something) and fail to connect all retry at exactly the same time too
+    backoff = 100 + Math.floor(Math.random() * 100), // Adding randomness to the initial backoff to avoid "thundering herd" scenario where a lot of clients that get kicked off all at the same time (say some script or something) and fail to connect all retry at exactly the same time too
   ): Promise<ResponseData> {
     try {
       const response = await fetch(url, {
@@ -79,7 +79,7 @@ export class HermesClient {
         throw new Error(
           `HTTP error! status: ${response.status}${
             errorBody ? `, body: ${errorBody}` : ""
-          }`
+          }`,
         );
       }
       const data = await response.json();
@@ -124,7 +124,7 @@ export class HermesClient {
     return await this.httpRequest(
       url.toString(),
       schemas.PriceFeedMetadata.array(),
-      fetchOptions
+      fetchOptions,
     );
   }
 
@@ -154,7 +154,7 @@ export class HermesClient {
     return await this.httpRequest(
       url.toString(),
       schemas.LatestPublisherStakeCapsUpdateDataResponse,
-      fetchOptions
+      fetchOptions,
     );
   }
 
@@ -178,7 +178,7 @@ export class HermesClient {
       parsed?: boolean;
       ignoreInvalidPriceIds?: boolean;
     },
-    fetchOptions?: RequestInit
+    fetchOptions?: RequestInit,
   ): Promise<PriceUpdate> {
     const url = this.buildURL("updates/price/latest");
     for (const id of ids) {
@@ -215,7 +215,7 @@ export class HermesClient {
       parsed?: boolean;
       ignoreInvalidPriceIds?: boolean;
     },
-    fetchOptions?: RequestInit
+    fetchOptions?: RequestInit,
   ): Promise<PriceUpdate> {
     const url = this.buildURL(`updates/price/${publishTime}`);
     for (const id of ids) {
@@ -255,7 +255,7 @@ export class HermesClient {
       allowUnordered?: boolean;
       benchmarksOnly?: boolean;
       ignoreInvalidPriceIds?: boolean;
-    }
+    },
   ): Promise<EventSource> {
     const url = this.buildURL("updates/price/stream");
     ids.forEach((id) => {
@@ -302,7 +302,7 @@ export class HermesClient {
       parsed?: boolean;
       ignoreInvalidPriceIds?: boolean;
     },
-    fetchOptions?: RequestInit
+    fetchOptions?: RequestInit,
   ): Promise<TwapsResponse> {
     const url = this.buildURL(`updates/twap/${window_seconds}/latest`);
     for (const id of ids) {
@@ -317,13 +317,13 @@ export class HermesClient {
     return this.httpRequest(
       url.toString(),
       schemas.TwapsResponse,
-      fetchOptions
+      fetchOptions,
     );
   }
 
   private appendUrlSearchParams(
     url: URL,
-    params: Record<string, string | boolean>
+    params: Record<string, string | boolean>,
   ) {
     Object.entries(params).forEach(([key, value]) => {
       if (value !== undefined) {
@@ -337,7 +337,7 @@ export class HermesClient {
       `./v2/${endpoint}`,
       // We ensure the `baseURL` ends with a `/` so that URL doesn't resolve the
       // path relative to the parent.
-      `${this.baseURL}${this.baseURL.endsWith("/") ? "" : "/"}`
+      `${this.baseURL}${this.baseURL.endsWith("/") ? "" : "/"}`,
     );
   }
 }

apps/hermes/client/js/src/examples/HermesClient.ts

@@ -43,7 +43,7 @@ function extractBasicAuthorizationHeadersFromUrl(urlString: string): {
 
   if (url.username && url.password) {
     headers["Authorization"] = `Basic ${btoa(
-      `${url.username}:${url.password}`
+      `${url.username}:${url.password}`,
     )}`;
     url.username = "";
     url.password = "";
@@ -54,7 +54,7 @@ function extractBasicAuthorizationHeadersFromUrl(urlString: string): {
 
 async function run() {
   const { endpoint, headers } = extractBasicAuthorizationHeadersFromUrl(
-    argv.endpoint
+    argv.endpoint,
   );
   const connection = new HermesClient(endpoint, { headers });
 

apps/hermes/client/js/src/utils.ts

@@ -3,7 +3,7 @@ function camelToSnakeCase(str: string): string {
 }
 
 export function camelToSnakeCaseObject(
-  obj: Record<string, string | boolean>
+  obj: Record<string, string | boolean>,
 ): Record<string, string | boolean> {
   const result: Record<string, string | boolean> = {};
   Object.keys(obj).forEach((key) => {

apps/price_pusher/src/aptos/aptos.ts

@@ -17,7 +17,7 @@ export class AptosPriceListener extends ChainPriceListener {
     private logger: Logger,
     config: {
       pollingFrequency: DurationInSeconds;
-    }
+    },
   ) {
     super(config.pollingFrequency, priceItems);
   }
@@ -27,7 +27,7 @@ export class AptosPriceListener extends ChainPriceListener {
 
     const res = await client.getAccountResource(
       this.pythModule,
-      `${this.pythModule}::state::LatestPriceInfo`
+      `${this.pythModule}::state::LatestPriceInfo`,
     );
 
     try {
@@ -50,8 +50,8 @@ export class AptosPriceListener extends ChainPriceListener {
 
       this.logger.debug(
         `Polled an Aptos on-chain price for feed ${this.priceIdToAlias.get(
-          priceId
-        )} (${priceId}).`
+          priceId,
+        )} (${priceId}).`,
       );
 
       return {
@@ -62,7 +62,7 @@ export class AptosPriceListener extends ChainPriceListener {
     } catch (err) {
       this.logger.error(
         err,
-        `Polling Aptos on-chain price for ${priceId} failed.`
+        `Polling Aptos on-chain price for ${priceId} failed.`,
       );
       return undefined;
     }
@@ -94,7 +94,7 @@ export class AptosPricePusher implements IPricePusher {
     private pythContractAddress: string,
     private endpoint: string,
     private mnemonic: string,
-    private overrideGasPriceMultiplier: number
+    private overrideGasPriceMultiplier: number,
   ) {
     this.sequenceNumberLocked = false;
   }
@@ -111,13 +111,13 @@ export class AptosPricePusher implements IPricePusher {
       encoding: "base64",
     });
     return response.binary.data.map((data) =>
-      Array.from(Buffer.from(data, "base64"))
+      Array.from(Buffer.from(data, "base64")),
     );
   }
 
   async updatePriceFeed(
     priceIds: string[],
-    pubTimesToPush: number[]
+    pubTimesToPush: number[],
   ): Promise<void> {
     if (priceIds.length === 0) {
       return;
@@ -137,7 +137,7 @@ export class AptosPricePusher implements IPricePusher {
 
     const account = AptosAccount.fromDerivePath(
       APTOS_ACCOUNT_HD_PATH,
-      this.mnemonic
+      this.mnemonic,
     );
     const client = new AptosClient(this.endpoint);
 
@@ -151,7 +151,7 @@ export class AptosPricePusher implements IPricePusher {
       },
       {
         sequence_number: sequenceNumber.toFixed(),
-      }
+      },
     );
 
     try {
@@ -160,7 +160,7 @@ export class AptosPricePusher implements IPricePusher {
 
       this.logger.debug(
         { hash: pendingTx.hash },
-        "Successfully broadcasted tx."
+        "Successfully broadcasted tx.",
       );
 
       // Sometimes broadcasted txs don't make it on-chain and they cause our sequence number
@@ -183,7 +183,7 @@ export class AptosPricePusher implements IPricePusher {
   // Wait for the transaction to be confirmed. If it fails, reset the sequence number.
   private async waitForTransactionConfirmation(
     client: AptosClient,
-    txHash: string
+    txHash: string,
   ): Promise<void> {
     try {
       await client.waitForTransaction(txHash, {
@@ -195,7 +195,7 @@ export class AptosPricePusher implements IPricePusher {
     } catch (err) {
       this.logger.error(
         { err, hash: txHash },
-        `Transaction failed to confirm.`
+        `Transaction failed to confirm.`,
       );
 
       this.lastSequenceNumber = undefined;
@@ -207,7 +207,7 @@ export class AptosPricePusher implements IPricePusher {
   // the blockchain itself (and caches it for later).
   private async tryGetNextSequenceNumber(
     client: AptosClient,
-    account: AptosAccount
+    account: AptosAccount,
   ): Promise<number> {
     if (this.lastSequenceNumber !== undefined) {
       this.lastSequenceNumber += 1;
@@ -220,10 +220,10 @@ export class AptosPricePusher implements IPricePusher {
         try {
           this.sequenceNumberLocked = true;
           this.lastSequenceNumber = Number(
-            (await client.getAccount(account.address())).sequence_number
+            (await client.getAccount(account.address())).sequence_number,
           );
           this.logger.debug(
-            `Fetched account sequence number: ${this.lastSequenceNumber}`
+            `Fetched account sequence number: ${this.lastSequenceNumber}`,
           );
           return this.lastSequenceNumber;
         } catch (e: any) {

apps/price_pusher/src/aptos/command.ts

@@ -64,7 +64,7 @@ export default {
     const mnemonic = fs.readFileSync(mnemonicFile, "utf-8").trim();
     const account = AptosAccount.fromDerivePath(
       APTOS_ACCOUNT_HD_PATH,
-      mnemonic
+      mnemonic,
     );
     logger.info(`Pushing from account address: ${account.address()}`);
 
@@ -78,7 +78,7 @@ export default {
       logger.error(
         `Invalid price id submitted for: ${invalidPriceItems
           .map(({ alias }) => alias)
-          .join(", ")}`
+          .join(", ")}`,
       );
     }
 
@@ -87,15 +87,15 @@ export default {
     const pythListener = new PythPriceListener(
       hermesClient,
       priceItems,
-      logger.child({ module: "PythPriceListener" })
+      logger.child({ module: "PythPriceListener" }),
     );
 
     const aptosListener = new AptosPriceListener(
       pythContractAddress,
       endpoint,
       priceItems,
       logger.child({ module: "AptosPriceListener" }),
-      { pollingFrequency }
+      { pollingFrequency },
     );
 
     const aptosPusher = new AptosPricePusher(
@@ -104,7 +104,7 @@ export default {
       pythContractAddress,
       endpoint,
       mnemonic,
-      overrideGasPriceMultiplier
+      overrideGasPriceMultiplier,
     );
 
     const controller = new Controller(
@@ -113,7 +113,7 @@ export default {
       aptosListener,
       aptosPusher,
       logger.child({ module: "Controller" }, { level: controllerLogLevel }),
-      { pushingFrequency }
+      { pushingFrequency },
     );
 
     controller.start();

apps/price_pusher/src/controller.ts

@@ -14,7 +14,7 @@ export class Controller {
     private logger: Logger,
     config: {
       pushingFrequency: DurationInSeconds;
-    }
+    },
   ) {
     this.pushingFrequency = config.pushingFrequency;
   }
@@ -48,7 +48,7 @@ export class Controller {
           priceConfig,
           sourceLatestPrice,
           targetLatestPrice,
-          this.logger
+          this.logger,
         );
         if (priceShouldUpdate == UpdateCondition.YES) {
           pushThresholdMet = true;
@@ -70,7 +70,7 @@ export class Controller {
               alias: priceConfig.alias,
             })),
           },
-          "Some of the checks triggered pushing update. Will push the updates for some feeds."
+          "Some of the checks triggered pushing update. Will push the updates for some feeds.",
         );
 
         // note that the priceIds are without leading "0x"

apps/price_pusher/src/evm/command.ts

@@ -125,7 +125,7 @@ export default {
       logger.error(
         `Invalid price id submitted for: ${invalidPriceItems
           .map(({ alias }) => alias)
-          .join(", ")}`
+          .join(", ")}`,
       );
     }
 
@@ -134,14 +134,14 @@ export default {
     const pythListener = new PythPriceListener(
       hermesClient,
       priceItems,
-      logger.child({ module: "PythPriceListener" })
+      logger.child({ module: "PythPriceListener" }),
     );
 
     const client = await createClient(endpoint, mnemonic);
     const pythContract = createPythContract(client, pythContractAddress);
 
     logger.info(
-      `Pushing updates from wallet address: ${client.account.address}`
+      `Pushing updates from wallet address: ${client.account.address}`,
     );
 
     // It is possible to watch the events in the non-ws endpoints, either by getFilter
@@ -156,13 +156,13 @@ export default {
       logger.child({ module: "EvmPriceListener" }),
       {
         pollingFrequency,
-      }
+      },
     );
 
     const gasStation = getCustomGasStation(
       logger.child({ module: "CustomGasStation" }),
       customGasStation,
-      txSpeed
+      txSpeed,
     );
     const evmPusher = new EvmPricePusher(
       hermesClient,
@@ -174,7 +174,7 @@ export default {
       updateFeeMultiplier,
       gasLimit,
       gasStation,
-      gasPrice
+      gasPrice,
     );
 
     const controller = new Controller(
@@ -183,7 +183,7 @@ export default {
       evmListener,
       evmPusher,
       logger.child({ module: "Controller" }, { level: controllerLogLevel }),
-      { pushingFrequency }
+      { pushingFrequency },
     );
 
     controller.start();