apply these change to taurus files indexer also

autonomys · Dec 18, 2024 · 944a298 · 944a298
1 parent db51ce5
commit 944a298
Show file tree

Hide file tree

Showing 3 changed files with 46 additions and 1 deletion.
diff --git a/indexers/taurus/files/schema.graphql b/indexers/taurus/files/schema.graphql
@@ -54,3 +54,14 @@ type FileCid @entity {
   parentCid: String! @index
   childCid: String! @index
 }
+
+type Error @entity {
+  id: ID!
+  blockHeight: BigInt! @index
+  blockHash: String! @index
+  extrinsicId: String! @index
+  extrinsicHash: String! @index
+  indexInBlock: Int! @index
+  error: String!
+  timestamp: Date! @index
+}
diff --git a/indexers/taurus/files/src/mappings/db.ts b/indexers/taurus/files/src/mappings/db.ts
@@ -1,6 +1,7 @@
 import {
   Chunk,
   Cid,
+  Error,
   File,
   FileCid,
   Folder,
@@ -120,3 +121,26 @@ export async function createAndSaveFile(
   }
   return file;
 }
+
+export async function createAndSaveError(
+  blockHeight: bigint,
+  blockHash: string,
+  extrinsicId: string,
+  extrinsicHash: string,
+  indexInBlock: number,
+  error: string,
+  timestamp: Date
+): Promise<Error> {
+  const _error = Error.create({
+    id: extrinsicId,
+    blockHeight,
+    blockHash,
+    extrinsicId,
+    extrinsicHash,
+    indexInBlock,
+    error,
+    timestamp,
+  });
+  await _error.save();
+  return _error;
+}
diff --git a/indexers/taurus/files/src/mappings/mappingHandlers.ts b/indexers/taurus/files/src/mappings/mappingHandlers.ts
@@ -17,6 +17,7 @@ import { SubstrateExtrinsic } from "@subql/types";
 import {
   createAndSaveChunk,
   createAndSaveCid,
+  createAndSaveError,
   createAndSaveFile,
   createAndSaveFolder,
   createAndSaveMetadata,
@@ -120,8 +121,17 @@ export async function handleCall(_call: SubstrateExtrinsic): Promise<void> {
         }
       }
     }
-  } catch (error) {
+  } catch (error: any) {
     logger.error("Error decoding remark or seedHistory extrinsic");
     logger.error(error);
+    await createAndSaveError(
+      BigInt(number.toString()),
+      blockHash.toString(),
+      `${number}-${idx}`,
+      hash.toString(),
+      idx,
+      stringify(error),
+      timestamp ? timestamp : new Date(0)
+    );
   }
 }