Fixed CI, Removed unused files, Cleaned test.flow.yaml, Added salesfo…

…rce to the new CDK

.github/workflows/python.yaml

@@ -53,6 +53,7 @@ jobs:
           - name: source-salesforce
             type: capture
             version: v2
+            usage_rate: "1.0"
 
     steps:
       - uses: actions/checkout@v4

source-salesforce/pyproject.toml

@@ -7,7 +7,7 @@ readme = "README.md"
 
 [tool.poetry.dependencies]
 python = ">=3.11,<3.12"
-flow-sdk = {path="../python", develop=true}
+estuary-cdk = {path="../estuary-cdk", develop = true}
 airbyte-cdk = "0.51.14"
 backoff = "^1.11"
 pendulum = "^3.0.0"

source-salesforce/source_salesforce/main.py

@@ -0,0 +1,28 @@
+import estuary_cdk.pydantic_polyfill  # Must be first.
+
+import asyncio
+import urllib
+from estuary_cdk import shim_airbyte_cdk, flow
+from source_hubspot import SourceHubspot
+
+asyncio.run(
+    shim_airbyte_cdk.CaptureShim(
+        delegate=SourceSalesforce(),
+        oauth2={
+        "provider": "salesforce",
+        "authUrlTemplate": (
+        r"https://{{#config.is_sandbox}}test{{/config.is_sandbox}}{{^config.is_sandbox}}login{{/config.is_sandbox}}.salesforce.com/services/oauth2/authorize?client_id={{#urlencode}}{{{ client_id }}}{{/urlencode}}&redirect_uri={{#urlencode}}{{{ redirect_uri }}}{{/urlencode}}&response_type=code&state={{#urlencode}}{{{ state }}}{{/urlencode}}"
+        ),
+        "accessTokenUrlTemplate": r"https://{{#config.is_sandbox}}test{{/config.is_sandbox}}{{^config.is_sandbox}}login{{/config.is_sandbox}}.salesforce.com/services/oauth2/token",
+        "accessTokenBody": (
+        "grant_type=authorization_code"
+        r"&client_id={{#urlencode}}{{{ client_id }}}{{/urlencode}}"
+        r"&client_secret={{#urlencode}}{{{ client_secret }}}{{/urlencode}}"
+        r"&redirect_uri={{#urlencode}}{{{ redirect_uri }}}{{/urlencode}}&code={{#urlencode}}{{{ code }}}{{/urlencode}}"
+        ),
+        "accessTokenHeaders": {"content-type": "application/x-www-form-urlencoded"},
+        "accessTokenResponseMap": {"refresh_token": "/refresh_token"}
+    },
+        usesSchemaInference=False,
+).serve()
+)