Add Robust Unit and Integration Tests for Product APITest complete suite

README.md

@@ -321,9 +321,24 @@ def hello_name(request):
     name = request.GET.get("name", "World")
     return JsonResponse({"message": f"Hello, {name}!"})
 
+
+
+def hello_name_age(request):
+    """
+    A simple view that returns 'Hello, {name}! You are {age} years old.' in JSON format.
+    Uses query parameters named 'name' and 'age'.
+    """
+    name = request.GET.get("name", "World")
+    age = request.GET.get("age", "unknown")  # Default to 'unknown' if age is not provided
+
+    return JsonResponse({"message": f"Hello, {name}! You are {age} years old."})
+
+# test this using -> hello_name_age/?name=John&age=25
+
 urlpatterns = [
     path('admin/', admin.site.urls),
     path('hello/', hello_name), 
+    path('hello_name_age/', hello_name_age), 
     # Example usage: /hello/?name=Bob
     # returns {"message": "Hello, Bob!"}
 ]
@@ -364,6 +379,9 @@ Enter the endpoint, for example:
 ```
 http://127.0.0.1:8001/hello/?name=Bob
 ```
+### http://127.0.0.1:8000/hello_name/?name=John%20Doe!@#  
+# This shows that the API can handle special characters as well.
+
 
 Send the request. You should see a JSON response:
 ```
@@ -474,7 +492,7 @@ A quick demonstration of hot reloading in action after making changes can be fou
 ---
 
 
-
-
-
-
+![GitHub Repo stars](https://img.shields.io/github/stars/VedanshiAwasthi/interneers-lab?style=social)  
+![GitHub forks](https://img.shields.io/github/forks/VedanshiAwasthi/interneers-lab?style=social)  
+![GitHub last commit](https://img.shields.io/github/last-commit/VedanshiAwasthi/interneers-lab)  
+![GitHub license](https://img.shields.io/github/license/VedanshiAwasthi/interneers-lab)

backend/django_app/settings.py

@@ -9,6 +9,7 @@
 For the full list of settings and their values, see
 https://docs.djangoproject.com/en/5.1/ref/settings/
 """
+import mongoengine
 
 from pathlib import Path
 
@@ -25,7 +26,12 @@
 # SECURITY WARNING: don't run with debug turned on in production!
 DEBUG = True
 
-ALLOWED_HOSTS = []
+ALLOWED_HOSTS = ["*"]
+
+REST_FRAMEWORK = {
+    'DEFAULT_PAGINATION_CLASS': 'rest_framework.pagination.PageNumberPagination',
+    'PAGE_SIZE': 10  
+}
 
 
 # Application definition
@@ -37,6 +43,8 @@
     "django.contrib.sessions",
     "django.contrib.messages",
     "django.contrib.staticfiles",
+    'rest_framework',
+    # "products",
 ]
 
 MIDDLEWARE = [
@@ -74,13 +82,29 @@
 # https://docs.djangoproject.com/en/5.1/ref/settings/#databases
 
 DATABASES = {
-    "default": {
-        "ENGINE": "django.db.backends.sqlite3",
-        "NAME": BASE_DIR / "db.sqlite3",
+    'default': {
+        'ENGINE': 'django.db.backends.sqlite3',
+        'NAME': BASE_DIR / "db.sqlite3",
     }
 }
 
 
+
+# mongoengine.connect(
+#     db="ECommerceDB",
+#     host="mongodb://localhost:27017/",
+# )
+
+#ADDED AUTHENTICATION
+
+mongoengine.connect(
+    db="ECommerceDB",
+    host="mongodb://root:example@localhost:27017/ECommerceDB?authSource=admin" ,
+    uuidRepresentation="standard"
+)
+
+
+
 # Password validation
 # https://docs.djangoproject.com/en/5.1/ref/settings/#auth-password-validators
 
@@ -116,8 +140,18 @@
 # https://docs.djangoproject.com/en/5.1/howto/static-files/
 
 STATIC_URL = "static/"
+STATIC_ROOT = BASE_DIR / 'static'
 
 # Default primary key field type
 # https://docs.djangoproject.com/en/5.1/ref/settings/#default-auto-field
 
-DEFAULT_AUTO_FIELD = "django.db.models.BigAutoField"
+DEFAULT_AUTO_FIELD = "django.db.models.AutoField"
+
+class DisableMigrations:
+    def __contains__(self, item):
+        return True
+
+    def __getitem__(self, item):
+        return None
+
+MIGRATION_MODULES = DisableMigrations()

backend/django_app/urls.py

@@ -1,11 +1,39 @@
 from django.contrib import admin
-from django.urls import path
+from django.urls import path, include
 from django.http import HttpResponse
+from django.http import JsonResponse
+
+# def hello_world(request):
+#     return HttpResponse("Hello, world! This is our interneers-lab Django server.")
+
+# urlpatterns = [
+#     path('admin/', admin.site.urls),
+#     path('hello/', hello_world),
+# ]
+
+
+def home(request):
+    return HttpResponse("Hi")
+
+
+def hello(request):
+    return HttpResponse("Hello, world! This is our interneers-lab Django server, First change made, function name changed from i.e hello_world to hello")
+
+def hello_name(request):
+    """
+    A simple view that returns 'Hello, {name}' in JSON format.
+    Uses a query parameter named 'name'.
+    """
+    # Get 'name' from the query string, default to 'World' if missing
+    name = request.GET.get("name", "World")
+    return JsonResponse({"message": f"Hello, {name}!"})
 
-def hello_world(request):
-    return HttpResponse("Hello, world! This is our interneers-lab Django server.")
 
 urlpatterns = [
     path('admin/', admin.site.urls),
-    path('hello/', hello_world),
+    path('hello/', hello),
+    path('', home),
+    path('hello_name/', hello_name),    #test this using -> hello_name/?name=Vedanshi
+    #tested with few more apis like http://127.0.0.1:8000/hello_name/?name=John%20Doe!@#   , etc
+   path('api/', include('products.urls')), 
 ]

backend/docker-compose.yaml

@@ -3,10 +3,11 @@ services:
     image: mongo:latest
     container_name: interneers_lab_mongodb
     ports:
-      - '27018:27017'
+      - '27017:27017'
     environment:
       MONGO_INITDB_ROOT_USERNAME: root
       MONGO_INITDB_ROOT_PASSWORD: example
+    command: ["mongod", "--auth"]
     volumes:
       - mongodb_data:/data/db
 

backend/products/admin.py

@@ -0,0 +1,4 @@
+from django.contrib import admin
+from .models import Product
+
+# admin.site.register(Product)

backend/products/apps.py

@@ -0,0 +1,5 @@
+from django.apps import AppConfig
+
+
+class ProductsConfig(AppConfig):
+    name = 'products'

backend/products/errorHandler.py

@@ -0,0 +1,18 @@
+from rest_framework.response import Response
+from rest_framework.exceptions import APIException, NotFound
+from rest_framework import status
+
+class ProductNotFound(NotFound):
+    default_detail = {"error": "Product not found"}
+    default_code = "not_found"
+
+def handle_exception(exception):
+    print("Exception Caught:", type(exception), exception)
+
+    if isinstance(exception, ProductNotFound):
+        return Response(exception.default_detail, status=status.HTTP_404_NOT_FOUND)
+
+    if isinstance(exception, APIException):
+        return Response({"error": str(exception)}, status=exception.status_code)
+
+    return Response({"error": "An unexpected error occurred"}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)

backend/products/models/CategoryModel.py

@@ -0,0 +1,19 @@
+import mongoengine
+import datetime
+
+class ProductCategory(mongoengine.Document):
+    title = mongoengine.StringField(max_length=100, required=True, unique=True)
+    description = mongoengine.StringField(required=False)
+    created_at = mongoengine.DateTimeField(default=lambda: datetime.datetime.now(datetime.UTC))
+    updated_at = mongoengine.DateTimeField(default=lambda: datetime.datetime.now(datetime.UTC))
+
+
+    meta = {'collection': 'ProductCategory' , 'db_alias': 'default'}  
+
+    def save(self, *args, **kwargs):
+        self.updated_at = datetime.datetime.now(datetime.UTC)
+        return super(ProductCategory, self).save(*args, **kwargs)
+
+    def __str__(self):
+        return self.title
+

backend/products/models/ProductModel.py

@@ -0,0 +1,28 @@
+import mongoengine
+import datetime
+from .CategoryModel import ProductCategory
+
+class Product(mongoengine.Document):
+    name = mongoengine.StringField(max_length=255, required=True)
+    description = mongoengine.StringField(required=False)
+    brand = mongoengine.StringField(max_length=100, required=True)
+    category = mongoengine.ListField(
+        mongoengine.ReferenceField(ProductCategory, reverse_delete_rule=mongoengine.PULL)
+    )       #Use PULL when you want to remove references to a deleted document without deleting dependent documents.
+    price = mongoengine.DecimalField(precision=2, required=True)
+    quantity = mongoengine.IntField(default=0, min_value=0)
+    created_at = mongoengine.DateTimeField(default=lambda: datetime.datetime.now(datetime.UTC))
+    updated_at = mongoengine.DateTimeField(default=lambda: datetime.datetime.now(datetime.UTC))
+
+    meta = {'collection': 'Product' , 'db_alias': 'default'}  
+
+    def save(self, *args, **kwargs):
+        self.updated_at = datetime.datetime.now(datetime.UTC)
+        return super(Product, self).save(*args, **kwargs)
+
+    def __str__(self):
+        return self.name
+
+
+
+

backend/products/repositories/Category.py

@@ -0,0 +1,57 @@
+from ..models.CategoryModel import ProductCategory
+from ..models.ProductModel import Product
+
+class CategoryRepository:
+    @staticmethod
+    def create(title, description=None):
+        if ProductCategory.objects.filter(title=title).first():
+            raise ValueError("Category with this title already exists.")
+        category = ProductCategory.objects.create(title=title, description=description)
+        return category
+
+    @staticmethod
+    def get_category_by_title(title):
+        return ProductCategory.objects.filter(title__iexact=title).first()
+
+
+    @staticmethod
+    def getCategoryById(category_id):
+        try:
+            return ProductCategory.objects.get(id = category_id)
+
+        except ProductCategory.DoesNotExist:
+            return None
+
+
+    @staticmethod
+    def get_products_by_category(category):
+        return Product.objects.filter(category=category)
+
+    @staticmethod
+    def get_all():
+        return ProductCategory.objects.all()
+
+    @staticmethod
+    def update(title, new_title=None, new_description=None):
+        category = ProductCategory.objects.filter(title=title).first()
+        if not category:
+            raise ValueError("Category not found.")
+
+        if new_title and ProductCategory.objects.filter(title=new_title).exists():
+            raise ValueError("Category with this new title already exists.")
+        if new_title:
+            category.title = new_title
+
+        if new_description is not None:
+            category.description = new_description
+
+        category.save()
+        return category
+
+    @staticmethod
+    def delete(title):
+        category = ProductCategory.objects.filter(title=title).first()
+        if not category:
+            raise ValueError("Category not found.")
+        category.delete()
+        return True

backend/products/repositories/ProductRepository.py

@@ -0,0 +1,66 @@
+from ..models.ProductModel import Product
+from bson import ObjectId
+from bson.errors import InvalidId
+
+class ProductRepository:
+
+    @staticmethod
+    def createProd(prod_details):
+        prod_details["price"] = float(prod_details["price"])
+        prod = Product(**prod_details)
+        prod.save()
+        return prod 
+
+
+    @staticmethod
+    def getAllProd():
+        return list(Product.objects.all())
+
+
+    @staticmethod
+    def getProdById(prod_id):
+        try:
+            obj_id = ObjectId(prod_id)
+            return Product.objects.get(id=obj_id)
+
+        except InvalidId:
+            raise ValueError("Invalid ID format. Must be a 12-byte input or 24-character hex string.")
+
+        except Product.DoesNotExist:
+            return None
+
+
+    @staticmethod
+    def updateProd(prod_id , prod_details):
+
+        prod = ProductRepository.getProdById(prod_id)
+
+        if prod:
+            for key,value in prod_details.items(): 
+                setattr(prod,key,value)
+            prod.save()
+            return prod
+
+        return None
+
+
+    @staticmethod
+    def deleteProd(prod_id):
+        print(f"Looking for product with ID: {prod_id}")
+        prod = ProductRepository.getProdById(prod_id)
+        print(f"Product fetched: {prod}")
+
+        if prod:
+            prod.delete()
+            return True
+
+        return None
+
+
+
+    @staticmethod
+    def update_product_categories(product, updated_categories):
+        product.category = updated_categories
+        product.save()
+
+