libnexakotlin/org.nexa.libnexakotlin/CapdProtocolCommunication

CapdProtocolCommunication

class CapdProtocolCommunication(val chain: Blockchain, convoSecret: ByteArray, var coCtxt: CoroutineContext, val name: String = "", val prefixSize: Int = 0) : ProtocolCommunication

Constructors

constructor(chain: Blockchain, convoSecret: ByteArray, coCtxt: CoroutineContext, name: String = "", prefixSize: Int = 0)

Properties

capdMonitorId

@Volatile

var capdMonitorId: Long?

capdRelayPriority

@Volatile

var capdRelayPriority: Double

chain

val chain: Blockchain

coCtxt

var coCtxt: CoroutineContext

convoEncryptionKey

val convoEncryptionKey: ByteArray

convoId

val convoId: ByteArray

val name: String

var p2p: P2pClient?

val prefixSize: Int

val scope: CoroutineScope

Functions

finalize

fun finalize()

launch

fun launch()

makeMessage

fun makeMessage(ba: ByteArray, tweakMsg: CapdMsg.() -> Unit): CapdMsg

Create a CAPD message but do not send it (typically for debugging)

receive

open suspend override fun receive(): Pair<ByteArray, Long>

suspend fun receive(filter: ByteArray): Pair<ByteArray, Long>

Same as receive, but only returns messages whose prefix region starts with the filter (leading-bytes match so an empty filter matches all).

reconnect

suspend fun reconnect()

send

open suspend override fun send(ba: ByteArray)

fun send(msg: CapdMsg)

suspend fun send(ba: ByteArray, msgPfx: ByteArray)

fun send(ba: ByteArray, tweakMsg: CapdMsg.() -> Unit)

Send some bytes over CAPD, allowing you to set CAPD-specific fields.

start

open suspend override fun start()

stop

open override fun stop()