jedarden/miroir
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Phase 1 (miroir-cdo): Fix index stats response parsing

Browse source 
Fix response body parsing in get_index_stats to properly parse
JSON response from scatter nodes. Previously was trying to
access JSON fields directly on Vec<u8> bytes.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
Bead-Id: miroir-cdo
This commit is contained in:
jedarden 2026-05-09 11:19:40 -04:00
parent 6cf50fec1f
commit bd0818405e
1 changed files with 14 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
crates/miroir-proxy/src/routes/indexes.rs
View file

@ -291,19 +291,22 @@ async fn get_index_stats(
{
if let Some(resp) = result.responses.first() {
if resp.status == 200 {
// Extract stats
if let Some(docs) = resp.body.get("numberOfDocuments").and_then(|v| v.as_u64())
{
// Use max document count across replicas (more accurate)
total_documents = total_documents.max(docs);
}
// Parse response body as JSON
if let Ok(json) = serde_json::from_slice::<Value>(&resp.body) {
// Extract stats
if let Some(docs) = json.get("numberOfDocuments").and_then(|v| v.as_u64())
{
// Use max document count across replicas (more accurate)
total_documents = total_documents.max(docs);
}
if let Some(indexing) = resp.body.get("isIndexing").and_then(|v| v.as_bool()) {
is_indexing = is_indexing || indexing;
}
if let Some(indexing) = json.get("isIndexing").and_then(|v| v.as_bool()) {
is_indexing = is_indexing || indexing;
}
if let Some(fields) = resp.body.get("fieldDistribution") {
field_distributions.push(fields.clone());
if let Some(fields) = json.get("fieldDistribution") {
field_distributions.push(fields.clone());
}
}
}
}