{"schema":"cmsg/1","type":"fix","scope":"global","summary":"normalize return spacing for space-004 rule","intent":"enforce one blank line before explicit returns and final tail expressions","impact":"removes space-004 violations without changing runtime behavior","breaking":false,"risk":"low","refs":[]}

Author: aurexav

apps/elf-api/src/lib.rs

@@ -66,5 +66,6 @@ fn init_tracing(config: &elf_config::Config) -> color_eyre::Result<()> {
 		EnvFilter::try_new(&config.service.log_level).unwrap_or_else(|_| EnvFilter::new("info"));
 
 	tracing_subscriber::fmt().with_env_filter(filter).init();
+
 	Ok(())
 }

apps/elf-api/src/state.rs

@@ -16,6 +16,7 @@ impl AppState {
 
 		let qdrant = QdrantStore::new(&config.storage.qdrant)?;
 		let service = ElfService::new(config, db, qdrant);
+
 		Ok(Self { service: Arc::new(service) })
 	}
 }

apps/elf-eval/src/lib.rs

@@ -1072,6 +1072,7 @@ fn percentile(values: &[f64], percentile: f64) -> f64 {
 		values[lower]
 	} else {
 		let weight = pos - lower as f64;
+
 		values[lower] * (1.0 - weight) + values[upper] * weight
 	}
 }

apps/elf-worker/src/worker.rs

@@ -492,12 +492,14 @@ async fn handle_upsert(state: &WorkerState, job: &IndexingOutboxEntry) -> Result
 	let note = fetch_note(&state.db, job.note_id).await?;
 	let Some(note) = note else {
 		tracing::info!(note_id = %job.note_id, "Note missing for outbox job. Marking done.");
+
 		return Ok(());
 	};
 	let now = OffsetDateTime::now_utc();
 
 	if !note_is_active(&note, now) {
 		tracing::info!(note_id = %job.note_id, "Note inactive or expired. Skipping index.");
+
 		return Ok(());
 	}
 

packages/elf-chunking/src/lib.rs

@@ -72,6 +72,7 @@ pub fn split_text(text: &str, cfg: &ChunkingConfig, tokenizer: &Tokenizer) -> Ve
 			text: current,
 		});
 	}
+
 	chunks
 }
 

packages/elf-domain/src/cjk.rs

@@ -1,6 +1,7 @@
 pub fn contains_cjk(input: &str) -> bool {
 	input.chars().any(|c| {
 		let code = c as u32;
+
 		matches!(
 			code,
 			0x3000..=0x303F

packages/elf-providers/src/embedding.rs

@@ -11,6 +11,7 @@ pub async fn embed(
 ) -> Result<Vec<Vec<f32>>> {
 	if cfg.provider_id == "local" {
 		let dim = cfg.dimensions as usize;
+
 		return Ok(texts.iter().map(|text| local_embed(dim, text)).collect());
 	}
 
@@ -63,6 +64,7 @@ fn local_embed(dim: usize, text: &str) -> Vec<f32> {
 	}
 
 	l2_normalize(&mut vec);
+
 	vec
 }
 
@@ -76,6 +78,7 @@ fn normalize_ascii_alnum_lowercase(text: &str) -> String {
 			normalized.push(' ');
 		}
 	}
+
 	normalized
 }
 

packages/elf-providers/src/lib.rs

@@ -23,5 +23,6 @@ pub fn auth_headers(api_key: &str, default_headers: &Map<String, Value>) -> Resu
 
 		headers.insert(HeaderName::from_bytes(key.as_bytes())?, raw.parse()?);
 	}
+
 	Ok(headers)
 }

packages/elf-service/src/add_note.rs

@@ -286,6 +286,7 @@ VALUES (
 							Some(existing_expires_at) => {
 								let existing_ttl =
 									(existing_expires_at - existing.updated_at).whole_days() as i64;
+
 								existing_ttl == ttl_days
 							},
 							None => false,
@@ -459,6 +460,7 @@ fn find_cjk_path(value: &Value, path: &str) -> Option<String> {
 					return Some(found);
 				}
 			}
+
 			None
 		},
 		Value::Object(map) => {
@@ -469,6 +471,7 @@ fn find_cjk_path(value: &Value, path: &str) -> Option<String> {
 					return Some(found);
 				}
 			}
+
 			None
 		},
 		_ => None,

packages/elf-service/src/delete.rs

@@ -65,6 +65,7 @@ FOR UPDATE",
 		}
 		if note.status == "deleted" {
 			tx.commit().await?;
+
 			return Ok(DeleteResponse { note_id: note.note_id, op: NoteOp::None });
 		}