feat: Respond to target list & msg fixes

- Respond to the target list via did resolution
- Fix response to incoming messages (hack it till it works)

Signed-off-by: Colton Wolkins (Laptop) <[email protected]>

Author: TheTechmage

acapy_agent/protocols_v2/trustping/v1_0/message_types.py

@@ -3,6 +3,8 @@
 #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://github.com/hyperledger/aries-rfcs/tree/"
@@ -22,16 +24,62 @@ async def __call__(self, *args, **kwargs):
     @staticmethod
     async def handle(context, responder, payload):
         message = payload
+        session = await context.profile.session()
+        ctx = session
+        messaging = ctx.inject(DIDCommMessaging)
+        routing_service = ctx.inject(RoutingService)
+        frm = message.get("from")
+        #destination = await routing_service._resolve_services(messaging.resolver, frm)
+        services = await routing_service._resolve_services(messaging.resolver, frm)
+        chain = [
+            {
+                "did": frm,
+                "service": services,
+            }
+        ]
+
+        # Loop through service DIDs until we run out of DIDs to forward to
+        to_did = services[0].service_endpoint.uri
+        found_forwardable_service = await routing_service.is_forwardable_service(
+            messaging.resolver, services[0]
+        )
+        while found_forwardable_service:
+            services = await routing_service._resolve_services(messaging.resolver, to_did)
+            if services:
+                chain.append(
+                    {
+                        "did": to_did,
+                        "service": services,
+                    }
+                )
+                to_did = services[0].service_endpoint.uri
+            found_forwardable_service = (
+                await routing_service.is_forwardable_service(messaging.resolver, services[0])
+                if services
+                else False
+            )
+        destination = [
+            ConnectionTarget(
+                did=context.message_receipt.sender_verkey,
+                endpoint=service.service_endpoint.uri,
+                recipient_keys=[context.message_receipt.sender_verkey],
+                sender_key=context.message_receipt.recipient_verkey,
+            )
+            for service in chain[-1]["service"]
+        ]
         logger = logging.getLogger(__name__)
         error_result = V2AgentMessage(
             message={
                 "type": "https://didcomm.org/basicmessage/2.0/message",
                 "body": {
-                    "message": "Hello Frosty :3",
+                    "content": "Hello from acapy",
                 },
+                "to": [context.message_receipt.sender_verkey.split('#')[0]],
+                "from": context.message_receipt.recipient_verkey.split('#')[0],
+                "lang": "en",
             }
         )
-        await responder.send_reply(error_result)
+        await responder.send_reply(error_result, target_list=destination)
 
 HANDLERS = {
     DEBUG: f"{PROTOCOL_PACKAGE}.message_types.test_func",