chore: clean up dead code

Signed-off-by: Colton Wolkins (Laptop) <colton@indicio.tech>

Author: TheTechmage

acapy_agent/core/dispatcher.py

@@ -159,9 +159,8 @@ async def handle_v2_message(
                 error_result.assign_thread_id(inbound_message.receipt.thread_id)
 
         session = await profile.session()
-        ctx = session
-        messaging = ctx.inject(DIDCommMessaging)
-        routing_service = ctx.inject(RoutingService)
+        messaging = session.inject(DIDCommMessaging)
+        routing_service = session.inject(RoutingService)
         frm = inbound_message.payload.get("from")
         services = await routing_service._resolve_services(messaging.resolver, frm)
         chain = [
@@ -231,27 +230,6 @@ async def handle_v2_message(
             if inbound_message.receipt.thread_id:
                 error_result.message["pthid"] = inbound_message.receipt.thread_id
 
-        # # When processing oob attach message we supply the connection id
-        # # associated with the inbound message
-        # if inbound_message.connection_id:
-        #     async with self.profile.session() as session:
-        #         connection = await ConnRecord.retrieve_by_id(
-        #             session, inbound_message.connection_id
-        #         )
-        # else:
-        #     connection_mgr = BaseConnectionManager(profile)
-        #     connection = await connection_mgr.find_inbound_connection(
-        #         inbound_message.receipt
-        #     )
-        #     del connection_mgr
-
-        # if connection:
-        #     inbound_message.connection_id = connection.connection_id
-
-        # context.connection_ready = connection and connection.is_ready
-        # context.connection_record = connection
-        # responder.connection_id = connection and connection.connection_id
-
         if error_result:
             await responder.send_reply(error_result)
         elif context.message:
@@ -290,9 +268,6 @@ 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 = message_cls.resolved
             message_cls = registry.protocols_matching_query(message_type)
         except ProtocolMinorVersionNotSupported as e:
             raise MessageParseError(f"Problem parsing message type. {e}")
@@ -301,7 +276,6 @@ 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 = registry.handlers[message_cls[0]]
             if isinstance(instance, DeferLoad):
                 instance = instance.resolved

acapy_agent/protocols_v2/basicmessage/v1_0/message_types.py

@@ -1,6 +1,5 @@
 """Message type identifiers for Trust Pings."""
 
-# from ...didcomm_prefix import DIDCommPrefix
 import logging
 from ....messaging.v2_agent_message import V2AgentMessage
 

acapy_agent/protocols_v2/discovery/v1_0/message_types.py

@@ -1,6 +1,5 @@
 """Message type identifiers for Trust Pings."""
 
-# from ...didcomm_prefix import DIDCommPrefix
 import logging
 from ....messaging.v2_agent_message import V2AgentMessage
 

acapy_agent/protocols_v2/empty/v1_0/message_types.py

@@ -1,6 +1,5 @@
 """Message type identifiers for Trust Pings."""
 
-# from ...didcomm_prefix import DIDCommPrefix
 import logging
 
 SPEC_URI = "https://identity.foundation/didcomm-messaging/spec/v2.1/#the-empty-message"

acapy_agent/protocols_v2/trustping/v1_0/message_types.py

@@ -1,6 +1,5 @@
 """Message type identifiers for Trust Pings."""
 
-# from ...didcomm_prefix import DIDCommPrefix
 import logging
 from ....messaging.v2_agent_message import V2AgentMessage
 

acapy_agent/protocols_v2/trustping/v1_0/routes.py

@@ -180,20 +180,11 @@ async def connections_send_ping(request: web.BaseRequest):
 
     """
     request["context"]
-    # connection_id = request.match_info["conn_id"]
     outbound_handler = request["outbound_message_router"]
     body = await request.json()
     to_did = body.get("to_did")
     response_requested = body.get("response_requested")
 
-    # if not connection.is_ready:
-    #    raise web.HTTPBadRequest(reason=f"Connection {connection_id} not ready")
-
-    # msg = Ping(did=did, response_requested=response_requested)
-    # await outbound_handler(msg, connection_id=connection_id)
-
-    # return web.json_response({"results": results})
-
     our_did = await get_mydid(request)
     their_did = to_did
     reply_destination = await get_target(request, to_did, our_did)
@@ -209,10 +200,8 @@ async def connections_send_ping(request: web.BaseRequest):
     if response_requested:
         msg.message["response_requested"] = True
 
-    ## await responder.send_reply(error_result)
     await outbound_handler(msg, target_list=reply_destination)
 
-    # return web.json_response({"thread_id": msg._thread_id})
     return web.json_response(msg.message)