Task Planning

**Acceptance Criteria:**
- REST endpoint listens on port ${rest.port} (externalized config)
- Accepts POST requests at /api/orders
- Expects JSON payload with orderId, customerId, items, totalAmount
- Returns HTTP 202 Accepted immediately (fire-and-forget)
- Passes order to internal SEDA queue for async processing
- No business logic in this route (separation of concerns)

**Acceptance Criteria:**
- Receives order from internal queue
- Queries PostgreSQL using camel-sql component
- SQL: SELECT credit_status, warehouse_location FROM customers WHERE id = :customerId
- Database URL, username, password from application.properties
- Sets headers: creditStatus, warehouseLocation
- Handles SQLException with 3 retries (exponential backoff 2s, 4s, 8s)
- If all retries exhausted, routes to error handler

**Components:**
- camel-kafka (producer)
- camel-jackson (JSON serialization)

**Dependencies:**
- Kafka client libraries (included with camel-kafka)

## Task N: [Task Name]

**Description:**
[What this task does in 1-2 sentences]

**Acceptance Criteria:**
- [Criterion 1]
- [Criterion 2]
- [Criterion 3]

**Components:**
- camel-component-1
- camel-component-2

**Review:**
- Spec compliance: Validate against acceptance criteria
- Code quality: Validate against Constitution

**Dependencies:**
- Task X (if any)

# Implementation Plan: Order Processing Integration

## Task 1: REST Endpoint for Order Reception

**Description:**
Expose a REST endpoint that accepts order POST requests and 
returns HTTP 202 Accepted immediately. The endpoint passes 
orders to an internal SEDA queue for asynchronous processing.

**Acceptance Criteria:**
- REST endpoint listens on port ${rest.port} (default 8080)
- Accepts POST at /api/orders with JSON body
- Returns HTTP 202 Accepted with no body
- Sends order to SEDA queue "orders.processing"
- No validation or business logic in this route
- Metrics: orders.received.total counter

**Components:**
- camel-rest (embedded Jetty)
- camel-jackson (JSON unmarshalling)
- camel-seda (async queue)

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rules 2 (single responsibility), 
  3 (separation of concerns), 5 (metrics), 6 (external config)

**Dependencies:**
- None

---

## Task 2: Order Validation Flow

**Description:**
Consumes orders from the SEDA queue, validates schema and 
business rules, and routes valid orders forward or invalid 
orders to the error queue.

**Acceptance Criteria:**
- Consumes from SEDA queue "orders.processing"
- Validates: orderId not null, totalAmount > 0, customerId not null
- Valid orders → send to SEDA "orders.enrichment"
- Invalid orders → send to Kafka topic "orders.invalid" with error message
- Metrics: orders.valid.total, orders.invalid.total counters
- Log validation failures at WARN level

**Components:**
- camel-seda (consumer)
- camel-bean (validation logic)
- camel-choice (conditional routing)
- camel-kafka (invalid orders producer)

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rules 1 (route structure), 2 (single 
  responsibility), 5 (observability), 6 (external config for Kafka)

**Dependencies:**
- Task 1 (REST Endpoint creates SEDA queue)

---

## Task 3: Customer Credit Lookup Flow

**Description:**
Queries PostgreSQL database to retrieve customer credit status 
and warehouse location, enriches the order, and handles database 
failures with retry logic.

**Acceptance Criteria:**
- Consumes from SEDA "orders.enrichment"
- SQL query: SELECT credit_status, warehouse_location FROM customers WHERE id = :customerId
- Database config from application.properties (url, username, password)
- Sets exchange headers: creditStatus, warehouseLocation
- On SQLException: retry 3x with exponential backoff (2s, 4s, 8s)
- After retry exhaustion: send to SEDA "orders.error"
- Metrics: database.lookup.time timer, errors.database.total counter

**Components:**
- camel-seda (consumer)
- camel-sql (database query)
- camel-bean (retry logic)

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rules 2, 5, 6

**Dependencies:**
- Task 2 (Validation sends to SEDA enrichment queue)

---

## Task 4: Conditional Routing Flow

**Description:**
Routes enriched orders based on credit status: ACTIVE → warehouse, 
BLOCKED → pending, or validation failures → invalid.

**Acceptance Criteria:**
- Consumes from credit lookup output
- If creditStatus = "ACTIVE" → send to SEDA "orders.warehouse"
- If creditStatus = "BLOCKED" → send to SEDA "orders.pending"
- Uses Camel Choice DSL for conditional routing
- Logs routing decision at INFO level

**Components:**
- camel-choice (conditional router)
- camel-seda (multiple destinations)

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rule 2 (single responsibility)

**Dependencies:**
- Task 3 (Credit lookup sets creditStatus header)

---

## Task 5: Kafka Publisher for Warehouse Orders

**Description:**
Publishes validated, active-credit orders to Kafka topic 
"warehouse.orders" for consumption by the warehouse management system.

**Acceptance Criteria:**
- Consumes from SEDA "orders.warehouse"
- Publishes to Kafka topic "warehouse.orders" on broker ${kafka.brokers}
- Message key: order.orderId
- Message value: JSON order with credit and warehouse fields
- On publish failure: retry indefinitely with 1s delay
- Metrics: kafka.publish.time timer

**Components:**
- camel-kafka (producer)
- camel-jackson (JSON marshalling)

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rules 5, 6

**Dependencies:**
- Task 4 (Routing sends to SEDA warehouse queue)

---

## Task 6: Kafka Publisher for Pending Orders

**Description:**
Publishes blocked-credit orders to Kafka topic "orders.pending" 
for manual review by the finance team.

**Acceptance Criteria:**
- Consumes from SEDA "orders.pending"
- Publishes to Kafka topic "orders.pending"
- Same retry and metrics as Task 5

**Components:**
- camel-kafka, camel-jackson

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rules 5, 6

**Dependencies:**
- Task 4 (Routing sends to SEDA pending queue)

---

## Task 7: Kafka Publisher for Invalid Orders

**Description:**
Publishes validation-failed orders to Kafka topic "orders.invalid" 
with error messages for manual review.

**Acceptance Criteria:**
- Consumes from validation failure route (Task 2 output)
- Publishes to Kafka topic "orders.invalid"
- Includes validation error message in JSON payload
- Same retry and metrics as Task 5

**Components:**
- camel-kafka, camel-jackson

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rules 5, 6

**Dependencies:**
- Task 2 (Validation failures route here)

---

## Task 8: Error Handler for Database Failures

**Description:**
Handles database lookup failures after retry exhaustion by 
sending email alerts to operations team.

**Acceptance Criteria:**
- Consumes from SEDA "orders.error"
- Sends email to ${ops.email} via SMTP server ${smtp.host}
- Email subject: "Order Processing Database Error"
- Email body: orderId, error message, timestamp
- Rate limiting: Alert if > 10 errors in 5 minutes
- Logs error at ERROR level

**Components:**
- camel-mail (SMTP sender)
- camel-bean (rate limiting logic)

**Review:**
- Spec compliance: All acceptance criteria met
- Code quality: Constitution Rules 5, 6

**Dependencies:**
- None (standalone error handler)

---

## Wave Analysis

**Wave 1 (Parallel Execution):**
- Task 1: REST Endpoint
- Task 8: Error Handler

**Wave 2 (Sequential, depends on Wave 1):**
- Task 2: Validation

**Wave 3 (Sequential, depends on Wave 2):**
- Task 3: Credit Lookup

**Wave 4 (Sequential, depends on Wave 3):**
- Task 4: Routing Decision

**Wave 5 (Parallel Execution, depends on Wave 4):**
- Task 5: Kafka Warehouse Publisher
- Task 6: Kafka Pending Publisher
- Task 7: Kafka Invalid Publisher

**Total Waves:** 5
**Total Tasks:** 8
**Parallelizable Tasks:** 4 (Tasks 1+8 in Wave 1, Tasks 5+6+7 in Wave 5)

**Review:**
- Spec compliance: Validate against acceptance criteria
- Code quality: Validate against Constitution
- Security: Validate no hardcoded secrets, proper input validation