Add TokenScope plugin (Phase 6)

Track ENS NFT transfers (ERC721/ERC1155) across all subregistries and
Seaport secondary market sales. Implements 9-type NFT transfer state
machine with CAIP-19 asset IDs for 6 contracts across 4 chains.

New files: tokenscope-helpers.ts, TokenScope.ts, Seaport1_5.json
New entities: NameToken, NameSale
New contract: Seaport 1.5 on mainnet
New events: ThreeDNSToken TransferSingle/TransferBatch

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: moose-code

MIGRATION_PLAN.md

@@ -0,0 +1,94 @@
+[
+  {
+    "anonymous": false,
+    "inputs": [
+      {
+        "indexed": false,
+        "internalType": "bytes32",
+        "name": "orderHash",
+        "type": "bytes32"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "offerer",
+        "type": "address"
+      },
+      {
+        "indexed": true,
+        "internalType": "address",
+        "name": "zone",
+        "type": "address"
+      },
+      {
+        "indexed": false,
+        "internalType": "address",
+        "name": "recipient",
+        "type": "address"
+      },
+      {
+        "components": [
+          {
+            "internalType": "enum ItemType",
+            "name": "itemType",
+            "type": "uint8"
+          },
+          {
+            "internalType": "address",
+            "name": "token",
+            "type": "address"
+          },
+          {
+            "internalType": "uint256",
+            "name": "identifier",
+            "type": "uint256"
+          },
+          {
+            "internalType": "uint256",
+            "name": "amount",
+            "type": "uint256"
+          }
+        ],
+        "indexed": false,
+        "internalType": "struct SpentItem[]",
+        "name": "offer",
+        "type": "tuple[]"
+      },
+      {
+        "components": [
+          {
+            "internalType": "enum ItemType",
+            "name": "itemType",
+            "type": "uint8"
+          },
+          {
+            "internalType": "address",
+            "name": "token",
+            "type": "address"
+          },
+          {
+            "internalType": "uint256",
+            "name": "identifier",
+            "type": "uint256"
+          },
+          {
+            "internalType": "uint256",
+            "name": "amount",
+            "type": "uint256"
+          },
+          {
+            "internalType": "address payable",
+            "name": "recipient",
+            "type": "address"
+          }
+        ],
+        "indexed": false,
+        "internalType": "struct ReceivedItem[]",
+        "name": "consideration",
+        "type": "tuple[]"
+      }
+    ],
+    "name": "OrderFulfilled",
+    "type": "event"
+  }
+]

abis/Seaport1_5.json

@@ -230,6 +230,15 @@ contracts:
         field_selection:
           transaction_fields:
             - hash
+      # ─── ERC1155 Transfer events (for TokenScope plugin) ──────────────────────
+      - event: "TransferSingle(address indexed operator, address indexed from, address indexed to, uint256 id, uint256 value)"
+        field_selection:
+          transaction_fields:
+            - hash
+      - event: "TransferBatch(address indexed operator, address indexed from, address indexed to, uint256[] ids, uint256[] values)"
+        field_selection:
+          transaction_fields:
+            - hash
 
   # ─── Resolver (dynamically registered via Registry.NewResolver) ─────────────
   - name: Resolver
@@ -301,6 +310,16 @@ contracts:
             - hash
             - from
 
+  # ─── Seaport (TokenScope plugin) ───────────────────────────────────────────
+  - name: Seaport
+    abi_file_path: ./abis/Seaport1_5.json
+    handler: ./src/handlers/TokenScope.ts
+    events:
+      - event: "OrderFulfilled(bytes32 orderHash, address indexed offerer, address indexed zone, address recipient, (uint8,address,uint256,uint256)[] offer, (uint8,address,uint256,uint256,address)[] consideration)"
+        field_selection:
+          transaction_fields:
+            - hash
+
   # ─── StandaloneReverseRegistrar (PA plugin) ────────────────────────────────
   - name: StandaloneReverseRegistrar
     events:
@@ -345,6 +364,10 @@ chains:
         address:
           - "0xf55575bde5953ee4272d5ce7cdd924c74d8fa81a"
         start_block: 23784217
+      - name: Seaport
+        address:
+          - "0x00000000000000adc04c56bf30ac9d3c0aaf14dc"
+        start_block: 17129405
       - name: Resolver
         address:
           # Static reverse resolver addresses (PA plugin)

config.yaml

@@ -348,3 +348,35 @@ type RegistrarActionMetadata {
   logicalEventKey: String!   # "{node}:{transactionHash}"
   logicalEventId: String!    # ID of registrarAction being built
 }
+
+# ─── TokenScope Plugin Entities ──────────────────────────────────────────
+
+type NameToken {
+  id: ID!                    # CAIP-19 Asset ID
+  domainId: String!          # namehash (node) of the ENS domain
+  chainId: Int!              # chain managing the token
+  contractAddress: String!   # NFT contract address
+  tokenId: BigInt!           # token ID in the contract
+  assetNamespace: String!    # "erc721" or "erc1155"
+  owner: String!             # current owner (zeroAddress if burned)
+  mintStatus: String!        # "minted" or "burned"
+}
+
+type NameSale {
+  id: ID!                    # "{chainId}-{blockNumber}-{logIndex}"
+  chainId: Int!
+  blockNumber: Int!
+  logIndex: Int!
+  transactionHash: String!
+  orderHash: String!
+  contractAddress: String!
+  tokenId: BigInt!
+  assetNamespace: String!
+  assetId: String!           # CAIP-19 Asset ID
+  domainId: String!          # namehash (node)
+  buyer: String!
+  seller: String!
+  currency: String!          # "ETH", "USDC", "DAI"
+  amount: BigInt!            # smallest unit
+  timestamp: BigInt!
+}

schema.graphql

@@ -26,6 +26,12 @@ import {
   handleRegistrarControllerEvent,
 } from "../lib/registrar-helpers";
 
+import {
+  handleNFTTransfer,
+  buildDomainAssetId,
+  AssetNamespaces,
+} from "../lib/tokenscope-helpers";
+
 // ─── Constants ──────────────────────────────────────────────────────────────
 
 const managedNode = BASE_ETH_NODE;
@@ -254,6 +260,16 @@ BaseRegistrar_Base.Transfer.handler(async ({ event, context }) => {
     registration_id: registrationId,
     newOwner_id: to,
   });
+
+  // TokenScope: track ERC721 transfer
+  const nft = buildDomainAssetId(
+    event.chainId,
+    event.srcAddress,
+    event.params.tokenId,
+    AssetNamespaces.ERC721,
+    (tokenId) => makeSubdomainNode(tokenIdToLabelHash(tokenId), managedNode),
+  );
+  await handleNFTTransfer(context, event.params.from, to, false, nft);
 });
 
 // ─── EAController_Base.NameRegistered ───────────────────────────────────────

src/handlers/BaseRegistrar.ts

@@ -24,6 +24,12 @@ import {
   handleRegistrarControllerEvent,
 } from "../lib/registrar-helpers";
 
+import {
+  handleNFTTransfer,
+  buildDomainAssetId,
+  AssetNamespaces,
+} from "../lib/tokenscope-helpers";
+
 // ─── Constants ──────────────────────────────────────────────────────────────
 
 const managedNode = LINEA_ETH_NODE;
@@ -178,6 +184,16 @@ BaseRegistrar_Linea.Transfer.handler(async ({ event, context }) => {
     registration_id: registrationId,
     newOwner_id: to,
   });
+
+  // TokenScope: track ERC721 transfer
+  const nft = buildDomainAssetId(
+    event.chainId,
+    event.srcAddress,
+    event.params.tokenId,
+    AssetNamespaces.ERC721,
+    (tokenId) => makeSubdomainNode(tokenIdToLabelHash(tokenId), managedNode),
+  );
+  await handleNFTTransfer(context, event.params.from, to, false, nft);
 });
 
 // ─── EthController_Linea.NameRegistered (paid registration) ─────────────────

src/handlers/LineaRegistrar.ts

@@ -11,8 +11,15 @@ import {
   upsertAccount,
   bigintMax,
   MANAGED_NODES,
+  tokenIdToLabelHash,
 } from "../lib/helpers";
 
+import {
+  handleERC1155Transfer,
+  buildDomainAssetId,
+  AssetNamespaces,
+} from "../lib/tokenscope-helpers";
+
 // ─── Constants ──────────────────────────────────────────────────────────────
 
 /**
@@ -130,7 +137,7 @@ async function handleTransfer(
 // ─── TransferSingle ─────────────────────────────────────────────────────────
 
 NameWrapper.TransferSingle.handler(async ({ event, context }) => {
-  const { id: tokenId, to } = event.params;
+  const { id: tokenId, to, from, value } = event.params;
 
   await handleTransfer(
     event,
@@ -139,22 +146,43 @@ NameWrapper.TransferSingle.handler(async ({ event, context }) => {
     tokenId,
     to,
   );
+
+  // TokenScope: track ERC1155 transfer
+  const nft = buildDomainAssetId(
+    event.chainId,
+    event.srcAddress,
+    tokenId,
+    AssetNamespaces.ERC1155,
+    (tid) => "0x" + tid.toString(16).padStart(64, "0"),
+  );
+  await handleERC1155Transfer(context, from, to, false, nft, value);
 });
 
 // ─── TransferBatch ──────────────────────────────────────────────────────────
 
 NameWrapper.TransferBatch.handler(async ({ event, context }) => {
-  const { ids: tokenIds, to } = event.params;
+  const { ids: tokenIds, values, to, from } = event.params;
 
   for (let i = 0; i < tokenIds.length; i++) {
     const tokenId = tokenIds[i]!;
+    const value = values[i]!;
     await handleTransfer(
       event,
       context,
       makeEventId(event.chainId, event.block.number, event.logIndex, i),
       tokenId,
       to,
     );
+
+    // TokenScope: track ERC1155 transfer for each token
+    const nft = buildDomainAssetId(
+      event.chainId,
+      event.srcAddress,
+      tokenId,
+      AssetNamespaces.ERC1155,
+      (tid) => "0x" + tid.toString(16).padStart(64, "0"),
+    );
+    await handleERC1155Transfer(context, from, to, false, nft, value);
   }
 });
 

src/handlers/NameWrapper.ts

@@ -29,6 +29,12 @@ import {
   decodeEncodedReferrer,
 } from "../lib/registrar-helpers";
 
+import {
+  handleNFTTransfer,
+  buildDomainAssetId,
+  AssetNamespaces,
+} from "../lib/tokenscope-helpers";
+
 // ─── Constants ──────────────────────────────────────────────────────────────
 
 const managedNode = ETH_NODE;
@@ -199,6 +205,16 @@ BaseRegistrar.Transfer.handler(async ({ event, context }) => {
     registration_id: registrationId,
     newOwner_id: to,
   });
+
+  // TokenScope: track ERC721 transfer
+  const nft = buildDomainAssetId(
+    event.chainId,
+    event.srcAddress,
+    event.params.tokenId,
+    AssetNamespaces.ERC721,
+    (tokenId) => makeSubdomainNode(tokenIdToLabelHash(tokenId), managedNode),
+  );
+  await handleNFTTransfer(context, event.params.from, to, false, nft);
 });
 
 // ─── LegacyController Handlers ─────────────────────────────────────────────

src/handlers/Registrar.ts

@@ -23,6 +23,12 @@ import {
 
 import { upsertDomainResolverRelation } from "../lib/protocol-acceleration";
 
+import {
+  handleERC1155Transfer,
+  buildDomainAssetId,
+  AssetNamespaces,
+} from "../lib/tokenscope-helpers";
+
 // ─── Root Node Tracking ─────────────────────────────────────────────────────
 // ThreeDNS lives on chains that may not have a Registry (e.g. Optimism).
 // Ensure the root domain exists on the first event per chain.
@@ -263,3 +269,50 @@ ThreeDNSToken.RegistrationExtended.handler(async ({ event, context }) => {
     expiryDate: newExpiry,
   });
 });
+
+// ─── ThreeDNSToken.TransferSingle (TokenScope: ERC1155 NFT tracking) ──────
+
+ThreeDNSToken.TransferSingle.handler(async ({ event, context }) => {
+  const { id: tokenId, from, to, value } = event.params;
+
+  // 3DNS allows non-standard minted remint (mint over already-minted token)
+  const allowMintedRemint = true;
+
+  const nft = buildDomainAssetId(
+    event.chainId,
+    event.srcAddress,
+    tokenId,
+    AssetNamespaces.ERC1155,
+    (tid) => "0x" + tid.toString(16).padStart(64, "0"),
+  );
+  await handleERC1155Transfer(context, from, to, allowMintedRemint, nft, value);
+});
+
+// ─── ThreeDNSToken.TransferBatch (TokenScope: ERC1155 NFT tracking) ───────
+
+ThreeDNSToken.TransferBatch.handler(async ({ event, context }) => {
+  const { ids: tokenIds, values, from, to } = event.params;
+
+  if (tokenIds.length !== values.length) {
+    throw new Error(
+      `ERC1155 transfer batch ids and values must have the same length, got ${tokenIds.length} and ${values.length}.`,
+    );
+  }
+
+  // 3DNS allows non-standard minted remint (mint over already-minted token)
+  const allowMintedRemint = true;
+
+  for (let i = 0; i < tokenIds.length; i++) {
+    const tokenId = tokenIds[i]!;
+    const value = values[i]!;
+
+    const nft = buildDomainAssetId(
+      event.chainId,
+      event.srcAddress,
+      tokenId,
+      AssetNamespaces.ERC1155,
+      (tid) => "0x" + tid.toString(16).padStart(64, "0"),
+    );
+    await handleERC1155Transfer(context, from, to, allowMintedRemint, nft, value);
+  }
+});