fix: Update example 04 event handler to properly handle Event objects

- Fixed new_bar_callback to correctly extract data from Event objects
- Added defensive checks for event.data attribute access
- Prevents 'Event object is not subscriptable' error

Author: TexasCoding

examples/03_position_management.py

@@ -104,16 +104,14 @@ async def display_positions(
             try:
                 # Get current market price
                 current_price = await suite.data.get_current_price()
-                if current_price:
-                    # Get instrument info for tick value
-                    instrument_info = await suite.client.get_instrument(
-                        suite.instrument
-                    )
-                    tick_value = instrument_info.tickValue
+                if current_price and suite.instrument:
+                    # Use the instrument already loaded in suite
+                    instrument_info = suite.instrument
+                    point_value = instrument_info.tickValue / instrument_info.tickSize
 
                     # Calculate P&L using position manager's method
                     pnl_data = await position_manager.calculate_position_pnl(
-                        position, float(current_price), point_value=tick_value
+                        position, float(current_price), point_value=point_value
                     )
                     unrealized_pnl = pnl_data["unrealized_pnl"]
             except Exception:
@@ -193,18 +191,19 @@ async def monitor_positions(
                     # Try to calculate real P&L with current prices
                     if suite and positions:
                         current_price = await suite.data.get_current_price()
-                        if current_price:
-                            instrument_info = await suite.client.get_instrument(
-                                suite.instrument
+                        if current_price and suite.instrument:
+                            # Use the instrument already loaded in suite
+                            instrument_info = suite.instrument
+                            point_value = (
+                                instrument_info.tickValue / instrument_info.tickSize
                             )
-                            tick_value = instrument_info.tickValue
 
                             for position in positions:
                                 pnl_data = (
                                     await position_manager.calculate_position_pnl(
                                         position,
                                         float(current_price),
-                                        point_value=tick_value,
+                                        point_value=point_value,
                                     )
                                 )
                                 total_pnl += pnl_data["unrealized_pnl"]

examples/04_realtime_data.py

@@ -173,14 +173,17 @@ async def demonstrate_historical_analysis(data_manager: "RealtimeDataManager") -
         print(f"   ❌ Analysis error: {e}")
 
 
-async def new_bar_callback(data: dict[str, Any]) -> None:
+async def new_bar_callback(event: Any) -> None:
     """Handle new bar creation asynchronously."""
     timestamp = datetime.now().strftime("%H:%M:%S")
-    timeframe = data["timeframe"]
-    bar = data["data"]
-    print(
-        f"📊 [{timestamp}] New {timeframe} Bar: ${bar['close']:.2f} (Vol: {bar['volume']:,})"
-    )
+    # Extract data from the Event object
+    data = event.data if hasattr(event, "data") else event
+    timeframe = data.get("timeframe", "unknown")
+    bar = data.get("data", {})
+    if bar and "close" in bar and "volume" in bar:
+        print(
+            f"📊 [{timestamp}] New {timeframe} Bar: ${bar['close']:.2f} (Vol: {bar['volume']:,})"
+        )
 
 
 async def main() -> bool: