BPM con Kogito / SonataFlow

┌──────────────────┐
│  CDC Event        │
│  (Kafka Topic)    │
└────────┬─────────┘
         │
┌────────▼─────────┐
│ Validate Customer │
│ Data              │
└────────┬─────────┘
         │
┌────────▼─────────┐
│ Classify Customer │
│ (basic/standard/  │
│  premium)         │
└────────┬─────────┘
         │
    ┌────┴────┐
    │ Premium? │
    └────┬────┘
   Yes   │   No
┌────────▼──┐  ┌──▼──────────┐
│ Manager    │  │ Auto-       │
│ Approval   │  │ Approved    │
│ (24h SLA)  │  │             │
└────────┬──┘  └──┬──────────┘
         │        │
┌────────▼────────▼┐
│ Provision Account │
│ (parallel)        │
│ ├─ Create Account │
│ └─ Send Welcome   │
└────────┬─────────┘
         │
┌────────▼─────────┐
│ Emit Onboarding   │
│ Metric            │
└──────────────────┘

spec:
  flow:
    start: ReceiveCDCEvent
    events:
      - name: cdcCustomerEvent
        type: cdc.public.customers
        source: debezium/cdc
      - name: approvalCompleted
        type: approval.completed
        source: internal

    functions:
      - name: classifyCustomer
        type: expression
        operation: |
          .customer | if .amount >= 50000 then "premium"
                    elif .amount >= 10000 then "standard"
                    else "basic" end
      - name: sendApprovalRequest
        type: rest
        operation: "http://cdc-bridge-bridge-service.kafka-cdc.svc:8080/topics/bpm.approval.requests#POST"
      - name: sendWelcomeNotification
        type: rest
        operation: "http://n8n-mailpit.openshift-lightspeed.svc:8025/api/v1/send#POST"
      - name: publishMetrics
        type: rest
        operation: "http://cdc-bridge-bridge-service.kafka-cdc.svc:8080/topics/bpm.onboarding.metrics#POST"

      - name: RequestManagerApproval
        type: callback
        action:
          name: requestApproval
          functionRef:
            refName: sendApprovalRequest
          actionDataFilter:
            fromStateData: |
              {
                "records": [{
                  "value": {
                    "customer_id": .customer.id,
                    "name": "\(.customer.first_name) \(.customer.last_name)",
                    "email": .customer.email,
                    "tier": .tier,
                    "status": "pending_approval"
                  }
                }]
              }
        eventRef: approvalCompleted
        timeouts:
          eventTimeout: PT24H
        transition: EvaluateApproval

      - name: ProvisionAccount
        type: parallel
        branches:
          - name: CreateAccount
            actions:
              - name: logProvisioning
                functionRef:
                  refName: logEvent
          - name: SendWelcome
            actions:
              - name: sendWelcome
                functionRef:
                  refName: sendWelcomeNotification
                actionDataFilter:
                  fromStateData: |
                    {
                      "from": {"name": "NeuralBank Onboarding", "email": "onboarding@neuralbank.io"},
                      "to": [{"name": "\(.customer.first_name)", "email": "\(.customer.email)"}],
                      "subject": "Welcome to NeuralBank - \(.tier) Account",
                      "text": "Hello \(.customer.first_name)! Your \(.tier) account has been created."
                    }
        completionType: allOf

-- Crear cliente basic (auto-approved)
INSERT INTO customers (first_name, last_name, email)
VALUES ('Juan', 'Basic', 'juan.basic@neuralbank.io');

-- Crear cliente premium (requires approval)
INSERT INTO customers (first_name, last_name, email)
VALUES ('Maria', 'Premium', 'maria.premium@neuralbank.io');