get catalogue details

app/product_catalogue/controllers/router.py

@@ -109,6 +109,65 @@ async def list_products(payload: ProductListRequest):
         )
 
 
+@router.get("/{catalogue_id}", response_model=CustomerProductResponse)
+async def get_product_details(catalogue_id: str = Path(..., description="Catalogue ID of the product")):
+    """
+    Get detailed information for a specific product.
+    
+    **Customer-facing endpoint** - Returns detailed product information.
+    **Company-level products** - Products are shared across the platform.
+    
+    - **catalogue_id**: The unique catalogue identifier for the product
+    
+    Returns detailed product information including:
+    - Complete product details (name, category, brand, description)
+    - Pricing information (MRP, currency, GST rate)
+    - Stock availability status
+    - All product images and media
+    - Product specifications and attributes
+    
+    **Data Source**: MongoDB collection `scm_catalogues`
+    **Filters Applied**: 
+    - `catalogue_type = "Product"`
+    - `meta.status = "active" or "Active"`
+    - `allow_ecommerce = true`
+    - `catalogue_id = {catalogue_id}`
+    
+    **Customer-Safe Fields Only**:
+    - No pricing levels beyond MRP
+    - No inventory numbers exposed
+    - No internal procurement data
+    - No commission or loyalty data
+    """
+    try:
+        logger.info("Getting product details", extra={
+            "catalogue_id": catalogue_id
+        })
+        
+        # Get product details
+        product = await product_catalogue_service.get_product_details(catalogue_id)
+        
+        if not product:
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail=f"Product with catalogue_id '{catalogue_id}' not found"
+            )
+        
+        return product
+        
+    except HTTPException:
+        # Re-raise HTTP exceptions as-is
+        raise
+    except Exception as e:
+        logger.error("Error getting product details", exc_info=e, extra={
+            "catalogue_id": catalogue_id
+        })
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail="Failed to get product details"
+        )
+
+
 # Legacy GET endpoint for backward compatibility (if needed)
 @router.get("/", response_model=ProductListResponse)
 async def list_products_get(

app/product_catalogue/services/service.py

@@ -329,6 +329,57 @@ class ProductCatalogueService:
             logger.error("Error getting company products count", exc_info=e)
             raise
 
+    async def get_product_details(
+        self,
+        catalogue_id: str
+    ) -> Optional[CustomerProductResponse]:
+        """
+        Get detailed information for a specific product by catalogue ID.
+        
+        Args:
+            catalogue_id: The catalogue ID to fetch details for
+            
+        Returns:
+            Product details if found, None otherwise
+        """
+        try:
+            logger.info("Getting product details", extra={
+                "catalogue_id": catalogue_id
+            })
+            
+            # Build query for specific product
+            query = {
+                "catalogue_id": catalogue_id,
+                "catalogue_type": "Product",
+                "meta.status": {"$in": ["active", "Active"]},
+                "allow_ecommerce": True
+            }
+            
+            # Find the product
+            doc = await self.collection.find_one(query)
+            
+            if not doc:
+                logger.warning("Product not found", extra={
+                    "catalogue_id": catalogue_id
+                })
+                return None
+            
+            # Transform to customer-safe response
+            product_response = self._transform_product_data(doc)
+            
+            logger.info("Successfully retrieved product details", extra={
+                "catalogue_id": catalogue_id,
+                "product_name": product_response.name
+            })
+            
+            return product_response
+            
+        except Exception as e:
+            logger.error("Error getting product details", exc_info=e, extra={
+                "catalogue_id": catalogue_id
+            })
+            raise
+
 
 
 # Global service instance

test_product_details.py

@@ -0,0 +1,70 @@
+#!/usr/bin/env python3
+"""
+Test the product details API endpoint.
+"""
+import asyncio
+
+async def test_product_details():
+    """Test the product details API"""
+    
+    try:
+        # Import the service
+        from app.product_catalogue.services.service import product_catalogue_service
+        from app.nosql import connect_to_mongo
+        
+        print("🔗 Connecting to database...")
+        await connect_to_mongo()
+        print("✅ Connected to database")
+        
+        # First, get a sample product ID from the list
+        print("\n🔍 Getting sample product ID...")
+        products = await product_catalogue_service.list_products(
+            limit=1,
+            offset=0,
+            projection_list=None
+        )
+        
+        if not products:
+            print("❌ No products found to test with")
+            return
+        
+        sample_product = products[0]
+        catalogue_id = sample_product.catalogue_id
+        print(f"📦 Using product: {sample_product.name} (ID: {catalogue_id})")
+        
+        # Test the get_product_details method
+        print(f"\n🧪 Testing get_product_details for ID: {catalogue_id}")
+        product_details = await product_catalogue_service.get_product_details(catalogue_id)
+        
+        if product_details:
+            print("✅ Product details retrieved successfully")
+            print(f"  Name: {product_details.name}")
+            print(f"  Brand: {product_details.brand}")
+            print(f"  Category: {product_details.category}")
+            print(f"  Price: {product_details.price} {product_details.currency}")
+            print(f"  In Stock: {product_details.in_stock}")
+            print(f"  Images: {len(product_details.images)} images")
+            if product_details.description:
+                print(f"  Description: {product_details.description[:100]}...")
+        else:
+            print("❌ Product details not found")
+        
+        # Test with non-existent ID
+        print(f"\n🧪 Testing with non-existent ID...")
+        fake_id = "00000000-0000-0000-0000-000000000000"
+        fake_product = await product_catalogue_service.get_product_details(fake_id)
+        
+        if fake_product is None:
+            print("✅ Correctly returned None for non-existent product")
+        else:
+            print("❌ Unexpectedly found product for fake ID")
+        
+        print("\n✅ Product details API test completed successfully")
+        
+    except Exception as e:
+        print(f"❌ Error testing product details API: {e}")
+        import traceback
+        traceback.print_exc()
+
+if __name__ == "__main__":
+    asyncio.run(test_product_details())