From c8732f859488d8549abcb609cb6606f661b1ef2b Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 15:16:33 +0300 Subject: [PATCH 1/8] chore: migrate from Motor to PyMongo async --- examples/why/requirements.in | 2 +- examples/why/requirements.txt | 10 ++++------ examples/why/why/__init__.py | 6 +++--- tests/conftest.py | 2 +- 4 files changed, 9 insertions(+), 11 deletions(-) diff --git a/examples/why/requirements.in b/examples/why/requirements.in index 97a0f0a..8398c2e 100644 --- a/examples/why/requirements.in +++ b/examples/why/requirements.in @@ -1,5 +1,5 @@ fastapi -motor[srv] +pymongo[srv] uvicorn jinja2 beanie \ No newline at end of file diff --git a/examples/why/requirements.txt b/examples/why/requirements.txt index c6053d3..4425973 100644 --- a/examples/why/requirements.txt +++ b/examples/why/requirements.txt @@ -28,10 +28,6 @@ lazy-model==0.2.0 # via beanie markupsafe==2.1.5 # via jinja2 -motor[srv]==3.4.0 - # via - # -r requirements.in - # beanie pydantic==2.7.1 # via # beanie @@ -39,8 +35,10 @@ pydantic==2.7.1 # lazy-model pydantic-core==2.18.2 # via pydantic -pymongo[srv]==4.6.3 - # via motor +pymongo[srv]==4.13.1 + # via + # -r requirements.in + # beanie sniffio==1.3.1 # via anyio starlette==0.37.2 diff --git a/examples/why/why/__init__.py b/examples/why/why/__init__.py index d8ab124..be1fd41 100644 --- a/examples/why/why/__init__.py +++ b/examples/why/why/__init__.py @@ -4,7 +4,7 @@ from fastapi import FastAPI -from motor.motor_asyncio import AsyncIOMotorClient +from pymongo import AsyncMongoClient # from docbridge import Document, Field, SequenceField from beanie import Document, init_beanie from pydantic import BaseModel, Field @@ -16,8 +16,8 @@ @asynccontextmanager async def db_lifespan(app: FastAPI): # Startup - app.mongodb_client = motor = AsyncIOMotorClient(CONNECTION_STRING) - app.database = db = motor.get_database("why") + app.mongodb_client = mongo_client = AsyncMongoClient(CONNECTION_STRING) + app.database = db = mongo_client.get_database("why") ping_response = await db.command("ping") if int(ping_response["ok"]) != 1: raise Exception("Problem connecting to database cluster.") diff --git a/tests/conftest.py b/tests/conftest.py index fdb238b..49578d4 100644 --- a/tests/conftest.py +++ b/tests/conftest.py @@ -1,6 +1,6 @@ import os import pytest_asyncio -from motor.motor_asyncio import AsyncIOMotorClient as MotorClient +from pymongo import AsyncMongoClient as MotorClient @pytest_asyncio.fixture(scope="session") From 07d5ea3e34e880dc6d90b2f093510c4d50fdde5a Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 15:24:18 +0300 Subject: [PATCH 2/8] ci: add standard GitHub Actions smoke workflow --- .github/workflows/ci.yml | 89 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 89 insertions(+) create mode 100644 .github/workflows/ci.yml diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml new file mode 100644 index 0000000..a3cc6bd --- /dev/null +++ b/.github/workflows/ci.yml @@ -0,0 +1,89 @@ +name: CI + +on: + push: + pull_request: + workflow_dispatch: + +jobs: + smoke: + runs-on: ubuntu-latest + + steps: + - name: Checkout + uses: actions/checkout@v4 + + - name: Set up Python + uses: actions/setup-python@v5 + with: + python-version: "3.12" + + - name: Set up Node + uses: actions/setup-node@v4 + with: + node-version: "20" + + - name: Repo smoke checks + shell: bash + run: | + set -euo pipefail + + echo "Validating repository structure and basic runnable signals" + + has_signal=0 + + if find . -maxdepth 4 -type f -name "package.json" | grep -q .; then + has_signal=1 + while IFS= read -r pkg; do + [ -z "$pkg" ] && continue + node -e "const fs=require('fs'); JSON.parse(fs.readFileSync(process.argv[1],'utf8'));" "$pkg" + done < <(find . -maxdepth 4 -type f -name "package.json") + fi + + if find . -maxdepth 4 -type f \( -name "pyproject.toml" -o -name "requirements.txt" -o -name "setup.py" -o -name "manage.py" \) | grep -q .; then + has_signal=1 + fi + + if find . -maxdepth 4 -type f \( -name "app.py" -o -name "main.py" -o -name "wsgi.py" -o -name "asgi.py" \) | grep -q .; then + has_signal=1 + fi + + if find . -maxdepth 4 -type f \( -name "pom.xml" -o -name "build.gradle" -o -name "build.gradle.kts" -o -name "gradlew" \) | grep -q .; then + has_signal=1 + fi + + if find . -maxdepth 4 -type f -name "go.mod" | grep -q .; then + has_signal=1 + fi + + if find . -maxdepth 4 -type f -name "Cargo.toml" | grep -q .; then + has_signal=1 + fi + + if find . -maxdepth 4 -type f \( -name "*.csproj" -o -name "*.sln" \) | grep -q .; then + has_signal=1 + fi + + if find . -maxdepth 4 -type f \( -name "Dockerfile" -o -name "docker-compose.yml" -o -name "docker-compose.yaml" \) | grep -q .; then + has_signal=1 + fi + + if find . -maxdepth 4 -type f -name "Makefile" | grep -q .; then + has_signal=1 + fi + + if [ "$has_signal" -ne 1 ]; then + echo "No runnable/build signals found in repository" + exit 1 + fi + + echo "Running Python syntax smoke check" + python_files="$(find . -type f -name '*.py' -not -path './.git/*' 2>/dev/null || true)" + if [ -n "$python_files" ]; then + while IFS= read -r f; do + [ -z "$f" ] && continue + python -m py_compile "$f" + done <<< "$python_files" + fi + + echo "Smoke checks passed" From 8e160f7117223a717662458c6ca5f14302e637ac Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 15:26:49 +0300 Subject: [PATCH 3/8] test: add runtime smoke test and run it in CI --- .github/workflows/ci.yml | 11 +++++ tests/run_runtime_smoke.py | 92 ++++++++++++++++++++++++++++++++++++++ 2 files changed, 103 insertions(+) create mode 100755 tests/run_runtime_smoke.py diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index a3cc6bd..986c994 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -87,3 +87,14 @@ jobs: fi echo "Smoke checks passed" + + - name: Run repository runtime smoke test + shell: bash + run: | + set -euo pipefail + if [ -f tests/run_runtime_smoke.py ]; then + python tests/run_runtime_smoke.py + else + echo "No runtime smoke test file found" + exit 1 + fi diff --git a/tests/run_runtime_smoke.py b/tests/run_runtime_smoke.py new file mode 100755 index 0000000..12e3437 --- /dev/null +++ b/tests/run_runtime_smoke.py @@ -0,0 +1,92 @@ +#!/usr/bin/env python3 +"""Repository runtime smoke test. + +This test intentionally avoids external services and validates: +1) repo has at least one runnable/build marker +2) Python source files in repo compile successfully +""" + +from __future__ import annotations + +from pathlib import Path +import py_compile +import sys + +REPO_ROOT = Path(__file__).resolve().parents[1] + +SKIP_DIRS = { + ".git", + ".venv", + "venv", + "node_modules", + "dist", + "build", + "__pycache__", +} + + +def has_runnable_marker(root: Path) -> bool: + markers = [ + "package.json", + "pyproject.toml", + "requirements.txt", + "setup.py", + "manage.py", + "pom.xml", + "build.gradle", + "build.gradle.kts", + "go.mod", + "Cargo.toml", + "Dockerfile", + "docker-compose.yml", + "docker-compose.yaml", + "Makefile", + ] + for marker in markers: + if list(root.rglob(marker)): + return True + + if list(root.rglob("*.csproj")) or list(root.rglob("*.sln")): + return True + + return False + + +def iter_python_files(root: Path): + for py_file in root.rglob("*.py"): + rel = py_file.relative_to(root) + if any(part in SKIP_DIRS for part in rel.parts): + continue + yield py_file + + +def main() -> int: + if not has_runnable_marker(REPO_ROOT): + print("FAIL: no runnable/build marker found") + return 1 + + py_files = list(iter_python_files(REPO_ROOT)) + if not py_files: + print("PASS: no python files to compile; marker checks passed") + return 0 + + failures = [] + for py_file in py_files: + try: + py_compile.compile(str(py_file), doraise=True) + except py_compile.PyCompileError as exc: + failures.append((py_file, exc.msg)) + + if failures: + print(f"FAIL: {len(failures)} python files failed to compile") + for py_file, msg in failures[:20]: + rel = py_file.relative_to(REPO_ROOT) + print(f" - {rel}: {msg}") + return 1 + + print(f"PASS: compiled {len(py_files)} python files") + return 0 + + +if __name__ == "__main__": + sys.exit(main()) From 9f57c241348f28260b0a0edc9eef90cea06f2f61 Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 15:30:30 +0300 Subject: [PATCH 4/8] test: replace generic smoke check with repo-specific runtime contract test --- tests/run_runtime_smoke.py | 203 ++++++++++++++++++++++++------------- 1 file changed, 130 insertions(+), 73 deletions(-) diff --git a/tests/run_runtime_smoke.py b/tests/run_runtime_smoke.py index 12e3437..596d0af 100755 --- a/tests/run_runtime_smoke.py +++ b/tests/run_runtime_smoke.py @@ -1,9 +1,9 @@ #!/usr/bin/env python3 -"""Repository runtime smoke test. +"""Repo-specific runtime contract test. -This test intentionally avoids external services and validates: -1) repo has at least one runnable/build marker -2) Python source files in repo compile successfully +This validates that the repository's primary runtime module(s): +- compile successfully +- keep expected runtime entrypoints/routes/contracts """ from __future__ import annotations @@ -12,80 +12,137 @@ import py_compile import sys -REPO_ROOT = Path(__file__).resolve().parents[1] - -SKIP_DIRS = { - ".git", - ".venv", - "venv", - "node_modules", - "dist", - "build", - "__pycache__", -} - - -def has_runnable_marker(root: Path) -> bool: - markers = [ - "package.json", - "pyproject.toml", - "requirements.txt", - "setup.py", - "manage.py", - "pom.xml", - "build.gradle", - "build.gradle.kts", - "go.mod", - "Cargo.toml", - "Dockerfile", - "docker-compose.yml", - "docker-compose.yaml", - "Makefile", - ] - for marker in markers: - if list(root.rglob(marker)): - return True - - if list(root.rglob("*.csproj")) or list(root.rglob("*.sln")): - return True - - return False - - -def iter_python_files(root: Path): - for py_file in root.rglob("*.py"): - rel = py_file.relative_to(root) - if any(part in SKIP_DIRS for part in rel.parts): - continue - yield py_file +ROOT = Path(__file__).resolve().parents[1] + + +def require_file(path: str) -> Path: + p = ROOT / path + if not p.exists(): + raise AssertionError(f"Missing expected file: {path}") + return p + + +def compile_file(path: str) -> None: + p = require_file(path) + py_compile.compile(str(p), doraise=True) + + +def read_text(path: str) -> str: + return require_file(path).read_text() + + +def require_contains(path: str, needle: str) -> None: + text = read_text(path) + if needle not in text: + raise AssertionError(f"Expected marker not found in {path}: {needle}") + + +def ok(msg: str) -> None: + print(f"PASS: {msg}") + + +def fail(msg: str) -> int: + print(f"FAIL: {msg}") + return 1 def main() -> int: - if not has_runnable_marker(REPO_ROOT): - print("FAIL: no runnable/build marker found") - return 1 + try: + repo = ROOT.name + + if repo == "FARM-Auth": + compile_file("backend/main.py") + require_contains("backend/main.py", "app = FastAPI()") + require_contains("backend/main.py", "@app.on_event(\"startup\")") + require_contains("backend/main.py", "get_users_router") + require_contains("backend/main.py", "get_todo_router") + ok("FARM-Auth runtime contracts") + + elif repo == "FARM-Intro": + compile_file("backend/main.py") + require_contains("backend/main.py", "app = FastAPI()") + require_contains("backend/main.py", "app.include_router(todo_router") + require_contains("backend/main.py", "prefix=\"/task\"") + ok("FARM-Intro runtime contracts") + + elif repo == "a2a-mcp-mongodb-multiagents": + compile_file("mcp/main.py") + require_contains("mcp/main.py", "mcp = FastMCP(") + require_contains("mcp/main.py", "@mcp.tool") + require_contains("mcp/main.py", "async def connect_to_mongo") + ok("a2a MCP runtime contracts") + + elif repo == "beanie-example": + compile_file("src/beaniecocktails/__init__.py") + compile_file("src/beaniecocktails/scripts/init_db.py") + require_contains("src/beaniecocktails/__init__.py", "app = FastAPI(lifespan=app_lifespan)") + require_contains("src/beaniecocktails/__init__.py", "init_beanie(") + require_contains("src/beaniecocktails/__init__.py", "app.include_router(cocktail_router") + ok("beanie-example runtime contracts") + + elif repo == "docbridge": + compile_file("examples/why/why/__init__.py") + require_contains("examples/why/why/__init__.py", "app = FastAPI(lifespan=db_lifespan)") + require_contains("examples/why/why/__init__.py", "@app.get(\"/profiles/{user_id}\")") + require_contains("examples/why/why/__init__.py", "class Profile(Document)") + ok("docbridge runtime contracts") + + elif repo == "farm-stack-to-do-app": + compile_file("backend/src/todo/server.py") + require_contains("backend/src/todo/server.py", "app = FastAPI(lifespan=lifespan") + require_contains("backend/src/todo/server.py", "@app.get(\"/api/lists\")") + require_contains("backend/src/todo/server.py", "@app.post(\"/api/lists\"") + require_contains("backend/src/todo/server.py", "@app.patch(\"/api/lists/{list_id}/checked_state\")") + ok("farm-stack-to-do-app runtime contracts") + + elif repo == "hr_agentic_chatbot": + compile_file("app.py") + require_contains("app.py", "@cl.on_chat_start") + require_contains("app.py", "@cl.on_message") + require_contains("app.py", "create_workflow(") + ok("hr_agentic_chatbot runtime contracts") + + elif repo == "mongodb-atlas-fastapi": + compile_file("app/main.py") + require_contains("app/main.py", "app = FastAPI()") + require_contains("app/main.py", "@app.get(\"/\", response_description=\"Student API HealthCheck\")") + require_contains("app/main.py", "@app.get(\"/students\"") + ok("mongodb-atlas-fastapi runtime contracts") + + elif repo == "mongodb-with-starlette": + compile_file("app.py") + require_contains("app.py", "app = Starlette(") + require_contains("app.py", "Route(\"/\", create_student, methods=[\"POST\"])") + require_contains("app.py", "Route(\"/{id}\", delete_student, methods=[\"DELETE\"])") + ok("mongodb-with-starlette runtime contracts") + + elif repo == "mongodb-with-tornado": + compile_file("app.py") + require_contains("app.py", "class MainHandler(tornado.web.RequestHandler)") + require_contains("app.py", "app = tornado.web.Application(") + require_contains("app.py", "(r\"/(?P\\w+)\", MainHandler)") + ok("mongodb-with-tornado runtime contracts") + + elif repo == "mongodb-with-sanic": + compile_file("app.py") + require_contains("app.py", "app = Sanic(__name__)") + require_contains("app.py", "@app.route(\"/\", methods=[\"POST\"])") + require_contains("app.py", "@app.route(\"/\", methods=[\"DELETE\"])") + ok("mongodb-with-sanic runtime contracts") + + elif repo == "celeb-matcher-farm": + compile_file("backend/src/server.py") + require_contains("backend/src/server.py", "app = FastAPI(lifespan=lifespan") + require_contains("backend/src/server.py", "@app.post(\"/api/search\")") + require_contains("backend/src/server.py", "class SearchPayload(BaseModel)") + ok("celeb-matcher-farm runtime contracts") + + else: + raise AssertionError(f"No repository-specific contract defined for: {repo}") - py_files = list(iter_python_files(REPO_ROOT)) - if not py_files: - print("PASS: no python files to compile; marker checks passed") return 0 - - failures = [] - for py_file in py_files: - try: - py_compile.compile(str(py_file), doraise=True) - except py_compile.PyCompileError as exc: - failures.append((py_file, exc.msg)) - - if failures: - print(f"FAIL: {len(failures)} python files failed to compile") - for py_file, msg in failures[:20]: - rel = py_file.relative_to(REPO_ROOT) - print(f" - {rel}: {msg}") - return 1 - - print(f"PASS: compiled {len(py_files)} python files") - return 0 + except Exception as exc: + return fail(str(exc)) if __name__ == "__main__": From 63bd7ecdba3de3f7f1c06427f08f8d64540c6b92 Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 15:41:56 +0300 Subject: [PATCH 5/8] test: replace smoke checks with repo-local runtime tests --- .github/workflows/ci.yml | 4 +- tests/run_runtime_smoke.py | 149 ------------------------------------- tests/test_runtime.py | 57 ++++++++++++++ 3 files changed, 59 insertions(+), 151 deletions(-) delete mode 100755 tests/run_runtime_smoke.py create mode 100644 tests/test_runtime.py diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 986c994..b8014ec 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -92,8 +92,8 @@ jobs: shell: bash run: | set -euo pipefail - if [ -f tests/run_runtime_smoke.py ]; then - python tests/run_runtime_smoke.py + if [ -f tests/test_runtime.py ]; then + python tests/test_runtime.py else echo "No runtime smoke test file found" exit 1 diff --git a/tests/run_runtime_smoke.py b/tests/run_runtime_smoke.py deleted file mode 100755 index 596d0af..0000000 --- a/tests/run_runtime_smoke.py +++ /dev/null @@ -1,149 +0,0 @@ -#!/usr/bin/env python3 -"""Repo-specific runtime contract test. - -This validates that the repository's primary runtime module(s): -- compile successfully -- keep expected runtime entrypoints/routes/contracts -""" - -from __future__ import annotations - -from pathlib import Path -import py_compile -import sys - -ROOT = Path(__file__).resolve().parents[1] - - -def require_file(path: str) -> Path: - p = ROOT / path - if not p.exists(): - raise AssertionError(f"Missing expected file: {path}") - return p - - -def compile_file(path: str) -> None: - p = require_file(path) - py_compile.compile(str(p), doraise=True) - - -def read_text(path: str) -> str: - return require_file(path).read_text() - - -def require_contains(path: str, needle: str) -> None: - text = read_text(path) - if needle not in text: - raise AssertionError(f"Expected marker not found in {path}: {needle}") - - -def ok(msg: str) -> None: - print(f"PASS: {msg}") - - -def fail(msg: str) -> int: - print(f"FAIL: {msg}") - return 1 - - -def main() -> int: - try: - repo = ROOT.name - - if repo == "FARM-Auth": - compile_file("backend/main.py") - require_contains("backend/main.py", "app = FastAPI()") - require_contains("backend/main.py", "@app.on_event(\"startup\")") - require_contains("backend/main.py", "get_users_router") - require_contains("backend/main.py", "get_todo_router") - ok("FARM-Auth runtime contracts") - - elif repo == "FARM-Intro": - compile_file("backend/main.py") - require_contains("backend/main.py", "app = FastAPI()") - require_contains("backend/main.py", "app.include_router(todo_router") - require_contains("backend/main.py", "prefix=\"/task\"") - ok("FARM-Intro runtime contracts") - - elif repo == "a2a-mcp-mongodb-multiagents": - compile_file("mcp/main.py") - require_contains("mcp/main.py", "mcp = FastMCP(") - require_contains("mcp/main.py", "@mcp.tool") - require_contains("mcp/main.py", "async def connect_to_mongo") - ok("a2a MCP runtime contracts") - - elif repo == "beanie-example": - compile_file("src/beaniecocktails/__init__.py") - compile_file("src/beaniecocktails/scripts/init_db.py") - require_contains("src/beaniecocktails/__init__.py", "app = FastAPI(lifespan=app_lifespan)") - require_contains("src/beaniecocktails/__init__.py", "init_beanie(") - require_contains("src/beaniecocktails/__init__.py", "app.include_router(cocktail_router") - ok("beanie-example runtime contracts") - - elif repo == "docbridge": - compile_file("examples/why/why/__init__.py") - require_contains("examples/why/why/__init__.py", "app = FastAPI(lifespan=db_lifespan)") - require_contains("examples/why/why/__init__.py", "@app.get(\"/profiles/{user_id}\")") - require_contains("examples/why/why/__init__.py", "class Profile(Document)") - ok("docbridge runtime contracts") - - elif repo == "farm-stack-to-do-app": - compile_file("backend/src/todo/server.py") - require_contains("backend/src/todo/server.py", "app = FastAPI(lifespan=lifespan") - require_contains("backend/src/todo/server.py", "@app.get(\"/api/lists\")") - require_contains("backend/src/todo/server.py", "@app.post(\"/api/lists\"") - require_contains("backend/src/todo/server.py", "@app.patch(\"/api/lists/{list_id}/checked_state\")") - ok("farm-stack-to-do-app runtime contracts") - - elif repo == "hr_agentic_chatbot": - compile_file("app.py") - require_contains("app.py", "@cl.on_chat_start") - require_contains("app.py", "@cl.on_message") - require_contains("app.py", "create_workflow(") - ok("hr_agentic_chatbot runtime contracts") - - elif repo == "mongodb-atlas-fastapi": - compile_file("app/main.py") - require_contains("app/main.py", "app = FastAPI()") - require_contains("app/main.py", "@app.get(\"/\", response_description=\"Student API HealthCheck\")") - require_contains("app/main.py", "@app.get(\"/students\"") - ok("mongodb-atlas-fastapi runtime contracts") - - elif repo == "mongodb-with-starlette": - compile_file("app.py") - require_contains("app.py", "app = Starlette(") - require_contains("app.py", "Route(\"/\", create_student, methods=[\"POST\"])") - require_contains("app.py", "Route(\"/{id}\", delete_student, methods=[\"DELETE\"])") - ok("mongodb-with-starlette runtime contracts") - - elif repo == "mongodb-with-tornado": - compile_file("app.py") - require_contains("app.py", "class MainHandler(tornado.web.RequestHandler)") - require_contains("app.py", "app = tornado.web.Application(") - require_contains("app.py", "(r\"/(?P\\w+)\", MainHandler)") - ok("mongodb-with-tornado runtime contracts") - - elif repo == "mongodb-with-sanic": - compile_file("app.py") - require_contains("app.py", "app = Sanic(__name__)") - require_contains("app.py", "@app.route(\"/\", methods=[\"POST\"])") - require_contains("app.py", "@app.route(\"/\", methods=[\"DELETE\"])") - ok("mongodb-with-sanic runtime contracts") - - elif repo == "celeb-matcher-farm": - compile_file("backend/src/server.py") - require_contains("backend/src/server.py", "app = FastAPI(lifespan=lifespan") - require_contains("backend/src/server.py", "@app.post(\"/api/search\")") - require_contains("backend/src/server.py", "class SearchPayload(BaseModel)") - ok("celeb-matcher-farm runtime contracts") - - else: - raise AssertionError(f"No repository-specific contract defined for: {repo}") - - return 0 - except Exception as exc: - return fail(str(exc)) - - -if __name__ == "__main__": - sys.exit(main()) diff --git a/tests/test_runtime.py b/tests/test_runtime.py new file mode 100644 index 0000000..3814f5c --- /dev/null +++ b/tests/test_runtime.py @@ -0,0 +1,57 @@ +import asyncio +import importlib.util +import os +import sys +import types +import unittest +from pathlib import Path + + +class RuntimeTest(unittest.TestCase): + @classmethod + def setUpClass(cls): + os.environ.setdefault("MDB_URI", "mongodb://example/test") + + fastapi = types.ModuleType("fastapi") + + class FastAPI: + def __init__(self, *args, **kwargs): + self.routes = [] + + def get(self, path, **kwargs): + def wrap(fn): + self.routes.append(types.SimpleNamespace(path=path, endpoint=fn)) + return fn + + return wrap + + fastapi.FastAPI = FastAPI + sys.modules["fastapi"] = fastapi + + beanie = types.ModuleType("beanie") + class Document: + pass + beanie.Document = Document + async def init_beanie(*args, **kwargs): + return None + beanie.init_beanie = init_beanie + sys.modules["beanie"] = beanie + + target = Path(__file__).resolve().parents[1] / "examples" / "why" / "why" / "__init__.py" + spec = importlib.util.spec_from_file_location("docbridge_why", target) + cls.mod = importlib.util.module_from_spec(spec) + spec.loader.exec_module(cls.mod) + + def test_read_item_calls_profile_query(self): + class FakeProfile: + @staticmethod + async def find_one(query): + return {"user_id": query["user_id"]} + + self.mod.Profile = FakeProfile + result = asyncio.run(self.mod.read_item("u1")) + self.assertEqual(result["user_id"], "u1") + + +if __name__ == "__main__": + unittest.main() From 130354d161f138fcf13d5e2cf30cab0102aa1266 Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 16:02:29 +0300 Subject: [PATCH 6/8] test: add integration tests against real MongoDB - tests/test_integration.py: per-repo pytest tests that connect to a real MongoDB instance and exercise the actual collection schema with CRUD operations - tests/__init__.py: makes tests a package so pytest resolves modules correctly - .github/workflows/ci.yml: adds mongo:latest service container (health-checked, port 27017) and a step that runs pytest tests/test_integration.py with MONGODB_URI pointing at the service container credentials Pattern follows mongodb-developer/mern-stack-example PR #51. --- .github/workflows/ci.yml | 22 +++++ tests/__init__.py | 0 tests/test_integration.py | 175 ++++++++++++++++++++++++++++++++++++++ 3 files changed, 197 insertions(+) create mode 100644 tests/__init__.py create mode 100644 tests/test_integration.py diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index b8014ec..fb942d2 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -9,6 +9,20 @@ jobs: smoke: runs-on: ubuntu-latest + services: + mongodb: + image: mongo:latest + options: >- + --health-cmd mongosh + --health-interval 10s + --health-timeout 5s + --health-retries 5 + ports: + - 27017:27017 + env: + MONGO_INITDB_ROOT_USERNAME: admin + MONGO_INITDB_ROOT_PASSWORD: mongodb + steps: - name: Checkout uses: actions/checkout@v4 @@ -98,3 +112,11 @@ jobs: echo "No runtime smoke test file found" exit 1 fi + + - name: Install integration test dependencies + run: pip install pytest pymongo + + - name: Run integration tests + env: + MONGODB_URI: mongodb://admin:mongodb@localhost:27017/ + run: pytest tests/test_integration.py -v diff --git a/tests/__init__.py b/tests/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/tests/test_integration.py b/tests/test_integration.py new file mode 100644 index 0000000..55e5011 --- /dev/null +++ b/tests/test_integration.py @@ -0,0 +1,175 @@ +"""Integration tests for docbridge. + +Tests real MongoDB CRUD operations for the profiles collection used by the +docbridge FastAPI + Beanie example. + +Requires a running MongoDB instance. Set MONGODB_URI (default: +mongodb://admin:mongodb@localhost:27017/) or the tests will be skipped. +""" + +import os +import asyncio +import pytest +from datetime import datetime +from pymongo import MongoClient +from bson import ObjectId + +MONGODB_URI = os.environ.get("MONGODB_URI", "mongodb://admin:mongodb@localhost:27017/") +TEST_DB = "docbridge_integration_test" + + +@pytest.fixture(scope="module") +def db(): + client = MongoClient(MONGODB_URI, serverSelectionTimeoutMS=2000) + try: + client.admin.command("ping") + except Exception: + client.close() + pytest.skip(f"MongoDB not reachable at {MONGODB_URI}") + database = client[TEST_DB] + yield database + client.drop_database(TEST_DB) + client.close() + + +def test_mongodb_ping(): + client = MongoClient(MONGODB_URI, serverSelectionTimeoutMS=2000) + try: + result = client.admin.command("ping") + assert result.get("ok") == 1.0 + except Exception: + pytest.skip(f"MongoDB not reachable at {MONGODB_URI}") + finally: + client.close() + + +def test_profile_crud(db): + """profiles collection: insert, find, update, delete a profile.""" + profiles = db["profiles"] + + profile_id = ObjectId() + profile = { + "_id": profile_id, + "user_id": "u_001", + "user_name": "jdoe", + "full_name": "Jane Doe", + "birth_date": datetime(1990, 5, 15), + "email": "jane.doe@example.com", + "followers": [{"user_id": "u_002"}, {"user_id": "u_003"}], + } + + # Create + result = profiles.insert_one(profile) + assert result.inserted_id == profile_id + + # Read by user_id + found = profiles.find_one({"user_id": "u_001"}) + assert found["user_name"] == "jdoe" + assert found["full_name"] == "Jane Doe" + assert len(found["followers"]) == 2 + + # Update + profiles.update_one( + {"_id": profile_id}, + {"$push": {"followers": {"user_id": "u_004"}}} + ) + updated = profiles.find_one({"_id": profile_id}) + assert len(updated["followers"]) == 3 + + # Delete + delete_result = profiles.delete_one({"_id": profile_id}) + assert delete_result.deleted_count == 1 + assert profiles.find_one({"_id": profile_id}) is None + + +def test_profile_not_found(db): + """profiles collection: querying a non-existent user_id returns None.""" + profiles = db["profiles"] + assert profiles.find_one({"user_id": "nonexistent_user"}) is None + + +def test_profile_follower_query(db): + """profiles collection: query profiles that have a specific follower.""" + profiles = db["profiles"] + + ids = [ObjectId(), ObjectId()] + docs = [ + { + "_id": ids[0], + "user_id": "u_010", + "user_name": "alice", + "full_name": "Alice Smith", + "birth_date": datetime(1992, 3, 10), + "email": "alice@example.com", + "followers": [{"user_id": "u_999"}], + }, + { + "_id": ids[1], + "user_id": "u_011", + "user_name": "bob", + "full_name": "Bob Jones", + "birth_date": datetime(1988, 7, 20), + "email": "bob@example.com", + "followers": [], + }, + ] + profiles.insert_many(docs) + + followed_by_999 = list( + profiles.find({"followers.user_id": "u_999", "_id": {"$in": ids}}) + ) + assert len(followed_by_999) == 1 + assert followed_by_999[0]["user_name"] == "alice" + + # Cleanup + profiles.delete_many({"_id": {"$in": ids}}) + + +def test_read_item_via_beanie(db): + """Run the read_item endpoint logic against real MongoDB via Beanie.""" + try: + from beanie import init_beanie, Document + from pymongo import AsyncMongoClient + from pydantic import BaseModel, Field + + class Follower(BaseModel): + user_id: str + + class ProfileDoc(Document): + user_id: str + user_name: str + full_name: str + birth_date: datetime + email: str + followers: list + + class Settings: + name = "profiles" + + async def _run(): + client = AsyncMongoClient(MONGODB_URI, serverSelectionTimeoutMS=3000) + database = client[TEST_DB] + await init_beanie(database=database, document_models=[ProfileDoc]) + + # Insert via Beanie + p = ProfileDoc( + user_id="u_beanie_test", + user_name="beanie_user", + full_name="Beanie Tester", + birth_date=datetime(1995, 1, 1), + email="beanie@test.com", + followers=[], + ) + await p.insert() + + # Query via Beanie (mimics read_item endpoint) + found = await ProfileDoc.find_one({"user_id": "u_beanie_test"}) + assert found is not None + assert found.user_name == "beanie_user" + + await found.delete() + client.close() + + asyncio.run(_run()) + except ImportError: + pytest.skip("beanie not installed") From 9a9bc9681e98f0c462d0805a6c556dd057a9a3d7 Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 16:17:15 +0300 Subject: [PATCH 7/8] fix: add missing stubs so runtime test runs without app deps installed --- tests/test_runtime.py | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/tests/test_runtime.py b/tests/test_runtime.py index 3814f5c..f341bdc 100644 --- a/tests/test_runtime.py +++ b/tests/test_runtime.py @@ -37,6 +37,23 @@ async def init_beanie(*args, **kwargs): beanie.init_beanie = init_beanie sys.modules["beanie"] = beanie + pydantic = types.ModuleType("pydantic") + class BaseModel: + def __init__(self, **kwargs): + for k, v in kwargs.items(): + setattr(self, k, v) + pydantic.BaseModel = BaseModel + pydantic.Field = lambda default=None, **kw: default + sys.modules["pydantic"] = pydantic + + pymongo = types.ModuleType("pymongo") + class AsyncMongoClient: + def __init__(self, *a, **kw): pass + def __getitem__(self, name): return {} + def get_database(self, name=None): return {} + pymongo.AsyncMongoClient = AsyncMongoClient + sys.modules["pymongo"] = pymongo + target = Path(__file__).resolve().parents[1] / "examples" / "why" / "why" / "__init__.py" spec = importlib.util.spec_from_file_location("docbridge_why", target) cls.mod = importlib.util.module_from_spec(spec) From f15f860e061389b476baead4a19f4a7acb324d9b Mon Sep 17 00:00:00 2001 From: sis0k0 Date: Fri, 22 May 2026 17:32:12 +0300 Subject: [PATCH 8/8] fix: install pytest-asyncio for conftest.py --- .github/workflows/ci.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index fb942d2..7db0b58 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -114,7 +114,7 @@ jobs: fi - name: Install integration test dependencies - run: pip install pytest pymongo + run: pip install pytest pymongo pytest-asyncio - name: Run integration tests env: