Added urllib3 2.5.0 to avoid breaking change affecting hubspot-api-client (removal of HTTPResponse.getheader in 2.6.0); changed docstring python file names

python/hubspot_audit.py

@@ -2,23 +2,23 @@
 HubSpot Audit → Supabase (incremental since a millisecond cursor)
 
 Usage from orchestrator:
-    import load_hubspot_companies
-    load_hubspot_companies.main(since_ms=<int milliseconds since epoch UTC>)
+    import hubspot_audit
+    hubspot_audit.main(since_ms=<int milliseconds since epoch UTC>)
 
 Direct CLI:
     # epoch ms
-    python load_hubspot_companies.py 1754025600000
+    python hubspot_audit.py 1754025600000
     # ISO-8601
-    python load_hubspot_companies.py 2025-08-01T09:30:00Z
+    python hubspot_audit.py 2025-08-01T09:30:00Z
     # Back-compat date (floors to 00:00Z)
-    python load_hubspot_companies.py 2025-08-01
+    python hubspot_audit.py 2025-08-01
 """
 import os
 import logging
 import datetime
 from typing import Dict, List, Optional, Union
 import re
-from dotenv import load_dotenv
+from dotenv import dotenv
 from supabase import create_client
 from supabase_utils import batched_insert, update_sync_metadata
 from hubspot_utils import (
@@ -40,7 +40,7 @@ logging.basicConfig(
 )
 
 # Environment
-load_dotenv()
+dotenv()
 HUBSPOT_TOKEN = os.getenv("HUBSPOT_TOKEN")
 SUPABASE_URL = os.getenv("SUPABASE_URL")
 SUPABASE_SERVICE_ROLE_KEY = os.getenv("SUPABASE_SERVICE_ROLE_KEY")

python/hubspot_billing.py

@@ -2,16 +2,16 @@
 HubSpot Billing → Supabase (incremental since a millisecond cursor)
 
 Usage from orchestrator:
-    import load_hubspot_billing
-    load_hubspot_billing.main(since_ms=<int milliseconds since epoch UTC>)
+    import hubspot_billing
+    hubspot_billing.main(since_ms=<int milliseconds since epoch UTC>)
 
 Direct CLI:
     # epoch ms
-    python load_hubspot_billing.py 1754025600000
+    python hubspot_billing.py 1754025600000
     # ISO-8601
-    python load_hubspot_billing.py 2025-08-01T09:30:00Z
+    python hubspot_billing.py 2025-08-01T09:30:00Z
     # Back-compat date (floors to 00:00Z)
-    python load_hubspot_billing.py 2025-08-01
+    python hubspot_billing.py 2025-08-01
 """
 import os
 import re

python/hubspot_companies.py

@@ -2,16 +2,16 @@
 HubSpot Companies → Supabase (incremental since a millisecond cursor)
 
 Usage from orchestrator:
-    import load_hubspot_companies
-    load_hubspot_companies.main(since_ms=<int milliseconds since epoch UTC>)
+    import hubspot_companies
+    hubspot_companies.main(since_ms=<int milliseconds since epoch UTC>)
 
 Direct CLI:
     # epoch ms
-    python load_hubspot_companies.py 1754025600000
+    python hubspot_companies.py 1754025600000
     # ISO-8601
-    python load_hubspot_companies.py 2025-08-01T09:30:00Z
+    python hubspot_companies.py 2025-08-01T09:30:00Z
     # Back-compat date (floors to 00:00Z)
-    python load_hubspot_companies.py 2025-08-01
+    python hubspot_companies.py 2025-08-01
 """
 
 import os
@@ -23,7 +23,7 @@ from typing import List, Dict, Optional, Tuple, Union
 
 import httpx
 import hubspot
-from dotenv import load_dotenv
+from dotenv import dotenv
 from supabase import create_client
 from hubspot.crm.companies import ApiException as CompaniesApiException
 
@@ -31,7 +31,7 @@ from hubspot_utils import (
     try_parse_int, parse_ts, get_property_label_mapping,
 )
 from supabase_utils import (
-    update_sync_metadata, enrich_supabase_row, upload_raw_json_to_supabase,
+    update_sync_metadata, enrich_supabase_row, upraw_json_to_supabase,
     batched_insert, fetch_supabase_table,
 )
 
@@ -48,7 +48,7 @@ logging.basicConfig(
 # -----------------------------------------------------------------------------
 # Environment
 # -----------------------------------------------------------------------------
-load_dotenv()
+dotenv()
 HUBSPOT_TOKEN = os.getenv("HUBSPOT_TOKEN")
 SUPABASE_URL = os.getenv("SUPABASE_URL")
 SUPABASE_SERVICE_ROLE_KEY = os.getenv("SUPABASE_SERVICE_ROLE_KEY")
@@ -407,7 +407,7 @@ def upsert_companies(companies: List[Dict]) -> None:
     print(f"{len(rows_to_upsert)} companies to insert/update (out of {len(companies)} read).")
 
     if rows_to_upsert:
-        # upload_raw_json_to_supabase(supabase_client, rows_to_upsert, object_type="companies")
+        # upraw_json_to_supabase(supabase_client, rows_to_upsert, object_type="companies")
         batched_insert(supabase_client, "hubspot_companies",
                        rows_to_upsert, batch_size=1000)
 

python/hubspot_contacts.py

@@ -1,9 +1,17 @@
 """
-HubSpot Contacts → Supabase (incremental since a millisecond cursor)
+HubSpot Companies → Supabase (incremental since a millisecond cursor)
 
 Usage from orchestrator:
-    import load_hubspot_contacts
-    load_hubspot_contacts.main(since_ms=<int milliseconds since epoch UTC>)
+    import hubspot_contacts
+    hubspot_contacts.main(since_ms=<int milliseconds since epoch UTC>)
+
+Direct CLI:
+    # epoch ms
+    python hubspot_contacts.py 1754025600000
+    # ISO-8601
+    python hubspot_contacts.py 2025-08-01T09:30:00Z
+    # Back-compat date (floors to 00:00Z)
+    python hubspot_contacts.py 2025-08-01
 """
 
 import os

python/hubspot_deals.py

@@ -2,16 +2,16 @@
 HubSpot Deals → Supabase (incremental since a millisecond cursor)
 
 Usage from orchestrator:
-    import load_hubspot_deals
-    load_hubspot_deals.main(since_ms=<int milliseconds since epoch UTC>)
+    import hubspot_deals
+    hubspot_deals.main(since_ms=<int milliseconds since epoch UTC>)
 
 Direct CLI:
     # epoch ms
-    python load_hubspot_deals.py 1754025600000
+    python hubspot_deals.py 1754025600000
     # ISO-8601
-    python load_hubspot_deals.py 2025-08-01T09:30:00Z
+    python hubspot_deals.py 2025-08-01T09:30:00Z
     # Back-compat date (floors to 00:00Z)
-    python load_hubspot_deals.py 2025-08-01
+    python hubspot_deals.py 2025-08-01
 """
 import os
 import re

python/hubspot_emails.py

@@ -2,18 +2,18 @@
 HubSpot Emails → Supabase (incremental since a millisecond cursor)
 
 Usage from orchestrator:
-    import load_hubspot_emails
-    load_hubspot_emails.main(since_ms=<int milliseconds since epoch UTC>)
+    import hubspot_emails
+    hubspot_emails.main(since_ms=<int milliseconds since epoch UTC>)
 
 Direct CLI:
     # epoch ms
-    python load_hubspot_emails.py 1754025600000
+    python hubspot_emails.py 1754025600000
 
     # ISO-8601 (Z or offset)
-    python load_hubspot_emails.py 2025-08-01T09:30:00Z
+    python hubspot_emails.py 2025-08-01T09:30:00Z
 
     # Back-compat date (floors to 00:00:00Z)
-    python load_hubspot_emails.py 2025-08-01
+    python hubspot_emails.py 2025-08-01
 """
 
 import os

python/hubspot_tickets.py

@@ -2,16 +2,16 @@
 HubSpot Tickets → Supabase (incremental since a millisecond cursor)
 
 Usage from orchestrator:
-    import load_hubspot_tickets
-    load_hubspot_tickets.main(since_ms=<int milliseconds since epoch UTC>)
+    import hubspot_tickets
+    hubspot_tickets.main(since_ms=<int milliseconds since epoch UTC>)
 
 Direct CLI:
     # epoch ms
-    python load_hubspot_tickets.py 1754025600000
+    python hubspot_tickets.py 1754025600000
     # ISO-8601
-    python load_hubspot_tickets.py 2025-08-01T09:30:00Z
+    python hubspot_tickets.py 2025-08-01T09:30:00Z
     # Back-compat date (floors to 00:00Z)
-    python load_hubspot_tickets.py 2025-08-01
+    python hubspot_tickets.py 2025-08-01
 """
 
 import os

python/load_hubspot_data.py

@@ -3,11 +3,11 @@ Unified orchestrator for HubSpot → Supabase pipelines with a timestamp cursor.
 
 CLI:
     # epoch ms
-    python hubspot_orchestrator.py 1754025600000
+    python load_hubspot_data.py 1754025600000
     # ISO-8601
-    python hubspot_orchestrator.py 2025-08-01T09:30:00Z
+    python load_hubspot_data.py 2025-08-01T09:30:00Z
     # Back-compat date (floors to 00:00Z)
-    python hubspot_orchestrator.py 2025-08-01
+    python load_hubspot_data.py 2025-08-01
     # No arg: defaults to today@00:00Z
 """
 

requirements.txt

@@ -6,4 +6,5 @@ pandas==2.2.2
 openpyxl==3.1.5
 phonenumbers
 tldextract
-rapidfuzz
+rapidfuzz
+urllib3==2.5.0