chore: fixed lint errors in blabsy

Author: Sahil2004

.vscode/settings.json

@@ -15,7 +15,7 @@
         }
     },
     "[typescript]": {
-        "editor.defaultFormatter": "biomejs.biome",
+        "editor.defaultFormatter": "esbenp.prettier-vscode",
         "editor.codeActionsOnSave": {
             "source.organizeImports.biome": "explicit",
             "source.fixAll.biome": "explicit"

infrastructure/web3-adapter/src/db/index.ts

@@ -1 +1 @@
-export * from "./mapping.db"; 
+export * from "./mapping.db";

infrastructure/web3-adapter/src/db/mapping.db.ts

@@ -47,7 +47,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",
             );
         }
 
@@ -64,7 +64,7 @@ export class MappingDatabase {
             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);
@@ -73,7 +73,7 @@ export class MappingDatabase {
                 console.log(
                     "storedMappingError",
                     storedMapping,
-                    params.globalId
+                    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) {
@@ -138,7 +138,7 @@ export class MappingDatabase {
             await this.runAsync(
                 `DELETE FROM id_mappings
                 WHERE local_id = ?`,
-                [localId]
+                [localId],
             );
         } catch (error) {
             throw error;
@@ -157,7 +157,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 }) => ({

infrastructure/web3-adapter/src/evault/evault.ts

@@ -122,18 +122,21 @@ 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 (require("http").Agent)({
                 keepAlive: true,
                 maxSockets: CONFIG.CONNECTION_POOL_SIZE,
                 timeout: CONFIG.CONNECTION_TIMEOUT,
             }),
-            httpsAgent: new (require('https').Agent)({
+            httpsAgent: new (require("https").Agent)({
                 keepAlive: true,
                 maxSockets: CONFIG.CONNECTION_POOL_SIZE,
                 timeout: CONFIG.CONNECTION_TIMEOUT,
@@ -146,12 +149,12 @@ export class EVaultClient {
      */
     public dispose(): void {
         if (this.isDisposed) return;
-        
+
         this.isDisposed = true;
         this.client = null;
         this.endpoint = null;
         this.tokenInfo = null;
-        
+
         // Close HTTP agents to free connections
         if (this.httpClient.defaults.httpAgent) {
             this.httpClient.defaults.httpAgent.destroy();
@@ -166,36 +169,36 @@ 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;
-        
+
         for (let attempt = 0; attempt <= maxRetries; attempt++) {
             try {
                 return await operation();
             } catch (error) {
                 lastError = error as Error;
-                
+
                 // Don't retry on the last attempt
                 if (attempt === maxRetries) break;
-                
+
                 // Don't retry on certain errors
                 if (error instanceof Error) {
                     const isRetryable = !(
-                        error.message.includes('401') ||
-                        error.message.includes('403') ||
-                        error.message.includes('404')
+                        error.message.includes("401") ||
+                        error.message.includes("403") ||
+                        error.message.includes("404")
                     );
-                    
+
                     if (!isRetryable) break;
                 }
-                
+
                 // Exponential backoff
                 const delay = CONFIG.RETRY_DELAY * Math.pow(2, attempt);
-                await new Promise(resolve => setTimeout(resolve, delay));
+                await new Promise((resolve) => setTimeout(resolve, delay));
             }
         }
-        
+
         throw lastError!;
     }
 
@@ -206,19 +209,22 @@ export class EVaultClient {
     private async requestPlatformToken(): Promise<TokenInfo> {
         try {
             const response = await this.httpClient.post<PlatformTokenResponse>(
-                new URL("/platforms/certification", this.registryUrl).toString(),
+                new URL(
+                    "/platforms/certification",
+                    this.registryUrl,
+                ).toString(),
                 { platform: this.platform },
                 {
                     headers: {
                         "Content-Type": "application/json",
                     },
                     timeout: CONFIG.REQUEST_TIMEOUT,
-                }
+                },
             );
-            
+
             const now = Date.now();
-            const expiresAt = response.data.expiresAt || (now + 3600000); // Default 1 hour
-            
+            const expiresAt = response.data.expiresAt || now + 3600000; // Default 1 hour
+
             return {
                 token: response.data.token,
                 expiresAt,
@@ -235,10 +241,10 @@ export class EVaultClient {
      */
     private isTokenExpired(): boolean {
         if (!this.tokenInfo) return true;
-        
+
         const now = Date.now();
         const timeUntilExpiry = this.tokenInfo.expiresAt - now;
-        
+
         return timeUntilExpiry <= CONFIG.TOKEN_REFRESH_THRESHOLD;
     }
 
@@ -259,7 +265,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) {
@@ -294,7 +300,7 @@ export class EVaultClient {
                 return null;
             });
             if (!client) return v4();
-            
+
             console.log("sending payload", envelope);
 
             const response = await client
@@ -306,7 +312,7 @@ export class EVaultClient {
                     },
                 })
                 .catch(() => null);
-                
+
             if (!response) return v4();
             return response.storeMetaEnvelope.metaEnvelope.id;
         });
@@ -327,7 +333,7 @@ export class EVaultClient {
                     },
                 })
                 .catch(() => null);
-                
+
             if (!response) {
                 console.error("Failed to store reference");
                 throw new Error("Failed to store reference");
@@ -345,7 +351,7 @@ export class EVaultClient {
                     {
                         id,
                         w3id,
-                    }
+                    },
                 );
                 return response.metaEnvelope;
             } catch (error) {
@@ -357,12 +363,15 @@ 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);
-            if (!client) throw new Error("Failed to establish client connection");
+            const client = await this.ensureClient(envelope.w3id).catch(
+                () => null,
+            );
+            if (!client)
+                throw new Error("Failed to establish client connection");
 
             try {
                 const variables = {
@@ -374,10 +383,11 @@ export class EVaultClient {
                     },
                 };
 
-                const response = await client.request<StoreMetaEnvelopeResponse>(
-                    UPDATE_META_ENVELOPE,
-                    variables
-                );
+                const response =
+                    await client.request<StoreMetaEnvelopeResponse>(
+                        UPDATE_META_ENVELOPE,
+                        variables,
+                    );
             } catch (error) {
                 console.error("Error updating meta envelope:", error);
                 throw error;

infrastructure/web3-adapter/src/index.ts

@@ -19,29 +19,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 +63,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 +122,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,
             );
         }