-- | Mempool queries

module Blockfrost.Client.Cardano.Mempool
  ( getMempoolTransactions
  , getMempoolTransactions'
  , getMempoolTransaction
  , getMempoolTransactionsByAddress
  , getMempoolTransactionsByAddress'
  ) where

import Blockfrost.API
import Blockfrost.Client.Types
import Blockfrost.Types

mempoolClient :: MonadBlockfrost m => Project -> MempoolAPI (AsClientT m)
mempoolClient :: forall (m :: * -> *).
MonadBlockfrost m =>
Project -> MempoolAPI (AsClientT m)
mempoolClient = ((Paged -> SortOrder -> m [TxHashObject])
 :<|> ((TxHash -> m MempoolTransaction)
       :<|> (Address -> Paged -> SortOrder -> m [TxHashObject])))
-> MempoolAPI (AsClientT m)
ToServant MempoolAPI (AsClientT m) -> MempoolAPI (AsClientT m)
forall {k} (routes :: k -> *) (mode :: k).
GenericServant routes mode =>
ToServant routes mode -> routes mode
fromServant (((Paged -> SortOrder -> m [TxHashObject])
  :<|> ((TxHash -> m MempoolTransaction)
        :<|> (Address -> Paged -> SortOrder -> m [TxHashObject])))
 -> MempoolAPI (AsClientT m))
-> (Project
    -> (Paged -> SortOrder -> m [TxHashObject])
       :<|> ((TxHash -> m MempoolTransaction)
             :<|> (Address -> Paged -> SortOrder -> m [TxHashObject])))
-> Project
-> MempoolAPI (AsClientT m)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. CardanoAPI (AsClientT m)
-> (Paged -> SortOrder -> m [TxHashObject])
   :<|> ((TxHash -> m MempoolTransaction)
         :<|> (Address -> Paged -> SortOrder -> m [TxHashObject]))
CardanoAPI (AsClientT m)
-> AsClientT m
   :- ("mempool"
       :> (Tag "Cardano \187 Mempool" :> ToServantApi MempoolAPI))
forall route.
CardanoAPI route
-> route
   :- ("mempool"
       :> (Tag "Cardano \187 Mempool" :> ToServantApi MempoolAPI))
_mempool (CardanoAPI (AsClientT m)
 -> (Paged -> SortOrder -> m [TxHashObject])
    :<|> ((TxHash -> m MempoolTransaction)
          :<|> (Address -> Paged -> SortOrder -> m [TxHashObject])))
-> (Project -> CardanoAPI (AsClientT m))
-> Project
-> (Paged -> SortOrder -> m [TxHashObject])
   :<|> ((TxHash -> m MempoolTransaction)
         :<|> (Address -> Paged -> SortOrder -> m [TxHashObject]))
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Project -> CardanoAPI (AsClientT m)
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> CardanoAPI (AsClientT m)
cardanoClient

getMempoolTransactions_ :: MonadBlockfrost m => Project -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactions_ :: forall (m :: * -> *).
MonadBlockfrost m =>
Project -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactions_ = MempoolAPI (AsClientT m)
-> AsClientT m
   :- (Summary "Transactions in Mempool."
       :> (Description
             "Tx hash list of all transactions that are currently stored in the mempool."
           :> (Pagination :> (Sorting :> Get '[JSON] [TxHashObject]))))
MempoolAPI (AsClientT m) -> Paged -> SortOrder -> m [TxHashObject]
forall route.
MempoolAPI route
-> route
   :- (Summary "Transactions in Mempool."
       :> (Description
             "Tx hash list of all transactions that are currently stored in the mempool."
           :> (Pagination :> (Sorting :> Get '[JSON] [TxHashObject]))))
_mempoolTransactions (MempoolAPI (AsClientT m)
 -> Paged -> SortOrder -> m [TxHashObject])
-> (Project -> MempoolAPI (AsClientT m))
-> Project
-> Paged
-> SortOrder
-> m [TxHashObject]
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Project -> MempoolAPI (AsClientT m)
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> MempoolAPI (AsClientT m)
mempoolClient

-- | Get a list of transactions currently in Blockfrost.io mempool
-- Allows custom paging and ordering using 'Paged' and 'SortOrder'.
getMempoolTransactions' :: MonadBlockfrost m => Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactions' :: forall (m :: * -> *).
MonadBlockfrost m =>
Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactions' Paged
pg SortOrder
s = (Project -> m [TxHashObject]) -> m [TxHashObject]
forall (m :: * -> *) a.
MonadBlockfrost m =>
(Project -> m a) -> m a
go (\Project
p -> Project -> Paged -> SortOrder -> m [TxHashObject]
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactions_ Project
p Paged
pg SortOrder
s)

-- | Get a list of transactions currently in Blockfrost.io mempool
--
-- Queries 100 entries. To query all entries use 'Blockfrost.Client.Core.allPages'
-- with principled variant of this function (suffixed with @'@)
-- that accepts 'Paged' argument.
getMempoolTransactions :: MonadBlockfrost m => m [TxHashObject]
getMempoolTransactions :: forall (m :: * -> *). MonadBlockfrost m => m [TxHashObject]
getMempoolTransactions = Paged -> SortOrder -> m [TxHashObject]
forall (m :: * -> *).
MonadBlockfrost m =>
Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactions' Paged
forall a. Default a => a
def SortOrder
forall a. Default a => a
def

getMempoolTransaction_ :: MonadBlockfrost m => Project -> TxHash -> m MempoolTransaction
getMempoolTransaction_ :: forall (m :: * -> *).
MonadBlockfrost m =>
Project -> TxHash -> m MempoolTransaction
getMempoolTransaction_ = MempoolAPI (AsClientT m)
-> AsClientT m
   :- (Summary "Transaction in mempoool."
       :> (Description "Content of a specific transaction in the mempool."
           :> (Capture "hash" TxHash :> Get '[JSON] MempoolTransaction)))
MempoolAPI (AsClientT m) -> TxHash -> m MempoolTransaction
forall route.
MempoolAPI route
-> route
   :- (Summary "Transaction in mempoool."
       :> (Description "Content of a specific transaction in the mempool."
           :> (Capture "hash" TxHash :> Get '[JSON] MempoolTransaction)))
_specificTransaction (MempoolAPI (AsClientT m) -> TxHash -> m MempoolTransaction)
-> (Project -> MempoolAPI (AsClientT m))
-> Project
-> TxHash
-> m MempoolTransaction
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Project -> MempoolAPI (AsClientT m)
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> MempoolAPI (AsClientT m)
mempoolClient

-- | Get details about a specific @MempoolTransaction@
getMempoolTransaction :: MonadBlockfrost m => TxHash -> m MempoolTransaction
getMempoolTransaction :: forall (m :: * -> *).
MonadBlockfrost m =>
TxHash -> m MempoolTransaction
getMempoolTransaction TxHash
t = (Project -> m MempoolTransaction) -> m MempoolTransaction
forall (m :: * -> *) a.
MonadBlockfrost m =>
(Project -> m a) -> m a
go (Project -> TxHash -> m MempoolTransaction
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> TxHash -> m MempoolTransaction
`getMempoolTransaction_` TxHash
t)

getMempoolTransactionsByAddress_ :: MonadBlockfrost m => Project -> Address -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactionsByAddress_ :: forall (m :: * -> *).
MonadBlockfrost m =>
Project -> Address -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactionsByAddress_ = MempoolAPI (AsClientT m)
-> AsClientT m
   :- (Summary "Transactions involving an address in mempool."
       :> (Description
             "List of transactions in the mempool that involves a specific address."
           :> ("addresses"
               :> (Capture "address" Address
                   :> (Pagination :> (Sorting :> Get '[JSON] [TxHashObject]))))))
MempoolAPI (AsClientT m)
-> Address -> Paged -> SortOrder -> m [TxHashObject]
forall route.
MempoolAPI route
-> route
   :- (Summary "Transactions involving an address in mempool."
       :> (Description
             "List of transactions in the mempool that involves a specific address."
           :> ("addresses"
               :> (Capture "address" Address
                   :> (Pagination :> (Sorting :> Get '[JSON] [TxHashObject]))))))
_specificAddress (MempoolAPI (AsClientT m)
 -> Address -> Paged -> SortOrder -> m [TxHashObject])
-> (Project -> MempoolAPI (AsClientT m))
-> Project
-> Address
-> Paged
-> SortOrder
-> m [TxHashObject]
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Project -> MempoolAPI (AsClientT m)
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> MempoolAPI (AsClientT m)
mempoolClient

-- | Get a list of transactions currently in Blockfrost.io mempool
-- where at least one of the transaction inputs or outputs belongs to the address.
-- Allows custom paging and ordering using 'Paged' and 'SortOrder'.
getMempoolTransactionsByAddress' :: MonadBlockfrost m => Address -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactionsByAddress' :: forall (m :: * -> *).
MonadBlockfrost m =>
Address -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactionsByAddress' Address
addr Paged
pg SortOrder
s = (Project -> m [TxHashObject]) -> m [TxHashObject]
forall (m :: * -> *) a.
MonadBlockfrost m =>
(Project -> m a) -> m a
go (\Project
p -> Project -> Address -> Paged -> SortOrder -> m [TxHashObject]
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> Address -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactionsByAddress_ Project
p Address
addr Paged
pg SortOrder
s)

-- | Get a list of transactions currently in Blockfrost.io mempool
-- where at least one of the transaction inputs or outputs belongs to the address.
--
-- Queries 100 entries. To query all entries use 'Blockfrost.Client.Core.allPages'
-- with principled variant of this function (suffixed with @'@)
-- that accepts 'Paged' argument.
getMempoolTransactionsByAddress :: MonadBlockfrost m => Address -> m [TxHashObject]
getMempoolTransactionsByAddress :: forall (m :: * -> *).
MonadBlockfrost m =>
Address -> m [TxHashObject]
getMempoolTransactionsByAddress Address
addr = (Project -> m [TxHashObject]) -> m [TxHashObject]
forall (m :: * -> *) a.
MonadBlockfrost m =>
(Project -> m a) -> m a
go (\Project
p -> Project -> Address -> Paged -> SortOrder -> m [TxHashObject]
forall (m :: * -> *).
MonadBlockfrost m =>
Project -> Address -> Paged -> SortOrder -> m [TxHashObject]
getMempoolTransactionsByAddress_ Project
p Address
addr Paged
forall a. Default a => a
def SortOrder
forall a. Default a => a
def)