feat: add swap purchase infos

Author: BromeRST

abis/AavegotchiDiamond.json

@@ -12498,5 +12498,122 @@
     ],
     "name": "ClaimedAt",
     "type": "event"
+  },
+  {
+    "anonymous": false,
+    "inputs": [
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "tokenIn",
+        "type": "address"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "tokenOut",
+        "type": "address"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint256",
+        "name": "amountIn",
+        "type": "uint256"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint256",
+        "name": "amountOut",
+        "type": "uint256"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "recipient",
+        "type": "address"
+      }
+    ],
+    "name": "TokenSwapped",
+    "type": "event"
+  },
+  {
+    "anonymous": false,
+    "inputs": [
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "recipient",
+        "type": "address"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "tokenIn",
+        "type": "address"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint256",
+        "name": "swapAmount",
+        "type": "uint256"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint256",
+        "name": "ghstReceived",
+        "type": "uint256"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint256",
+        "name": "listingId",
+        "type": "uint256"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint256",
+        "name": "tokenId",
+        "type": "uint256"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "nftContract",
+        "type": "address"
+      }
+    ],
+    "name": "SwapAndPurchase",
+    "type": "event"
+  },
+  {
+    "anonymous": false,
+    "inputs": [
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "buyer",
+        "type": "address"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "tokenIn",
+        "type": "address"
+      },
+      {
+        "indexed": false,
+        "internalType": "uint256",
+        "name": "ghstReceived",
+        "type": "uint256"
+      },
+      {
+        "indexed": true,
+        "internalType": "uint256",
+        "name": "listingId",
+        "type": "uint256"
+      }
+    ],
+    "name": "SwapAndPurchaseERC1155",
+    "type": "event"
   }
 ]

schema.graphql

@@ -249,6 +249,12 @@ type ERC721Listing @entity {
   fakeGotchi_artist: User
   fakeGotchi_artistName: String
   fakeGotchi_editions: Int
+
+  # Swap metadata when purchased via swap-and-buy
+  purchasedWithSwap: Boolean
+  swapTokenIn: Bytes
+  swapAmountIn: BigInt
+  swapGhstReceived: BigInt
 }
 
 type ERC1155Listing @entity {
@@ -293,6 +299,12 @@ type ERC1155Purchase @entity {
   timeLastPurchased: BigInt! # Time when the listing was purchased
   #sold: Boolean!
   rarityLevel: BigInt
+
+  # Swap metadata when purchased via swap-and-buy
+  purchasedWithSwap: Boolean
+  swapTokenIn: Bytes
+  swapAmountIn: BigInt
+  swapGhstReceived: BigInt
 }
 
 type Statistic @entity {
@@ -539,6 +551,22 @@ type ERC1155BuyOrderExecution @entity {
   executedAt: BigInt
 }
 
+# Swap audit trail
+type SwapAction @entity {
+  id: ID!
+  tokenIn: Bytes!
+  tokenOut: Bytes!
+  amountIn: BigInt!
+  amountOut: BigInt!
+  recipient: Bytes!
+  createdAt: BigInt!
+  txHash: Bytes!
+  listingId: BigInt
+  erc1155ListingId: BigInt
+  tokenId: BigInt
+  nftContract: Bytes
+}
+
 # Cards
 type FakeGotchiCardBalance @entity {
   id: ID!

src/mappings/baseDiamond.ts

@@ -71,6 +71,9 @@ import {
   ResyncAavegotchis,
   ClaimedAt,
   EscrowUpdated,
+  SwapAndPurchase,
+  SwapAndPurchaseERC1155,
+  TokenSwapped,
 } from "../../generated/AavegotchiDiamond/AavegotchiDiamond";
 import {
   getOrCreateUser,
@@ -118,7 +121,13 @@ import {
 } from "../utils/constants";
 import { Address, BigInt, log, Bytes } from "@graphprotocol/graph-ts";
 
-import { Parcel, TokenCommitment, ERC721Listing } from "../../generated/schema";
+import {
+  Parcel,
+  TokenCommitment,
+  ERC721Listing,
+  ERC1155Purchase,
+  SwapAction,
+} from "../../generated/schema";
 
 import { updatePermissionsFromBitmap } from "../utils/decimals";
 import * as erc7589 from "./erc-7589";
@@ -1308,6 +1317,53 @@ export function handleERC721ExecutedToRecipient(
   listing.save();
 }
 
+// Swap-and-buy helpers
+export function handleSwapAndPurchase(event: SwapAndPurchase): void {
+  let listing = getOrCreateERC721Listing(event.params.listingId.toString());
+  listing = updateERC721ListingInfo(listing, event.params.listingId, event);
+
+  listing.purchasedWithSwap = true;
+  listing.swapTokenIn = event.params.tokenIn;
+  listing.swapAmountIn = event.params.swapAmount;
+  listing.swapGhstReceived = event.params.ghstReceived;
+
+  listing.save();
+}
+
+export function handleSwapAndPurchaseERC1155(
+  event: SwapAndPurchaseERC1155
+): void {
+  // Purchase id mirrors the id created in handleERC1155ExecutedListing
+  let purchaseID =
+    event.params.listingId.toString() +
+    "_" +
+    event.params.buyer.toHexString() +
+    "_" +
+    event.block.timestamp.toString();
+
+  let purchase = ERC1155Purchase.load(purchaseID);
+  if (purchase) {
+    purchase.purchasedWithSwap = true;
+    purchase.swapTokenIn = event.params.tokenIn;
+    // swapAmountIn not available in this event; leave null
+    purchase.swapGhstReceived = event.params.ghstReceived;
+    purchase.save();
+  }
+}
+
+export function handleTokenSwapped(event: TokenSwapped): void {
+  const id = event.transaction.hash.toHex() + "-" + event.logIndex.toString();
+  let action = new SwapAction(id);
+  action.tokenIn = event.params.tokenIn;
+  action.tokenOut = event.params.tokenOut;
+  action.amountIn = event.params.amountIn;
+  action.amountOut = event.params.amountOut;
+  action.recipient = event.params.recipient;
+  action.createdAt = event.block.timestamp;
+  action.txHash = event.transaction.hash;
+  action.save();
+}
+
 export function handleWhitelistAccessRightSet(
   event: WhitelistAccessRightSet
 ): void {

subgraph.base.yaml

@@ -174,6 +174,12 @@ dataSources:
           handler: handleClaimedAt
         - event: EscrowUpdated(indexed uint256,address)
           handler: handleEscrowUpdated
+        - event: SwapAndPurchase(indexed address,indexed address,uint256,uint256,uint256,uint256,indexed address)
+          handler: handleSwapAndPurchase
+        - event: SwapAndPurchaseERC1155(indexed address,indexed address,uint256,indexed uint256)
+          handler: handleSwapAndPurchaseERC1155
+        - event: TokenSwapped(indexed address,indexed address,uint256,uint256,indexed address)
+          handler: handleTokenSwapped
 
   - kind: ethereum/contract
     name: RealmDiamond

subgraph.yaml

@@ -174,6 +174,12 @@ dataSources:
           handler: handleClaimedAt
         - event: EscrowUpdated(indexed uint256,address)
           handler: handleEscrowUpdated
+        - event: SwapAndPurchase(indexed address,indexed address,uint256,uint256,uint256,uint256,indexed address)
+          handler: handleSwapAndPurchase
+        - event: SwapAndPurchaseERC1155(indexed address,indexed address,uint256,indexed uint256)
+          handler: handleSwapAndPurchaseERC1155
+        - event: TokenSwapped(indexed address,indexed address,uint256,uint256,indexed address)
+          handler: handleTokenSwapped
 
   - kind: ethereum/contract
     name: RealmDiamond