fix: handle-file-datasource-duplicate-cases

schema.graphql

@@ -156,7 +156,7 @@ type LItem @entity {
 }
 
 type LItemMetadata @entity {
-  "ipfs cid"
+  "ipfs cid - Litem ID"
   id: ID!
   "The parsed data describing the item."
   props: [ItemProp!]! @derivedFrom(field: "item")

src/GeneralizedTCRMapping.ts

@@ -1,5 +1,11 @@
 /* eslint-disable prefer-const */
-import { Bytes, BigInt, Address, log } from '@graphprotocol/graph-ts';
+import {
+  Bytes,
+  BigInt,
+  Address,
+  log,
+  DataSourceContext,
+} from '@graphprotocol/graph-ts';
 import {
   Item,
   Request,
@@ -614,8 +620,12 @@ export function handleEvidence(event: EvidenceEvent): void {
   );
 
   const ipfsHash = extractPath(event.params._evidence);
-  evidence.metadata = ipfsHash;
-  EvidenceMetadataTemplate.create(ipfsHash);
+  evidence.metadata = `${ipfsHash}-${evidence.id}`;
+
+  const context = new DataSourceContext();
+  context.setString('evidenceId', evidence.id);
+
+  EvidenceMetadataTemplate.createWithContext(ipfsHash, context);
 
   evidenceGroup.save();
   evidence.save();

src/LightGeneralizedTCRMapping.ts

@@ -250,7 +250,9 @@ export function handleNewItem(event: NewItem): void {
   item.latestRequestSubmissionTime = BigInt.fromI32(0);
 
   const ipfsHash = extractPath(event.params._data);
-  item.metadata = ipfsHash;
+  item.metadata = `${ipfsHash}-${graphItemID}`;
+
+  log.debug('Creating datasource for ipfs hash : {}', [ipfsHash]);
 
   const context = new DataSourceContext();
   context.setString('graphItemID', graphItemID);
@@ -850,8 +852,11 @@ export function handleEvidence(event: EvidenceEvent): void {
   );
 
   const ipfsHash = extractPath(event.params._evidence);
-  evidence.metadata = ipfsHash;
-  EvidenceMetadataTemplate.create(ipfsHash);
+  evidence.metadata = `${ipfsHash}-${evidence.id}`;
+
+  const context = new DataSourceContext();
+  context.setString('evidenceId', evidence.id);
+  EvidenceMetadataTemplate.createWithContext(ipfsHash, context);
 
   evidenceGroup.save();
   evidence.save();

src/fileHandlers/EvidenceMetadataHandler.ts

@@ -3,7 +3,11 @@ import { EvidenceMetadata } from '../../generated/schema';
 
 export function handleGTCREvidenceMetadata(content: Bytes): void {
   const id = dataSource.stringParam();
-  const evidence = new EvidenceMetadata(id);
+
+  const context = dataSource.context();
+  const evidenceId = context.getString('evidenceId');
+
+  const evidence = new EvidenceMetadata(`${id}-${evidenceId}`);
   const value = json.fromBytes(content).toObject();
 
   log.debug(`ipfs hash : {}, content : {}`, [id, content.toString()]);

src/fileHandlers/LEvidenceMetadataHandler.ts

@@ -3,7 +3,10 @@ import { EvidenceMetadata } from '../../generated/schema';
 
 export function handleLGTCREvidenceMetadata(content: Bytes): void {
   const id = dataSource.stringParam();
-  const evidence = new EvidenceMetadata(id);
+  const context = dataSource.context();
+  const evidenceId = context.getString('evidenceId');
+
+  const evidence = new EvidenceMetadata(`${id}-${evidenceId}`);
   const value = json.fromBytes(content).toObject();
 
   log.debug(`ipfs hash : {}, content : {}`, [id, content.toString()]);

src/fileHandlers/LItemMetadataHandler.ts

@@ -4,14 +4,15 @@ import { JSONValueToBool, JSONValueToMaybeString } from '../utils';
 
 export function handleLItemMetadata(content: Bytes): void {
   const id = dataSource.stringParam();
-  const metadata = new LItemMetadata(id);
 
   const value = json.fromBytes(content).toObject();
-  const context = dataSource.context();
 
+  const context = dataSource.context();
   const graphItemID = context.getString('graphItemID');
   const address = context.getString('address');
 
+  const metadata = new LItemMetadata(`${id}-${graphItemID}`);
+
   metadata.keywords = address;
 
   log.debug(`ipfs hash : {}, content : {}`, [id, content.toString()]);

subgraph.template.yaml

@@ -1,4 +1,4 @@
-specVersion: 0.0.4
+specVersion: 1.0.0
 description: Generalized TCR
 features:
   - fullTextSearch