feat: load stamps from cache api before ceramic

Co-authored-by: schultztimothy <[email protected]> Co-authored-by: Lucian <[email protected]>
mjone0gx · Feb 3, 2023 · f777cfb · f777cfb
1 parent 49fafb8
commit f777cfb
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 13 deletions.
diff --git a/app/context/ceramicContext.tsx b/app/context/ceramicContext.tsx
@@ -185,6 +185,13 @@ export type AllProvidersState = {
   };
 };
 
+export class NoStampsInCacheError extends Error {
+  constructor(message: string) {
+    super(message);
+    this.name = "NoStampsInCacheError";
+  }
+}
+
 const getProviderSpec = (platform: PLATFORM_ID, provider: string): ProviderSpec => {
   return STAMP_PROVIDERS[platform]
     ?.find((i) => i.providers.find((p) => p.name == provider))
@@ -561,6 +568,9 @@ export const CeramicContextProvider = ({ children }: { children: any }) => {
         setPassport(undefined);
         if (!skipLoadingState) setIsLoadingPassport(IsLoadingPassportState.FailedToConnect);
         break;
+      case "NoStampsInCache":
+        datadogRum.addError("No stamps found in cache", { address });
+        throw new NoStampsInCacheError("No stamps found in cache");
     }
 
     setPassportLoadResponse({ passport, status, errorDetails });

diff --git a/database-client/src/ceramicCacheClient.ts b/database-client/src/ceramicCacheClient.ts
@@ -35,15 +35,17 @@ export class CeramicCacheDatabase implements DataStorageBase {
     let errorDetails: PassportLoadErrorDetails;
 
     try {
-      const response = await axios.get(
-        `${this.ceramicCacheUrl}/ceramic-cache/stamp?address=${this.address}`,
-      )
+      const response = await axios.get(`${this.ceramicCacheUrl}/ceramic-cache/stamp?address=${this.address}`);
       const { data } = response;
       if (data && data.success === 200) {
         passport = {
           issuanceDate: null,
           expiryDate: null,
           stamps: data.stamps,
+        };
+
+        if (data.stamps.length === 0) {
+          status = "NoStampsInCache";
         }
       }
     } catch (e) {
@@ -61,14 +63,11 @@ export class CeramicCacheDatabase implements DataStorageBase {
     this.logger.info(`adding stamp to ceramicCache address: ${this.address}`);
     try {
       // Todo will need to validate ownership / pass signature
-      await axios.post(
-        `${this.ceramicCacheUrl}/ceramic-cache/stamp`,
-        {
-          address: this.address,
-          provider: stamp.provider,
-          stamp: stamp.credential,
-        },
-      )
+      await axios.post(`${this.ceramicCacheUrl}/ceramic-cache/stamp`, {
+        address: this.address,
+        provider: stamp.provider,
+        stamp: stamp.credential,
+      });
     } catch (e) {
       this.logger.error(`Error saving stamp to ceramicCache address:  ${this.address}:` + e.toString());
     }
@@ -80,7 +79,7 @@ export class CeramicCacheDatabase implements DataStorageBase {
         data: {
           address: this.address,
           provider: provider,
-        }
+        },
       });
     } catch (e) {
       this.logger.error(`Error deleting stamp from ceramicCache for ${provider} on ${this.address}: ` + e.toString());

diff --git a/types/src/index.d.ts b/types/src/index.d.ts
@@ -144,7 +144,8 @@ export type PassportLoadStatus =
   | "DoesNotExist"
   | "ExceptionRaised"
   | "StampCacaoError"
-  | "PassportCacaoError";
+  | "PassportCacaoError"
+  | "NoStampsInCache";
 
 export type PassportLoadErrorDetails = {
   stampStreamIds: string[];