import { ethers } from 'ethers'

const getCollection = async (holderAddress: string): Promise<number[]> => {
  // アドレスが同値かどうかを判定する関数
  const isAddressesEqual = (address1: string, address2: string) => {
    return address1.toLowerCase() === address2.toLowerCase()
  }

  // 設定値： ABI(Transferイベントのみ抽出)
  const sampleAbi = [
    {
      anonymous: false,
      inputs: [
        {
          indexed: true,
          internalType: 'address',
          name: 'from',
          type: 'address',
        },
        {
          indexed: true,
          internalType: 'address',
          name: 'to',
          type: 'address',
        },
        {
          indexed: true,
          internalType: 'uint256',
          name: 'tokenId',
          type: 'uint256',
        },
      ],
      name: 'Transfer',
      type: 'event',
    },
  ]

  // ① Provider　インスタンスを作成する。
  const provider = new ethers.providers.JsonRpcProvider(
    process.env.RPC_URL as string,
    process.env.NETWORK as string,
  )

  // ② 　Contract インスタンスを作成する。
  const token = new ethers.Contract(process.env.NFT_CONTRACT_ADDRESS as string, sampleAbi, provider)

  // ③ 調べたいホルダーのウォレットの過去のtokenIdの送信イベントログすべて取得する。
  const sentLogs = await token.queryFilter(token.filters.Transfer(holderAddress, null))

  // ④ 調べたいホルダーのウォレットの過去のtokenIdの受信イベントログすべて取得する。
  const receivedLogs = await token.queryFilter(token.filters.Transfer(null, holderAddress))

  // ⑤ ③と④のログを結合し、EventLogを時間が古いものから順に時系列で並べる。
  const logs = sentLogs
    .concat(receivedLogs)
    .sort((a, b) => a.blockNumber - b.blockNumber || a.transactionIndex - b.transactionIndex)

  // ⑥ ⑤のログを操作して、調べたいウォレットが最終的に持っている最新のtokenIdを取得する
  const owned = new Set<number>()

  for (const log of logs) {
    if (log.args) {
      const { from, to, tokenId } = log.args

      if (isAddressesEqual(to, holderAddress)) {
        owned.add(Number(tokenId))
      } else if (isAddressesEqual(from, holderAddress)) {
        owned.delete(Number(tokenId))
      }
    }
  }

  // ⑦ Setをarrayに戻して返却
  return Array.from(owned)
}

// 実行
getCollection(process.env.YOUR_WALLET_ADDRESS as string).then((result) => {
  console.log('result', result)
})

/\*\*

- Get all token ids of NFTs owned by a specific wallet.
- @param walletAddress - the wallet address to query, defaults to the connected wallet
  \*/
  public async getOwnedTokenIds(walletAddress?: string) {
  if (this.query?.owned) {
  return this.query.owned.tokenIds(walletAddress);
  } else {
  const address =
  walletAddress || (await this.contractWrapper.getSignerAddress());
  const allOwners = await this.getAllOwners();
  return (allOwners || [])
  .filter((i) => address?.toLowerCase() === i.owner?.toLowerCase())
  .map((i) => BigNumber.from(i.tokenId));
  }
  }

/\*\*

- Get All owners of minted NFTs on this contract
- @returns an array of token ids and owners
- @twfeature ERC721Supply
  \*/
  public async getAllOwners() {
  return assertEnabled(this.query, FEATURE_NFT_SUPPLY).allOwners();
  }

/**
   * Get All owners of minted NFTs on this contract
   * @returns an array of token ids and owners
   * @twfeature ERC721Supply
   */
  public async getAllOwners() {
    return assertEnabled(this.query, FEATURE_NFT_SUPPLY).allOwners();
  }

/\*\*

- Return all the owners of each token id in this contract
- @returns
  \*/
  public async allOwners() {
  return Promise.all(
  [...new Array((await this.totalCount()).toNumber()).keys()].map(
  async (i) => ({
  tokenId: i,
  owner: await this.erc721
  .ownerOf(i)
  .catch(() => constants.AddressZero),
  }),
  ),
  );
  }

event Transfer(address indexed \_from, address indexed \_to, uint256 indexed \_tokenId);