fix: format code and use self-hosted windows runner

- Run cargo fmt to fix formatting issues
- Use windows-64-cli self-hosted runner for faster Windows builds

Author: factorydroid

.github/workflows/ci.yml

@@ -33,34 +33,46 @@ jobs:
       - run: cargo clippy --all-targets --all-features
 
   test:
-    name: Test (${{ matrix.os }})
-    runs-on: ${{ matrix.os }}
+    name: Test (${{ matrix.name }})
+    runs-on: ${{ matrix.runner }}
     strategy:
       fail-fast: false
       matrix:
-        os: [blacksmith-32vcpu-ubuntu-2404, blacksmith-32vcpu-windows-2025, macos-latest]
+        include:
+          - name: ubuntu
+            runner: blacksmith-32vcpu-ubuntu-2404
+          - name: macos
+            runner: macos-latest
+          - name: windows
+            runner: [self-hosted, windows-64-cli]
     steps:
       - uses: actions/checkout@v4
       - uses: dtolnay/rust-toolchain@stable
       - uses: Swatinem/rust-cache@v2
         with:
-          key: ${{ matrix.os }}
+          key: ${{ matrix.name }}
       - name: Run tests
         run: cargo test --workspace --all-features
 
   build-check:
-    name: Build Check (${{ matrix.os }})
-    runs-on: ${{ matrix.os }}
+    name: Build Check (${{ matrix.name }})
+    runs-on: ${{ matrix.runner }}
     strategy:
       fail-fast: false
       matrix:
-        os: [blacksmith-32vcpu-ubuntu-2404, blacksmith-32vcpu-windows-2025, macos-latest]
+        include:
+          - name: ubuntu
+            runner: blacksmith-32vcpu-ubuntu-2404
+          - name: macos
+            runner: macos-latest
+          - name: windows
+            runner: [self-hosted, windows-64-cli]
     steps:
       - uses: actions/checkout@v4
       - uses: dtolnay/rust-toolchain@stable
       - uses: Swatinem/rust-cache@v2
         with:
-          key: ${{ matrix.os }}
+          key: ${{ matrix.name }}
       - name: Check build
         run: cargo check --workspace --all-features
 

cortex-common/src/lib.rs

@@ -21,8 +21,8 @@ pub use file_locking::{
     FileLockError, FileLockGuard, FileLockManager, FileLockResult, LockConfig, LockMode,
     acquire_lock, atomic_write, global_lock_manager, locked_read_modify_write, try_acquire_lock,
 };
-pub use model_presets::*;
 pub use http_client::create_default_client;
+pub use model_presets::*;
 
 #[cfg(feature = "cli")]
 pub use config_override::{CliConfigOverrides, ConfigOverride};

cortex-engine/src/tools/handlers/fetch_url.rs

@@ -35,9 +35,7 @@ impl FetchUrlHandler {
     /// Create a new FetchUrlHandler with default SSRF protection.
     pub fn new() -> Self {
         let ssrf_protection = SsrfProtection::new();
-        let client = ssrf_protection
-            .create_http_client()
-            .expect("HTTP client");
+        let client = ssrf_protection.create_http_client().expect("HTTP client");
 
         Self {
             ssrf_protection,
@@ -49,9 +47,7 @@ impl FetchUrlHandler {
     pub fn with_allowed_domains(domains: impl IntoIterator<Item = impl Into<String>>) -> Self {
         let config = SsrfConfig::new().allow_domains(domains);
         let ssrf_protection = SsrfProtection::with_config(config);
-        let client = ssrf_protection
-            .create_http_client()
-            .expect("HTTP client");
+        let client = ssrf_protection.create_http_client().expect("HTTP client");
 
         Self {
             ssrf_protection,
@@ -62,9 +58,7 @@ impl FetchUrlHandler {
     /// Create a new FetchUrlHandler with custom SSRF config.
     pub fn with_config(config: SsrfConfig) -> Self {
         let ssrf_protection = SsrfProtection::with_config(config);
-        let client = ssrf_protection
-            .create_http_client()
-            .expect("HTTP client");
+        let client = ssrf_protection.create_http_client().expect("HTTP client");
 
         Self {
             ssrf_protection,

cortex-mcp-client/src/client.rs

@@ -1,6 +1,6 @@
-use anyhow::Result;
-use cortex_mcp_types::{Tool, CallToolParams, CallToolResult, InitializeParams, Implementation};
 use crate::transport::Transport;
+use anyhow::Result;
+use cortex_mcp_types::{CallToolParams, CallToolResult, Implementation, InitializeParams, Tool};
 
 pub struct McpClient {
     transport: Box<dyn Transport>,

cortex-mcp-client/src/discovery.rs

@@ -1,5 +1,5 @@
 use cortex_mcp_types::Tool;
-use serde_json::{json, Value};
+use serde_json::{Value, json};
 use std::collections::HashMap;
 
 pub struct ToolDiscovery {

cortex-mcp-client/src/lib.rs

@@ -1,9 +1,9 @@
 //! MCP Client implementation for Cortex
 
 pub mod client;
-pub mod transport;
 pub mod discovery;
+pub mod transport;
 
 pub use client::McpClient;
-pub use transport::Transport;
 pub use discovery::ToolDiscovery;
+pub use transport::Transport;

cortex-mcp-client/src/transport.rs

@@ -13,9 +13,9 @@ use async_trait::async_trait;
 use cortex_common::create_default_client;
 use cortex_mcp_types::{
     CallToolParams, CallToolResult, GetPromptParams, GetPromptResult, InitializeParams,
-    InitializeResult, JsonRpcNotification, JsonRpcRequest, JsonRpcResponse,
-    ListPromptsResult, ListResourcesResult, ListToolsResult, ReadResourceParams,
-    ReadResourceResult, RequestId, methods,
+    InitializeResult, JsonRpcNotification, JsonRpcRequest, JsonRpcResponse, ListPromptsResult,
+    ListResourcesResult, ListToolsResult, ReadResourceParams, ReadResourceResult, RequestId,
+    methods,
 };
 use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};
 use tokio::process::{Child, Command};
@@ -172,7 +172,8 @@ impl StdioTransport {
                     }
                 }
                 // Try to parse as notification
-                else if let Ok(notification) = serde_json::from_str::<JsonRpcNotification>(trimmed)
+                else if let Ok(notification) =
+                    serde_json::from_str::<JsonRpcNotification>(trimmed)
                 {
                     debug!(method = %notification.method, "Received notification");
                 }
@@ -209,7 +210,11 @@ impl StdioTransport {
 
         while attempt < self.reconnect_config.max_attempts {
             attempt += 1;
-            info!(attempt, max = self.reconnect_config.max_attempts, "Attempting reconnection");
+            info!(
+                attempt,
+                max = self.reconnect_config.max_attempts,
+                "Attempting reconnection"
+            );
 
             match self.connect().await {
                 Ok(()) => {
@@ -473,7 +478,8 @@ impl HttpTransport {
             ));
         }
 
-        let json_response: JsonRpcResponse = response.json().await.context("Failed to parse response")?;
+        let json_response: JsonRpcResponse =
+            response.json().await.context("Failed to parse response")?;
         Ok(json_response)
     }
 
@@ -500,7 +506,11 @@ impl HttpTransport {
 
         while attempt < self.reconnect_config.max_attempts {
             attempt += 1;
-            info!(attempt, max = self.reconnect_config.max_attempts, "Attempting HTTP reconnection");
+            info!(
+                attempt,
+                max = self.reconnect_config.max_attempts,
+                "Attempting HTTP reconnection"
+            );
 
             match self.test_connection().await {
                 Ok(()) => {