chore: cargo fmt --all + CI hardening (rustfmt gate, resilient Linux install) (#79)

* chore: cargo fmt --all + add rustfmt CI gate

Trunk had accumulated rustfmt drift — CI never ran `cargo fmt --check` and
there is no rustfmt.toml, so pre-existing code had multi-line attributes,
unwrapped imports, and inconsistent call wrapping.

- Run `cargo fmt --all` across the workspace (src/params.rs, src/client.rs).
- Add a `rustfmt` job to build.yml (`cargo fmt --all --check`) so formatting
  stays clean going forward.

Pure formatting — no behavioral change; all lib tests and doctests pass.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

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

* ci: make Linux Spice install resilient to GitHub 429 rate limits

`curl https://install.spiceai.org | /bin/bash` has no `-f` flag, so when the
proxied GitHub script returns an HTTP 429 rate-limit page, that page is piped
into bash and executed (syntax error → exit 2) — an intermittent flake seen on
PR CI. Add `-f` + `pipefail` so a bad HTTP response is a real curl failure, and
retry the installer and `spice install` (mirrors the resilient macOS step from
#72/#78).

🤖 Generated with [Claude Code](https://claude.com/claude-code)

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

---------

Co-authored-by: Claude <noreply@anthropic.com>

Author: lukekim

.github/workflows/build.yml

@@ -12,6 +12,23 @@ env:
   CARGO_TERM_COLOR: always
 
 jobs:
+  fmt:
+    name: rustfmt
+    runs-on: ubuntu-latest
+    steps:
+      # actions/checkout v4.2.2
+      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
+
+      - name: Install Rust toolchain
+        # dtolnay/rust-toolchain (pinned 2026-06-30)
+        uses: dtolnay/rust-toolchain@fa04a1451ff1842e2626ccb99004d0195b455a88
+        with:
+          toolchain: 1.93.1
+          components: rustfmt
+
+      - name: Check formatting
+        run: cargo fmt --all --check
+
   build_toolchains:
     name: Clippy on ${{ matrix.toolchain }}
     runs-on: ubuntu-latest
@@ -97,9 +114,21 @@ jobs:
         env:
           GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
         run: |
-          curl https://install.spiceai.org | /bin/bash
-          echo "$HOME/.spice/bin" >> $GITHUB_PATH
-          $HOME/.spice/bin/spice install
+          # install.spiceai.org proxies a GitHub-hosted script and can return an
+          # HTTP 429 (rate-limit) page; without -f, `curl | bash` pipes that page
+          # into bash and fails the job. Use -f + pipefail so a bad response is a
+          # real error, and retry the rate-limitable network steps.
+          set -o pipefail
+          for i in 1 2 3; do
+            curl -fsSL https://install.spiceai.org | /bin/bash && break
+            echo "spice installer attempt $i failed (likely GitHub 429); retrying in 15s"
+            [ "$i" = 3 ] && exit 1
+            sleep 15
+          done
+          echo "$HOME/.spice/bin" >> "$GITHUB_PATH"
+          "$HOME/.spice/bin/spice" install \
+            || { sleep 15 && "$HOME/.spice/bin/spice" install; } \
+            || { sleep 15 && "$HOME/.spice/bin/spice" install; }
 
       - name: Install Spice (https://install.spiceai.org) (MacOS)
         if: startsWith(matrix.os, 'macos')

src/client.rs

@@ -992,34 +992,30 @@ mod tests {
         Mock::given(method("POST"))
             .and(path("/v1/queries"))
             .and(body_json(json!({ "sql": "SELECT 1" })))
-            .respond_with(
-                ResponseTemplate::new(202).set_body_json(json!({
-                    "query_id": query_id,
-                    "status": "PENDING",
-                    "status_url": format!("{}/v1/queries/{query_id}/status", server.uri()),
-                    "results_url": format!("{}/v1/queries/{query_id}/results", server.uri())
-                })),
-            )
+            .respond_with(ResponseTemplate::new(202).set_body_json(json!({
+                "query_id": query_id,
+                "status": "PENDING",
+                "status_url": format!("{}/v1/queries/{query_id}/status", server.uri()),
+                "results_url": format!("{}/v1/queries/{query_id}/results", server.uri())
+            })))
             .mount(&server)
             .await;
 
         Mock::given(method("GET"))
             .and(path("/v1/queries"))
             .and(query_param("status", "running"))
             .and(query_param("limit", "5"))
-            .respond_with(
-                ResponseTemplate::new(200).set_body_json(json!({
-                    "queries": [
-                        {
-                            "query_id": query_id,
-                            "status": "RUNNING",
-                            "created_at": "2025-01-01T00:00:00Z",
-                            "sql_preview": "SELECT 1"
-                        }
-                    ],
-                    "total_count": 1
-                })),
-            )
+            .respond_with(ResponseTemplate::new(200).set_body_json(json!({
+                "queries": [
+                    {
+                        "query_id": query_id,
+                        "status": "RUNNING",
+                        "created_at": "2025-01-01T00:00:00Z",
+                        "sql_preview": "SELECT 1"
+                    }
+                ],
+                "total_count": 1
+            })))
             .mount(&server)
             .await;
 
@@ -1034,10 +1030,8 @@ mod tests {
         Mock::given(method("GET"))
             .and(path(format!("/v1/queries/{query_id}")))
             .respond_with(
-                ResponseTemplate::new(200).set_body_json(query_manifest_response(
-                    query_id,
-                    QueryStatus::Succeeded,
-                )),
+                ResponseTemplate::new(200)
+                    .set_body_json(query_manifest_response(query_id, QueryStatus::Succeeded)),
             )
             .mount(&server)
             .await;
@@ -1078,7 +1072,10 @@ mod tests {
 
         let job = client.query("SELECT 1").await.expect("submit async query");
         assert_eq!(job.id(), query_id);
-        assert_eq!(job.status().await.expect("get query status"), QueryStatus::Running);
+        assert_eq!(
+            job.status().await.expect("get query status"),
+            QueryStatus::Running
+        );
 
         let info = job.info().await.expect("get query info");
         assert_eq!(info.query_id, query_id);