feat: evaluateTx

Author: nelsonksh

packages/mesh-provider/package.json

@@ -37,8 +37,8 @@
   "dependencies": {
     "@meshsdk/common": "1.9.0-beta.43",
     "@meshsdk/core-cst": "1.9.0-beta.43",
-    "@utxorpc/sdk": "0.6.2",
-    "@utxorpc/spec": "0.10.1",
+    "@utxorpc/sdk": "^0.6.7",
+    "@utxorpc/spec": "^0.16.0",
     "axios": "^1.7.2"
   },
   "prettier": "@meshsdk/configs/prettier",

packages/mesh-provider/src/utxo-rpc.ts

@@ -18,6 +18,7 @@ import {
   IListener,
   ISubmitter,
   Protocol,
+  RedeemerTagType,
   toBytes,
   TransactionInfo,
   UTxO,
@@ -115,8 +116,7 @@ import { utxosToAssets } from "./common/utxos-to-assets";
  * ```
  */
 export class U5CProvider
-  implements IFetcher, ISubmitter, IEvaluator, IListener
-{
+  implements IFetcher, ISubmitter, IEvaluator, IListener {
   // Clients for querying and submitting transactions on the Cardano blockchain.
   private queryClient: CardanoQueryClient;
   private submitClient: CardanoSubmitClient;
@@ -176,8 +176,33 @@ export class U5CProvider
    * Evaluates the resources required to execute the transaction
    * @param tx - The transaction to evaluate
    */
-  evaluateTx(tx: string): Promise<Omit<Action, "data">[]> {
-    throw new Error("Method not implemented.");
+  async evaluateTx(tx: string): Promise<Omit<Action, "data">[]> {
+
+    const report = await this.submitClient.evalTx(hexToBytes(tx));
+    const evalResult = report.report[0]!.chain.value?.redeemers!;
+
+    const tagMap: { [key: number]: RedeemerTagType } = {
+      // 0: "UNSPECIFIED",   // REDEEMER_PURPOSE_UNSPECIFIED
+      1: "SPEND",   // REDEEMER_PURPOSE_SPEND
+      2: "MINT",    // REDEEMER_PURPOSE_MINT
+      3: "CERT",    // REDEEMER_PURPOSE_CERT
+      4: "REWARD",  // REDEEMER_PURPOSE_REWARD
+      5: "VOTE",    // REDEEMER_PURPOSE_VOTE
+      6: "PROPOSE", // REDEEMER_PURPOSE_PROPOSE
+    };
+
+    const result: Omit<Action, "data">[] = [];
+
+    evalResult.map((action: any) => {
+      result.push({
+        tag: tagMap[action.purpose!]!,
+        index: action.index,
+        budget: { mem: Number(action.exUnits!.memory), steps: Number(action.exUnits!.steps) },
+      });
+    })
+
+    return result;
+
   }
 
   /**
@@ -213,7 +238,7 @@ export class U5CProvider
    * @returns UTxOs for the given address
    */
   async fetchAddressUTxOs(address: string, asset?: string): Promise<UTxO[]> {
-    const addressBytes = Buffer.from(Address.fromBech32(address).toBytes());
+    const addressBytes = hexToBytes(Address.fromBech32(address).toBytes());
 
     const utxoSearchResult =
       await this.queryClient.searchUtxosByAddress(addressBytes);
@@ -344,13 +369,21 @@ export class U5CProvider
   }
 
   /**
-   * Unimplemented - open for contribution
+   * Not complete - open for contribution
    *
    * Fetches output UTxOs of a given transaction hash.
    * @param hash - The transaction hash
    */
-  fetchUTxOs(hash: string): Promise<UTxO[]> {
-    throw new Error("Method not implemented.");
+  async fetchUTxOs(hash: string, index?: number): Promise<UTxO[]> {
+    const utxoSearchResult = await this.queryClient.readUtxosByOutputRef(
+      [{
+        txHash: hexToBytes(hash),
+        outputIndex: index || 0,    // TODO: handle case when index is not provided. Note: readUtxos might not support this, try when readTx is implemented
+      }]
+    );
+    return utxoSearchResult.map((item) => {
+      return this._rpcUtxoToMeshUtxo(item.txoRef, item.parsedValued!);
+    });
   }
 
   /**