aries_cloudagent.protocols.routing.v1_0 package

Submodules

aries_cloudagent.protocols.routing.v1_0.manager module

Routing manager classes for tracking and inspecting routing records.

exception aries_cloudagent.protocols.routing.v1_0.manager.RouteNotFoundError(*args, error_code: str = None, **kwargs)[source]

Bases: aries_cloudagent.protocols.routing.v1_0.manager.RoutingManagerError

Requested route was not found.

class aries_cloudagent.protocols.routing.v1_0.manager.RoutingManager(profile: aries_cloudagent.core.profile.Profile)[source]

Bases: object

Class for handling routing records.

RECORD_TYPE = 'forward_route'
create_route_record(client_connection_id: str = None, recipient_key: str = None, internal_wallet_id: str = None) → aries_cloudagent.protocols.routing.v1_0.models.route_record.RouteRecord[source]

Create and store a new RouteRecord.

Parameters:
  • client_connection_id – The ID of the connection record
  • recipient_key – The recipient verkey of the route
  • internal_wallet_id – The ID of the wallet record. Used for internal routing
Returns:

The new routing record

delete_route_record(route: aries_cloudagent.protocols.routing.v1_0.models.route_record.RouteRecord)[source]

Remove an existing route record.

get_recipient(recip_verkey: str) → aries_cloudagent.protocols.routing.v1_0.models.route_record.RouteRecord[source]

Resolve the recipient for a verkey.

Parameters:recip_verkey – The verkey (“to”) of the incoming Forward message
Returns:The RouteRecord associated with this verkey
get_routes(client_connection_id: str = None, tag_filter: dict = None) → Sequence[aries_cloudagent.protocols.routing.v1_0.models.route_record.RouteRecord][source]

Fetch all routes associated with the current connection.

Parameters:
  • client_connection_id – The ID of the connection record
  • tag_filter – An optional dictionary of tag filters
Returns:

A sequence of route records found by the query

send_create_route(router_connection_id: str, recip_key: str, outbound_handler: Coroutine[T_co, T_contra, V_co])[source]

Create and send a route update request.

Returns: the current routing state (request or done)

update_routes(client_connection_id: str, updates: Sequence[aries_cloudagent.protocols.routing.v1_0.models.route_update.RouteUpdate]) → Sequence[aries_cloudagent.protocols.routing.v1_0.models.route_updated.RouteUpdated][source]

Update routes associated with the current connection.

Parameters:
  • client_connection_id – The ID of the connection record
  • updates – The sequence of route updates (create/delete) to perform.
exception aries_cloudagent.protocols.routing.v1_0.manager.RoutingManagerError(*args, error_code: str = None, **kwargs)[source]

Bases: aries_cloudagent.core.error.BaseError

Generic routing error.

aries_cloudagent.protocols.routing.v1_0.message_types module

Message type identifiers for Routing.