aries_cloudagent.transport package
Subpackages
- aries_cloudagent.transport.inbound package
- Submodules
- aries_cloudagent.transport.inbound.base module
- aries_cloudagent.transport.inbound.delivery_queue module
- aries_cloudagent.transport.inbound.http module
- aries_cloudagent.transport.inbound.manager module
- aries_cloudagent.transport.inbound.message module
- aries_cloudagent.transport.inbound.receipt module
MessageReceipt
MessageReceipt.REPLY_MODE_ALL
MessageReceipt.REPLY_MODE_NONE
MessageReceipt.REPLY_MODE_THREAD
MessageReceipt.connection_id
MessageReceipt.direct_response_mode
MessageReceipt.direct_response_requested
MessageReceipt.in_time
MessageReceipt.parent_thread_id
MessageReceipt.raw_message
MessageReceipt.recipient_did
MessageReceipt.recipient_did_public
MessageReceipt.recipient_verkey
MessageReceipt.sender_did
MessageReceipt.sender_verkey
MessageReceipt.thread_id
- aries_cloudagent.transport.inbound.session module
- aries_cloudagent.transport.inbound.ws module
- aries_cloudagent.transport.outbound package
- Submodules
- aries_cloudagent.transport.outbound.base module
- aries_cloudagent.transport.outbound.http module
- aries_cloudagent.transport.outbound.manager module
OutboundTransportManager
OutboundTransportManager.MAX_RETRY_COUNT
OutboundTransportManager.deliver_queued_message()
OutboundTransportManager.encode_outbound_message()
OutboundTransportManager.encode_queued_message()
OutboundTransportManager.enqueue_message()
OutboundTransportManager.enqueue_webhook()
OutboundTransportManager.finished_deliver()
OutboundTransportManager.finished_encode()
OutboundTransportManager.flush()
OutboundTransportManager.get_external_running_transport()
OutboundTransportManager.get_registered_transport_for_scheme()
OutboundTransportManager.get_running_transport_for_endpoint()
OutboundTransportManager.get_running_transport_for_scheme()
OutboundTransportManager.get_transport_instance()
OutboundTransportManager.perform_encode()
OutboundTransportManager.process_queued()
OutboundTransportManager.register()
OutboundTransportManager.register_class()
OutboundTransportManager.setup()
OutboundTransportManager.start()
OutboundTransportManager.start_transport()
OutboundTransportManager.stop()
- aries_cloudagent.transport.outbound.message module
- aries_cloudagent.transport.outbound.status module
- aries_cloudagent.transport.outbound.ws module
- aries_cloudagent.transport.queue package
Submodules
aries_cloudagent.transport.error module
Transport-related error classes and codes.
- exception aries_cloudagent.transport.error.RecipientKeysError(*args, error_code: Optional[str] = None, **kwargs)[source]
Bases:
WireFormatError
Extract recipient keys error.
- exception aries_cloudagent.transport.error.TransportError(*args, error_code: Optional[str] = None, **kwargs)[source]
Bases:
BaseError
Base class for all transport errors.
- exception aries_cloudagent.transport.error.WireFormatEncodeError(*args, error_code: Optional[str] = None, **kwargs)[source]
Bases:
WireFormatError
Encoding error when packing the wire format.
- error_code = 'message_encode_error'
- exception aries_cloudagent.transport.error.WireFormatError(*args, error_code: Optional[str] = None, **kwargs)[source]
Bases:
TransportError
Base class for wire-format errors.
aries_cloudagent.transport.pack_format module
Standard packed message format classes.
- class aries_cloudagent.transport.pack_format.PackWireFormat[source]
Bases:
BaseWireFormat
Standard DIDComm message parser and serializer.
- async encode_message(session: ProfileSession, message_json: Union[str, bytes], recipient_keys: Sequence[str], routing_keys: Sequence[str], sender_key: str) Union[str, bytes] [source]
Encode an outgoing message for transport.
- Parameters
session – The profile session for providing wallet access
message_json – The message body to serialize
recipient_keys – A sequence of recipient verkeys
routing_keys – A sequence of routing verkeys
sender_key – The verification key of the sending agent
- Returns
The encoded message
- Raises
MessageEncodeError – If the message could not be encoded
- get_recipient_keys(message_body: Union[str, bytes]) List[str] [source]
Get all recipient keys from a wire message.
- Parameters
message_body – The body of the message
- Returns
List of recipient keys from the message body
- Raises
RecipientKeysError – If the recipient keys could not be extracted
- async pack(session: ProfileSession, message_json: Union[str, bytes], recipient_keys: Sequence[str], routing_keys: Sequence[str], sender_key: str)[source]
Look up the wallet instance and perform the message pack.
- async parse_message(session: ProfileSession, message_body: Union[str, bytes]) Tuple[dict, MessageReceipt] [source]
Deserialize an incoming message and further populate the request context.
- Parameters
session – The profile session for providing wallet access
message_body – The body of the message
- Returns
A tuple of the parsed message and a message receipt instance
- Raises
WireFormatParseError – If the JSON parsing failed
WireFormatParseError – If a wallet is required but can’t be located
- async unpack(session: ProfileSession, message_body: Union[str, bytes], receipt: MessageReceipt)[source]
Look up the wallet instance and perform the message unpack.
aries_cloudagent.transport.stats module
aiohttp stats collector support.
- class aries_cloudagent.transport.stats.StatsTracer(*args: Any, **kwargs: Any)[source]
Bases:
TraceConfig
Attach hooks to client session events and report statistics.
- async connection_queued_end(session, context, params)[source]
Handle the end of a queued connection.
- async connection_queued_start(session, context, params)[source]
Handle the start of a queued connection.
aries_cloudagent.transport.wire_format module
Abstract wire format classes.
- class aries_cloudagent.transport.wire_format.BaseWireFormat[source]
Bases:
object
Abstract messaging wire format.
- abstract async encode_message(session: ProfileSession, message_json: Union[str, bytes], recipient_keys: Sequence[str], routing_keys: Sequence[str], sender_key: str) Union[str, bytes] [source]
Encode an outgoing message for transport.
- Parameters
session – The profile session for providing wallet access
message_json – The message body to serialize
recipient_keys – A sequence of recipient verkeys
routing_keys – A sequence of routing verkeys
sender_key – The verification key of the sending agent
- Returns
The encoded message
- Raises
MessageEncodeError – If the message could not be encoded
- abstract get_recipient_keys(message_body: Union[str, bytes]) List[str] [source]
Get all recipient keys from a wire message.
- Parameters
message_body – The body of the message
- Returns
List of recipient keys from the message body
- Raises
RecipientKeysError – If the recipient keys could not be extracted
- abstract async parse_message(session: ProfileSession, message_body: Union[str, bytes]) Tuple[dict, MessageReceipt] [source]
Deserialize an incoming message and further populate the request context.
- Parameters
session – The profile session for providing wallet access
message_body – The body of the message
- Returns
A tuple of the parsed message and a message receipt instance
- Raises
WireFormatParseError – If the message can’t be parsed
- class aries_cloudagent.transport.wire_format.JsonWireFormat[source]
Bases:
BaseWireFormat
Unencrypted wire format.
- abstract async encode_message(session: ProfileSession, message_json: Union[str, bytes], recipient_keys: Sequence[str], routing_keys: Sequence[str], sender_key: str) Union[str, bytes] [source]
Encode an outgoing message for transport.
- Parameters
session – The profile session for providing wallet access
message_json – The message body to serialize
recipient_keys – A sequence of recipient verkeys
routing_keys – A sequence of routing verkeys
sender_key – The verification key of the sending agent
- Returns
The encoded message
- Raises
MessageEncodeError – If the message could not be encoded
- get_recipient_keys(message_body: Union[str, bytes]) List[str] [source]
Get all recipient keys from a wire message.
- Parameters
message_body – The body of the message
- Returns
List of recipient keys from the message body
- Raises
RecipientKeysError – If the recipient keys could not be extracted
- abstract async parse_message(session: ProfileSession, message_body: Union[str, bytes]) Tuple[dict, MessageReceipt] [source]
Deserialize an incoming message and further populate the request context.
- Parameters
session – The profile session for providing wallet access
message_body – The body of the message
- Returns
A tuple of the parsed message and a message receipt instance
- Raises
WireFormatParseError – If the JSON parsing failed