EdgeAgentSDK/org.hyperledger.identus.walletsdk.edgeagent/ConnectionManagerImpl

ConnectionManagerImpl

class ConnectionManagerImpl(mercury: Mercury, castor: Castor, pluto: Pluto, val mediationHandler: MediationHandler, pairings: MutableList<DIDPair>, pollux: Pollux, experimentLiveModeOptIn: Boolean = false, scope: CoroutineScope = CoroutineScope(Dispatchers.IO)) : ConnectionManager, ConnectionsManager, DIDCommConnection(source)

ConnectionManager is responsible for managing connections and communication between entities.

Constructors

constructor(mercury: Mercury, castor: Castor, pluto: Pluto, mediationHandler: MediationHandler, pairings: MutableList<DIDPair>, pollux: Pollux, experimentLiveModeOptIn: Boolean = false, scope: CoroutineScope = CoroutineScope(Dispatchers.IO))

Types

Companion

object Companion

Properties

fetchingMessagesJob

var fetchingMessagesJob: Job?

mediationHandler

open override val mediationHandler: MediationHandler

The instance of the MediationHandler interface used for handling mediation.

Functions

addConnection

open suspend override fun addConnection(paired: DIDPair)

Adds a connection to the manager.

awaitMessageResponse

open suspend override fun awaitMessageResponse(id: String): Message?

Awaits a response to a specified message ID from the connection.

awaitMessages

open suspend override fun awaitMessages(): Flow<Array<Pair<String, Message>>>

Awaits messages from the connection.

registerMediator

open suspend override fun registerMediator(host: DID)

Registers a mediator with the given host DID.

removeConnection

open suspend override fun removeConnection(pair: DIDPair): DIDPair?

Removes a connection from the manager.

sendMessage

open suspend override fun sendMessage(message: Message): Message?

Sends a message over the connection.

startFetchingMessages

open override fun startFetchingMessages(requestInterval: Int)

Starts the process of fetching messages at a regular interval.

startMediator

open suspend override fun startMediator()

Suspends the current coroutine and boots the registered mediator associated with the mediator handler. If no mediator is available, a EdgeAgentError.NoMediatorAvailableError is thrown.

stopConnection

open override fun stopConnection()

Stops a connection