Add invoice-contact associations

python/hubspot_invoices.py

@@ -212,6 +212,9 @@ def read_invoice_by_ids(
         return [], [], None
 
     all_invoices: List[Dict] = []
+    invoice_contact_links: List[Dict] = []
+
+    assoc_types = ["contacts"]
 
     max_ts_ms: Optional[int] = None
 
@@ -219,7 +222,8 @@ def read_invoice_by_ids(
         try:
             record = hubspot_client.crm.objects.basic_api.get_by_id(
                 object_type="invoices",
-                object_id=did, properties=INOVICE_PROPERTIES, archived=False
+                object_id=did, properties=INOVICE_PROPERTIES,
+                associations=assoc_types,archived=False
             )
             p = record.properties or {}
 
@@ -228,6 +232,17 @@ def read_invoice_by_ids(
             ts_ms = parse_any_ts_ms(cursor_val)
             if ts_ms is not None and (max_ts_ms is None or ts_ms > max_ts_ms):
                 max_ts_ms = ts_ms
+            
+            # Contacts
+            if getattr(record, "associations", None) and record.associations.get("contacts"):
+                bucket = record.associations["contacts"]
+                if getattr(bucket, "results", None):
+                    for a in bucket.results:
+                        if a.id and a.id.isdigit():
+                            invoice_contact_links.append({
+                                "invoice_id": try_parse_int(record.id),
+                                "contact_id": try_parse_int(a.id),
+                            })
 
             # Created date: accept either createdate or hs_createdate
             created_iso = p.get("createdate") or p.get("hs_createdate")
@@ -258,16 +273,27 @@ def read_invoice_by_ids(
         except (ObjectsApiException, httpx.HTTPError) as e:
             logging.error("Error reading invoice %s: %s", did, e)
 
-    return all_invoices, max_ts_ms
+    return all_invoices, invoice_contact_links, max_ts_ms
 
 # -----------------------------------------------------------------------------
 # Upsert
 # -----------------------------------------------------------------------------
-def upsert_invoices(invoices: List[Dict]) -> None:
+def upsert_invoices(invoices: List[Dict], invoice_contact_links: List[Dict]) -> None:
     if invoices:
         insert_into_supabase_table(supabase_client, "hubspot_invoices", invoices)
         print(f"Upserted {len(invoices)} invoices.")
 
+    if invoice_contact_links:
+        invoice_contact_links = deduplicate_by_key(invoice_contact_links, key=("invoice_id", "contact_id"))
+        insert_into_supabase_table(
+            supabase_client,
+            "hubspot_invoice_contacts",
+            invoice_contact_links,
+            on_conflict=["invoice_id", "contact_id"],
+        )
+        print(f"Upserted {len(invoice_contact_links)} invoice-contact associations.")
+    
+
 # -----------------------------------------------------------------------------
 # Main (timestamp cursor)
 # -----------------------------------------------------------------------------
@@ -303,10 +329,10 @@ def main(since_ms: Optional[int] = None):
         return
 
     print("Reading invoices (with associations)...")
-    invoices, max_ts_ms = read_invoice_by_ids(ids, cursor_prop)
+    invoices, invoice_contact_links, max_ts_ms = read_invoice_by_ids(ids, cursor_prop)
 
     print("Upserting into Supabase...")
-    upsert_invoices(invoices)
+    upsert_invoices(invoices, invoice_contact_links)
 
     # Advance cursor to max timestamp we actually ingested for the chosen property
     new_cursor_ms = max_ts_ms if max_ts_ms is not None else since_ms