mirror of
https://github.com/creyD/creyPY.git
synced 2026-04-12 19:30:30 +02:00
Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| abe84bcfcb | |||
|
|
2d6de99585 | ||
|
|
573f59349f | ||
|
|
32bf089456 | ||
|
|
d75fede3d1 | ||
|
|
f8b781b3e7 | ||
|
|
93c7f6f6cb | ||
|
|
2e44453915 | ||
|
|
2a22471de9 | ||
| 2176b1a37d |
@@ -5,7 +5,9 @@ from sqlalchemy.orm import sessionmaker
|
||||
|
||||
from .common import SQLALCHEMY_DATABASE_URL, name
|
||||
|
||||
async_engine = create_async_engine(SQLALCHEMY_DATABASE_URL + name, pool_pre_ping=True)
|
||||
async_engine = create_async_engine(
|
||||
SQLALCHEMY_DATABASE_URL + name, pool_pre_ping=True, connect_args={"sslmode": "require"}
|
||||
)
|
||||
|
||||
AsyncSessionLocal = sessionmaker(
|
||||
bind=async_engine,
|
||||
|
||||
@@ -6,7 +6,9 @@ from sqlalchemy.orm.session import Session
|
||||
|
||||
from .common import SQLALCHEMY_DATABASE_URL, name
|
||||
|
||||
engine = create_engine(SQLALCHEMY_DATABASE_URL + name, pool_pre_ping=True)
|
||||
engine = create_engine(
|
||||
SQLALCHEMY_DATABASE_URL + name, pool_pre_ping=True, connect_args={"sslmode": "require"}
|
||||
)
|
||||
SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
|
||||
|
||||
|
||||
|
||||
@@ -41,7 +41,7 @@ class GenericClient(TestClient):
|
||||
re = self.c.post(
|
||||
url,
|
||||
files={"file": file},
|
||||
headers=self.default_headers | {"Content-Type": "application/json"},
|
||||
headers=self.default_headers,
|
||||
*args,
|
||||
**kwargs,
|
||||
)
|
||||
|
||||
@@ -1,11 +1,14 @@
|
||||
import json
|
||||
from httpx import AsyncClient
|
||||
|
||||
from httpx import ASGITransport, AsyncClient
|
||||
|
||||
|
||||
class AsyncGenericClient:
|
||||
def __init__(self, app):
|
||||
self.c = AsyncClient(app=app, base_url="http://testserver", follow_redirects=True)
|
||||
self.default_headers = {}
|
||||
def __init__(self, app, headers={}):
|
||||
self.c = AsyncClient(
|
||||
transport=ASGITransport(app=app), base_url="http://testserver", follow_redirects=True
|
||||
)
|
||||
self.default_headers = headers
|
||||
|
||||
async def get(self, url: str, r_code: int = 200, parse_json=True):
|
||||
re = await self.c.get(url, headers=self.default_headers)
|
||||
@@ -33,7 +36,8 @@ class AsyncGenericClient:
|
||||
)
|
||||
if re.status_code != r_code:
|
||||
print(re.content)
|
||||
assert r_code == re.status_code
|
||||
if not raw_response:
|
||||
assert r_code == re.status_code
|
||||
return re.json() if not raw_response else re
|
||||
|
||||
async def post_file(
|
||||
@@ -42,7 +46,7 @@ class AsyncGenericClient:
|
||||
re = await self.c.post(
|
||||
url,
|
||||
files={"file": file},
|
||||
headers=self.default_headers | {"Content-Type": "application/json"},
|
||||
headers=self.default_headers,
|
||||
*args,
|
||||
**kwargs,
|
||||
)
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
cachetools==5.5.0 # for caching
|
||||
charset-normalizer==3.4.0 # Auth0 API interactions
|
||||
requests==2.32.3 # Auth0 API interactions
|
||||
pyjwt==2.10.0 # Auth0 API interactions
|
||||
cffi==1.17.1 # Auth0 API interactions
|
||||
cryptography==43.0.3 # Auth0 API interactions
|
||||
pycparser==2.22 # Auth0 API interactions
|
||||
cachetools>=5.5.0 # for caching
|
||||
charset-normalizer>=3.4.0 # Auth0 API interactions
|
||||
requests>=2.32.3 # Auth0 API interactions
|
||||
pyjwt>=2.10.1 # Auth0 API interactions
|
||||
cffi>=1.17.1 # Auth0 API interactions
|
||||
cryptography>=43.0.3 # Auth0 API interactions
|
||||
pycparser>=2.22 # Auth0 API interactions
|
||||
|
||||
@@ -11,7 +11,7 @@ starlette>=0.37.2 # FastAPI
|
||||
|
||||
fastapi-pagination>=0.12.26 # Pagination
|
||||
sqlalchemy>=2.0.31 # SQLAlchemy
|
||||
sqlalchemy-utils==0.41.2 # For managing databases
|
||||
sqlalchemy-utils>=0.41.2 # For managing databases
|
||||
|
||||
python-dotenv>=1.0.1 # Environment variables
|
||||
|
||||
|
||||
Reference in New Issue
Block a user