feat: add version check support (#299)

Adds a new decorator, `@context.requires`, which asserts version
compatibility when the server version is known. The check is skipped if
the server version is unknown (e.g., the Connect configuration disables
version information).

Also marks the OAuth API with a '2024.08.0' requirement.

Closes #272

Author: tdstein

pyproject.toml

@@ -19,7 +19,10 @@ classifiers = [
     "Typing :: Typed",
 ]
 dynamic = ["version"]
-dependencies = ["requests>=2.31.0,<3"]
+dependencies = [
+    "requests>=2.31.0,<3",
+    "packaging"
+]
 
 [project.urls]
 Source = "https://github.com/posit-dev/posit-sdk-py"

requirements.txt

@@ -1 +1,2 @@
 requests==2.32.2
+packaging==24.1

src/posit/connect/client.py

@@ -2,14 +2,15 @@
 
 from __future__ import annotations
 
-from typing import overload
+from typing import Optional, overload
 
 from requests import Response, Session
 
 from . import hooks, me
 from .auth import Auth
 from .config import Config
 from .content import Content
+from .context import Context, ContextManager, requires
 from .groups import Groups
 from .metrics import Metrics
 from .oauth import OAuth
@@ -18,7 +19,7 @@
 from .users import User, Users
 
 
-class Client:
+class Client(ContextManager):
     """
     Client connection for Posit Connect.
 
@@ -156,9 +157,10 @@ def __init__(self, *args, **kwargs) -> None:
         session.hooks["response"].append(hooks.handle_errors)
         self.session = session
         self.resource_params = ResourceParameters(session, self.cfg.url)
+        self.ctx = Context(self.session, self.cfg.url)
 
     @property
-    def version(self) -> str:
+    def version(self) -> Optional[str]:
         """
         The server version.
 
@@ -167,7 +169,7 @@ def version(self) -> str:
         str
             The version of the Posit Connect server.
         """
-        return self.get("server_settings").json()["version"]
+        return self.ctx.version
 
     @property
     def me(self) -> User:
@@ -257,6 +259,7 @@ def metrics(self) -> Metrics:
         return Metrics(self.resource_params)
 
     @property
+    @requires(version="2024.08.0")
     def oauth(self) -> OAuth:
         """
         The OAuth API interface.

src/posit/connect/context.py

@@ -0,0 +1,45 @@
+import functools
+from typing import Optional, Protocol
+
+from packaging.version import Version
+
+
+def requires(version: str):
+    def decorator(func):
+        @functools.wraps(func)
+        def wrapper(instance: ContextManager, *args, **kwargs):
+            ctx = instance.ctx
+            if ctx.version and Version(ctx.version) < Version(version):
+                raise RuntimeError(
+                    f"This API is not available in Connect version {ctx.version}. Please upgrade to version {version} or later.",
+                )
+            return func(instance, *args, **kwargs)
+
+        return wrapper
+
+    return decorator
+
+
+class Context(dict):
+    def __init__(self, session, url):
+        self.session = session
+        self.url = url
+
+    @property
+    def version(self) -> Optional[str]:
+        try:
+            value = self["version"]
+        except KeyError:
+            endpoint = self.url + "server_settings"
+            response = self.session.get(endpoint)
+            result = response.json()
+            value = self["version"] = result.get("version")
+        return value
+
+    @version.setter
+    def version(self, value: str):
+        self["version"] = value
+
+
+class ContextManager(Protocol):
+    ctx: Context

tests/posit/connect/external/test_databricks.py

@@ -48,6 +48,7 @@ def test_posit_credentials_provider(self):
         register_mocks()
 
         client = Client(api_key="12345", url="https://connect.example/")
+        client.ctx.version = None
         cp = PositCredentialsProvider(client=client, user_session_token="cit")
         assert cp() == {"Authorization": f"Bearer dynamic-viewer-access-token"}
 
@@ -57,6 +58,7 @@ def test_posit_credentials_strategy(self):
         register_mocks()
 
         client = Client(api_key="12345", url="https://connect.example/")
+        client.ctx.version = None
         cs = PositCredentialsStrategy(
             local_strategy=mock_strategy(),
             user_session_token="cit",

tests/posit/connect/external/test_snowflake.py

@@ -33,6 +33,7 @@ def test_posit_authenticator(self):
         register_mocks()
 
         client = Client(api_key="12345", url="https://connect.example/")
+        client.ctx.version = None
         auth = PositAuthenticator(
             local_authenticator="SNOWFLAKE",
             user_session_token="cit",
@@ -44,6 +45,7 @@ def test_posit_authenticator(self):
     def test_posit_authenticator_fallback(self):
         # local_authenticator is used when the content is running locally
         client = Client(api_key="12345", url="https://connect.example/")
+        client.ctx.version = None
         auth = PositAuthenticator(
             local_authenticator="SNOWFLAKE",
             user_session_token="cit",

tests/posit/connect/oauth/test_associations.py

@@ -55,6 +55,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
         # invoke
         associations = c.oauth.integrations.get(guid).associations.find()
 
@@ -83,6 +84,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
         # invoke
         associations = c.content.get(guid).oauth.associations.find()
 
@@ -115,6 +117,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
 
         # invoke
         c.content.get(guid).oauth.associations.update(new_integration_guid)
@@ -142,6 +145,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
 
         # invoke
         c.content.get(guid).oauth.associations.delete()

tests/posit/connect/oauth/test_integrations.py

@@ -73,6 +73,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
         integration = c.oauth.integrations.get(guid)
 
         # invoke
@@ -93,6 +94,7 @@ def test(self):
         )
 
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
         integration = c.oauth.integrations.get(guid)
         assert integration.guid == guid
 
@@ -137,6 +139,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
 
         # invoke
         integration = c.oauth.integrations.create(
@@ -164,10 +167,11 @@ def test(self):
         )
 
         # setup
-        client = Client("https://connect.example", "12345")
+        c = Client("https://connect.example", "12345")
+        c.ctx.version = None
 
         # invoke
-        integrations = client.oauth.integrations.find()
+        integrations = c.oauth.integrations.find()
 
         # assert
         assert mock_get.call_count == 1
@@ -189,6 +193,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
         integration = c.oauth.integrations.get(guid)
 
         assert mock_get.call_count == 1

tests/posit/connect/oauth/test_oauth.py

@@ -23,5 +23,6 @@ def test_get_credentials(self):
                 "token_type": "Bearer",
             },
         )
-        con = Client(api_key="12345", url="https://connect.example/")
-        assert con.oauth.get_credentials("cit")["access_token"] == "viewer-token"
+        c = Client(api_key="12345", url="https://connect.example/")
+        c.ctx.version = None
+        assert c.oauth.get_credentials("cit")["access_token"] == "viewer-token"

tests/posit/connect/oauth/test_sessions.py

@@ -53,6 +53,7 @@ def test(self):
 
         # setup
         c = Client("https://connect.example", "12345")
+        c.ctx.version = None
         session = c.oauth.sessions.get(guid)
 
         # invoke
@@ -72,10 +73,11 @@ def test(self):
         )
 
         # setup
-        client = Client("https://connect.example", "12345")
+        c = Client("https://connect.example", "12345")
+        c.ctx.version = None
 
         # invoke
-        sessions = client.oauth.sessions.find()
+        sessions = c.oauth.sessions.find()
 
         # assert
         assert mock_get.call_count == 1
@@ -94,10 +96,11 @@ def test_params_all(self):
         )
 
         # setup
-        client = Client("https://connect.example", "12345")
+        c = Client("https://connect.example", "12345")
+        c.ctx.version = None
 
         # invoke
-        client.oauth.sessions.find(all=True)
+        c.oauth.sessions.find(all=True)
 
         # assert
         assert mock_get.call_count == 1
@@ -115,10 +118,11 @@ def test(self):
         )
 
         # setup
-        client = Client("https://connect.example", "12345")
+        c = Client("https://connect.example", "12345")
+        c.ctx.version = None
 
         # invoke
-        session = client.oauth.sessions.get(guid=guid)
+        session = c.oauth.sessions.get(guid=guid)
 
         # assert
         assert mock_get.call_count == 1