Add sample app that uses distributed fastapi_allauth

Author: ArtyomVancyan

examples/DogeAPI/.gitignore

@@ -0,0 +1,130 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+pip-wheel-metadata/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+db.sqlite3-journal
+blog.db
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# IPython
+profile_default/
+ipython_config.py
+
+# pyenv
+.python-version
+
+# pipenv
+#   According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
+#   However, in case of collaboration, if having platform-specific dependencies or dependencies
+#   having no cross-platform support, pipenv may install dependencies that don't work, or not
+#   install all needed dependencies.
+#Pipfile.lock
+
+# PEP 582; used by e.g. github.com/David-OConnor/pyflow
+__pypackages__/
+
+# Celery stuff
+celerybeat-schedule
+celerybeat.pid
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Pyre type checker
+.pyre/

examples/DogeAPI/api/blog.py

@@ -0,0 +1,113 @@
+#!/usr/bin/python3
+
+from fastapi import HTTPException, status
+from sqlalchemy.orm import Session
+
+from models import models
+from schema import schemas
+
+
+def get_all(db: Session):
+    """
+    Get all blogs
+
+    Args:
+        db (Session): Database session
+
+    Returns:
+        List[models.Blog]: List of blogs
+    """
+    return db.query(models.Blog).all()
+
+
+def create(request: schemas.Blog, db: Session):
+    """
+    Create a new blog
+
+    Args:
+        request (schemas.Blog): Blog object
+        db (Session): Database session
+
+    Returns:
+        models.Blog: Blog object
+    """
+    new_blog = models.Blog(title=request.title, body=request.body)
+    db.add(new_blog)
+    db.commit()
+    db.refresh(new_blog)
+    return new_blog
+
+
+def destroy(id: int, db: Session):
+    """
+    Delete a blog
+
+    Args:
+        id (int): Blog id
+        db (Session): Database session
+
+    Raises:
+        HTTPException: 404 not found
+
+    Returns:
+        str: Success message
+    """
+    blog_to_delete = db.query(models.Blog).filter(models.Blog.id == id)
+
+    if not blog_to_delete.first():
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail=f"Blog with id {id} not found.",
+        )
+    blog_to_delete.delete(synchronize_session=False)
+    db.commit()
+    return {"done"}
+
+
+def update(id: int, request: schemas.Blog, db: Session):
+    """
+    Update a blog
+
+    Args:
+        id (int): Blog id
+        request (schemas.Blog): Blog object
+        db (Session): Database session
+
+    Raises:
+        HTTPException: 404 not found
+
+    Returns:
+        models.Blog: Blog object
+    """
+    blog = db.query(models.Blog).filter(models.Blog.id == id)
+    if not blog.first():
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND, detail=f"Blog with id {id} not found"
+        )
+    blog.update(request.__dict__)
+    db.commit()
+    return "updated"
+
+
+def show(id: int, db: Session):
+    """
+    Get a blog
+
+    Args:
+        id (int): Blog id
+        db (Session): Database session
+
+    Raises:
+        HTTPException: 404 not found
+
+    Returns:
+        models.Blog: Blog object
+    """
+    blog = db.query(models.Blog).filter(models.Blog.id == id).first()
+    if blog:
+        return blog
+    else:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail=f"Blog with the id {id} is not available",
+        )

examples/DogeAPI/api/user.py

@@ -0,0 +1,62 @@
+#!/usr/bin/python3
+
+from fastapi import HTTPException, status
+from sqlalchemy.orm import Session
+
+from models import models
+from schema import schemas
+from schema.hash import Hash
+
+
+def create(request: schemas.User, db: Session):
+    """
+    Create a new user
+
+    Args:
+        request (schemas.User): User data
+        db (Session): Database session
+
+    Returns:
+        models.User: User created
+    """
+    hashedPassword = Hash.bcrypt(request.password)
+    user = models.User(name=request.name, email=request.email, password=hashedPassword)
+    db.add(user)
+    db.commit()
+    db.refresh(user)
+    return user
+
+
+def show(id: int, db: Session):
+    """
+    Show a user
+
+    Args:
+        id (int): User id
+        db (Session): Database session
+
+    Raises:
+        HTTPException: User not found
+
+    Returns:
+        models.User: User found
+    """
+    user = db.query(models.User).filter(models.User.id == id).first()
+    if not user:
+        raise HTTPException(
+            status.HTTP_404_NOT_FOUND, detail=f"User with id {id} not found"
+        )
+    return user
+
+
+def get_all(db: Session):
+    """
+    Get all users
+
+    Args:
+        db (Session): Database session
+
+    Returns:
+        list: List of users
+    """
+    return db.query(models.User).all()

examples/DogeAPI/core/auth.py

@@ -0,0 +1,53 @@
+#!/usr/bin/python3
+
+
+from fastapi import APIRouter, Depends, HTTPException, status
+from fastapi.security.oauth2 import OAuth2PasswordRequestForm
+from sqlalchemy.orm import Session
+
+from database import configuration
+from models import models
+from schema import schemas
+from schema.hash import Hash
+from schema.token import create_access_token
+
+router = APIRouter(prefix="/login", tags=["Authentication"],)
+
+
+@router.post("/")
+def login(
+    request: OAuth2PasswordRequestForm = Depends(),
+    db: Session = Depends(configuration.get_db),
+):
+    """
+    Login user
+
+    Args:
+        request (OAuth2PasswordRequestForm, optional): OAuth2PasswordRequestForm.
+        db (Session, optional): Session. Defaults to Depends(configuration.get_db).
+
+    Raises:
+        HTTPException: 401 Unauthorized
+        HTTPException: 404 Not Found
+
+    Returns:
+        Hash: Hash
+    """
+    user: schemas.User = db.query(models.User).filter(
+        models.User.email == request.username
+    ).first()
+    if not user:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND, detail="Invalid Credentials"
+        )
+
+    if not Hash.verify(user.password, request.password):
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND, detail="Incorrect password"
+        )
+
+    # access_token_expires = timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES)
+    access_token = create_access_token(data={"sub": user.email})
+
+    # generate JWT token and return
+    return {"access_token": access_token, "token_type": "bearer"}