Merge remote-tracking branch 'origin/main'

Author: Test User

CHANGELOG.md

@@ -9,6 +9,15 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+- **`QualityScore` type** added to `IndexedDocument` and `Document` in `terraphim_types`, carrying `logic_score`, `structure_score`, and `composite` (NaN-guarded) fields for downstream ranking (Refs #547)
+- **Rustdoc on `terraphim_server`** added `//!` crate-level doc, struct/enum/field docs and function doc-comments across `src/lib.rs`, `src/error.rs`, `src/api.rs`, and all `src/workflows/` sub-modules -- `RUSTDOCFLAGS="-W missing-docs" cargo doc --no-deps` now produces zero warnings
+- **Rustdoc on core public types** added doc comments to `ServiceError`, `TerraphimService`, middleware `Error`, rolegraph `Error`, `split_paragraphs`, `DocumentType`, `RouteDirective`, `MarkdownDirectives`, `Edge`, `ChatMessage`, and `Priority` across four crates (Refs #547)
+- **Orchestrator webhook fix** resolves project from repo for unqualified `@adf:` mentions
+- **Provider probe timeout** increased from 60s to 120s for reliability
+- **Orchestrator fallback** triggers fallback provider on `rate_limit` exit when KG routing fails
+- **ADF config validation** added for `grace_period`, `max_cpu`, and `probe_ttl`
+- **Build-runner-llm** agent with Graph-first System, cost tracking, and BUILD.md build sequences
+- **Rate-limit backoff** enabled by default in orchestrator; `RATE_LIMIT_BACKOFF_ENABLED` env var wired to systemd service
 - **Intra-doc link fixes** resolved broken rustdoc links and unclosed HTML tag warnings across `terraphim_orchestrator`, `terraphim_types`, `terraphim_tracker` — cargo doc now produces zero warnings on all core crates
 - **Unique tempdir** in `test_tool_index_save_and_load` to eliminate cross-run state pollution (Refs #1340)
 - **Module-level rustdoc** added to `terraphim_dsm` and `terraphim_github_runner_server` — the final two binary crates lacking a crate-level `//!` comment
@@ -42,6 +51,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Fixed
 
+- **`min_quality` threshold clamped** to `[0.0, 1.0]` in `apply_min_quality_filter`; negative values are now treated as zero rather than silently excluding all documents (Refs #1459)
+- **Unit tests for `apply_min_quality_filter`** cover zero, midpoint, boundary, and negative-threshold cases to prevent regression (Refs #1459)
 - **World-readable sensitive config files** now emit tracing error/warn at load time via `warn_if_world_readable()` in orchestrator config and all `conf.d` include files (Refs #826)- **RUSTSEC-2026-0049** eliminated by switching serenity to native-tls (Refs #418)
 - **Spec gaps** addressed and resolved across ADF orchestrator templates (Refs #1040)
 - **Global concurrency limits** enforced in orchestrator to prevent task/memory exhaustion (Refs #664)

crates/haystack_jmap/src/lib.rs

@@ -421,6 +421,7 @@ pub fn email_to_document(email: &Email) -> Document {
         synonyms: None,
         route: None,
         priority: None,
+        quality_score: None,
     }
 }
 

crates/terraphim-markdown-parser/src/lib.rs

@@ -204,6 +204,7 @@ pub fn blocks_to_documents(source_id: &str, normalized: &NormalizedMarkdown) ->
                 synonyms: None,
                 route: None,
                 priority: None,
+                quality_score: None,
             }
         })
         .collect()

crates/terraphim_agent/src/main.rs

@@ -716,6 +716,9 @@ enum Command {
         /// Include pinned KG entries in results
         #[arg(long, default_value_t = false)]
         include_pinned: bool,
+        /// Minimum composite quality score (0.0-1.0). Excludes documents below this threshold.
+        #[arg(long)]
+        min_quality: Option<f64>,
     },
     /// Manage roles (list, select)
     Roles {
@@ -2048,6 +2051,7 @@ async fn run_offline_command(
             limit,
             fail_on_empty,
             include_pinned,
+            min_quality,
         } => {
             let (role_name, auto) = service
                 .resolve_or_auto_route(role.as_deref(), &query)
@@ -2091,14 +2095,24 @@ async fn run_offline_command(
                     include_pinned,
                     role: Some(role_name.clone()),
                     layer: Layer::default(),
+                    min_quality,
                 };
 
                 service.search_with_query(&search_query).await?
             } else {
-                // Single term query (backward compatibility)
-                service
-                    .search_with_role(&query, &role_name, Some(limit))
-                    .await?
+                // Single term query
+                let search_query = SearchQuery {
+                    search_term: NormalizedTermValue::from(query.as_str()),
+                    search_terms: None,
+                    operator: None,
+                    skip: Some(0),
+                    limit: Some(limit),
+                    include_pinned,
+                    role: Some(role_name.clone()),
+                    layer: Layer::default(),
+                    min_quality,
+                };
+                service.search_with_query(&search_query).await?
             };
 
             let results_count = results.len();
@@ -4095,6 +4109,7 @@ async fn run_server_command(
             limit,
             fail_on_empty: _,
             include_pinned,
+            min_quality,
         } => {
             // Get selected role from server if not specified
             let role_name = if let Some(role) = role {
@@ -4121,6 +4136,7 @@ async fn run_server_command(
                     role: Some(role_name),
                     layer: Layer::default(),
                     include_pinned,
+                    min_quality,
                 }
             } else {
                 // Single term query (backward compatibility)
@@ -4133,6 +4149,7 @@ async fn run_server_command(
                     role: Some(role_name),
                     layer: Layer::default(),
                     include_pinned,
+                    min_quality,
                 }
             };
 
@@ -5124,6 +5141,7 @@ fn ui_loop(
                                         role: Some(RoleName::new(&role)),
                                         layer: Layer::default(),
                                         include_pinned: false,
+                                        min_quality: None,
                                     };
                                     backend.search(&q).await
                                 }) {

crates/terraphim_agent/src/repl/handler.rs

@@ -540,6 +540,7 @@ impl ReplHandler {
                     role: role_name,
                     layer: Layer::default(),
                     include_pinned: false,
+                    min_quality: None,
                 };
 
                 match api_client.search(&search_query).await {
@@ -891,6 +892,7 @@ impl ReplHandler {
                     synonyms: None,
                     route: None,
                     priority: None,
+                    quality_score: None,
                 };
 
                 match api_client

crates/terraphim_agent/src/service.rs

@@ -324,13 +324,16 @@ impl TuiService {
             role: Some(role.clone()),
             layer: Layer::default(),
             include_pinned: false,
+            min_quality: None,
         };
 
         let mut service = self.service.lock().await;
         Ok(service.search(&query).await?)
     }
 
     /// Search documents using a complete SearchQuery (supports logical operators)
+    ///
+    /// Quality filtering via `query.min_quality` is applied by the underlying service.
     pub async fn search_with_query(&self, query: &SearchQuery) -> Result<Vec<Document>> {
         let mut service = self.service.lock().await;
         Ok(service.search(query).await?)

crates/terraphim_agent/src/shared_learning/store.rs

@@ -1368,6 +1368,7 @@ mod tests {
                 synonyms: None,
                 route: None,
                 priority: None,
+                quality_score: None,
             };
             let learning_id = "learning-graph-test";
             graph.insert_document(learning_id, doc);

crates/terraphim_agent/tests/cross_mode_consistency_test.rs

@@ -253,6 +253,7 @@ async fn search_via_server(
         role: Some(RoleName::new(role)),
         layer: Layer::default(),
         include_pinned: false,
+        min_quality: None,
     };
 
     let response = client.search(&search_query).await?;

crates/terraphim_agent/tests/error_handling_test.rs

@@ -94,6 +94,7 @@ async fn test_malformed_server_response() {
         role: Some(RoleName::new("Default")),
         layer: Layer::default(),
         include_pinned: false,
+        min_quality: None,
     };
 
     let result = client.search(&extreme_query).await;
@@ -141,6 +142,7 @@ async fn test_invalid_role_handling() {
         role: Some(RoleName::new("CompleteLyInvalidRoleName12345")),
         layer: Layer::default(),
         include_pinned: false,
+        min_quality: None,
     };
 
     let result = client.search(&invalid_query).await;
@@ -206,6 +208,7 @@ async fn test_empty_and_special_character_queries() {
             role: Some(RoleName::new("Default")),
             layer: Layer::default(),
             include_pinned: false,
+            min_quality: None,
         };
 
         let result = client.search(&search_query).await;
@@ -261,6 +264,7 @@ async fn test_concurrent_request_handling() {
                 role: Some(RoleName::new("Default")),
                 layer: Layer::default(),
                 include_pinned: false,
+                min_quality: None,
             };
             client_clone.search(&query).await
         });
@@ -371,6 +375,7 @@ async fn test_summarization_error_handling() {
         synonyms: None,
         route: None,
         priority: None,
+        quality_score: None,
     };
 
     let result = client
@@ -527,6 +532,7 @@ async fn test_graceful_degradation() {
                     role: Some(RoleName::new("Default")),
                     layer: Layer::default(),
                     include_pinned: false,
+                    min_quality: None,
                 };
                 client
                     .search(&query)

crates/terraphim_agent/tests/integration_test.rs

@@ -60,6 +60,7 @@ async fn test_api_client_search() {
         role: Some(RoleName::new("Terraphim Engineer")),
         layer: Layer::default(),
         include_pinned: false,
+        min_quality: None,
     };
 
     let result = client.search(&query).await;
@@ -212,6 +213,7 @@ async fn test_search_with_different_roles() {
             role: Some(RoleName::new(role_name)),
             layer: Layer::default(),
             include_pinned: false,
+            min_quality: None,
         };
 
         let result = client.search(&query).await;
@@ -255,6 +257,7 @@ async fn test_search_pagination() {
         role: Some(RoleName::new("Default")),
         layer: Layer::default(),
         include_pinned: false,
+        min_quality: None,
     };
 
     let result1 = client.search(&query1).await;
@@ -270,6 +273,7 @@ async fn test_search_pagination() {
         role: Some(RoleName::new("Default")),
         layer: Layer::default(),
         include_pinned: false,
+        min_quality: None,
     };
 
     let result2 = client.search(&query2).await;
@@ -464,6 +468,7 @@ async fn test_api_error_handling() {
         role: Some(RoleName::new("NonExistentRole")),
         layer: Layer::default(),
         include_pinned: false,
+        min_quality: None,
     };
 
     let result = client.search(&query).await;