added project files and dockerfile

Dockerfile

@@ -0,0 +1,10 @@
+FROM python:3.9-slim
+WORKDIR /app
+COPY requirements.txt ./requirements.txt
+# Install uvicorn
+RUN pip install uvicorn
+# Install dependencies
+RUN pip install -r requirements.txt
+COPY . /app
+ENTRYPOINT ["uvicorn", "app:app"]
+CMD ["--host", "0.0.0.0", "--port", "7860"]

app.py

@@ -0,0 +1,10 @@
+from fastapi import FastAPI
+from routes.student_routes import router as StudentRouter
+
+app = FastAPI(title="FastAPI and MongoDB")
+app.include_router(StudentRouter, tags=["Student"], prefix="/student")
+
+
+@app.get("/", tags=["Root"])
+async def root():
+    return {"message": "FastAPI and MongoDB"}

database.py

@@ -0,0 +1,66 @@
+import motor.motor_asyncio
+import os
+from bson.objectid import ObjectId
+
+MONGO_DETAILS = os.getenv("MONGO_DETAILS")
+
+client = motor.motor_asyncio.AsyncIOMotorClient(MONGO_DETAILS)
+
+database = client.fastapi_students
+
+students_collection = database.get_collection("students")
+
+
+# helpers
+def student_helper(student) -> dict:
+    return {
+        "id": str(student["_id"]),
+        "name": student["name"],
+        "email": student["email"],
+        "password": student["password"],
+        "year": student["year"],
+        "branch": student["branch"],
+        "division": student["division"],
+        "pin": student["pin"],
+        "gpa": student["gpa"],
+        "phone": student["phone"],
+        "address": student["address"],
+    }
+
+# Retrieve all students present in the database
+
+
+async def get_all():
+    students = []
+    async for student in students_collection.find():
+        students.append(student_helper(student))
+    return students
+
+
+async def add(student_data: dict) -> dict:
+    student = await students_collection.insert_one(student_data)
+    new_student = await students_collection.find_one({"_id": student.inserted_id})
+    return student_helper(new_student)
+
+
+async def get(PIN: str) -> dict:
+    student = await students_collection.find_one({"pin": PIN})
+    if student:
+        return student_helper(student)
+
+async def update(PIN: str, updated_data: dict) -> dict:
+    if not updated_data:
+        return False
+    student = await students_collection.find_one({"pin": PIN})
+    if student:
+        students_collection.update_one({"pin": PIN}, {"$set": updated_data})
+        return True
+    return False
+
+
+async def delete(PIN: str):
+    student = await students_collection.find_one({"pin": PIN})
+    if student:
+        await students_collection.delete_one({"pin": PIN})
+        return True
+    return False

models/schema.py

@@ -0,0 +1,98 @@
+from typing import Optional
+from pydantic import BaseModel, Field, EmailStr
+
+
+class StudentSchema(BaseModel):
+    name: str = Field(..., example="John Doe",
+                      description="Name of the student")
+    email: EmailStr = Field(..., example="johndoe@gmail.com",
+                            description="Email of the student")
+    password: str = Field(..., example="JohnDoe123",
+                          description="Password of the student")
+    year: int = Field(..., gt=0, lt=5, example=1, description="Year of study")
+    branch: str = Field(..., min_length=3,
+                        example="CSE or Computer Science and Engineering", description="Branch of study")
+    division: str = Field(..., min_length=1, max_length=1,
+                          example="A", description="Division of study")
+    pin: str = Field(..., min_length=10, max_length=10,
+                     example="20KJ1A0501", description="PIN of the student")
+    gpa: Optional[float] = Field(
+        None, gt=0, lt=10, example=9.0, description="GPA of the student")
+    phone: int = Field(..., gt=1000000000, lt=9999999999,
+                       example=1234567890, description="Phone number of the student")
+    address: str = Field(..., min_length=3, max_length=100,
+                         example="123, 1st cross, 1st main, City, State, Country - 123456", description="Address of the student")
+
+    class Config:
+        schema_extra = {
+            "Example": {
+                "name": "John Doe",
+                "email": "Johndoe@example.com",
+                "password": "JohnDoe123",
+                "year": 1,
+                "branch": "CSE",
+                "division": "A",
+                "pin": "20KJ1A0501",
+                "gpa": 9.0,
+                "phone": 1234567890,
+                "address": """
+                    123, 1st cross, 1st main,
+                    City, State, Country - 123456""",
+            }
+        }
+
+
+class StudentUpdateSchema(BaseModel):
+    name: Optional[str] = Field(
+        None, example="John Doe", description="Name of the student")
+    email: Optional[EmailStr] = Field(
+        None, example="johndoe@example.com", description="Email")
+    password: Optional[str] = Field(
+        None, example="JohnDoe123", description="Password")
+    year: Optional[int] = Field(
+        None, gt=0, lt=5, example=1, description="Year of study")
+    branch: Optional[str] = Field(
+        None, min_length=3, example="CSE or Computer Science and Engineering", description="Branch of study")
+    division: Optional[str] = Field(
+        None, min_length=1, max_length=1, example="A", description="Division of study")
+    pin: Optional[str] = Field(None, min_length=10, max_length=10,
+                               example="20KJ1A0501", description="PIN of the student")
+    gpa: Optional[float] = Field(
+        None, gt=0, lt=10, example=9.0, description="GPA of the student")
+
+    phone: Optional[int] = Field(None, gt=1000000000, lt=9999999999,
+                                 example=1234567890, description="Phone number of the student")
+
+    address: Optional[str] = Field(None, min_length=3, max_length=100,
+                                   example="123, 1st cross, 1st main, City, State, Country - 123456",
+                                   description="Address of the student")
+
+    class Config:
+        schema_extra = {
+            "Example": {
+                "name": "John Doe",
+                "email": "Johndoe@example.com",
+                "password": "JohnDoe123",
+                "year": 1,
+                "branch": "CSE",
+                "division": "A",
+                "pin": "20KJ1A0501",
+                "gpa": 9.0,
+                "phone": 1234567890,
+                "address": """
+                    123, 1st cross, 1st main,
+                    City, State, Country - 123456""",
+            }
+        }
+
+
+def ResponseModel(data, message):
+    return {
+        "data": [data],
+        "code": 200,
+        "message": message,
+    }
+
+
+def ErrorResponseModel(error, code, message):
+    return {"error": error, "code": code, "message": message}

requirements.txt

@@ -0,0 +1,5 @@
+fastapi==0.96.0
+motor==2.5.1
+pydantic==1.10.2
+pydantic[email]
+pymongo==3.13.0

routes/student_routes.py

@@ -0,0 +1,59 @@
+from fastapi import APIRouter, Body, status
+from fastapi.encoders import jsonable_encoder
+from models.schema import (
+    StudentSchema,
+    StudentUpdateSchema,
+    ResponseModel,
+    ErrorResponseModel,
+)
+
+from database import *
+
+router = APIRouter()
+
+
+@router.post("/", response_description="Student data added into the database")
+async def add_student_data(student: StudentSchema = Body(...)):
+    student = jsonable_encoder(student)
+
+    if get_student_data(student["pin"]):
+        return ErrorResponseModel("Student Exist", 404, f"Student with PIN: {student['pin']} already exists.")
+
+    new_student = await add(student)
+    return ResponseModel(new_student, "Student added successfully.")
+
+
+@router.get("/all", response_description="Students Data Retrieved")
+async def get_all_students():
+    students = await get_all()
+    if len(students) < 1:
+        return ErrorResponseModel("Empty Database", 404, "No Students data found")
+
+    if students:
+        return ResponseModel(students, "Retrieved all students data")
+    ErrorResponseModel("An Error Occurred", 404, "No Students database found")
+
+
+@router.get("/{pin}", response_description="Student data retrieved")
+async def get_student_data(pin):
+    student = await get(pin)
+    if student:
+        return ResponseModel(student, "Student data retrieved successfully")
+    return ErrorResponseModel("An error occurred.", 404, "Student doesn't exist.")
+
+
+@router.put("/{pin}")
+async def update_student_data(pin: str, data: StudentUpdateSchema = Body(...)):
+    data = {k: v for k, v in data.dict().items() if v is not None}
+    updated_student = await update(pin, data)
+    if updated_student:
+        return ResponseModel(updated_student, f"{pin} data updated")
+    return ErrorResponseModel("An Error occurred", 404, "Cannot update the data. Maybe pin doesn't exist")
+
+
+@router.delete("/delete/{pin}", response_description="Delete student from database")
+async def delete_student(pin: str):
+    student = await delete(pin)
+    if student:
+        return ResponseModel(f"Student with {pin} removed from the database", "Operation Success")
+    return ErrorResponseModel("An Error occurred", 404, f"student with PIN {pin} does not exist")