feat: add ConditionalCommitAuthorizedEventLog

packages/subgraph/package.json

@@ -32,6 +32,6 @@
     "deploy:staging:goerli": "npm run manifest:staging:goerli && graph deploy --node https://api.thegraph.com/deploy/ --product hosted-service --ipfs https://api.thegraph.com/ipfs/ bosonprotocol/goerli-staging",
     "deploy:production": "npm run manifest:production && graph deploy --node https://api.thegraph.com/deploy/ --product hosted-service --ipfs https://api.thegraph.com/ipfs/ bosonprotocol/polygon",
     "deploy:production:ethereum": "npm run manifest:production:ethereum && graph deploy --node https://api.thegraph.com/deploy/ --product hosted-service --ipfs https://api.thegraph.com/ipfs/ bosonprotocol/ethereum",
-    "test": "npm run manifest:local && graph test"
+    "test": "npm run manifest:local && graph test -v 0.5.4"
   }
 }

packages/subgraph/schema.graphql

@@ -718,6 +718,21 @@ type ExchangeEventLog implements EventLog @entity {
   exchange: Exchange!
 }
 
+type ConditionalCommitAuthorizedEventLog @entity {
+  id: ID!
+  hash: String!
+  type: EventType!
+  timestamp: BigInt!
+  executedBy: Bytes!
+
+  offerId: String!
+  groupId: String!
+  tokenId: BigInt!
+  gating: Int!
+  commitCount: BigInt!
+  maxCommits: BigInt!
+}
+
 type FundsEventLog implements EventLog @entity {
   id: ID!
   hash: String!

packages/subgraph/src/entities/event-log.ts

@@ -1,11 +1,14 @@
-import { BigInt, Bytes } from "@graphprotocol/graph-ts";
+/* eslint-disable @typescript-eslint/ban-types */
+import { Address, BigInt, Bytes } from "@graphprotocol/graph-ts";
 import {
   AccountEventLog,
   OfferEventLog,
   ExchangeEventLog,
   FundsEventLog,
   DisputeEventLog,
-  Exchange
+  Exchange,
+  ConditionalCommitAuthorizedEventLog,
+  Buyer
 } from "../../generated/schema";
 
 export function getEventLogId(
@@ -226,3 +229,38 @@ function saveDisputeEventLog(
 
   return eventLogId;
 }
+
+export function saveConditionalCommitAuthorizedEventLog(
+  txHash: string,
+  logIndex: BigInt,
+  type: string,
+  timestamp: BigInt,
+  buyerAddress: Address,
+  offerId: BigInt,
+  commitCount: BigInt,
+  maxCommits: BigInt,
+  gating: i32,
+  tokenId: BigInt,
+  groupId: string
+): string {
+  const eventLogId = getEventLogId(txHash, logIndex, offerId.toString());
+
+  let eventLog = ConditionalCommitAuthorizedEventLog.load(eventLogId);
+
+  if (!eventLog) {
+    eventLog = new ConditionalCommitAuthorizedEventLog(eventLogId);
+  }
+
+  eventLog.hash = txHash;
+  eventLog.type = type;
+  eventLog.timestamp = timestamp;
+  eventLog.executedBy = changetype<Bytes>(buyerAddress.toString());
+  eventLog.commitCount = commitCount;
+  eventLog.maxCommits = maxCommits;
+  eventLog.gating = gating;
+  eventLog.tokenId = tokenId;
+  eventLog.groupId = groupId;
+  eventLog.save();
+
+  return eventLogId;
+}

packages/subgraph/src/mappings/exchange-handler.ts

@@ -7,12 +7,16 @@ import {
   VoucherExtended,
   VoucherTransferred,
   ExchangeCompleted,
-  VoucherExpired
+  VoucherExpired,
+  ConditionalCommitAuthorized
 } from "../../generated/BosonExchangeHandler/IBosonExchangeHandler";
-import { Exchange, Offer } from "../../generated/schema";
+import { ConditionEntity, Exchange, Offer } from "../../generated/schema";
 
 import { saveMetadata } from "../entities/metadata/handler";
-import { saveExchangeEventLogs } from "../entities/event-log";
+import {
+  saveConditionalCommitAuthorizedEventLog,
+  saveExchangeEventLogs
+} from "../entities/event-log";
 
 export function handleBuyerCommittedEvent(event: BuyerCommitted): void {
   const exchangeFromEvent = event.params.exchange;
@@ -223,3 +227,28 @@ export function handleExchangeCompletedEvent(event: ExchangeCompleted): void {
     );
   }
 }
+
+export function handleConditionalCommitAuthorizedEvent(
+  event: ConditionalCommitAuthorized
+): void {
+  const offer = Offer.load(event.params.offerId.toString());
+
+  if (offer && offer.condition) {
+    const offerCondition = ConditionEntity.load(offer.condition as string);
+    if (offerCondition) {
+      saveConditionalCommitAuthorizedEventLog(
+        event.transaction.hash.toHexString(),
+        event.logIndex,
+        "CONDITIONAL_COMMIT",
+        event.block.timestamp,
+        event.params.buyerAddress,
+        event.params.offerId,
+        event.params.commitCount,
+        event.params.maxCommits,
+        event.params.gating,
+        event.params.tokenId,
+        offerCondition.id
+      );
+    }
+  }
+}

packages/subgraph/subgraph.template.yaml

@@ -196,6 +196,8 @@ dataSources:
           handler: handleVoucherTransferredEvent
         - event: ExchangeCompleted(indexed uint256,indexed uint256,indexed uint256,address)
           handler: handleExchangeCompletedEvent
+        - event: ConditionalCommitAuthorized(indexed uint256,uint8,indexed address,indexed uint256,uint256,uint256)
+          handler: handleConditionalCommitAuthorizedEvent
       file: ./src/mappings/exchange-handler.ts
   - kind: ethereum/contract
     name: BosonFundsHandler