Initial commit

Author: aspects19

.env.example

@@ -0,0 +1,3 @@
+.env
+app/__pycache__/
+.venv/

.gitignore

@@ -0,0 +1,42 @@
+from sqlalchemy.orm import Session
+from fastapi import HTTPException
+from app import schemas, models
+
+
+def get_user(db: Session, user_id: int):
+    return db.query(models.User).filter(models.User.id == user_id).first()
+
+def get_user_by_name(db: Session, name: str):
+    return db.query(models.User).filter(models.User.name == name).first()
+
+def get_users(db: Session, skip:int=0, limit:int=100):
+    return db.query(models.User).offset(skip).limit(limit).all()
+
+def create_user(db: Session, user:schemas.UserCreate):
+    existing_user = get_user_by_name(db, name=user.name)
+    if existing_user: 
+        raise HTTPException(status_code=400, detail="Username already taken")
+    db_user = models.User(name=user.name,
+                          premium_user=user.premium_user,
+                          payment_id=user.payment_id)
+    db.add(db_user)
+    db.commit()
+    db.refresh(db_user)
+    return db_user
+
+def update_user(db: Session, user_id: int, updated_user: schemas.UserCreate):
+    db_user = db.query(models.User).filter(models.User.id == user_id).first()
+    if db_user:
+        db_user.name = updated_user.name
+        db_user.premium_user = updated_user.premium_user
+        db_user.payment_id = updated_user.payment_id
+        db.commit()
+        db.refresh(db_user)
+    return db_user
+
+def delete_user(db: Session, user_id: int):
+    db_user = db.query(models.User).filter(models.User.id == user_id).first()
+    if db_user:
+        db.delete(db_user)
+        db.commit()
+    return db_user    

app/crud.py

@@ -0,0 +1,20 @@
+from sqlalchemy import create_engine
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.orm import sessionmaker
+from dotenv import load_dotenv
+import os
+
+load_dotenv()
+
+DB_URL = os.getenv("DB_URL")
+engine = create_engine(DB_URL,echo=True)
+SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+
+Base = declarative_base()
+
+def get_db():
+    db = SessionLocal()
+    try : 
+        yield db
+    finally:
+        db.close()

app/database.py

@@ -0,0 +1,15 @@
+from typing import Union
+
+from fastapi import FastAPI
+
+app = FastAPI()
+
+
+@app.get("/")
+def read_root():
+    return {"Hello": "World"}
+
+
+@app.get("/items/{item_id}")
+def read_item(item_id: int, q: Union[str, None] = None):
+    return {"item_id": item_id, "q": q}

app/main.py

@@ -0,0 +1,12 @@
+from sqlalchemy import Boolean, Column, Integer, String, DateTime
+from sqlalchemy.sql import func
+from app.database import Base
+
+class User(Base):
+    __tablename__ = "users"
+    id = Column(Integer, primary_key=True, index=True)
+    name = Column(String(255), unique=True, index=True)
+    premium_user = Column(Boolean)
+    payment_id = Column(String(255))
+    created_at = Column(DateTime(timezone=True), default=func.now() )
+    updated_at = Column(DateTime(timezone=True), default=func.now(), onupdate=func.now() )

app/models.py

@@ -0,0 +1,19 @@
+from pydantic import BaseModel
+from datetime import datetime
+
+class UserBase(BaseModel):
+    name: str
+    premium_user: bool
+    payment_id: str
+
+
+class UserCreate(UserBase):
+    pass 
+
+
+class User(UserBase):
+    id : int
+    created_at : datetime
+
+    class Config:
+        from_attributes = True

app/schemas.py

@@ -0,0 +1,34 @@
+annotated-types==0.7.0
+anyio==4.8.0
+certifi==2025.1.31
+click==8.1.8
+dnspython==2.7.0
+email_validator==2.2.0
+fastapi==0.115.10
+fastapi-cli==0.0.7
+h11==0.14.0
+httpcore==1.0.7
+httptools==0.6.4
+httpx==0.28.1
+idna==3.10
+Jinja2==3.1.5
+markdown-it-py==3.0.0
+MarkupSafe==3.0.2
+mdurl==0.1.2
+pydantic==2.10.6
+pydantic_core==2.27.2
+Pygments==2.19.1
+python-dotenv==1.0.1
+python-multipart==0.0.20
+PyYAML==6.0.2
+rich==13.9.4
+rich-toolkit==0.13.2
+shellingham==1.5.4
+sniffio==1.3.1
+starlette==0.46.0
+typer==0.15.2
+typing_extensions==4.12.2
+uvicorn==0.34.0
+uvloop==0.21.0
+watchfiles==1.0.4
+websockets==15.0