fix: add missing event_type field, re-exports, target_size_fp, and update docs

- Add event_type: Option<UserOrderEventType> to UserOrderData (was
  defined but unused, matching OrderGroupUpdateData pattern)
- Re-export UserOrderData and UserOrderEventType from ws module
- Add missing target_size_fp field on IncentiveProgram (per official SDK)
- Add UserOrders and OrderGroupUpdates to stream_user_channels example
- Update ws module docs with complete channel listing
- Update order_groups example with new subaccount method

Author: pbeets

CHANGELOG.md

@@ -89,7 +89,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - `subaccount` filter on `ListRfqsParams` for per-subaccount RFQ queries.
 - `subaccount` filter on `GetOrderGroupsParams` for per-subaccount order group
   queries. New `get_order_group_for_subaccount()` method on `KalshiClient`.
-- `market_id` field on `IncentiveProgram`.
+- `market_id` and `target_size_fp` fields on `IncentiveProgram`.
 
 ### Fixed
 

examples/order_groups.rs

@@ -160,14 +160,15 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     // Available API Methods
     println!("=== Available Order Group Methods ===");
-    println!("  create_order_group()            - Create new order group");
-    println!("  get_order_group(id)             - Get order group details");
-    println!("  list_order_groups()             - List all order groups");
-    println!("  list_order_groups_with_params() - List with pagination");
-    println!("  update_order_group_limit(id, r) - Update contracts limit");
-    println!("  reset_order_group(id)           - Reset matched contracts counter");
-    println!("  trigger_order_group(id)         - Trigger auto-cancel manually");
-    println!("  delete_order_group(id)          - Delete group and cancel orders");
+    println!("  create_order_group()                     - Create new order group");
+    println!("  get_order_group(id)                      - Get order group details");
+    println!("  get_order_group_for_subaccount(id, sub)  - Get for specific subaccount");
+    println!("  list_order_groups()                      - List all order groups");
+    println!("  list_order_groups_with_params()          - List with pagination/subaccount");
+    println!("  update_order_group_limit(id, r)          - Update contracts limit");
+    println!("  reset_order_group(id)                    - Reset matched contracts counter");
+    println!("  trigger_order_group(id)                  - Trigger auto-cancel manually");
+    println!("  delete_order_group(id)                   - Delete group and cancel orders");
     println!();
 
     println!("=== Done ===");

examples/stream_user_channels.rs

@@ -1,4 +1,4 @@
-//! Example: Stream user-scoped channels (Fill, MarketPositions, Communications).
+//! Example: Stream user-scoped channels.
 //!
 //! This example demonstrates subscribing to authenticated channels that track
 //! user-specific activity. These channels don't require market tickers - they
@@ -9,6 +9,8 @@
 //! - `Fill`: Notifications when your orders are filled
 //! - `MarketPositions`: Real-time position updates
 //! - `Communications`: RFQ and quote notifications
+//! - `OrderGroupUpdates`: Order group lifecycle events
+//! - `UserOrders`: Real-time order updates (created, updated, canceled, executed)
 //!
 //! # Usage
 //!
@@ -65,6 +67,12 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     handle.subscribe(Channel::Communications, &[]).await?;
     println!("  Communications -> subscribed");
 
+    handle.subscribe(Channel::OrderGroupUpdates, &[]).await?;
+    println!("  OrderGroupUpdates -> subscribed");
+
+    handle.subscribe(Channel::UserOrders, &[]).await?;
+    println!("  UserOrders -> subscribed");
+
     println!("\nWaiting for updates (60 seconds)...");
     println!("Tip: Create/fill orders in another terminal to see Fill updates\n");
 
@@ -111,6 +119,21 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                 StreamMessage::Communication(comm) => {
                     println!("[COMMUNICATION] {:?}", comm);
                 }
+                StreamMessage::OrderGroupUpdate(og) => {
+                    println!(
+                        "[ORDER GROUP] {} | event={:?}",
+                        og.order_group_id, og.event_type
+                    );
+                }
+                StreamMessage::UserOrder(order) => {
+                    println!(
+                        "[USER ORDER] {} | event={:?} | ticker={} | status={:?}",
+                        order.order_id,
+                        order.event_type,
+                        order.ticker.as_deref().unwrap_or("?"),
+                        order.status
+                    );
+                }
                 StreamMessage::Unsubscribed => {
                     println!("[UNSUBSCRIBED] sid={}", update.sid);
                 }
@@ -135,6 +158,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     handle.unsubscribe_all(Channel::Fill).await?;
     handle.unsubscribe_all(Channel::MarketPositions).await?;
     handle.unsubscribe_all(Channel::Communications).await?;
+    handle.unsubscribe_all(Channel::OrderGroupUpdates).await?;
+    handle.unsubscribe_all(Channel::UserOrders).await?;
 
     println!("Shutting down...");
     client.shutdown().await?;

src/models/incentive_program.rs

@@ -36,6 +36,9 @@ pub struct IncentiveProgram {
     /// Target size for the program.
     #[serde(default)]
     pub target_size: Option<i64>,
+    /// Target size (fixed-point decimal string).
+    #[serde(default)]
+    pub target_size_fp: Option<String>,
     /// The market ID associated with this incentive program.
     #[serde(default)]
     pub market_id: Option<String>,

src/ws.rs

@@ -129,10 +129,12 @@
 //! - [`Channel::OrderbookDelta`] - Orderbook changes
 //! - [`Channel::MarketLifecycle`] - Market status changes
 //!
-//! User channels (no market tickers needed):
+//! User channels (require authentication, no market tickers needed):
 //! - [`Channel::Fill`] - Your executed fills
 //! - [`Channel::MarketPositions`] - Position changes
 //! - [`Channel::Communications`] - RFQ/quote updates
+//! - [`Channel::OrderGroupUpdates`] - Order group lifecycle events
+//! - [`Channel::UserOrders`] - Real-time order updates (created, updated, canceled, executed)
 //! - [`Channel::Multivariate`] - Multivariate event updates
 //!
 //! # Subscription Management
@@ -175,7 +177,8 @@ pub use message::{
     Action, CommunicationData, FillData, MarketLifecycleData, MarketLifecycleEventType,
     MarketPositionData, MultivariateLookupData, MveLeg, OrderGroupEventType, OrderGroupUpdateData,
     OrderbookDeltaData, OrderbookSnapshotData, PriceLevel, QuoteAcceptedData, QuoteData, RfqData,
-    RfqDeletedData, Side, StreamMessage, StreamUpdate, TickerData, TradeData,
+    RfqDeletedData, Side, StreamMessage, StreamUpdate, TickerData, TradeData, UserOrderData,
+    UserOrderEventType,
 };
 
 /// Connection strategy for the WebSocket client.

src/ws/message.rs

@@ -52,6 +52,9 @@ pub enum UserOrderEventType {
 pub struct UserOrderData {
     /// The order identifier.
     pub order_id: String,
+    /// The type of event (created, updated, canceled, executed).
+    #[serde(default)]
+    pub event_type: Option<UserOrderEventType>,
     /// Market ticker identifier.
     #[serde(default)]
     pub ticker: Option<String>,