Added sorting functionality to low level API

Author: kzscisoft

simvue/api/objects/alert/base.py

@@ -8,11 +8,12 @@
 
 import http
 import pydantic
+import datetime
 import typing
 from simvue.api.objects.base import SimvueObject, staging_check, write_only
 from simvue.api.request import get as sv_get, get_json_from_response
 from simvue.api.url import URL
-from simvue.models import NAME_REGEX
+from simvue.models import NAME_REGEX, DATETIME_FORMAT
 
 
 class AlertBase(SimvueObject):
@@ -125,6 +126,20 @@ def abort(self) -> bool:
         """Retrieve if alert can abort simulations"""
         return self._get_attribute("abort")
 
+    @property
+    @staging_check
+    def delay(self) -> int:
+        """Retrieve delay value for this alert"""
+        return self._get_attribute("delay")
+
+    @property
+    def created(self) -> datetime.datetime | None:
+        """Retrieve created datetime for the alert"""
+        _created: str | None = self._get_attribute("created")
+        return (
+            datetime.datetime.strptime(_created, DATETIME_FORMAT) if _created else None
+        )
+
     @abort.setter
     @write_only
     @pydantic.validate_call

simvue/api/objects/alert/fetch.py

@@ -8,10 +8,12 @@
 
 import typing
 import http
+import json
 
 import pydantic
 
 from simvue.api.objects.alert.user import UserAlert
+from simvue.api.objects.base import Sort
 from simvue.api.request import get_json_from_response
 from simvue.api.request import get as sv_get
 from .events import EventsAlert
@@ -21,6 +23,15 @@
 AlertType = EventsAlert | UserAlert | MetricsThresholdAlert | MetricsRangeAlert
 
 
+class AlertSort(Sort):
+    @pydantic.field_validator("column")
+    @classmethod
+    def check_column(cls, column: str) -> str:
+        if column and column not in ("name", "created"):
+            raise ValueError(f"Invalid sort column for alerts '{column}'")
+        return column
+
+
 class Alert:
     """Generic Simvue alert retrieval class"""
 
@@ -50,11 +61,13 @@ def __new__(cls, identifier: str, **kwargs) -> AlertType:
         raise RuntimeError(f"Unknown source type '{_alert_pre.source}'")
 
     @classmethod
+    @pydantic.validate_call
     def get(
         cls,
         offline: bool = False,
         count: int | None = None,
         offset: int | None = None,
+        sorting: list[AlertSort] | None = None,
         **kwargs,
     ) -> typing.Generator[tuple[str, AlertType], None, None]:
         """Fetch all alerts from the server for the current user.
@@ -65,6 +78,8 @@ def get(
             limit the number of results, default of None returns all.
         offset : int, optional
             start index for returned results, default of None starts at 0.
+        sorting : list[dict] | None, optional
+            list of sorting definitions in the form {'column': str, 'descending': bool}
 
         Yields
         ------
@@ -80,11 +95,15 @@ def get(
 
         _class_instance = AlertBase(_local=True, _read_only=True)
         _url = f"{_class_instance._base_url}"
+        _params: dict[str, int | str] = {"start": offset, "count": count}
+
+        if sorting:
+            _params["sorting"] = json.dumps([sort.to_params() for sort in sorting])
 
         _response = sv_get(
             _url,
             headers=_class_instance._headers,
-            params={"start": offset, "count": count} | kwargs,
+            params=_params | kwargs,
         )
 
         _label: str = _class_instance.__class__.__name__.lower()

simvue/api/objects/artifact/fetch.py

@@ -1,17 +1,31 @@
+import http
+import typing
+import pydantic
+import json
+
 from simvue.api.objects.artifact.base import ArtifactBase
+from simvue.api.objects.base import Sort
 from .file import FileArtifact
 from simvue.api.objects.artifact.object import ObjectArtifact
 from simvue.api.request import get_json_from_response, get as sv_get
 from simvue.api.url import URL
 from simvue.exception import ObjectNotFoundError
 
-import http
-import typing
-import pydantic
 
 __all__ = ["Artifact"]
 
 
+class ArtifactSort(Sort):
+    @pydantic.field_validator("column")
+    @classmethod
+    def check_column(cls, column: str) -> str:
+        if column and (
+            column not in ("name", "created") and not column.startswith("metadata.")
+        ):
+            raise ValueError(f"Invalid sort column for artifacts '{column}'")
+        return column
+
+
 class Artifact:
     """Generic Simvue artifact retrieval class"""
 
@@ -119,6 +133,7 @@ def get(
         cls,
         count: int | None = None,
         offset: int | None = None,
+        sorting: list[ArtifactSort] | None = None,
         **kwargs,
     ) -> typing.Generator[tuple[str, FileArtifact | ObjectArtifact], None, None]:
         """Returns artifacts associated with the current user.
@@ -129,6 +144,8 @@ def get(
             limit the number of results, default of None returns all.
         offset : int, optional
             start index for returned results, default of None starts at 0.
+        sorting : list[dict] | None, optional
+            list of sorting definitions in the form {'column': str, 'descending': bool}
 
         Yields
         ------
@@ -139,10 +156,15 @@ def get(
 
         _class_instance = ArtifactBase(_local=True, _read_only=True)
         _url = f"{_class_instance._base_url}"
+        _params = {"start": offset, "count": count}
+
+        if sorting:
+            _params["sorting"] = json.dumps([sort.to_params() for sort in sorting])
+
         _response = sv_get(
             _url,
             headers=_class_instance._headers,
-            params={"start": offset, "count": count} | kwargs,
+            params=_params | kwargs,
         )
         _label: str = _class_instance.__class__.__name__.lower()
         _label = _label.replace("base", "")

simvue/api/objects/base.py

@@ -128,6 +128,14 @@ def tenant(self, tenant: bool) -> None:
         self._update_visibility("tenant", tenant)
 
 
+class Sort(pydantic.BaseModel):
+    column: str
+    descending: bool = True
+
+    def to_params(self) -> dict[str, str]:
+        return {"id": self.column, "desc": self.descending}
+
+
 class SimvueObject(abc.ABC):
     def __init__(
         self,
@@ -323,7 +331,13 @@ def get(
         **kwargs,
     ) -> typing.Generator[tuple[str, T | None], None, None]:
         _class_instance = cls(_read_only=True, _local=True)
-        if (_data := cls._get_all_objects(count, offset, **kwargs).get("data")) is None:
+        if (
+            _data := cls._get_all_objects(
+                count=count,
+                offset=offset,
+                **kwargs,
+            ).get("data")
+        ) is None:
             raise RuntimeError(
                 f"Expected key 'data' for retrieval of {_class_instance.__class__.__name__.lower()}s"
             )
@@ -350,14 +364,19 @@ def count(cls, **kwargs) -> int:
 
     @classmethod
     def _get_all_objects(
-        cls, count: int | None, offset: int | None, **kwargs
+        cls,
+        count: int | None,
+        offset: int | None,
+        **kwargs,
     ) -> dict[str, typing.Any]:
         _class_instance = cls(_read_only=True)
         _url = f"{_class_instance._base_url}"
+        _params: dict[str, int | str] = {"start": offset, "count": count}
+
         _response = sv_get(
             _url,
             headers=_class_instance._headers,
-            params={"start": offset, "count": count} | kwargs,
+            params=_params | kwargs,
         )
 
         _label = _class_instance.__class__.__name__.lower()

simvue/api/objects/events.py

@@ -44,6 +44,7 @@ def get(
         **kwargs,
     ) -> typing.Generator[EventSet, None, None]:
         _class_instance = cls(_read_only=True, _local=True)
+
         if (
             _data := cls._get_all_objects(count, offset, run=run_id, **kwargs).get(
                 "data"

simvue/api/objects/folder.py

@@ -16,9 +16,25 @@
 
 from simvue.exception import ObjectNotFoundError
 
-from .base import SimvueObject, staging_check, write_only
+from .base import SimvueObject, staging_check, write_only, Sort
 from simvue.models import FOLDER_REGEX, DATETIME_FORMAT
 
+# Need to use this inside of Generator typing to fix bug present in Python 3.10 - see issue #745
+T = typing.TypeVar("T", bound="Folder")
+
+
+class FolderSort(Sort):
+    @pydantic.field_validator("column")
+    @classmethod
+    def check_column(cls, column: str) -> str:
+        if (
+            column
+            and column not in ("created", "modified", "path")
+            and not column.startswith("metadata.")
+        ):
+            raise ValueError(f"Invalid sort column for folders '{column}")
+        return column
+
 
 class Folder(SimvueObject):
     """
@@ -60,6 +76,17 @@ def new(
         """Create a new Folder on the Simvue server with the given path"""
         return Folder(path=path, _read_only=False, _offline=offline, **kwargs)
 
+    @classmethod
+    @pydantic.validate_call
+    def get(
+        cls,
+        count: pydantic.PositiveInt | None = None,
+        offset: pydantic.NonNegativeInt | None = None,
+        sorting: list[FolderSort] | None = None,
+        **kwargs,
+    ) -> typing.Generator[tuple[str, T | None], None, None]:
+        return super().get(count=count, offset=offset, sorting=sorting)
+
     @property
     @staging_check
     def tags(self) -> list[str]:

simvue/api/objects/run.py

@@ -12,13 +12,14 @@
 import pydantic
 import datetime
 import time
+import json
 
 try:
     from typing import Self
 except ImportError:
     from typing_extensions import Self
 
-from .base import SimvueObject, staging_check, Visibility, write_only
+from .base import SimvueObject, Sort, staging_check, Visibility, write_only
 from simvue.api.request import (
     get as sv_get,
     put as sv_put,
@@ -31,9 +32,27 @@
     "lost", "failed", "completed", "terminated", "running", "created"
 ]
 
+# Need to use this inside of Generator typing to fix bug present in Python 3.10 - see issue #745
+T = typing.TypeVar("T", bound="Run")
+
 __all__ = ["Run"]
 
 
+class RunSort(Sort):
+    @pydantic.field_validator("column")
+    @classmethod
+    def check_column(cls, column: str) -> str:
+        if (
+            column
+            and column != "name"
+            and not column.startswith("metrics")
+            and not column.startswith("metadata.")
+        ):
+            raise ValueError(f"Invalid sort column for runs '{column}")
+
+        return column
+
+
 class Run(SimvueObject):
     """Class for interacting with/creating runs on the server."""
 
@@ -243,6 +262,39 @@ def get_alert_details(self) -> typing.Generator[dict[str, typing.Any], None, Non
         for alert in self._get_attribute("alerts"):
             yield alert["alert"]
 
+    @classmethod
+    @pydantic.validate_call
+    def get(
+        cls,
+        count: pydantic.PositiveInt | None = None,
+        offset: pydantic.NonNegativeInt | None = None,
+        sorting: list[RunSort] | None = None,
+        **kwargs,
+    ) -> typing.Generator[tuple[str, T | None], None, None]:
+        """Get runs from the server.
+
+        Parameters
+        ----------
+        count : int, optional
+            limit the number of objects returned, default no limit.
+        offset : int, optional
+            start index for results, default is 0.
+        sorting : list[dict] | None, optional
+            list of sorting definitions in the form {'column': str, 'descending': bool}
+
+        Yields
+        ------
+        tuple[str, Run]
+            id of run
+            Run object representing object on server
+        """
+        _params: dict[str, str] = {}
+
+        if sorting:
+            _params["sorting"] = json.dumps([i.to_params() for i in sorting])
+
+        return super().get(count=count, offset=offset, **_params)
+
     @alerts.setter
     @write_only
     @pydantic.validate_call