feat: add pending tx queries

core/api/dev/apollo-federation/supergraph.graphql

@@ -32,6 +32,7 @@ interface Account
   level: AccountLevel!
   limits: AccountLimits!
   notificationSettings: NotificationSettings!
+  pendingTransactions(walletIds: [WalletId]): [Transaction!]!
   realtimePrice: RealtimePrice!
   transactions(
     """Returns the items in the list that come after the specified cursor."""
@@ -183,6 +184,11 @@ type BTCWallet implements Wallet
 
   """An unconfirmed incoming onchain balance."""
   pendingIncomingBalance: SignedAmount!
+  pendingTransactions: [Transaction!]!
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
 
   """A list of BTC transactions associated with this wallet."""
@@ -306,6 +312,7 @@ type ConsumerAccount implements Account
   level: AccountLevel!
   limits: AccountLimits!
   notificationSettings: NotificationSettings!
+  pendingTransactions(walletIds: [WalletId]): [Transaction!]!
 
   """List the quiz questions of the consumer account"""
   quiz: [Quiz!]!
@@ -1617,6 +1624,11 @@ type UsdWallet implements Wallet
 
   """An unconfirmed incoming onchain balance."""
   pendingIncomingBalance: SignedAmount!
+  pendingTransactions: [Transaction!]!
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
   transactions(
     """Returns the items in the list that come after the specified cursor."""
@@ -1922,6 +1934,25 @@ interface Wallet
     paymentHash: PaymentHash!
   ): Invoice!
   pendingIncomingBalance: SignedAmount!
+
+  """
+  Pending OnChain transactions. When transactions
+  are confirmed they will receive a new id and be found in the transactions
+  list. Transactions are ordered anti-chronologically,
+  ie: the newest transaction will be first
+  """
+  pendingTransactions: [Transaction!]!
+
+  """
+  Pending OnChain transactions. When transactions
+  are confirmed they will receive a new id and be found in the transactions
+  list. Transactions are ordered anti-chronologically,
+  ie: the newest transaction will be first
+  """
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
 
   """

core/api/src/app/accounts/get-pending-onchain-transactions-for-account.ts

@@ -0,0 +1,33 @@
+import { getPendingOnChainTransactionsForWallets } from "../wallets/get-pending-onchain-transactions-for-wallets"
+
+import { AccountValidator } from "@/domain/accounts"
+import { RepositoryError } from "@/domain/errors"
+import { WalletsRepository } from "@/services/mongoose"
+import { checkedToWalletId } from "@/domain/wallets"
+
+export const getPendingOnChainTransactionsForAccountByWalletIds = async ({
+  account,
+  walletIds,
+}: {
+  account: Account
+  walletIds: string[]
+}): Promise<WalletOnChainSettledTransaction[] | ApplicationError> => {
+  const walletsRepo = WalletsRepository()
+
+  const wallets: Wallet[] = []
+  for (const uncheckedWalletId of walletIds) {
+    const walletId = checkedToWalletId(uncheckedWalletId)
+    if (walletId instanceof Error) return walletId
+    const wallet = await walletsRepo.findById(walletId)
+    if (wallet instanceof RepositoryError) return wallet
+
+    const accountValidator = AccountValidator(account)
+    if (accountValidator instanceof Error) return accountValidator
+    const validateWallet = accountValidator.validateWalletForAccount(wallet)
+    if (validateWallet instanceof Error) return validateWallet
+
+    wallets.push(wallet)
+  }
+
+  return getPendingOnChainTransactionsForWallets({ wallets })
+}

core/api/src/app/accounts/index.ts

@@ -25,6 +25,7 @@ export * from "./disable-notification-category"
 export * from "./enable-notification-category"
 export * from "./enable-notification-channel"
 export * from "./disable-notification-channel"
+export * from "./get-pending-onchain-transactions-for-account"
 
 const accounts = AccountsRepository()
 

core/api/src/app/wallets/get-pending-onchain-transactions-for-wallets.ts

@@ -0,0 +1,21 @@
+import { CouldNotFindError } from "@/domain/errors"
+
+import { WalletOnChainPendingReceiveRepository } from "@/services/mongoose"
+
+export const getPendingOnChainTransactionsForWallets = async ({
+  wallets,
+}: {
+  wallets: Wallet[]
+}): Promise<WalletOnChainSettledTransaction[] | ApplicationError> => {
+  const walletIds = wallets.map((wallet) => wallet.id)
+
+  const pendingHistory = await WalletOnChainPendingReceiveRepository().listByWalletIds({
+    walletIds,
+  })
+
+  if (pendingHistory instanceof CouldNotFindError) {
+    return []
+  }
+
+  return pendingHistory
+}

core/api/src/app/wallets/get-pending-transactions-by-addresses.ts

@@ -0,0 +1,25 @@
+import { CouldNotFindError } from "@/domain/errors"
+
+import { WalletOnChainPendingReceiveRepository } from "@/services/mongoose"
+
+export const getPendingTransactionsForWalletsByAddresses = async ({
+  wallets,
+  addresses,
+}: {
+  wallets: Wallet[]
+  addresses: OnChainAddress[]
+}): Promise<WalletOnChainSettledTransaction[] | ApplicationError> => {
+  const walletIds = wallets.map((wallet) => wallet.id)
+
+  const pendingHistory =
+    await WalletOnChainPendingReceiveRepository().listByWalletIdsAndAddresses({
+      walletIds,
+      addresses,
+    })
+
+  if (pendingHistory instanceof CouldNotFindError) {
+    return []
+  }
+
+  return pendingHistory
+}

core/api/src/app/wallets/index.ts

@@ -17,6 +17,8 @@ export * from "./update-legacy-on-chain-receipt"
 export * from "./update-pending-invoices"
 export * from "./validate"
 export * from "./get-invoice-for-wallet-by-hash"
+export * from "./get-pending-onchain-transactions-for-wallets"
+export * from "./get-pending-transactions-by-addresses"
 
 import { WalletsRepository } from "@/services/mongoose"
 

core/api/src/graphql/admin/schema.graphql

@@ -85,6 +85,11 @@ type BTCWallet implements Wallet {
 
   """An unconfirmed incoming onchain balance."""
   pendingIncomingBalance: SignedAmount!
+  pendingTransactions: [Transaction!]!
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
 
   """A list of BTC transactions associated with this wallet."""
@@ -424,6 +429,11 @@ type UsdWallet implements Wallet {
 
   """An unconfirmed incoming onchain balance."""
   pendingIncomingBalance: SignedAmount!
+  pendingTransactions: [Transaction!]!
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
   transactions(
     """Returns the items in the list that come after the specified cursor."""
@@ -480,6 +490,25 @@ interface Wallet {
     paymentHash: PaymentHash!
   ): Invoice!
   pendingIncomingBalance: SignedAmount!
+
+  """
+  Pending OnChain transactions. When transactions
+  are confirmed they will receive a new id and be found in the transactions
+  list. Transactions are ordered anti-chronologically,
+  ie: the newest transaction will be first
+  """
+  pendingTransactions: [Transaction!]!
+
+  """
+  Pending OnChain transactions. When transactions
+  are confirmed they will receive a new id and be found in the transactions
+  list. Transactions are ordered anti-chronologically,
+  ie: the newest transaction will be first
+  """
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
 
   """

core/api/src/graphql/public/schema.graphql

@@ -7,6 +7,7 @@ interface Account {
   level: AccountLevel!
   limits: AccountLimits!
   notificationSettings: NotificationSettings!
+  pendingTransactions(walletIds: [WalletId]): [Transaction!]!
   realtimePrice: RealtimePrice!
   transactions(
     """Returns the items in the list that come after the specified cursor."""
@@ -126,6 +127,11 @@ type BTCWallet implements Wallet {
 
   """An unconfirmed incoming onchain balance."""
   pendingIncomingBalance: SignedAmount!
+  pendingTransactions: [Transaction!]!
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
 
   """A list of BTC transactions associated with this wallet."""
@@ -227,6 +233,7 @@ type ConsumerAccount implements Account {
   level: AccountLevel!
   limits: AccountLimits!
   notificationSettings: NotificationSettings!
+  pendingTransactions(walletIds: [WalletId]): [Transaction!]!
 
   """List the quiz questions of the consumer account"""
   quiz: [Quiz!]!
@@ -1269,6 +1276,11 @@ type UsdWallet implements Wallet {
 
   """An unconfirmed incoming onchain balance."""
   pendingIncomingBalance: SignedAmount!
+  pendingTransactions: [Transaction!]!
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
   transactions(
     """Returns the items in the list that come after the specified cursor."""
@@ -1510,6 +1522,25 @@ interface Wallet {
     paymentHash: PaymentHash!
   ): Invoice!
   pendingIncomingBalance: SignedAmount!
+
+  """
+  Pending OnChain transactions. When transactions
+  are confirmed they will receive a new id and be found in the transactions
+  list. Transactions are ordered anti-chronologically,
+  ie: the newest transaction will be first
+  """
+  pendingTransactions: [Transaction!]!
+
+  """
+  Pending OnChain transactions. When transactions
+  are confirmed they will receive a new id and be found in the transactions
+  list. Transactions are ordered anti-chronologically,
+  ie: the newest transaction will be first
+  """
+  pendingTransactionsByAddress(
+    """Returns the items that include this address."""
+    address: OnChainAddress!
+  ): [Transaction!]!
   transactionById(transactionId: ID!): Transaction!
 
   """

core/api/src/graphql/public/types/abstract/account.ts

@@ -13,7 +13,9 @@ import WalletId from "@/graphql/shared/types/scalar/wallet-id"
 import AccountLimits from "@/graphql/public/types/object/account-limits"
 import RealtimePrice from "@/graphql/public/types/object/realtime-price"
 import DisplayCurrency from "@/graphql/shared/types/scalar/display-currency"
-import { TransactionConnection } from "@/graphql/shared/types/object/transaction"
+import Transaction, {
+  TransactionConnection,
+} from "@/graphql/shared/types/object/transaction"
 
 const IAccount = GT.Interface({
   name: "Account",
@@ -59,6 +61,14 @@ const IAccount = GT.Interface({
         },
       },
     },
+    pendingTransactions: {
+      type: GT.NonNullList(Transaction),
+      args: {
+        walletIds: {
+          type: GT.List(WalletId),
+        },
+      },
+    },
     notificationSettings: {
       type: GT.NonNull(NotificationSettings),
     },

core/api/src/graphql/public/types/object/consumer-account.ts

@@ -1,6 +1,8 @@
 import AccountLevel from "../../../shared/types/scalar/account-level"
 
-import { TransactionConnection } from "../../../shared/types/object/transaction"
+import Transaction, {
+  TransactionConnection,
+} from "../../../shared/types/object/transaction"
 
 import AccountLimits from "./account-limits"
 
@@ -206,6 +208,35 @@ const ConsumerAccount = GT.Object<Account, GraphQLPublicContextAuth>({
         )
       },
     },
+    pendingTransactions: {
+      type: GT.NonNullList(Transaction),
+      args: {
+        walletIds: {
+          type: GT.List(WalletId),
+        },
+      },
+      resolve: async (source, args) => {
+        let { walletIds } = args
+
+        if (!walletIds) {
+          const wallets = await WalletsRepository().listByAccountId(source.id)
+          if (wallets instanceof Error) {
+            throw mapError(wallets)
+          }
+          walletIds = wallets.map((wallet) => wallet.id)
+        }
+
+        const transactions =
+          await Accounts.getPendingOnChainTransactionsForAccountByWalletIds({
+            account: source,
+            walletIds,
+          })
+        if (transactions instanceof Error) {
+          throw mapError(transactions)
+        }
+        return transactions
+      },
+    },
 
     notificationSettings: {
       type: GT.NonNull(NotificationSettings),

core/api/src/graphql/shared/types/abstract/wallet.ts

@@ -48,6 +48,26 @@ const IWallet = GT.Interface({
         },
       },
     },
+    pendingTransactionsByAddress: {
+      description: dedent`Pending OnChain transactions. When transactions
+      are confirmed they will receive a new id and be found in the transactions
+      list. Transactions are ordered anti-chronologically,
+      ie: the newest transaction will be first`,
+      type: GT.NonNullList(Transaction),
+      args: {
+        address: {
+          type: GT.NonNull(OnChainAddress),
+          description: "Returns the items that include this address.",
+        },
+      },
+    },
+    pendingTransactions: {
+      description: dedent`Pending OnChain transactions. When transactions
+      are confirmed they will receive a new id and be found in the transactions
+      list. Transactions are ordered anti-chronologically,
+      ie: the newest transaction will be first`,
+      type: GT.NonNullList(Transaction),
+    },
     invoiceByPaymentHash: {
       type: GT.NonNull(IInvoice),
       args: {