refactor: finalize readability cleanup

Author: rexleimo

CHANGELOG.md

@@ -4,6 +4,8 @@ All notable user-visible changes are documented in this file.
 
 ## [Unreleased]
 
+## [1.2.0] - 2026-03-07
+
 ### Added
 
 - Versioning policy documented in `docs/versioning-and-release.md`.
@@ -20,6 +22,7 @@ All notable user-visible changes are documented in this file.
 
 ### Changed
 
+- Internal readability refactor: decomposed `rexos-tools` browser/defs/dispatch/ops/patch internals into smaller modules and aligned dependent crates/tests with the new layout.
 - Competitor-analysis posts were moved out of `docs-site/` into `docs/internal/competitive/`, and public blog/homepage references to OpenFang/OpenClaw were removed.
 - `loopforge release check` now fails when public docs contain competitor-analysis terms or when semver tags on HEAD do not match the requested release tag.
 

Cargo.lock

@@ -14,7 +14,7 @@ members = [
 ]
 
 [workspace.package]
-version = "1.1.0"
+version = "1.2.0"
 edition = "2021"
 license = "MIT"
 rust-version = "1.75"

Cargo.toml

@@ -1,11 +1,11 @@
 use std::collections::BTreeMap;
 use std::path::{Path, PathBuf};
 
-use anyhow::{Context, bail};
+use anyhow::{bail, Context};
 use serde::Serialize;
 
 use rexos::paths::RexosPaths;
-use rexos_skills::loader::{DiscoveredSkill, SkillSource, discover_skills};
+use rexos_skills::loader::{discover_skills, DiscoveredSkill, SkillSource};
 use rexos_skills::manifest::parse_manifest;
 
 #[derive(Debug, Clone, Serialize)]
@@ -41,7 +41,9 @@ pub struct SkillsDoctorReport {
     pub issues: Vec<SkillsDoctorIssue>,
 }
 
-pub fn discover_workspace_skills(workspace_root: &Path) -> anyhow::Result<BTreeMap<String, DiscoveredSkill>> {
+pub fn discover_workspace_skills(
+    workspace_root: &Path,
+) -> anyhow::Result<BTreeMap<String, DiscoveredSkill>> {
     let home_skills = home_skills_root()?;
     discover_skills(workspace_root, &home_skills)
 }

crates/loopforge-cli/src/skills.rs

@@ -126,9 +126,7 @@ pub async fn serve(addr: SocketAddr) -> anyhow::Result<()> {
     let listener = tokio::net::TcpListener::bind(addr)
         .await
         .with_context(|| format!("bind {addr}"))?;
-    axum::serve(listener, app())
-        .await
-        .context("serve http")?;
+    axum::serve(listener, app()).await.context("serve http")?;
     Ok(())
 }
 
@@ -185,7 +183,10 @@ async fn enforce_auth_and_rate_limit(
     next.run(request).await
 }
 
-async fn add_security_headers(request: axum::http::Request<axum::body::Body>, next: Next) -> Response {
+async fn add_security_headers(
+    request: axum::http::Request<axum::body::Body>,
+    next: Next,
+) -> Response {
     let mut response = next.run(request).await;
     let headers = response.headers_mut();
     headers.insert(

crates/rexos-daemon/src/lib.rs

@@ -557,7 +557,10 @@ fn run_init_script_capture(workspace_dir: &Path) -> anyhow::Result<String> {
     Ok(combined)
 }
 
-fn run_powershell_script_output(workspace_dir: &Path, script: &str) -> anyhow::Result<std::process::Output> {
+fn run_powershell_script_output(
+    workspace_dir: &Path,
+    script: &str,
+) -> anyhow::Result<std::process::Output> {
     let args = [
         "-NoProfile",
         "-NonInteractive",

crates/rexos-harness/src/lib.rs

@@ -1,4 +1,3 @@
 pub mod config;
 pub mod paths;
 pub mod router;
-

crates/rexos-kernel/src/lib.rs

@@ -65,8 +65,14 @@ mod tests {
         let workspace = Path::new("/tmp/workspace");
         let home = Path::new("/tmp/home");
 
-        assert_eq!(paths.config_path(), PathBuf::from("/tmp/home/.loopforge/config.toml"));
-        assert_eq!(paths.db_path(), PathBuf::from("/tmp/home/.loopforge/loopforge.db"));
+        assert_eq!(
+            paths.config_path(),
+            PathBuf::from("/tmp/home/.loopforge/config.toml")
+        );
+        assert_eq!(
+            paths.db_path(),
+            PathBuf::from("/tmp/home/.loopforge/loopforge.db")
+        );
         assert_eq!(
             RexosPaths::workspace_skills_dir(workspace),
             PathBuf::from("/tmp/workspace/.loopforge/skills")

crates/rexos-kernel/src/paths.rs

@@ -142,14 +142,26 @@ fn map_messages(messages: &[ChatMessage]) -> anyhow::Result<(String, Vec<Anthrop
     for m in messages {
         match m.role {
             Role::System => {
-                if let Some(s) = m.content.as_ref().map(|s| s.trim()).filter(|s| !s.is_empty()) {
+                if let Some(s) = m
+                    .content
+                    .as_ref()
+                    .map(|s| s.trim())
+                    .filter(|s| !s.is_empty())
+                {
                     system_parts.push(s.to_string());
                 }
             }
             Role::User => {
                 let mut blocks = Vec::new();
-                if let Some(s) = m.content.as_ref().map(|s| s.trim()).filter(|s| !s.is_empty()) {
-                    blocks.push(AnthropicContentBlock::Text { text: s.to_string() });
+                if let Some(s) = m
+                    .content
+                    .as_ref()
+                    .map(|s| s.trim())
+                    .filter(|s| !s.is_empty())
+                {
+                    blocks.push(AnthropicContentBlock::Text {
+                        text: s.to_string(),
+                    });
                 }
                 if !blocks.is_empty() {
                     out.push(AnthropicMessage {
@@ -160,14 +172,22 @@ fn map_messages(messages: &[ChatMessage]) -> anyhow::Result<(String, Vec<Anthrop
             }
             Role::Assistant => {
                 let mut blocks = Vec::new();
-                if let Some(s) = m.content.as_ref().map(|s| s.trim()).filter(|s| !s.is_empty()) {
-                    blocks.push(AnthropicContentBlock::Text { text: s.to_string() });
+                if let Some(s) = m
+                    .content
+                    .as_ref()
+                    .map(|s| s.trim())
+                    .filter(|s| !s.is_empty())
+                {
+                    blocks.push(AnthropicContentBlock::Text {
+                        text: s.to_string(),
+                    });
                 }
 
                 if let Some(calls) = &m.tool_calls {
                     for c in calls {
-                        let input = serde_json::from_str::<serde_json::Value>(&c.function.arguments)
-                            .unwrap_or(serde_json::Value::Null);
+                        let input =
+                            serde_json::from_str::<serde_json::Value>(&c.function.arguments)
+                                .unwrap_or(serde_json::Value::Null);
                         blocks.push(AnthropicContentBlock::ToolUse {
                             id: c.id.clone(),
                             name: c.function.name.clone(),

crates/rexos-llm/src/anthropic.rs

@@ -43,10 +43,7 @@ impl LlmDriver for DashscopeDriver {
                 },
             };
 
-            let url = format!(
-                "{}/services/aigc/text-generation/generation",
-                self.base_url
-            );
+            let url = format!("{}/services/aigc/text-generation/generation", self.base_url);
             let mut http_req = self.http.post(url).json(&dash_req);
             if let Some(key) = &self.api_key {
                 if !key.trim().is_empty() {
@@ -137,7 +134,11 @@ fn map_messages(messages: &[ChatMessage]) -> Vec<DashscopeMessage> {
 }
 
 fn clean_message(mut m: ChatMessage) -> ChatMessage {
-    if m.content.as_ref().map(|s| s.trim().is_empty()).unwrap_or(false) {
+    if m.content
+        .as_ref()
+        .map(|s| s.trim().is_empty())
+        .unwrap_or(false)
+    {
         m.content = None;
     }
     if m.tool_calls.as_ref().map(|c| c.is_empty()).unwrap_or(false) {