ci: Add GitHub Actions CI workflow

- Add CI workflow with fmt, clippy, test, MSRV (1.92), and docs checks
- Add clippy allow attributes for too_many_arguments and result_large_err
- Update README badges (CI status, license, docs.rs)
- Use idiomatic while let pattern in reconnect example

Author: pbeets

.github/workflows/ci.yml

@@ -0,0 +1,64 @@
+name: CI
+
+on:
+  push:
+    branches: [main]
+  pull_request:
+    branches: [main]
+
+env:
+  CARGO_TERM_COLOR: always
+
+jobs:
+  fmt:
+    name: Format
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+        with:
+          components: rustfmt
+      - run: cargo fmt --all --check
+
+  clippy:
+    name: Clippy
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+        with:
+          components: clippy
+      - uses: Swatinem/rust-cache@v2
+      - run: cargo clippy --all-targets -- -D warnings
+
+  test:
+    name: Test
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+      - uses: Swatinem/rust-cache@v2
+      # Run single-threaded to avoid env var race conditions in config tests
+      - run: cargo test -- --test-threads=1
+
+  msrv:
+    name: MSRV (1.92)
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@master
+        with:
+          toolchain: "1.92"
+      - uses: Swatinem/rust-cache@v2
+      - run: cargo build --all-targets
+
+  docs:
+    name: Docs
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+      - uses: Swatinem/rust-cache@v2
+      - run: cargo doc --no-deps
+        env:
+          RUSTDOCFLAGS: -D warnings

README.md

@@ -1,7 +1,9 @@
 # Rust Rithmic R | Protocol API client
 
 [![Crates.io](https://img.shields.io/crates/v/rithmic-rs.svg)](https://crates.io/crates/rithmic-rs)
-[![Documentation](https://docs.rs/rithmic-rs/badge.svg)](https://docs.rs/rithmic-rs)
+[![docs.rs](https://img.shields.io/docsrs/rithmic-rs)](https://docs.rs/rithmic-rs)
+[![CI](https://github.com/pbeets/rithmic-rs/actions/workflows/ci.yml/badge.svg)](https://github.com/pbeets/rithmic-rs/actions)
+[![License](https://img.shields.io/crates/l/rithmic-rs)](LICENSE-MIT)
 
 [Official Rithmic API](https://www.rithmic.com/apis)
 

examples/reconnect.rs

@@ -48,26 +48,23 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             info!("Subscribed to {} on {}", symbol, exchange);
         }
 
-        // Inner loop: process until disconnect
-        loop {
-            match handle.subscription_receiver.recv().await {
-                Ok(update) => match &update.message {
-                    RithmicMessage::HeartbeatTimeout
-                    | RithmicMessage::ForcedLogout(_)
-                    | RithmicMessage::ConnectionError => {
-                        warn!("Disconnected, reconnecting...");
-                        break;
-                    }
-                    RithmicMessage::LastTrade(t) => {
-                        info!(
-                            "Trade: {} @ {}",
-                            t.trade_size.unwrap_or(0),
-                            t.trade_price.unwrap_or(0.0)
-                        );
-                    }
-                    _ => {}
-                },
-                Err(_) => break,
+        // Process until disconnect
+        while let Ok(update) = handle.subscription_receiver.recv().await {
+            match &update.message {
+                RithmicMessage::HeartbeatTimeout
+                | RithmicMessage::ForcedLogout(_)
+                | RithmicMessage::ConnectionError => {
+                    warn!("Disconnected, reconnecting...");
+                    break;
+                }
+                RithmicMessage::LastTrade(t) => {
+                    info!(
+                        "Trade: {} @ {}",
+                        t.trade_size.unwrap_or(0),
+                        t.trade_price.unwrap_or(0.0)
+                    );
+                }
+                _ => {}
             }
         }
 

src/api/receiver_api.rs

@@ -113,6 +113,10 @@ pub(crate) struct RithmicReceiverApi {
 }
 
 impl RithmicReceiverApi {
+    // TODO: Consider boxing RithmicMessage or using a dedicated error type to reduce
+    // Result size (~1296 bytes). Current impact is minimal since the Result is
+    // immediately matched and not passed through deep call stacks.
+    #[allow(clippy::result_large_err)]
     pub(crate) fn buf_to_message(&self, data: Bytes) -> Result<RithmicResponse, RithmicResponse> {
         let payload = &data[4..];
 

src/api/sender_api.rs

@@ -440,6 +440,7 @@ impl RithmicSenderApi {
     ///
     /// # Returns
     /// A tuple of (serialized request buffer, request ID)
+    #[allow(clippy::too_many_arguments)]
     pub fn request_new_order(
         &mut self,
         exchange: &str,
@@ -855,6 +856,7 @@ impl RithmicSenderApi {
     /// a round number of bars (e.g., 10000) or does not cover the entire requested
     /// time period, use [`request_resume_bars`](Self::request_resume_bars) with the
     /// `request_key` from the response to fetch the remaining data.
+    #[allow(clippy::too_many_arguments)]
     pub fn request_volume_profile_minute_bars(
         &mut self,
         symbol: &str,

src/plants/history_plant.rs

@@ -880,6 +880,7 @@ impl RithmicHistoryPlantHandle {
     ///
     /// # Returns
     /// The volume profile minute bar responses or an error message
+    #[allow(clippy::too_many_arguments)]
     pub async fn load_volume_profile_minute_bars(
         &self,
         symbol: String,

src/plants/order_plant.rs

@@ -1726,6 +1726,7 @@ impl RithmicOrderPlantHandle {
     ///
     /// # Returns
     /// A vector of order placement responses or an error message
+    #[allow(clippy::too_many_arguments)]
     pub async fn place_new_order(
         &self,
         exchange: &str,