chore: fix mapper sync

Author: coodos

\

@@ -20,6 +20,7 @@
         "graphql-request": "^6.1.0",
         "sqlite3": "^5.1.7",
         "test": "^3.3.0",
+        "uuid": "^11.1.0",
         "vitest": "^3.1.2"
     },
     "devDependencies": {

infrastructure/web3-adapter/package.json

@@ -1,5 +1,6 @@
 import { GraphQLClient } from "graphql-request";
 import axios from "axios";
+import { v4 } from "uuid";
 
 export interface MetaEnvelope {
     id?: string | null;
@@ -102,7 +103,7 @@ export class EVaultClient {
     private async resolveEndpoint(w3id: string): Promise<string> {
         try {
             const response = await axios.get(
-                new URL(`/resolve?w3id=${w3id}`, this.registryUrl).toString()
+                new URL(`/resolve?w3id=${w3id}`, this.registryUrl).toString(),
             );
             return new URL("/graphql", response.data.uri).toString();
         } catch (error) {
@@ -113,14 +114,18 @@ export class EVaultClient {
 
     private async ensureClient(w3id: string): Promise<GraphQLClient> {
         if (!this.endpoint || !this.client) {
-            this.endpoint = await this.resolveEndpoint(w3id);
+            this.endpoint = await this.resolveEndpoint(w3id).catch(() => null);
+            if (!this.endpoint) throw new Error();
             this.client = new GraphQLClient(this.endpoint);
         }
         return this.client;
     }
 
     async storeMetaEnvelope(envelope: MetaEnvelope): Promise<string> {
-        const client = await this.ensureClient(envelope.w3id);
+        const client = await this.ensureClient(envelope.w3id).catch(() => {
+            return null;
+        });
+        if (!client) return v4();
 
         try {
             const response = await client.request<StoreMetaEnvelopeResponse>(
@@ -131,7 +136,7 @@ export class EVaultClient {
                         payload: envelope.data,
                         acl: ["*"],
                     },
-                }
+                },
             );
             return response.storeMetaEnvelope.metaEnvelope.id;
         } catch (error) {
@@ -154,7 +159,7 @@ export class EVaultClient {
                         },
                         acl: ["*"],
                     },
-                }
+                },
             );
 
             response.storeMetaEnvelope.metaEnvelope.id;
@@ -174,7 +179,7 @@ export class EVaultClient {
                 {
                     id,
                     w3id,
-                }
+                },
             );
             return response.metaEnvelope;
         } catch (error) {
@@ -185,9 +190,10 @@ export class EVaultClient {
 
     async updateMetaEnvelopeById(
         id: string,
-        envelope: MetaEnvelope
+        envelope: MetaEnvelope,
     ): Promise<StoreMetaEnvelopeResponse["storeMetaEnvelope"]> {
-        const client = await this.ensureClient(envelope.w3id);
+        const client = await this.ensureClient(envelope.w3id).catch(() => null);
+        if (!client) throw new Error();
 
         try {
             const variables = {
@@ -201,7 +207,7 @@ export class EVaultClient {
 
             const response = await client.request<StoreMetaEnvelopeResponse>(
                 UPDATE_META_ENVELOPE,
-                variables
+                variables,
             );
             return response.updateMetaEnvelopeById;
         } catch (error) {

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

@@ -17,7 +17,7 @@ export class Web3Adapter {
             schemasPath: string;
             dbPath: string;
             registryUrl: string;
-        }
+        },
     ) {
         this.readPaths();
         this.mappingDb = new MappingDatabase(config.dbPath);
@@ -27,15 +27,15 @@ export class Web3Adapter {
     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;
         }
@@ -69,13 +69,14 @@ export class Web3Adapter {
                 mappingStore: this.mappingDb,
             });
 
-            // Update the existing global entity
-            // await this.evaultClient.updateMetaEnvelopeById(existingGlobalId, {
-            //     id: existingGlobalId,
-            //     w3id: global.ownerEvault as string,
-            //     data: global.data,
-            //     schemaId: this.mapping[tableName].schemaId,
-            // });
+            this.evaultClient
+                .updateMetaEnvelopeById(existingGlobalId, {
+                    id: existingGlobalId,
+                    w3id: global.ownerEvault as string,
+                    data: global.data,
+                    schemaId: this.mapping[tableName].schemaId,
+                })
+                .catch(() => console.error("failed to sync update"));
 
             return {
                 id: existingGlobalId,
@@ -113,12 +114,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,
             );
         }
 

infrastructure/web3-adapter/src/index.ts

@@ -1,6 +1,6 @@
 # Dev URL
 NEXT_PUBLIC_URL=http://localhost
-NEXT_PUBLIC_BASE_URL=http://192.168.29.208:4444
+NEXT_PUBLIC_BASE_URL=http://192.168.0.226:4444
 
 # Emulator
 NEXT_PUBLIC_USE_EMULATOR=false