TransactionManager offer a simple way to query and cache the pending transactions, it means you can get the pending cells without waiting for the transaction to be confirmed.
The easiest way to use the module is to use the RPCTransactionManager class, which uses the RPC module to query the pending transactions.
const indexer = new RPCTransactionManager({ rpcUrl: "https://localhost:8114" });
const collector = indexer.collector({ lock: aliceLock });
for await (const cell of collector.collect()) {
// do something with the cell
}Tips:
The
collectormethod accepts the same options as theCkbIndexerQueryOptionsof the@ckb-lumos/indexermodule, but it is a little different from theCkbIndexerQueryOptionswhen querying pending cells.
skipis suppressed whencollector(queryOptions), and whenusePendingCellsis set totruefromBlockandtoBlockare ignored, pending cells will be returned regardless of the block number.- when
orderis set todesc, the pending cells will be returned first
TransactionManager use an in-memory cache to store the pending transactions by default, but you can also use your own cache storage by passing the storage options.
import { Store } from "@ckb-lumos/transaction-manager";
// set a prefix to avoid the key conflicts other libraries
const CUSTOM_KEY_PREFIX = "__lumos_store__";
const storage: Store = {
getItem(key) {
const customKey = CUSTOM_KEY_PREFIX + key;
const value = window.localStorage.getItem(customKey);
if (!value) return value;
// deep clone to avoid the value being modified by the caller
return JSON.parse(value)[customKey];
},
hasItem(key) {
return !!window.localStorage.getItem(CUSTOM_KEY_PREFIX + key);
},
removeItem(key) {
window.localStorage.removeItem(CUSTOM_KEY_PREFIX + key);
},
setItem(key, value) {
window.localStorage.setItem(CUSTOM_KEY_PREFIX + key, JSON.stringify(value));
},
};
new RPCTransactionManager({ rpcUrl: "http://localhost:8114", storage });