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."""
@@ -221,6 +222,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."""
@@ -344,6 +350,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!]!
@@ -1656,6 +1663,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."""
@@ -1964,6 +1976,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,36 @@
+import { getPendingOnChainTransactionsForWallets } from "../wallets/get-pending-onchain-transactions-for-wallets"
+
+import { RepositoryError } from "@/domain/errors"
+import { checkedToWalletId } from "@/domain/wallets"
+import { WalletsRepository } from "@/services/mongoose"
+
+export const getPendingOnChainTransactionsForAccountByWalletIds = async ({
+  account,
+  walletIds,
+}: {
+  account: Account
+  walletIds?: string[]
+}): Promise<WalletOnChainSettledTransaction[] | ApplicationError> => {
+  const walletsRepo = WalletsRepository()
+
+  const accountWallets = await walletsRepo.listByAccountId(account.id)
+  if (accountWallets instanceof RepositoryError) return accountWallets
+
+  if (!walletIds) {
+    return getPendingOnChainTransactionsForWallets({ wallets: accountWallets })
+  }
+
+  const checkedWalletIds: WalletId[] = []
+
+  for (const walletId of walletIds) {
+    const checkedWalletId = checkedToWalletId(walletId)
+    if (checkedWalletId instanceof Error) return checkedWalletId
+    checkedWalletIds.push(checkedWalletId)
+  }
+
+  const selectedWallets = accountWallets.filter((wallet) =>
+    checkedWalletIds.includes(wallet.id),
+  )
+
+  return getPendingOnChainTransactionsForWallets({ wallets: selectedWallets })
+}

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/business-account.ts

@@ -6,7 +6,9 @@ import DisplayCurrency from "../../../shared/types/scalar/display-currency"
 
 import AccountLevel from "../../../shared/types/scalar/account-level"
 
-import { TransactionConnection } from "../../../shared/types/object/transaction"
+import Transaction, {
+  TransactionConnection,
+} from "../../../shared/types/object/transaction"
 
 import RealtimePrice from "./realtime-price"
 import { NotificationSettings } from "./notification-settings"
@@ -158,6 +160,28 @@ const BusinessAccount = GT.Object({
         )
       },
     },
+    pendingTransactions: {
+      type: GT.NonNullList(Transaction),
+      args: {
+        walletIds: {
+          type: GT.List(WalletId),
+        },
+      },
+      resolve: async (source, args) => {
+        const { walletIds } = args
+
+        const transactions =
+          await Accounts.getPendingOnChainTransactionsForAccountByWalletIds({
+            account: source,
+            walletIds,
+          })
+
+        if (transactions instanceof Error) {
+          throw mapError(transactions)
+        }
+        return transactions
+      },
+    },
     notificationSettings: {
       type: GT.NonNull(NotificationSettings),
       resolve: (source) => source.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,28 @@ const ConsumerAccount = GT.Object<Account, GraphQLPublicContextAuth>({
         )
       },
     },
+    pendingTransactions: {
+      type: GT.NonNullList(Transaction),
+      args: {
+        walletIds: {
+          type: GT.List(WalletId),
+        },
+      },
+      resolve: async (source, args) => {
+        const { walletIds } = args
+
+        const transactions =
+          await Accounts.getPendingOnChainTransactionsForAccountByWalletIds({
+            account: source,
+            walletIds,
+          })
+
+        if (transactions instanceof Error) {
+          throw mapError(transactions)
+        }
+        return transactions
+      },
+    },
 
     notificationSettings: {
       type: GT.NonNull(NotificationSettings),