content_quality_tool/attr_extraction/views.py

# #  #==================== views.py ====================
# # from rest_framework.views import APIView
# # from rest_framework.response import Response
# # from rest_framework import status
# # from .serializers import (
# #     ProductAttributeRequestSerializer,
# #     ProductAttributeResponseSerializer
# # )
# # from .services import ProductAttributeService


# # class ExtractProductAttributesView(APIView):
# #     """
# #     API endpoint to extract product attributes using Groq LLM.
    
# #     POST /api/extract-attributes/
    
# #     Request Body:
# #     {
# #         "title": "Product title (optional)",
# #         "short_desc": "Short description (optional)",
# #         "long_desc": "Long description (optional)",
# #         "mandatory_attrs": {
# #             "Attribute1": ["value1", "value2", "value3"],
# #             "Attribute2": ["valueA", "valueB"]
# #         },
# #         "model": "llama-3.1-8b-instant (optional)",
# #         "extract_additional": true (optional, default: true)
# #     }
    
# #     Response:
# #     {
# #         "mandatory": {
# #             "Attribute1": "value1",
# #             "Attribute2": "valueA"
# #         },
# #         "additional": {
# #             "Color": "Blue",
# #             "Brand": "Example"
# #         }
# #     }
# #     """

# #     def post(self, request):
# #         # Validate request data
# #         serializer = ProductAttributeRequestSerializer(data=request.data)
# #         if not serializer.is_valid():
# #             return Response(
# #                 {"error": serializer.errors},
# #                 status=status.HTTP_400_BAD_REQUEST
# #             )

# #         validated_data = serializer.validated_data

# #         # Combine product text
# #         product_text = ProductAttributeService.combine_product_text(
# #             title=validated_data.get('title'),
# #             short_desc=validated_data.get('short_desc'),
# #             long_desc=validated_data.get('long_desc')
# #         )

# #         # Extract attributes
# #         result = ProductAttributeService.extract_attributes(
# #             product_text=product_text,
# #             mandatory_attrs=validated_data['mandatory_attrs'],
# #             model=validated_data.get('model'),
# #             extract_additional=validated_data.get('extract_additional', True)
# #         )

# #         # Return response
# #         response_serializer = ProductAttributeResponseSerializer(data=result)
# #         if response_serializer.is_valid():
# #             return Response(response_serializer.data, status=status.HTTP_200_OK)
        
# #         return Response(result, status=status.HTTP_200_OK)







# from rest_framework.views import APIView
# from rest_framework.response import Response
# from rest_framework import status
# from .serializers import (
#     SingleProductRequestSerializer,
#     BatchProductRequestSerializer,
#     ProductAttributeResultSerializer,
#     BatchProductResponseSerializer
# )
# from .services import ProductAttributeService


# class ExtractProductAttributesView(APIView):
#     """
#     API endpoint to extract product attributes for a single product.
    
#     POST /api/extract-attributes/
    
#     Request Body:
#     {
#         "title": "Product title (optional)",
#         "short_desc": "Short description (optional)",
#         "long_desc": "Long description (optional)",
#         "mandatory_attrs": {
#             "Attribute1": ["value1", "value2", "value3"],
#             "Attribute2": ["valueA", "valueB"]
#         },
#         "model": "llama-3.1-8b-instant (optional)",
#         "extract_additional": true (optional, default: true)
#     }
#     """

#     def post(self, request):
#         serializer = SingleProductRequestSerializer(data=request.data)
#         if not serializer.is_valid():
#             return Response(
#                 {"error": serializer.errors},
#                 status=status.HTTP_400_BAD_REQUEST
#             )

#         validated_data = serializer.validated_data

#         product_text = ProductAttributeService.combine_product_text(
#             title=validated_data.get('title'),
#             short_desc=validated_data.get('short_desc'),
#             long_desc=validated_data.get('long_desc')
#         )

#         result = ProductAttributeService.extract_attributes(
#             product_text=product_text,
#             mandatory_attrs=validated_data['mandatory_attrs'],
#             model=validated_data.get('model'),
#             extract_additional=validated_data.get('extract_additional', True)
#         )

#         response_serializer = ProductAttributeResultSerializer(data=result)
#         if response_serializer.is_valid():
#             return Response(response_serializer.data, status=status.HTTP_200_OK)
        
#         return Response(result, status=status.HTTP_200_OK)


# class BatchExtractProductAttributesView(APIView):
#     """
#     API endpoint to extract product attributes for multiple products in batch.
    
#     POST /api/batch-extract-attributes/
    
#     Request Body:
#     {
#         "products": [
#             {
#                 "product_id": "prod_001",
#                 "title": "Product 1 title",
#                 "short_desc": "Short description",
#                 "long_desc": "Long description"
#             },
#             {
#                 "product_id": "prod_002",
#                 "title": "Product 2 title",
#                 "short_desc": "Short description"
#             }
#         ],
#         "mandatory_attrs": {
#             "Attribute1": ["value1", "value2", "value3"],
#             "Attribute2": ["valueA", "valueB"]
#         },
#         "model": "llama-3.1-8b-instant (optional)",
#         "extract_additional": true (optional, default: true)
#     }
    
#     Response:
#     {
#         "results": [
#             {
#                 "product_id": "prod_001",
#                 "mandatory": {...},
#                 "additional": {...}
#             },
#             {
#                 "product_id": "prod_002",
#                 "mandatory": {...},
#                 "additional": {...}
#             }
#         ],
#         "total_products": 2,
#         "successful": 2,
#         "failed": 0
#     }
#     """

#     def post(self, request):
#         serializer = BatchProductRequestSerializer(data=request.data)
#         if not serializer.is_valid():
#             return Response(
#                 {"error": serializer.errors},
#                 status=status.HTTP_400_BAD_REQUEST
#             )

#         validated_data = serializer.validated_data

#         # Extract attributes for all products in batch
#         result = ProductAttributeService.extract_attributes_batch(
#             products=validated_data['products'],
#             mandatory_attrs=validated_data['mandatory_attrs'],
#             model=validated_data.get('model'),
#             extract_additional=validated_data.get('extract_additional', True)
#         )

#         response_serializer = BatchProductResponseSerializer(data=result)
#         if response_serializer.is_valid():
#             return Response(response_serializer.data, status=status.HTTP_200_OK)
        
#         return Response(result, status=status.HTTP_200_OK)







# ==================== views.py ====================
from rest_framework.views import APIView
from rest_framework.response import Response
from rest_framework import status
from .serializers import (
    SingleProductRequestSerializer,
    BatchProductRequestSerializer,
    ProductAttributeResultSerializer,
    BatchProductResponseSerializer
)
from .services import ProductAttributeService
from .ocr_service import OCRService


class ExtractProductAttributesView(APIView):
    """
    API endpoint to extract product attributes for a single product.
    Now supports image URL for OCR-based text extraction.
    """

    def post(self, request):
        serializer = SingleProductRequestSerializer(data=request.data)
        if not serializer.is_valid():
            return Response(
                {"error": serializer.errors},
                status=status.HTTP_400_BAD_REQUEST
            )

        validated_data = serializer.validated_data
        
        # Process image if URL provided
        ocr_results = None
        ocr_text = None
        
        if validated_data.get('process_image', True) and validated_data.get('image_url'):
            ocr_service = OCRService()
            ocr_results = ocr_service.process_image(validated_data['image_url'])
            
            # Extract attributes from OCR
            if ocr_results and ocr_results.get('detected_text'):
                ocr_attrs = ProductAttributeService.extract_attributes_from_ocr(
                    ocr_results,
                    validated_data.get('model')
                )
                ocr_results['extracted_attributes'] = ocr_attrs
                
                # Format OCR text
                ocr_text = "\n".join([
                    f"{item['text']} (confidence: {item['confidence']:.2f})"
                    for item in ocr_results['detected_text']
                ])

        # Combine all product information
        product_text = ProductAttributeService.combine_product_text(
            title=validated_data.get('title'),
            short_desc=validated_data.get('short_desc'),
            long_desc=validated_data.get('long_desc'),
            ocr_text=ocr_text
        )

        # Extract attributes
        result = ProductAttributeService.extract_attributes(
            product_text=product_text,
            mandatory_attrs=validated_data['mandatory_attrs'],
            model=validated_data.get('model'),
            extract_additional=validated_data.get('extract_additional', True)
        )
        
        # Add OCR results if available
        if ocr_results:
            result['ocr_results'] = ocr_results

        response_serializer = ProductAttributeResultSerializer(data=result)
        if response_serializer.is_valid():
            return Response(response_serializer.data, status=status.HTTP_200_OK)
        
        return Response(result, status=status.HTTP_200_OK)


class BatchExtractProductAttributesView(APIView):
    """
    API endpoint to extract product attributes for multiple products in batch.
    Now supports image URLs for OCR-based text extraction.
    """

    def post(self, request):
        serializer = BatchProductRequestSerializer(data=request.data)
        if not serializer.is_valid():
            return Response(
                {"error": serializer.errors},
                status=status.HTTP_400_BAD_REQUEST
            )

        validated_data = serializer.validated_data

        # Extract attributes for all products in batch
        result = ProductAttributeService.extract_attributes_batch(
            products=validated_data['products'],
            mandatory_attrs=validated_data['mandatory_attrs'],
            model=validated_data.get('model'),
            extract_additional=validated_data.get('extract_additional', True),
            process_image=validated_data.get('process_image', True)
        )

        response_serializer = BatchProductResponseSerializer(data=result)
        if response_serializer.is_valid():
            return Response(response_serializer.data, status=status.HTTP_200_OK)
        
        return Response(result, status=status.HTTP_200_OK)





from rest_framework.views import APIView
from rest_framework.response import Response
from rest_framework import status
from .models import Product
from .serializers import ProductSerializer

class ProductListView(APIView):
    """
    GET API to list all products with details
    """
    def get(self, request):
        products = Product.objects.all()
        serializer = ProductSerializer(products, many=True)
        return Response(serializer.data, status=status.HTTP_200_OK)