stroblmeandClaude Opus 5
961a8f881d
One process owns this database — the image has run a single uvicorn worker for that reason since the four-engines bug — so a file beside the flows is the honest shape for it, and it is what lets `fluksio serve` need no infrastructure at all. Live values, node execution and the work queue never came here anyway; what does is a rollup a minute at a time, a row per cascade and the run history, and WAL keeps the readers going while that one writer works. DATA_DIR is now the one setting that moves everything an installation keeps; the rest derive from it and the images still spell theirs out. The schema is prepared in-process at startup, so the prestart service is gone, and the ten Postgres-only revisions collapse into one portable baseline. Three things only worked because psycopg was casting for us: a token's subject arriving as a string where the column is a UUID, `greatest`, and `date_bin`. The timestamps needed a column type of their own — SQLite stores no offset, and a naive datetime read back either raises against an aware `now` or serialises as local time. Postgres stays in the stack only for Umami, behind the analytics profile. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
50 lines
1.4 KiB
Python
50 lines
1.4 KiB
Python
import uuid
|
|
|
|
import pytest
|
|
from fastapi.testclient import TestClient
|
|
from sqlmodel import Session, select
|
|
|
|
from fluksio.core.config import settings
|
|
from fluksio.models import User
|
|
|
|
|
|
def test_create_user(client: TestClient, db: Session) -> None:
|
|
r = client.post(
|
|
f"{settings.API_V1_STR}/private/users/",
|
|
json={
|
|
"email": "pollo@listo.com",
|
|
"password": "password123",
|
|
"full_name": "Pollo Listo",
|
|
},
|
|
)
|
|
|
|
assert r.status_code == 200
|
|
|
|
data = r.json()
|
|
|
|
# The id comes back from JSON as a string, and the column is a UUID.
|
|
user = db.exec(select(User).where(User.id == uuid.UUID(data["id"]))).first()
|
|
|
|
assert user
|
|
assert user.email == "pollo@listo.com"
|
|
assert user.full_name == "Pollo Listo"
|
|
|
|
|
|
def test_creating_a_user_is_refused_unless_the_private_api_is_enabled(
|
|
client: TestClient, monkeypatch: pytest.MonkeyPatch
|
|
) -> None:
|
|
"""The route is always mounted so the SDK keeps its shape; the opt-in is
|
|
what decides whether unauthenticated user seeding actually works."""
|
|
monkeypatch.setattr(settings, "PRIVATE_API_ENABLED", False)
|
|
|
|
r = client.post(
|
|
f"{settings.API_V1_STR}/private/users/",
|
|
json={
|
|
"email": "nobody@listo.com",
|
|
"password": "password123",
|
|
"full_name": "Nobody",
|
|
},
|
|
)
|
|
|
|
assert r.status_code == 403
|