source-hubspot-native: custom object path components

source-hubspot-native/source_hubspot_native/resources.py

@@ -64,32 +64,39 @@ async def all_resources(
     ]
 
     custom_object_names = await list_custom_objects(log, http)
+    # Some HubSpot endpoints like /v3/properties/{objectType} do not work for every custom object type.
+    # However, these endpoints do work if we prepend a "p_" to the beginning of the custom object name
+    # and use that in the path instead. 
+    # Docs reference: https://developers.hubspot.com/docs/api/crm/crm-custom-objects#retrieve-existing-custom-objects
+    custom_object_path_components = [f"p_{n}" for n in custom_object_names]
 
     custom_object_resources = [
         crm_object_with_associations(
             CustomObject,
             n,
+            custom_object_path_components[index],
             http,
-            functools.partial(fetch_recent_custom_objects, n),
-            functools.partial(fetch_delayed_custom_objects, n),
+            functools.partial(fetch_recent_custom_objects, custom_object_path_components[index]),
+            functools.partial(fetch_delayed_custom_objects, custom_object_path_components[index]),
         )
-        for n in custom_object_names
+        for index, n in enumerate(custom_object_names)
     ]
 
     return [
-        crm_object_with_associations(Company, Names.companies, http, fetch_recent_companies, fetch_delayed_companies),
-        crm_object_with_associations(Contact, Names.contacts, http, fetch_recent_contacts, fetch_delayed_contacts),
-        crm_object_with_associations(Deal, Names.deals, http, fetch_recent_deals, fetch_delayed_deals),
-        crm_object_with_associations(Engagement, Names.engagements, http, fetch_recent_engagements, fetch_delayed_engagements),
-        crm_object_with_associations(Ticket, Names.tickets, http, fetch_recent_tickets, fetch_delayed_tickets),
-        properties(http, itertools.chain(standard_object_names, custom_object_names)),
+        crm_object_with_associations(Company, Names.companies, Names.companies, http, fetch_recent_companies, fetch_delayed_companies),
+        crm_object_with_associations(Contact, Names.contacts, Names.contacts, http, fetch_recent_contacts, fetch_delayed_contacts),
+        crm_object_with_associations(Deal, Names.deals, Names.deals, http, fetch_recent_deals, fetch_delayed_deals),
+        crm_object_with_associations(Engagement, Names.engagements, Names.engagements, http, fetch_recent_engagements, fetch_delayed_engagements),
+        crm_object_with_associations(Ticket, Names.tickets, Names.tickets, http, fetch_recent_tickets, fetch_delayed_tickets),
+        properties(http, itertools.chain(standard_object_names, custom_object_path_components)),
         email_events(http),
         *custom_object_resources,
     ]
 
 def crm_object_with_associations(
     cls: type[CRMObject],
     object_name: str,
+    path_component: str,
     http: HTTPSession,
     fetch_recent: FetchRecentFn,
     fetch_delayed: FetchDelayedFn,
@@ -109,12 +116,12 @@ def open(
             task,
             fetch_changes=functools.partial(
                 process_changes,
-                object_name,
+                path_component,
                 fetch_recent,
                 fetch_delayed,
                 http,
             ),
-            fetch_page=functools.partial(fetch_page_with_associations, cls, http, object_name),
+            fetch_page=functools.partial(fetch_page_with_associations, cls, http, path_component),
         )
 
     started_at = datetime.now(tz=UTC)