Add new properties to deals, tickes and companies

python/hubspot_companies.py

@@ -90,6 +90,7 @@ COMPANY_PROPERTIES = [
     "hs_analytics_source",
     "hs_analytics_latest_source",
     "hs_object_source_detail_1",
+    "average_deal_closed_days",
 ]
 
 # -----------------------------------------------------------------------------
@@ -375,6 +376,7 @@ def map_company_data_for_db(companies: 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_analytics_latest_source"),
+            "average_deal_closed_days": try_parse_int(c.get("average_deal_closed_days")),
         }
         mapped.append(enrich_supabase_row(base_row))
     return mapped

python/hubspot_deals.py

@@ -71,7 +71,8 @@ DEAL_PROPERTIES = [
     "hs_object_source_label",
     "hs_object_source_detail_1",
     "dealtype",
-    "hs_lastmodifieddate",   # for mapping/debugging
+    "days_to_close",
+    "hs_lastmodifieddate",
     "lastmodifieddate",
 ]
 
@@ -335,6 +336,7 @@ def read_deals_by_ids(
                 "record_source": p.get("hs_object_source_label"),
                 "record_source_detail_1": p.get("hs_object_source_detail_1"),
                 "dealtype": p.get("dealtype"),
+                "days_to_close": try_parse_int(p.get("days_to_close")),
                 "company_id": company_id,
             })
 

python/hubspot_tickets.py

@@ -28,7 +28,7 @@ from supabase import create_client
 from hubspot.crm.tickets import ApiException as TicketsApiException
 
 from hubspot_utils import (
-    parse_ts, try_parse_int, deduplicate_by_key,
+    parse_ts, try_parse_int, try_parse_float, deduplicate_by_key,
 )
 from supabase_utils import (
     batched_insert, update_sync_metadata,
@@ -85,6 +85,10 @@ TICKET_PROPERTIES = [
     "source_type",
     "hs_object_source_label",
     "hs_object_source_detail_1",
+    "hs_is_closed",
+    "last_sales_reply",
+    "time_to_first_agent_reply",
+    "time_to_close",
 ]
 
 # -----------------------------------------------------------------------------
@@ -284,6 +288,16 @@ def read_tickets_by_ids(
             if ts_ms is not None and (max_ts_ms is None or ts_ms > max_ts_ms):
                 max_ts_ms = ts_ms
 
+            if try_parse_float(p.get("time_to_first_agent_reply")) is None:
+                time_to_first_agent_reply = None
+            else:  
+                time_to_first_agent_reply = try_parse_float(p.get("time_to_first_agent_reply")) / 1000
+
+            if try_parse_float(p.get("time_to_close")) is None:
+                time_to_close = None
+            else:
+                time_to_close = try_parse_float(p.get("time_to_close")) / 1000
+
             tickets.append({
                 "ticket_id": try_parse_int(record.id),
                 "subject": p.get("subject"),
@@ -299,6 +313,10 @@ def read_tickets_by_ids(
                 "source": p.get("source_type"),
                 "record_source": p.get("hs_object_source_label"),
                 "record_source_detail_1": p.get("hs_object_source_detail_1"),
+                "is_closed": p.get("hs_is_closed"),
+                "last_sales_reply": p.get("last_sales_reply"),
+                "time_to_first_agent_reply": time_to_first_agent_reply,
+                "time_to_close": time_to_close,
                 "hubspot_owner_id": try_parse_int(p.get("hubspot_owner_id")),
                 "hubspot_created_at": parse_ts(p.get("createdate")),
                 "hubspot_created_by": try_parse_int(p.get("hs_created_by_user_id")),