Added getIsTransferInboundQueued method

Author: kev1n-peters

evm/ts/src/ntt.ts

@@ -151,11 +151,22 @@ export class EvmNtt<N extends Network, C extends EvmChains>
     );
     if (!isExecuted) return false;
     // Also check that the transfer is not queued for it to be considered complete
-    const queued = await this.getInboundQueuedTransfer(
-      attestation.emitterChain,
-      payload["nttManagerPayload"]
+    return !(await this.getIsTransferInboundQueued(attestation));
+  }
+
+  async getIsTransferInboundQueued(
+    attestation: Ntt.Attestation
+  ): Promise<boolean> {
+    const payload =
+      attestation.payloadName === "WormholeTransfer"
+        ? attestation.payload
+        : attestation.payload.payload;
+    return (
+      (await this.getInboundQueuedTransfer(
+        attestation.emitterChain,
+        payload["nttManagerPayload"]
+      )) !== null
     );
-    return queued === null;
   }
 
   getIsApproved(attestation: Ntt.Attestation): Promise<boolean> {

sdk/definitions/src/ntt.ts

@@ -241,6 +241,12 @@ export interface Ntt<N extends Network, C extends Chain> {
    */
   getIsExecuted(attestation: Ntt.Attestation): Promise<boolean>;
 
+  /**
+   * getIsTransferInboundQueued returns whether the transfer is inbound queued
+   * @param attestation the attestation to check
+   */
+  getIsTransferInboundQueued(attestation: Ntt.Attestation): Promise<boolean>;
+
   /**
    * getInboundQueuedTransfer returns the details of an inbound queued transfer
    * @param transceiverMessage the transceiver message

sdk/route/src/types.ts

@@ -175,7 +175,6 @@ export namespace NttRoute {
     capacity: bigint
   ): boolean {
     const threshold = (capacity * 95n) / 100n;
-    console.log(amount, threshold, amount > threshold);
     return amount > threshold;
   }
 }

solana/ts/sdk/ntt.ts

@@ -567,6 +567,25 @@ export class SolanaNtt<N extends Network, C extends SolanaChains>
     return !!inboxItem.releaseStatus.released;
   }
 
+  async getIsTransferInboundQueued(
+    attestation: Ntt.Attestation
+  ): Promise<boolean> {
+    if (attestation.payloadName !== "WormholeTransfer") return false;
+    const payload = attestation.payload["nttManagerPayload"];
+    let inboxItem;
+    try {
+      inboxItem = await this.program.account.inboxItem.fetch(
+        this.pdas.inboxItemAccount(attestation.emitterChain, payload)
+      );
+    } catch (e: any) {
+      if (e.message?.includes("Account does not exist")) {
+        return false;
+      }
+      throw e;
+    }
+    return !!inboxItem.releaseStatus.releaseAfter;
+  }
+
   async getIsApproved(attestation: Ntt.Attestation): Promise<boolean> {
     const digest = (attestation as WormholeNttTransceiver.VAA).hash;
     const vaaAddress = utils.derivePostedVaaKey(