Fix C++ engine buy/sell and add Optiq actor stages to Message Flow

- ClOrdID: use numeric IDs (C++ strtoull parsed 'D-42' as 0)
- ExecType: handle FIX standard '150=F' for trades (was checking '1'/'2')
- Use order data from _pending instead of missing exec report tags
- Add MECore stage to pipeline visualizer (OEG > Book > MECore > Match)
- Log full C++ actor path: OEG > Book > MECore > Match > Trade > DB > CH
- Auto-restart FIX gateway on engine crash

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

dashboard/app.py

@@ -339,7 +339,7 @@ class CppEngineBridge:
         global next_order_id
         oid = next_order_id
         next_order_id += 1
-        cl_ord_id = cl_ord_id or f"D-{oid}"
+        cl_ord_id = cl_ord_id or str(oid)
 
         sym_name = symbols.get(symbol_id, {}).get("name", "???")
         fix_side = "1" if side == "Buy" else "2"
@@ -377,10 +377,13 @@ class CppEngineBridge:
 
         if self._connected:
             self._pending[cl_ord_id] = order
+            log_message("OEG", f"[C++] NewOrder {sym_name} {side} {quantity}@{price:.2f} → FIXAcceptor", order_id=oid)
+            log_message("Book", f"[C++] 35=D clOrdId={cl_ord_id} → OEGActor → MECoreActor", order_id=oid)
             self._send_fix(fields)
         else:
             order["status"] = "Rejected"
             order["remainingQty"] = quantity
+            log_message("OEG", f"[C++] NewOrder REJECTED — not connected", order_id=oid)
 
         with state_lock:
             orders.append(order)
@@ -515,40 +518,46 @@ class CppEngineBridge:
     def _handle_exec_report(self, fields):
         cl_ord_id = fields.get(11, "")
         exec_type = fields.get(150, "")
-        symbol = fields.get(55, "")
-        side = "Buy" if fields.get(54) == "1" else "Sell"
+        ord_status = fields.get(39, "")
         last_px = float(fields.get(31, 0))
         last_qty = int(fields.get(32, 0))
         leaves_qty = int(fields.get(151, 0))
 
         order = self._pending.get(cl_ord_id)
-        if order:
-            order["remainingQty"] = leaves_qty
-            if exec_type == "2":  # Fill
+        if not order:
+            return
+
+        symbol = order.get("symbol", "?")
+        side = order.get("side", "?")
+        oid = order.get("orderId", "?")
+
+        order["remainingQty"] = leaves_qty
+        if exec_type == "F" or ord_status == "2":
+            if leaves_qty == 0:
                 order["status"] = "Filled"
-            elif exec_type == "1":  # Partial
+            else:
                 order["status"] = "PartiallyFilled"
-            elif exec_type == "4":  # Cancelled
-                order["status"] = "Cancelled"
-            elif exec_type == "8":  # Rejected
-                order["status"] = "Rejected"
-            save_order(db_path, order)
-            broadcast_event("order", order)
-
-        if exec_type in ("1", "2") and last_qty > 0:
-            sym_id = None
-            for sid, info in symbols.items():
-                if info["name"] == symbol:
-                    sym_id = sid
-                    break
+        elif exec_type == "0" or ord_status == "0":
+            order["status"] = "New"
+        elif exec_type == "4" or ord_status == "4":
+            order["status"] = "Cancelled"
+        elif exec_type == "8" or ord_status == "8":
+            order["status"] = "Rejected"
+        save_order(db_path, order)
+        broadcast_event("order", order)
+
+        log_message("MECore", f"[C++] ExecReport Order#{oid} → {order['status']}", order_id=oid)
+
+        if exec_type == "F" and last_qty > 0:
+            sym_id = order.get("symbolIdx", 0)
             trade = {
                 "tradeId": len(trades) + 1,
-                "symbolIdx": sym_id or 0,
+                "symbolIdx": sym_id,
                 "symbol": symbol,
                 "price": last_px,
                 "quantity": last_qty,
-                "buyOrderId": order["orderId"] if order and side == "Buy" else 0,
-                "sellOrderId": order["orderId"] if order and side == "Sell" else 0,
+                "buyOrderId": oid if side == "Buy" else 0,
+                "sellOrderId": oid if side == "Sell" else 0,
                 "timestamp": time.time(),
                 "source": "cpp-engine",
             }
@@ -556,6 +565,10 @@ class CppEngineBridge:
                 trades.append(trade)
             save_trade(db_path, trade)
             record_ohlcv(db_path, symbol, last_px, last_qty)
+            log_message("Match", f"[C++] Trade#{trade['tradeId']} {symbol} {last_qty}@{last_px:.2f}", order_id=oid)
+            log_message("Trade", f"[C++] Trade#{trade['tradeId']} persisted", order_id=oid, trade_id=trade["tradeId"])
+            log_message("DB", f"[C++] Trade#{trade['tradeId']} → SQLite", trade_id=trade["tradeId"])
+            log_message("CH", f"[C++] Trade#{trade['tradeId']} → clearing", order_id=oid, trade_id=trade["tradeId"])
             broadcast_event("trade", trade)
             if sym_id:
                 engine._update_snapshot(sym_id)
@@ -802,11 +815,6 @@ def _active_engine():
 def new_order():
     d = request.json
     active = _active_engine()
-    if engine_mode == "cpp":
-        sym_name = symbols.get(int(d["symbolIdx"]), {}).get("name", "?")
-        log_message("OEG", f"[C++] NewOrder {sym_name} {d['side']} {d['quantity']}@{float(d.get('price',0)):.2f}",
-                    order_id=0)
-        log_message("FIX", f"[C++] 35=D → eunex_me:{cpp_bridge.port}", order_id=0)
     order = active.submit_order(
         symbol_id=int(d["symbolIdx"]),
         side=d["side"],

dashboard/templates/index.html

@@ -159,9 +159,11 @@ border-radius:6px;color:var(--text);font-size:12px}
 .stage-match{background:#f0c04022;color:var(--yellow);border:1px solid #f0c04044}
 .stage-trade{background:#7c5cfc22;color:var(--purple);border:1px solid #7c5cfc44}
 .stage-db{background:#ff6b6b22;color:var(--red);border:1px solid #ff6b6b44}
+.stage-mecore{background:#ff8c0022;color:#ff8c00;border:1px solid #ff8c0044}
 .stage-ch{background:#00d4aa22;color:var(--accent);border:1px solid #00d4aa44}
 .stage-oeg.active{background:#4a90d944;box-shadow:0 0 12px #4a90d944}
 .stage-book.active{background:#00d4aa44;box-shadow:0 0 12px #00d4aa44}
+.stage-mecore.active{background:#ff8c0044;box-shadow:0 0 12px #ff8c0044}
 .stage-match.active{background:#f0c04044;box-shadow:0 0 12px #f0c04044}
 .stage-trade.active{background:#7c5cfc44;box-shadow:0 0 12px #7c5cfc44}
 .stage-db.active{background:#ff6b6b44;box-shadow:0 0 12px #ff6b6b44}
@@ -172,7 +174,7 @@ border-radius:6px;color:var(--text);font-size:12px}
 @keyframes fadeFlow{from{opacity:0;transform:translateX(-8px)}to{opacity:1;transform:translateX(0)}}
 .flow-ts{color:var(--muted);min-width:75px;font-size:10px}
 .flow-tag{min-width:50px;font-weight:600;font-size:10px;text-transform:uppercase}
-.flow-tag-oeg{color:var(--blue)}.flow-tag-book{color:var(--accent)}.flow-tag-match{color:var(--yellow)}
+.flow-tag-oeg{color:var(--blue)}.flow-tag-book{color:var(--accent)}.flow-tag-mecore{color:#ff8c00}.flow-tag-match{color:var(--yellow)}
 .flow-tag-trade{color:var(--purple)}.flow-tag-db{color:var(--red)}.flow-tag-ch{color:var(--accent)}
 .flow-detail{color:var(--text)}
 .flow-empty{padding:30px;text-align:center;color:var(--muted)}
@@ -363,12 +365,14 @@ border-radius:6px;color:var(--text);font-size:12px}
           <div class="flow-arrow" id="fa1">&#9654;</div>
           <div class="flow-stage stage-book" id="fpBook"><span class="count">-</span>Book</div>
           <div class="flow-arrow" id="fa2">&#9654;</div>
-          <div class="flow-stage stage-match" id="fpMatch"><span class="count">-</span>Match</div>
+          <div class="flow-stage stage-mecore" id="fpMECore"><span class="count">-</span>MECore</div>
           <div class="flow-arrow" id="fa3">&#9654;</div>
-          <div class="flow-stage stage-trade" id="fpTrade"><span class="count">-</span>Trade</div>
+          <div class="flow-stage stage-match" id="fpMatch"><span class="count">-</span>Match</div>
           <div class="flow-arrow" id="fa4">&#9654;</div>
-          <div class="flow-stage stage-db" id="fpDB"><span class="count">-</span>DB</div>
+          <div class="flow-stage stage-trade" id="fpTrade"><span class="count">-</span>Trade</div>
           <div class="flow-arrow" id="fa5">&#9654;</div>
+          <div class="flow-stage stage-db" id="fpDB"><span class="count">-</span>DB</div>
+          <div class="flow-arrow" id="fa6">&#9654;</div>
           <div class="flow-stage stage-ch" id="fpCH"><span class="count">-</span>CH</div>
         </div>
         <div class="flow-msgs" id="flowMsgs">
@@ -876,7 +880,7 @@ function renderOrderDetail(oid) {
   const o = flowOrderMap[oid];
   if (!o) return;
   const stages = new Set(o.entries.map(e => e.stage));
-  const stageOrder = ['OEG','Book','Match','Trade','DB','CH'];
+  const stageOrder = ['OEG','Book','MECore','Match','Trade','DB','CH'];
   const reachedIdx = Math.max(...stageOrder.map((s,i) => stages.has(s) ? i : -1));
 
   stageOrder.forEach((s, i) => {