layout events_table

app/_fixtures.py

@@ -0,0 +1,41 @@
+from edgedb.asyncio_client import AsyncIOClient
+from faker import Faker
+
+fker = Faker()
+
+
+async def add_users(db_client: AsyncIOClient, target_n_users=5):
+    """
+    faker.name() might produce the same name. Using `set` to make sure `target_n_users` can be achieved.
+    """
+    names = set()
+    while len(names) < target_n_users:
+        names.add(fker.name())
+
+    await db_client.query(
+        """\
+        delete Event;
+        delete User;
+        for name in array_unpack(<array<str>>$names)
+        union (insert User {name:= name});\
+        """,
+        names=list(names),
+    )
+
+
+async def add_events(db_client: AsyncIOClient, target_n_events=5):
+    """
+    faker.text() might produce the same name. Using `set` to make sure `target_n_events` can be achieved.
+    """
+    names = set()
+    while len(names) < target_n_events:
+        names.add(fker.text(max_nb_chars=20).rstrip("."))
+
+    await db_client.query(
+        """\
+        with dummy_user:= (insert User {name:= "dummy user"}),
+        for name in array_unpack(<array<str>>$names)
+        union (insert Event {name:= name, host:= dummy_user });\
+        """,
+        names=list(names),
+    )

app/_lifespan.py

@@ -3,8 +3,10 @@
 from edgedb.asyncio_client import AsyncIOClient
 from fastapi import FastAPI
 
+from ._fixtures import add_events, add_users
 
-async def _lifespan(app: FastAPI, registry: svcs.Registry):
+
+async def _lifespan(app: FastAPI, registry: svcs.Registry, prefill: bool = False):
     # EdgeDB client
     db_client = edgedb.create_async_client()
 
@@ -20,6 +22,11 @@ async def ping_db_callable(_db_client):
         ping=ping_db_callable,
     )
 
+    # Add users and events for testing
+    if prefill:
+        await add_users(db_client)
+        await add_events(db_client)
+
     yield
 
     await registry.aclose()

app/common.py

@@ -0,0 +1,8 @@
+from fastapi import APIRouter
+
+router = APIRouter(include_in_schema=False)
+
+
+@router.get("/")
+async def home():
+    return {"message": "Hello World from FastAPI"}

app/lifespan.py

@@ -1,5 +1,7 @@
+from functools import partial
+
 import svcs
 
 from ._lifespan import _lifespan
 
-lifespan = svcs.fastapi.lifespan(_lifespan)
+lifespan = svcs.fastapi.lifespan(partial(_lifespan, prefill=True))

app/main.py

@@ -1,7 +1,7 @@
 from fastapi import FastAPI
 from starlette.middleware.cors import CORSMiddleware
 
-from app import _internal, events, health, users
+from app import common, events, health, users
 
 from .lifespan import lifespan
 
@@ -21,7 +21,7 @@ def make_app(lifespan):
     app.include_router(users.router)
     app.include_router(events.router)
     app.include_router(health.router)
-    app.include_router(_internal.router)
+    app.include_router(common.router)
 
     return app
 

app/models.py

@@ -48,8 +48,8 @@ class EventBase(BaseModel):
 
 
 class EventCreate(EventBase):
-    address: str
-    schedule: datetime.datetime
+    address: str | None
+    schedule: datetime.datetime | None
     host_name: str = Field(max_length=50)
 
 

app/queries/get_event_by_name.edgeql

@@ -1,5 +1,6 @@
 select Event {
     name, 
+    created_at,
     address,
     schedule,
     host : {name}

app/queries/get_event_by_name_async_edgeql.py

@@ -29,6 +29,7 @@ def __get_validators__(cls):
 class GetEventByNameResult(NoPydanticValidation):
     id: uuid.UUID
     name: str
+    created_at: datetime.datetime
     address: str | None
     schedule: datetime.datetime | None
     host: GetEventByNameResultHost | None
@@ -49,6 +50,7 @@ async def get_event_by_name(
         """\
         select Event {
             name, 
+            created_at,
             address,
             schedule,
             host : {name}

app/queries/get_events.edgeql

@@ -1 +1 @@
-select Event {name, address, schedule, host : {name}};
+select Event {name, created_at, address, schedule, host : {name}};

app/queries/get_events_async_edgeql.py

@@ -29,6 +29,7 @@ def __get_validators__(cls):
 class GetEventsResult(NoPydanticValidation):
     id: uuid.UUID
     name: str
+    created_at: datetime.datetime
     address: str | None
     schedule: datetime.datetime | None
     host: GetEventsResultHost | None
@@ -45,6 +46,6 @@ async def get_events(
 ) -> list[GetEventsResult]:
     return await executor.query(
         """\
-        select Event {name, address, schedule, host : {name}};\
+        select Event {name, created_at, address, schedule, host : {name}};\
         """,
     )

app/queries/get_user_by_name.edgeql

@@ -1 +1,6 @@
-select User {name, created_at} filter User.name=<str>$name;
+select User {name,
+            created_at, 
+            n_events:= count(.<host[is Event])
+        } 
+filter User.name=<str>$name;
+

app/queries/get_user_by_name_async_edgeql.py

@@ -30,6 +30,7 @@ class GetUserByNameResult(NoPydanticValidation):
     id: uuid.UUID
     name: str
     created_at: datetime.datetime
+    n_events: int
 
 
 async def get_user_by_name(
@@ -39,7 +40,11 @@ async def get_user_by_name(
 ) -> GetUserByNameResult | None:
     return await executor.query_single(
         """\
-        select User {name, created_at} filter User.name=<str>$name;\
+        select User {name,
+                    created_at, 
+                    n_events:= count(.<host[is Event])
+                } 
+        filter User.name=<str>$name;\
         """,
         name=name,
     )

app/queries/get_users.edgeql

@@ -1 +1,4 @@
-select User {name, created_at};
+select User {name,
+            created_at, 
+            n_events:= count(.<host[is Event])
+        } 

app/queries/get_users_async_edgeql.py

@@ -30,13 +30,17 @@ class GetUsersResult(NoPydanticValidation):
     id: uuid.UUID
     name: str
     created_at: datetime.datetime
+    n_events: int
 
 
 async def get_users(
     executor: edgedb.AsyncIOExecutor,
 ) -> list[GetUsersResult]:
     return await executor.query(
         """\
-        select User {name, created_at};\
+        select User {name,
+                    created_at, 
+                    n_events:= count(.<host[is Event])
+                }\
         """,
     )

fastui_app/common.py

@@ -0,0 +1,27 @@
+from fastapi import (
+    APIRouter,
+    HTTPException,  # noqa: F401
+)
+from fastapi.responses import HTMLResponse
+from fastui import AnyComponent, FastUI, prebuilt_html
+from fastui import components as c
+from fastui.events import BackEvent, GoToEvent, PageEvent  # noqa:F401
+
+from .models import EventFull, UserFull  # noqa: F401
+from .shared import demo_page
+from .utils import _raise_for_status  # noqa: F401
+
+router = APIRouter(include_in_schema=False)
+
+
+@router.get("/api/", response_model=FastUI, response_model_exclude_none=True)
+async def home() -> list[AnyComponent]:
+    return demo_page(
+        c.Heading(text="Home", level=1), c.Paragraph(text="Hello World from FastUI")
+    )
+
+
+@router.get("/{path:path}")
+async def html_landing() -> HTMLResponse:
+    """Simple HTML page which serves the React router, comes last as it matches all paths."""
+    return HTMLResponse(prebuilt_html(title="FastUI Demo"))