Added debugging

Signed-off-by: Ian Costanzo <ian@anon-solutions.ca>

Author: ianco

aries_cloudagent/protocols/routing/v1_0/manager.py

@@ -1,5 +1,6 @@
 """Routing manager classes for tracking and inspecting routing records."""
 
+import logging
 from typing import Coroutine, Sequence
 
 from ....core.error import BaseError
@@ -16,6 +17,9 @@
 from .models.route_updated import RouteUpdated
 
 
+LOGGER = logging.getLogger(__name__)
+
+
 class RoutingManagerError(BaseError):
     """Generic routing error."""
 
@@ -55,15 +59,19 @@ async def get_recipient(self, recip_verkey: str) -> RouteRecord:
             raise RoutingManagerError("Must pass non-empty recip_verkey")
 
         try:
+            LOGGER.error(">>> fetching routing record for verkey: " + recip_verkey)
             async with self._profile.session() as session:
                 record = await RouteRecord.retrieve_by_recipient_key(
                     session, recip_verkey
                 )
+            LOGGER.error(">>> FOUND routing record for verkey: " + recip_verkey)
         except StorageDuplicateError:
+            LOGGER.error(">>> DUPLICATE routing record for verkey: " + recip_verkey)
             raise RouteNotFoundError(
                 f"More than one route record found with recipient key: {recip_verkey}"
             )
         except StorageNotFoundError:
+            LOGGER.error(">>> NOT FOUND routing record for verkey: " + recip_verkey)
             raise RouteNotFoundError(
                 f"No route found with recipient key: {recip_verkey}"
             )
@@ -136,13 +144,15 @@ async def create_route_record(
             )
         if not recipient_key:
             raise RoutingManagerError("Missing recipient_key")
+        LOGGER.error(">>> creating routing record for verkey: " + recipient_key)
         route = RouteRecord(
             connection_id=client_connection_id,
             wallet_id=internal_wallet_id,
             recipient_key=recipient_key,
         )
         async with self._profile.session() as session:
             await route.save(session, reason="Created new route")
+        LOGGER.error(">>> CREATED routing record for verkey: " + recipient_key)
         return route
 
     async def update_routes(