feat: all to filter annotations by companyId (scopes permitting)

sypht/client.py

@@ -419,6 +419,7 @@ def get_annotations(
         to_date=None,
         endpoint=None,
         rec_limit=None,
+        company_id=None,
     ):
         page_iter = fetch_all_pages(
             name="get_annotations",
@@ -435,6 +436,7 @@ def get_annotations(
             from_date=from_date,
             to_date=to_date,
             endpoint=endpoint,
+            company_id=company_id,
         ):
             annotations.extend(response["annotations"])
         return {"annotations": annotations}
@@ -448,6 +450,7 @@ def _get_annotations(
         from_date=None,
         to_date=None,
         endpoint=None,
+        company_id=None,
         offset=0,
     ):
         """Fetch a single page of annotations skipping the given offset number of pages first.  Use get_annotations to fetch all pages."""
@@ -464,6 +467,8 @@ def _get_annotations(
             filters.append("fromDate=" + from_date)
         if to_date is not None:
             filters.append("toDate=" + to_date)
+        if company_id is not None:
+            filters.append("companyId=" + company_id)
 
         endpoint = urljoin(
             endpoint or self.base_endpoint, ("/app/annotations?" + "&".join(filters))

sypht/util.py

@@ -1,3 +1,4 @@
+import logging
 from typing import Any, Callable, Iterator, List
 
 DEFAULT_REC_LIMIT = 100_000
@@ -48,6 +49,9 @@ def fetch_all_pages(*args, **kwargs) -> Iterator[Any]:
             if len(page) == 0:
                 break
             recs += len(page)
+            logging.info(
+                f"fetch_all_pages({name}): fetched page {page_count} (records={recs})"
+            )
             yield response
 
     return fetch_all_pages