NBitcoin.Indexer by Nicolas Dorier

<PackageReference Include="NBitcoin.Indexer" Version="2.0.6.23" />

---

API Diff between 2.0.6.23 and 1.0.0.25

347 Additions 36 Removals

NBitcoin.Indexer

• public class AddressEntry
• public class AzureIndexer
  • public class MempoolUpload
  • public static readonly Network InternalNetwork
  • public int BlkCount { get; set; }
  • public IndexerServerConfiguration Configuration { get; }
  • public int FromBlk { get; set; }
  • public bool NoSave { get; set; }
  • public int TaskCount { get; set; }
  • public AzureIndexer(IndexerServerConfiguration configuration)
  • public IndexerConfiguration Configuration { get; }
  • public int FromHeight { get; set; }
  • public bool IgnoreCheckpoints { get; set; }
  • public TaskScheduler TaskScheduler { get; set; }
  • public int ToHeight { get; set; }
  • public AzureIndexer(IndexerConfiguration configuration)
  • public TaskPool<TItem> CreateTaskPool<TItem>(BlockingCollection<TItem> collection, Action<TItem> action, int defaultTaskCount)
  • public void Index(Entity[] entries)
  • public BlockFetcher GetBlockFetcher(Checkpoint checkpoint, Node node, ChainBase chain = null)
  • public BlockFetcher GetBlockFetcher(string checkpointName, Node node, ChainBase chain = null)
  • public Checkpoint GetCheckpoint(IndexerCheckpoints checkpoint)
  • public Task<Checkpoint> GetCheckpointAsync(IndexerCheckpoints checkpoint)
  • public CheckpointRepository GetCheckpointRepository()
  • public ChainBase GetNodeChain()
  • public ChainBase GetNodeChain(Node node)
  • public void Index(Block[] blocks)
  • public void Index(Block block)
  • public void Index(Chain chain, int startHeight)
  • public void Index(ChainChangeEntry[] chainChanges)
  • public void IndexBalances()
  • public long IndexBlocks()
  • public void IndexMainChain()
  • public int IndexMempool()
  • public long IndexTransactions()
  • public void Index(IEnumerable<OrderedBalanceChange> balances)
  • public Task IndexAsync(Block[] blocks)
  • public Task IndexAsync(Entity[] entities)
  • public Task IndexAsync(IEnumerable<OrderedBalanceChange> balances)
  • public long IndexBlocks(ChainBase chain = null)
  • public void IndexChain(ChainBase chain)
  • public void IndexNodeMainChain()
  • public void IndexOrderedBalance(int height, Block block)
  • public void IndexOrderedBalance(Transaction tx)
  • public Task IndexOrderedBalanceAsync(Transaction tx)
  • public int IndexOrderedBalances(ChainBase chain)
  • public long IndexTransactions(ChainBase chain = null)
  • public void IndexTransactions(int height, Block block)
  • public int IndexWalletBalances(ChainBase chain)
  • public void IndexWalletOrderedBalance(int height, Block block, WalletRuleEntryCollection walletRules)
  • public Task IndexWalletOrderedBalanceAsync(int height, Block block, WalletRuleEntryCollection walletRules)
• public class BlockEnumerable : IEnumerable<StoredBlock>, IEnumerable
• public class ChainChangeEntry
• public class BalanceId
  • public bool ContainsScript { get; }
  • public string PartitionKey { get; }
  • public BalanceType Type { get; }
  • public BalanceId(string walletId)
  • public BalanceId(Script scriptPubKey)
  • public BalanceId(IDestination destination)
  • public static BalanceId Parse(string balanceId)
  • public Script ExtractScript()
  • public string GetWalletId()
• public abstract class BalanceLocator
  • protected BalanceLocator()
  • public static BalanceLocator Parse(string str)
  • public static BalanceLocator Parse(string str, bool queryFormat)
  • public abstract BalanceLocator Ceil()
  • public abstract BalanceLocator Floor()
  • public bool IsGreaterThan(BalanceLocator to)
  • public abstract string ToString(bool queryFormat)
• public class BalanceQuery
  • public BalanceLocator From { get; set; }
  • public bool FromIncluded { get; set; }
  • public IEnumerable<int> PageSizes { get; set; }
  • public bool RawOrdering { get; set; }
  • public BalanceLocator To { get; set; }
  • public bool ToIncluded { get; set; }
  • public BalanceQuery()
  • public TableQuery CreateTableQuery(BalanceId balanceId)
  • public TableQuery CreateTableQuery(string partitionId, string scope)
• public class BalanceSheet
  • public List<OrderedBalanceChange> All { get; }
  • public ChainBase Chain { get; }
  • public List<OrderedBalanceChange> Confirmed { get; }
  • public List<OrderedBalanceChange> Prunable { get; }
  • public List<OrderedBalanceChange> Unconfirmed { get; }
  • public BalanceSheet(IEnumerable<OrderedBalanceChange> changes, ChainBase chain)
• public enum BalanceType
  • Address = 1
  • Wallet = 0
• public class BlockFetcher : IEnumerable<BlockInfo>, IEnumerable
  • public ChainBase BlockHeaders { get; }
  • public IBlocksRepository BlocksRepository { get; }
  • public CancellationToken CancellationToken { get; set; }
  • public Checkpoint Checkpoint { get; }
  • public int FromHeight { get; set; }
  • public bool NeedSave { get; }
  • public TimeSpan NeedSaveInterval { get; set; }
  • public int ToHeight { get; set; }
  • public BlockFetcher(Checkpoint checkpoint, Node node, ChainBase chain = null)
  • public BlockFetcher(Checkpoint checkpoint, IBlocksRepository blocksRepository, ChainBase chain)
  • public IEnumerator<BlockInfo> GetEnumerator()
  • public void SaveCheckpoint()
• public class BlockInfo
  • public Block Block { get; set; }
  • public uint256 BlockId { get; set; }
  • public int Height { get; set; }
  • public BlockInfo()
• public class ChainBlockHeader
  • public uint256 BlockId { get; set; }
  • public BlockHeader Header { get; set; }
  • public int Height { get; set; }
  • public ChainBlockHeader()
• public static class ChainChangeEntryExtensions
  • public static void UpdateChain(this IEnumerable<ChainChangeEntry> entries, Chain chain)
  • public static void UpdateChain(this IEnumerable<ChainBlockHeader> entries, ChainBase chain)
• public class ChainPartEntry
  • public List<BlockHeader> BlockHeaders { get; }
  • public int ChainOffset { get; set; }
  • public ChainPartEntry()
  • public ChainPartEntry(DynamicTableEntity entity)
  • public BlockHeader GetHeader(int height)
  • public DynamicTableEntity ToEntity()
• public class Checkpoint
  • public BlockLocator BlockLocator { get; }
  • public string CheckpointName { get; }
  • public uint256 Genesis { get; }
  • public Checkpoint(string checkpointName, Network network, Stream data, CloudBlockBlob blob)
  • public static Task<Checkpoint> LoadBlobAsync(CloudBlockBlob blob, Network network)
  • public Task DeleteAsync()
  • public bool SaveProgress(ChainedBlock tip)
  • public bool SaveProgress(BlockLocator locator)
• public class CheckpointRepository
  • public string CheckpointSet { get; set; }
  • public CheckpointRepository(CloudBlobContainer container, Network network, string checkpointSet)
  • public void DeleteCheckpoints()
  • public Task DeleteCheckpointsAsync()
  • public Checkpoint GetCheckpoint(string checkpointName)
  • public Task<Checkpoint> GetCheckpointAsync(string checkpointName)
  • public Task<Checkpoint[]> GetCheckpointsAsync()
• public class CoinCollection : List<ICoin>
  • public ICoin this[OutPoint index] { get; set; }
  • public CoinCollection()
  • public CoinCollection(IEnumerable<ICoin> enumerable)
  • public IEnumerable<ColoredCoin> WhereColored(BitcoinAssetId assetId)
  • public IEnumerable<ColoredCoin> WhereColored(AssetId assetId)
  • public IEnumerable<Coin> WhereUncolored()
• public class ConfirmedBalanceLocator : BalanceLocator
  • public uint256 BlockHash { get; set; }
  • public int Height { get; set; }
  • public uint256 TransactionId { get; set; }
  • public ConfirmedBalanceLocator()
  • public ConfirmedBalanceLocator(OrderedBalanceChange change)
  • public ConfirmedBalanceLocator(int height, uint256 blockId = null, uint256 transactionId = null)
  • public static ConfirmedBalanceLocator Parse(string str)
• public class CustomThreadPoolTaskScheduler : TaskScheduler, IDisposable
  • public int AvailableThreads { get; }
  • public int QueuedCount { get; }
  • public int RemainingTasks { get; }
  • public int ThreadsCount { get; }
  • public CustomThreadPoolTaskScheduler(int threadCount, int maxQueued, string name = null)
  • public void Dispose()
  • public void WaitFinished()
• public static class Extensions
  • public static BalanceSheet AsBalanceSheet(this IEnumerable<OrderedBalanceChange> entries, ChainBase chain)
  • public static void Deserialize(this ITableEntity entity, byte[] value)
  • public static IEnumerable<T> Distinct<T, TComparer>(this IEnumerable<T> input, Func<T, TComparer> comparer)
  • public static string GetFatBlobName(this ITableEntity entity)
  • public static bool IsFat(this DynamicTableEntity entity)
  • public static void MakeFat(this DynamicTableEntity entity, int size)
  • public static CoinCollection SelectSpentCoins(this IEnumerable<OrderedBalanceChange> entries)
  • public static CoinCollection SelectUnspentCoins(this IEnumerable<OrderedBalanceChange> entries)
  • public static byte[] Serialize(this ITableEntity entity)
  • public static IEnumerable<OrderedBalanceChange> WhereConfirmed(this IEnumerable<OrderedBalanceChange> entries, ChainBase chain, int minConfirmation = 1)
  • public static IEnumerable<OrderedBalanceChange> WhereNotExpired(this IEnumerable<OrderedBalanceChange> entries)
  • public static IEnumerable<OrderedBalanceChange> WhereNotExpired(this IEnumerable<OrderedBalanceChange> entries, TimeSpan expiration)
• public class FastEncoder
  • public static FastEncoder Instance { get; }
  • public FastEncoder()
  • public byte[] DecodeData(string encoded)
  • public string EncodeData(byte[] data, int offset, int length)
  • public string EncodeData(byte[] data)
• public enum IndexerCheckpoints
  • Balances = 3
  • Blocks = 2
  • Transactions = 1
  • Wallets = 0
• public class IndexerClient
  • public int BalancePartitionSize { get; set; }
  • public bool ColoredBalance { get; set; }
  • public AddressEntry[][] GetAllEntries(BitcoinAddress[] addresses)
  • public ChainChangeEntry GetBestBlock()
  • public WalletRuleEntry AddWalletRule(string walletId, WalletRule walletRule)
  • public void CleanUnconfirmedChanges(IDestination destination, TimeSpan olderThan)
  • public void CleanUnconfirmedChanges(Script scriptPubKey, TimeSpan olderThan)
  • public Task<bool> EnsurePreviousLoadedAsync(OrderedBalanceChange change)
  • public WalletRuleEntryCollection GetAllWalletRules()
  • public ChainBlockHeader GetBestBlock()
  • public IEnumerable<ChainChangeEntry> GetChainChangesUntilFork(ChainedBlock currentTip, bool forkIncluded)
  • public AddressEntry[] GetEntries(BitcoinAddress address)
  • public AddressEntry[] GetEntries(KeyId keyId)
  • public AddressEntry[] GetEntries(ScriptId scriptId)
  • public AddressEntry[] GetEntries(BitcoinScriptAddress scriptAddress)
  • public AddressEntry[] GetEntries(PubKey pubKey)
  • public IEnumerable<ChainBlockHeader> GetChainChangesUntilFork(ChainedBlock currentTip, bool forkIncluded, CancellationToken cancellation = default)
  • public ConcurrentChain GetMainChain()
  • public IEnumerable<OrderedBalanceChange> GetOrderedBalance(string walletId, BalanceQuery query = null, CancellationToken cancel = default)
  • public IEnumerable<OrderedBalanceChange> GetOrderedBalance(BalanceId balanceId, BalanceQuery query = null, CancellationToken cancel = default)
  • public IEnumerable<OrderedBalanceChange> GetOrderedBalance(IDestination destination, BalanceQuery query = null, CancellationToken cancel = default)
  • public IEnumerable<OrderedBalanceChange> GetOrderedBalance(Script scriptPubKey, BalanceQuery query = null, CancellationToken cancel = default)
  • public IEnumerable<Task<List<OrderedBalanceChange>>> GetOrderedBalanceAsync(BalanceId balanceId, BalanceQuery query = null, CancellationToken cancel = default)
  • public IEnumerable<Task<List<OrderedBalanceChange>>> GetOrderedBalanceAsync(string walletId, BalanceQuery query = null, CancellationToken cancel = default)
  • public IEnumerable<Task<List<OrderedBalanceChange>>> GetOrderedBalanceAsync(IDestination destination, BalanceQuery query = null, CancellationToken cancel = default)
  • public IEnumerable<Task<List<OrderedBalanceChange>>> GetOrderedBalanceAsync(Script scriptPubKey, BalanceQuery query = null, CancellationToken cancel = default)
  • public Task<TransactionEntry> GetTransactionAsync(bool loadPreviousOutput, uint256 txId)
  • public Task<TransactionEntry> GetTransactionAsync(uint256 txId)
  • public Task<TransactionEntry> GetTransactionAsync(bool loadPreviousOutput, bool fetchColor, uint256 txId)
  • public bool LoadAddressEntity(Entity indexAddress)
  • public bool LoadAddressEntity(Entity indexAddress, IDictionary<uint256, Transaction> transactionsCache)
  • public Task<TransactionEntry[]> GetTransactionsAsync(bool loadPreviousOutput, uint256[] txIds)
  • public Task<TransactionEntry[]> GetTransactionsAsync(bool lazyLoadPreviousOutput, bool fetchColor, uint256[] txIds)
  • public WalletRuleEntry[] GetWalletRules(string walletId)
  • public bool MergeIntoWallet(string walletId, IDestination destination, WalletRule rule = null, CancellationToken cancel = default)
  • public bool MergeIntoWallet(string walletId, Script scriptPubKey, WalletRule rule = null, CancellationToken cancel = default)
  • public bool MergeIntoWallet(string walletId, string walletSource, WalletRule rule = null, CancellationToken cancel = default)
  • public bool NeedLoading(OrderedBalanceChange change)
  • public void PruneBalances(IEnumerable<OrderedBalanceChange> balances)
  • public void SynchronizeChain(ChainBase chain)
• public class IndexerColoredTransactionRepository : IColoredTransactionRepository
  • public IndexerConfiguration Configuration { get; }
  • public ITransactionRepository Transactions { get; set; }
  • public IndexerColoredTransactionRepository(IndexerConfiguration config)
  • public Task<ColoredTransaction> GetAsync(uint256 txId)
  • public Task PutAsync(uint256 txId, ColoredTransaction colored)
• public class IndexerConfiguration
  • public string CheckpointSetName { get; set; }
  • public string Node { get; set; }
  • public Node ConnectToNode(bool isRelay)
  • public AzureIndexer CreateIndexer()
  • public void EnsureSetup()
  • public Task EnsureSetupAsync()
  • public CloudTable GetTable(string tableName)
  • public CloudTable GetWalletRulesTable()
• public class IndexerServerConfiguration : IndexerConfiguration
• public class ProgressTracker
• public class TaskPool<TItem>
• public class IndexerTransactionRepository : ITransactionRepository
  • public IndexerConfiguration Configuration { get; }
  • public IndexerTransactionRepository(IndexerConfiguration config)
  • public Task<Transaction> GetAsync(uint256 txId)
  • public Task PutAsync(uint256 txId, Transaction tx)
• public class MatchedRule
  • public uint Index { get; set; }
  • public MatchLocation MatchType { get; set; }
  • public WalletRule Rule { get; set; }
  • public MatchedRule()
• public enum MatchLocation
  • Input = 1
  • Output = 0
• public class OrderedBalanceChange
  • public Money Amount { get; }
  • public BalanceId BalanceId { get; }
  • public uint256 BlockId { get; set; }
  • public ColoredTransaction ColoredTransaction { get; set; }
  • public string CustomData { get; set; }
  • public bool HasOpReturn { get; set; }
  • public int Height { get; set; }
  • public bool IsCoinbase { get; set; }
  • public List<MatchedRule> MatchedRules { get; }
  • public bool MempoolEntry { get; }
  • public string PartitionKey { get; }
  • public CoinCollection ReceivedCoins { get; }
  • public DateTime SeenUtc { get; set; }
  • public CoinCollection SpentCoins { get; }
  • public List<uint> SpentIndices { get; }
  • public List<OutPoint> SpentOutpoints { get; }
  • public uint256 TransactionId { get; set; }
  • public OrderedBalanceChange()
  • public static IEnumerable<OrderedBalanceChange> ExtractScriptBalances(uint256 txId, Transaction transaction, uint256 blockId, BlockHeader blockHeader, int height)
  • public static IEnumerable<OrderedBalanceChange> ExtractScriptBalances(Transaction tx)
  • public static IEnumerable<OrderedBalanceChange> ExtractWalletBalances(uint256 txId, Transaction tx, uint256 blockId, BlockHeader blockHeader, int height, WalletRuleEntryCollection walletCollection)
  • public BalanceLocator CreateBalanceLocator()
  • public Task<bool> EnsureColoredTransactionLoadedAsync(IColoredTransactionRepository repository)
  • public Task<bool> EnsureSpentCoinsLoadedAsync(ITransactionRepository transactions)
  • public IMoney GetAssetAmount(BitcoinAssetId assetId)
  • public IMoney GetAssetAmount(AssetId assetId)
  • public IEnumerable<WalletRule> GetMatchedRules(int index, MatchLocation matchType)
  • public IEnumerable<WalletRule> GetMatchedRules(ICoin coin)
  • public IEnumerable<WalletRule> GetMatchedRules(OutPoint outPoint)
  • public void UpdateToColoredCoins()
  • public void UpdateToScriptCoins()
  • public void UpdateToUncoloredCoins()
• public class ScriptRule : WalletRule
  • public Script RedeemScript { get; set; }
  • public Script ScriptPubKey { get; set; }
  • public ScriptRule(Script destination, bool isRedeemScript = false)
  • public ScriptRule(IDestination destination, bool isRedeemScript = false)
  • public ScriptRule()
• public class TransactionEntry
  • public ColoredTransaction ColoredTransaction { get; set; }
  • public DateTimeOffset FirstSeen { get; set; }
  • public TxOut[] PreviousTxOuts { get; set; }
  • public List<Spendable> SpentCoins { get; set; }
• public class UnconfirmedBalanceLocator : BalanceLocator
  • public DateTimeOffset SeenDate { get; set; }
  • public uint256 TransactionId { get; set; }
  • public UnconfirmedBalanceLocator()
  • public UnconfirmedBalanceLocator(DateTimeOffset seenDate, uint256 transactionId = null)
  • public static UnconfirmedBalanceLocator Parse(string str)
• public abstract class WalletRule
  • public string CustomData { get; set; }
  • public abstract string Id { get; }
  • public WalletRule()
• public class WalletRuleEntry
  • public WalletRule Rule { get; set; }
  • public string WalletId { get; set; }
  • public WalletRuleEntry()
  • public WalletRuleEntry(DynamicTableEntity entity, IndexerClient client)
  • public WalletRuleEntry(string walletId, WalletRule rule)
  • public DynamicTableEntity CreateTableEntity()
• public class WalletRuleEntryCollection : IEnumerable<WalletRuleEntry>, IEnumerable
  • public int Count { get; }
  • public bool Add(WalletRuleEntry entry)
  • public void AddRange(IEnumerable<WalletRuleEntry> entries)
  • public IEnumerator<WalletRuleEntry> GetEnumerator()
  • public IEnumerable<WalletRuleEntry> GetRulesFor(IDestination destination)
  • public IEnumerable<WalletRuleEntry> GetRulesFor(Script script)
  • public IEnumerable<WalletRuleEntry> GetRulesForWallet(string walletName)

NBitcoin.Indexer.Converters

• public class ScriptJsonConverter : JsonConverter
  • public ScriptJsonConverter()
• public class WalletRuleConverter : JsonConverter
  • public WalletRuleConverter()

NBitcoin.Indexer.DamienG.Security.Cryptography

• public sealed class Crc32 : HashAlgorithm
  • public const uint DefaultPolynomial = 3988292384
  • public const uint DefaultSeed = 4294967295
  • public Crc32 Instance
  • public Crc32()
  • public Crc32(uint polynomial, uint seed)
  • public static uint Compute(byte[] buffer)
  • public static uint Compute(uint seed, byte[] buffer)
  • public static uint Compute(uint polynomial, uint seed, byte[] buffer)
  • public static uint Compute(string str)

NBitcoin.Indexer.IndexTasks

• public class BulkImport<T>
  • public bool HasFullPartition { get; }
  • public int PartitionSize { get; set; }
  • public BulkImport(int partitionSize)
  • public void Add(string partitionName, T item)
  • public void FlushUncompletePartitions()
• public interface IBlocksRepository
  • IEnumerable<Block> GetBlocks(IEnumerable<uint256> hashes, CancellationToken cancellationToken)
• public interface IIndexTask
  • bool EnsureIsSetup { get; set; }
  • bool SaveProgression { get; set; }
  • void Index(BlockFetcher blockFetcher, TaskScheduler scheduler)
• public class IndexBalanceTask : IndexTableEntitiesTaskBase<OrderedBalanceChange>
  • public IndexBalanceTask(IndexerConfiguration conf, WalletRuleEntryCollection walletRules)
• public class IndexBlocksTask : IndexTask<BlockInfo>
  • public int IndexedBlocks { get; }
  • public IndexBlocksTask(IndexerConfiguration configuration)
  • public void Index(Block[] blocks, TaskScheduler taskScheduler)
  • public Task IndexAsync(Block[] blocks, TaskScheduler taskScheduler)
• public class IndexTableEntitiesTask : IndexTableEntitiesTaskBase<ITableEntity>
  • public IndexTableEntitiesTask(IndexerConfiguration conf, CloudTable table)
  • public void Index(IEnumerable<ITableEntity> entities, TaskScheduler taskScheduler)
  • public Task IndexAsync(IEnumerable<ITableEntity> entities, TaskScheduler taskScheduler)
• public abstract class IndexTableEntitiesTaskBase<TIndexed> : IndexTask<TIndexed>
  • public int IndexedEntities { get; }
  • public IndexTableEntitiesTaskBase(IndexerConfiguration configuration)
  • protected abstract CloudTable GetCloudTable()
  • protected abstract ITableEntity ToTableEntity(TIndexed item)
• public abstract class IndexTask<TIndexed> : IIndexTask
  • protected TimeSpan _Timeout
  • public IndexerConfiguration Configuration { get; }
  • public bool EnsureIsSetup { get; set; }
  • public int MaxQueued { get; set; }
  • protected abstract int PartitionSize { get; }
  • public bool SaveProgression { get; set; }
  • protected virtual bool SkipToEnd { get; }
  • public IndexTask(IndexerConfiguration configuration)
  • protected abstract Task EnsureSetup()
  • public void Index(BlockFetcher blockFetcher, TaskScheduler scheduler)
  • protected abstract void IndexCore(string partitionName, IEnumerable<TIndexed> items)
  • protected abstract void ProcessBlock(BlockInfo block, BulkImport<TIndexed> bulk)
• public class IndexTransactionsTask : IndexTableEntitiesTaskBase<Entity>
  • public IndexTransactionsTask(IndexerConfiguration configuration)
• public class NodeBlocksRepository : IBlocksRepository
  • public NodeBlocksRepository(Node node)
  • public IEnumerable<Block> GetBlocks(IEnumerable<uint256> hashes, CancellationToken cancellationToken)