chore: ruff formatting

Signed-off-by: Colton Wolkins (Laptop) <colton@indicio.tech>
openwallet-foundation · Jan 3, 2025 · 3f3b708 · 3f3b708
1 parent ebefef9
commit 3f3b708
Show file tree

Hide file tree

Showing 10 changed files with 125 additions and 72 deletions.
diff --git a/acapy_agent/core/dispatcher.py b/acapy_agent/core/dispatcher.py
@@ -187,7 +187,9 @@ async def handle_v2_message(
                 )
                 to_did = services[0].service_endpoint.uri
             found_forwardable_service = (
-                await routing_service.is_forwardable_service(messaging.resolver, services[0])
+                await routing_service.is_forwardable_service(
+                    messaging.resolver, services[0]
+                )
                 if services
                 else False
             )
@@ -212,7 +214,7 @@ async def handle_v2_message(
             send_outbound,
             reply_session_id=inbound_message.session_id,
             reply_to_verkey=inbound_message.receipt.sender_verkey,
-            target_list=reply_destination
+            target_list=reply_destination,
         )
 
         context.injector.bind_instance(BaseResponder, responder)
@@ -288,8 +290,8 @@ async def make_v2_message(self, profile: Profile, parsed_msg: dict) -> BaseMessa
 
         registry: V2ProtocolRegistry = self.profile.inject(V2ProtocolRegistry)
         try:
-            #message_cls = registry.resolve_message_class(message_type)
-            #if isinstance(message_cls, DeferLoad):
+            # message_cls = registry.resolve_message_class(message_type)
+            # if isinstance(message_cls, DeferLoad):
             #    message_cls = message_cls.resolved
             message_cls = registry.protocols_matching_query(message_type)
         except ProtocolMinorVersionNotSupported as e:
@@ -299,7 +301,7 @@ async def make_v2_message(self, profile: Profile, parsed_msg: dict) -> BaseMessa
             raise MessageParseError(f"Unrecognized message type {message_type}")
 
         try:
-            #instance = message_cls[0] #message_cls.deserialize(parsed_msg)
+            # instance = message_cls[0] #message_cls.deserialize(parsed_msg)
             instance = registry.handlers[message_cls[0]]
             if isinstance(instance, DeferLoad):
                 instance = instance.resolved
@@ -310,7 +312,6 @@ async def make_v2_message(self, profile: Profile, parsed_msg: dict) -> BaseMessa
 
         return instance
 
-
     async def handle_v1_message(
         self,
         profile: Profile,

diff --git a/acapy_agent/core/plugin_registry.py b/acapy_agent/core/plugin_registry.py
@@ -224,9 +224,7 @@ async def load_protocol_version(
         goal_code_registry = context.inject(GoalCodeRegistry)
         if hasattr(mod, "HANDLERS"):
             for message_type, handler in mod.HANDLERS:
-                v2_protocol_registry.register_handler(
-                    message_type, handler
-                )
+                v2_protocol_registry.register_handler(message_type, handler)
         if hasattr(mod, "MESSAGE_TYPES"):
             protocol_registry.register_message_types(
                 mod.MESSAGE_TYPES, version_definition=version_definition

diff --git a/acapy_agent/didcomm_v2/protocol_registry.py b/acapy_agent/didcomm_v2/protocol_registry.py
@@ -39,5 +39,5 @@ def protocols_matching_query(self, query: str) -> Sequence[str]:
     def register_handler(self, message_type: str, handler: Union[Coroutine, str]):
         """Register a new message type to handler association."""
         if isinstance(handler, str):
-                handler = DeferLoad(handler)
+            handler = DeferLoad(handler)
         self._type_to_message_handler[message_type] = handler
diff --git a/acapy_agent/protocols_v2/basicmessage/v1_0/message_types.py b/acapy_agent/protocols_v2/basicmessage/v1_0/message_types.py
@@ -1,28 +1,28 @@
 """Message type identifiers for Trust Pings."""
 
-#from ...didcomm_prefix import DIDCommPrefix
+# from ...didcomm_prefix import DIDCommPrefix
 import logging
 from ....messaging.v2_agent_message import V2AgentMessage
 from ....connections.models.connection_target import ConnectionTarget
 from didcomm_messaging import DIDCommMessaging, RoutingService
 
-SPEC_URI = (
-    "https://didcomm.org/basicmessage/2.0/message"
-)
+SPEC_URI = "https://didcomm.org/basicmessage/2.0/message"
 
 # Message types
 BASIC_MESSAGE = "https://didcomm.org/basicmessage/2.0/message"
 
 PROTOCOL_PACKAGE = "acapy_agent.protocols_v2.basicmessage.v1_0"
 
+
 class basic_message:
     async def __call__(self, *args, **kwargs):
         await self.handle(*args, **kwargs)
+
     @staticmethod
     async def handle(context, responder, payload):
         logger = logging.getLogger(__name__)
-        their_did = context.message_receipt.sender_verkey.split('#')[0]
-        our_did = context.message_receipt.recipient_verkey.split('#')[0]
+        their_did = context.message_receipt.sender_verkey.split("#")[0]
+        our_did = context.message_receipt.recipient_verkey.split("#")[0]
         error_result = V2AgentMessage(
             message={
                 "type": BASIC_MESSAGE,

diff --git a/acapy_agent/protocols_v2/basicmessage/v1_0/routes.py b/acapy_agent/protocols_v2/basicmessage/v1_0/routes.py
@@ -51,14 +51,25 @@ class PingConnIdMatchInfoSchema(OpenAPISchema):
         metadata={"description": "Connection identifier", "example": UUID4_EXAMPLE},
     )
 
+
 from ....wallet.base import BaseWallet
 from ....wallet.did_info import DIDInfo
-from ....wallet.did_method import KEY, PEER2, PEER4, SOV, DIDMethod, DIDMethods, HolderDefinedDid
+from ....wallet.did_method import (
+    KEY,
+    PEER2,
+    PEER4,
+    SOV,
+    DIDMethod,
+    DIDMethods,
+    HolderDefinedDid,
+)
 from ....wallet.did_posture import DIDPosture
 from ....wallet.error import WalletError, WalletNotFoundError
 from ....messaging.v2_agent_message import V2AgentMessage
 from ....connections.models.connection_target import ConnectionTarget
 from didcomm_messaging import DIDCommMessaging, RoutingService
+
+
 def format_did_info(info: DIDInfo):
     """Serialize a DIDInfo object."""
     if info:
@@ -71,19 +82,20 @@ def format_did_info(info: DIDInfo):
             "metadata": info.metadata,
         }
 
+
 async def get_mydid(request: web.BaseRequest):
     context: AdminRequestContext = request["context"]
-    #filter_did = request.query.get("did")
-    #filter_verkey = request.query.get("verkey")
+    # filter_did = request.query.get("did")
+    # filter_verkey = request.query.get("verkey")
     filter_posture = DIDPosture.get(request.query.get("posture"))
     results = []
     async with context.session() as session:
         did_methods: DIDMethods = session.inject(DIDMethods)
         filter_method: DIDMethod | None = did_methods.from_method(
             request.query.get("method") or "did:peer:2"
         )
-        #key_types = session.inject(KeyTypes)
-        #filter_key_type = key_types.from_key_type(request.query.get("key_type", ""))
+        # key_types = session.inject(KeyTypes)
+        # filter_key_type = key_types.from_key_type(request.query.get("key_type", ""))
         wallet: BaseWallet | None = session.inject_or(BaseWallet)
         if not wallet:
             raise web.HTTPForbidden(reason="No wallet available")
@@ -97,13 +109,14 @@ async def get_mydid(request: web.BaseRequest):
                     or DIDPosture.get(info.metadata) is DIDPosture.WALLET_ONLY
                 )
                 and (not filter_method or info.method == filter_method)
-                #and (not filter_key_type or info.key_type == filter_key_type)
+                # and (not filter_key_type or info.key_type == filter_key_type)
             ]
 
     results.sort(key=lambda info: (DIDPosture.get(info["posture"]).ordinal, info["did"]))
     our_did = results[0]["did"]
     return our_did
 
+
 async def get_target(request: web.BaseRequest, to_did: str, from_did: str):
     context: AdminRequestContext = request["context"]
 
@@ -133,7 +146,9 @@ async def get_target(request: web.BaseRequest, to_did: str, from_did: str):
             messaging.resolver, services[0]
         )
         while found_forwardable_service:
-            services = await routing_service._resolve_services(messaging.resolver, to_target)
+            services = await routing_service._resolve_services(
+                messaging.resolver, to_target
+            )
             if services:
                 chain.append(
                     {
@@ -143,7 +158,9 @@ async def get_target(request: web.BaseRequest, to_did: str, from_did: str):
                 )
                 to_target = services[0].service_endpoint.uri
             found_forwardable_service = (
-                await routing_service.is_forwardable_service(messaging.resolver, services[0])
+                await routing_service.is_forwardable_service(
+                    messaging.resolver, services[0]
+                )
                 if services
                 else False
             )
@@ -192,9 +209,7 @@ async def basic_message_send(request: web.BaseRequest):
     msg = V2AgentMessage(
         message={
             "type": "https://didcomm.org/basicmessage/2.0/message",
-            "body": {
-                "content": message
-            },
+            "body": {"content": message},
             "lang": "en",
             "to": [their_did],
             "from": our_did,
@@ -227,6 +242,9 @@ def post_process_routes(app: web.Application):
         {
             "name": "didcommv2",
             "description": "DIDComm V2 based protocols for Interop-a-thon",
-            "externalDocs": {"description": "Specification", "url": "https://didcomm.org"},
+            "externalDocs": {
+                "description": "Specification",
+                "url": "https://didcomm.org",
+            },
         }
     )
diff --git a/acapy_agent/protocols_v2/discovery/v1_0/message_types.py b/acapy_agent/protocols_v2/discovery/v1_0/message_types.py
@@ -1,29 +1,29 @@
 """Message type identifiers for Trust Pings."""
 
-#from ...didcomm_prefix import DIDCommPrefix
+# from ...didcomm_prefix import DIDCommPrefix
 import logging
 from ....messaging.v2_agent_message import V2AgentMessage
 from ....connections.models.connection_target import ConnectionTarget
 from didcomm_messaging import DIDCommMessaging, RoutingService
 
-SPEC_URI = (
-    "https://didcomm.org/discover-features/2.0/queries"
-)
+SPEC_URI = "https://didcomm.org/discover-features/2.0/queries"
 
 # Message types
 QUERIES = "https://didcomm.org/discover-features/2.0/queries"
 DISCLOSE = "https://didcomm.org/discover-features/2.0/disclose"
 
 PROTOCOL_PACKAGE = "acapy_agent.protocols_v2.discovery.v1_0"
 
+
 class discover_features:
     async def __call__(self, *args, **kwargs):
         await self.handle(*args, **kwargs)
+
     @staticmethod
     async def handle(context, responder, payload):
         logger = logging.getLogger(__name__)
-        their_did = context.message_receipt.sender_verkey.split('#')[0]
-        our_did = context.message_receipt.recipient_verkey.split('#')[0]
+        their_did = context.message_receipt.sender_verkey.split("#")[0]
+        our_did = context.message_receipt.recipient_verkey.split("#")[0]
         error_result = V2AgentMessage(
             message={
                 "type": DISCLOSE,
@@ -44,7 +44,6 @@ async def handle(context, responder, payload):
         await responder.send_reply(error_result)
 
 
-
 HANDLERS = {
     QUERIES: f"{PROTOCOL_PACKAGE}.message_types.discover_features",
 }.items()

diff --git a/acapy_agent/protocols_v2/discovery/v1_0/routes.py b/acapy_agent/protocols_v2/discovery/v1_0/routes.py
@@ -51,14 +51,25 @@ class PingConnIdMatchInfoSchema(OpenAPISchema):
         metadata={"description": "Connection identifier", "example": UUID4_EXAMPLE},
     )
 
+
 from ....wallet.base import BaseWallet
 from ....wallet.did_info import DIDInfo
-from ....wallet.did_method import KEY, PEER2, PEER4, SOV, DIDMethod, DIDMethods, HolderDefinedDid
+from ....wallet.did_method import (
+    KEY,
+    PEER2,
+    PEER4,
+    SOV,
+    DIDMethod,
+    DIDMethods,
+    HolderDefinedDid,
+)
 from ....wallet.did_posture import DIDPosture
 from ....wallet.error import WalletError, WalletNotFoundError
 from ....messaging.v2_agent_message import V2AgentMessage
 from ....connections.models.connection_target import ConnectionTarget
 from didcomm_messaging import DIDCommMessaging, RoutingService
+
+
 def format_did_info(info: DIDInfo):
     """Serialize a DIDInfo object."""
     if info:
@@ -71,19 +82,20 @@ def format_did_info(info: DIDInfo):
             "metadata": info.metadata,
         }
 
+
 async def get_mydid(request: web.BaseRequest):
     context: AdminRequestContext = request["context"]
-    #filter_did = request.query.get("did")
-    #filter_verkey = request.query.get("verkey")
+    # filter_did = request.query.get("did")
+    # filter_verkey = request.query.get("verkey")
     filter_posture = DIDPosture.get(request.query.get("posture"))
     results = []
     async with context.session() as session:
         did_methods: DIDMethods = session.inject(DIDMethods)
         filter_method: DIDMethod | None = did_methods.from_method(
             request.query.get("method") or "did:peer:2"
         )
-        #key_types = session.inject(KeyTypes)
-        #filter_key_type = key_types.from_key_type(request.query.get("key_type", ""))
+        # key_types = session.inject(KeyTypes)
+        # filter_key_type = key_types.from_key_type(request.query.get("key_type", ""))
         wallet: BaseWallet | None = session.inject_or(BaseWallet)
         if not wallet:
             raise web.HTTPForbidden(reason="No wallet available")
@@ -97,13 +109,14 @@ async def get_mydid(request: web.BaseRequest):
                     or DIDPosture.get(info.metadata) is DIDPosture.WALLET_ONLY
                 )
                 and (not filter_method or info.method == filter_method)
-                #and (not filter_key_type or info.key_type == filter_key_type)
+                # and (not filter_key_type or info.key_type == filter_key_type)
             ]
 
     results.sort(key=lambda info: (DIDPosture.get(info["posture"]).ordinal, info["did"]))
     our_did = results[0]["did"]
     return our_did
 
+
 async def get_target(request: web.BaseRequest, to_did: str, from_did: str):
     context: AdminRequestContext = request["context"]
 
@@ -133,7 +146,9 @@ async def get_target(request: web.BaseRequest, to_did: str, from_did: str):
             messaging.resolver, services[0]
         )
         while found_forwardable_service:
-            services = await routing_service._resolve_services(messaging.resolver, to_target)
+            services = await routing_service._resolve_services(
+                messaging.resolver, to_target
+            )
             if services:
                 chain.append(
                     {
@@ -143,7 +158,9 @@ async def get_target(request: web.BaseRequest, to_did: str, from_did: str):
                 )
                 to_target = services[0].service_endpoint.uri
             found_forwardable_service = (
-                await routing_service.is_forwardable_service(messaging.resolver, services[0])
+                await routing_service.is_forwardable_service(
+                    messaging.resolver, services[0]
+                )
                 if services
                 else False
             )
@@ -234,6 +251,9 @@ def post_process_routes(app: web.Application):
         {
             "name": "didcommv2",
             "description": "DIDComm V2 based protocols for Interop-a-thon",
-            "externalDocs": {"description": "Specification", "url": "https://didcomm.org"},
+            "externalDocs": {
+                "description": "Specification",
+                "url": "https://didcomm.org",
+            },
         }
     )
diff --git a/acapy_agent/protocols_v2/empty/v1_0/message_types.py b/acapy_agent/protocols_v2/empty/v1_0/message_types.py
@@ -1,23 +1,23 @@
 """Message type identifiers for Trust Pings."""
 
-#from ...didcomm_prefix import DIDCommPrefix
+# from ...didcomm_prefix import DIDCommPrefix
 import logging
 from ....messaging.v2_agent_message import V2AgentMessage
 from ....connections.models.connection_target import ConnectionTarget
 from didcomm_messaging import DIDCommMessaging, RoutingService
 
-SPEC_URI = (
-    "https://identity.foundation/didcomm-messaging/spec/v2.1/#the-empty-message"
-)
+SPEC_URI = "https://identity.foundation/didcomm-messaging/spec/v2.1/#the-empty-message"
 
 # Message types
 EMPTY = "https://didcomm.org/empty/1.0/empty"
 
 PROTOCOL_PACKAGE = "acapy_agent.protocols_v2.empty.v1_0"
 
+
 class basic_message:
     async def __call__(self, *args, **kwargs):
         await self.handle(*args, **kwargs)
+
     @staticmethod
     async def handle(context, responder, payload):
         logger = logging.getLogger(__name__)