Indicio-tech
diff --git a/‎acapy_agent/__main__.py‎
Lines changed: 9 additions & 4 deletions b/‎acapy_agent/__main__.py‎
Lines changed: 9 additions & 4 deletions
diff --git a/‎acapy_agent/admin/server.py‎
Lines changed: 8 additions & 5 deletions b/‎acapy_agent/admin/server.py‎
Lines changed: 8 additions & 5 deletions
diff --git a/‎acapy_agent/anoncreds/default/did_indy/registry.py‎
Lines changed: 1 addition & 1 deletion b/‎acapy_agent/anoncreds/default/did_indy/registry.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎acapy_agent/anoncreds/default/did_web/registry.py‎
Lines changed: 4 additions & 1 deletion b/‎acapy_agent/anoncreds/default/did_web/registry.py‎
Lines changed: 4 additions & 1 deletion
diff --git a/‎acapy_agent/anoncreds/default/legacy_indy/registry.py‎
Lines changed: 1 addition & 1 deletion b/‎acapy_agent/anoncreds/default/legacy_indy/registry.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎acapy_agent/commands/provision.py‎
Lines changed: 5 additions & 2 deletions b/‎acapy_agent/commands/provision.py‎
Lines changed: 5 additions & 2 deletions
diff --git a/‎acapy_agent/commands/start.py‎
Lines changed: 2 additions & 2 deletions b/‎acapy_agent/commands/start.py‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎acapy_agent/config/argparse.py‎
Lines changed: 1 addition & 1 deletion b/‎acapy_agent/config/argparse.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎acapy_agent/config/default_context.py‎
Lines changed: 7 additions & 5 deletions b/‎acapy_agent/config/default_context.py‎
Lines changed: 7 additions & 5 deletions
diff --git a/‎acapy_agent/config/ledger.py‎
Lines changed: 29 additions & 1 deletion b/‎acapy_agent/config/ledger.py‎
Lines changed: 29 additions & 1 deletion
@@ -1,8 +1,11 @@
 """acapy_agent package entry point."""
 
+import logging
 import os
 import sys
 
+LOGGER = logging.getLogger(__name__)
+
 
 def init_debug(args):
     """Initialize debugging environment."""
@@ -26,16 +29,18 @@ def init_debug(args):
             import debugpy
 
             debugpy.listen((DAP_HOST, DAP_PORT))
-            print(f"=== Waiting for debugger to attach to {DAP_HOST}:{DAP_PORT} ===")
+            LOGGER.info(
+                f"=== Waiting for debugger to attach to {DAP_HOST}:{DAP_PORT} ==="
+            )
             debugpy.wait_for_client()
         except ImportError:
-            print("debugpy library was not found")
+            LOGGER.error("debugpy library was not found")
 
     if ENABLE_PYDEVD_PYCHARM or "--debug-pycharm" in args:
         try:
             import pydevd_pycharm
 
-            print(
+            LOGGER.info(
                 "aca-py remote debugging to "
                 f"{PYDEVD_PYCHARM_HOST}:{PYDEVD_PYCHARM_AGENT_PORT}"
             )
@@ -47,7 +52,7 @@ def init_debug(args):
                 suspend=False,
             )
         except ImportError:
-            print("pydevd_pycharm library was not found")
+            LOGGER.error("pydevd_pycharm library was not found")
 
 
 def run(args):
 
@@ -226,11 +226,14 @@ async def upgrade_middleware(request: web.BaseRequest, handler: Coroutine):
 async def debug_middleware(request: web.BaseRequest, handler: Coroutine):
     """Show request detail in debug log."""
 
-    if LOGGER.isEnabledFor(logging.DEBUG):
-        LOGGER.debug(f"Incoming request: {request.method} {request.path_qs}")
-        LOGGER.debug(f"Match info: {request.match_info}")
-        body = await request.text() if request.body_exists else None
-        LOGGER.debug(f"Body: {body}")
+    if LOGGER.isEnabledFor(logging.DEBUG):  # Skipped if DEBUG is not enabled
+        LOGGER.debug("Incoming request: %s %s", request.method, request.path_qs)
+        is_status_check = str(request.rel_url).startswith("/status/")
+        if not is_status_check:  # Don't log match info for status checks; reduces noise
+            LOGGER.debug("Match info: %s", request.match_info)
+
+            if request.body_exists:  # Only log body if it exists
+                LOGGER.debug("Body: %s", await request.text())
 
     return await handler(request)
 
 
@@ -42,7 +42,7 @@ def supported_identifiers_regex(self) -> Pattern:
 
     async def setup(self, context: InjectionContext):
         """Setup."""
-        print("Successfully registered DIDIndyRegistry")
+        LOGGER.info("Successfully registered DIDIndyRegistry")
 
     async def get_schema(self, profile: Profile, schema_id: str) -> GetSchemaResult:
         """Get a schema from the registry."""
 
@@ -1,5 +1,6 @@
 """DID Web Registry."""
 
+import logging
 import re
 from typing import Optional, Pattern, Sequence
 
@@ -18,6 +19,8 @@
 from ...models.schema import AnonCredsSchema, GetSchemaResult, SchemaResult
 from ...models.schema_info import AnoncredsSchemaInfo
 
+LOGGER = logging.getLogger(__name__)
+
 
 class DIDWebRegistry(BaseAnonCredsResolver, BaseAnonCredsRegistrar):
     """DIDWebRegistry."""
@@ -41,7 +44,7 @@ def supported_identifiers_regex(self) -> Pattern:
 
     async def setup(self, context: InjectionContext):
         """Setup."""
-        print("Successfully registered DIDWebRegistry")
+        LOGGER.info("Successfully registered DIDWebRegistry")
 
     async def get_schema(self, profile, schema_id: str) -> GetSchemaResult:
         """Get a schema from the registry."""
 
@@ -145,7 +145,7 @@ def supported_identifiers_regex(self) -> Pattern:
 
     async def setup(self, context: InjectionContext):
         """Setup."""
-        print("Successfully registered LegacyIndyRegistry")
+        LOGGER.info("Successfully registered LegacyIndyRegistry")
 
     @staticmethod
     def make_schema_id(schema: AnonCredsSchema) -> str:
 
@@ -1,6 +1,7 @@
 """Provision command for setting up agent settings before starting."""
 
 import asyncio
+import logging
 from typing import Sequence
 
 from configargparse import ArgumentParser
@@ -22,6 +23,8 @@
 from ..storage.base import BaseStorage
 from . import PROG
 
+LOGGER = logging.getLogger(__name__)
+
 
 class ProvisionError(BaseError):
     """Base exception for provisioning errors."""
@@ -58,9 +61,9 @@ async def provision(settings: dict):
                 )
 
         if await ledger_config(root_profile, public_did and public_did.did, True):
-            print("Ledger configured")
+            LOGGER.info("Ledger configured")
         else:
-            print("Ledger not configured")
+            LOGGER.warning("Ledger not configured")
 
         await root_profile.close()
     except BaseError as e:
 
@@ -31,7 +31,7 @@ async def start_app(conductor: Conductor):
 
 async def shutdown_app(conductor: Conductor):
     """Shut down."""
-    print("\nShutting down")
+    LOGGER.info("Shutting down")
     await conductor.stop()
 
 
@@ -59,7 +59,7 @@ def execute(argv: Sequence[str] = None):
     # Run the application
     if uvloop:
         uvloop.install()
-        print("uvloop installed")
+        LOGGER.info("uvloop installed")
     run_loop(start_app(conductor), shutdown_app(conductor))
 
 
 
@@ -63,7 +63,7 @@ def get_registered(cls, category: Optional[str] = None):
 
 
 def create_argument_parser(*, prog: Optional[str] = None):
-    """Create am instance of an arg parser, force yaml format for external config."""
+    """Create an instance of an arg parser, force yaml format for external config."""
     return ArgumentParser(config_file_parser_class=YAMLConfigFileParser, prog=prog)
 
 
 
@@ -36,11 +36,14 @@ class DefaultContextBuilder(ContextBuilder):
 
     async def build_context(self) -> InjectionContext:
         """Build the base injection context; set DIDComm prefix to emit."""
+        LOGGER.debug("Building new injection context")
+
         context = InjectionContext(settings=self.settings)
         context.settings.set_default("default_label", "Aries Cloud Agent")
 
         if context.settings.get("timing.enabled"):
             timing_log = context.settings.get("timing.log_file")
+            LOGGER.debug("Enabling timing collector with log file: %s", timing_log)
             collector = Collector(log_path=timing_log)
             context.injector.bind_instance(Collector, collector)
 
@@ -67,6 +70,7 @@ async def build_context(self) -> InjectionContext:
 
         # DIDComm Messaging
         if context.settings.get("experiment.didcomm_v2"):
+            LOGGER.info("DIDComm v2 experimental mode enabled")
             from didcomm_messaging import CryptoService, PackagingService, RoutingService
             from didcomm_messaging.crypto.backend.askar import AskarCryptoService
 
@@ -81,19 +85,15 @@ async def build_context(self) -> InjectionContext:
 
     async def bind_providers(self, context: InjectionContext):
         """Bind various class providers."""
+        LOGGER.debug("Begin binding providers to context")
 
         context.injector.bind_provider(ProfileManager, ProfileManagerProvider())
 
         # Register default pack format
         context.injector.bind_provider(
             BaseWireFormat,
             CachedProvider(
-                # StatsProvider(
                 ClassProvider("acapy_agent.transport.pack_format.PackWireFormat"),
-                #    (
-                #        "encode_message", "parse_message"
-                #    ),
-                # )
             ),
         )
 
@@ -110,6 +110,7 @@ async def bind_providers(self, context: InjectionContext):
     async def load_plugins(self, context: InjectionContext):
         """Set up plugin registry and load plugins."""
 
+        LOGGER.debug("Initializing plugin registry")
         plugin_registry = PluginRegistry(
             blocklist=self.settings.get("blocked_plugins", [])
         )
@@ -183,6 +184,7 @@ def register_anoncreds_plugins():
 
         # Register external plugins
         for plugin_path in self.settings.get("external_plugins", []):
+            LOGGER.debug("Registering external plugin: %s", plugin_path)
             plugin_registry.register_plugin(plugin_path)
 
         # Register message protocols
 
@@ -33,14 +33,18 @@ async def fetch_genesis_transactions(genesis_url: str) -> str:
         # https://github.com/openwallet-foundation/acapy/issues/1745
         return await fetch(genesis_url, headers=headers, max_attempts=20)
     except FetchError as e:
+        LOGGER.error("Error retrieving genesis transactions from %s: %s", genesis_url, e)
         raise ConfigError("Error retrieving ledger genesis transactions") from e
 
 
 async def get_genesis_transactions(settings: Settings) -> str:
     """Fetch genesis transactions if necessary."""
 
+    LOGGER.debug("Getting genesis transactions from settings")
     txns = settings.get("ledger.genesis_transactions")
+    LOGGER.debug("Genesis transactions from settings: %s", "found" if txns else "absent")
     if not txns:
+        LOGGER.debug("No genesis transactions found in settings")
         if settings.get("ledger.genesis_url"):
             txns = await fetch_genesis_transactions(settings["ledger.genesis_url"])
         elif settings.get("ledger.genesis_file"):
@@ -50,8 +54,10 @@ async def get_genesis_transactions(settings: Settings) -> str:
                 with open(genesis_path, "r") as genesis_file:
                     txns = genesis_file.read()
             except IOError as e:
+                LOGGER.error("Failed to read genesis file: %s", str(e))
                 raise ConfigError("Error reading ledger genesis transactions") from e
         if txns:
+            LOGGER.debug("Storing genesis transactions in settings")
             settings["ledger.genesis_transactions"] = txns
     return txns
 
@@ -62,6 +68,8 @@ async def load_multiple_genesis_transactions_from_config(settings: Settings):
     ledger_config_list = settings.get("ledger.ledger_config_list")
     ledger_txns_list = []
     write_ledger_set = False
+    LOGGER.debug("Processing %d ledger configs", len(ledger_config_list))
+
     for config in ledger_config_list:
         txns = None
         if "genesis_transactions" in config:
@@ -73,11 +81,12 @@ async def load_multiple_genesis_transactions_from_config(settings: Settings):
                 try:
                     genesis_path = config.get("genesis_file")
                     LOGGER.info(
-                        "Reading ledger genesis transactions from: %s", genesis_path
+                        "Reading ledger genesis transactions from file: %s", genesis_path
                     )
                     with open(genesis_path, "r") as genesis_file:
                         txns = genesis_file.read()
                 except IOError as e:
+                    LOGGER.error("Failed to read genesis file: %s", str(e))
                     raise ConfigError("Error reading ledger genesis transactions") from e
         is_write_ledger = (
             False if config.get("is_write") is None else config.get("is_write")
@@ -118,13 +127,18 @@ async def load_multiple_genesis_transactions_from_config(settings: Settings):
             " genesis_file and genesis_transactions provided."
         )
     settings["ledger.ledger_config_list"] = ledger_txns_list
+    LOGGER.debug("Processed %d ledger configs successfully", len(ledger_txns_list))
 
 
 async def ledger_config(
     profile: Profile, public_did: str, provision: bool = False
 ) -> bool:
     """Perform Indy ledger configuration."""
 
+    LOGGER.debug(
+        "Configuring ledger for profile %s and public_did %s", profile.name, public_did
+    )
+
     session = await profile.session()
 
     ledger = session.inject_or(BaseLedger)
@@ -135,32 +149,46 @@ async def ledger_config(
     async with ledger:
         # Check transaction author agreement acceptance
         if not ledger.read_only:
+            LOGGER.debug("Checking transaction author agreement")
             taa_info = await ledger.get_txn_author_agreement()
             if taa_info["taa_required"] and public_did:
+                LOGGER.debug("TAA acceptance required")
                 taa_accepted = await ledger.get_latest_txn_author_acceptance()
                 if (
                     not taa_accepted
                     or taa_info["taa_record"]["digest"] != taa_accepted["digest"]
                 ):
+                    LOGGER.info("TAA acceptance needed - performing acceptance")
                     if not await accept_taa(ledger, profile, taa_info, provision):
+                        LOGGER.warning("TAA acceptance failed")
                         return False
+                    LOGGER.info("TAA acceptance completed")
 
         # Publish endpoints if necessary - skipped if TAA is required but not accepted
         endpoint = session.settings.get("default_endpoint")
         if public_did:
             wallet = session.inject(BaseWallet)
             try:
+                LOGGER.debug("Setting DID endpoint to: %s", endpoint)
                 await wallet.set_did_endpoint(public_did, endpoint, ledger)
             except LedgerError as x_ledger:
+                LOGGER.error("Error setting DID endpoint: %s", x_ledger.message)
                 raise ConfigError(x_ledger.message) from x_ledger  # e.g., read-only
 
             # Publish profile endpoint if ledger is NOT read-only
             profile_endpoint = session.settings.get("profile_endpoint")
             if profile_endpoint and not ledger.read_only:
+                LOGGER.debug(
+                    "Publishing profile endpoint: %s for DID: %s",
+                    profile_endpoint,
+                    public_did,
+                )
                 await ledger.update_endpoint_for_did(
                     public_did, profile_endpoint, EndpointType.PROFILE
                 )
+                LOGGER.info("Profile endpoint published successfully")
 
+    LOGGER.info("Ledger configuration complete")
     return True