api: glue code for EVM NFTs

oasisprotocol · Sep 27, 2023 · d95cd32 · d95cd32
1 parent e00b761
commit d95cd32
Show file tree

Hide file tree

Showing 3 changed files with 66 additions and 2 deletions.
diff --git a/api/v1/strict_server.go b/api/v1/strict_server.go
@@ -291,8 +291,11 @@ func (srv *StrictServerImpl) GetRuntimeEvmTokensAddressHolders(ctx context.Conte
 }
 
 func (srv *StrictServerImpl) GetRuntimeEvmNftsAddress(ctx context.Context, request apiTypes.GetRuntimeEvmNftsAddressRequestObject) (apiTypes.GetRuntimeEvmNftsAddressResponseObject, error) {
-	// TODO implement me
-	panic("implement me")
+	nfts, err := srv.dbClient.RuntimeEVMNFTs(ctx, request.Params, request.Address)
+	if err != nil {
+		return nil, err
+	}
+	return apiTypes.GetRuntimeEvmNftsAddress200JSONResponse(*nfts), nil
 }
 
 func (srv *StrictServerImpl) GetRuntimeTransactions(ctx context.Context, request apiTypes.GetRuntimeTransactionsRequestObject) (apiTypes.GetRuntimeTransactionsResponseObject, error) {

diff --git a/storage/client/client.go b/storage/client/client.go
@@ -2,6 +2,7 @@ package client
 
 import (
 	"context"
+	"database/sql"
 	"fmt"
 	"math/big"
 	"time"
@@ -1531,6 +1532,62 @@ func (c *StorageClient) RuntimeTokenHolders(ctx context.Context, p apiTypes.GetR
 	return &hs, nil
 }
 
+func (c *StorageClient) RuntimeEVMNFTs(ctx context.Context, p apiTypes.GetRuntimeEvmNftsAddressParams, address staking.Address) (*EvmNftList, error) {
+	res, err := c.withTotalCount(
+		ctx,
+		"SELECT 1 FROM FALSE", // todo: queries.EvmNfts
+		runtimeFromCtx(ctx),
+		address,
+		p.Limit,
+		p.Offset,
+	)
+	if err != nil {
+		return nil, wrapError(err)
+	}
+	defer res.rows.Close()
+
+	nfts := EvmNftList{
+		EvmNfts:             []EvmNft{},
+		TotalCount:          res.totalCount,
+		IsTotalCountClipped: res.isTotalCountClipped,
+	}
+	for res.rows.Next() {
+		var nft EvmNft
+		var contractAddrContextIdentifier string
+		var contractAddrContextVersion int
+		var contractAddrData []byte
+		var metadataAccessedN sql.NullTime
+		if err2 := res.rows.Scan(
+			&nft.ContractAddr,
+			&contractAddrContextIdentifier,
+			&contractAddrContextVersion,
+			&contractAddrData,
+			&nft.TokenName,
+			&nft.TokenSymbol,
+			&nft.TokenType,
+			&nft.TokenTotalSupply,
+			&nft.Id,
+			&nft.MetadataUri,
+			&metadataAccessedN,
+			&nft.Name,
+			&nft.Description,
+			&nft.Image,
+		); err2 != nil {
+			return nil, wrapError(err2)
+		}
+		if contractEthAddr, err2 := EVMEthAddrFromPreimage(contractAddrContextIdentifier, contractAddrContextVersion, contractAddrData); err2 == nil {
+			contractECAddr := ethCommon.BytesToAddress(contractEthAddr)
+			nft.EthContractAddr = common.Ptr(contractECAddr.String())
+		}
+		if metadataAccessedN.Valid {
+			nft.MetadataAccessed = common.Ptr(metadataAccessedN.Time.String())
+		}
+		nfts.EvmNfts = append(nfts.EvmNfts, nft)
+	}
+
+	return &nfts, nil
+}
+
 // RuntimeStatus returns runtime status information.
 func (c *StorageClient) RuntimeStatus(ctx context.Context) (*RuntimeStatus, error) {
 	runtimeName := runtimeFromCtx(ctx)

diff --git a/storage/client/types.go b/storage/client/types.go
@@ -135,6 +135,10 @@ type BareTokenHolder = api.BareTokenHolder
 
 type TokenHolderList = api.TokenHolderList
 
+type EvmNft = api.EvmNft
+
+type EvmNftList = api.EvmNftList
+
 // TxVolumeList is the storage response for GetVolumes.
 type TxVolumeList = api.TxVolumeList