crud.py

import schemas
from fastapi import HTTPException,status
from helpers import hash_password

import models
from sqlalchemy.orm import Session



class UserCrud():

    @staticmethod
    def create_user(request:schemas.User,db:Session):
        if request.password1 != request.password2:
            raise HTTPException(status_code=status.HTTP_403_FORBIDDEN,detail="passwords do not match")
        if len(request.password1) < 6 :
            raise HTTPException(status_code=status.HTTP_403_FORBIDDEN,detail="make password 6 characters")
        cleaned_password = hash_password(request.password1)
        new_user = models.UserModel(email=request.email,username=request.username,first_name = request.first_name,last_name = request.last_name,phoneNumber= request.phoneNumber,password=cleaned_password)
        db.add(new_user)
        db.commit()
        db.refresh(new_user)
        return new_user

    @staticmethod
    def update(id:int,db:Session,request:schemas.UserUpdate):
        user = db.query(models.UserModel).filter(models.UserModel.id == id)
        if not user:
            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND,detail="user not found")
        user.update(request.dict(exclude_unset=True),synchronize_session=False)
        db.commit()
        return "user updated"


class AdminCrud():

    @staticmethod
    def create_admin_user(request:schemas.User,db:Session):
        if request.password1 != request.password2:
            raise HTTPException(status_code=status.HTTP_403_FORBIDDEN,detail="passwords do not match")
        if len(request.password1) < 6 :
            raise HTTPException(status_code=status.HTTP_403_FORBIDDEN,detail="make password 6 characters")
        cleaned_password = hash_password(request.password1)
        new_user = models.AdminModel(email=request.email,username=request.username,first_name = request.first_name,last_name = request.last_name,phoneNumber= request.phoneNumber,password=cleaned_password)
        db.add(new_user)
        db.commit()
        db.refresh(new_user)
        return new_user

    @staticmethod
    def update(id:int,db:Session,request:schemas.UserUpdate):
        user = db.query(models.AdminModel).filter(models.AdminModel.id == id)
        if not user:
            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND,detail="admin not found")
        user.update(request.dict(exclude_unset=True),synchronize_session=False)
        db.commit()
        return "admin updated"

    



class BlogCrud():


    @staticmethod
    def create_post(post:schemas.Posts,db:Session,user:dict):
        """create a new blogpost"""
        new_post = models.BlogModel(title=post.title,body=post.body,user_id=user.id)
        db.add(new_post)
        db.commit()
        db.refresh(new_post)
        return new_post


    @staticmethod
    def delete(db:Session,id:int,):
        post = db.query(models.BlogModel).filter(models.BlogModel.id == id)
        if not post:
            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND,detail=f"post with id {id} not found")
        post.delete(synchronize_session=False)
        db.commit()
        return {"post deleted successfully"}


    @staticmethod
    def update(db:Session,id:int,request):
        post = db.query(models.BlogModel).filter(models.BlogModel.id == id)
        if not post:
            raise HTTPException(status_code=status.HTTP_404_NOT_FOUND,detail=f"post with id {id} not found")
        post.update(request.dict(exclude_unset=True))
        db.commit()
        return {"post updated"}