Merge branch 'main' into async-effects

Author: rmorshea

docs/source/about/changelog.rst

@@ -23,7 +23,10 @@ more info, see the :ref:`Contributor Guide <Creating a Changelog Entry>`.
 Unreleased
 ----------
 
-Nothing yet...
+**Fixed**
+
+- :pull:`1118` - `module_from_template` is broken with a recent release of `requests`
+- :pull:`1131` - `module_from_template` did not work when using Flask backend
 
 
 v1.0.2
@@ -40,11 +43,15 @@ v1.0.1
 **Changed**
 
 - :pull:`1050` - Warn and attempt to fix missing mime types, which can result in ``reactpy.run`` not working as expected.
+- :pull:`1051` - Rename ``reactpy.backend.BackendImplementation`` to ``reactpy.backend.BackendType``
+- :pull:`1051` - Allow ``reactpy.run`` to fail in more predictable ways
 
 **Fixed**
 
 - :issue:`930` - better traceback for JSON serialization errors (via :pull:`1008`)
 - :issue:`437` - explain that JS component attributes must be JSON (via :pull:`1008`)
+- :pull:`1051` - Fix ``reactpy.run`` port assignment sometimes attaching to in-use ports on Windows
+- :pull:`1051` - Fix ``reactpy.run`` not recognizing ``fastapi``
 
 
 v1.0.0

pyproject.toml

@@ -13,7 +13,7 @@ dependencies = [
   "invoke",
   # lint
   "black",
-  "ruff==0.0.278",  # Ruff is moving really fast, so pinning for now.
+  "ruff==0.0.278",        # Ruff is moving really fast, so pinning for now.
   "toml",
   "flake8",
   "flake8-pyproject",
@@ -32,9 +32,11 @@ publish = "invoke publish {args}"
 docs = "invoke docs {args}"
 check = ["lint-py", "lint-js", "test-py", "test-js", "test-docs"]
 
+lint = ["lint-py", "lint-js"]
 lint-py = "invoke lint-py {args}"
 lint-js = "invoke lint-js {args}"
 
+test = ["test-py", "test-js", "test-docs"]
 test-py = "invoke test-py {args}"
 test-js = "invoke test-js"
 test-docs = "invoke test-docs"
@@ -56,7 +58,7 @@ warn_unused_ignores = true
 # --- Flake8 ---------------------------------------------------------------------------
 
 [tool.flake8]
-select = ["RPY"]  # only need to check with reactpy-flake8
+select = ["RPY"]                                                  # only need to check with reactpy-flake8
 exclude = ["**/node_modules/*", ".eggs/*", ".tox/*", "**/venv/*"]
 
 # --- Ruff -----------------------------------------------------------------------------
@@ -95,27 +97,37 @@ select = [
 ]
 ignore = [
   # TODO: turn this on later
-  "N802", "N806",  # allow TitleCase functions/variables
+  "N802",
+  "N806", # allow TitleCase functions/variables
   # We're not any cryptography
   "S311",
   # For loop variable re-assignment seems like an uncommon mistake
   "PLW2901",
   # Let Black deal with line-length
   "E501",
   # Allow args/attrs to shadow built-ins
-  "A002", "A003",
+  "A002",
+  "A003",
   # Allow unused args (useful for documenting what the parameter is for later)
-  "ARG001", "ARG002", "ARG005",
+  "ARG001",
+  "ARG002",
+  "ARG005",
   # Allow non-abstract empty methods in abstract base classes
   "B027",
   # Allow boolean positional values in function calls, like `dict.get(... True)`
   "FBT003",
   # If we're making an explicit comparison to a falsy value it was probably intentional
   "PLC1901",
   # Ignore checks for possible passwords
-  "S105", "S106", "S107",
+  "S105",
+  "S106",
+  "S107",
   # Ignore complexity
-  "C901", "PLR0911", "PLR0912", "PLR0913", "PLR0915",
+  "C901",
+  "PLR0911",
+  "PLR0912",
+  "PLR0913",
+  "PLR0915",
 ]
 unfixable = [
   # Don't touch unused imports

requirements.txt

@@ -0,0 +1,28 @@
+from reactpy import component, html, run, use_state
+from reactpy.core.types import State
+
+
+@component
+def Item(item: str, all_items: State[list[str]]):
+    color = use_state(None)
+
+    def deleteme(event):
+        all_items.set_value([i for i in all_items.value if (i != item)])
+
+    def colorize(event):
+        color.set_value("blue" if not color.value else None)
+
+    return html.div(
+        {"id": item, "style": {"background_color": color.value}},
+        html.button({"on_click": colorize}, f"Color {item}"),
+        html.button({"on_click": deleteme}, f"Delete {item}"),
+    )
+
+
+@component
+def App():
+    items = use_state(["A", "B", "C"])
+    return html._([Item(item, items, key=item) for item in items.value])
+
+
+run(App)

src/py/reactpy/.temp.py

@@ -14,53 +14,49 @@
 from reactpy.utils import vdom_to_html
 
 if TYPE_CHECKING:
+    import uvicorn
     from asgiref.typing import ASGIApplication
 
 PATH_PREFIX = PurePosixPath("/_reactpy")
 MODULES_PATH = PATH_PREFIX / "modules"
 ASSETS_PATH = PATH_PREFIX / "assets"
 STREAM_PATH = PATH_PREFIX / "stream"
-
 CLIENT_BUILD_DIR = Path(_reactpy_file_path).parent / "_static" / "app" / "dist"
 
-try:
+
+async def serve_with_uvicorn(
+    app: ASGIApplication | Any,
+    host: str,
+    port: int,
+    started: asyncio.Event | None,
+) -> None:
+    """Run a development server for an ASGI application"""
     import uvicorn
-except ImportError:  # nocov
-    pass
-else:
-
-    async def serve_development_asgi(
-        app: ASGIApplication | Any,
-        host: str,
-        port: int,
-        started: asyncio.Event | None,
-    ) -> None:
-        """Run a development server for an ASGI application"""
-        server = uvicorn.Server(
-            uvicorn.Config(
-                app,
-                host=host,
-                port=port,
-                loop="asyncio",
-                reload=True,
-            )
+
+    server = uvicorn.Server(
+        uvicorn.Config(
+            app,
+            host=host,
+            port=port,
+            loop="asyncio",
         )
-        server.config.setup_event_loop()
-        coros: list[Awaitable[Any]] = [server.serve()]
+    )
+    server.config.setup_event_loop()
+    coros: list[Awaitable[Any]] = [server.serve()]
 
-        # If a started event is provided, then use it signal based on `server.started`
-        if started:
-            coros.append(_check_if_started(server, started))
+    # If a started event is provided, then use it signal based on `server.started`
+    if started:
+        coros.append(_check_if_started(server, started))
 
-        try:
-            await asyncio.gather(*coros)
-        finally:
-            # Since we aren't using the uvicorn's `run()` API, we can't guarantee uvicorn's
-            # order of operations. So we need to make sure `shutdown()` always has an initialized
-            # list of `self.servers` to use.
-            if not hasattr(server, "servers"):  # nocov
-                server.servers = []
-            await asyncio.wait_for(server.shutdown(), timeout=3)
+    try:
+        await asyncio.gather(*coros)
+    finally:
+        # Since we aren't using the uvicorn's `run()` API, we can't guarantee uvicorn's
+        # order of operations. So we need to make sure `shutdown()` always has an initialized
+        # list of `self.servers` to use.
+        if not hasattr(server, "servers"):  # nocov
+            server.servers = []
+        await asyncio.wait_for(server.shutdown(), timeout=3)
 
 
 async def _check_if_started(server: uvicorn.Server, started: asyncio.Event) -> None:
@@ -72,8 +68,7 @@ async def _check_if_started(server: uvicorn.Server, started: asyncio.Event) -> N
 def safe_client_build_dir_path(path: str) -> Path:
     """Prevent path traversal out of :data:`CLIENT_BUILD_DIR`"""
     return traversal_safe_path(
-        CLIENT_BUILD_DIR,
-        *("index.html" if path in ("", "/") else path).split("/"),
+        CLIENT_BUILD_DIR, *("index.html" if path in {"", "/"} else path).split("/")
     )
 
 
@@ -140,6 +135,9 @@ class CommonOptions:
     url_prefix: str = ""
     """The URL prefix where ReactPy resources will be served from"""
 
+    serve_index_route: bool = True
+    """Automatically generate and serve the index route (``/``)"""
+
     def __post_init__(self) -> None:
         if self.url_prefix and not self.url_prefix.startswith("/"):
             msg = "Expected 'url_prefix' to start with '/'"

src/py/reactpy/reactpy/backend/_common.py

@@ -5,13 +5,26 @@
 from sys import exc_info
 from typing import Any, NoReturn
 
-from reactpy.backend.types import BackendImplementation
-from reactpy.backend.utils import SUPPORTED_PACKAGES, all_implementations
+from reactpy.backend.types import BackendType
+from reactpy.backend.utils import SUPPORTED_BACKENDS, all_implementations
 from reactpy.types import RootComponentConstructor
 
 logger = getLogger(__name__)
+_DEFAULT_IMPLEMENTATION: BackendType[Any] | None = None
 
 
+# BackendType.Options
+class Options:  # nocov
+    """Configuration options that can be provided to the backend.
+    This definition should not be used/instantiated. It exists only for
+    type hinting purposes."""
+
+    def __init__(self, *args: Any, **kwds: Any) -> NoReturn:
+        msg = "Default implementation has no options."
+        raise ValueError(msg)
+
+
+# BackendType.configure
 def configure(
     app: Any, component: RootComponentConstructor, options: None = None
 ) -> None:
@@ -22,17 +35,13 @@ def configure(
     return _default_implementation().configure(app, component)
 
 
+# BackendType.create_development_app
 def create_development_app() -> Any:
     """Create an application instance for development purposes"""
     return _default_implementation().create_development_app()
 
 
-def Options(*args: Any, **kwargs: Any) -> NoReturn:  # nocov
-    """Create configuration options"""
-    msg = "Default implementation has no options."
-    raise ValueError(msg)
-
-
+# BackendType.serve_development_app
 async def serve_development_app(
     app: Any,
     host: str,
@@ -45,10 +54,7 @@ async def serve_development_app(
     )
 
 
-_DEFAULT_IMPLEMENTATION: BackendImplementation[Any] | None = None
-
-
-def _default_implementation() -> BackendImplementation[Any]:
+def _default_implementation() -> BackendType[Any]:
     """Get the first available server implementation"""
     global _DEFAULT_IMPLEMENTATION  # noqa: PLW0603
 
@@ -59,7 +65,7 @@ def _default_implementation() -> BackendImplementation[Any]:
         implementation = next(all_implementations())
     except StopIteration:  # nocov
         logger.debug("Backend implementation import failed", exc_info=exc_info())
-        supported_backends = ", ".join(SUPPORTED_PACKAGES)
+        supported_backends = ", ".join(SUPPORTED_BACKENDS)
         msg = (
             "It seems you haven't installed a backend. To resolve this issue, "
             "you can install a backend by running:\n\n"

src/py/reactpy/reactpy/backend/default.py

@@ -4,22 +4,22 @@
 
 from reactpy.backend import starlette
 
-serve_development_app = starlette.serve_development_app
-"""Alias for :func:`reactpy.backend.starlette.serve_development_app`"""
-
-use_connection = starlette.use_connection
-"""Alias for :func:`reactpy.backend.starlette.use_location`"""
-
-use_websocket = starlette.use_websocket
-"""Alias for :func:`reactpy.backend.starlette.use_websocket`"""
-
+# BackendType.Options
 Options = starlette.Options
-"""Alias for :class:`reactpy.backend.starlette.Options`"""
 
+# BackendType.configure
 configure = starlette.configure
-"""Alias for :class:`reactpy.backend.starlette.configure`"""
 
 
+# BackendType.create_development_app
 def create_development_app() -> FastAPI:
     """Create a development ``FastAPI`` application instance."""
     return FastAPI(debug=True)
+
+
+# BackendType.serve_development_app
+serve_development_app = starlette.serve_development_app
+
+use_connection = starlette.use_connection
+
+use_websocket = starlette.use_websocket