AWS AppSyncを使ったNFT保有者のみがアクセス可能なサービスを実装する

import * as ethers from 'ethers';
const AWSHttpProvider = require('@aws/web3-http-provider');

const ambEndpoint = process.env.AMB_HTTP_ENDPOINT;
const privateKey = process.env.PRIVATE_KEY;
const baseProvider = new AWSHttpProvider(ambEndpoint);
const provider = new ethers.providers.Web3Provider(baseProvider);
const account = new ethers.Wallet(privateKey, provider);


const message = JSON.stringify({
    tokenId: tokenId, // tokenId 保有を証明したいトークンのIDを指定する
})

// ユーザーの秘密鍵でmessageに電子署名を付与する
const signedMessage = await account.signMessage(message);

// 電子署名のエンコードしたものをトークンとして使用する。
// Lambda Authorizerでデコードする。
const abiCoder = new ethers.utils.AbiCoder();

let encodedAuthToken = abiCoder.encode(["string", "string"], [message, signedMessage])
console.log("encodedAuthToken", encodedAuthToken)

return encodedAuthToken

import * as path from 'path';
import * as ethers from 'ethers';

exports.handler = async (event) => {
    const {
      authorizationToken,
      requestContext: { apiId, accountId },
    } = event
    
    // 認証OKならtrueにする
    let isAuthorized = false
    let username =  ''
    let tokenId = ''
    
    try {
        // Blockchainに接続する部分を準備
        const ambEndpoint = process.env.AMB_HTTP_ENDPOINT;
        const contractAddress = process.env.CONTRACT_ADDRESS;
        const AWSHttpProvider = require('@aws/web3-http-provider');
        const ERC1155ContractInfo = require(path.join(__dirname, 'contracts', 'ERC1155.json'));
        const baseProvider = new AWSHttpProvider(ambEndpoint);
        const provider = new ethers.providers.Web3Provider(baseProvider);
        const contract = new ethers.Contract(contractAddress, ERC1155ContractInfo.abi, provider);
        
        // authorizationTokenから電子署名を解析
        const abiCoder = new ethers.utils.AbiCoder();
        let decoded = abiCoder.decode(["string", "string"], authorizationToken)
        let message = decoded[0]
        let signedMessage = decoded[1]
        let messageJson = JSON.parse(message);
        
        // 電子署名を付与したユーザーのアドレスを取得
        let signerAddress = ethers.utils.verifyMessage(message, signedMessage);
        username = signerAddress;
        tokenId = messageJson.tokenId

        // NFTの保有数を確認
        let balanceOf = await contract.balanceOf(signerAddress, messageJson.tokenId);
        console.log(balanceOf.toNumber())
        
        // NFTを保有していれば認証は承認する
        if(balanceOf.toNumber() >0) {
            isAuthorized=true
        };
    
      
    } catch (error) {
      console.log(error)      
    }

    // 認証結果を返す部分の組み立て
    const response = {
      
      // 認証結果。trueなら認証成功
      isAuthorized: isAuthorized,

      // 認証後のメッセージ
      // 後続処理に渡すことのできる情報
      resolverContext: {
        username: username,
        tokenId: tokenId
      },
      deniedFields: [
      ],
      ttlOverride: 10,
    }
    console.log(`response >`, JSON.stringify(response, null, 2))
    return response
  }