mirror of
https://github.com/creyD/creyPY.git
synced 2026-04-12 19:30:30 +02:00
Compare commits
33 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| e381992f8e | |||
| 6d5411a8ae | |||
| 89351d714b | |||
| c24f8933fb | |||
| 0bed0e0da4 | |||
| 8463eef907 | |||
| 5903de2aad | |||
| 0bf89fe14d | |||
| d54146e05b | |||
| d6f79c3ed8 | |||
| 3f4a0ee00d | |||
| 714178d68f | |||
| c7e205f14b | |||
| 39ae74becb | |||
| 5f39966223 | |||
| c91e684f08 | |||
| f11b8b8864 | |||
| 983553e97a | |||
| 8740eafce2 | |||
| aa44b9ebe9 | |||
| 851573d964 | |||
| cfa1da08d3 | |||
| 4a5a777ef5 | |||
| c9a9b1bc0a | |||
| d9f6e82736 | |||
| 65e93a023b | |||
|
|
6ce0cfbd14 | ||
|
|
da7ec0b28e | ||
| 2727c452b6 | |||
| be7d7ddb22 | |||
| 3f0379290d | |||
|
|
fa7a1c8a61 | ||
| 5a7e1776db |
28
.github/workflows/ci.yml
vendored
28
.github/workflows/ci.yml
vendored
@@ -4,12 +4,16 @@ on:
|
||||
push:
|
||||
branches:
|
||||
- master
|
||||
- dev
|
||||
paths-ignore:
|
||||
- "**/.github/**"
|
||||
- "**/.gitignore"
|
||||
- "**/.vscode/**"
|
||||
- "**/README.md"
|
||||
- "**/CHANGELOG.md"
|
||||
pull_request:
|
||||
branches:
|
||||
- master
|
||||
- dev
|
||||
workflow_dispatch:
|
||||
|
||||
jobs:
|
||||
@@ -42,6 +46,7 @@ jobs:
|
||||
|
||||
tag_and_publish:
|
||||
runs-on: ubuntu-latest
|
||||
if: github.head_ref == 'master' || github.head_ref == 'dev'
|
||||
needs: test
|
||||
permissions:
|
||||
id-token: write # IMPORTANT: this permission is mandatory for trusted publishing
|
||||
@@ -51,7 +56,7 @@ jobs:
|
||||
- uses: actions/checkout@v4
|
||||
with:
|
||||
fetch-tags: true
|
||||
ref: ${{ github.ref }}
|
||||
ref: ${{ github.head_ref }}
|
||||
fetch-depth: 0
|
||||
|
||||
- name: setup git
|
||||
@@ -60,17 +65,20 @@ jobs:
|
||||
git config --local user.name "creyD"
|
||||
|
||||
- name: Git Version
|
||||
uses: codacy/git-version@2.8.0
|
||||
uses: PaulHatch/semantic-version@v5.4.0
|
||||
id: git_version
|
||||
with:
|
||||
minor-identifier: "feat:"
|
||||
major-identifier: "breaking:"
|
||||
tag_prefix: ""
|
||||
major_pattern: "breaking:"
|
||||
minor_pattern: "feat:"
|
||||
enable_prerelease_mode: false
|
||||
version_format: "${major}.${minor}.${patch}rc${increment}"
|
||||
|
||||
- name: Create Tag
|
||||
run: git tag ${{ steps.git_version.outputs.version }}
|
||||
|
||||
- name: Push tag
|
||||
run: git push origin ${{ steps.git_version.outputs.version }}
|
||||
- name: Create & Push Tag
|
||||
if: github.head_ref == 'master' || github.head_ref == 'dev'
|
||||
run: |
|
||||
git tag ${{ steps.git_version.outputs.version }}
|
||||
git push origin ${{ steps.git_version.outputs.version }}
|
||||
|
||||
- name: Set up Python
|
||||
uses: actions/setup-python@v5
|
||||
|
||||
8
.vscode/settings.json
vendored
8
.vscode/settings.json
vendored
@@ -26,10 +26,16 @@
|
||||
"**/db.sqlite3": true,
|
||||
"**/.DS_Store": true,
|
||||
"**/*.pyc": true,
|
||||
"**/__pycache__/": true
|
||||
"**/__pycache__/": true,
|
||||
"**/build": true,
|
||||
"**/dist": true,
|
||||
"**/*.egg-info": true,
|
||||
},
|
||||
"search.exclude": {
|
||||
"**/.git": true,
|
||||
"**/build": true,
|
||||
"**/*.egg-info": true,
|
||||
"**/dist": true,
|
||||
"**/.venv": true,
|
||||
"**/tmp": true,
|
||||
"htmlcov/*": true,
|
||||
|
||||
29
CHANGELOG.md
29
CHANGELOG.md
@@ -2,7 +2,34 @@
|
||||
|
||||
All notable changes to this project will be documented in this file.
|
||||
|
||||
## 1.2.X
|
||||
## 2.0.0
|
||||
|
||||
- Fixed #1 Rename misspelled additonal_data to additional_data on create_obj_from_data
|
||||
- Fixed #3 Inverse partial flag: bool = False because it was wrong on update_obj_from_data
|
||||
|
||||
Notes:
|
||||
|
||||
You will need to change calls to `create_obj_from_data` according to #1 (rename additonal_data to additional_data)
|
||||
|
||||
You will need to change calls to `update_obj_from_data` according to #3 (if you supplied `partial`, you will need to reverse it: `true` -> `false` and `false` -> `true`)
|
||||
|
||||
## 1.3.0
|
||||
|
||||
- Addition of pagination proxy and pagination=off functionality (Thanks to @vikbhas)
|
||||
|
||||
## 1.2.5
|
||||
|
||||
- Bumped dependencies
|
||||
|
||||
## 1.2.4
|
||||
|
||||
- Enabled newer versions for all dependencies
|
||||
|
||||
## 1.2.3
|
||||
|
||||
- Added option to specify lookup_column for get_object_or_404
|
||||
|
||||
## 1.2.2
|
||||
|
||||
- Added order_by method
|
||||
|
||||
|
||||
@@ -10,8 +10,10 @@ from .models.base import Base
|
||||
T = TypeVar("T", bound=Base)
|
||||
|
||||
|
||||
def get_object_or_404(db_class: Type[T], id: UUID | str, db: Session, expunge: bool = False) -> T:
|
||||
obj = db.query(db_class).filter(db_class.id == id).one_or_none()
|
||||
def get_object_or_404(
|
||||
db_class: Type[T], id: UUID | str, db: Session, expunge: bool = False, lookup_column: str = "id"
|
||||
) -> T:
|
||||
obj = db.query(db_class).filter(getattr(db_class, lookup_column) == id).one_or_none()
|
||||
if obj is None:
|
||||
raise HTTPException(status_code=404, detail="The object does not exist.")
|
||||
if expunge:
|
||||
@@ -21,9 +23,9 @@ def get_object_or_404(db_class: Type[T], id: UUID | str, db: Session, expunge: b
|
||||
|
||||
# TODO: Add testing
|
||||
def create_obj_from_data(
|
||||
data: BaseModel, model: Type[T], db: Session, additonal_data={}, exclude={}
|
||||
data: BaseModel, model: Type[T], db: Session, additional_data={}, exclude={}
|
||||
) -> T:
|
||||
obj = model(**data.model_dump(exclude=exclude) | additonal_data)
|
||||
obj = model(**data.model_dump(exclude=exclude) | additional_data)
|
||||
db.add(obj)
|
||||
db.commit()
|
||||
db.refresh(obj)
|
||||
@@ -36,13 +38,13 @@ def update_obj_from_data(
|
||||
model: Type[T],
|
||||
id: UUID | str,
|
||||
db: Session,
|
||||
partial: bool = False, # TODO: inverse, because it is currently the wrong way around
|
||||
partial: bool = True,
|
||||
ignore_fields=[],
|
||||
additional_data={},
|
||||
exclude={},
|
||||
) -> T:
|
||||
obj = get_object_or_404(model, id, db)
|
||||
data_dict = data.model_dump(exclude_unset=not partial, exclude=exclude)
|
||||
data_dict = data.model_dump(exclude_unset=partial, exclude=exclude)
|
||||
data_dict.update(additional_data) # merge additional_data into data_dict
|
||||
for field in data_dict:
|
||||
if field not in ignore_fields:
|
||||
|
||||
@@ -1,10 +1,21 @@
|
||||
from math import ceil
|
||||
from typing import Any, Generic, Optional, Self, Sequence, TypeVar
|
||||
from typing import Any, Generic, Optional, Self, Sequence, TypeVar, Union
|
||||
|
||||
from fastapi_pagination import Params
|
||||
from fastapi_pagination.bases import AbstractPage, AbstractParams
|
||||
from fastapi_pagination.types import GreaterEqualOne, GreaterEqualZero
|
||||
from fastapi_pagination.types import (
|
||||
GreaterEqualOne,
|
||||
GreaterEqualZero,
|
||||
AdditionalData,
|
||||
SyncItemsTransformer,
|
||||
)
|
||||
from fastapi_pagination.api import create_page, apply_items_transformer
|
||||
from fastapi_pagination.utils import verify_params
|
||||
from fastapi_pagination.ext.sqlalchemy import create_paginate_query
|
||||
from pydantic.json_schema import SkipJsonSchema
|
||||
from sqlalchemy.sql.selectable import Select
|
||||
from sqlalchemy.orm.session import Session
|
||||
from sqlalchemy import select, func
|
||||
|
||||
T = TypeVar("T")
|
||||
|
||||
@@ -70,3 +81,44 @@ def parse_page(response, page: int, size: int) -> Page:
|
||||
has_next=response.has_next,
|
||||
has_prev=response.has_prev,
|
||||
)
|
||||
|
||||
|
||||
def create_count_query(query: Select) -> Select:
|
||||
return select(func.count()).select_from(query.subquery())
|
||||
|
||||
|
||||
def unwrap_scalars(
|
||||
items: Sequence[Sequence[T]],
|
||||
force_unwrap: bool = True,
|
||||
) -> Union[Sequence[T], Sequence[Sequence[T]]]:
|
||||
return [item[0] if force_unwrap else item for item in items]
|
||||
|
||||
|
||||
def paginate(
|
||||
connection: Session,
|
||||
query: Select,
|
||||
paginationFlag: bool = True,
|
||||
params: Optional[AbstractParams] = None,
|
||||
transformer: Optional[SyncItemsTransformer] = None,
|
||||
additional_data: Optional[AdditionalData] = None,
|
||||
):
|
||||
params, _ = verify_params(params, "limit-offset", "cursor")
|
||||
|
||||
count_query = create_count_query(query)
|
||||
total = connection.scalar(count_query)
|
||||
|
||||
if paginationFlag is False:
|
||||
params = Params(page=1, size=total)
|
||||
|
||||
query = create_paginate_query(query, params)
|
||||
items = connection.execute(query).all()
|
||||
|
||||
items = unwrap_scalars(items)
|
||||
t_items = apply_items_transformer(items, transformer)
|
||||
|
||||
return create_page(
|
||||
t_items,
|
||||
params=params,
|
||||
total=total,
|
||||
**(additional_data or {}),
|
||||
)
|
||||
|
||||
@@ -1,27 +1,27 @@
|
||||
certifi==2024.2.2
|
||||
charset-normalizer==3.3.2
|
||||
docutils==0.20.1
|
||||
idna==3.6
|
||||
importlib_metadata==7.1.0
|
||||
jaraco.classes==3.4.0
|
||||
jaraco.context==4.3.0
|
||||
jaraco.functools==4.0.0
|
||||
keyring==25.0.0
|
||||
markdown-it-py==3.0.0
|
||||
mdurl==0.1.2
|
||||
more-itertools==10.2.0
|
||||
nh3==0.2.17
|
||||
pkginfo==1.10.0
|
||||
Pygments==2.17.2
|
||||
readme_renderer==43.0
|
||||
requests==2.31.0
|
||||
requests-toolbelt==1.0.0
|
||||
rfc3986==2.0.0
|
||||
rich==13.7.1
|
||||
setuptools==69.2.0
|
||||
twine==5.0.0
|
||||
urllib3==2.2.1
|
||||
wheel==0.43.0
|
||||
zipp==3.18.1
|
||||
certifi>=2024.2.2
|
||||
charset-normalizer>=3.3.2
|
||||
docutils>=0.20.1
|
||||
idna>=3.6
|
||||
importlib_metadata>=7.1.0
|
||||
jaraco.classes>=3.4.0
|
||||
jaraco.context>=4.3.0
|
||||
jaraco.functools>=4.0.0
|
||||
keyring>=25.0.0
|
||||
markdown-it-py>=3.0.0
|
||||
mdurl>=0.1.2
|
||||
more-itertools>=10.2.0
|
||||
nh3>=0.2.17
|
||||
pkginfo>=1.10.0
|
||||
Pygments>=2.17.2
|
||||
readme_renderer>=43.0
|
||||
requests>=2.31.0
|
||||
requests-toolbelt>=1.0.0
|
||||
rfc3986>=2.0.0
|
||||
rich>=13.7.1
|
||||
setuptools>=69.2.0
|
||||
twine>=5.0.0
|
||||
urllib3>=2.2.1
|
||||
wheel>=0.43.0
|
||||
zipp>=3.18.1
|
||||
|
||||
-r requirements.txt
|
||||
|
||||
@@ -1,23 +1,23 @@
|
||||
annotated-types==0.6.0 # Pydantic
|
||||
pydantic==2.6.4 # Pydantic
|
||||
pydantic-core==2.16.3 # Pydantic
|
||||
typing-extensions==4.10.0 # Pydantic
|
||||
annotated-types>=0.7.0 # Pydantic
|
||||
pydantic>=2.8.2 # Pydantic
|
||||
pydantic-core>=2.20.1 # Pydantic
|
||||
typing-extensions>=4.12.2 # Pydantic
|
||||
|
||||
anyio==4.3.0 # FastAPI
|
||||
fastapi==0.110.1 # FastAPI
|
||||
idna==3.6 # FastAPI
|
||||
sniffio==1.3.1 # FastAPI
|
||||
starlette==0.37.2 # FastAPI
|
||||
anyio>=4.4.0 # FastAPI
|
||||
fastapi>=0.111.0 # FastAPI
|
||||
idna>=3.7 # FastAPI
|
||||
sniffio>=1.3.1 # FastAPI
|
||||
starlette>=0.37.2 # FastAPI
|
||||
|
||||
fastapi-pagination==0.12.21 # Pagination
|
||||
sqlalchemy==2.0.29 # SQLAlchemy
|
||||
fastapi-pagination>=0.12.26 # Pagination
|
||||
sqlalchemy>=2.0.31 # SQLAlchemy
|
||||
|
||||
python-dotenv==1.0.1 # Environment variables
|
||||
python-dotenv>=1.0.1 # Environment variables
|
||||
|
||||
psycopg==3.1.18 # PostgreSQL
|
||||
psycopg-binary==3.1.18 # PostgreSQL
|
||||
psycopg-pool==3.2.1 # PostgreSQL
|
||||
psycopg>=3.2.1 # PostgreSQL
|
||||
psycopg-binary>=3.2.1 # PostgreSQL
|
||||
psycopg-pool>=3.2.2 # PostgreSQL
|
||||
|
||||
h11==0.14.0 # Testing
|
||||
httpcore==1.0.5 # Testing
|
||||
httpx==0.27.0 # Testing
|
||||
h11>=0.14.0 # Testing
|
||||
httpcore>=1.0.5 # Testing
|
||||
httpx>=0.27.0 # Testing
|
||||
|
||||
Reference in New Issue
Block a user