feat: add handler for IssueAmountChange event

Signed-off-by: Gregory Hill <gregorydhill@outlook.com>

Author: gregdhill

kintsugi.typegen.json

@@ -9,6 +9,7 @@
         "issue.CancelIssue",
         "issue.ExecuteIssue",
         "issue.IssuePeriodChange",
+        "issue.IssueAmountChange",
         "issue.RequestIssue",
         "oracle.FeedValues",
         "redeem.CancelRedeem",
@@ -28,4 +29,4 @@
         "Issue.IssuePeriod",
         "Redeem.RedeemPeriod"
     ]
-}
+}

schema.graphql

@@ -73,6 +73,7 @@ type Issue @entity {
     backingPayment: IssuePayment @derivedFrom(field: "issue")
     status: IssueStatus @index # TODO: find a way to optimise queries by status
     execution: IssueExecution @derivedFrom(field: "issue")
+    amountChange: IssueAmountChange @derivedFrom(field: "issue")
     cancellation: IssueCancellation @derivedFrom(field: "issue")
     refund: Refund @derivedFrom(field: "issue")
 }
@@ -102,6 +103,14 @@ type IssueExecution @entity {
     timestamp: DateTime!
 }
 
+type IssueAmountChange @entity {
+    issue: Issue! @unique
+    amountWrapped: BigInt!
+    bridgeFeeWrapped: BigInt!
+    confiscatedGriefingCollateral: BigInt!
+    height: Height!
+}
+
 type IssueCancellation @entity {
     issue: Issue! @unique
     height: Height!

src/mappings/event/issue.ts

@@ -5,6 +5,7 @@ import {
     Issue,
     IssueCancellation,
     IssueExecution,
+    IssueAmountChange,
     IssuePeriod,
     IssueRequest,
     IssueStatus,
@@ -16,6 +17,7 @@ import {
     IssueCancelIssueEvent,
     IssueExecuteIssueEvent,
     IssueIssuePeriodChangeEvent,
+    IssueIssueAmountChangeEvent,
     IssueRequestIssueEvent,
     RefundExecuteRefundEvent,
     RefundRequestRefundEvent,
@@ -304,3 +306,32 @@ export async function issuePeriodChange(
 
     await ctx.store.save(issuePeriod);
 }
+
+export async function issueAmountChange(ctx: EventHandlerContext): Promise<void> {
+    const rawEvent = new IssueIssueAmountChangeEvent(ctx);
+    const e = rawEvent.asLatest;
+
+    const id = toHex(e.issueId);
+
+    const issue = await ctx.store.get(Issue, { where: { id } });
+    if (issue === undefined) {
+        debug(
+            "WARNING: IssueAmountChange event did not match any existing issue requests! Skipping."
+        );
+        return;
+    }
+    const height = await blockToHeight(
+        ctx.store,
+        ctx.block.height,
+        "IssueAmountChange"
+    );
+    const amountChanged = new IssueAmountChange({
+        id: issue.id,
+        issue,
+        amountWrapped: e.amount,
+        bridgeFeeWrapped: e.fee,
+        height,
+    });
+    await ctx.store.save(amountChanged);
+    await ctx.store.save(issue);
+}

src/processor.ts

@@ -11,6 +11,7 @@ import {
     findAndUpdateExpiredRequests,
     increaseLockedCollateral,
     issuePeriodChange,
+    issueAmountChange,
     redeemPeriodChange,
     registerVault,
     requestIssue,
@@ -48,11 +49,12 @@ processor.addEventHandler("issue.CancelIssue", cancelIssue);
 processor.addEventHandler("issue.ExecuteIssue", executeIssue);
 processor.addEventHandler("issue.RequestIssue", requestIssue);
 processor.addEventHandler("issue.IssuePeriodChange", issuePeriodChange);
+processor.addEventHandler("issue.IssueAmountChange", issueAmountChange);
 processor.addEventHandler("oracle.FeedValues", feedValues);
 processor.addEventHandler("redeem.CancelRedeem", cancelRedeem);
 processor.addEventHandler("redeem.ExecuteRedeem", executeRedeem);
 processor.addEventHandler("redeem.RequestRedeem", requestRedeem);
-processor.addEventHandler("reddem.RedeemPeriodChange", redeemPeriodChange);
+processor.addEventHandler("redeem.RedeemPeriodChange", redeemPeriodChange);
 processor.addEventHandler("refund.ExecuteRefund", executeRefund);
 processor.addEventHandler("refund.RequestRefund", requestRefund);
 processor.addEventHandler("security.UpdateActiveBlock", updateActiveBlock);

testnet.typegen.json

@@ -9,6 +9,7 @@
         "issue.CancelIssue",
         "issue.ExecuteIssue",
         "issue.IssuePeriodChange",
+        "issue.IssueAmountChange",
         "issue.RequestIssue",
         "oracle.FeedValues",
         "redeem.CancelRedeem",
@@ -28,4 +29,4 @@
         "Issue.IssuePeriod",
         "Redeem.RedeemPeriod"
     ]
-}
+}