replaced ui engine

Author: Andrei Neagu

.env-devel

@@ -19,6 +19,7 @@ AGENT_VOLUMES_CLEANUP_S3_REGION=us-east-1
 AGENT_VOLUMES_CLEANUP_S3_SECRET_KEY=12345678
 AGENT_TRACING={}
 
+
 API_SERVER_DEV_FEATURES_ENABLED=0
 API_SERVER_LOGLEVEL=INFO
 API_SERVER_PROFILING=1
@@ -128,6 +129,7 @@ DYNAMIC_SCHEDULER_LOGLEVEL=DEBUG
 DYNAMIC_SCHEDULER_PROFILING=1
 DYNAMIC_SCHEDULER_STOP_SERVICE_TIMEOUT=01:00:00
 DYNAMIC_SCHEDULER_TRACING={}
+DYNAMIC_SCHEDULER_UI_STORAGE_SECRET=c411085b-a75e-4a38-aa37-f085c91c3371
 
 FUNCTION_SERVICES_AUTHORS='{"UN": {"name": "Unknown", "email": "[email protected]", "affiliation": "unknown"}}'
 

services/docker-compose.yml

@@ -567,6 +567,7 @@ services:
       DYNAMIC_SCHEDULER_STOP_SERVICE_TIMEOUT: ${DYNAMIC_SCHEDULER_STOP_SERVICE_TIMEOUT}
       DYNAMIC_SCHEDULER_PROFILING: ${DYNAMIC_SCHEDULER_PROFILING}
       DYNAMIC_SCHEDULER_TRACING: ${DYNAMIC_SCHEDULER_TRACING}
+      DYNAMIC_SCHEDULER_UI_STORAGE_SECRET: ${DYNAMIC_SCHEDULER_UI_STORAGE_SECRET}
       TRACING_OPENTELEMETRY_COLLECTOR_ENDPOINT: ${TRACING_OPENTELEMETRY_COLLECTOR_ENDPOINT}
       TRACING_OPENTELEMETRY_COLLECTOR_PORT: ${TRACING_OPENTELEMETRY_COLLECTOR_PORT}
   static-webserver:

services/dynamic-scheduler/requirements/_base.in

@@ -17,8 +17,8 @@
 
 arrow
 fastapi
-fastui
 httpx
+nicegui
 packaging
 python-socketio
 typer[all]

services/dynamic-scheduler/requirements/_base.txt

@@ -7,7 +7,9 @@ aiodebug==2.3.0
 aiodocker==0.23.0
     # via -r requirements/../../../packages/service-library/requirements/_base.in
 aiofiles==24.1.0
-    # via -r requirements/../../../packages/service-library/requirements/_base.in
+    # via
+    #   -r requirements/../../../packages/service-library/requirements/_base.in
+    #   nicegui
 aiohappyeyeballs==2.4.3
     # via aiohttp
 aiohttp==3.10.10
@@ -27,6 +29,8 @@ aiohttp==3.10.10
     #   -c requirements/../../../packages/settings-library/requirements/../../../requirements/constraints.txt
     #   -c requirements/../../../requirements/constraints.txt
     #   aiodocker
+    #   nicegui
+    #   python-socketio
 aiormq==6.8.1
     # via aio-pika
 aiosignal==1.3.1
@@ -79,6 +83,7 @@ certifi==2024.8.30
     #   -c requirements/../../../requirements/constraints.txt
     #   httpcore
     #   httpx
+    #   nicegui
     #   requests
 charset-normalizer==3.4.0
     # via requests
@@ -94,6 +99,8 @@ deprecated==1.2.14
     #   opentelemetry-semantic-conventions
 dnspython==2.7.0
     # via email-validator
+docutils==0.21.2
+    # via nicegui
 email-validator==2.2.0
     # via pydantic
 fast-depends==2.4.12
@@ -102,10 +109,9 @@ fastapi==0.115.5
     # via
     #   -r requirements/../../../packages/service-library/requirements/_fastapi.in
     #   -r requirements/_base.in
+    #   nicegui
 faststream==0.5.28
     # via -r requirements/../../../packages/service-library/requirements/_base.in
-fastui==0.7.0
-    # via -r requirements/_base.in
 frozenlist==1.4.1
     # via
     #   aiohttp
@@ -145,15 +151,37 @@ httpx==0.27.2
     #   -c requirements/../../../requirements/constraints.txt
     #   -r requirements/../../../packages/service-library/requirements/_fastapi.in
     #   -r requirements/_base.in
+    #   nicegui
 idna==3.10
     # via
     #   anyio
     #   email-validator
     #   httpx
     #   requests
     #   yarl
+ifaddr==0.2.0
+    # via nicegui
 importlib-metadata==8.4.0
     # via opentelemetry-api
+itsdangerous==2.2.0
+    # via nicegui
+jinja2==3.1.4
+    # via
+    #   -c requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/models-library/requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/models-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/postgres-database/requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/postgres-database/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/service-library/requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/service-library/requirements/../../../packages/models-library/requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/service-library/requirements/../../../packages/models-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/service-library/requirements/../../../packages/settings-library/requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/service-library/requirements/../../../packages/settings-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/service-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/settings-library/requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../packages/settings-library/requirements/../../../requirements/constraints.txt
+    #   -c requirements/../../../requirements/constraints.txt
+    #   nicegui
 jsonschema==4.23.0
     # via
     #   -r requirements/../../../packages/models-library/requirements/_base.in
@@ -179,14 +207,20 @@ mako==1.3.5
     #   alembic
 markdown-it-py==3.0.0
     # via rich
+markdown2==2.5.1
+    # via nicegui
 markupsafe==3.0.1
-    # via mako
+    # via
+    #   jinja2
+    #   mako
 mdurl==0.1.2
     # via markdown-it-py
 multidict==6.1.0
     # via
     #   aiohttp
     #   yarl
+nicegui==2.7.0
+    # via -r requirements/_base.in
 opentelemetry-api==1.27.0
     # via
     #   -r requirements/../../../packages/service-library/requirements/_base.in
@@ -281,6 +315,7 @@ orjson==3.10.7
     #   -r requirements/../../../packages/service-library/requirements/../../../packages/models-library/requirements/_base.in
     #   -r requirements/../../../packages/service-library/requirements/../../../packages/settings-library/requirements/../../../packages/common-library/requirements/_base.in
     #   -r requirements/../../../packages/settings-library/requirements/../../../packages/common-library/requirements/_base.in
+    #   nicegui
 packaging==24.1
     # via -r requirements/_base.in
 pamqp==3.3.0
@@ -297,6 +332,8 @@ protobuf==4.25.5
     # via
     #   googleapis-common-protos
     #   opentelemetry-proto
+pscript==0.7.7
+    # via vbuild
 psutil==6.0.0
     # via -r requirements/../../../packages/service-library/requirements/_base.in
 psycopg2-binary==2.9.10
@@ -332,7 +369,6 @@ pydantic==2.9.2
     #   -r requirements/../../../packages/settings-library/requirements/_base.in
     #   fast-depends
     #   fastapi
-    #   fastui
     #   pydantic-extra-types
     #   pydantic-settings
 pydantic-core==2.23.4
@@ -355,7 +391,9 @@ pydantic-settings==2.6.1
     #   -r requirements/../../../packages/service-library/requirements/../../../packages/settings-library/requirements/_base.in
     #   -r requirements/../../../packages/settings-library/requirements/_base.in
 pygments==2.18.0
-    # via rich
+    # via
+    #   nicegui
+    #   rich
 pyinstrument==5.0.0
     # via -r requirements/../../../packages/service-library/requirements/_base.in
 python-dateutil==2.9.0.post0
@@ -366,8 +404,12 @@ python-dotenv==1.0.1
     #   uvicorn
 python-engineio==4.10.1
     # via python-socketio
+python-multipart==0.0.17
+    # via nicegui
 python-socketio==5.11.4
-    # via -r requirements/_base.in
+    # via
+    #   -r requirements/_base.in
+    #   nicegui
 pyyaml==6.0.2
     # via
     #   -c requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
@@ -411,7 +453,9 @@ referencing==0.29.3
 repro-zipfile==0.3.1
     # via -r requirements/../../../packages/service-library/requirements/_base.in
 requests==2.32.3
-    # via opentelemetry-exporter-otlp-proto-http
+    # via
+    #   nicegui
+    #   opentelemetry-exporter-otlp-proto-http
 rich==13.9.2
     # via
     #   -r requirements/../../../packages/service-library/requirements/../../../packages/settings-library/requirements/_base.in
@@ -488,6 +532,7 @@ typing-extensions==4.12.2
     #   alembic
     #   fastapi
     #   faststream
+    #   nicegui
     #   opentelemetry-sdk
     #   pydantic
     #   pydantic-core
@@ -510,15 +555,21 @@ urllib3==2.2.3
     #   -c requirements/../../../packages/settings-library/requirements/../../../packages/common-library/requirements/../../../requirements/constraints.txt
     #   -c requirements/../../../packages/settings-library/requirements/../../../requirements/constraints.txt
     #   -c requirements/../../../requirements/constraints.txt
+    #   nicegui
     #   requests
 uvicorn==0.32.0
     # via
     #   -r requirements/../../../packages/service-library/requirements/_fastapi.in
     #   -r requirements/_base.in
+    #   nicegui
 uvloop==0.21.0
     # via uvicorn
+vbuild==0.8.2
+    # via nicegui
 watchfiles==0.24.0
-    # via uvicorn
+    # via
+    #   nicegui
+    #   uvicorn
 websockets==13.1
     # via uvicorn
 wrapt==1.16.0

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/api/frontend/__init__.py

@@ -0,0 +1,3 @@
+from ._setup import setup_frontend
+
+__all__: tuple[str, ...] = ("setup_frontend",)

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/api/frontend/_common.py

@@ -0,0 +1,21 @@
+from collections.abc import Iterator
+from contextlib import contextmanager
+
+from nicegui import ui
+
+
+@contextmanager
+def base_page(*, title: str | None = None, colour: str = "#D3D3D3") -> Iterator[None]:
+    display_title = (
+        "Dynamic Scheduler" if title is None else f"Dynamic Scheduler - {title}"
+    )
+    ui.page_title(display_title)
+    with ui.header(elevated=True).style(f"background-color: {colour}").classes(
+        "items-center justify-between"
+    ):
+        ui.label("HEADER")
+
+    yield None
+
+    with ui.footer().style(f"background-color: {colour}"):
+        ui.label("FOOTER")

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/api/frontend/_index.py

@@ -0,0 +1,48 @@
+from fastapi import FastAPI
+from models_library.projects_nodes_io import NodeID
+from nicegui import APIRouter, app, ui
+from nicegui.element import Element
+
+from ...services.service_tracker import TrackedServiceModel, get_all_tracked_services
+from ._common import base_page
+from ._utils import get_parent_app
+
+router = APIRouter()
+
+
+def _render_card(
+    card_container: Element, node_id: NodeID, service: TrackedServiceModel
+) -> None:
+    with card_container:  # noqa: SIM117
+        with ui.card():
+            ui.label(f"{node_id}")
+            # TODO finish card
+            ui.label(service.model_dump_json())
+
+
+async def _update_cards(parent_app: FastAPI, card_container) -> None:
+    card_container.clear()  # Clear the current cards
+
+    tracked_services = await get_all_tracked_services(parent_app)
+
+    for node_id, service in tracked_services.items():
+        _render_card(card_container, node_id, service)
+
+
+# changed this form ui to router
+@router.page("/")
+async def main_page():
+    parent_app = get_parent_app(app)
+
+    with base_page():
+
+        # Initial UI setup
+        ui.label("Dynamic Item List")
+
+        card_container: Element = ui.row()
+
+        # render cards when page is loaded
+        await _update_cards(parent_app, card_container)
+
+        # update card at a set interval
+        ui.timer(1.0, lambda: _update_cards(parent_app, card_container))

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/api/frontend/_setup.py

@@ -0,0 +1,17 @@
+import nicegui
+from fastapi import FastAPI
+
+from ...core.settings import ApplicationSettings
+from . import _index
+from ._utils import set_parent_app
+
+
+def setup_frontend(app: FastAPI) -> None:
+    settings: ApplicationSettings = app.state.settings
+
+    nicegui.app.include_router(_index.router)
+
+    nicegui.ui.run_with(
+        app, mount_path="/", storage_secret=settings.DYNAMIC_SCHEDULER_UI_STORAGE_SECRET
+    )
+    set_parent_app(app)

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/api/frontend/_utils.py

@@ -0,0 +1,11 @@
+import nicegui
+from fastapi import FastAPI
+
+
+def set_parent_app(parent_app: FastAPI) -> None:
+    nicegui.app.state.parent_app = parent_app
+
+
+def get_parent_app(app: FastAPI) -> FastAPI:
+    parent_app: FastAPI = app.state.parent_app
+    return parent_app