feat: convert handler to a class

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

Author: TheTechmage

acapy_agent/core/dispatcher.py

@@ -212,7 +212,7 @@ async def handle_v2_message(
             handler = context.message
             if self.collector:
                 handler = self.collector.wrap_coro(handler, [handler.__qualname__])
-            await handler(context, responder, payload=inbound_message.payload)
+            await handler()(context, responder, payload=inbound_message.payload)
 
     async def make_v2_message(self, profile: Profile, parsed_msg: dict) -> BaseMessage:
         """Deserialize a message dict into the appropriate message instance.

acapy_agent/protocols_v2/trustping/v1_0/message_types.py

@@ -1,6 +1,8 @@
 """Message type identifiers for Trust Pings."""
 
 #from ...didcomm_prefix import DIDCommPrefix
+import logging
+from ....messaging.v2_agent_message import V2AgentMessage
 
 SPEC_URI = (
     "https://github.com/hyperledger/aries-rfcs/tree/"
@@ -12,11 +14,24 @@
 PING_RESPONSE = "trust_ping/1.0/ping_response"
 DEBUG = "https://didcomm.org/basicmessage/2.0/message"
 
-PROTOCOL_PACKAGE = "acapy_agent.protocols.trustping.v1_0"
+PROTOCOL_PACKAGE = "acapy_agent.protocols_v2.trustping.v1_0"
 
-def test_func(context, responder, payload):
-    message = payload
-    print(message)
+class test_func:
+    async def __call__(self, *args, **kwargs):
+        await self.handle(*args, **kwargs)
+    @staticmethod
+    async def handle(context, responder, payload):
+        message = payload
+        logger = logging.getLogger(__name__)
+        error_result = V2AgentMessage(
+            message={
+                "type": "https://didcomm.org/basicmessage/2.0/message",
+                "body": {
+                    "message": "Hello Frosty :3",
+                },
+            }
+        )
+        await responder.send_reply(error_result)
 
 HANDLERS = {
     DEBUG: f"{PROTOCOL_PACKAGE}.message_types.test_func",