failed execuion event track

abis/InstaAutomation.json

@@ -169,6 +169,102 @@
     "name": "LogExecutedAutomation",
     "type": "event"
   },
+  {
+    "anonymous": false,
+    "inputs": [
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "user",
+        "type": "address"
+      },
+      {
+        "indexed": true,
+        "internalType": "uint32",
+        "name": "id",
+        "type": "uint32"
+      },
+      {
+        "indexed": true,
+        "internalType": "uint32",
+        "name": "nonce",
+        "type": "uint32"
+      },
+      {
+        "components": [
+          {
+            "internalType": "address",
+            "name": "collateralToken",
+            "type": "address"
+          },
+          { "internalType": "address", "name": "debtToken", "type": "address" },
+          {
+            "internalType": "uint256",
+            "name": "collateralAmount",
+            "type": "uint256"
+          },
+          {
+            "internalType": "uint256",
+            "name": "debtAmount",
+            "type": "uint256"
+          },
+          {
+            "internalType": "uint256",
+            "name": "collateralAmountWithTotalFee",
+            "type": "uint256"
+          },
+          {
+            "components": [
+              {
+                "internalType": "address",
+                "name": "buyToken",
+                "type": "address"
+              },
+              {
+                "internalType": "address",
+                "name": "sellToken",
+                "type": "address"
+              },
+              {
+                "internalType": "uint256",
+                "name": "sellAmt",
+                "type": "uint256"
+              },
+              {
+                "internalType": "uint256",
+                "name": "unitAmt",
+                "type": "uint256"
+              },
+              { "internalType": "bytes", "name": "callData", "type": "bytes" }
+            ],
+            "internalType": "struct Structs.Swap",
+            "name": "swap",
+            "type": "tuple"
+          },
+          { "internalType": "uint256", "name": "route", "type": "uint256" },
+          { "internalType": "uint256", "name": "rateMode", "type": "uint256" }
+        ],
+        "indexed": false,
+        "internalType": "struct Structs.ExecutionParams",
+        "name": "params",
+        "type": "tuple"
+      },
+      {
+        "indexed": false,
+        "internalType": "bytes",
+        "name": "metadata",
+        "type": "bytes"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint128",
+        "name": "initialHf",
+        "type": "uint128"
+      }
+    ],
+    "name": "LogExecutionFailedAutomation",
+    "type": "event"
+  },
   {
     "anonymous": false,
     "inputs": [

generated/InstaAutomation/InstaAutomation.ts

@@ -166,6 +166,104 @@ export class LogExecutedAutomationParamsSwapStruct extends ethereum.Tuple {
   }
 }
 
+export class LogExecutionFailedAutomation extends ethereum.Event {
+  get params(): LogExecutionFailedAutomation__Params {
+    return new LogExecutionFailedAutomation__Params(this);
+  }
+}
+
+export class LogExecutionFailedAutomation__Params {
+  _event: LogExecutionFailedAutomation;
+
+  constructor(event: LogExecutionFailedAutomation) {
+    this._event = event;
+  }
+
+  get user(): Address {
+    return this._event.parameters[0].value.toAddress();
+  }
+
+  get id(): BigInt {
+    return this._event.parameters[1].value.toBigInt();
+  }
+
+  get nonce(): BigInt {
+    return this._event.parameters[2].value.toBigInt();
+  }
+
+  get params(): LogExecutionFailedAutomationParamsStruct {
+    return changetype<LogExecutionFailedAutomationParamsStruct>(
+      this._event.parameters[3].value.toTuple()
+    );
+  }
+
+  get metadata(): Bytes {
+    return this._event.parameters[4].value.toBytes();
+  }
+
+  get initialHf(): BigInt {
+    return this._event.parameters[5].value.toBigInt();
+  }
+}
+
+export class LogExecutionFailedAutomationParamsStruct extends ethereum.Tuple {
+  get collateralToken(): Address {
+    return this[0].toAddress();
+  }
+
+  get debtToken(): Address {
+    return this[1].toAddress();
+  }
+
+  get collateralAmount(): BigInt {
+    return this[2].toBigInt();
+  }
+
+  get debtAmount(): BigInt {
+    return this[3].toBigInt();
+  }
+
+  get collateralAmountWithTotalFee(): BigInt {
+    return this[4].toBigInt();
+  }
+
+  get swap(): LogExecutionFailedAutomationParamsSwapStruct {
+    return changetype<LogExecutionFailedAutomationParamsSwapStruct>(
+      this[5].toTuple()
+    );
+  }
+
+  get route(): BigInt {
+    return this[6].toBigInt();
+  }
+
+  get rateMode(): BigInt {
+    return this[7].toBigInt();
+  }
+}
+
+export class LogExecutionFailedAutomationParamsSwapStruct extends ethereum.Tuple {
+  get buyToken(): Address {
+    return this[0].toAddress();
+  }
+
+  get sellToken(): Address {
+    return this[1].toAddress();
+  }
+
+  get sellAmt(): BigInt {
+    return this[2].toBigInt();
+  }
+
+  get unitAmt(): BigInt {
+    return this[3].toBigInt();
+  }
+
+  get callData(): Bytes {
+    return this[4].toBytes();
+  }
+}
+
 export class LogFeeTransferred extends ethereum.Event {
   get params(): LogFeeTransferred__Params {
     return new LogFeeTransferred__Params(this);

generated/schema.ts

@@ -394,6 +394,15 @@ export class Account extends Entity {
   set systemCancelData(value: Array<string>) {
     this.set("systemCancelData", Value.fromStringArray(value));
   }
+
+  get failedExecutionData(): Array<string> {
+    let value = this.get("failedExecutionData");
+    return value!.toStringArray();
+  }
+
+  set failedExecutionData(value: Array<string>) {
+    this.set("failedExecutionData", Value.fromStringArray(value));
+  }
 }
 
 export class SubmitData extends Entity {
@@ -1215,3 +1224,107 @@ export class Executor extends Entity {
     this.set("executors", Value.fromBytesArray(value));
   }
 }
+
+export class FailedExecution extends Entity {
+  constructor(id: string) {
+    super();
+    this.set("id", Value.fromString(id));
+  }
+
+  save(): void {
+    let id = this.get("id");
+    assert(id != null, "Cannot save FailedExecution entity without an ID");
+    if (id) {
+      assert(
+        id.kind == ValueKind.STRING,
+        `Entities of type FailedExecution must have an ID of type String but the id '${id.displayData()}' is of type ${id.displayKind()}`
+      );
+      store.set("FailedExecution", id.toString(), this);
+    }
+  }
+
+  static load(id: string): FailedExecution | null {
+    return changetype<FailedExecution | null>(store.get("FailedExecution", id));
+  }
+
+  get id(): string {
+    let value = this.get("id");
+    return value!.toString();
+  }
+
+  set id(value: string) {
+    this.set("id", Value.fromString(value));
+  }
+
+  get user(): Bytes {
+    let value = this.get("user");
+    return value!.toBytes();
+  }
+
+  set user(value: Bytes) {
+    this.set("user", Value.fromBytes(value));
+  }
+
+  get account(): string {
+    let value = this.get("account");
+    return value!.toString();
+  }
+
+  set account(value: string) {
+    this.set("account", Value.fromString(value));
+  }
+
+  get userId(): BigInt {
+    let value = this.get("userId");
+    return value!.toBigInt();
+  }
+
+  set userId(value: BigInt) {
+    this.set("userId", Value.fromBigInt(value));
+  }
+
+  get nonce(): BigInt {
+    let value = this.get("nonce");
+    return value!.toBigInt();
+  }
+
+  set nonce(value: BigInt) {
+    this.set("nonce", Value.fromBigInt(value));
+  }
+
+  get params(): string {
+    let value = this.get("params");
+    return value!.toString();
+  }
+
+  set params(value: string) {
+    this.set("params", Value.fromString(value));
+  }
+
+  get metadata(): Bytes {
+    let value = this.get("metadata");
+    return value!.toBytes();
+  }
+
+  set metadata(value: Bytes) {
+    this.set("metadata", Value.fromBytes(value));
+  }
+
+  get initialHf(): BigInt {
+    let value = this.get("initialHf");
+    return value!.toBigInt();
+  }
+
+  set initialHf(value: BigInt) {
+    this.set("initialHf", Value.fromBigInt(value));
+  }
+
+  get transactionDetail(): string {
+    let value = this.get("transactionDetail");
+    return value!.toString();
+  }
+
+  set transactionDetail(value: string) {
+    this.set("transactionDetail", Value.fromString(value));
+  }
+}

networks.json

@@ -10,5 +10,11 @@
       "address": "0x08c1c01be430C9381AD2794412C3E940254CD97c",
       "startBlock": 18160000
     }
+  },
+  "mainnet": {
+    "InstaAutomation": {
+      "address": "0x08c1c01be430C9381AD2794412C3E940254CD97c",
+      "startBlock": 15435700
+    }
   }
 }

schema.graphql

@@ -41,6 +41,7 @@ type Account @entity {
   executeAutomation: [ExecuteData!]! @derivedFrom(field: "account")
   cancelData: [CancelData!]! @derivedFrom(field: "account")
   systemCancelData: [SystemCancelData!]! @derivedFrom(field: "account")
+  failedExecutionData: [FailedExecution!]! @derivedFrom(field: "account")
 }
 
 type SubmitData @entity {
@@ -137,3 +138,15 @@ type Executor @entity {
   id: ID!
   executors: [Bytes!]!
 }
+
+type FailedExecution @entity {
+  id: ID!
+  user: Bytes!
+  account: Account!
+  userId: BigInt!
+  nonce: BigInt!
+  params: ExecutionParams!
+  metadata: Bytes!
+  initialHf: BigInt!
+  transactionDetail: TransactionData!
+}

src/insta-automation.ts

@@ -10,6 +10,7 @@ import {
   LogCancelledAutomation,
   LogChangedOwner,
   LogExecutedAutomation,
+  LogExecutionFailedAutomation,
   LogFeeTransferred,
   LogFlippedExecutors,
   LogSubmittedAutomation,
@@ -36,6 +37,7 @@ import {
   createOrLoadDsa,
   createOrLoadExecute,
   createOrLoadExecutionParams,
+  createOrLoadFailedExecution,
   createOrLoadFeeTransferData,
   createOrLoadSubmit,
   createOrLoadSwap,
@@ -150,9 +152,7 @@ export function handleSystemCancelledAutomation(
   dsa.save();
 }
 
-export function handleLogExecuteAutomation(
+export function handleLogExecuteAutomation(event: LogExecutedAutomation): void {
-  event: LogExecutedAutomation
-): void {
   let dsaId =
     event.params.user.toHexString() + "#" + event.params.id.toString();
   let eventId =
@@ -277,7 +277,9 @@ export function handleLogSystemCall(event: LogSystemCall): void {
   data.save();
 }
 
-export function handleLogUpdateAutomationFee(event: LogUpdatedAutomationFee): void {
+export function handleLogUpdateAutomationFee(
+  event: LogUpdatedAutomationFee
+): void {
   let eventId =
     event.transaction.hash.toHexString() + event.logIndex.toString();
 
@@ -358,3 +360,57 @@ export function handleExecutors(event: LogFlippedExecutors): void {
   executors_.executors = execArr;
   executors_.save();
 }
+
+export function handleLogFailedExecution(
+  event: LogExecutionFailedAutomation
+): void {
+  let dsaId =
+    event.params.user.toHexString() + "#" + event.params.id.toString();
+  let eventId =
+    event.transaction.hash.toHexString() + event.logIndex.toString();
+
+  log.info("transaction hash: {} and from: {} ", [
+    event.transaction.hash.toHexString(),
+    event.transaction.from.toHexString(),
+  ]);
+  log.info("ID: {}", [dsaId]);
+
+  let dsa = createOrLoadDsa(dsaId);
+  dsa.user = event.params.user;
+  let failedExecuteData = createOrLoadFailedExecution(eventId);
+  let params = createOrLoadExecutionParams(eventId);
+
+  failedExecuteData.user = event.params.user;
+  failedExecuteData.userId = event.params.id;
+  failedExecuteData.nonce = event.params.nonce;
+  failedExecuteData.initialHf = event.params.initialHf;
+  params.collateralToken = event.params.params.collateralToken;
+  params.debtToken = event.params.params.debtToken;
+  params.collateralAmount = event.params.params.collateralAmount;
+  params.debtAmount = event.params.params.debtAmount;
+  params.collateralAmountWithTotalFee =
+    event.params.params.collateralAmountWithTotalFee;
+  failedExecuteData.metadata = event.params.metadata;
+  let swaps = createOrLoadSwap(eventId);
+  swaps.buyToken = event.params.params.swap.buyToken;
+  swaps.sellToken = event.params.params.swap.sellToken;
+  swaps.sellAmt = event.params.params.swap.sellAmt;
+  swaps.unitAmt = event.params.params.swap.unitAmt;
+  swaps.callData = event.params.params.swap.callData;
+  params.swap = swaps.id;
+  failedExecuteData.params = params.id;
+  failedExecuteData.account = dsaId;
+  let transaction = createOrLoadTransaction(eventId);
+  transaction.blockNumber = event.block.number;
+  transaction.timeStamp = event.block.timestamp;
+  transaction.logIndex = event.logIndex;
+  transaction.transactionHash = event.transaction.hash;
+  transaction.transactionLogIndex = event.transactionLogIndex;
+  failedExecuteData.transactionDetail = transaction.id;
+
+  transaction.save();
+  params.save();
+  swaps.save();
+  failedExecuteData.save();
+  dsa.save();
+}

src/insta-index.ts

@@ -4,7 +4,7 @@ import {
   Bytes,
   DataSourceContext,
 } from "@graphprotocol/graph-ts";
-import { Account, ExecutionParams, SubmitData, Swap, Spell, ExecuteData, CancelData, SystemCancelData, TransactionData, ChangedOwner, FeeTransferData, SystemCallData, UpdateAutomationFeeData, UpdateBufferHfData, UpdateMinHfData } from "../generated/schema";
+import { Account, ExecutionParams, SubmitData, Swap, Spell, ExecuteData, CancelData, SystemCancelData, TransactionData, ChangedOwner, FeeTransferData, SystemCallData, UpdateAutomationFeeData, UpdateBufferHfData, UpdateMinHfData, FailedExecution } from "../generated/schema";
 import { InstaAutomation } from "../generated/InstaAutomation/InstaAutomation";
 import { InstaAutomation as InstaAutomationABI } from "../generated/templates";
 
@@ -107,6 +107,21 @@ export function createOrLoadExecute(id: string): ExecuteData {
   return data;
 }
 
+export function createOrLoadFailedExecution(id: string): FailedExecution {
+  let data = FailedExecution.load(id);
+  if(data == null) {
+    data = new FailedExecution(id);
+    data.user = ADDR_ZERO;
+    data.userId = ZERO;
+    data.nonce = ZERO;
+    data.initialHf = ZERO;
+    data.params = createOrLoadExecutionParams(id).id;
+    data.transactionDetail = createOrLoadTransaction(id).id;
+    data.metadata = new Bytes(0);
+  }
+  return data;
+}
+
 export function createOrLoadCancelData(id: string): CancelData {
   let data = CancelData.load(id);
   if(data == null) {

subgraph.yaml

@@ -4,11 +4,11 @@ schema:
 dataSources:
   - kind: ethereum
     name: InstaAutomation
-    network: matic
+    network: mainnet
     source:
       abi: InstaAutomation
-      address: "0x3cF499Dbd2aBB6505f48Db27a9871523A38e6e2C"
+      address: "0x08c1c01be430C9381AD2794412C3E940254CD97c"
-      startBlock: 31471200
+      startBlock: 15435700
     mapping:
       kind: ethereum/events
       apiVersion: 0.0.5
@@ -30,6 +30,7 @@ dataSources:
         - UpdateAutomationFeeData
         - UpdateBufferHfData
         - UpdateMinHfData
+        - FailedExecution
       eventHandlers:
         - event: LogCancelledAutomation(indexed address,indexed uint32,indexed uint32)
           handler: handleLogCancelAutomation
@@ -56,4 +57,7 @@ dataSources:
           handler: handleLogSubmitAutomation
         - event: LogChangedOwner(indexed address,indexed address)
           handler: handleLogChangedOwner
+        - event: LogExecutionFailedAutomation(indexed address,indexed uint32,indexed
+            uint32,(address,address,uint256,uint256,uint256,(address,address,uint256,uint256,bytes),uint256,uint256),bytes,uint128)
+          handler: handleLogFailedExecution
       file: ./src/insta-automation.ts