prettier

Author: saihaj

deployments/index.ts

@@ -36,7 +36,7 @@ const servicePrincipalPassword = new azuread.ServicePrincipalPassword(
   "graph-webhooks-sp-password",
   {
     servicePrincipalId: servicePrincipal.id,
-  }
+  },
 );
 
 // Create a new resource group
@@ -56,7 +56,7 @@ const { cluster, provider, kubeConfig, publicIp, subnet } = createAksCluster({
 });
 
 export const { tlsIssueName } = new CertManager(
-  provider
+  provider,
 ).deployCertManagerAndIssuer();
 
 const { server, username, password } = createPostgres({
@@ -99,7 +99,7 @@ const svixServer = new ServiceDeployment(
     ],
   },
   provider,
-  [redisDeployment, redisService]
+  [redisDeployment, redisService],
 );
 
 const deploySvix = svixServer.deploy();

substream-listener/src/index.mts

@@ -71,28 +71,28 @@ const router = createRouter({
       if (startBlock == null) {
         return Response.json(
           { message: "startBlock is required" },
-          { status: 400 }
+          { status: 400 },
         );
       }
 
       if (!contractAddress) {
         return Response.json(
           { message: "contractAddress is required" },
-          { status: 400 }
+          { status: 400 },
         );
       }
 
       if (!substreamsToken) {
         return Response.json(
           { message: "substreamsToken is required" },
-          { status: 400 }
+          { status: 400 },
         );
       }
 
       if (!isAddress(contractAddress)) {
         return Response.json(
           { message: "contractAddress is invalid" },
-          { status: 400 }
+          { status: 400 },
         );
       }
 

substream-listener/src/logger.mts

@@ -26,14 +26,14 @@ class SinkLogger extends Logger<ILogObj> {
 
   public info(...info: unknown[]) {
     const messages = info.map((i) =>
-      typeof i === "string" ? i : JSON.stringify(i)
+      typeof i === "string" ? i : JSON.stringify(i),
     );
     return super.info(...messages);
   }
 
   public error(...err: unknown[]) {
     const errors = err.map((e) =>
-      typeof e === "string" ? e : JSON.stringify(e)
+      typeof e === "string" ? e : JSON.stringify(e),
     );
     return super.error(...errors);
   }

substream-listener/src/prometheus.mts

@@ -19,7 +19,7 @@ export function registerCounter(
   name: string,
   help = "help",
   labelNames: string[] = [],
-  config?: CounterConfiguration<string>
+  config?: CounterConfiguration<string>,
 ): Counter | undefined {
   try {
     const metric = registry.getSingleMetric(name);
@@ -37,7 +37,7 @@ export function registerGauge(
   name: string,
   help = "help",
   labelNames: string[] = [],
-  config?: GaugeConfiguration<string>
+  config?: GaugeConfiguration<string>,
 ): Gauge | undefined {
   try {
     const metric = registry.getSingleMetric(name);
@@ -57,7 +57,7 @@ export function registerSummary(
   name: string,
   help = "help",
   labelNames: string[] = [],
-  config?: SummaryConfiguration<string>
+  config?: SummaryConfiguration<string>,
 ): Summary | undefined {
   try {
     const metric = registry.getSingleMetric(name);
@@ -75,7 +75,7 @@ export function registerHistogram(
   name: string,
   help = "help",
   labelNames: string[] = [],
-  config?: HistogramConfiguration<string>
+  config?: HistogramConfiguration<string>,
 ): Histogram | undefined {
   try {
     const metric = registry.getSingleMetric(name);
@@ -84,7 +84,7 @@ export function registerHistogram(
     }
 
     registry.registerMetric(
-      new Histogram({ name, help, labelNames, ...config })
+      new Histogram({ name, help, labelNames, ...config }),
     );
     return registry.getSingleMetric(name) as Histogram;
   } catch (e) {
@@ -110,25 +110,25 @@ function calculateHeadBlockTimeDrift(clock: Clock) {
 export const substreams_sink_progress_message = registerCounter(
   "substreams_sink_progress_message",
   "The number of progress message received",
-  ["module", ...DEFAULT_LABEL_NAMES]
+  ["module", ...DEFAULT_LABEL_NAMES],
 );
 
 const substreams_sink_data_message = registerCounter(
   "substreams_sink_data_message",
   "The number of data message received",
-  DEFAULT_LABEL_NAMES
+  DEFAULT_LABEL_NAMES,
 );
 
 const substreams_sink_data_message_size_bytes = registerCounter(
   "substreams_sink_data_message_size_bytes",
   "The total size of in bytes of all data message received",
-  DEFAULT_LABEL_NAMES
+  DEFAULT_LABEL_NAMES,
 );
 
 const substreams_sink_undo_message = registerCounter(
   "substreams_sink_undo_message",
   "The number of block undo message received",
-  DEFAULT_LABEL_NAMES
+  DEFAULT_LABEL_NAMES,
 );
 
 // ------------------------------------------------------------------
@@ -138,25 +138,25 @@ const substreams_sink_undo_message = registerCounter(
 const substreams_sink_backprocessing_completion = registerGauge(
   "substreams_sink_backprocessing_completion",
   "Determines if backprocessing is completed, which is if we receive a first data message",
-  DEFAULT_LABEL_NAMES
+  DEFAULT_LABEL_NAMES,
 );
 
 const head_block_number = registerGauge(
   "head_block_number",
   "Last processed block number",
-  DEFAULT_LABEL_NAMES
+  DEFAULT_LABEL_NAMES,
 );
 
 const head_block_time_drift = registerGauge(
   "head_block_time_drift",
   "Head block time drift in seconds",
-  DEFAULT_LABEL_NAMES
+  DEFAULT_LABEL_NAMES,
 );
 
 const head_block_timestamp = registerGauge(
   "head_block_timestamp",
   "Head block timestamp",
-  DEFAULT_LABEL_NAMES
+  DEFAULT_LABEL_NAMES,
 );
 
 const manifest = registerGauge(
@@ -168,7 +168,7 @@ const manifest = registerGauge(
     "stop_block_num",
     "final_blocks_only",
     ...DEFAULT_LABEL_NAMES,
-  ]
+  ],
 );
 
 // ------------------------------------------------------------------
@@ -179,7 +179,7 @@ export function onPrometheusMetrics(
     substreamsEndpoint: string;
     contractAddress: string;
     moduleHash: string;
-  }
+  },
 ) {
   manifest?.set(
     {
@@ -191,7 +191,7 @@ export function onPrometheusMetrics(
       contract_address: options.contractAddress,
       output_module: emitter.request.outputModule,
     },
-    1
+    1,
   );
 
   emitter.on("session", (session) => {
@@ -213,7 +213,7 @@ export function onPrometheusMetrics(
         contract_address: options.contractAddress,
         output_module: emitter.request.outputModule,
       },
-      1
+      1,
     );
   });
 
@@ -224,7 +224,7 @@ export function onPrometheusMetrics(
         contract_address: options.contractAddress,
         output_module: emitter.request.outputModule,
       })
-      .inc(1)
+      .inc(1),
   );
 
   emitter.on("block", (block) => {
@@ -250,7 +250,7 @@ export function onPrometheusMetrics(
         contract_address: options.contractAddress,
         output_module: emitter.request.outputModule,
       },
-      1
+      1,
     );
 
     if (block.clock) {
@@ -260,7 +260,7 @@ export function onPrometheusMetrics(
           contract_address: options.contractAddress,
           output_module: emitter.request.outputModule,
         },
-        Number(block.clock.number)
+        Number(block.clock.number),
       );
 
       head_block_time_drift?.set(
@@ -269,7 +269,7 @@ export function onPrometheusMetrics(
           contract_address: options.contractAddress,
           output_module: emitter.request.outputModule,
         },
-        calculateHeadBlockTimeDrift(block.clock)
+        calculateHeadBlockTimeDrift(block.clock),
       );
 
       head_block_timestamp?.set(
@@ -278,7 +278,7 @@ export function onPrometheusMetrics(
           contract_address: options.contractAddress,
           output_module: emitter.request.outputModule,
         },
-        Number(block.clock.timestamp?.seconds)
+        Number(block.clock.timestamp?.seconds),
       );
     }
   });

substream-listener/src/send-webhook.mts

@@ -20,7 +20,7 @@ const svix = new Svix(
   "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTI3NjcxODYsImV4cCI6MjAyODEyNzE4NiwibmJmIjoxNzEyNzY3MTg2LCJpc3MiOiJzdml4LXNlcnZlciIsInN1YiI6Im9yZ18yM3JiOFlkR3FNVDBxSXpwZ0d3ZFhmSGlyTXUifQ.Gnj4vMl0qls2Q6ks690ZEUAW7h6VsgUHc6iwFWNPa1I",
   {
     serverUrl: "http://localhost:8071",
-  }
+  },
 );
 
 const BASE_URL = "https://mainnet.eth.streamingfast.io:443";
@@ -31,7 +31,7 @@ const spkgPath = path.join(
   "..",
   "..",
   "erc721-substream",
-  "erc-721-v0.1.0.spkg"
+  "erc-721-v0.1.0.spkg",
 );
 
 export async function sendWebhook({
@@ -59,12 +59,12 @@ export async function sendWebhook({
 
   applyParams(
     [`map_transfers=${contractAddress}`],
-    substreamPackage.modules.modules
+    substreamPackage.modules.modules,
   );
 
   const moduleHash = await createModuleHashHex(
     substreamPackage.modules,
-    OUTPUT_MODULE
+    OUTPUT_MODULE,
   );
 
   const registry = createRegistry(substreamPackage);