Ens changes + module changes

README.md

@@ -1,2 +1,7 @@
 # Subgraphs
 Airstack Subgraphs
+
+## Verticals Supported in airstack-modules
+1. NFT_MARKET_PLACE - [Check docs here](https://github.com/Airstack-xyz/Subgraphs/tree/main/airstack-modules/modules/airstack/nft-marketplace/Readme.md)
+
+2. DOMAIN_NAME - [Check docs here](https://github.com/Airstack-xyz/Subgraphs/tree/main/airstack-modules/modules/airstack/domain-name/Readme.md)

airstack-modules/bin/index.ts

@@ -69,211 +69,18 @@ for (let index = START_INDEX; index < args.length; index++) {
 integrate(vertical, yaml, graphql, dataSources, templates)
   .then(() => {
     switch (vertical) {
-      case Vertical.Dex:
-        console.log(`
-        Integration done. Please call the following functions.
-        1. Add pool
-
-          function addDexPool(
-            poolAddress: string,
-            fee: BigInt,
-            inputTokens: Array<string>,
-            weights: Array<BigDecimal> | null = null,
-            outputToken: string | null = null
-          ): void
-
-        2. Add pool
-
-          function swap(
-            poolAddress: string,
-            inputAmounts: Array<BigInt>,
-            outputAmounts: Array<BigInt>,
-            inputTokenIndex: i32,
-            outputTokenIndex: i32,
-            from: string,
-            to: string,
-            hash: string,
-            logIndex: BigInt,
-            timestamp: BigInt,
-            blockNumber: BigInt
-          ): void
-
-          For documentation and examples please check: https://github.com/Airstack-xyz/Subgraphs
-        `);
-        break;
 
       case Vertical.NftMarketplace:
         console.log(`
-        Integration done. Please call the following functions.
-
-        1. Track NFT trade transaction
-        trackNFTSaleTransactions(
-          chainID: string,
-          txHash: string,
-          txIndex: BigInt,
-          NftSales: Sale[],
-          protocolType: string,
-          protocolActionType: string,
-          timestamp: BigInt,
-          blockHeight: BigInt,
-          blockHash: string
-        )
-
-        For documentation and examples please check: https://github.com/Airstack-xyz/Subgraphs
+Integration for DOMAIN_NAME vertical done. For documentation and examples please check below link:
+https://github.com/Airstack-xyz/Subgraphs/blob/ens-airstack-module-refactor/airstack-modules/modules/airstack/nft-marketplace/Readme.md
         `);
         break;
 
       case Vertical.DomainName:
         console.log(`
-        Integration done. Please call the following functions.
-
-        1. Track domain owner change transaction
-          trackDomainOwnerChangedTransaction(
-            blockHeight: BigInt,
-            blockHash: string,
-            blockTimestamp: BigInt,
-            logIndex: BigInt,
-            chainId: string,
-            newOwner: string,
-            transactionHash: string,
-            isMigrated: boolean,
-            node: Bytes,
-            label: Bytes,
-            tokenAddress: string,
-            fromOldRegistry: boolean,
-          )
-
-        2. Track domain transfer transaction
-        trackDomainTransferTransaction(
-          node: string,
-          chainId: string,
-          newOwnerAddress: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          logIndex: BigInt,
-          transactionHash: string,
-          tokenAddress: string,
-          fromOldRegistry: boolean,
-        )
-
-        3. Track domain new resolver transaction
-        trackDomainNewResolverTransaction(
-          resolver: string,
-          node: string,
-          chainId: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          transactionHash: string,
-          logIndex: BigInt,
-          tokenAddress: string,
-          fromOldRegistry: boolean,
-        )
-
-        4. Track domain new ttl transaction
-        trackDomainNewTTLTransaction(
-          node: string,
-          newTTL: BigInt,
-          chainId: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          logIndex: BigInt,
-          transactionHash: string,
-          tokenAddress: string,
-          fromOldRegistry: boolean,
-        )
-
-        5. Track name registered transaction
-        trackNameRegisteredTransaction(
-          transactionHash: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          logIndex: BigInt,
-          chainId: string,
-          registrantAddress: string,
-          expiryTimestamp: BigInt,
-          cost: BigInt,
-          paymentToken: string,
-          labelId: BigInt,
-          rootNode: ByteArray,
-          tokenAddress: string,
-        )
-
-        6. Track name renewed transaction
-        trackNameRenewedTransaction(
-          transactionHash: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          chainId: string,
-          cost: BigInt | null,
-          paymentToken: string,
-          renewer: string,
-          labelId: BigInt,
-          rootNode: ByteArray,
-          expiryTimestamp: BigInt,
-          tokenAddress: string,
-        )
-
-        7. Track set name preimage transaction
-        trackSetNamePreImage(
-          name: string,
-          label: Bytes,
-          cost: BigInt,
-          paymentToken: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          chainId: string,
-          rootNode: ByteArray,
-          tokenAddress: string,
-          transactionHash: string,
-          renewer: string | null,
-          expiryTimestamp: BigInt | null,
-          fromRegistrationEvent: boolean,
-        )
-
-        8. Track addr(resolvedAddress) changed transaction
-        trackAddrChangedTransaction(
-          chainId: string,
-          logIndex: BigInt,
-          resolverAddress: string,
-          addr: string,
-          node: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          transactionHash: string,
-          tokenAddress: string,
-        )
-
-        9. Track resolver version changed transaction
-        trackResolverVersionChange(
-          chainId: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          node: string,
-          resolverAddress: string,
-          tokenAddress: string,
-        )
-
-        10. Track set primary domain transaction
-        trackSetPrimaryDomainTransaction(
-          ensName: string,
-          chainId: string,
-          from: string,
-          blockHeight: BigInt,
-          blockHash: string,
-          blockTimestamp: BigInt,
-          transactionHash: string,
-          tokenAddress: string,
-        )
-
-        For documentation and examples please check: https://github.com/Airstack-xyz/Subgraphs
+Integration for DOMAIN_NAME vertical done. For documentation and examples please check below link:
+https://github.com/Airstack-xyz/Subgraphs/blob/ens-airstack-module-refactor/airstack-modules/modules/airstack/domain-name/Readme.md
         `
         );
         break;

airstack-modules/graphql/airstack-domain-name-schema.graphql.ts

@@ -28,6 +28,7 @@ type AirEntityCounter @entity {
 type AirAccount @entity {
   id: ID!
   address: String!
+  createdAt: AirBlock!
 }
 
 type AirToken @entity {

airstack-modules/modules/airstack/common/index.ts

@@ -7,6 +7,7 @@ import {
   AirBlock,
   AirEntityCounter,
   AirMeta,
+  AirAccount,
 } from "../../../generated/schema";
 
 export const AIR_META_ID = "AIR_META";
@@ -17,9 +18,9 @@ export const BIG_INT_ZERO = BigInt.fromI32(0);
 
 export const SUBGRAPH_SCHEMA_VERSION = "1.0.0";
 
-export const SUBGRAPH_NAME = "AIRSTACK-SUBGRAPH";
-export const SUBGRAPH_VERSION = "AIRSTACK-SUBGRAPH";
-export const SUBGRAPH_SLUG = "AIRSTACK-SUBGRAPH";
+export const SUBGRAPH_NAME = "ens";
+export const SUBGRAPH_VERSION = "v1";
+export const SUBGRAPH_SLUG = "ens-v1";
 
 const AIR_NETWORK_MAP = new TypedMap<string, string>();
 AIR_NETWORK_MAP.set("arbitrum-one", "ARBITRUM_ONE");
@@ -44,12 +45,42 @@ AIR_NETWORK_MAP.set("osmosis", "OSMOSIS");
 AIR_NETWORK_MAP.set("matic", "MATIC");
 AIR_NETWORK_MAP.set("xdai", "XDAI");
 
+const AIR_CHAIN_ID_MAP = new TypedMap<string, string>();
+AIR_CHAIN_ID_MAP.set("arbitrum-one", "42161");
+AIR_CHAIN_ID_MAP.set("arweave-mainnet", "174");
+AIR_CHAIN_ID_MAP.set("aurora", "1313161554");
+AIR_CHAIN_ID_MAP.set("avalanche", "43114");
+AIR_CHAIN_ID_MAP.set("boba", "288");
+AIR_CHAIN_ID_MAP.set("bsc", "56");
+AIR_CHAIN_ID_MAP.set("celo", "42220");
+AIR_CHAIN_ID_MAP.set("COSMOS", "cosmos");
+AIR_CHAIN_ID_MAP.set("CRONOS", "25");
+AIR_CHAIN_ID_MAP.set("mainnet", "1");
+AIR_CHAIN_ID_MAP.set("fantom", "250");
+AIR_CHAIN_ID_MAP.set("fuse", "122");
+AIR_CHAIN_ID_MAP.set("harmony", "1666600000");
+AIR_CHAIN_ID_MAP.set("juno", "juno-1");
+AIR_CHAIN_ID_MAP.set("moonbeam", "1284");
+AIR_CHAIN_ID_MAP.set("moonriver", "1285");
+AIR_CHAIN_ID_MAP.set("near-mainnet", "1313161554");
+AIR_CHAIN_ID_MAP.set("optimism", "10");
+AIR_CHAIN_ID_MAP.set("osmosis", "osmosis-1");
+AIR_CHAIN_ID_MAP.set("matic", "137");
+AIR_CHAIN_ID_MAP.set("xdai", "100");
+
 export function processNetwork(network: string): string {
   const value = AIR_NETWORK_MAP.get(network);
   const result: string = value !== null ? value : "unknown";
   return result;
 }
 
+export function processChainId(): string {
+  let network = dataSource.network();
+  const value = AIR_CHAIN_ID_MAP.get(network);
+  const result: string = value !== null ? value : "unknown";
+  return result;
+}
+
 //air entity funcitons
 
 /**
@@ -124,4 +155,22 @@ export function getOrCreateAirBlock(
     block.save()
   }
   return block as AirBlock;
-}
+}
+
+/**
+ * @dev this function gets or creates a new air account entity
+ * @param chainId chain id
+ * @param address account address
+ * @param block air block object
+ * @returns AirAccount entity
+ */
+export function getOrCreateAirAccount(chainId: string, address: string, block: AirBlock): AirAccount {
+  let id = chainId.concat("-").concat(address);
+  let entity = AirAccount.load(id);
+  if (entity == null) {
+    entity = new AirAccount(id);
+    entity.address = address;
+    entity.createdAt = block.id;
+  }
+  return entity as AirAccount;
+}