Add a Product Review service with GenAI-powered summaries

.env

@@ -116,6 +116,11 @@ PRODUCT_CATALOG_PORT=3550
 PRODUCT_CATALOG_ADDR=product-catalog:${PRODUCT_CATALOG_PORT}
 PRODUCT_CATALOG_DOCKERFILE=./src/product-catalog/Dockerfile
 
+# Product Reviews Service
+PRODUCT_REVIEWS_PORT=3551
+PRODUCT_REVIEWS_ADDR=product-reviews:${PRODUCT_REVIEWS_PORT}
+PRODUCT_REVIEWS_DOCKERFILE=./src/product-reviews/Dockerfile
+
 # Quote Service
 QUOTE_PORT=8090
 QUOTE_ADDR=http://quote:${QUOTE_PORT}
@@ -150,6 +155,17 @@ KAFKA_HOST=kafka
 KAFKA_ADDR=${KAFKA_HOST}:${KAFKA_PORT}
 KAFKA_DOCKERFILE=./src/kafka/Dockerfile
 
+# LLM service
+LLM_DOCKERFILE=./src/llm/Dockerfile
+LLM_HOST=llm
+LLM_PORT=8000
+
+# Mock LLM - to use a real OpenAI API-compatible LLM,
+# configure the .env.override file
+LLM_BASE_URL=http://${LLM_HOST}:${LLM_PORT}/v1
+LLM_MODEL=astronomy-llm
+OPENAI_API_KEY=dummy
+
 # Valkey
 VALKEY_PORT=6379
 VALKEY_ADDR=valkey-cart:${VALKEY_PORT}

.env.override

@@ -1,2 +1,12 @@
 # DO NOT PUSH CHANGES OF THIS FILE TO opentelemetry/opentelemetry-demo
 # PLACE YOUR .env ENVIRONMENT VARIABLES OVERRIDES IN THIS FILE
+
+
+# To use a real OpenAI API-compatible LLM,
+# set the appropriate values for the target LLM
+# Required permissions:
+# [Models and Model capabilities]
+
+#LLM_BASE_URL=https://api.openai.com/v1
+#LLM_MODEL=gpt-4o-mini
+#OPENAI_API_KEY=<replace with API key>

.github/workflows/component-build-images.yml

@@ -106,6 +106,10 @@ jobs:
             tag_suffix: kafka
             context: ./
             setup-qemu: true
+          - file: ./src/llm/Dockerfile
+            tag_suffix: llm
+            context: ./
+            setup-qemu: true
           - file: ./src/load-generator/Dockerfile
             tag_suffix: load-generator
             context: ./
@@ -126,6 +130,10 @@ jobs:
             tag_suffix: product-catalog
             context: ./
             setup-qemu: true
+          - file: ./src/product-reviews/Dockerfile
+            tag_suffix: product-reviews
+            context: ./
+            setup-qemu: true
           - file: ./src/quote/Dockerfile
             tag_suffix: quote
             context: ./

.licenserc.json

@@ -47,6 +47,8 @@
         "src/checkout/genproto/",
         "src/flagd-ui/assets/vendor/",
         "src/product-catalog/genproto/",
+        "src/product-reviews/demo_pb2.py",
+        "src/product-reviews/demo_pb2_grpc.py",
         "src/react-native-app/ios/Pods/",
         "src/react-native-app/ios/build/",
         "src/react-native-app/android/app/build/",

CHANGELOG.md

@@ -15,6 +15,8 @@ the release.
   ([#2615](https://github.com/open-telemetry/opentelemetry-demo/pull/2615))
 * [frontend] Fix navigation and cart math
   ([#2660](https://github.com/open-telemetry/opentelemetry-demo/pull/2660))
+* [feat] Add Product Review service with AI-generated summaries
+  ([#2663](https://github.com/open-telemetry/opentelemetry-demo/pull/2663))
 * [chore] Upgrade OpenFeature and add fix deprecation warnings for dependency
   injection
   ([#2644](https://github.com/open-telemetry/opentelemetry-demo/pull/2644))

docker-compose-tests.yml

@@ -45,6 +45,7 @@ services:
       - FRONTEND_ADDR
       - PAYMENT_ADDR
       - PRODUCT_CATALOG_ADDR
+      - PRODUCT_REVIEWS_ADDR
       - RECOMMENDATION_ADDR
       - SHIPPING_ADDR
       - KAFKA_ADDR
@@ -73,10 +74,14 @@ services:
         condition: service_started
       frontend:
         condition: service_started
+      llm:
+        condition: service_started
       payment:
         condition: service_started
       product-catalog:
         condition: service_started
+      product-reviews:
+        condition: service_started
       quote:
         condition: service_started
       recommendation:

docker-compose.minimal.yml

@@ -430,6 +430,47 @@ services:
         condition: service_started
     logging: *logging
 
+  # Product reviews service
+  product-reviews:
+    image: ${IMAGE_NAME}:${DEMO_VERSION}-product-reviews
+    container_name: product-reviews
+    build:
+      context: ./
+      dockerfile: ${PRODUCT_REVIEWS_DOCKERFILE}
+      cache_from:
+        - ${IMAGE_NAME}:${IMAGE_VERSION}-product-reviews
+    deploy:
+      resources:
+        limits:
+          memory: 500M
+    restart: unless-stopped
+    ports:
+      - "${PRODUCT_REVIEWS_PORT}"
+    environment:
+      - PRODUCT_REVIEWS_PORT
+      - OTEL_PYTHON_LOG_CORRELATION=true
+      - OTEL_EXPORTER_OTLP_ENDPOINT
+      - OTEL_EXPORTER_OTLP_METRICS_TEMPORALITY_PREFERENCE
+      - OTEL_RESOURCE_ATTRIBUTES
+      - OTEL_SERVICE_NAME=product-reviews
+      - OTEL_INSTRUMENTATION_GENAI_CAPTURE_MESSAGE_CONTENT=true
+      - PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=python
+      - DB_CONNECTION_STRING=host=${POSTGRES_HOST} user=otelu password=otelp dbname=${POSTGRES_DB}
+      - LLM_BASE_URL
+      - OPENAI_API_KEY
+      - LLM_MODEL
+      - PRODUCT_CATALOG_ADDR
+    depends_on:
+      product-catalog:
+        condition: service_started
+      llm:
+        condition: service_started
+      postgresql:
+        condition: service_started
+      otel-collector:
+        condition: service_started
+    logging: *logging
+
   # Quote service
   quote:
     image: ${IMAGE_NAME}:${DEMO_VERSION}-quote
@@ -559,6 +600,27 @@ services:
     logging:
       *logging
 
+  # LLM used by Product Review service
+  llm:
+    image: ${IMAGE_NAME}:${DEMO_VERSION}-llm
+    container_name: llm
+    build:
+      context: ./
+      dockerfile: ${LLM_DOCKERFILE}
+      cache_from:
+        - ${IMAGE_NAME}:${IMAGE_VERSION}-llm
+    deploy:
+      resources:
+        limits:
+          memory: 50M
+    restart: unless-stopped
+    environment:
+      - FLAGD_HOST
+      - FLAGD_PORT
+    ports:
+      - "${LLM_PORT}"
+    logging: *logging
+
   # Valkey used by Cart service
   valkey-cart:
     image: ${VALKEY_IMAGE}

docker-compose.yml

@@ -288,6 +288,7 @@ services:
       - CHECKOUT_ADDR
       - CURRENCY_ADDR
       - PRODUCT_CATALOG_ADDR
+      - PRODUCT_REVIEWS_ADDR
       - RECOMMENDATION_ADDR
       - SHIPPING_ADDR
       - OTEL_EXPORTER_OTLP_ENDPOINT
@@ -511,6 +512,47 @@ services:
         condition: service_started
     logging: *logging
 
+  # Product reviews service
+  product-reviews:
+    image: ${IMAGE_NAME}:${DEMO_VERSION}-product-reviews
+    container_name: product-reviews
+    build:
+      context: ./
+      dockerfile: ${PRODUCT_REVIEWS_DOCKERFILE}
+      cache_from:
+        - ${IMAGE_NAME}:${IMAGE_VERSION}-product-reviews
+    deploy:
+      resources:
+        limits:
+          memory: 100M
+    restart: unless-stopped
+    ports:
+      - "${PRODUCT_REVIEWS_PORT}"
+    environment:
+      - PRODUCT_REVIEWS_PORT
+      - OTEL_PYTHON_LOG_CORRELATION=true
+      - OTEL_EXPORTER_OTLP_ENDPOINT
+      - OTEL_EXPORTER_OTLP_METRICS_TEMPORALITY_PREFERENCE
+      - OTEL_RESOURCE_ATTRIBUTES
+      - OTEL_SERVICE_NAME=product-reviews
+      - OTEL_INSTRUMENTATION_GENAI_CAPTURE_MESSAGE_CONTENT=true
+      - PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=python
+      - DB_CONNECTION_STRING=host=${POSTGRES_HOST} user=otelu password=otelp dbname=${POSTGRES_DB}
+      - LLM_BASE_URL
+      - OPENAI_API_KEY
+      - LLM_MODEL
+      - PRODUCT_CATALOG_ADDR
+    depends_on:
+      product-catalog:
+        condition: service_started
+      llm:
+        condition: service_started
+      postgresql:
+        condition: service_started
+      otel-collector:
+        condition: service_started
+    logging: *logging
+
   # Quote service
   quote:
     image: ${IMAGE_NAME}:${DEMO_VERSION}-quote
@@ -704,6 +746,30 @@ services:
       retries: 10
     logging: *logging
 
+  # LLM used by Product Review service
+  llm:
+    image: ${IMAGE_NAME}:${DEMO_VERSION}-llm
+    container_name: llm
+    build:
+      context: ./
+      dockerfile: ${LLM_DOCKERFILE}
+      cache_from:
+        - ${IMAGE_NAME}:${IMAGE_VERSION}-llm
+    deploy:
+      resources:
+        limits:
+          memory: 50M
+    restart: unless-stopped
+    environment:
+      - FLAGD_HOST
+      - FLAGD_PORT
+    ports:
+      - "${LLM_PORT}"
+    depends_on:
+      flagd:
+        condition: service_started
+    logging: *logging
+
   # Postgresql used by Accounting service
   postgresql:
     image: ${IMAGE_NAME}:${DEMO_VERSION}-postgresql

docker-gen-proto.sh

@@ -54,6 +54,7 @@ if [ -z "$1" ]; then
   #gen_proto_js payment
   gen_proto_go product-catalog
   #gen_proto_php quote
+  gen_proto_python product-reviews
   gen_proto_python recommendation
   #gen_proto_rust shipping
 else

ide-gen-proto.sh

@@ -75,6 +75,7 @@ gen_proto_ts frontend
 gen_proto_ts react-native-app
 gen_proto_js payment
 gen_proto_go product-catalog
+gen_proto_go product-reviews
 # gen_proto_php quote
 gen_proto_python recommendation
 gen_proto_rust shipping

pb/demo.proto

@@ -102,6 +102,45 @@ message SearchProductsResponse {
     repeated Product results = 1;
 }
 
+// ---------------Product Review service----------
+
+service ProductReviewService {
+  rpc GetProductReviews(GetProductReviewsRequest) returns (GetProductReviewsResponse){}
+  rpc GetAverageProductReviewScore(GetAverageProductReviewScoreRequest) returns (GetAverageProductReviewScoreResponse){}
+  rpc AskProductAIAssistant(AskProductAIAssistantRequest) returns (AskProductAIAssistantResponse){}
+}
+
+message ProductReview {
+    string username = 1;
+    string description = 2;
+    string score = 3;
+}
+
+message GetProductReviewsRequest {
+    string product_id = 1;
+}
+
+message GetProductReviewsResponse {
+    repeated ProductReview product_reviews = 1;
+}
+
+message GetAverageProductReviewScoreRequest {
+    string product_id = 1;
+}
+
+message GetAverageProductReviewScoreResponse {
+    string average_score = 1;
+}
+
+message AskProductAIAssistantRequest {
+    string product_id = 1;
+    string question = 2;
+}
+
+message AskProductAIAssistantResponse {
+    string response = 1;
+}
+
 // ---------------Shipping Service----------
 
 service ShippingService {

src/accounting/Entities.cs

@@ -6,7 +6,7 @@
 
 namespace Accounting;
 
-[Table("shipping")]
+[Table("shipping", Schema = "accounting")]
 [PrimaryKey(nameof(ShippingTrackingId))]
 internal class ShippingEntity
 {
@@ -32,7 +32,7 @@ internal class ShippingEntity
     public required string OrderId { get; set; }
 }
 
-[Table("orderitem")]
+[Table("orderitem", Schema = "accounting")]
 [PrimaryKey(nameof(ProductId), nameof(OrderId))]
 internal class OrderItemEntity
 {
@@ -49,7 +49,7 @@ internal class OrderItemEntity
     public required string OrderId { get; set; }
 }
 
-[Table("order")]
+[Table("order", Schema = "accounting")]
 [PrimaryKey(nameof(Id))]
 internal class OrderEntity
 {