Add new properties to contacts and billing

python/hubspot_billing.py

@@ -80,7 +80,8 @@ BILLING_PROPERTIES = [
     "product_type_name",
     "hs_created_by_user_id",
     "hs_createdate",
-    # "hs_lastmodifieddate",  # optionally include if needed later
+    "connection_date",
+    "disconnect_date"
 ]
 
 PROPERTY_RENAME = {
@@ -286,6 +287,8 @@ def read_billing_by_ids(
                 "product_type_name": p.get("product_type_name"),
                 "hubspot_created_by": try_parse_int(p.get("hs_created_by_user_id")),
                 "hubspot_created_at": parse_ts(p.get("hs_createdate")),
+                "connection_date": parse_ts(p.get("connection_date")),
+                "disconnect_date": parse_ts(p.get("disconnect_date")),
             }
             services.append(row)
 

python/hubspot_contacts.py

@@ -85,6 +85,11 @@ CONTACT_PROPERTIES = [
     "hs_object_source_detail_1",
     "hs_analytics_source",
     "hs_latest_source",
+    "ar_1__30",
+    "ar_31__60",
+    "ar_61__90",
+    "ar_91_and_over",
+    "ar_total"
 ]
 
 # -----------------------------------------------------------------------------
@@ -158,6 +163,11 @@ def map_contact_data_for_db(contacts: List[Dict]) -> List[Dict]:
             "record_source_detail_1": c.get("hs_object_source_detail_1"),
             "original_traffic_source": c.get("hs_analytics_source"),
             "latest_traffic_source": c.get("hs_latest_source"),
+            "ar_1_30": c.get("ar_1__30"),
+            "ar_31_60": c.get("ar_31__60"),
+            "ar_61_90": c.get("ar_61__90"),
+            "ar_91_and_over": c.get("ar_91_and_over"),
+            "ar_total": c.get("ar_total"),
         }
         mapped.append(enrich_supabase_row(base_row))
     return mapped