Unique wallet listing works (#1505)

apps/api/src/routes/wallets/index.ts

@@ -6,12 +6,13 @@ import { DeepAsset } from '@sni/types';
 import {
   getArbitrumWalletAssets,
   getCrossmintWalletAssets,
+  getUniqueWalletAssets,
 } from '@sni/clients/wallets-client';
 
 import { env } from 'hono/adapter';
 import { zValidator } from '@hono/zod-validator';
 import { parseAssetDID } from '@sni/address-utils';
-import { reportUnknownNetwork as errorResponse } from '../../shared';
+import { errorResponse } from '../../shared';
 
 app.get(
   '/:walletAddress',
@@ -68,6 +69,18 @@ app.get(
         } catch (e) {
           return errorResponse(e, c);
         }
+      case 'unique':
+      case 'opal':
+        try {
+          assets = await getUniqueWalletAssets(
+            network,
+            walletAddress,
+            Number.parseInt(contractAddress)
+          );
+          return c.json(assets);
+        } catch (e) {
+          return errorResponse(e, c);
+        }
       default:
         return c.json({ error: true, message: 'Invalid network' }, 400);
     }

apps/api/src/shared.ts

@@ -1,8 +1,9 @@
 import { Context } from 'hono';
+import { logger } from './utils/logger';
 
-export function reportUnknownNetwork(e: unknown, c: Context) {
+export function errorResponse(e: unknown, c: Context) {
   if (e instanceof Error) {
-    return c.json({ error: true, message: e.message }, 500);
+    logger.error(e);
   }
 
   return c.json({ error: true, message: 'Internal server error' }, 500);

packages/clients/assets-client/targets/unique/client.ts

@@ -1,5 +1,6 @@
 import { DeepAsset } from '@sni/types';
 import { UniqueNFTResponseSchema } from './schemas';
+import { createAssetDID } from '@sni/address-utils';
 
 export async function getUniqueAsset(
   network: string,
@@ -29,6 +30,11 @@ export async function getUniqueAsset(
       id: nftResponse.collectionId.toString(),
       name: '', //TODO: Make name optional in the schema
     },
-    address: `did:asset:eip155:11155420.unique2:${collectionId}:${nftResponse.tokenId}`, //TODO: Proper network ID
+    address: createAssetDID(
+      network,
+      'unique2',
+      nftResponse.collectionId,
+      nftResponse.tokenId
+    ),
   };
 }

packages/clients/wallets-client/index.ts

@@ -1,2 +1,3 @@
 export { getArbitrumWalletAssets } from './targets/arbitrum/client';
 export { getCrossmintWalletAssets } from './targets/crossmint/client';
+export { getUniqueWalletAssets } from './targets/unique/client';

packages/clients/wallets-client/targets/unique/client.ts

@@ -0,0 +1,32 @@
+import { DeepAsset, ExternalApiError } from '@sni/types';
+import { getUniqueAsset } from '../../../assets-client/targets/unique/client'; //TODO: Add path aliases
+import { AccountTokensResponseSchema } from './schemas';
+
+//TODO: Cover with tests
+export async function getUniqueWalletAssets(
+  network: 'unique' | 'opal',
+  walletAddress: string,
+  collectionId: number
+): Promise<DeepAsset[]> {
+  const response = await fetch(
+    `https://rest.unique.network/${network}/v1/tokens/account-tokens?address=${walletAddress.toLowerCase()}&collectionId=${collectionId}`,
+    {
+      method: 'GET',
+      headers: { Accept: 'application/json' },
+    }
+  );
+
+  if (response.status !== 200) {
+    throw new ExternalApiError(
+      `Failed to fetch wallet data from ${network} network. ${response.statusText}`
+    );
+  }
+
+  const nfts = AccountTokensResponseSchema.parse(await response.json()).tokens;
+
+  const deepAssets = await Promise.all(
+    nfts.map((nft) => getUniqueAsset(network, nft.collectionId, nft.tokenId))
+  );
+
+  return deepAssets;
+}

packages/clients/wallets-client/targets/unique/schemas.ts

@@ -0,0 +1,10 @@
+import { z } from 'zod';
+
+export const AccountTokensResponseSchema = z.object({
+  tokens: z.array(
+    z.object({
+      collectionId: z.number(),
+      tokenId: z.number(),
+    })
+  ),
+});

packages/types/index.ts

@@ -12,3 +12,5 @@ export type DeepAsset = {
   };
   address: string; //TODO: Rename to did?
 };
+
+export class ExternalApiError extends Error {}