Add mode to configuration and remove offline server check

Author: kzscisoft

CHANGELOG.md

@@ -1,10 +1,14 @@
 # Change log
 
-## Unreleased
+## [v1.1.3](https://github.com/simvue-io/client/releases/tag/v1.1.3) - 2024-12-09
+
 * Fixed bug with `requirements.txt` metadata read.
+* Added Simvue server version check.
+
 ## [v1.1.2](https://github.com/simvue-io/client/releases/tag/v1.1.2) - 2024-11-06
 
 * Fix bug in offline mode directory retrieval.
+
 ## [v1.1.1](https://github.com/simvue-io/client/releases/tag/v1.1.1) - 2024-10-22
 
 * Add missing `offline.cache` key to TOML config.

poetry.lock

@@ -55,6 +55,7 @@ humanfriendly = "^10.0"
 tabulate = "^0.9.0"
 randomname = "^0.2.1"
 codecarbon = "^2.7.1"
+semver = "^3.0.2"
 
 [tool.poetry.extras]
 plot = ["matplotlib", "plotly"]

pyproject.toml

@@ -7,18 +7,13 @@
 """
 
 import logging
-import os
 import time
 import pydantic
 import typing
 import pathlib
-import http
-import functools
 
 import simvue.models as sv_models
 from simvue.utilities import get_expiry
-from simvue.version import __version__
-from simvue.api import get
 
 
 logger = logging.getLogger(__file__)
@@ -42,37 +37,6 @@ def check_token(cls, v: typing.Any) -> str:
             raise AssertionError("Simvue token has expired")
         return value
 
-    @classmethod
-    @functools.lru_cache
-    def _check_server(cls, token: str, url: str) -> None:
-        headers: dict[str, str] = {
-            "Authorization": f"Bearer {token}",
-            "User-Agent": f"Simvue Python client {__version__}",
-        }
-        try:
-            response = get(f"{url}/api/version", headers)
-
-            if response.status_code != http.HTTPStatus.OK or not response.json().get(
-                "version"
-            ):
-                raise AssertionError
-
-            if response.status_code == http.HTTPStatus.UNAUTHORIZED:
-                raise AssertionError("Unauthorised token")
-
-        except Exception as err:
-            raise AssertionError(f"Exception retrieving server version: {str(err)}")
-
-    @pydantic.model_validator(mode="after")
-    @classmethod
-    def check_valid_server(cls, values: "ServerSpecifications") -> bool:
-        if os.environ.get("SIMVUE_NO_SERVER_CHECK"):
-            return values
-
-        cls._check_server(values.token, values.url)
-
-        return values
-
 
 class OfflineSpecifications(pydantic.BaseModel):
     cache: typing.Optional[pathlib.Path] = None
@@ -89,6 +53,7 @@ class DefaultRunSpecifications(pydantic.BaseModel):
     tags: typing.Optional[list[str]] = None
     folder: str = pydantic.Field("/", pattern=sv_models.FOLDER_REGEX)
     metadata: typing.Optional[dict[str, typing.Union[str, int, float, bool]]] = None
+    mode: typing.Literal["offline", "disabled", "online"] = "online"
 
 
 class ClientGeneralOptions(pydantic.BaseModel):

simvue/config/parameters.py

@@ -14,9 +14,10 @@
 import configparser
 import contextlib
 import warnings
-
+import http
 import pydantic
 import toml
+import semver
 
 import simvue.utilities as sv_util
 from simvue.config.parameters import (
@@ -31,9 +32,16 @@
     CONFIG_INI_FILE_NAMES,
     DEFAULT_OFFLINE_DIRECTORY,
 )
+from simvue.version import __version__
+from simvue.api import get
 
 logger = logging.getLogger(__name__)
 
+SIMVUE_SERVER_UPPER_CONSTRAINT: typing.Optional[semver.Version] = semver.Version.parse(
+    "2.0.0"
+)
+SIMVUE_SERVER_LOWER_CONSTRAINT: typing.Optional[semver.Version] = None
+
 
 class SimvueConfiguration(pydantic.BaseModel):
     # Hide values as they contain token and URL
@@ -70,12 +78,65 @@ def _parse_ini_config(cls, ini_file: pathlib.Path) -> dict[str, dict[str, str]]:
 
         return config_dict
 
+    @classmethod
+    @functools.lru_cache
+    def _check_server(
+        cls, token: str, url: str, mode: typing.Literal["offline", "online", "disabled"]
+    ) -> None:
+        if mode in ("offline", "disabled"):
+            return
+
+        headers: dict[str, str] = {
+            "Authorization": f"Bearer {token}",
+            "User-Agent": f"Simvue Python client {__version__}",
+        }
+        try:
+            response = get(f"{url}/api/version", headers)
+
+            if response.status_code != http.HTTPStatus.OK or not (
+                _version_str := response.json().get("version")
+            ):
+                raise AssertionError
+
+            if response.status_code == http.HTTPStatus.UNAUTHORIZED:
+                raise AssertionError("Unauthorised token")
+
+        except Exception as err:
+            raise AssertionError(f"Exception retrieving server version: {str(err)}")
+
+        _version = semver.Version.parse(_version_str)
+
+        if (
+            SIMVUE_SERVER_UPPER_CONSTRAINT
+            and _version >= SIMVUE_SERVER_UPPER_CONSTRAINT
+        ):
+            raise AssertionError(
+                f"Python API v{_version_str} is not compatible with Simvue server versions "
+                f">= {SIMVUE_SERVER_UPPER_CONSTRAINT}"
+            )
+        if SIMVUE_SERVER_LOWER_CONSTRAINT and _version < SIMVUE_SERVER_LOWER_CONSTRAINT:
+            raise AssertionError(
+                f"Python API v{_version_str} is not compatible with Simvue server versions "
+                f"< {SIMVUE_SERVER_LOWER_CONSTRAINT}"
+            )
+
+    @pydantic.model_validator(mode="after")
+    @classmethod
+    def check_valid_server(cls, values: "SimvueConfiguration") -> bool:
+        if os.environ.get("SIMVUE_NO_SERVER_CHECK"):
+            return values
+
+        cls._check_server(values.server.token, values.server.url, values.server.mode)
+
+        return values
+
     @classmethod
     @sv_util.prettify_pydantic
     def fetch(
         cls,
         server_url: typing.Optional[str] = None,
         server_token: typing.Optional[str] = None,
+        mode: typing.Literal["offline", "online", "disabled"] = "online",
     ) -> "SimvueConfiguration":
         """Retrieve the Simvue configuration from this project
 
@@ -88,6 +149,8 @@ def fetch(
             override the URL used for this session
         server_token : str, optional
             override the token used for this session
+        mode : 'online' | 'offline' | 'disabled'
+            set the run mode for this session
 
         Return
         ------
@@ -115,6 +178,8 @@ def fetch(
 
         _config_dict["offline"] = _config_dict.get("offline", {})
 
+        _config_dict["run"] = _config_dict.get("run", {})
+
         # Allow override of specification of offline directory via environment variable
         if not (_default_dir := os.environ.get("SIMVUE_OFFLINE_DIRECTORY")):
             _default_dir = _config_dict["offline"].get(
@@ -134,6 +199,8 @@ def fetch(
             "SIMVUE_TOKEN", server_token or _config_dict["server"].get("token")
         )
 
+        _run_mode = mode or _config_dict["run"].get("mode")
+
         if not _server_url:
             raise RuntimeError("No server URL was specified")
 
@@ -142,6 +209,7 @@ def fetch(
 
         _config_dict["server"]["token"] = _server_token
         _config_dict["server"]["url"] = _server_url
+        _config_dict["run"]["mode"] = _run_mode
 
         return SimvueConfiguration(**_config_dict)
 

simvue/config/user.py

@@ -159,7 +159,9 @@ def __init__(
         self._data: dict[str, typing.Any] = {}
         self._step: int = 0
         self._active: bool = False
-        self._user_config = SimvueConfiguration.fetch()
+        self._user_config = SimvueConfiguration.fetch(
+            server_url=server_url, server_token=server_token, mode=mode
+        )
 
         logging.getLogger(self.__class__.__module__).setLevel(
             logging.DEBUG