chore: fixed the lint issues in web3-adapter.

Sahil2004 · Sahil2004 · commit dad9c81b4e0c · 2025-07-24T23:51:19.000+05:30
diff --git a/infrastructure/web3-adapter/src/db/mapping.db.ts b/infrastructure/web3-adapter/src/db/mapping.db.ts
@@ -1,12 +1,20 @@
+import { join } from "node:path";
+import { promisify } from "node:util";
 import sqlite3 from "sqlite3";
-import { join } from "path";
-import { promisify } from "util";
 
 export class MappingDatabase {
     private db: sqlite3.Database;
-    private runAsync: (sql: string, params?: any) => Promise<void>;
-    private getAsync: (sql: string, params?: any) => Promise<any>;
-    private allAsync: (sql: string, params?: any) => Promise<any[]>;
+    private runAsync: (sql: string, params?: string[]) => Promise<void>;
+    private getAsync: (
+        sql: string,
+        params?: string[]
+        // biome-ignore lint/suspicious/noExplicitAny: can't explicitly state that this would return an array of strings
+    ) => Promise<Record<string, string | any>>;
+    private allAsync: (
+        sql: string,
+        params?: string[]
+        // biome-ignore lint/suspicious/noExplicitAny: can't explicitly state that this would return an array of strings
+    ) => Promise<Record<string, string | any>[]>;
 
     constructor(dbPath: string) {
         // Ensure the directory exists
@@ -47,7 +55,7 @@ export class MappingDatabase {
         // Validate inputs
         if (!params.localId || !params.globalId) {
             throw new Error(
-                "Invalid mapping parameters: all fields are required",
+                "Invalid mapping parameters: all fields are required"
             );
         }
 
@@ -60,26 +68,18 @@ export class MappingDatabase {
             return;
         }
 
-        try {
-            await this.runAsync(
-                `INSERT INTO id_mappings (local_id, global_id)
+        await this.runAsync(
+            `INSERT INTO id_mappings (local_id, global_id)
                 VALUES (?, ?)`,
-                [params.localId, params.globalId],
-            );
+            [params.localId, params.globalId]
+        );
 
-            const storedMapping = await this.getGlobalId(params.localId);
-
-            if (storedMapping !== params.globalId) {
-                console.log(
-                    "storedMappingError",
-                    storedMapping,
-                    params.globalId,
-                );
-                console.error("Failed to store mapping");
-                return;
-            }
-        } catch (error) {
-            throw error;
+        const storedMapping = await this.getGlobalId(params.localId);
+
+        if (storedMapping !== params.globalId) {
+            console.log("storedMappingError", storedMapping, params.globalId);
+            console.error("Failed to store mapping");
+            return;
         }
     }
 
@@ -96,7 +96,7 @@ export class MappingDatabase {
                 `SELECT global_id
                 FROM id_mappings
                 WHERE local_id = ?`,
-                [localId],
+                [localId]
             );
             return result?.global_id ?? null;
         } catch (error) {
@@ -118,7 +118,7 @@ export class MappingDatabase {
                 `SELECT local_id
                 FROM id_mappings
                 WHERE global_id = ?`,
-                [globalId],
+                [globalId]
             );
             return result?.local_id ?? null;
         } catch (error) {
@@ -134,15 +134,11 @@ export class MappingDatabase {
             return;
         }
 
-        try {
-            await this.runAsync(
-                `DELETE FROM id_mappings
+        await this.runAsync(
+            `DELETE FROM id_mappings
                 WHERE local_id = ?`,
-                [localId],
-            );
-        } catch (error) {
-            throw error;
-        }
+            [localId]
+        );
     }
 
     /**
@@ -157,7 +153,7 @@ export class MappingDatabase {
         try {
             const results = await this.allAsync(
                 `SELECT local_id, global_id
-                FROM id_mappings`,
+                FROM id_mappings`
             );
 
             return results.map(({ local_id, global_id }) => ({
diff --git a/infrastructure/web3-adapter/src/evault/evault.ts b/infrastructure/web3-adapter/src/evault/evault.ts
@@ -1,10 +1,12 @@
-import { GraphQLClient } from "graphql-request";
+import { Agent } from "node:http";
 import axios, { type AxiosInstance } from "axios";
+import { GraphQLClient } from "graphql-request";
 import { v4 } from "uuid";
 
 export interface MetaEnvelope {
     id?: string | null;
     schemaId: string;
+    // biome-ignore lint/suspicious/noExplicitAny: <explanation>
     data: Record<string, any>;
     w3id: string;
 }
@@ -71,14 +73,17 @@ interface StoreMetaEnvelopeResponse {
             envelopes: Array<{
                 id: string;
                 ontology: string;
+                // biome-ignore lint/suspicious/noExplicitAny: <explanation>
                 value: any;
                 valueType: string;
             }>;
+            // biome-ignore lint/suspicious/noExplicitAny: <explanation>
             parsed: any;
         };
         envelopes: Array<{
             id: string;
             ontology: string;
+            // biome-ignore lint/suspicious/noExplicitAny: <explanation>
             value: any;
             valueType: string;
         }>;
@@ -90,14 +95,17 @@ interface StoreMetaEnvelopeResponse {
             envelopes: Array<{
                 id: string;
                 ontology: string;
+                // biome-ignore lint/suspicious/noExplicitAny: <explanation>
                 value: any;
                 valueType: string;
             }>;
+            // biome-ignore lint/suspicious/noExplicitAny: <explanation>
             parsed: any;
         };
         envelopes: Array<{
             id: string;
             ontology: string;
+            // biome-ignore lint/suspicious/noExplicitAny: <explanation>
             value: any;
             valueType: string;
         }>;
@@ -122,21 +130,18 @@ export class EVaultClient {
     private httpClient: AxiosInstance;
     private isDisposed = false;
 
-    constructor(
-        private registryUrl: string,
-        private platform: string,
-    ) {
+    constructor(private registryUrl: string, private platform: string) {
         // Configure axios with connection pooling and timeouts
         this.httpClient = axios.create({
             timeout: CONFIG.REQUEST_TIMEOUT,
             maxRedirects: 3,
             // Connection pooling configuration
-            httpAgent: new (require("http").Agent)({
+            httpAgent: new Agent({
                 keepAlive: true,
                 maxSockets: CONFIG.CONNECTION_POOL_SIZE,
                 timeout: CONFIG.CONNECTION_TIMEOUT,
             }),
-            httpsAgent: new (require("https").Agent)({
+            httpsAgent: new Agent({
                 keepAlive: true,
                 maxSockets: CONFIG.CONNECTION_POOL_SIZE,
                 timeout: CONFIG.CONNECTION_TIMEOUT,
@@ -169,7 +174,7 @@ export class EVaultClient {
      */
     private async withRetry<T>(
         operation: () => Promise<T>,
-        maxRetries: number = CONFIG.MAX_RETRIES,
+        maxRetries: number = CONFIG.MAX_RETRIES
     ): Promise<T> {
         let lastError: Error;
 
@@ -194,11 +199,12 @@ export class EVaultClient {
                 }
 
                 // Exponential backoff
-                const delay = CONFIG.RETRY_DELAY * Math.pow(2, attempt);
+                const delay = CONFIG.RETRY_DELAY * 2 ** attempt;
                 await new Promise((resolve) => setTimeout(resolve, delay));
             }
         }
 
+        // biome-ignore lint/style/noNonNullAssertion: <explanation>
         throw lastError!;
     }
 
@@ -211,15 +217,15 @@ export class EVaultClient {
             const response = await this.httpClient.post<PlatformTokenResponse>(
                 new URL(
                     "/platforms/certification",
-                    this.registryUrl,
+                    this.registryUrl
                 ).toString(),
                 { platform: this.platform },
                 {
                     headers: {
                         "Content-Type": "application/json",
                     },
                     timeout: CONFIG.REQUEST_TIMEOUT,
-                },
+                }
             );
 
             const now = Date.now();
@@ -265,7 +271,7 @@ export class EVaultClient {
                 new URL(`/resolve?w3id=${w3id}`, this.registryUrl).toString(),
                 {
                     timeout: CONFIG.REQUEST_TIMEOUT,
-                },
+                }
             );
             return new URL("/graphql", response.data.uri).toString();
         } catch (error) {
@@ -351,7 +357,7 @@ export class EVaultClient {
                     {
                         id,
                         w3id,
-                    },
+                    }
                 );
                 return response.metaEnvelope;
             } catch (error) {
@@ -363,12 +369,12 @@ export class EVaultClient {
 
     async updateMetaEnvelopeById(
         id: string,
-        envelope: MetaEnvelope,
+        envelope: MetaEnvelope
     ): Promise<void> {
         return this.withRetry(async () => {
             console.log("sending to eVault", envelope.w3id);
             const client = await this.ensureClient(envelope.w3id).catch(
-                () => null,
+                () => null
             );
             if (!client)
                 throw new Error("Failed to establish client connection");
@@ -386,7 +392,7 @@ export class EVaultClient {
                 const response =
                     await client.request<StoreMetaEnvelopeResponse>(
                         UPDATE_META_ENVELOPE,
-                        variables,
+                        variables
                     );
             } catch (error) {
                 console.error("Error updating meta envelope:", error);
diff --git a/infrastructure/web3-adapter/src/index.ts b/infrastructure/web3-adapter/src/index.ts
@@ -1,10 +1,9 @@
-import * as fs from "fs/promises";
-import path from "path";
-import type { IMapping } from "./mapper/mapper.types";
-import { fromGlobal, toGlobal } from "./mapper/mapper";
+import * as fs from "node:fs/promises";
+import path from "node:path";
 import { MappingDatabase } from "./db";
 import { EVaultClient } from "./evault/evault";
-import { v4 as uuidv4 } from "uuid";
+import { fromGlobal, toGlobal } from "./mapper/mapper";
+import type { IMapping } from "./mapper/mapper.types";
 
 export class Web3Adapter {
     mapping: Record<string, IMapping> = {};
@@ -19,29 +18,29 @@ export class Web3Adapter {
             dbPath: string;
             registryUrl: string;
             platform: string;
-        },
+        }
     ) {
         this.readPaths();
         this.mappingDb = new MappingDatabase(config.dbPath);
         this.evaultClient = new EVaultClient(
             config.registryUrl,
-            config.platform,
+            config.platform
         );
         this.platform = config.platform;
     }
 
     async readPaths() {
         const allRawFiles = await fs.readdir(this.config.schemasPath);
         const mappingFiles = allRawFiles.filter((p: string) =>
-            p.endsWith(".json"),
+            p.endsWith(".json")
         );
 
         for (const mappingFile of mappingFiles) {
             const mappingFileContent = await fs.readFile(
-                path.join(this.config.schemasPath, mappingFile),
+                path.join(this.config.schemasPath, mappingFile)
             );
             const mappingParsed = JSON.parse(
-                mappingFileContent.toString(),
+                mappingFileContent.toString()
             ) as IMapping;
             this.mapping[mappingParsed.tableName] = mappingParsed;
         }
@@ -63,7 +62,7 @@ export class Web3Adapter {
         const { data, tableName, participants } = props;
 
         const existingGlobalId = await this.mappingDb.getGlobalId(
-            data.id as string,
+            data.id as string
         );
 
         console.log(this.mapping, tableName, this.mapping[tableName]);
@@ -122,12 +121,12 @@ export class Web3Adapter {
 
         // Handle references for other participants
         const otherEvaults = (participants ?? []).filter(
-            (i: string) => i !== global.ownerEvault,
+            (i: string) => i !== global.ownerEvault
         );
         for (const evault of otherEvaults) {
             await this.evaultClient.storeReference(
                 `${global.ownerEvault}/${globalId}`,
-                evault,
+                evault
             );
         }
 
diff --git a/infrastructure/web3-adapter/src/mapper/mapper.ts b/infrastructure/web3-adapter/src/mapper/mapper.ts
