source-airtable: upgrade to estuary-cdk

.github/workflows/ci.yaml

@@ -118,9 +118,6 @@ jobs:
           - connector: source-shopify
             connector_type: capture
             python: true
-          - connector: source-airtable
-            connector_type: capture
-            python: true
           - connector: source-facebook-marketing
             connector_type: capture
             python: true

.github/workflows/python.yaml

@@ -5,6 +5,7 @@ on:
     branches: [main]
     paths:
       - "estuary-cdk/**"
+      - "source-airtable/**"
       - "source-asana/**"
       - "source-gladly/**"
       - "source-google-ads/**"
@@ -14,6 +15,7 @@ on:
     branches: [main]
     paths:
       - "estuary-cdk/**"
+      - "source-airtable/**"
       - "source-asana/**"
       - "source-gladly/**"
       - "source-google-ads/**"
@@ -31,6 +33,9 @@ jobs:
       fail-fast: false
       matrix:
         connector:
+          - name: source-airtable
+            type: capture
+            version: v1
           - name: source-asana
             type: capture
             version: v1

source-airtable/pyproject.toml

@@ -1,20 +1,21 @@
 [tool.poetry]
-name = "source-airtable-estuary"
+name = "source_airtable"
 version = "0.1.0"
 description = ""
 authors = ["Joseph Shearer <joseph@estuary.dev>"]
 
 [tool.poetry.dependencies]
-airbyte-cdk = "0.51.14"
-mypy = "^1.5"
-python = ">=3.11,<3.12"
-debugpy = "^1.8.0"
-source_airtable = { path = "source_airtable", develop=true }
-flow-sdk = {path="../python", develop=true}
+airbyte-cdk = "^0.52"
+estuary-cdk = {path="../estuary-cdk", develop = true}
+python = "^3.11"
+types-requests = "^2.31"
 
 [tool.poetry.group.dev.dependencies]
+debugpy = "^1.8.0"
+mypy = "^1.8.0"
 pytest = "^7.4.3"
-pytest-insta = "^0.2.0"
+pytest-insta = "^0.3.0"
+requests-mock = "^1.11.0"
 
 [build-system]
 requires = ["poetry-core"]

source-airtable/source_airtable/__main__.py

@@ -0,0 +1,27 @@
+import estuary_cdk.pydantic_polyfill  # Must be first.
+
+import asyncio
+from estuary_cdk import shim_airbyte_cdk, flow
+from source_airtable import SourceAirtable
+
+asyncio.run(
+    shim_airbyte_cdk.CaptureShim(
+        delegate=SourceAirtable(),
+        oauth2=flow.OAuth2Spec(
+            provider="airtable",
+            accessTokenBody=r"grant_type=authorization_code&client_id={{#urlencode}}{{{ client_id }}}{{/urlencode}}&client_secret={{#urlencode}}{{{ client_secret }}}{{/urlencode}}&redirect_uri={{#urlencode}}{{{ redirect_uri }}}{{/urlencode}}&code={{#urlencode}}{{{ code }}}{{/urlencode}}&code_verifier={{#urlencode}}{{{ code_verifier }}}{{/urlencode}}",
+            authUrlTemplate="https://airtable.com/oauth2/v1/authorize?client_id={{#urlencode}}{{{ client_id }}}{{/urlencode}}&redirect_uri={{#urlencode}}{{{ redirect_uri }}}{{/urlencode}}&response_type=code&state={{#urlencode}}{{{ state }}}{{/urlencode}}&scope=data.records:read%20data.recordComments:read%20schema.bases:read&code_challenge={{#urlencode}}{{{ code_challenge }}}{{/urlencode}}&code_challenge_method={{{ code_challenge_method }}}",
+            accessTokenHeaders={
+                "content-type": "application/x-www-form-urlencoded",
+                "authorization": "Basic {{#basicauth}}{{{ client_id }}}:{{{client_secret }}}{{/basicauth}}",
+            },
+            accessTokenResponseMap={
+                "access_token": "/access_token",
+                "refresh_token": "/refresh_token",
+                "token_expiry_date": r"{{#now_plus}}{{ expires_in }}{{/now_plus}}",
+            },
+            accessTokenUrlTemplate="https://airtable.com/oauth2/v1/token",
+        ),
+        schema_inference=True,
+    ).serve()
+)