Merge pull request #205 from ckb-cell/develop (v2.4.1)

Merge develop to main branch (v2.4.1)

Author: Flouse

package.json

@@ -1,6 +1,6 @@
 {
   "name": "btc-assets-api",
-  "version": "2.4.0",
+  "version": "2.4.1",
   "title": "Bitcoin/RGB++ Assets API",
   "description": "",
   "main": "index.js",
@@ -47,6 +47,7 @@
     "@rgbpp-sdk/service": "^0.4.0",
     "@sentry/node": "^7.102.1",
     "@sentry/profiling-node": "^7.102.1",
+    "@spore-sdk/core": "^0.2.0-beta.9",
     "async-retry": "^1.3.3",
     "awilix": "^10.0.1",
     "axios": "^1.6.7",

pnpm-lock.yaml

@@ -28,3 +28,16 @@ export const JWT_IGNORE_URLS = ['/token', '/docs', '/cron', '/internal', '/healt
 export const SWAGGER_PROD_IGNORE_URLS = isAdminMode ? ['/token', '/cron'] : ['/cron'];
 
 export const VERCEL_MAX_DURATION = 300;
+
+// estimate time: 2024-04-03 09:45:17
+// ref: https://mempool.space/testnet/block/000000000000000493ba5eebf0602f3e0e5381dd35f763a62ca7ea135343a0d6
+export const BTC_TESTNET_SPV_START_BLOCK_HEIGHT = 2584900;
+
+// estimate time: 2024-06-13 18:31:56
+// ref: https://mempool.space/signet/block/000000b2af39a66ec81d414b102804d975c5c4527adfd9bd3cabf2b7b4634737
+// Signet BTC SPV deployment time: https://pudge.explorer.nervos.org/transaction/0x61efdeddbaa0bb4132c0eb174b3e8002ff5ec430f61ba46f30768d683c516eec
+export const BTC_SIGNET_SPV_START_BLOCK_HEIGHT = 199800;
+
+// estimate time: 2024-04-02 06:20:03
+// ref: https://mempool.space/block/0000000000000000000077d98a103858c7d7cbc5ba67a4135f348a436bec1748
+export const BTC_MAINNET_SPV_START_BLOCK_HEIGHT = 837300;

src/constants.ts

@@ -1,9 +1,8 @@
-import { FastifyPluginCallback, FastifyRequest } from 'fastify';
+import { FastifyPluginCallback } from 'fastify';
 import { Server } from 'http';
 import validateBitcoinAddress from '../../utils/validators';
 import { ZodTypeProvider } from 'fastify-type-provider-zod';
 import { CKBTransaction, Cell, IsomorphicTransaction, Script, XUDTBalance } from './types';
-import { blockchain } from '@ckb-lumos/base';
 import z from 'zod';
 import { Env } from '../../env';
 import { buildPreLockArgs, getXudtTypeScript, isScriptEqual, isTypeAssetSupported } from '@rgbpp-sdk/ckb';
@@ -13,6 +12,7 @@ import { UTXO } from '../../services/bitcoin/schema';
 import { Transaction as BTCTransaction } from '../bitcoin/types';
 import { TransactionWithStatus } from '../../services/ckb';
 import { computeScriptHash } from '@ckb-lumos/lumos/utils';
+import { filterCellsByTypeScript, getTypeScript } from '../../utils/typescript';
 
 const addressRoutes: FastifyPluginCallback<Record<never, never>, Server, ZodTypeProvider> = (fastify, _, done) => {
   const env: Env = fastify.container.resolve('env');
@@ -25,26 +25,6 @@ const addressRoutes: FastifyPluginCallback<Record<never, never>, Server, ZodType
     }
   });
 
-  /**
-   * Get type script from request query
-   */
-  function getTypeScript(request: FastifyRequest) {
-    const { type_script } = request.query as { type_script: string | Script };
-    let typeScript: Script | undefined = undefined;
-    if (type_script) {
-      if (typeof type_script === 'string') {
-        if (type_script.startsWith('0x')) {
-          typeScript = blockchain.Script.unpack(type_script);
-        } else {
-          typeScript = JSON.parse(decodeURIComponent(type_script));
-        }
-      } else {
-        typeScript = type_script;
-      }
-    }
-    return typeScript;
-  }
-
   /**
    * Get UTXOs by btc address
    */
@@ -72,23 +52,6 @@ const addressRoutes: FastifyPluginCallback<Record<never, never>, Server, ZodType
     return cells;
   }
 
-  /**
-   * Filter cells by type script
-   */
-  function filterCellsByTypeScript(cells: Cell[], typeScript: Script) {
-    return cells.filter((cell) => {
-      if (!cell.cellOutput.type) {
-        return false;
-      }
-      // if typeScript.args is empty, only compare codeHash and hashType
-      if (!typeScript.args || typeScript.args === '0x') {
-        const script = { ...cell.cellOutput.type, args: '' };
-        return isScriptEqual(script, typeScript);
-      }
-      return isScriptEqual(cell.cellOutput.type, typeScript);
-    });
-  }
-
   fastify.get(
     '/:btc_address/assets',
     {
@@ -125,7 +88,7 @@ const addressRoutes: FastifyPluginCallback<Record<never, never>, Server, ZodType
       const { no_cache } = request.query;
       const utxos = await getUxtos(btc_address, no_cache);
       const cells = await getRgbppAssetsCells(btc_address, utxos, no_cache);
-      const typeScript = getTypeScript(request);
+      const typeScript = getTypeScript(request.query.type_script);
       const assetCells = typeScript ? filterCellsByTypeScript(cells, typeScript) : cells;
       return assetCells.map((cell) => {
         const typeHash = cell.cellOutput.type ? computeScriptHash(cell.cellOutput.type) : undefined;
@@ -175,7 +138,7 @@ const addressRoutes: FastifyPluginCallback<Record<never, never>, Server, ZodType
       const { btc_address } = request.params;
       const { no_cache } = request.query;
 
-      const typeScript = getTypeScript(request);
+      const typeScript = getTypeScript(request.query.type_script);
       if (!typeScript || !isTypeAssetSupported(typeScript, env.NETWORK === 'mainnet')) {
         throw fastify.httpErrors.badRequest('Unsupported type asset');
       }
@@ -189,6 +152,7 @@ const addressRoutes: FastifyPluginCallback<Record<never, never>, Server, ZodType
 
       let cells = await getRgbppAssetsCells(btc_address, utxos, no_cache);
       cells = typeScript ? filterCellsByTypeScript(cells, typeScript) : cells;
+
       const availableXudtBalances = await fastify.rgbppCollector.getRgbppBalanceByCells(cells);
       Object.keys(availableXudtBalances).forEach((key) => {
         const { amount, ...xudtInfo } = availableXudtBalances[key];
@@ -340,7 +304,7 @@ const addressRoutes: FastifyPluginCallback<Record<never, never>, Server, ZodType
     async (request) => {
       const { btc_address } = request.params;
       const { rgbpp_only, after_btc_txid } = request.query;
-      const typeScript = getTypeScript(request);
+      const typeScript = getTypeScript(request.query.type_script);
 
       const btcTxs = await fastify.bitcoin.getAddressTxs({
         address: btc_address,

src/routes/rgbpp/address.ts

@@ -2,11 +2,18 @@ import { FastifyPluginCallback } from 'fastify';
 import { ZodTypeProvider } from 'fastify-type-provider-zod';
 import { Server } from 'http';
 import z from 'zod';
-import { Cell } from './types';
+import { Cell, Script, SporeTypeInfo, XUDTTypeInfo } from './types';
 import { UTXO } from '../../services/bitcoin/schema';
+import { getTypeScript } from '../../utils/typescript';
+import { Env } from '../../env';
+import { IndexerCell, isSporeTypeSupported, isUDTTypeSupported } from '@rgbpp-sdk/ckb';
 import { computeScriptHash } from '@ckb-lumos/lumos/utils';
+import { getSporeConfig, unpackToRawClusterData, unpackToRawSporeData } from '../../utils/spore';
+import { SearchKey } from '../../services/rgbpp';
 
 const assetsRoute: FastifyPluginCallback<Record<never, never>, Server, ZodTypeProvider> = (fastify, _, done) => {
+  const env: Env = fastify.container.resolve('env');
+
   fastify.get(
     '/:btc_txid',
     {
@@ -97,6 +104,108 @@ const assetsRoute: FastifyPluginCallback<Record<never, never>, Server, ZodTypePr
     },
   );
 
+  fastify.get(
+    '/type',
+    {
+      schema: {
+        description: 'Get RGB++ assets type info by typescript',
+        tags: ['RGB++@Unstable'],
+        querystring: z.object({
+          type_script: Script.or(z.string())
+            .optional()
+            .describe(
+              `
+              type script to filter cells
+
+              two ways to provide:
+              - as a object: 'encodeURIComponent(JSON.stringify({"codeHash":"0x...", "args":"0x...", "hashType":"type"}))'
+              - as a hex string: '0x...' (You can pack by @ckb-lumos/codec blockchain.Script.pack({ "codeHash": "0x...", ... }))
+            `,
+            ),
+        }),
+        response: {
+          200: z
+            .union([
+              z
+                .object({
+                  type: z.literal('xudt'),
+                })
+                .merge(XUDTTypeInfo),
+              z
+                .object({
+                  type: z.literal('spore'),
+                })
+                .merge(SporeTypeInfo),
+            ])
+            .nullable(),
+        },
+      },
+    },
+    async (request) => {
+      const isMainnet = env.NETWORK === 'mainnet';
+      const typeScript = getTypeScript(request.query.type_script);
+      if (!typeScript) {
+        return null;
+      }
+      if (isUDTTypeSupported(typeScript, isMainnet)) {
+        const infoCell = await fastify.ckb.getInfoCellData(typeScript);
+        const typeHash = computeScriptHash(typeScript);
+        if (!infoCell) {
+          return null;
+        }
+        return {
+          type: 'xudt' as const,
+          type_hash: typeHash,
+          type_script: typeScript,
+          ...infoCell,
+        };
+      }
+      if (isSporeTypeSupported(typeScript, isMainnet)) {
+        const searchKey: SearchKey = {
+          script: typeScript,
+          scriptType: 'type',
+          withData: true,
+        };
+        const result = await fastify.ckb.rpc.getCells(searchKey, 'desc', '0x1');
+        const [sporeCell] = result.objects;
+        const sporeData = unpackToRawSporeData(sporeCell.outputData!);
+        const sporeInfo: SporeTypeInfo = {
+          contentType: sporeData.contentType,
+        };
+        if (sporeData.clusterId) {
+          const sporeConfig = getSporeConfig(isMainnet);
+          const batchRequest = fastify.ckb.rpc.createBatchRequest(
+            sporeConfig.scripts.Cluster.versions.map((version) => {
+              const clusterScript = {
+                ...version.script,
+                args: sporeData.clusterId!,
+              };
+              const searchKey: SearchKey = {
+                script: clusterScript,
+                scriptType: 'type',
+                withData: true,
+              };
+              return ['getCells', searchKey, 'desc', '0x1'];
+            }),
+          );
+          const cells = await batchRequest.exec();
+          const [cell] = cells.map(({ objects }: { objects: IndexerCell[] }) => objects).flat();
+          const clusterData = unpackToRawClusterData(cell.outputData!);
+          sporeInfo.cluster = {
+            id: sporeData.clusterId,
+            name: clusterData.name,
+            description: clusterData.description,
+          };
+        }
+        return {
+          type: 'spore' as const,
+          ...sporeInfo,
+        };
+      }
+      return null;
+    },
+  );
+
   done();
 };
 

src/routes/rgbpp/assets.ts

@@ -83,16 +83,34 @@ export const CKBVirtualResult = z.object({
 });
 export type CKBVirtualResult = z.infer<typeof CKBVirtualResult>;
 
-export const XUDTBalance = z.object({
+export const XUDTTypeInfo = z.object({
+  symbol: z.string(),
   name: z.string(),
   decimal: z.number(),
-  symbol: z.string(),
-  total_amount: z.string(),
-  available_amount: z.string(),
-  pending_amount: z.string(),
   type_hash: z.string(),
   type_script: Script,
 });
+export type XUDTTypeInfo = z.infer<typeof XUDTTypeInfo>;
+
+export const SporeTypeInfo = z.object({
+  contentType: z.string(),
+  cluster: z
+    .object({
+      id: z.string(),
+      name: z.string(),
+      description: z.string(),
+    })
+    .optional(),
+});
+export type SporeTypeInfo = z.infer<typeof SporeTypeInfo>;
+
+export const XUDTBalance = XUDTTypeInfo.merge(
+  z.object({
+    total_amount: z.string(),
+    available_amount: z.string(),
+    pending_amount: z.string(),
+  }),
+);
 export type XUDTBalance = z.infer<typeof XUDTBalance>;
 
 export const IsomorphicTransaction = z.object({