feat(sdk): implement transaction progress streaming (MettaChain#167)

Author: victor-134

sdk/frontend/src/client/EscrowClient.ts

@@ -8,7 +8,7 @@
  */
 
 import type { PropertyRegistryClient, Signer } from './PropertyRegistryClient';
-import type { EscrowInfo, TxResult } from '../types';
+import type { EscrowInfo, TxResult, TxProgressCallback } from '../types';
 
 /**
  * Focused client for escrow operations.
@@ -56,8 +56,9 @@ export class EscrowClient {
     buyer: string,
     seller: string,
     amount: bigint,
+    onProgress?: TxProgressCallback,
   ): Promise<{ escrowId: number } & TxResult> {
-    return this.registryClient.createEscrow(signer, propertyId, buyer, seller, amount);
+    return this.registryClient.createEscrow(signer, propertyId, buyer, seller, amount, onProgress);
   }
 
   /**
@@ -66,8 +67,8 @@ export class EscrowClient {
    * @param signer - Authorized account
    * @param escrowId - Escrow to release
    */
-  async release(signer: Signer, escrowId: number): Promise<TxResult> {
-    return this.registryClient.releaseEscrow(signer, escrowId);
+  async release(signer: Signer, escrowId: number, onProgress?: TxProgressCallback): Promise<TxResult> {
+    return this.registryClient.releaseEscrow(signer, escrowId, onProgress);
   }
 
   /**
@@ -76,8 +77,8 @@ export class EscrowClient {
    * @param signer - Authorized account
    * @param escrowId - Escrow to refund
    */
-  async refund(signer: Signer, escrowId: number): Promise<TxResult> {
-    return this.registryClient.refundEscrow(signer, escrowId);
+  async refund(signer: Signer, escrowId: number, onProgress?: TxProgressCallback): Promise<TxResult> {
+    return this.registryClient.refundEscrow(signer, escrowId, onProgress);
   }
 
   /**

sdk/frontend/src/client/OracleClient.ts

@@ -19,9 +19,10 @@ import type {
   VolatilityMetrics,
   PropertyType,
   OracleSource,
-  TxResult,
   ContractEvent,
   ClientOptions,
+  TxProgressCallback,
+  TxProgressStatus,
 } from '../types';
 import { decodeContractError, TransactionError, GasEstimationError } from '../utils/errors';
 import { decodeTransactionEvents } from '../utils/events';
@@ -131,8 +132,9 @@ export class OracleClient {
   async requestValuation(
     signer: Signer,
     propertyId: number,
+    onProgress?: TxProgressCallback,
   ): Promise<{ requestId: number } & TxResult> {
-    const txResult = await this.submitTx(signer, 'request_valuation', [propertyId]);
+    const txResult = await this.submitTx(signer, 'request_valuation', [propertyId], onProgress);
     return { requestId: 0, ...txResult };
   }
 
@@ -145,8 +147,9 @@ export class OracleClient {
   async batchRequestValuations(
     signer: Signer,
     propertyIds: number[],
+    onProgress?: TxProgressCallback,
   ): Promise<TxResult> {
-    return this.submitTx(signer, 'batch_request_valuations', [propertyIds]);
+    return this.submitTx(signer, 'batch_request_valuations', [propertyIds], onProgress);
   }
 
   // ==========================================================================
@@ -156,15 +159,15 @@ export class OracleClient {
   /**
    * Adds an oracle source (admin only).
    */
-  async addSource(signer: Signer, source: OracleSource): Promise<TxResult> {
-    return this.submitTx(signer, 'add_source', [source]);
+  async addSource(signer: Signer, source: OracleSource, onProgress?: TxProgressCallback): Promise<TxResult> {
+    return this.submitTx(signer, 'add_source', [source], onProgress);
   }
 
   /**
    * Removes an oracle source (admin only).
    */
-  async removeSource(signer: Signer, sourceId: string): Promise<TxResult> {
-    return this.submitTx(signer, 'remove_source', [sourceId]);
+  async removeSource(signer: Signer, sourceId: string, onProgress?: TxProgressCallback): Promise<TxResult> {
+    return this.submitTx(signer, 'remove_source', [sourceId], onProgress);
   }
 
   /**
@@ -211,6 +214,7 @@ export class OracleClient {
     signer: Signer,
     method: string,
     args: unknown[],
+    onProgress?: TxProgressCallback,
   ): Promise<TxResult> {
     const signerAddress = typeof signer === 'string' ? signer : signer.address;
 
@@ -246,7 +250,26 @@ export class OracleClient {
         signer as KeyringPair,
         {},
         ({ status, events: rawEvents, dispatchError }) => {
+          if (status.isReady && onProgress) {
+            onProgress({ status: TxProgressStatus.Ready, txHash: tx.hash.toString() });
+          } else if (status.isBroadcast && onProgress) {
+            onProgress({ status: TxProgressStatus.Broadcast, txHash: tx.hash.toString() });
+          } else if (status.isInBlock && onProgress) {
+            onProgress({
+              status: TxProgressStatus.InBlock,
+              txHash: tx.hash.toString(),
+              blockHash: status.asInBlock.toString()
+            });
+          }
+
           if (dispatchError) {
+            if (onProgress) {
+              onProgress({
+                status: TxProgressStatus.Error,
+                txHash: tx.hash.toString(),
+                message: dispatchError.toString()
+              });
+            }
             reject(
               new TransactionError(
                 `Transaction failed: ${dispatchError.toString()}`,
@@ -259,6 +282,14 @@ export class OracleClient {
 
           if (status.isFinalized) {
             const blockHash = status.asFinalized.toString();
+            if (onProgress) {
+              onProgress({
+                status: TxProgressStatus.Finalized,
+                txHash: tx.hash.toString(),
+                blockHash
+              });
+            }
+
             const decodedEvents: ContractEvent[] = decodeTransactionEvents(
               this.abi,
               rawEvents as unknown as Array<{