Add RAG client

2026-02-23 07:22:07 +00:00
176 changed files with 495 additions and 9167 deletions
--- a/docs/rag-api-specification.md
+++ b/docs/rag-api-specification.md
@@ -1,268 +0,0 @@
-# RAG API Specification
-
-## Overview
-This document defines the API contract between the integration layer (`capa-de-integracion`) and the RAG server.
-
-The RAG server replaces Dialogflow CX for intent detection and response generation using Retrieval-Augmented Generation.
-
-## Base URL
-```
-https://your-rag-server.com/api/v1
-```
-
-## Authentication
- Method: API Key (optional)
- Header: `X-API-Key: <your-api-key>`
-
---
-
-## Endpoint: Query
-
-### **POST /query**
-
-Process a user message or notification and return a generated response.
-
-### Request
-
-**Headers:**
- `Content-Type: application/json`
- `X-API-Key: <api-key>` (optional)
-
-**Body:**
-```json
-{
-  "phone_number": "string (required)",
-  "text": "string (required - obfuscated user input or notification text)",
-  "type": "string (optional: 'conversation' or 'notification')",
-  "notification": {
-    "text": "string (optional - original notification text)",
-    "parameters": {
-      "key": "value"
-    }
-  },
-  "language_code": "string (optional, default: 'es')"
-}
-```
-
-**Field Descriptions:**
-
-| Field | Type | Required | Description |
-|-------|------|----------|-------------|
-| `phone_number` | string | ✅ Yes | User's phone number (used by RAG for internal conversation history tracking) |
-| `text` | string | ✅ Yes | Obfuscated user input (already processed by DLP in integration layer) |
-| `type` | string | ❌ No | Request type: `"conversation"` (default) or `"notification"` |
-| `notification` | object | ❌ No | Present only when processing a notification-related query |
-| `notification.text` | string | ❌ No | Original notification text (obfuscated) |
-| `notification.parameters` | object | ❌ No | Key-value pairs of notification metadata |
-| `language_code` | string | ❌ No | Language code (e.g., `"es"`, `"en"`). Defaults to `"es"` |
-
-### Response
-
-**Status Code:** `200 OK`
-
-**Body:**
-```json
-{
-  "response_id": "string (unique identifier for this response)",
-  "response_text": "string (generated response)",
-  "parameters": {
-    "key": "value"
-  },
-  "confidence": 0.95
-}
-```
-
-**Field Descriptions:**
-
-| Field | Type | Description |
-|-------|------|-------------|
-| `response_id` | string | Unique identifier for this RAG response (for tracking/logging) |
-| `response_text` | string | The generated response text to send back to the user |
-| `parameters` | object | Optional key-value pairs extracted or computed by RAG (can be empty) |
-| `confidence` | number | Optional confidence score (0.0 - 1.0) |
-
---
-
-## Error Responses
-
-### **400 Bad Request**
-Invalid request format or missing required fields.
-
-```json
-{
-  "error": "Bad Request",
-  "message": "Missing required field: phone_number",
-  "status": 400
-}
-```
-
-### **500 Internal Server Error**
-RAG server encountered an error processing the request.
-
-```json
-{
-  "error": "Internal Server Error",
-  "message": "Failed to generate response",
-  "status": 500
-}
-```
-
-### **503 Service Unavailable**
-RAG server is temporarily unavailable (triggers retry in client).
-
-```json
-{
-  "error": "Service Unavailable",
-  "message": "RAG service is currently unavailable",
-  "status": 503
-}
-```
-
---
-
-## Example Requests
-
-### Example 1: Regular Conversation
-```json
-POST /api/v1/query
-{
-  "phone_number": "573001234567",
-  "text": "¿Cuál es el estado de mi solicitud?",
-  "type": "conversation",
-  "language_code": "es"
-}
-```
-
-**Response:**
-```json
-{
-  "response_id": "rag-resp-12345-67890",
-  "response_text": "Tu solicitud está en proceso de revisión. Te notificaremos cuando esté lista.",
-  "parameters": {},
-  "confidence": 0.92
-}
-```
-
-### Example 2: Notification Flow
-```json
-POST /api/v1/query
-{
-  "phone_number": "573001234567",
-  "text": "necesito más información",
-  "type": "notification",
-  "notification": {
-    "text": "Tu documento ha sido aprobado. Descárgalo desde el portal.",
-    "parameters": {
-      "document_id": "DOC-2025-001",
-      "status": "approved"
-    }
-  },
-  "language_code": "es"
-}
-```
-
-**Response:**
-```json
-{
-  "response_id": "rag-resp-12345-67891",
-  "response_text": "Puedes descargar tu documento aprobado ingresando al portal con tu número de documento DOC-2025-001.",
-  "parameters": {
-    "document_id": "DOC-2025-001"
-  },
-  "confidence": 0.88
-}
-```
-
---
-
-## Design Decisions
-
-### 1. **RAG Handles Conversation History Internally**
- The RAG server maintains its own conversation history indexed by `phone_number`
- The integration layer will continue to store conversation history (redundant for now)
- This allows gradual migration without risk
-
-### 2. **No Session ID Required**
- Unlike Dialogflow (complex session paths), RAG uses `phone_number` as the session identifier
- Simpler and aligns with RAG's internal tracking
-
-### 3. **Notifications Are Contextual**
- When a notification is active, the integration layer passes both:
-  - The user's query (`text`)
-  - The notification context (`notification.text` and `notification.parameters`)
- RAG uses this context to generate relevant responses
-
-### 4. **Minimal Parameter Passing**
- Only essential data is sent to RAG
- The integration layer can store additional metadata internally without sending it to RAG
- RAG can return parameters if needed (e.g., extracted entities)
-
-### 5. **Obfuscation Stays in Integration Layer**
- DLP obfuscation happens before calling RAG
- RAG receives already-obfuscated text
- This maintains the existing security boundary
-
---
-
-## Non-Functional Requirements
-
-### Performance
- **Target Response Time:** < 2 seconds (p95)
- **Timeout:** 30 seconds (configurable in client)
-
-### Reliability
- **Availability:** 99.5%+
- **Retry Strategy:** Client will retry on 500, 503, 504 errors (exponential backoff)
-
-### Scalability
- **Concurrent Requests:** Support 100+ concurrent requests
- **Rate Limiting:** None (or specify if needed)
-
---
-
-## Migration Notes
-
-### What the Integration Layer Will Do:
-✅ Continue to obfuscate text via DLP before calling RAG
-✅ Continue to store conversation history in Memorystore + Firestore (redundant but safe)
-✅ Continue to manage session timeouts (30 minutes)
-✅ Continue to handle notification storage and retrieval
-✅ Map `DetectIntentRequestDTO` → RAG request format
-✅ Map RAG response → `DetectIntentResponseDTO`
-
-### What the RAG Server Will Do:
-✅ Maintain its own conversation history by `phone_number`
-✅ Use notification context when provided to generate relevant responses
-✅ Generate responses using RAG (retrieval + generation)
-✅ Return structured responses with optional parameters
-
-### What We're NOT Changing:
-❌ External API contracts (controllers remain unchanged)
-❌ DTO structures (`DetectIntentRequestDTO`, `DetectIntentResponseDTO`)
-❌ Conversation storage logic (Memorystore + Firestore)
-❌ DLP obfuscation flow
-❌ Session management (30-minute timeout)
-❌ Notification storage
-
---
-
-## Questions for RAG Team
-
-Before implementation:
-
-1. **Endpoint URL:** What is the actual RAG server URL?
-2. **Authentication:** Do we need API key authentication? If yes, what's the header format?
-3. **Timeout:** What's a reasonable timeout? (We're using 30s as default)
-4. **Rate Limiting:** Any rate limits we should be aware of?
-5. **Conversation History:** Does RAG need explicit conversation history, or does it fetch by phone_number internally?
-6. **Response Parameters:** Will RAG return any extracted parameters, or just `response_text`?
-7. **Health Check:** Is there a `/health` endpoint for monitoring?
-8. **Versioning:** Should we use `/api/v1/query` or a different version?
-
---
-
-## Changelog
-
-| Version | Date | Changes |
-|---------|------|---------|
-| 1.0 | 2025-02-22 | Initial specification based on 3 core requirements |
--- a/docs/rag-migration-guide.md
+++ b/docs/rag-migration-guide.md
@@ -1,424 +0,0 @@
-# RAG Migration Guide
-
-## Overview
-
-This guide explains how to migrate from Dialogflow CX to the RAG (Retrieval-Augmented Generation) server for intent detection and response generation.
-
-## Architecture
-
-The integration layer now supports **both Dialogflow and RAG** implementations through a common interface (`IntentDetectionService`). You can switch between them using a configuration property.
-
-```
-┌─────────────────────────────────────────┐
-│  ConversationManagerService /           │
-│  NotificationManagerService             │
-└────────────────┬────────────────────────┘
-                 │
-                 ▼
-┌─────────────────────────────────────────┐
-│    IntentDetectionService (interface)   │
-└────────────┬────────────────────────────┘
-             │
-      ┌──────┴──────┐
-      │             │
-      ▼             ▼
-┌──────────┐  ┌──────────┐
-│Dialogflow│  │   RAG    │
-│ Client   │  │  Client  │
-└──────────┘  └──────────┘
-```
-
-## Quick Start
-
-### 1. Configure the RAG Server
-
-Set the following environment variables:
-
-```bash
-# Select RAG as the intent detection client
-export INTENT_DETECTION_CLIENT=rag
-
-# RAG server URL
-export RAG_SERVER_URL=https://your-rag-server.com
-
-# Optional: API key for authentication
-export RAG_SERVER_API_KEY=your-api-key-here
-
-# Optional: Customize timeouts and retries (defaults shown)
-export RAG_SERVER_TIMEOUT=30s
-export RAG_SERVER_RETRY_MAX_ATTEMPTS=3
-export RAG_SERVER_RETRY_BACKOFF=1s
-```
-
-### 2. Deploy and Test
-
-Deploy the application with the new configuration:
-
-```bash
-# Using Docker
-docker build -t capa-integracion:rag .
-docker run -e INTENT_DETECTION_CLIENT=rag \
-           -e RAG_SERVER_URL=https://your-rag-server.com \
-           capa-integracion:rag
-
-# Or using Maven
-mvn spring-boot:run -Dspring-boot.run.profiles=dev
-```
-
-### 3. Monitor Logs
-
-On startup, you should see:
-
-```
-✓ Intent detection configured to use RAG client
-RAG Client initialized successfully with endpoint: https://your-rag-server.com
-```
-
-## Configuration Reference
-
-### Intent Detection Selection
-
-| Property | Values | Default | Description |
-|----------|--------|---------|-------------|
-| `intent.detection.client` | `dialogflow`, `rag` | `dialogflow` | Selects which implementation to use |
-
-### RAG Server Configuration
-
-| Property | Type | Default | Description |
-|----------|------|---------|-------------|
-| `rag.server.url` | URL | `http://localhost:8080` | RAG server base URL |
-| `rag.server.timeout` | Duration | `30s` | HTTP request timeout |
-| `rag.server.retry.max-attempts` | Integer | `3` | Maximum retry attempts on errors |
-| `rag.server.retry.backoff` | Duration | `1s` | Initial backoff duration for retries |
-| `rag.server.api-key` | String | (empty) | Optional API key for authentication |
-
-### Dialogflow Configuration (Kept for Rollback)
-
-These properties remain unchanged and are used when `intent.detection.client=dialogflow`:
-
-```properties
-dialogflow.cx.project-id=${DIALOGFLOW_CX_PROJECT_ID}
-dialogflow.cx.location=${DIALOGFLOW_CX_LOCATION}
-dialogflow.cx.agent-id=${DIALOGFLOW_CX_AGENT_ID}
-dialogflow.default-language-code=${DIALOGFLOW_DEFAULT_LANGUAGE_CODE:es}
-```
-
-## Switching Between Implementations
-
-### Switch to RAG
-
-```bash
-export INTENT_DETECTION_CLIENT=rag
-```
-
-### Switch Back to Dialogflow
-
-```bash
-export INTENT_DETECTION_CLIENT=dialogflow
-```
-
-**No code changes required!** Just restart the application.
-
-## What Stays the Same
-
-✅ **External API contracts** - Controllers remain unchanged
-✅ **DTOs** - `DetectIntentRequestDTO` and `DetectIntentResponseDTO` unchanged
-✅ **Conversation storage** - Memorystore + Firestore persistence unchanged
-✅ **DLP obfuscation** - Data Loss Prevention flow unchanged
-✅ **Session management** - 30-minute timeout logic unchanged
-✅ **Notification handling** - Notification storage and retrieval unchanged
-
-## What Changes
-
-### RAG Receives:
- Phone number (for internal conversation history tracking)
- Obfuscated user input (already processed by DLP)
- Notification context (when applicable)
-
-### RAG Returns:
- Response text (generated by RAG)
- Response ID (for tracking)
- Optional parameters (extracted/computed by RAG)
-
-## Data Flow
-
-### Conversation Flow
-```
-User Message
-    ↓
-DLP Obfuscation
-    ↓
-ConversationManagerService
-    ↓
-IntentDetectionService (RAG or Dialogflow)
-    ↓
-RagRequestMapper → RAG Server → RagResponseMapper
-    ↓
-DetectIntentResponseDTO
-    ↓
-Persist to Memorystore + Firestore
-    ↓
-Response to User
-```
-
-### Notification Flow
-```
-Notification Event
-    ↓
-DLP Obfuscation
-    ↓
-NotificationManagerService
-    ↓
-Store Notification (Memorystore + Firestore)
-    ↓
-IntentDetectionService (RAG or Dialogflow)
-    ↓
-RagRequestMapper → RAG Server → RagResponseMapper
-    ↓
-DetectIntentResponseDTO
-    ↓
-Response to User
-```
-
-## Redundancy by Design
-
-The integration layer intentionally maintains **redundant functionality** to ensure safe migration:
-
-1. **Conversation History**
-   - Integration layer: Continues to store history in Memorystore + Firestore
-   - RAG server: Maintains its own history by phone number
-   - **Why:** Allows gradual migration without data loss
-
-2. **Session Management**
-   - Integration layer: Continues to enforce 30-minute timeout
-   - RAG server: Handles session internally by phone number
-   - **Why:** Preserves existing business logic
-
-3. **Parameter Passing**
-   - Integration layer: Continues to extract and pass all parameters
-   - RAG server: Uses only what it needs (phone number, text, notifications)
-   - **Why:** Maintains flexibility for future requirements
-
-## Troubleshooting
-
-### RAG Server Not Responding
-
-**Symptom:** Errors like "RAG connection failed" or "RAG request timeout"
-
-**Solution:**
-1. Verify `RAG_SERVER_URL` is correct
-2. Check RAG server is running and accessible
-3. Verify network connectivity
-4. Check RAG server logs for errors
-5. Temporarily switch back to Dialogflow:
-   ```bash
-   export INTENT_DETECTION_CLIENT=dialogflow
-   ```
-
-### Invalid RAG Response Format
-
-**Symptom:** Errors like "Failed to parse RAG response"
-
-**Solution:**
-1. Verify RAG server implements the API specification (see `docs/rag-api-specification.md`)
-2. Check RAG server response format matches expected structure
-3. Review `RagResponseMapper` logs for specific parsing errors
-
-### Missing Phone Number
-
-**Symptom:** Error "Phone number is required in request parameters"
-
-**Solution:**
-1. Verify external requests include phone number in user data
-2. Check `ExternalConvRequestMapper` correctly maps phone number to `telefono` parameter
-
-### Dialogflow Fallback Issues
-
-**Symptom:** After switching back to Dialogflow, errors occur
-
-**Solution:**
-1. Verify all Dialogflow environment variables are still set:
-   - `DIALOGFLOW_CX_PROJECT_ID`
-   - `DIALOGFLOW_CX_LOCATION`
-   - `DIALOGFLOW_CX_AGENT_ID`
-2. Check Dialogflow credentials are valid
-
-## Rollback Plan
-
-If issues arise with RAG, immediately rollback:
-
-### Step 1: Switch Configuration
-```bash
-export INTENT_DETECTION_CLIENT=dialogflow
-```
-
-### Step 2: Restart Application
-```bash
-# Docker
-docker restart <container-id>
-
-# Kubernetes
-kubectl rollout restart deployment/capa-integracion
-```
-
-### Step 3: Verify
-Check logs for:
-```
-✓ Intent detection configured to use Dialogflow CX client
-Dialogflow CX SessionsClient initialized successfully
-```
-
-## Monitoring
-
-### Key Metrics to Monitor
-
-1. **Response Time**
-   - RAG should respond within 2 seconds (p95)
-   - Monitor: Log entries with "RAG query successful"
-
-2. **Error Rate**
-   - Target: < 0.5% error rate
-   - Monitor: Log entries with "RAG query failed"
-
-3. **Retry Rate**
-   - Monitor: Log entries with "Retrying RAG call"
-   - High retry rate may indicate RAG server issues
-
-4. **Response Quality**
-   - Monitor user satisfaction or conversation completion rates
-   - Compare before/after RAG migration
-
-### Log Patterns
-
-**Successful RAG Call:**
-```
-INFO  Initiating RAG query for session: <session-id>
-DEBUG Successfully mapped request to RAG format
-INFO  RAG query successful for session: <session-id>, response ID: <response-id>
-```
-
-**Failed RAG Call:**
-```
-ERROR RAG server error for session <session-id>: status=500
-WARN  Retrying RAG call for session <session-id> due to status code: 500
-ERROR RAG retries exhausted for session <session-id>
-```
-
-## Testing
-
-### Manual Testing
-
-1. **Test Regular Conversation**
-   ```bash
-   curl -X POST http://localhost:8080/api/v1/dialogflow/detect-intent \
-     -H "Content-Type: application/json" \
-     -d '{
-       "message": "¿Cuál es el estado de mi solicitud?",
-       "user": {
-         "telefono": "573001234567",
-         "nickname": "TestUser"
-       },
-       "channel": "web",
-       "tipo": "text"
-     }'
-   ```
-
-2. **Test Notification Flow**
-   ```bash
-   curl -X POST http://localhost:8080/api/v1/dialogflow/notification \
-     -H "Content-Type: application/json" \
-     -d '{
-       "text": "Tu documento ha sido aprobado",
-       "phoneNumber": "573001234567",
-       "hiddenParameters": {
-         "document_id": "DOC-2025-001"
-       }
-     }'
-   ```
-
-### Expected Behavior
-
- RAG should return relevant responses based on conversation context
- Response time should be similar to or better than Dialogflow
- All parameters should be preserved in conversation history
- Notification context should be used in RAG responses
-
-## Migration Phases (Recommended)
-
-### Phase 1: Development Testing (1 week)
- Deploy RAG to dev environment
- Set `INTENT_DETECTION_CLIENT=rag`
- Test all conversation flows manually
- Verify notification handling
-
-### Phase 2: QA Environment (1 week)
- Deploy to QA with RAG enabled
- Run automated test suite
- Perform load testing
- Compare responses with Dialogflow baseline
-
-### Phase 3: Production Pilot (1-2 weeks)
- Deploy to production with `INTENT_DETECTION_CLIENT=dialogflow` (Dialogflow still active)
- Gradually switch to RAG:
-  - Week 1: 10% of traffic
-  - Week 2: 50% of traffic
-  - Week 3: 100% of traffic
- Monitor metrics closely
-
-### Phase 4: Full Migration
- Set `INTENT_DETECTION_CLIENT=rag` for all environments
- Keep Dialogflow config for potential rollback
- Monitor for 2 weeks before considering removal of Dialogflow dependencies
-
-## Future Cleanup (Optional)
-
-After RAG is stable in production for 1+ month:
-
-### Phase 1: Deprecate Dialogflow
-1. Add `@Deprecated` annotation to `DialogflowClientService`
-2. Update documentation to mark Dialogflow as legacy
-
-### Phase 2: Remove Dependencies (Optional)
-Edit `pom.xml` and remove:
-```xml
-<!-- Can be removed after RAG is stable -->
-<!--
-<dependency>
-    <groupId>com.google.cloud</groupId>
-    <artifactId>google-cloud-dialogflow-cx</artifactId>
-</dependency>
-<dependency>
-    <groupId>com.google.protobuf</groupId>
-    <artifactId>protobuf-java-util</artifactId>
-</dependency>
-<dependency>
-    <groupId>com.google.api</groupId>
-    <artifactId>gax</artifactId>
-</dependency>
-->
-```
-
-### Phase 3: Code Cleanup
-1. Remove `DialogflowClientService.java`
-2. Remove `DialogflowRequestMapper.java`
-3. Remove `DialogflowResponseMapper.java`
-4. Remove Dialogflow-specific tests
-5. Update documentation
-
-**Note:** Only proceed with cleanup after confirming no rollback will be needed.
-
-## Support
-
-For issues or questions:
-1. Check this guide and `docs/rag-api-specification.md`
-2. Review application logs
-3. Contact the RAG server team for API issues
-4. Contact the integration layer team for mapping/configuration issues
-
-## Summary
-
- **Minimal Code Changes:** Only configuration needed to switch
- **Safe Rollback:** Can switch back to Dialogflow instantly
- **Redundancy:** Both systems store data for safety
- **Gradual Migration:** Supports phased rollout
- **No External Impact:** API contracts unchanged
--- a/docs/rag-migration-summary.md
+++ b/docs/rag-migration-summary.md
@@ -1,440 +0,0 @@
-# RAG Migration - Implementation Summary
-
-## ✅ **Migration Complete**
-
-All components for the Dialogflow → RAG migration have been successfully implemented and tested.
-
---
-
-## 📦 **What Was Delivered**
-
-### 1. Core Implementation (7 new files)
-
-| File | Purpose | Lines | Status |
-|------|---------|-------|--------|
-| `IntentDetectionService.java` | Common interface for both implementations | 20 | ✅ Complete |
-| `RagClientService.java` | HTTP client for RAG server | 180 | ✅ Complete |
-| `RagRequestMapper.java` | DTO → RAG format conversion | 140 | ✅ Complete |
-| `RagResponseMapper.java` | RAG → DTO conversion | 60 | ✅ Complete |
-| `RagQueryRequest.java` | RAG request DTO | 25 | ✅ Complete |
-| `RagQueryResponse.java` | RAG response DTO | 20 | ✅ Complete |
-| `RagClientException.java` | Custom exception | 15 | ✅ Complete |
-| `IntentDetectionConfig.java` | Feature flag configuration | 50 | ✅ Complete |
-
-**Total:** ~510 lines of production code
-
-### 2. Configuration Files (3 updated)
-
-| File | Changes | Status |
-|------|---------|--------|
-| `application-dev.properties` | Added RAG configuration | ✅ Updated |
-| `application-prod.properties` | Added RAG configuration | ✅ Updated |
-| `application-qa.properties` | Added RAG configuration | ✅ Updated |
-
-### 3. Service Integration (2 updated)
-
-| File | Changes | Status |
-|------|---------|--------|
-| `ConversationManagerService.java` | Uses `IntentDetectionService` | ✅ Updated |
-| `NotificationManagerService.java` | Uses `IntentDetectionService` | ✅ Updated |
-| `DialogflowClientService.java` | Implements interface | ✅ Updated |
-
-### 4. Test Suite (4 new test files)
-
-| Test File | Tests | Coverage | Status |
-|-----------|-------|----------|--------|
-| `RagRequestMapperTest.java` | 15 tests | Request mapping | ✅ Complete |
-| `RagResponseMapperTest.java` | 10 tests | Response mapping | ✅ Complete |
-| `RagClientServiceTest.java` | 7 tests | Service unit tests | ✅ Complete |
-| `RagClientIntegrationTest.java` | 12 tests | End-to-end with mock server | ✅ Complete |
-
-**Total:** 44 comprehensive tests (~1,100 lines)
-
-### 5. Documentation (3 new docs)
-
-| Document | Purpose | Pages | Status |
-|----------|---------|-------|--------|
-| `rag-api-specification.md` | RAG API contract | 8 | ✅ Complete |
-| `rag-migration-guide.md` | Migration instructions | 12 | ✅ Complete |
-| `rag-testing-guide.md` | Testing documentation | 10 | ✅ Complete |
-
-**Total:** ~30 pages of documentation
-
-### 6. Dependency Updates
-
-Added to `pom.xml`:
-```xml
-<dependency>
-    <groupId>com.squareup.okhttp3</groupId>
-    <artifactId>mockwebserver</artifactId>
-    <version>4.12.0</version>
-    <scope>test</scope>
-</dependency>
-```
-
---
-
-## 🎯 **Key Features**
-
-### ✅ **Zero-Downtime Migration**
- Switch between Dialogflow and RAG with a single environment variable
- No code deployment required to switch
- Instant rollback capability
-
-### ✅ **Backward Compatible**
- All external APIs unchanged
- All DTOs preserved
- All existing services work without modification
-
-### ✅ **Redundant Safety**
- Conversation history stored in both systems
- Session management preserved
- DLP obfuscation maintained
-
-### ✅ **Production-Ready**
- Retry logic: 3 attempts with exponential backoff
- Timeout handling: 30-second default
- Error mapping: Comprehensive exception handling
- Logging: Detailed info, debug, and error logs
-
-### ✅ **Fully Reactive**
- Native WebClient integration
- Project Reactor patterns
- Non-blocking I/O throughout
-
-### ✅ **Comprehensive Testing**
- 44 tests across unit and integration levels
- Mock HTTP server for realistic testing
- Retry scenarios validated
- Edge cases covered
-
---
-
-## 🔄 **How It Works**
-
-### Configuration-Based Switching
-
-**Use RAG:**
-```bash
-export INTENT_DETECTION_CLIENT=rag
-export RAG_SERVER_URL=https://your-rag-server.com
-export RAG_SERVER_API_KEY=your-api-key
-```
-
-**Use Dialogflow:**
-```bash
-export INTENT_DETECTION_CLIENT=dialogflow
-```
-
-### Request Flow
-
-```
-User Request
-    ↓
-DLP Obfuscation
-    ↓
-ConversationManagerService / NotificationManagerService
-    ↓
-IntentDetectionService (interface)
-    ↓
-    ├─→ DialogflowClientService (if client=dialogflow)
-    └─→ RagClientService (if client=rag)
-            ↓
-            RagRequestMapper
-            ↓
-            WebClient → RAG Server
-            ↓
-            RagResponseMapper
-    ↓
-DetectIntentResponseDTO
-    ↓
-Persist to Memorystore + Firestore
-    ↓
-Response to User
-```
-
---
-
-## 📊 **Test Coverage**
-
-### Unit Tests (32 tests)
-
-**RagRequestMapper (15 tests):**
- ✅ Text input mapping
- ✅ Event input mapping
- ✅ Notification parameter extraction
- ✅ Phone number validation
- ✅ Parameter prefix removal
- ✅ Type determination
- ✅ Null/empty handling
-
-**RagResponseMapper (10 tests):**
- ✅ Complete response mapping
- ✅ Response ID generation
- ✅ Null field handling
- ✅ Complex parameter types
- ✅ Long text handling
-
-**RagClientService (7 tests):**
- ✅ Mapper integration
- ✅ Null validation
- ✅ Exception propagation
- ✅ Configuration variants
-
-### Integration Tests (12 tests)
-
-**RagClientIntegrationTest:**
- ✅ Full HTTP request/response cycle
- ✅ Request headers validation
- ✅ Notification context transmission
- ✅ Event-based inputs
- ✅ Retry logic (500, 503, 504)
- ✅ No retry on 4xx errors
- ✅ Timeout handling
- ✅ Complex parameter types
- ✅ Empty/missing field handling
-
---
-
-## 🚀 **Ready to Deploy**
-
-### Prerequisites
-
-1. **RAG Server Running**
-   - Implement API per `docs/rag-api-specification.md`
-   - Endpoint: `POST /api/v1/query`
-
-2. **Environment Variables Set**
-   ```bash
-   INTENT_DETECTION_CLIENT=rag
-   RAG_SERVER_URL=https://your-rag-server.com
-   RAG_SERVER_API_KEY=your-api-key  # optional
-   ```
-
-### Deployment Steps
-
-1. **Build Application**
-   ```bash
-   mvn clean package
-   ```
-
-2. **Run Tests**
-   ```bash
-   mvn test
-   ```
-
-3. **Deploy to Dev**
-   ```bash
-   # Deploy with RAG enabled
-   kubectl apply -f deployment-dev.yaml
-   ```
-
-4. **Verify Logs**
-   ```
-   ✓ Intent detection configured to use RAG client
-   RAG Client initialized successfully with endpoint: https://...
-   ```
-
-5. **Test Endpoints**
-   ```bash
-   # Test conversation
-   curl -X POST http://localhost:8080/api/v1/dialogflow/detect-intent \
-     -H "Content-Type: application/json" \
-     -d '{"message": "Hola", "user": {"telefono": "123"}}'
-   ```
-
---
-
-## 📈 **Migration Phases**
-
-### Phase 1: Development (1 week) - **READY NOW**
- ✅ Code complete
- ✅ Tests passing
- ✅ Documentation ready
- 🎯 Deploy to dev environment with `INTENT_DETECTION_CLIENT=rag`
-
-### Phase 2: QA Testing (1 week)
- 🎯 Run automated test suite
- 🎯 Manual testing of all flows
- 🎯 Load testing
- 🎯 Compare responses with Dialogflow
-
-### Phase 3: Production Pilot (2-3 weeks)
- 🎯 Deploy with feature flag
- 🎯 Gradual rollout: 10% → 50% → 100%
- 🎯 Monitor metrics (response time, errors)
- 🎯 Keep Dialogflow as fallback
-
-### Phase 4: Full Migration
- 🎯 Set `INTENT_DETECTION_CLIENT=rag` for all environments
- 🎯 Monitor for 2 weeks
- 🎯 Remove Dialogflow dependencies (optional)
-
---
-
-## 🔍 **Monitoring**
-
-### Key Metrics
-
-| Metric | Target | How to Monitor |
-|--------|--------|----------------|
-| Response Time (p95) | < 2s | Log entries: "RAG query successful" |
-| Error Rate | < 0.5% | Log entries: "RAG query failed" |
-| Retry Rate | < 5% | Log entries: "Retrying RAG call" |
-| Success Rate | > 99.5% | Count successful vs failed requests |
-
-### Log Patterns
-
-**Success:**
-```
-INFO  Initiating RAG query for session: <session-id>
-INFO  RAG query successful for session: <session-id>
-```
-
-**Failure:**
-```
-ERROR RAG server error for session <session-id>: status=500
-ERROR RAG retries exhausted for session <session-id>
-```
-
---
-
-## 🛡️ **Rollback Plan**
-
-If issues occur:
-
-### Step 1: Switch Configuration (< 1 minute)
-```bash
-export INTENT_DETECTION_CLIENT=dialogflow
-```
-
-### Step 2: Restart Application
-```bash
-kubectl rollout restart deployment/capa-integracion
-```
-
-### Step 3: Verify
-```
-✓ Intent detection configured to use Dialogflow CX client
-```
-
-**No code changes needed. No data loss.**
-
---
-
-## 📁 **File Structure**
-
-```
-capa-de-integracion/
-├── docs/
-│   ├── rag-api-specification.md        [NEW - 250 lines]
-│   ├── rag-migration-guide.md          [NEW - 400 lines]
-│   ├── rag-testing-guide.md            [NEW - 350 lines]
-│   └── rag-migration-summary.md        [NEW - this file]
-├── src/main/java/com/example/
-│   ├── config/
-│   │   └── IntentDetectionConfig.java  [NEW - 50 lines]
-│   ├── dto/rag/
-│   │   ├── RagQueryRequest.java        [NEW - 25 lines]
-│   │   └── RagQueryResponse.java       [NEW - 20 lines]
-│   ├── exception/
-│   │   └── RagClientException.java     [NEW - 15 lines]
-│   ├── mapper/rag/
-│   │   ├── RagRequestMapper.java       [NEW - 140 lines]
-│   │   └── RagResponseMapper.java      [NEW - 60 lines]
-│   ├── service/base/
-│   │   ├── IntentDetectionService.java [NEW - 20 lines]
-│   │   ├── RagClientService.java       [NEW - 180 lines]
-│   │   └── DialogflowClientService.java [UPDATED]
-│   ├── service/conversation/
-│   │   └── ConversationManagerService.java [UPDATED]
-│   └── service/notification/
-│       └── NotificationManagerService.java [UPDATED]
-├── src/main/resources/
-│   ├── application-dev.properties      [UPDATED]
-│   ├── application-prod.properties     [UPDATED]
-│   └── application-qa.properties       [UPDATED]
-├── src/test/java/com/example/
-│   ├── mapper/rag/
-│   │   ├── RagRequestMapperTest.java   [NEW - 280 lines]
-│   │   └── RagResponseMapperTest.java  [NEW - 220 lines]
-│   ├── service/unit_testing/
-│   │   └── RagClientServiceTest.java   [NEW - 150 lines]
-│   └── service/integration_testing/
-│       └── RagClientIntegrationTest.java [NEW - 450 lines]
-└── pom.xml                             [UPDATED]
-```
-
---
-
-## 🎉 **Benefits Achieved**
-
-### Technical Benefits
- ✅ Cleaner architecture with interface abstraction
- ✅ Easier to switch implementations
- ✅ Better testability
- ✅ Simpler HTTP-based protocol vs gRPC
- ✅ No Protobuf complexity
-
-### Operational Benefits
- ✅ Instant rollback capability
- ✅ No downtime during migration
- ✅ Gradual rollout support
- ✅ Better monitoring and debugging
-
-### Business Benefits
- ✅ Freedom from Dialogflow limitations
- ✅ Custom RAG implementation control
- ✅ Cost optimization potential
- ✅ Better response quality (once RAG is tuned)
-
---
-
-## 📞 **Support & Resources**
-
-### Documentation
- **API Specification:** `docs/rag-api-specification.md`
- **Migration Guide:** `docs/rag-migration-guide.md`
- **Testing Guide:** `docs/rag-testing-guide.md`
-
-### Key Commands
-
-**Run All Tests:**
-```bash
-mvn test
-```
-
-**Run RAG Tests Only:**
-```bash
-mvn test -Dtest="**/rag/**/*Test"
-```
-
-**Build Application:**
-```bash
-mvn clean package
-```
-
-**Run Locally:**
-```bash
-mvn spring-boot:run -Dspring-boot.run.profiles=dev
-```
-
---
-
-## ✨ **Summary**
-
-The RAG migration implementation is **production-ready** and includes:
-
- ✅ **~510 lines** of production code
- ✅ **~1,100 lines** of test code
- ✅ **~1,000 lines** of documentation
- ✅ **44 comprehensive tests**
- ✅ **Zero breaking changes**
- ✅ **Instant rollback support**
-
-**Next Action:** Deploy to dev environment and test with real RAG server.
-
---
-
-*Generated: 2025-02-22*
-*Status: ✅ Ready for Deployment*
--- a/docs/rag-testing-guide.md
+++ b/docs/rag-testing-guide.md
@@ -1,412 +0,0 @@
-# RAG Client Testing Guide
-
-## Overview
-
-This document describes the comprehensive test suite for the RAG client implementation, including unit tests and integration tests.
-
-## Test Structure
-
-```
-src/test/java/com/example/
-├── mapper/rag/
-│   ├── RagRequestMapperTest.java          (Unit tests for request mapping)
-│   └── RagResponseMapperTest.java         (Unit tests for response mapping)
-├── service/unit_testing/
-│   └── RagClientServiceTest.java          (Unit tests for RAG client service)
-└── service/integration_testing/
-    └── RagClientIntegrationTest.java      (Integration tests with mock server)
-```
-
-## Test Coverage Summary
-
-### 1. RagRequestMapperTest (15 tests)
-
-**Purpose:** Validates conversion from `DetectIntentRequestDTO` to `RagQueryRequest`.
-
-| Test | Description |
-|------|-------------|
-| `mapToRagRequest_withTextInput_shouldMapCorrectly` | Text input mapping |
-| `mapToRagRequest_withEventInput_shouldMapCorrectly` | Event input mapping (LLM flow) |
-| `mapToRagRequest_withNotificationParameters_shouldMapAsNotificationType` | Notification detection |
-| `mapToRagRequest_withNotificationTextOnly_shouldMapNotificationContext` | Notification context |
-| `mapToRagRequest_withMissingPhoneNumber_shouldThrowException` | Phone validation |
-| `mapToRagRequest_withNullTextAndEvent_shouldThrowException` | Input validation |
-| `mapToRagRequest_withEmptyTextInput_shouldThrowException` | Empty text validation |
-| `mapToRagRequest_withNullRequestDTO_shouldThrowException` | Null safety |
-| `mapToRagRequest_withNullQueryParams_shouldUseEmptyParameters` | Empty params handling |
-| `mapToRagRequest_withMultipleNotificationParameters_shouldExtractAll` | Parameter extraction |
-| `mapToRagRequest_withDefaultLanguageCode_shouldUseNull` | Language code handling |
-
-**Key Scenarios Covered:**
- ✅ Text input mapping
- ✅ Event input mapping (for LLM hybrid flow)
- ✅ Notification parameter detection and extraction
- ✅ Phone number validation
- ✅ Parameter prefix removal (`notification_po_*` → clean keys)
- ✅ Request type determination (conversation vs notification)
- ✅ Null and empty input handling
-
-### 2. RagResponseMapperTest (10 tests)
-
-**Purpose:** Validates conversion from `RagQueryResponse` to `DetectIntentResponseDTO`.
-
-| Test | Description |
-|------|-------------|
-| `mapFromRagResponse_withCompleteResponse_shouldMapCorrectly` | Full response mapping |
-| `mapFromRagResponse_withNullResponseId_shouldGenerateOne` | Response ID generation |
-| `mapFromRagResponse_withEmptyResponseId_shouldGenerateOne` | Empty ID handling |
-| `mapFromRagResponse_withNullResponseText_shouldUseEmptyString` | Null text handling |
-| `mapFromRagResponse_withNullParameters_shouldUseEmptyMap` | Null params handling |
-| `mapFromRagResponse_withNullConfidence_shouldStillMapSuccessfully` | Confidence optional |
-| `mapFromRagResponse_withEmptyParameters_shouldMapEmptyMap` | Empty params |
-| `mapFromRagResponse_withComplexParameters_shouldMapCorrectly` | Complex types |
-| `mapFromRagResponse_withMinimalResponse_shouldMapSuccessfully` | Minimal valid response |
-| `mapFromRagResponse_withLongResponseText_shouldMapCorrectly` | Long text handling |
-
-**Key Scenarios Covered:**
- ✅ Complete response mapping
- ✅ Response ID generation when missing
- ✅ Null/empty field handling
- ✅ Complex parameter types (strings, numbers, booleans, nested objects)
- ✅ Minimal valid responses
- ✅ Long text handling
-
-### 3. RagClientServiceTest (7 tests)
-
-**Purpose:** Unit tests for RagClientService behavior.
-
-| Test | Description |
-|------|-------------|
-| `detectIntent_withValidRequest_shouldReturnMappedResponse` | Mapper integration |
-| `detectIntent_withNullSessionId_shouldThrowException` | Session ID validation |
-| `detectIntent_withNullRequest_shouldThrowException` | Request validation |
-| `detectIntent_withMapperException_shouldPropagateAsIllegalArgumentException` | Error propagation |
-| `constructor_withApiKey_shouldInitializeSuccessfully` | API key configuration |
-| `constructor_withoutApiKey_shouldInitializeSuccessfully` | No API key |
-| `constructor_withCustomConfiguration_shouldInitializeCorrectly` | Custom config |
-
-**Key Scenarios Covered:**
- ✅ Mapper integration
- ✅ Null validation
- ✅ Exception propagation
- ✅ Configuration variants
- ✅ Initialization with/without API key
-
-### 4. RagClientIntegrationTest (12 tests)
-
-**Purpose:** End-to-end tests with mock HTTP server using OkHttp MockWebServer.
-
-| Test | Description |
-|------|-------------|
-| `detectIntent_withSuccessfulResponse_shouldReturnMappedDTO` | Successful HTTP call |
-| `detectIntent_withNotificationFlow_shouldSendNotificationContext` | Notification request |
-| `detectIntent_withEventInput_shouldMapEventAsText` | Event handling |
-| `detectIntent_with500Error_shouldRetryAndFail` | Retry on 500 |
-| `detectIntent_with503Error_shouldRetryAndSucceed` | Retry success |
-| `detectIntent_with400Error_shouldFailImmediatelyWithoutRetry` | No retry on 4xx |
-| `detectIntent_withTimeout_shouldFailWithTimeoutError` | Timeout handling |
-| `detectIntent_withEmptyResponseText_shouldMapSuccessfully` | Empty response |
-| `detectIntent_withMissingResponseId_shouldGenerateOne` | Missing ID |
-| `detectIntent_withComplexParameters_shouldMapCorrectly` | Complex params |
-
-**Key Scenarios Covered:**
- ✅ Full HTTP request/response cycle
- ✅ Request headers validation (API key, session ID)
- ✅ Notification context in request body
- ✅ Event-based inputs
- ✅ Retry logic (exponential backoff on 500, 503, 504)
- ✅ No retry on client errors (4xx)
- ✅ Timeout handling
- ✅ Empty and missing field handling
- ✅ Complex parameter types
-
-## Running Tests
-
-### Run All Tests
-```bash
-mvn test
-```
-
-### Run Specific Test Class
-```bash
-mvn test -Dtest=RagRequestMapperTest
-mvn test -Dtest=RagResponseMapperTest
-mvn test -Dtest=RagClientServiceTest
-mvn test -Dtest=RagClientIntegrationTest
-```
-
-### Run RAG-Related Tests Only
-```bash
-mvn test -Dtest="**/rag/**/*Test"
-```
-
-### Run with Coverage
-```bash
-mvn test jacoco:report
-```
-
-## Test Dependencies
-
-The following dependencies are required for testing:
-
-```xml
-<!-- JUnit 5 (included in spring-boot-starter-test) -->
-<dependency>
-    <groupId>org.springframework.boot</groupId>
-    <artifactId>spring-boot-starter-test</artifactId>
-    <scope>test</scope>
-</dependency>
-
-<!-- Reactor Test (for reactive testing) -->
-<dependency>
-    <groupId>io.projectreactor</groupId>
-    <artifactId>reactor-test</artifactId>
-    <scope>test</scope>
-</dependency>
-
-<!-- OkHttp MockWebServer (for integration tests) -->
-<dependency>
-    <groupId>com.squareup.okhttp3</groupId>
-    <artifactId>mockwebserver</artifactId>
-    <version>4.12.0</version>
-    <scope>test</scope>
-</dependency>
-```
-
-## Integration Test Details
-
-### MockWebServer Usage
-
-The integration tests use OkHttp's MockWebServer to simulate the RAG server:
-
-```java
-@BeforeEach
-void setUp() throws IOException {
-    mockWebServer = new MockWebServer();
-    mockWebServer.start();
-
-    String baseUrl = mockWebServer.url("/").toString();
-    ragClientService = new RagClientService(baseUrl, ...);
-}
-
-@Test
-void testExample() {
-    // Enqueue mock response
-    mockWebServer.enqueue(new MockResponse()
-        .setBody("{...}")
-        .setHeader("Content-Type", "application/json")
-        .setResponseCode(200));
-
-    // Make request and verify
-    StepVerifier.create(ragClientService.detectIntent(...))
-        .assertNext(response -> { /* assertions */ })
-        .verifyComplete();
-
-    // Verify request was sent correctly
-    RecordedRequest recordedRequest = mockWebServer.takeRequest();
-    assertEquals("/api/v1/query", recordedRequest.getPath());
-}
-```
-
-### Retry Testing
-
-The integration tests verify retry behavior:
-
-**Scenario 1: Retry and Fail**
- Request 1: 500 error
- Request 2: 500 error (retry)
- Request 3: 500 error (retry)
- Result: Fails with `RagClientException`
-
-**Scenario 2: Retry and Succeed**
- Request 1: 503 error
- Request 2: 503 error (retry)
- Request 3: 200 success (retry)
- Result: Success
-
-**Scenario 3: No Retry on 4xx**
- Request 1: 400 error
- Result: Immediate failure (no retries)
-
-## Reactive Testing with StepVerifier
-
-All tests use `StepVerifier` for reactive stream testing:
-
-```java
-// Test successful flow
-StepVerifier.create(ragClientService.detectIntent(...))
-    .assertNext(response -> {
-        assertEquals("expected", response.responseText());
-    })
-    .verifyComplete();
-
-// Test error flow
-StepVerifier.create(ragClientService.detectIntent(...))
-    .expectErrorMatches(throwable ->
-        throwable instanceof RagClientException)
-    .verify();
-```
-
-## Test Data
-
-### Sample Phone Numbers
- `573001234567` - Standard test phone
-
-### Sample Session IDs
- `test-session-123` - Standard test session
-
-### Sample Request DTOs
-
-**Text Input:**
-```java
-TextInputDTO textInputDTO = new TextInputDTO("¿Cuál es el estado de mi solicitud?");
-QueryInputDTO queryInputDTO = new QueryInputDTO(textInputDTO, null, "es");
-Map<String, Object> parameters = Map.of("telefono", "573001234567");
-QueryParamsDTO queryParamsDTO = new QueryParamsDTO(parameters);
-DetectIntentRequestDTO requestDTO = new DetectIntentRequestDTO(queryInputDTO, queryParamsDTO);
-```
-
-**Event Input:**
-```java
-EventInputDTO eventInputDTO = new EventInputDTO("LLM_RESPONSE_PROCESSED");
-QueryInputDTO queryInputDTO = new QueryInputDTO(null, eventInputDTO, "es");
-```
-
-**Notification Flow:**
-```java
-Map<String, Object> parameters = new HashMap<>();
-parameters.put("telefono", "573001234567");
-parameters.put("notification_text", "Tu documento ha sido aprobado");
-parameters.put("notification_po_document_id", "DOC-2025-001");
-```
-
-### Sample RAG Responses
-
-**Success Response:**
-```json
-{
-    "response_id": "rag-resp-12345",
-    "response_text": "Tu solicitud está en proceso de revisión.",
-    "parameters": {
-        "extracted_entity": "solicitud",
-        "status": "en_proceso"
-    },
-    "confidence": 0.92
-}
-```
-
-**Minimal Response:**
-```json
-{
-    "response_text": "OK",
-    "parameters": {}
-}
-```
-
-## Debugging Tests
-
-### Enable Debug Logging
-
-Add to `src/test/resources/application-test.properties`:
-
-```properties
-logging.level.com.example.service.base.RagClientService=DEBUG
-logging.level.com.example.mapper.rag=DEBUG
-logging.level.okhttp3.mockwebserver=DEBUG
-```
-
-### View HTTP Requests/Responses
-
-```java
-@Test
-void debugTest() throws Exception {
-    // ... test code ...
-
-    RecordedRequest request = mockWebServer.takeRequest();
-    System.out.println("Request path: " + request.getPath());
-    System.out.println("Request headers: " + request.getHeaders());
-    System.out.println("Request body: " + request.getBody().readUtf8());
-}
-```
-
-## Test Maintenance
-
-### When to Update Tests
-
- **RAG API changes:** Update `RagClientIntegrationTest` mock responses
- **DTO changes:** Update all mapper tests
- **New features:** Add corresponding test cases
- **Bug fixes:** Add regression tests
-
-### Adding New Tests
-
-1. **Identify test type:** Unit or integration?
-2. **Choose test class:** Use existing or create new
-3. **Follow naming convention:** `methodName_withCondition_shouldExpectedBehavior`
-4. **Use AAA pattern:** Arrange, Act, Assert
-5. **Add documentation:** Update this guide
-
-## Continuous Integration
-
-These tests should run automatically in CI/CD:
-
-```yaml
-# Example GitHub Actions workflow
- name: Run Tests
-  run: mvn test
-
- name: Generate Coverage Report
-  run: mvn jacoco:report
-
- name: Upload Coverage
-  uses: codecov/codecov-action@v3
-```
-
-## Test Coverage Goals
-
-| Component | Target Coverage | Current Status |
-|-----------|----------------|----------------|
-| RagRequestMapper | 95%+ | ✅ Achieved |
-| RagResponseMapper | 95%+ | ✅ Achieved |
-| RagClientService | 85%+ | ✅ Achieved |
-| Integration Tests | All critical paths | ✅ Complete |
-
-## Common Issues and Solutions
-
-### Issue: MockWebServer Port Conflict
-
-**Problem:** Tests fail with "Address already in use"
-
-**Solution:** Ensure `mockWebServer.shutdown()` is called in `@AfterEach`
-
-### Issue: Timeout in Integration Tests
-
-**Problem:** Tests hang or timeout
-
-**Solution:**
- Check `mockWebServer.enqueue()` is called before request
- Verify timeout configuration in RagClientService
- Use shorter timeouts in tests
-
-### Issue: Flaky Retry Tests
-
-**Problem:** Retry tests sometimes fail
-
-**Solution:**
- Don't rely on timing-based assertions
- Use deterministic mock responses
- Verify request count instead of timing
-
-## Summary
-
-The RAG client test suite provides comprehensive coverage:
-
- ✅ **44 total tests** across 4 test classes
- ✅ **Unit tests** for all mapper logic
- ✅ **Integration tests** with mock HTTP server
- ✅ **Retry logic** thoroughly tested
- ✅ **Error handling** validated
- ✅ **Edge cases** covered (null, empty, missing fields)
- ✅ **Reactive patterns** tested with StepVerifier
-
-All tests use industry-standard testing libraries and patterns, ensuring maintainability and reliability.
--- a/src/main/java/com/example/config/IntentDetectionConfig.java
+++ b/src/main/java/com/example/config/IntentDetectionConfig.java
@@ -1,8 +1,3 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.config;

 import com.example.service.base.IntentDetectionService;
@@ -25,7 +20,9 @@ import org.springframework.context.annotation.Primary;
@Configuration
 public class IntentDetectionConfig {

-    private static final Logger logger = LoggerFactory.getLogger(IntentDetectionConfig.class);
+    private static final Logger logger = LoggerFactory.getLogger(
+        IntentDetectionConfig.class
+    );

    @Value("${intent.detection.client:dialogflow}")
    private String clientType;
@@ -41,17 +38,24 @@ public class IntentDetectionConfig {
    @Bean
    @Primary
    public IntentDetectionService intentDetectionService(
-            @Qualifier("dialogflowClientService") IntentDetectionService dialogflowService,
-            @Qualifier("ragClientService") IntentDetectionService ragService) {
-
+        @Qualifier(
+            "dialogflowClientService"
+        ) IntentDetectionService dialogflowService,
+        @Qualifier("ragClientService") IntentDetectionService ragService
+    ) {
        if ("rag".equalsIgnoreCase(clientType)) {
            logger.info("✓ Intent detection configured to use RAG client");
            return ragService;
        } else if ("dialogflow".equalsIgnoreCase(clientType)) {
-            logger.info("✓ Intent detection configured to use Dialogflow CX client");
+            logger.info(
+                "✓ Intent detection configured to use Dialogflow CX client"
+            );
            return dialogflowService;
        } else {
-            logger.warn("Unknown intent.detection.client value: '{}'. Defaulting to Dialogflow.", clientType);
+            logger.warn(
+                "Unknown intent.detection.client value: '{}'. Defaulting to Dialogflow.",
+                clientType
+            );
            return dialogflowService;
        }
    }
--- a/src/main/java/com/example/dto/rag/RagQueryRequest.java
+++ b/src/main/java/com/example/dto/rag/RagQueryRequest.java
@@ -1,13 +1,7 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.dto.rag;

 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
-
 import java.util.Map;

 /**
@@ -16,18 +10,18 @@ import java.util.Map;
 */
@JsonInclude(JsonInclude.Include.NON_NULL)
 public record RagQueryRequest(
-        @JsonProperty("phone_number") String phoneNumber,
-        @JsonProperty("text") String text,
-        @JsonProperty("type") String type,
-        @JsonProperty("notification") NotificationContext notification,
-        @JsonProperty("language_code") String languageCode
+    @JsonProperty("phone_number") String phoneNumber,
+    @JsonProperty("text") String text,
+    @JsonProperty("type") String type,
+    @JsonProperty("notification") NotificationContext notification,
+    @JsonProperty("language_code") String languageCode
 ) {
    /**
     * Nested record for notification context
     */
    @JsonInclude(JsonInclude.Include.NON_NULL)
    public record NotificationContext(
-            @JsonProperty("text") String text,
-            @JsonProperty("parameters") Map<String, Object> parameters
+        @JsonProperty("text") String text,
+        @JsonProperty("parameters") Map<String, Object> parameters
    ) {}
 }
--- a/src/main/java/com/example/dto/rag/RagQueryResponse.java
+++ b/src/main/java/com/example/dto/rag/RagQueryResponse.java
@@ -1,13 +1,7 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.dto.rag;

 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import com.fasterxml.jackson.annotation.JsonProperty;
-
 import java.util.Map;

 /**
@@ -16,8 +10,8 @@ import java.util.Map;
 */
@JsonIgnoreProperties(ignoreUnknown = true)
 public record RagQueryResponse(
-        @JsonProperty("response_id") String responseId,
-        @JsonProperty("response_text") String responseText,
-        @JsonProperty("parameters") Map<String, Object> parameters,
-        @JsonProperty("confidence") Double confidence
+    @JsonProperty("response_id") String responseId,
+    @JsonProperty("response_text") String responseText,
+    @JsonProperty("parameters") Map<String, Object> parameters,
+    @JsonProperty("confidence") Double confidence
 ) {}
--- a/src/main/java/com/example/exception/RagClientException.java
+++ b/src/main/java/com/example/exception/RagClientException.java
@@ -1,8 +1,3 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.exception;

 /**
--- a/src/main/java/com/example/mapper/rag/RagRequestMapper.java
+++ b/src/main/java/com/example/mapper/rag/RagRequestMapper.java
@@ -1,21 +1,15 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.mapper.rag;

 import com.example.dto.dialogflow.base.DetectIntentRequestDTO;
 import com.example.dto.dialogflow.conversation.QueryInputDTO;
 import com.example.dto.rag.RagQueryRequest;
 import com.example.dto.rag.RagQueryRequest.NotificationContext;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
-
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Objects;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;

 /**
 * Mapper component responsible for converting DetectIntentRequestDTO to RAG API format.
@@ -24,7 +18,9 @@ import java.util.Objects;
@Component
 public class RagRequestMapper {

-    private static final Logger logger = LoggerFactory.getLogger(RagRequestMapper.class);
+    private static final Logger logger = LoggerFactory.getLogger(
+        RagRequestMapper.class
+    );
    private static final String NOTIFICATION_PREFIX = "notification_po_";
    private static final String NOTIFICATION_TEXT_PARAM = "notification_text";

@@ -36,20 +32,34 @@ public class RagRequestMapper {
     * @param sessionId The session ID (not used by RAG but kept for logging)
     * @return A RagQueryRequest ready to send to the RAG server
     */
-    public RagQueryRequest mapToRagRequest(DetectIntentRequestDTO requestDto, String sessionId) {
-        Objects.requireNonNull(requestDto, "DetectIntentRequestDTO cannot be null");
+    public RagQueryRequest mapToRagRequest(
+        DetectIntentRequestDTO requestDto,
+        String sessionId
+    ) {
+        Objects.requireNonNull(
+            requestDto,
+            "DetectIntentRequestDTO cannot be null"
+        );

-        logger.debug("Mapping DetectIntentRequestDTO to RagQueryRequest for session: {}", sessionId);
+        logger.debug(
+            "Mapping DetectIntentRequestDTO to RagQueryRequest for session: {}",
+            sessionId
+        );

        // Extract phone number from parameters
-        Map<String, Object> parameters = requestDto.queryParams() != null
-            ? requestDto.queryParams().parameters()
-            : Map.of();
+        Map<String, Object> parameters =
+            requestDto.queryParams() != null
+                ? requestDto.queryParams().parameters()
+                : Map.of();

        String phoneNumber = extractPhoneNumber(parameters);
        if (phoneNumber == null || phoneNumber.isBlank()) {
-            logger.error("Phone number is required but not found in request parameters");
-            throw new IllegalArgumentException("Phone number is required in request parameters");
+            logger.error(
+                "Phone number is required but not found in request parameters"
+            );
+            throw new IllegalArgumentException(
+                "Phone number is required in request parameters"
+            );
        }

        // Extract text or event from QueryInputDTO
@@ -59,7 +69,9 @@ public class RagRequestMapper {

        // Determine request type and notification context
        String type = determineRequestType(queryInput, parameters);
-        NotificationContext notificationContext = extractNotificationContext(parameters);
+        NotificationContext notificationContext = extractNotificationContext(
+            parameters
+        );

        RagQueryRequest ragRequest = new RagQueryRequest(
            phoneNumber,
@@ -69,8 +81,12 @@ public class RagRequestMapper {
            languageCode
        );

-        logger.debug("Mapped RAG request: type={}, phoneNumber={}, hasNotification={}",
-            type, phoneNumber, notificationContext != null);
+        logger.debug(
+            "Mapped RAG request: type={}, phoneNumber={}, hasNotification={}",
+            type,
+            phoneNumber,
+            notificationContext != null
+        );

        return ragRequest;
    }
@@ -83,7 +99,9 @@ public class RagRequestMapper {
        if (telefono instanceof String) {
            return (String) telefono;
        }
-        logger.warn("Phone number (telefono) not found or not a string in parameters");
+        logger.warn(
+            "Phone number (telefono) not found or not a string in parameters"
+        );
        return null;
    }

@@ -92,16 +110,24 @@ public class RagRequestMapper {
     * For events, we use the event name as the text.
     */
    private String extractText(QueryInputDTO queryInput) {
-        if (queryInput.text() != null && queryInput.text().text() != null
-                && !queryInput.text().text().trim().isEmpty()) {
+        if (
+            queryInput.text() != null &&
+            queryInput.text().text() != null &&
+            !queryInput.text().text().trim().isEmpty()
+        ) {
            return queryInput.text().text();
-        } else if (queryInput.event() != null && queryInput.event().event() != null
-                && !queryInput.event().event().trim().isEmpty()) {
+        } else if (
+            queryInput.event() != null &&
+            queryInput.event().event() != null &&
+            !queryInput.event().event().trim().isEmpty()
+        ) {
            // For events (like "LLM_RESPONSE_PROCESSED"), use the event name
            return queryInput.event().event();
        } else {
            logger.error("Query input must contain either text or event");
-            throw new IllegalArgumentException("Query input must contain either text or event");
+            throw new IllegalArgumentException(
+                "Query input must contain either text or event"
+            );
        }
    }

@@ -109,19 +135,30 @@ public class RagRequestMapper {
     * Determines if this is a conversation or notification request.
     * If notification parameters are present, it's a notification request.
     */
-    private String determineRequestType(QueryInputDTO queryInput, Map<String, Object> parameters) {
+    private String determineRequestType(
+        QueryInputDTO queryInput,
+        Map<String, Object> parameters
+    ) {
        // Check if there are notification-prefixed parameters
-        boolean hasNotificationParams = parameters.keySet().stream()
+        boolean hasNotificationParams = parameters
+            .keySet()
+            .stream()
            .anyMatch(key -> key.startsWith(NOTIFICATION_PREFIX));

        // Check if there's a notification_text parameter
-        boolean hasNotificationText = parameters.containsKey(NOTIFICATION_TEXT_PARAM);
+        boolean hasNotificationText = parameters.containsKey(
+            NOTIFICATION_TEXT_PARAM
+        );

        // Check if the input is an event (notifications use events)
-        boolean isEvent = queryInput.event() != null && queryInput.event().event() != null;
+        boolean isEvent =
+            queryInput.event() != null && queryInput.event().event() != null;

-        if (hasNotificationParams || hasNotificationText ||
-            (isEvent && "notificacion".equals(queryInput.event().event()))) {
+        if (
+            hasNotificationParams ||
+            hasNotificationText ||
+            (isEvent && "notificacion".equals(queryInput.event().event()))
+        ) {
            return "notification";
        }

@@ -132,8 +169,12 @@ public class RagRequestMapper {
     * Extracts notification context from parameters.
     * Looks for notification_text and notification_po_* parameters.
     */
-    private NotificationContext extractNotificationContext(Map<String, Object> parameters) {
-        String notificationText = (String) parameters.get(NOTIFICATION_TEXT_PARAM);
+    private NotificationContext extractNotificationContext(
+        Map<String, Object> parameters
+    ) {
+        String notificationText = (String) parameters.get(
+            NOTIFICATION_TEXT_PARAM
+        );

        // Extract all notification_po_* parameters and remove the prefix
        Map<String, Object> notificationParams = new HashMap<>();
@@ -146,7 +187,10 @@ public class RagRequestMapper {

        // Only create NotificationContext if we have notification data
        if (notificationText != null || !notificationParams.isEmpty()) {
-            return new NotificationContext(notificationText, notificationParams);
+            return new NotificationContext(
+                notificationText,
+                notificationParams
+            );
        }

        return null;
--- a/src/main/java/com/example/mapper/rag/RagResponseMapper.java
+++ b/src/main/java/com/example/mapper/rag/RagResponseMapper.java
@@ -1,20 +1,14 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.mapper.rag;

 import com.example.dto.dialogflow.base.DetectIntentResponseDTO;
 import com.example.dto.dialogflow.conversation.QueryResultDTO;
 import com.example.dto.rag.RagQueryResponse;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
-
 import java.util.Collections;
 import java.util.Map;
 import java.util.UUID;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;

 /**
 * Mapper component responsible for converting RAG API responses to DetectIntentResponseDTO.
@@ -23,7 +17,9 @@ import java.util.UUID;
@Component
 public class RagResponseMapper {

-    private static final Logger logger = LoggerFactory.getLogger(RagResponseMapper.class);
+    private static final Logger logger = LoggerFactory.getLogger(
+        RagResponseMapper.class
+    );

    /**
     * Maps a RagQueryResponse to a DetectIntentResponseDTO.
@@ -33,40 +29,68 @@ public class RagResponseMapper {
     * @param sessionId The session ID (for logging purposes)
     * @return A DetectIntentResponseDTO matching the expected structure
     */
-    public DetectIntentResponseDTO mapFromRagResponse(RagQueryResponse ragResponse, String sessionId) {
-        logger.info("Mapping RAG response to DetectIntentResponseDTO for session: {}", sessionId);
+    public DetectIntentResponseDTO mapFromRagResponse(
+        RagQueryResponse ragResponse,
+        String sessionId
+    ) {
+        logger.info(
+            "Mapping RAG response to DetectIntentResponseDTO for session: {}",
+            sessionId
+        );

        // Use RAG's response_id if available, otherwise generate one
-        String responseId = ragResponse.responseId() != null && !ragResponse.responseId().isBlank()
-            ? ragResponse.responseId()
-            : "rag-" + UUID.randomUUID().toString();
+        String responseId =
+            ragResponse.responseId() != null &&
+            !ragResponse.responseId().isBlank()
+                ? ragResponse.responseId()
+                : "rag-" + UUID.randomUUID().toString();

        // Extract response text
-        String responseText = ragResponse.responseText() != null
-            ? ragResponse.responseText()
-            : "";
+        String responseText =
+            ragResponse.responseText() != null
+                ? ragResponse.responseText()
+                : "";

        if (responseText.isBlank()) {
-            logger.warn("RAG returned empty response text for session: {}", sessionId);
+            logger.warn(
+                "RAG returned empty response text for session: {}",
+                sessionId
+            );
        }

        // Extract parameters (can be null or empty)
-        Map<String, Object> parameters = ragResponse.parameters() != null
-            ? ragResponse.parameters()
-            : Collections.emptyMap();
+        Map<String, Object> parameters =
+            ragResponse.parameters() != null
+                ? ragResponse.parameters()
+                : Collections.emptyMap();

        // Log confidence if available
        if (ragResponse.confidence() != null) {
-            logger.debug("RAG response confidence: {} for session: {}", ragResponse.confidence(), sessionId);
+            logger.debug(
+                "RAG response confidence: {} for session: {}",
+                ragResponse.confidence(),
+                sessionId
+            );
        }

        // Create QueryResultDTO with response text and parameters
-        QueryResultDTO queryResult = new QueryResultDTO(responseText, parameters);
+        QueryResultDTO queryResult = new QueryResultDTO(
+            responseText,
+            parameters
+        );

        // Create DetectIntentResponseDTO (quickReplies is null for now)
-        DetectIntentResponseDTO response = new DetectIntentResponseDTO(responseId, queryResult, null);
+        DetectIntentResponseDTO response = new DetectIntentResponseDTO(
+            responseId,
+            queryResult,
+            null
+        );

-        logger.info("Successfully mapped RAG response for session: {}. Response ID: {}", sessionId, responseId);
+        logger.info(
+            "Successfully mapped RAG response for session: {}. Response ID: {}",
+            sessionId,
+            responseId
+        );

        return response;
    }
--- a/src/main/java/com/example/service/base/DialogflowClientService.java
+++ b/src/main/java/com/example/service/base/DialogflowClientService.java
@@ -1,29 +1,24 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose. 
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.service.base;

-import com.example.mapper.conversation.DialogflowRequestMapper;
-import com.example.mapper.conversation.DialogflowResponseMapper;
 import com.example.dto.dialogflow.base.DetectIntentRequestDTO;
 import com.example.dto.dialogflow.base.DetectIntentResponseDTO;
 import com.example.exception.DialogflowClientException;
+import com.example.mapper.conversation.DialogflowRequestMapper;
+import com.example.mapper.conversation.DialogflowResponseMapper;
 import com.google.api.gax.rpc.ApiException;
 import com.google.cloud.dialogflow.cx.v3.DetectIntentRequest;
 import com.google.cloud.dialogflow.cx.v3.QueryParameters;
-import com.google.cloud.dialogflow.cx.v3.SessionsClient;
 import com.google.cloud.dialogflow.cx.v3.SessionName;
+import com.google.cloud.dialogflow.cx.v3.SessionsClient;
 import com.google.cloud.dialogflow.cx.v3.SessionsSettings;
+import java.io.IOException;
+import java.util.Objects;
+import javax.annotation.PreDestroy;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Service;
 import reactor.core.publisher.Mono;
-import javax.annotation.PreDestroy;
-import java.io.IOException;
-import java.util.Objects;
 import reactor.util.retry.Retry;

 /**
@@ -36,7 +31,9 @@ import reactor.util.retry.Retry;
@Qualifier("dialogflowClientService")
 public class DialogflowClientService implements IntentDetectionService {

-    private static final Logger logger = LoggerFactory.getLogger(DialogflowClientService.class);
+    private static final Logger logger = LoggerFactory.getLogger(
+        DialogflowClientService.class
+    );

    private final String dialogflowCxProjectId;
    private final String dialogflowCxLocation;
@@ -45,16 +42,20 @@ public class DialogflowClientService implements IntentDetectionService {
    private final DialogflowRequestMapper dialogflowRequestMapper;
    private final DialogflowResponseMapper dialogflowResponseMapper;
    private SessionsClient sessionsClient;
-    
+
    public DialogflowClientService(
-
-        @org.springframework.beans.factory.annotation.Value("${dialogflow.cx.project-id}") String dialogflowCxProjectId,
-        @org.springframework.beans.factory.annotation.Value("${dialogflow.cx.location}") String dialogflowCxLocation,
-        @org.springframework.beans.factory.annotation.Value("${dialogflow.cx.agent-id}") String dialogflowCxAgentId,
+        @org.springframework.beans.factory.annotation.Value(
+            "${dialogflow.cx.project-id}"
+        ) String dialogflowCxProjectId,
+        @org.springframework.beans.factory.annotation.Value(
+            "${dialogflow.cx.location}"
+        ) String dialogflowCxLocation,
+        @org.springframework.beans.factory.annotation.Value(
+            "${dialogflow.cx.agent-id}"
+        ) String dialogflowCxAgentId,
        DialogflowRequestMapper dialogflowRequestMapper,
-        DialogflowResponseMapper dialogflowResponseMapper)
-        throws IOException {
-
+        DialogflowResponseMapper dialogflowResponseMapper
+    ) throws IOException {
        this.dialogflowCxProjectId = dialogflowCxProjectId;
        this.dialogflowCxLocation = dialogflowCxLocation;
        this.dialogflowCxAgentId = dialogflowCxAgentId;
@@ -62,15 +63,28 @@ public class DialogflowClientService implements IntentDetectionService {
        this.dialogflowResponseMapper = dialogflowResponseMapper;

        try {
-            String regionalEndpoint = String.format("%s-dialogflow.googleapis.com:443", dialogflowCxLocation);
+            String regionalEndpoint = String.format(
+                "%s-dialogflow.googleapis.com:443",
+                dialogflowCxLocation
+            );
            SessionsSettings sessionsSettings = SessionsSettings.newBuilder()
                .setEndpoint(regionalEndpoint)
                .build();
            this.sessionsClient = SessionsClient.create(sessionsSettings);
-            logger.info("Dialogflow CX SessionsClient initialized successfully for endpoint: {}", regionalEndpoint);
-            logger.info("Dialogflow CX SessionsClient initialized successfully for agent - Test Agent version: {}", dialogflowCxAgentId);
+            logger.info(
+                "Dialogflow CX SessionsClient initialized successfully for endpoint: {}",
+                regionalEndpoint
+            );
+            logger.info(
+                "Dialogflow CX SessionsClient initialized successfully for agent - Test Agent version: {}",
+                dialogflowCxAgentId
+            );
        } catch (IOException e) {
-            logger.error("Failed to create Dialogflow CX SessionsClient: {}", e.getMessage(), e);
+            logger.error(
+                "Failed to create Dialogflow CX SessionsClient: {}",
+                e.getMessage(),
+                e
+            );
            throw e;
        }
    }
@@ -85,35 +99,61 @@ public class DialogflowClientService implements IntentDetectionService {

    @Override
    public Mono<DetectIntentResponseDTO> detectIntent(
-            String sessionId,
-            DetectIntentRequestDTO request) {
-
-        Objects.requireNonNull(sessionId, "Dialogflow session ID cannot be null.");
-        Objects.requireNonNull(request, "Dialogflow request DTO cannot be null.");
+        String sessionId,
+        DetectIntentRequestDTO request
+    ) {
+        Objects.requireNonNull(
+            sessionId,
+            "Dialogflow session ID cannot be null."
+        );
+        Objects.requireNonNull(
+            request,
+            "Dialogflow request DTO cannot be null."
+        );

        logger.info("Initiating detectIntent for session: {}", sessionId);

        DetectIntentRequest.Builder detectIntentRequestBuilder;
        try {
-            detectIntentRequestBuilder = dialogflowRequestMapper.mapToDetectIntentRequestBuilder(request);
-            logger.debug("Obtained partial DetectIntentRequest.Builder from mapper for session: {}", sessionId);
+            detectIntentRequestBuilder =
+                dialogflowRequestMapper.mapToDetectIntentRequestBuilder(
+                    request
+                );
+            logger.debug(
+                "Obtained partial DetectIntentRequest.Builder from mapper for session: {}",
+                sessionId
+            );
        } catch (IllegalArgumentException e) {
-            logger.error(" Failed to map DTO to partial Protobuf request for session {}: {}", sessionId, e.getMessage());
-            return Mono.error(new IllegalArgumentException("Invalid Dialogflow request input: " + e.getMessage()));
+            logger.error(
+                " Failed to map DTO to partial Protobuf request for session {}: {}",
+                sessionId,
+                e.getMessage()
+            );
+            return Mono.error(
+                new IllegalArgumentException(
+                    "Invalid Dialogflow request input: " + e.getMessage()
+                )
+            );
        }

        SessionName sessionName = SessionName.newBuilder()
-                .setProject(dialogflowCxProjectId)
-                .setLocation(dialogflowCxLocation)
-                .setAgent(dialogflowCxAgentId)
-                .setSession(sessionId)
-                .build();
+            .setProject(dialogflowCxProjectId)
+            .setLocation(dialogflowCxLocation)
+            .setAgent(dialogflowCxAgentId)
+            .setSession(sessionId)
+            .build();
        detectIntentRequestBuilder.setSession(sessionName.toString());
-        logger.debug("Set session path {} on the request builder for session: {}", sessionName.toString(), sessionId);
+        logger.debug(
+            "Set session path {} on the request builder for session: {}",
+            sessionName.toString(),
+            sessionId
+        );

        QueryParameters.Builder queryParamsBuilder;
        if (detectIntentRequestBuilder.hasQueryParams()) {
-            queryParamsBuilder = detectIntentRequestBuilder.getQueryParams().toBuilder();
+            queryParamsBuilder = detectIntentRequestBuilder
+                .getQueryParams()
+                .toBuilder();
        } else {
            queryParamsBuilder = QueryParameters.newBuilder();
        }
@@ -121,50 +161,89 @@ public class DialogflowClientService implements IntentDetectionService {
        detectIntentRequestBuilder.setQueryParams(queryParamsBuilder.build());

        // Build the final DetectIntentRequest Protobuf object
-        DetectIntentRequest detectIntentRequest = detectIntentRequestBuilder.build();
+        DetectIntentRequest detectIntentRequest =
+            detectIntentRequestBuilder.build();
        return Mono.fromCallable(() -> {
-            logger.debug("Calling Dialogflow CX detectIntent for session: {}", sessionId);
+            logger.debug(
+                "Calling Dialogflow CX detectIntent for session: {}",
+                sessionId
+            );
            return sessionsClient.detectIntent(detectIntentRequest);
        })
+            .retryWhen(
+                reactor.util.retry.Retry.backoff(
+                    3,
+                    java.time.Duration.ofSeconds(1)
+                )
+                    .filter(throwable -> {
+                        if (throwable instanceof ApiException apiException) {
+                            com.google.api.gax.rpc.StatusCode.Code code =
+                                apiException.getStatusCode().getCode();
+                            boolean isRetryable =
+                                code ==
+                                    com.google.api.gax.rpc.StatusCode.Code.INTERNAL ||
+                                code ==
+                                com.google.api.gax.rpc.StatusCode.Code.UNAVAILABLE;
+                            if (isRetryable) {
+                                logger.warn(
+                                    "Retrying Dialogflow CX call for session {} due to transient error: {}",
+                                    sessionId,
+                                    code
+                                );
+                            }
+                            return isRetryable;
+                        }
+                        return false;
+                    })
+                    .doBeforeRetry(retrySignal ->
+                        logger.debug(
+                            "Retry attempt #{} for session {}",
+                            retrySignal.totalRetries() + 1,
+                            sessionId
+                        )
+                    )
+                    .onRetryExhaustedThrow((retrySpec, retrySignal) -> {
+                        logger.error(
+                            "Dialogflow CX retries exhausted for session {}",
+                            sessionId
+                        );
+                        return retrySignal.failure();
+                    })
+            )
+            .onErrorMap(ApiException.class, e -> {
+                String statusCode = e.getStatusCode().getCode().name();
+                String message = e.getMessage();
+                String detailedLog = message;

-        .retryWhen(reactor.util.retry.Retry.backoff(3, java.time.Duration.ofSeconds(1))
-            .filter(throwable -> {
-                if (throwable instanceof ApiException apiException) {
-                    com.google.api.gax.rpc.StatusCode.Code code = apiException.getStatusCode().getCode();
-                    boolean isRetryable = code == com.google.api.gax.rpc.StatusCode.Code.INTERNAL || 
-                                          code == com.google.api.gax.rpc.StatusCode.Code.UNAVAILABLE;
-                    if (isRetryable) {
-                        logger.warn("Retrying Dialogflow CX call for session {} due to transient error: {}", sessionId, code);
-                    }
-                    return isRetryable;
+                if (
+                    e.getCause() instanceof
+                        io.grpc.StatusRuntimeException grpcEx
+                ) {
+                    detailedLog = String.format(
+                        "Status: %s, Message: %s, Trailers: %s",
+                        grpcEx.getStatus().getCode(),
+                        grpcEx.getStatus().getDescription(),
+                        grpcEx.getTrailers()
+                    );
                }
-                return false;
-            })
-            .doBeforeRetry(retrySignal -> logger.debug("Retry attempt #{} for session {}", 
-                retrySignal.totalRetries() + 1, sessionId))
-            .onRetryExhaustedThrow((retrySpec, retrySignal) -> {
-                logger.error("Dialogflow CX retries exhausted for session {}", sessionId);
-                return retrySignal.failure();
-            })
-        )
-        .onErrorMap(ApiException.class, e -> {
-            String statusCode = e.getStatusCode().getCode().name();
-            String message = e.getMessage();
-            String detailedLog = message;
-            
-            if (e.getCause() instanceof io.grpc.StatusRuntimeException grpcEx) {
-                detailedLog = String.format("Status: %s, Message: %s, Trailers: %s", 
-                    grpcEx.getStatus().getCode(), 
-                    grpcEx.getStatus().getDescription(), 
-                    grpcEx.getTrailers());
-            }

-            logger.error("Dialogflow CX API error for session {}: details={}", 
-                    sessionId, detailedLog, e);
+                logger.error(
+                    "Dialogflow CX API error for session {}: details={}",
+                    sessionId,
+                    detailedLog,
+                    e
+                );

-            return new DialogflowClientException(
-                    "Dialogflow CX API error: " + statusCode + " - " + message, e);
-        })
-        .map(dfResponse -> this.dialogflowResponseMapper.mapFromDialogflowResponse(dfResponse, sessionId));
+                return new DialogflowClientException(
+                    "Dialogflow CX API error: " + statusCode + " - " + message,
+                    e
+                );
+            })
+            .map(dfResponse ->
+                this.dialogflowResponseMapper.mapFromDialogflowResponse(
+                    dfResponse,
+                    sessionId
+                )
+            );
    }
-}
+}
--- a/src/main/java/com/example/service/base/IntentDetectionService.java
+++ b/src/main/java/com/example/service/base/IntentDetectionService.java
@@ -1,8 +1,3 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.service.base;

 import com.example.dto.dialogflow.base.DetectIntentRequestDTO;
@@ -15,7 +10,6 @@ import reactor.core.publisher.Mono;
 * (e.g., Dialogflow, RAG) without changing dependent services.
 */
 public interface IntentDetectionService {
-
    /**
     * Detects user intent and generates a response.
     *
@@ -23,5 +17,8 @@ public interface IntentDetectionService {
     * @param request The request containing user input and context parameters
     * @return A Mono of DetectIntentResponseDTO with the generated response
     */
-    Mono<DetectIntentResponseDTO> detectIntent(String sessionId, DetectIntentRequestDTO request);
+    Mono<DetectIntentResponseDTO> detectIntent(
+        String sessionId,
+        DetectIntentRequestDTO request
+    );
 }
--- a/src/main/java/com/example/service/base/RagClientService.java
+++ b/src/main/java/com/example/service/base/RagClientService.java
@@ -1,8 +1,3 @@
-/*
- * Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose.
- * Your use of it is subject to your agreement with Google.
- */
-
 package com.example.service.base;

 import com.example.dto.dialogflow.base.DetectIntentRequestDTO;
@@ -12,6 +7,9 @@ import com.example.dto.rag.RagQueryResponse;
 import com.example.exception.RagClientException;
 import com.example.mapper.rag.RagRequestMapper;
 import com.example.mapper.rag.RagResponseMapper;
+import java.time.Duration;
+import java.util.Objects;
+import java.util.concurrent.TimeoutException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Qualifier;
@@ -24,10 +22,6 @@ import org.springframework.web.reactive.function.client.WebClientResponseExcepti
 import reactor.core.publisher.Mono;
 import reactor.util.retry.Retry;

-import java.time.Duration;
-import java.util.Objects;
-import java.util.concurrent.TimeoutException;
-
 /**
 * Service for interacting with the RAG server to detect user intent and generate responses.
 * This service mirrors the structure of DialogflowClientService but calls a RAG API instead.
@@ -37,7 +31,9 @@ import java.util.concurrent.TimeoutException;
@Qualifier("ragClientService")
 public class RagClientService implements IntentDetectionService {

-    private static final Logger logger = LoggerFactory.getLogger(RagClientService.class);
+    private static final Logger logger = LoggerFactory.getLogger(
+        RagClientService.class
+    );

    private final WebClient webClient;
    private final RagRequestMapper ragRequestMapper;
@@ -47,14 +43,14 @@ public class RagClientService implements IntentDetectionService {
    private final Duration timeout;

    public RagClientService(
-            @Value("${rag.server.url}") String ragServerUrl,
-            @Value("${rag.server.timeout:30s}") Duration timeout,
-            @Value("${rag.server.retry.max-attempts:3}") int maxRetries,
-            @Value("${rag.server.retry.backoff:1s}") Duration retryBackoff,
-            @Value("${rag.server.api-key:}") String apiKey,
-            RagRequestMapper ragRequestMapper,
-            RagResponseMapper ragResponseMapper) {
-
+        @Value("${rag.server.url}") String ragServerUrl,
+        @Value("${rag.server.timeout:30s}") Duration timeout,
+        @Value("${rag.server.retry.max-attempts:3}") int maxRetries,
+        @Value("${rag.server.retry.backoff:1s}") Duration retryBackoff,
+        @Value("${rag.server.api-key:}") String apiKey,
+        RagRequestMapper ragRequestMapper,
+        RagResponseMapper ragResponseMapper
+    ) {
        this.ragRequestMapper = ragRequestMapper;
        this.ragResponseMapper = ragResponseMapper;
        this.maxRetries = maxRetries;
@@ -74,9 +70,16 @@ public class RagClientService implements IntentDetectionService {

        this.webClient = builder.build();

-        logger.info("RAG Client initialized successfully with endpoint: {}", ragServerUrl);
-        logger.info("RAG Client configuration - timeout: {}, max retries: {}, backoff: {}",
-            timeout, maxRetries, retryBackoff);
+        logger.info(
+            "RAG Client initialized successfully with endpoint: {}",
+            ragServerUrl
+        );
+        logger.info(
+            "RAG Client configuration - timeout: {}, max retries: {}, backoff: {}",
+            timeout,
+            maxRetries,
+            retryBackoff
+        );
    }

    /**
@@ -89,9 +92,9 @@ public class RagClientService implements IntentDetectionService {
     */
    @Override
    public Mono<DetectIntentResponseDTO> detectIntent(
-            String sessionId,
-            DetectIntentRequestDTO request) {
-
+        String sessionId,
+        DetectIntentRequestDTO request
+    ) {
        Objects.requireNonNull(sessionId, "Session ID cannot be null.");
        Objects.requireNonNull(request, "Request DTO cannot be null.");

@@ -101,83 +104,171 @@ public class RagClientService implements IntentDetectionService {
        RagQueryRequest ragRequest;
        try {
            ragRequest = ragRequestMapper.mapToRagRequest(request, sessionId);
-            logger.debug("Successfully mapped request to RAG format for session: {}", sessionId);
+            logger.debug(
+                "Successfully mapped request to RAG format for session: {}",
+                sessionId
+            );
        } catch (IllegalArgumentException e) {
-            logger.error("Failed to map DTO to RAG request for session {}: {}", sessionId, e.getMessage());
-            return Mono.error(new IllegalArgumentException("Invalid RAG request input: " + e.getMessage()));
+            logger.error(
+                "Failed to map DTO to RAG request for session {}: {}",
+                sessionId,
+                e.getMessage()
+            );
+            return Mono.error(
+                new IllegalArgumentException(
+                    "Invalid RAG request input: " + e.getMessage()
+                )
+            );
        }

        // Call RAG API
-        return Mono.defer(() ->
-            webClient.post()
-                .uri("/api/v1/query")
-                .header("X-Session-Id", sessionId)  // Optional: for RAG server logging
-                .bodyValue(ragRequest)
-                .retrieve()
-                .onStatus(
-                    HttpStatusCode::is4xxClientError,
-                    response -> response.bodyToMono(String.class)
-                        .flatMap(body -> {
-                            logger.error("RAG client error for session {}: status={}, body={}",
-                                sessionId, response.statusCode(), body);
-                            return Mono.error(new RagClientException(
-                                "Invalid RAG request: " + response.statusCode() + " - " + body));
-                        })
-                )
-                .bodyToMono(RagQueryResponse.class)
-                .timeout(timeout)  // Timeout per attempt
-            )
-            .retryWhen(Retry.backoff(maxRetries, retryBackoff)
-                .filter(throwable -> {
-                    // Retry on server errors and timeouts
-                    if (throwable instanceof WebClientResponseException wce) {
-                        int statusCode = wce.getStatusCode().value();
-                        boolean isRetryable = statusCode == 500 || statusCode == 503 || statusCode == 504;
-                        if (isRetryable) {
-                            logger.warn("Retrying RAG call for session {} due to status code: {}",
-                                sessionId, statusCode);
+        return Mono.defer(
+            () ->
+                webClient
+                    .post()
+                    .uri("/api/v1/query")
+                    .header("X-Session-Id", sessionId) // Optional: for RAG server logging
+                    .bodyValue(ragRequest)
+                    .retrieve()
+                    .onStatus(HttpStatusCode::is4xxClientError, response ->
+                        response
+                            .bodyToMono(String.class)
+                            .flatMap(body -> {
+                                logger.error(
+                                    "RAG client error for session {}: status={}, body={}",
+                                    sessionId,
+                                    response.statusCode(),
+                                    body
+                                );
+                                return Mono.error(
+                                    new RagClientException(
+                                        "Invalid RAG request: " +
+                                            response.statusCode() +
+                                            " - " +
+                                            body
+                                    )
+                                );
+                            })
+                    )
+                    .bodyToMono(RagQueryResponse.class)
+                    .timeout(timeout) // Timeout per attempt
+        )
+            .retryWhen(
+                Retry.backoff(maxRetries, retryBackoff)
+                    .filter(throwable -> {
+                        // Retry on server errors and timeouts
+                        if (
+                            throwable instanceof WebClientResponseException wce
+                        ) {
+                            int statusCode = wce.getStatusCode().value();
+                            boolean isRetryable =
+                                statusCode == 500 ||
+                                statusCode == 503 ||
+                                statusCode == 504;
+                            if (isRetryable) {
+                                logger.warn(
+                                    "Retrying RAG call for session {} due to status code: {}",
+                                    sessionId,
+                                    statusCode
+                                );
+                            }
+                            return isRetryable;
                        }
-                        return isRetryable;
-                    }
-                    if (throwable instanceof TimeoutException) {
-                        logger.warn("Retrying RAG call for session {} due to timeout", sessionId);
-                        return true;
-                    }
-                    return false;
-                })
-                .doBeforeRetry(retrySignal ->
-                    logger.debug("Retry attempt #{} for session {}: {}",
-                        retrySignal.totalRetries() + 1, sessionId, retrySignal.failure().getMessage()))
-                .onRetryExhaustedThrow((retrySpec, retrySignal) -> {
-                    logger.error("RAG retries exhausted for session {}", sessionId);
-                    return retrySignal.failure();
-                })
+                        if (throwable instanceof TimeoutException) {
+                            logger.warn(
+                                "Retrying RAG call for session {} due to timeout",
+                                sessionId
+                            );
+                            return true;
+                        }
+                        return false;
+                    })
+                    .doBeforeRetry(retrySignal ->
+                        logger.debug(
+                            "Retry attempt #{} for session {}: {}",
+                            retrySignal.totalRetries() + 1,
+                            sessionId,
+                            retrySignal.failure().getMessage()
+                        )
+                    )
+                    .onRetryExhaustedThrow((retrySpec, retrySignal) -> {
+                        logger.error(
+                            "RAG retries exhausted for session {}",
+                            sessionId
+                        );
+                        return retrySignal.failure();
+                    })
            )
            .onErrorMap(WebClientResponseException.class, e -> {
                int statusCode = e.getStatusCode().value();
-                logger.error("RAG server error for session {}: status={}, body={}",
-                    sessionId, statusCode, e.getResponseBodyAsString());
+                logger.error(
+                    "RAG server error for session {}: status={}, body={}",
+                    sessionId,
+                    statusCode,
+                    e.getResponseBodyAsString()
+                );
                return new RagClientException(
-                    "RAG server error: " + statusCode + " - " + e.getResponseBodyAsString(), e);
+                    "RAG server error: " +
+                        statusCode +
+                        " - " +
+                        e.getResponseBodyAsString(),
+                    e
+                );
            })
            .onErrorMap(WebClientRequestException.class, e -> {
-                logger.error("RAG connection error for session {}: {}", sessionId, e.getMessage());
-                return new RagClientException("RAG connection failed: " + e.getMessage(), e);
+                logger.error(
+                    "RAG connection error for session {}: {}",
+                    sessionId,
+                    e.getMessage()
+                );
+                return new RagClientException(
+                    "RAG connection failed: " + e.getMessage(),
+                    e
+                );
            })
            .onErrorMap(TimeoutException.class, e -> {
-                logger.error("RAG timeout for session {}: {}", sessionId, e.getMessage());
-                return new RagClientException("RAG request timeout after " + timeout.getSeconds() + "s", e);
+                logger.error(
+                    "RAG timeout for session {}: {}",
+                    sessionId,
+                    e.getMessage()
+                );
+                return new RagClientException(
+                    "RAG request timeout after " + timeout.getSeconds() + "s",
+                    e
+                );
            })
-            .onErrorMap(RagClientException.class, e -> e)  // Pass through RagClientException
-            .onErrorMap(throwable -> !(throwable instanceof RagClientException), throwable -> {
-                logger.error("Unexpected error during RAG call for session {}: {}", sessionId, throwable.getMessage(), throwable);
-                return new RagClientException("Unexpected RAG error: " + throwable.getMessage(), throwable);
-            })
-            .map(ragResponse -> ragResponseMapper.mapFromRagResponse(ragResponse, sessionId))
+            .onErrorMap(RagClientException.class, e -> e) // Pass through RagClientException
+            .onErrorMap(
+                throwable -> !(throwable instanceof RagClientException),
+                throwable -> {
+                    logger.error(
+                        "Unexpected error during RAG call for session {}: {}",
+                        sessionId,
+                        throwable.getMessage(),
+                        throwable
+                    );
+                    return new RagClientException(
+                        "Unexpected RAG error: " + throwable.getMessage(),
+                        throwable
+                    );
+                }
+            )
+            .map(ragResponse ->
+                ragResponseMapper.mapFromRagResponse(ragResponse, sessionId)
+            )
            .doOnSuccess(response ->
-                logger.info("RAG query successful for session: {}, response ID: {}",
-                    sessionId, response.responseId()))
+                logger.info(
+                    "RAG query successful for session: {}, response ID: {}",
+                    sessionId,
+                    response.responseId()
+                )
+            )
            .doOnError(error ->
-                logger.error("RAG query failed for session {}: {}", sessionId, error.getMessage()));
+                logger.error(
+                    "RAG query failed for session {}: {}",
+                    sessionId,
+                    error.getMessage()
+                )
+            );
    }
 }
--- a/target/classes/application-dev.properties
+++ b/target/classes/application-dev.properties
@@ -1,93 +0,0 @@
-# Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose. 
-# Your use of it is subject to your agreement with Google.
-
-# =========================================
-# Spring Boot Configuration Template
-# =========================================
-# This file serves as a reference template for all application configuration properties.
-
-# Best Practices:
-# - Use Spring Profiles (e.g., application-dev.properties, application-prod.properties)
-#   to manage environment-specific settings.
-# - Do not store in PROD sensitive information directly here.
-#   Use environment variables or a configuration server for production environments.
-# - This template can be adapted for logging configuration, database connections,
-#   and other external service settings.
-
-# =========================================================
-# Orchestrator general Configuration
-# =========================================================
-spring.cloud.gcp.project-id=${GCP_PROJECT_ID}
-# =========================================================
-# Google Firestore Configuration
-# =========================================================
-spring.cloud.gcp.firestore.project-id=${GCP_PROJECT_ID}
-spring.cloud.gcp.firestore.database-id=${GCP_FIRESTORE_DATABASE_ID}
-spring.cloud.gcp.firestore.host=${GCP_FIRESTORE_HOST}
-spring.cloud.gcp.firestore.port=${GCP_FIRESTORE_PORT}
-# =========================================================
-# Google Memorystore(Redis) Configuration
-# =========================================================
-spring.data.redis.host=${REDIS_HOST}
-spring.data.redis.port=${REDIS_PORT}
-#spring.data.redis.password=${REDIS_PWD}
-#spring.data.redis.username=default
-
-# SSL Configuration (if using SSL)
-# spring.data.redis.ssl=true
-# spring.data.redis.ssl.key-store=classpath:keystore.p12
-# spring.data.redis.ssl.key-store-password=${REDIS_KEY_PWD}
-# =========================================================
-# Intent Detection Client Selection
-# =========================================================
-# Options: 'dialogflow' or 'rag'
-# Set to 'dialogflow' to use Dialogflow CX (default)
-# Set to 'rag' to use RAG server
-intent.detection.client=${INTENT_DETECTION_CLIENT:dialogflow}
-# =========================================================
-# Google Conversational Agents Configuration (Dialogflow)
-# =========================================================
-dialogflow.cx.project-id=${DIALOGFLOW_CX_PROJECT_ID}
-dialogflow.cx.location=${DIALOGFLOW_CX_LOCATION}
-dialogflow.cx.agent-id=${DIALOGFLOW_CX_AGENT_ID}
-dialogflow.default-language-code=${DIALOGFLOW_DEFAULT_LANGUAGE_CODE:es}
-# =========================================================
-# RAG Server Configuration
-# =========================================================
-rag.server.url=${RAG_SERVER_URL:http://localhost:8080}
-rag.server.timeout=${RAG_SERVER_TIMEOUT:30s}
-rag.server.retry.max-attempts=${RAG_SERVER_RETRY_MAX_ATTEMPTS:3}
-rag.server.retry.backoff=${RAG_SERVER_RETRY_BACKOFF:1s}
-rag.server.api-key=${RAG_SERVER_API_KEY:}
-# =========================================================
-# Google Generative AI (Gemini) Configuration
-# =========================================================
-google.cloud.project=${GCP_PROJECT_ID}
-google.cloud.location=${GCP_LOCATION}
-gemini.model.name=${GEMINI_MODEL_NAME}
-# =========================================================
-# (Gemini) MessageFilter Configuration
-# =========================================================
-messagefilter.geminimodel=${MESSAGE_FILTER_GEMINI_MODEL}
-messagefilter.temperature=${MESSAGE_FILTER_TEMPERATURE}
-messagefilter.maxOutputTokens=${MESSAGE_FILTER_MAX_OUTPUT_TOKENS}
-messagefilter.topP=${MESSAGE_FILTER_TOP_P}
-messagefilter.prompt=prompts/message_filter_prompt.txt
-# =========================================================
-# (DLP) Configuration
-# =========================================================
-google.cloud.dlp.dlpTemplateCompleteFlow=${DLP_TEMPLATE_COMPLETE_FLOW}
-# =========================================================
-# Quick-replies Preset-data
-# =========================================================
-firestore.data.importer.enabled=${GCP_FIRESTORE_IMPORTER_ENABLE}
-# =========================================================
-# LOGGING Configuration
-# =========================================================
-logging.level.root=${LOGGING_LEVEL_ROOT:INFO}
-logging.level.com.example=${LOGGING_LEVEL_COM_EXAMPLE:INFO}
-# =========================================================
-# ConversationContext Configuration
-# =========================================================
-conversation.context.message.limit=${CONVERSATION_CONTEXT_MESSAGE_LIMIT}
-conversation.context.days.limit=${CONVERSATION_CONTEXT_DAYS_LIMIT}
--- a/target/classes/application-prod.properties
+++ b/target/classes/application-prod.properties
@@ -1,94 +0,0 @@
-# Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose. 
-# Your use of it is subject to your agreement with Google.
-
-# =========================================
-# Spring Boot Configuration Template
-# =========================================
-# This file serves as a reference template for all application configuration properties.
-
-# Best Practices:
-# - Use Spring Profiles (e.g., application-dev.properties, application-prod.properties)
-#   to manage environment-specific settings.
-# - Do not store in PROD sensitive information directly here.
-#   Use environment variables or a configuration server for production environments.
-# - This template can be adapted for logging configuration, database connections,
-#   and other external service settings.
-
-# =========================================================
-# Orchestrator general Configuration
-# =========================================================
-spring.cloud.gcp.project-id=${GCP_PROJECT_ID}
-# =========================================================
-# Google Firestore Configuration
-# =========================================================
-spring.cloud.gcp.firestore.project-id=${GCP_PROJECT_ID}
-spring.cloud.gcp.firestore.database-id=${GCP_FIRESTORE_DATABASE_ID}
-spring.cloud.gcp.firestore.host=${GCP_FIRESTORE_HOST}
-spring.cloud.gcp.firestore.port=${GCP_FIRESTORE_PORT}
-# =========================================================
-# Google Memorystore(Redis) Configuration
-# =========================================================
-spring.data.redis.host=${REDIS_HOST}
-spring.data.redis.port=${REDIS_PORT}
-#spring.data.redis.password=${REDIS_PWD}
-#spring.data.redis.username=default
-
-# SSL Configuration (if using SSL)
-# spring.data.redis.ssl=true
-# spring.data.redis.ssl.key-store=classpath:keystore.p12
-# spring.data.redis.ssl.key-store-password=${REDIS_KEY_PWD}
-# =========================================================
-# Intent Detection Client Selection
-# =========================================================
-# Options: 'dialogflow' or 'rag'
-# Set to 'dialogflow' to use Dialogflow CX (default)
-# Set to 'rag' to use RAG server
-intent.detection.client=${INTENT_DETECTION_CLIENT:dialogflow}
-# =========================================================
-# Google Conversational Agents Configuration (Dialogflow)
-# =========================================================
-dialogflow.cx.project-id=${DIALOGFLOW_CX_PROJECT_ID}
-dialogflow.cx.location=${DIALOGFLOW_CX_LOCATION}
-dialogflow.cx.agent-id=${DIALOGFLOW_CX_AGENT_ID}
-dialogflow.default-language-code=${DIALOGFLOW_DEFAULT_LANGUAGE_CODE:es}
-# =========================================================
-# RAG Server Configuration
-# =========================================================
-rag.server.url=${RAG_SERVER_URL:http://localhost:8080}
-rag.server.timeout=${RAG_SERVER_TIMEOUT:30s}
-rag.server.retry.max-attempts=${RAG_SERVER_RETRY_MAX_ATTEMPTS:3}
-rag.server.retry.backoff=${RAG_SERVER_RETRY_BACKOFF:1s}
-rag.server.api-key=${RAG_SERVER_API_KEY:}
-# =========================================================
-# Google Generative AI (Gemini) Configuration
-# =========================================================
-google.cloud.project=${GCP_PROJECT_ID}
-google.cloud.location=${GCP_LOCATION}
-gemini.model.name=${GEMINI_MODEL_NAME}
-# =========================================================
-# (Gemini) MessageFilter Configuration
-# =========================================================
-messagefilter.geminimodel=${MESSAGE_FILTER_GEMINI_MODEL}
-messagefilter.temperature=${MESSAGE_FILTER_TEMPERATURE}
-messagefilter.maxOutputTokens=${MESSAGE_FILTER_MAX_OUTPUT_TOKENS}
-messagefilter.topP=${MESSAGE_FILTER_TOP_P}
-messagefilter.prompt=prompts/message_filter_prompt.txt
-# =========================================================
-# (DLP) Configuration
-# =========================================================
-google.cloud.dlp.dlpTemplateCompleteFlow=${DLP_TEMPLATE_COMPLETE_FLOW}
-google.cloud.dlp.dlpTemplatePersistFlow=${DLP_TEMPLATE_PERSIST_FLOW}
-# =========================================================
-# Quick-replies Preset-data
-# =========================================================
-firestore.data.importer.enabled=${GCP_FIRESTORE_IMPORTER_ENABLE}
-# =========================================================
-# LOGGING Configuration
-# =========================================================
-logging.level.root=${LOGGING_LEVEL_ROOT:INFO}
-logging.level.com.example=${LOGGING_LEVEL_COM_EXAMPLE:INFO}
-# =========================================================
-# ConversationContext Configuration
-# =========================================================
-conversation.context.message.limit=${CONVERSATION_CONTEXT_MESSAGE_LIMIT}
-conversation.context.days.limit=${CONVERSATION_CONTEXT_DAYS_LIMIT}
--- a/target/classes/application-qa.properties
+++ b/target/classes/application-qa.properties
@@ -1,94 +0,0 @@
-# Copyright 2025 Google. This software is provided as-is, without warranty or representation for any use or purpose. 
-# Your use of it is subject to your agreement with Google.
-
-# =========================================
-# Spring Boot Configuration Template
-# =========================================
-# This file serves as a reference template for all application configuration properties.
-
-# Best Practices:
-# - Use Spring Profiles (e.g., application-dev.properties, application-prod.properties)
-#   to manage environment-specific settings.
-# - Do not store in PROD sensitive information directly here.
-#   Use environment variables or a configuration server for production environments.
-# - This template can be adapted for logging configuration, database connections,
-#   and other external service settings.
-
-# =========================================================
-# Orchestrator general Configuration
-# =========================================================
-spring.cloud.gcp.project-id=${GCP_PROJECT_ID}
-# =========================================================
-# Google Firestore Configuration
-# =========================================================
-spring.cloud.gcp.firestore.project-id=${GCP_PROJECT_ID}
-spring.cloud.gcp.firestore.database-id=${GCP_FIRESTORE_DATABASE_ID}
-spring.cloud.gcp.firestore.host=${GCP_FIRESTORE_HOST}
-spring.cloud.gcp.firestore.port=${GCP_FIRESTORE_PORT}
-# =========================================================
-# Google Memorystore(Redis) Configuration
-# =========================================================
-spring.data.redis.host=${REDIS_HOST}
-spring.data.redis.port=${REDIS_PORT}
-#spring.data.redis.password=${REDIS_PWD}
-#spring.data.redis.username=default
-
-# SSL Configuration (if using SSL)
-# spring.data.redis.ssl=true
-# spring.data.redis.ssl.key-store=classpath:keystore.p12
-# spring.data.redis.ssl.key-store-password=${REDIS_KEY_PWD}
-# =========================================================
-# Intent Detection Client Selection
-# =========================================================
-# Options: 'dialogflow' or 'rag'
-# Set to 'dialogflow' to use Dialogflow CX (default)
-# Set to 'rag' to use RAG server
-intent.detection.client=${INTENT_DETECTION_CLIENT:dialogflow}
-# =========================================================
-# Google Conversational Agents Configuration (Dialogflow)
-# =========================================================
-dialogflow.cx.project-id=${DIALOGFLOW_CX_PROJECT_ID}
-dialogflow.cx.location=${DIALOGFLOW_CX_LOCATION}
-dialogflow.cx.agent-id=${DIALOGFLOW_CX_AGENT_ID}
-dialogflow.default-language-code=${DIALOGFLOW_DEFAULT_LANGUAGE_CODE:es}
-# =========================================================
-# RAG Server Configuration
-# =========================================================
-rag.server.url=${RAG_SERVER_URL:http://localhost:8080}
-rag.server.timeout=${RAG_SERVER_TIMEOUT:30s}
-rag.server.retry.max-attempts=${RAG_SERVER_RETRY_MAX_ATTEMPTS:3}
-rag.server.retry.backoff=${RAG_SERVER_RETRY_BACKOFF:1s}
-rag.server.api-key=${RAG_SERVER_API_KEY:}
-# =========================================================
-# Google Generative AI (Gemini) Configuration
-# =========================================================
-google.cloud.project=${GCP_PROJECT_ID}
-google.cloud.location=${GCP_LOCATION}
-gemini.model.name=${GEMINI_MODEL_NAME}
-# =========================================================
-# (Gemini) MessageFilter Configuration
-# =========================================================
-messagefilter.geminimodel=${MESSAGE_FILTER_GEMINI_MODEL}
-messagefilter.temperature=${MESSAGE_FILTER_TEMPERATURE}
-messagefilter.maxOutputTokens=${MESSAGE_FILTER_MAX_OUTPUT_TOKENS}
-messagefilter.topP=${MESSAGE_FILTER_TOP_P}
-messagefilter.prompt=prompts/message_filter_prompt.txt
-# =========================================================
-# (DLP) Configuration
-# =========================================================
-google.cloud.dlp.dlpTemplateCompleteFlow=${DLP_TEMPLATE_COMPLETE_FLOW}
-google.cloud.dlp.dlpTemplatePersistFlow=${DLP_TEMPLATE_PERSIST_FLOW}
-# =========================================================
-# Quick-replies Preset-data
-# =========================================================
-firestore.data.importer.enabled=${GCP_FIRESTORE_IMPORTER_ENABLE}
-# =========================================================
-# LOGGING Configuration
-# =========================================================
-logging.level.root=${LOGGING_LEVEL_ROOT:INFO}
-logging.level.com.example=${LOGGING_LEVEL_COM_EXAMPLE:INFO}
-# =========================================================
-# ConversationContext Configuration
-# =========================================================
-conversation.context.message.limit=${CONVERSATION_CONTEXT_MESSAGE_LIMIT}
-conversation.context.days.limit=${CONVERSATION_CONTEXT_DAYS_LIMIT}
--- a/target/classes/application.properties
+++ b/target/classes/application.properties
@@ -1 +0,0 @@
-spring.profiles.active=${SPRING_PROFILE}
--- a/target/classes/com/example/Orchestrator.class
+++ b/target/classes/com/example/Orchestrator.class
--- a/target/classes/com/example/config/DlpConfig.class
+++ b/target/classes/com/example/config/DlpConfig.class
--- a/target/classes/com/example/config/GeminiConfig.class
+++ b/target/classes/com/example/config/GeminiConfig.class
--- a/target/classes/com/example/config/IntentDetectionConfig.class
+++ b/target/classes/com/example/config/IntentDetectionConfig.class
--- a/target/classes/com/example/config/OpenApiConfig.class
+++ b/target/classes/com/example/config/OpenApiConfig.class
--- a/target/classes/com/example/config/RedisConfig.class
+++ b/target/classes/com/example/config/RedisConfig.class
--- a/target/classes/com/example/controller/ConversationController.class
+++ b/target/classes/com/example/controller/ConversationController.class
--- a/target/classes/com/example/controller/DataPurgeController.class
+++ b/target/classes/com/example/controller/DataPurgeController.class
--- a/target/classes/com/example/controller/LlmResponseTunerController.class
+++ b/target/classes/com/example/controller/LlmResponseTunerController.class
--- a/target/classes/com/example/controller/NotificationController.class
+++ b/target/classes/com/example/controller/NotificationController.class
--- a/target/classes/com/example/controller/QuickRepliesController.class
+++ b/target/classes/com/example/controller/QuickRepliesController.class
--- a/target/classes/com/example/dto/dialogflow/base/DetectIntentRequestDTO.class
+++ b/target/classes/com/example/dto/dialogflow/base/DetectIntentRequestDTO.class
--- a/target/classes/com/example/dto/dialogflow/base/DetectIntentResponseDTO.class
+++ b/target/classes/com/example/dto/dialogflow/base/DetectIntentResponseDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/ConversationContext.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/ConversationContext.class
--- a/target/classes/com/example/dto/dialogflow/conversation/ConversationEntryDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/ConversationEntryDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/ConversationEntryEntity.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/ConversationEntryEntity.class
--- a/target/classes/com/example/dto/dialogflow/conversation/ConversationEntryType.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/ConversationEntryType.class
--- a/target/classes/com/example/dto/dialogflow/conversation/ConversationMessageDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/ConversationMessageDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/ConversationSessionDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/ConversationSessionDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/ExternalConvRequestDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/ExternalConvRequestDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/MessageType.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/MessageType.class
--- a/target/classes/com/example/dto/dialogflow/conversation/QueryInputDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/QueryInputDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/QueryParamsDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/QueryParamsDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/QueryResultDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/QueryResultDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/TextInputDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/TextInputDTO.class
--- a/target/classes/com/example/dto/dialogflow/conversation/UsuarioDTO.class
+++ b/target/classes/com/example/dto/dialogflow/conversation/UsuarioDTO.class
--- a/target/classes/com/example/dto/dialogflow/notification/EventInputDTO.class
+++ b/target/classes/com/example/dto/dialogflow/notification/EventInputDTO.class
--- a/target/classes/com/example/dto/dialogflow/notification/ExternalNotRequestDTO.class
+++ b/target/classes/com/example/dto/dialogflow/notification/ExternalNotRequestDTO.class
--- a/target/classes/com/example/dto/dialogflow/notification/NotificationDTO.class
+++ b/target/classes/com/example/dto/dialogflow/notification/NotificationDTO.class
--- a/target/classes/com/example/dto/dialogflow/notification/NotificationSessionDTO.class
+++ b/target/classes/com/example/dto/dialogflow/notification/NotificationSessionDTO.class
--- a/target/classes/com/example/dto/llm/webhook/SessionInfoDTO.class
+++ b/target/classes/com/example/dto/llm/webhook/SessionInfoDTO.class
--- a/target/classes/com/example/dto/llm/webhook/WebhookRequestDTO.class
+++ b/target/classes/com/example/dto/llm/webhook/WebhookRequestDTO.class
--- a/target/classes/com/example/dto/llm/webhook/WebhookResponseDTO.class
+++ b/target/classes/com/example/dto/llm/webhook/WebhookResponseDTO.class
--- a/target/classes/com/example/dto/quickreplies/QuestionDTO.class
+++ b/target/classes/com/example/dto/quickreplies/QuestionDTO.class
--- a/target/classes/com/example/dto/quickreplies/QuickReplyDTO.class
+++ b/target/classes/com/example/dto/quickreplies/QuickReplyDTO.class
--- a/target/classes/com/example/dto/quickreplies/QuickReplyScreenRequestDTO.class
+++ b/target/classes/com/example/dto/quickreplies/QuickReplyScreenRequestDTO.class
--- a/target/classes/com/example/dto/rag/RagQueryRequest$NotificationContext.class
+++ b/target/classes/com/example/dto/rag/RagQueryRequest$NotificationContext.class
--- a/target/classes/com/example/dto/rag/RagQueryRequest.class
+++ b/target/classes/com/example/dto/rag/RagQueryRequest.class
--- a/target/classes/com/example/dto/rag/RagQueryResponse.class
+++ b/target/classes/com/example/dto/rag/RagQueryResponse.class
--- a/target/classes/com/example/exception/DialogflowClientException.class
+++ b/target/classes/com/example/exception/DialogflowClientException.class
--- a/target/classes/com/example/exception/FirestorePersistenceException.class
+++ b/target/classes/com/example/exception/FirestorePersistenceException.class
--- a/target/classes/com/example/exception/GeminiClientException.class
+++ b/target/classes/com/example/exception/GeminiClientException.class
--- a/target/classes/com/example/exception/GlobalExceptionHandler.class
+++ b/target/classes/com/example/exception/GlobalExceptionHandler.class
--- a/target/classes/com/example/exception/RagClientException.class
+++ b/target/classes/com/example/exception/RagClientException.class
--- a/target/classes/com/example/mapper/conversation/ConversationEntryMapper.class
+++ b/target/classes/com/example/mapper/conversation/ConversationEntryMapper.class
--- a/target/classes/com/example/mapper/conversation/ConversationMessageMapper.class
+++ b/target/classes/com/example/mapper/conversation/ConversationMessageMapper.class
--- a/target/classes/com/example/mapper/conversation/DialogflowRequestMapper.class
+++ b/target/classes/com/example/mapper/conversation/DialogflowRequestMapper.class
--- a/target/classes/com/example/mapper/conversation/DialogflowResponseMapper.class
+++ b/target/classes/com/example/mapper/conversation/DialogflowResponseMapper.class
--- a/target/classes/com/example/mapper/conversation/ExternalConvRequestMapper.class
+++ b/target/classes/com/example/mapper/conversation/ExternalConvRequestMapper.class
--- a/target/classes/com/example/mapper/conversation/FirestoreConversationMapper.class
+++ b/target/classes/com/example/mapper/conversation/FirestoreConversationMapper.class
--- a/target/classes/com/example/mapper/messagefilter/ConversationContextMapper.class
+++ b/target/classes/com/example/mapper/messagefilter/ConversationContextMapper.class
--- a/target/classes/com/example/mapper/messagefilter/NotificationContextMapper.class
+++ b/target/classes/com/example/mapper/messagefilter/NotificationContextMapper.class
--- a/target/classes/com/example/mapper/notification/ExternalNotRequestMapper.class
+++ b/target/classes/com/example/mapper/notification/ExternalNotRequestMapper.class
--- a/target/classes/com/example/mapper/notification/FirestoreNotificationMapper$1.class
+++ b/target/classes/com/example/mapper/notification/FirestoreNotificationMapper$1.class
--- a/target/classes/com/example/mapper/notification/FirestoreNotificationMapper.class
+++ b/target/classes/com/example/mapper/notification/FirestoreNotificationMapper.class
--- a/target/classes/com/example/mapper/rag/RagRequestMapper.class
+++ b/target/classes/com/example/mapper/rag/RagRequestMapper.class
--- a/target/classes/com/example/mapper/rag/RagResponseMapper.class
+++ b/target/classes/com/example/mapper/rag/RagResponseMapper.class
--- a/target/classes/com/example/repository/FirestoreBaseRepository.class
+++ b/target/classes/com/example/repository/FirestoreBaseRepository.class
--- a/target/classes/com/example/service/base/DataPurgeService.class
+++ b/target/classes/com/example/service/base/DataPurgeService.class
--- a/target/classes/com/example/service/base/DialogflowClientService.class
+++ b/target/classes/com/example/service/base/DialogflowClientService.class
--- a/target/classes/com/example/service/base/GeminiClientService.class
+++ b/target/classes/com/example/service/base/GeminiClientService.class
--- a/target/classes/com/example/service/base/IntentDetectionService.class
+++ b/target/classes/com/example/service/base/IntentDetectionService.class
--- a/target/classes/com/example/service/base/MessageEntryFilter.class
+++ b/target/classes/com/example/service/base/MessageEntryFilter.class
--- a/target/classes/com/example/service/base/NotificationContextResolver.class
+++ b/target/classes/com/example/service/base/NotificationContextResolver.class
--- a/target/classes/com/example/service/base/RagClientService.class
+++ b/target/classes/com/example/service/base/RagClientService.class
--- a/target/classes/com/example/service/conversation/ConversationHistoryService.class
+++ b/target/classes/com/example/service/conversation/ConversationHistoryService.class
--- a/target/classes/com/example/service/conversation/ConversationManagerService.class
+++ b/target/classes/com/example/service/conversation/ConversationManagerService.class
--- a/target/classes/com/example/service/conversation/DataLossPrevention.class
+++ b/target/classes/com/example/service/conversation/DataLossPrevention.class
--- a/target/classes/com/example/service/conversation/DataLossPreventionImpl$1.class
+++ b/target/classes/com/example/service/conversation/DataLossPreventionImpl$1.class
--- a/target/classes/com/example/service/conversation/DataLossPreventionImpl.class
+++ b/target/classes/com/example/service/conversation/DataLossPreventionImpl.class
--- a/target/classes/com/example/service/conversation/FirestoreConversationService.class
+++ b/target/classes/com/example/service/conversation/FirestoreConversationService.class
--- a/target/classes/com/example/service/conversation/MemoryStoreConversationService.class
+++ b/target/classes/com/example/service/conversation/MemoryStoreConversationService.class
--- a/target/classes/com/example/service/llm/LlmResponseTunerService.class
+++ b/target/classes/com/example/service/llm/LlmResponseTunerService.class
--- a/target/classes/com/example/service/llm/LlmResponseTunerServiceImpl.class
+++ b/target/classes/com/example/service/llm/LlmResponseTunerServiceImpl.class
--- a/target/classes/com/example/service/notification/FirestoreNotificationService.class
+++ b/target/classes/com/example/service/notification/FirestoreNotificationService.class
--- a/target/classes/com/example/service/notification/MemoryStoreNotificationService.class
+++ b/target/classes/com/example/service/notification/MemoryStoreNotificationService.class
--- a/target/classes/com/example/service/notification/NotificationManagerService.class
+++ b/target/classes/com/example/service/notification/NotificationManagerService.class
--- a/target/classes/com/example/service/quickreplies/MemoryStoreQRService.class
+++ b/target/classes/com/example/service/quickreplies/MemoryStoreQRService.class
--- a/target/classes/com/example/service/quickreplies/QuickRepliesManagerService.class
+++ b/target/classes/com/example/service/quickreplies/QuickRepliesManagerService.class
--- a/target/classes/com/example/service/quickreplies/QuickReplyContentService.class
+++ b/target/classes/com/example/service/quickreplies/QuickReplyContentService.class
--- a/target/classes/com/example/util/FirestoreDataImporter$1.class
+++ b/target/classes/com/example/util/FirestoreDataImporter$1.class
--- a/target/classes/com/example/util/FirestoreDataImporter.class
+++ b/target/classes/com/example/util/FirestoreDataImporter.class
--- a/target/classes/com/example/util/FirestoreTimestampDeserializer.class
+++ b/target/classes/com/example/util/FirestoreTimestampDeserializer.class
--- a/Show More
+++ b/Show More