feat(service): support /rgbpp/v1/address/{btc_address}/activity

.changeset/odd-cheetahs-shake.md

@@ -0,0 +1,5 @@
+---
+"@rgbpp-sdk/service": minor
+---
+
+Add support of /rgbpp/v1/address/{btc_address}/activity API for querying RGBPP asset activities by an BTC address

packages/service/README.md

@@ -161,6 +161,7 @@ interface BaseApiRequestOptions extends RequestInit {
   params?: Record<string, any>;
   method?: 'GET' | 'POST';
   requireToken?: boolean;
+  allow404?: boolean;
 }
 
 interface BtcAssetsApiToken {
@@ -188,7 +189,6 @@ interface BtcApis {
 interface BtcApiBlockchainInfo {
   chain: string;
   blocks: number;
-  headers: number;
   bestblockhash: number;
   difficulty: number;
   mediantime: number;
@@ -222,11 +222,18 @@ interface BtcApiBlockTransactionIds {
   txids: string[];
 }
 
+interface BtcApiRecommendedFeeRates {
+  fastestFee: number;
+  halfHourFee: number;
+  hourFee: number;
+  economyFee: number;
+  minimumFee: number;
+}
+
 interface BtcApiBalanceParams {
   min_satoshi?: number;
   no_cache?: boolean;
 }
-
 interface BtcApiBalance {
   address: string;
   // @deprecated Use available_satoshi instead
@@ -245,7 +252,6 @@ interface BtcApiUtxoParams {
   min_satoshi?: number;
   no_cache?: boolean;
 }
-
 interface BtcApiUtxo {
   txid: string;
   vout: number;
@@ -262,7 +268,7 @@ interface BtcApiSentTransaction {
   txid: string;
 }
 
-export interface BtcApiTransactionParams {
+interface BtcApiTransactionParams {
   after_txid?: string;
 }
 
@@ -312,9 +318,11 @@ interface RgbppApis {
   getRgbppPaymasterInfo(): Promise<RgbppApiPaymasterInfo>;
   getRgbppTransactionHash(btcTxId: string): Promise<RgbppApiCkbTransactionHash>;
   getRgbppTransactionState(btcTxId: string): Promise<RgbppApiTransactionState>;
-  getRgbppAssetsByBtcTxId(btcTxId: string): Promise<Cell[]>;
-  getRgbppAssetsByBtcUtxo(btcTxId: string, vout: number): Promise<Cell[]>;
-  getRgbppAssetsByBtcAddress(btcAddress: string, params?: RgbppApiAssetsByAddressParams): Promise<Cell[]>;
+  getRgbppAssetsByBtcTxId(btcTxId: string): Promise<RgbppCell[]>;
+  getRgbppAssetsByBtcUtxo(btcTxId: string, vout: number): Promise<RgbppCell[]>;
+  getRgbppAssetsByBtcAddress(btcAddress: string, params?: RgbppApiAssetsByAddressParams): Promise<RgbppCell[]>;
+  getRgbppBalanceByBtcAddress(btcAddress: string, params?: RgbppApiBalanceByAddressParams): Promise<RgbppApiBalance>;
+  getRgbppActivityByBtcAddress(btcAddress: string, params?: RgbppApiActivityByAddressParams): Promise<RgbppApiActivity>;
   getRgbppSpvProof(btcTxId: string, confirmations: number): Promise<RgbppApiSpvProof>;
   sendRgbppCkbTransaction(payload: RgbppApiSendCkbTransactionPayload): Promise<RgbppApiTransactionState>;
   retryRgbppCkbTransaction(payload: RgbppApiRetryCkbTransactionPayload): Promise<RgbppApiTransactionRetry>;
@@ -331,15 +339,76 @@ interface RgbppApiCkbTransactionHash {
   txhash: string;
 }
 
+interface RgbppApiTransactionStateParams {
+  with_data?: boolean;
+}
+
 interface RgbppApiTransactionState {
   state: RgbppTransactionState;
+  attempts: number;
+  failedReason?: string;
+  data?: {
+    txid: string;
+    ckbVirtualResult: {
+      ckbRawTx: CKBComponents.RawTransaction;
+      needPaymasterCell: boolean;
+      sumInputsCapacity: string;
+      commitment: string;
+    };
+  };
+}
+
+interface RgbppCell extends Cell {
+  typeHash?: Hash;
 }
 
 interface RgbppApiAssetsByAddressParams {
   type_script?: string;
   no_cache?: boolean;
 }
 
+interface RgbppApiBalanceByAddressParams {
+  type_script?: string;
+  no_cache?: boolean;
+}
+interface RgbppApiBalance {
+  address: string;
+  xudt: RgbppApiXudtBalance[];
+}
+interface RgbppApiXudtBalance {
+  name: string;
+  decimal: number;
+  symbol: string;
+  total_amount: string;
+  available_amount: string;
+  pending_amount: string;
+  type_hash: string;
+  type_script: Script;
+}
+
+interface RgbppApiActivityByAddressParams {
+  rgbpp_only?: boolean;
+  type_script?: string;
+  after_btc_txid?: string;
+}
+interface RgbppApiActivity {
+  address: string;
+  cursor: string;
+  txs: {
+    btcTx: BtcApiTransaction;
+    isRgbpp: boolean;
+    isomorphicTx?: {
+      ckbVirtualTx?: CKBComponents.RawTransaction;
+      ckbTx?: CKBComponents.Transaction;
+      inputs?: CKBComponents.CellOutput[];
+      outputs?: CKBComponents.CellOutput[];
+      status: {
+        confirmed: boolean;
+      };
+    };
+  }[];
+}
+
 interface RgbppApiSpvProof {
   proof: string;
   spv_client: {
@@ -350,12 +419,14 @@ interface RgbppApiSpvProof {
 
 interface RgbppApiSendCkbTransactionPayload {
   btc_txid: string;
-  ckb_virtual_result: {
-    ckbRawTx: CKBComponents.RawTransaction;
-    needPaymasterCell: boolean;
-    sumInputsCapacity: string;
-    commitment: string;
-  };
+  // Support ckbVirtualTxResult and it's JSON string as request parameter
+  ckb_virtual_result: RgbppApiSendCkbVirtualResult | string;
+}
+interface RgbppApiSendCkbVirtualResult {
+  ckbRawTx: CKBComponents.RawTransaction;
+  needPaymasterCell: boolean;
+  sumInputsCapacity: string;
+  commitment: string;
 }
 
 interface RgbppApiRetryCkbTransactionPayload {
@@ -366,4 +437,5 @@ interface RgbppApiTransactionRetry {
   success: boolean;
   state: RgbppTransactionState;
 }
+
 ```

packages/service/src/service/service.ts

@@ -14,6 +14,8 @@ import {
   BtcApiUtxoParams,
   BtcApiTransactionParams,
   BtcApiRecommendedFeeRates,
+  RgbppApiActivityByAddressParams,
+  RgbppApiActivity,
 } from '../types';
 import {
   RgbppApis,
@@ -136,6 +138,12 @@ export class BtcAssetsApi extends BtcAssetsApiBase implements BtcApis, RgbppApis
     });
   }
 
+  getRgbppActivityByBtcAddress(btcAddress: string, params?: RgbppApiActivityByAddressParams) {
+    return this.request<RgbppApiActivity>(`/rgbpp/v1/address/${btcAddress}/activity`, {
+      params,
+    });
+  }
+
   getRgbppSpvProof(btcTxId: string, confirmations: number) {
     return this.request<RgbppApiSpvProof>('/rgbpp/v1/btc-spv/proof', {
       params: {

packages/service/src/types/btc.ts

@@ -15,7 +15,7 @@ export interface BtcApis {
 export interface BtcApiBlockchainInfo {
   chain: string;
   blocks: number;
-  bestblockhash: number;
+  bestblockhash: string;
   difficulty: number;
   mediantime: number;
 }

packages/service/src/types/rgbpp.ts

@@ -1,4 +1,5 @@
 import { Cell, Hash, Script } from '@ckb-lumos/base';
+import { BtcApiTransaction } from './btc';
 
 export interface RgbppApis {
   getRgbppPaymasterInfo(): Promise<RgbppApiPaymasterInfo>;
@@ -8,6 +9,7 @@ export interface RgbppApis {
   getRgbppAssetsByBtcUtxo(btcTxId: string, vout: number): Promise<RgbppCell[]>;
   getRgbppAssetsByBtcAddress(btcAddress: string, params?: RgbppApiAssetsByAddressParams): Promise<RgbppCell[]>;
   getRgbppBalanceByBtcAddress(btcAddress: string, params?: RgbppApiBalanceByAddressParams): Promise<RgbppApiBalance>;
+  getRgbppActivityByBtcAddress(btcAddress: string, params?: RgbppApiActivityByAddressParams): Promise<RgbppApiActivity>;
   getRgbppSpvProof(btcTxId: string, confirmations: number): Promise<RgbppApiSpvProof>;
   sendRgbppCkbTransaction(payload: RgbppApiSendCkbTransactionPayload): Promise<RgbppApiTransactionState>;
   retryRgbppCkbTransaction(payload: RgbppApiRetryCkbTransactionPayload): Promise<RgbppApiTransactionRetry>;
@@ -71,6 +73,29 @@ export interface RgbppApiXudtBalance {
   type_script: Script;
 }
 
+export interface RgbppApiActivityByAddressParams {
+  rgbpp_only?: boolean;
+  type_script?: string;
+  after_btc_txid?: string;
+}
+export interface RgbppApiActivity {
+  address: string;
+  cursor: string;
+  txs: {
+    btcTx: BtcApiTransaction;
+    isRgbpp: boolean;
+    isomorphicTx?: {
+      ckbVirtualTx?: CKBComponents.RawTransaction;
+      ckbTx?: CKBComponents.Transaction;
+      inputs?: CKBComponents.CellOutput[];
+      outputs?: CKBComponents.CellOutput[];
+      status: {
+        confirmed: boolean;
+      };
+    };
+  }[];
+}
+
 export interface RgbppApiSpvProof {
   proof: string;
   spv_client: {
@@ -81,15 +106,14 @@ export interface RgbppApiSpvProof {
 
 export interface RgbppApiSendCkbTransactionPayload {
   btc_txid: string;
-  // Support ckbVirtaulTxResult and it's JSON string as request parameter
-  ckb_virtual_result:
-    | {
-        ckbRawTx: CKBComponents.RawTransaction;
-        needPaymasterCell: boolean;
-        sumInputsCapacity: string;
-        commitment: string;
-      }
-    | string;
+  // Support ckbVirtualTxResult and it's JSON string as request parameter
+  ckb_virtual_result: RgbppApiSendCkbVirtualResult | string;
+}
+export interface RgbppApiSendCkbVirtualResult {
+  ckbRawTx: CKBComponents.RawTransaction;
+  needPaymasterCell: boolean;
+  sumInputsCapacity: string;
+  commitment: string;
 }
 
 export interface RgbppApiRetryCkbTransactionPayload {

packages/service/tests/Service.test.ts

@@ -146,7 +146,6 @@ describe(
       });
       it('getBtcTransactions()', async () => {
         const res = await service.getBtcTransactions(btcAddress);
-        console.log(res.map((tx) => tx.txid));
         expect(Array.isArray(res)).toBe(true);
         expect(res.length).toBeGreaterThan(0);
         res.forEach((transaction) => {
@@ -277,6 +276,30 @@ describe(
           expectScript(xudt.type_script);
         }
       });
+      it('getRgbppActivityByBtcAddress()', async () => {
+        const res = await service.getRgbppActivityByBtcAddress(rgbppBtcAddress, {
+          type_script: rgbppCellType,
+        });
+        expect(res).toBeDefined();
+        expect(res.address).toBeTypeOf('string');
+        expect(res.cursor).toBeTypeOf('string');
+        expect(res.txs).toHaveProperty('length');
+        if (res.txs.length > 0) {
+          for (const tx of res.txs) {
+            expect(tx.btcTx).toBeDefined();
+            expect(tx.isRgbpp).toBeTypeOf('boolean');
+            if (tx.isRgbpp) {
+              expect(tx.isomorphicTx).toBeDefined();
+              expect(tx.isomorphicTx.status.confirmed).toBeTypeOf('boolean');
+              const hasTxOrVirtualTx = tx.isomorphicTx.ckbVirtualTx ?? tx.isomorphicTx.ckbTx;
+              if (hasTxOrVirtualTx) {
+                expect(tx.isomorphicTx.inputs).toBeDefined();
+                expect(tx.isomorphicTx.outputs).toBeDefined();
+              }
+            }
+          }
+        }
+      });
       it('getRgbppSpvProof()', async () => {
         const res = await service.getRgbppSpvProof(rgbppBtcTxId, 6);
         expect(res).toBeDefined();