Packages

trait BitcoindRpcTestUtil extends BitcoinSLogger

Linear Supertypes
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BitcoindRpcTestUtil
  2. BitcoinSLogger
  3. Logging
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. type RpcClientAccum = Builder[BitcoindRpcClient, Vector[BitcoindRpcClient]]

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def awaitConnection(from: BitcoindRpcClient, to: BitcoindRpcClient, interval: FiniteDuration = 100.milliseconds, maxTries: Int = 50)(implicit system: ActorSystem): Future[Unit]

    Awaits non-blockingly until the provided clients are connected

  6. def awaitDisconnected(from: BitcoindRpcClient, to: BitcoindRpcClient, interval: FiniteDuration = 100.milliseconds, maxTries: Int = 50)(implicit system: ActorSystem): Future[Unit]
  7. def awaitSameBlockHeight(client1: BitcoindRpcClient, client2: BitcoindRpcClient, interval: FiniteDuration = BitcoindRpcTestUtil.DEFAULT_LONG_INTERVAL, maxTries: Int = 50)(implicit system: ActorSystem): Future[Unit]
  8. def awaitStopped(client: BitcoindRpcClient, interval: FiniteDuration = 100.milliseconds, maxTries: Int = 50)(implicit system: ActorSystem): Future[Unit]
  9. def awaitSynced(client1: BitcoindRpcClient, client2: BitcoindRpcClient, interval: FiniteDuration = BitcoindRpcTestUtil.DEFAULT_LONG_INTERVAL, maxTries: Int = 50)(implicit system: ActorSystem): Future[Unit]
  10. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  11. def config(uri: URI, rpcUri: URI, zmqPort: Int, pruneMode: Boolean, blockFilterIndex: Boolean = false): BitcoindConfig
  12. def connectPairs(pairs: Vector[(BitcoindRpcClient, BitcoindRpcClient)])(implicit system: ActorSystem): Future[Unit]

    Connects and waits non-blockingly until all the provided pairs of clients are connected

  13. def createNodePair(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindRpcClient, BitcoindRpcClient)]

    Returns a pair of BitcoindRpcClient that are connected with some blocks in the chain

  14. def createNodePairV16(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV16RpcClient, BitcoindV16RpcClient)]

    Returns a pair of BitcoindV16RpcClient that are connected with some blocks in the chain

  15. def createNodePairV17(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV17RpcClient, BitcoindV17RpcClient)]

    Returns a pair of BitcoindV17RpcClient that are connected with some blocks in the chain

  16. def createNodePairV18(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV18RpcClient, BitcoindV18RpcClient)]

    Returns a pair of BitcoindV18RpcClient that are connected with some blocks in the chain

  17. def createNodePairV19(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV19RpcClient, BitcoindV19RpcClient)]

    Returns a pair of BitcoindV19RpcClient that are connected with some blocks in the chain

  18. def createNodePairV20(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV20RpcClient, BitcoindV20RpcClient)]

    Returns a pair of BitcoindV20RpcClient that are connected with some blocks in the chain

  19. def createNodePairV21(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV21RpcClient, BitcoindV21RpcClient)]

    Returns a pair of BitcoindV21RpcClient that are connected with some blocks in the chain

  20. def createNodeTriple(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindRpcClient, BitcoindRpcClient, BitcoindRpcClient)]

    Returns a triple of org.bitcoins.rpc.client.common.BitcoindRpcClient BitcoindRpcClient that are connected with some blocks in the chain

  21. def createNodeTripleV17(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV17RpcClient, BitcoindV17RpcClient, BitcoindV17RpcClient)]

    returns

    a triple of BitcoindV17RpcClient that are connected with some blocks in the chain

  22. def createNodeTripleV18(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV18RpcClient, BitcoindV18RpcClient, BitcoindV18RpcClient)]
  23. def createNodeTripleV19(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindV19RpcClient, BitcoindV19RpcClient, BitcoindV19RpcClient)]
  24. def createRawCoinbaseTransaction(sender: BitcoindRpcClient, receiver: BitcoindRpcClient, amount: Bitcoins = Bitcoins(1))(implicit executionContext: ExecutionContext): Future[Transaction]
  25. def createUnconnectedNodePair(clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[(BitcoindRpcClient, BitcoindRpcClient)]

    Returns a pair of unconnected BitcoindRpcClients with no blocks

  26. def debug(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  27. def debug(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  28. def debug(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  29. def deleteNodePair(client1: BitcoindRpcClient, client2: BitcoindRpcClient)(implicit executionContext: ExecutionContext): Future[Unit]

    Stops the provided nodes and deletes their data directories

  30. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  31. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  32. def error(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  33. def error(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  34. def error(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  35. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  36. def findOutput(client: BitcoindRpcClient, txid: DoubleSha256DigestBE, amount: Bitcoins, blockhash: Option[DoubleSha256DigestBE] = None)(implicit executionContext: ExecutionContext): Future[UInt32]

    Return index of output of TX txid with value amount

    Return index of output of TX txid with value amount

    See also

    function we're mimicking in Core test suite

  37. def fundBlockChainTransaction(sender: BitcoindRpcClient, receiver: BitcoindRpcClient, address: BitcoinAddress, amount: Bitcoins)(implicit system: ActorSystem): Future[DoubleSha256DigestBE]

    Produces a confirmed transaction from sender to address for amount

  38. def fundMemPoolTransaction(sender: BitcoindRpcClient, address: BitcoinAddress, amount: Bitcoins)(implicit system: ActorSystem): Future[DoubleSha256DigestBE]

    Produces a unconfirmed transaction from sender to address for amount

  39. def generateAllAndSync(clients: Vector[BitcoindRpcClient], blocks: Int = 6)(implicit system: ActorSystem): Future[Vector[Vector[DoubleSha256DigestBE]]]

    Generates the specified amount of blocks with all provided clients and waits until they are synced.

    Generates the specified amount of blocks with all provided clients and waits until they are synced.

    returns

    Vector of Blockhashes of generated blocks, with index corresponding to the list of provided clients

  40. def generateAndSync(clients: Vector[BitcoindRpcClient], blocks: Int = 6)(implicit system: ActorSystem): Future[Vector[DoubleSha256DigestBE]]

    Generates the specified amount of blocks and waits until the provided clients are synced.

    Generates the specified amount of blocks and waits until the provided clients are synced.

    returns

    Blockhashes of generated blocks

  41. def getBinary(version: BitcoindVersion, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): File
  42. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  43. def getFirstBlock(node: BitcoindRpcClient)(implicit executionContext: ExecutionContext): Future[GetBlockWithTransactionsResult]

    returns

    The first block (after genesis) in the given node's blockchain

  44. def getInstance(bitcoindVersion: BitcoindVersion, port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance

    Gets an instance of bitcoind with the given version

  45. def getPubkey(client: BitcoindRpcClient, address: BitcoinAddress)(implicit system: ActorSystem): Future[Option[ECPublicKey]]

    Gets the pubkey (if it exists) asscociated with a given bitcoin address in a version-agnostic manner

  46. def hasSeenBlock(client1: BitcoindRpcClient, hash: DoubleSha256Digest)(implicit ec: ExecutionContext): Future[Boolean]
  47. def hasSeenBlock(client: BitcoindRpcClient, hash: DoubleSha256DigestBE)(implicit ec: ExecutionContext): Future[Boolean]

    Checks whether the provided client has seen the given block hash

  48. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  49. def info(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  50. def info(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  51. def info(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  52. def instance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, versionOpt: Option[BitcoindVersion] = None, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance

    Creates a bitcoind instance within the user temporary directory

  53. def isDebugEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  54. def isErrorEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  55. def isInfoEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  56. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  57. def isTraceEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  58. def isWarnEnabled: Boolean
    Attributes
    protected
    Definition Classes
    Logging
  59. def logger: Logger
    Attributes
    protected
    Definition Classes
    Logging
  60. def loggerName: String
    Attributes
    protected
    Definition Classes
    Logging
  61. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  62. lazy val network: RegTest.type
  63. def newestBitcoindBinary: File
  64. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  65. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  66. def removeDataDirectory(client: BitcoindRpcClient, interval: FiniteDuration = 100.milliseconds, maxTries: Int = 50)(implicit system: ActorSystem): Future[Unit]
  67. def sendCoinbaseTransaction(sender: BitcoindRpcClient, receiver: BitcoindRpcClient, amount: Bitcoins = Bitcoins(1))(implicit actorSystem: ActorSystem): Future[GetTransactionResult]
  68. def signRawTransaction(signer: BitcoindRpcClient, transaction: Transaction, utxoDeps: Vector[SignRawTransactionOutputParameter] = Vector.empty): Future[SignRawTransactionResult]

    Bitcoin Core 0.16 and 0.17 has diffrent APIs for signing raw transactions.

    Bitcoin Core 0.16 and 0.17 has diffrent APIs for signing raw transactions. This method tries to construct either a BitcoindV16RpcClient or a BitcoindV16RpcClient from the provided signer, and then calls the appropriate method on the result.

    Exceptions thrown

    RuntimeException if no versioned BitcoindRpcClient can be constructed.

  69. def standardConfig: BitcoindConfig

    Standard config used for testing purposes

  70. def startServers(servers: Vector[BitcoindRpcClient])(implicit ec: ExecutionContext): Future[Unit]
  71. def startedBitcoindRpcClient(instance: BitcoindInstance = BitcoindRpcTestUtil.instance(), clientAccum: RpcClientAccum = Vector.newBuilder)(implicit system: ActorSystem): Future[BitcoindRpcClient]

    clientAccum

    If provided, the generated client is added to this vectorbuilder.

  72. def stopServer(server: BitcoindRpcClient)(implicit system: ActorSystem): Future[Unit]

    Stops the given server and deletes its data directory

  73. def stopServers(servers: Vector[BitcoindRpcClient])(implicit system: ActorSystem): Future[Unit]

    Stops the given servers and deletes their data directories

  74. def syncPairs(pairs: Vector[(BitcoindRpcClient, BitcoindRpcClient)])(implicit system: ActorSystem): Future[Unit]
  75. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  76. def toString(): String
    Definition Classes
    AnyRef → Any
  77. def trace(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  78. def trace(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  79. def trace(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  80. def v16Instance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance
  81. def v17Instance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance
  82. def v18Instance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance
  83. def v19Instance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance
  84. def v20Instance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance
  85. def v21Instance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance
  86. def vExperimentalInstance(port: Int = RpcUtil.randomPort, rpcPort: Int = RpcUtil.randomPort, zmqPort: Int = RpcUtil.randomPort, pruneMode: Boolean = false, binaryDirectory: Path = BitcoindRpcTestClient.sbtBinaryDirectory): BitcoindInstance
  87. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  88. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  89. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  90. def waitUntilBlock(blockHeight: Int, client: BitcoindRpcClient, addressForMining: BitcoinAddress)(implicit ec: ExecutionContext): Future[Unit]

    Mines blocks until the specified block height.

  91. def warn(mkr: Marker, msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  92. def warn(msg: => Any, t: => Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  93. def warn(msg: => Any): Unit
    Attributes
    protected
    Definition Classes
    Logging
  94. def writtenConfig(uri: URI, rpcUri: URI, zmqPort: Int, pruneMode: Boolean, blockFilterIndex: Boolean = false): Path

    Creates a bitcoind config within the system temp directory, writes the file and returns the written file

Inherited from BitcoinSLogger

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped