Add yet broken tests

Author: insani7y

.gitignore

@@ -0,0 +1,64 @@
+.idea/
+.vscode/
+# Byte-compiled / optimized / DLL files
+pycache/
+__pycache__
+*.py[cod]
+*$py.class
+__test*
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+cover/
+
+# Environments
+.env
+.gen.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Cython debug symbols
+cython_debug/

piccolo_conf.py

@@ -0,0 +1,32 @@
+"""This piccolo_conf file is just here so migrations can be made for Piccolo's own internal apps.
+
+For example:
+
+python -m piccolo.main migration new user --auto
+
+"""
+
+import os
+
+from piccolo.conf.apps import AppRegistry
+
+from psqlpy_piccolo import PSQLPyEngine as Engine
+
+DB = Engine(
+    config={
+        "host": os.environ.get("PG_HOST", "127.0.0.1"),
+        "port": os.environ.get("PG_PORT", 5432),
+        "user": os.environ.get("PG_USER", "postgres"),
+        "password": os.environ.get("PG_PASSWORD", "postgres"),
+        "database": os.environ.get("PG_DATABASE", "piccolo"),
+    },
+)
+
+# from piccolo.apps.migrations.tables
+APP_REGISTRY = AppRegistry(
+    apps=[
+        "piccolo.apps.migrations.piccolo_app",
+        "tests.test_apps.mega.piccolo_app",
+        "tests.test_apps.music.piccolo_app",
+    ],
+)

poetry.lock

@@ -0,0 +1,5 @@
+"""Package with piccolo engine based on psqlpy driver."""
+
+from psqlpy_piccolo.engine import PSQLPyEngine
+
+__all__ = ("PSQLPyEngine",)

psqlpy_piccolo/__init__.py

@@ -530,10 +530,13 @@ async def start_connection_pool(self: Self, **kwargs: Dict[str, Any]) -> None:
         else:
             config = dict(self.config)
             config.update(**kwargs)
+            print("----------------")
+            print(config)
+            print("----------------")
             self.pool = ConnectionPool(
                 db_name=config.pop("database", None),
                 username=config.pop("user", None),
-                max_db_pool_size=config.pop("max_size"),
+                max_db_pool_size=config.pop("max_size", 2),
                 **config,
             )
 
@@ -622,7 +625,6 @@ async def _run_in_new_connection(
         Result from the database as a list of dicts.
         """
         connection = await self.get_new_connection()
-
         try:
             results = await connection.execute(
                 querystring=query,
@@ -647,6 +649,9 @@ async def run_querystring(
         ### Returns:
         Result from the database as a list of dicts.
         """
+        print("------------------")
+        print("RUN", querystring)
+        print("------------------")
         query, query_args = querystring.compile_string(engine_type=self.engine_type)
 
         query_id = self.get_query_id()
@@ -669,7 +674,7 @@ async def run_querystring(
 
         if self.log_responses:
             self.print_response(query_id=query_id, response=response)
-
+        print(response)
         return response
 
     async def run_ddl(

psqlpy_piccolo/__pycache__/__init__.cpython-312.pyc

@@ -8,14 +8,21 @@ readme = "README.md"
 [tool.poetry.dependencies]
 python = "^3.8"
 psqlpy = "^0.6.0"
-piccolo = "^1.12.0"
+piccolo = {version = "^1.13.1", extras = ["postgres"]}
 
 
 [tool.poetry.group.lint.dependencies]
 ruff = "^0.4.7"
 black = "^24.4.2"
 isort = "^5.13.2"
 
+
+[tool.poetry.group.dev.dependencies]
+anyio = "^4.4.0"
+pytest = "^8.3.1"
+pytest-cov = "^5.0.0"
+trio = "^0.26.0"
+
 [build-system]
 requires = ["poetry-core"]
 build-backend = "poetry.core.masonry.api"

psqlpy_piccolo/__pycache__/engine.cpython-312.pyc

@@ -0,0 +1,8 @@
+import pytest
+
+pytestmark = [pytest.mark.anyio]
+
+
+@pytest.fixture(scope="session", autouse=True)
+def anyio_backend() -> str:
+    return "asyncio"