fix(cdp): Salesforce destinations url (PostHog#24218)

silentninja · Aug 8, 2024 · abf4341 · abf4341
1 parent aa2227c
commit abf4341
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/posthog/cdp/templates/salesforce/template_salesforce.py b/posthog/cdp/templates/salesforce/template_salesforce.py
@@ -20,11 +20,11 @@
 template_create: HogFunctionTemplate = HogFunctionTemplate(
     status="alpha",
     id="template-salesforce-create",
-    name="Salesforce",
+    name="Create Salesforce objects",
     description="Create objects in Salesforce",
     icon_url="/static/services/salesforce.png",
     hog="""
-let res := fetch(f'https://posthog.my.salesforce.com/services/data/v61.0/sobjects/{inputs.path}', {
+let res := fetch(f'{inputs.oauth.instance_url}/services/data/v61.0/sobjects/{inputs.path}', {
   'body': inputs.properties,
   'method': 'POST',
   'headers': {
@@ -68,11 +68,11 @@
 template_update: HogFunctionTemplate = HogFunctionTemplate(
     status="alpha",
     id="template-salesforce-update",
-    name="Salesforce",
+    name="Update Salesforce objects",
     description="Update objects in Salesforce",
     icon_url="/static/services/salesforce.png",
     hog="""
-let res := fetch(f'https://posthog.my.salesforce.com/services/data/v61.0/sobjects/{inputs.path}', {
+let res := fetch(f'{inputs.oauth.instance_url}/services/data/v61.0/sobjects/{inputs.path}', {
   'body': inputs.properties,
   'method': 'PATCH',
   'headers': {

diff --git a/posthog/cdp/templates/salesforce/test_template_salesforce.py b/posthog/cdp/templates/salesforce/test_template_salesforce.py
@@ -12,6 +12,7 @@ class TestTemplateSalesforceCreate(BaseHogFunctionTemplateTest):
     def _inputs(self, **kwargs):
         inputs = {
             "oauth": {
+                "instance_url": "https://example.my.salesforce.com",
                 "access_token": "oauth-1234",
             },
             "path": "Contact",
@@ -27,7 +28,7 @@ def test_function_works(self):
         self.run_function(self._inputs())
         assert self.get_mock_fetch_calls()[0] == snapshot(
             (
-                "https://posthog.my.salesforce.com/services/data/v61.0/sobjects/Contact",
+                "https://example.my.salesforce.com/services/data/v61.0/sobjects/Contact",
                 {
                     "body": {"foo": "bar"},
                     "method": "POST",
@@ -43,6 +44,7 @@ class TestTemplateSalesforceUpdate(BaseHogFunctionTemplateTest):
     def _inputs(self, **kwargs):
         inputs = {
             "oauth": {
+                "instance_url": "https://example.my.salesforce.com",
                 "access_token": "oauth-1234",
             },
             "path": "Lead/Email/[email protected]",
@@ -58,7 +60,7 @@ def test_function_works(self):
         self.run_function(self._inputs())
         assert self.get_mock_fetch_calls()[0] == snapshot(
             (
-                "https://posthog.my.salesforce.com/services/data/v61.0/sobjects/Lead/Email/[email protected]",
+                "https://example.my.salesforce.com/services/data/v61.0/sobjects/Lead/Email/[email protected]",
                 {
                     "body": {"foo": "bar"},
                     "method": "PATCH",