Home Reference Source Test
public class | source

BaseMiniConsensus

Extends:

ObservableBaseConsensus → BaseMiniConsensus

Direct Subclass:

NanoConsensus, PicoConsensus

Constructor Summary

Public Constructor
public

constructor(blockchain: BaseChain, mempool: Observable, network: Network)

Method Summary

Public Methods
public

addSubscriptions(newAddresses: Array<Address> | Address)

this method was deprecated.
public

async getAccount(address: Address, blockHash: Hash): PromiseAccount>

public

async getAccounts(addresses: Array<Address>, blockHash: Hash): Promise<Array<Account>>

public

async getPendingTransactions(hashes: Array<Hash>): Promise<Array<Transaction>>

public

async getPendingTransactionsByAddress(address: Address): Promise<Array<Transaction>>

public

async relayTransaction(transaction: Transaction): Promise<void>

public

removeSubscriptions(addressesToRemove: Array<Address> | Address)

this method was deprecated.
public

async sendTransaction(tx: Transaction): Promise<BaseConsensus.SendTransactionResult>

public

subscribe(subscription: *)

public

subscribeAccounts(addresses: Array<Address>)

this method was deprecated.
Protected Methods
protected

Inherited Summary

From class Observable
public static get

WILDCARD: string: string

public

bubble(observable: Observable, types: ...string)

public

fire(type: string, args: ...*): Promise

public

off(type: string, id: number)

public

on(type: string, callback: Function): number

From class BaseConsensus
public get

established: boolean

public get
public get
protected

_established: boolean

public abstract

async getAccounts(addresses: Array<Address>): Promise<Array<Account>>

public

async getBlock(hash: Hash, includeBody: boolean, includeBodyFromLocal: boolean, blockHeight: number): Promise<Block>

public

async getBlockAt(height: number, includeBody: boolean): Promise<Block>

public

async getBlockTemplate(minerAddress: Address, extraData: Uint8Array): Promise<Block>

public

async getHeadHash(): Promise<Hash>

public

async getHeadHeight(): Promise<number>

public
public

getPendingTransactions(hashes: Array<Hash>): Promise<Array<Transaction>>

public

async getPendingTransactionsByAddress(address: Address): Promise<Array<Transaction>>

public
public
public

getTransactionReceiptsByHashes(hashes: Array<Hash>): Promise<Array<TransactionReceipt>>

public

async getTransactionsFromBlock(hashes: Array<Hash>, blockHash: Hash, blockHeight: number, block: Block): Promise<Array<Transaction>>

public

async getTransactionsFromBlockByAddresses(addresses: Array<Address>, blockHash: Hash, blockHeight: number): Promise<Array<Transaction>>

public
public abstract

async sendTransaction(tx: Transaction): Promise<BaseConsensus.SendTransactionResult>

public

async submitBlock(block: Block): Promise<boolean>

public

subscribe(subscription: Subscription)

protected
protected

_hasEnoughPeers(numSyncedFullNodes: number, numSyncedNodes: number): boolean

protected
protected
protected
protected

_onPeerLeft(peer: Peer)

protected
protected
protected

_onToDisconnect(obj: Observable, type: string, callback: function)

protected
protected
protected

async _requestBlockProof(blockHashToProve: Hash, blockHeightToProve: number): Promise<Block>

protected

async _requestBlockProofAt(blockHeightToProve: number): Promise<Block>

protected

async _requestTransactionHistory(address: Address): Promise<Array<{transaction: Transaction, header: BlockHeader}>>

this method was deprecated.
protected
protected

async _requestTransactionsByAddresses(addresses: Array<Address>, block: Block): Promise<Array<Transaction>>

protected

Public Constructors

public constructor(blockchain: BaseChain, mempool: Observable, network: Network) source

Override:

BaseConsensus#constructor

Params:

NameTypeAttributeDescription
blockchain BaseChain
mempool Observable
network Network

Public Methods

public addSubscriptions(newAddresses: Array<Address> | Address) source

this method was deprecated.

Params:

NameTypeAttributeDescription
newAddresses Array<Address> | Address

public async getAccount(address: Address, blockHash: Hash): PromiseAccount> source

Params:

NameTypeAttributeDescription
address Address
blockHash Hash
  • optional

Return:

PromiseAccount>

public async getAccounts(addresses: Array<Address>, blockHash: Hash): Promise<Array<Account>> source

Override:

BaseConsensus#getAccounts

Params:

NameTypeAttributeDescription
addresses Array<Address>
blockHash Hash
  • optional

Return:

Promise<Array<Account>>

public async getPendingTransactions(hashes: Array<Hash>): Promise<Array<Transaction>> source

Override:

BaseConsensus#getPendingTransactions

Params:

NameTypeAttributeDescription
hashes Array<Hash>

Return:

Promise<Array<Transaction>>

public async getPendingTransactionsByAddress(address: Address): Promise<Array<Transaction>> source

Override:

BaseConsensus#getPendingTransactionsByAddress

Params:

NameTypeAttributeDescription
address Address

Return:

Promise<Array<Transaction>>

public async relayTransaction(transaction: Transaction): Promise<void> source

Params:

NameTypeAttributeDescription
transaction Transaction

Return:

Promise<void>

public removeSubscriptions(addressesToRemove: Array<Address> | Address) source

this method was deprecated.

Params:

NameTypeAttributeDescription
addressesToRemove Array<Address> | Address

public async sendTransaction(tx: Transaction): Promise<BaseConsensus.SendTransactionResult> source

Override:

BaseConsensus#sendTransaction

Params:

NameTypeAttributeDescription
tx Transaction

Return:

Promise<BaseConsensus.SendTransactionResult>

public subscribe(subscription: *) source

Override:

BaseConsensus#subscribe

Params:

NameTypeAttributeDescription
subscription *

public subscribeAccounts(addresses: Array<Address>) source

this method was deprecated.

Params:

NameTypeAttributeDescription
addresses Array<Address>

Protected Methods

protected _onTransactionAdded(tx: Transaction) source

Override:

BaseConsensus#_onTransactionAdded

Params:

NameTypeAttributeDescription
tx Transaction