Log and send observability headers

i.e. The session ID and the request ID, are both included in logs
from the `ProxyConnection` object and in the requests sent to the
EfileProxyServer.

Author: BryceStevenWilley

.gitignore

@@ -20,4 +20,4 @@ runtime_config.json
 
 # Python Test stuff
 .coverage
-coverage_html
+coverage_html

docassemble/EFSPIntegration/efm_client.py

@@ -1,10 +1,12 @@
 #!/usr/bin/env python3
-import json
+import logging
+import re
 import pycountry
-from typing import Callable, Dict, Union
+from typing import Dict, Union
 
 import requests
-from requests import Response
+from logging import LoggerAdapter
+from requests import Response, PreparedRequest
 from docassemble.base.functions import all_variables, get_config
 from docassemble.base.util import (
     DAObject,
@@ -23,6 +25,23 @@
 __all__ = ["ApiResponse", "ProxyConnection", "state_name_to_code"]
 
 
+class DALogger(LoggerAdapter):
+    def __init__(self, logger):
+        super().__init__(logger)
+
+    def log(self, level, msg, *args, **kwargs):
+        """
+        Delegate a log call to Docassemble's `log` function, after adding
+        contextual information from this adapter instance.
+        """
+        kwargs
+        if not self.isEnabledFor(level):
+            return
+
+        msg = re.sub(r"\n", " ", msg)
+        log(f"[{args}, {kwargs}] {msg}")
+
+
 def state_name_to_code(state_name: str) -> str:
     try:
         return pycountry.subdivisions.lookup(state_name).code.split("-")[-1]
@@ -147,12 +166,15 @@ def __init__(
         self.credentials_code_block = credentials_code_block
 
         super().__init__(
-            url=url, api_key=api_key, default_jurisdiction=default_jurisdiction
+            url=url,
+            api_key=api_key,
+            default_jurisdiction=default_jurisdiction,
+            logger=DALogger(logging.getLogger("docassemble")),
         )
 
-    def _call_proxy(self, send_func: Callable[[], Response]) -> ApiResponse:
+    def _call_proxy(self, req: PreparedRequest) -> ApiResponse:
         try:
-            resp = send_func()
+            resp = self.proxy_client.send(req)
             if resp.status_code == 401 and self.credentials_code_block:
                 reconsider(self.credentials_code_block)
         except requests.ConnectionError as ex: