mod helpers;
use helpers::extract_bytes_document;
use xberg::core::config::ExtractionConfig;
#[tokio::test]
async fn test_csv_preserves_header_value_association() {
let config = ExtractionConfig::default();
let csv = b"Name,Age,City\nAlice,30,NYC\nBob,25,LA\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert!(result.content.contains("Name: Alice"));
assert!(result.content.contains("Age: 30"));
assert!(result.content.contains("City: NYC"));
assert!(result.content.contains("Name: Bob"));
assert!(result.content.contains("Age: 25"));
assert!(result.content.contains("City: LA"));
}
#[tokio::test]
async fn test_csv_row_grouping() {
let config = ExtractionConfig::default();
let csv = b"Name,Score\nAlice,95\nBob,88\nCarol,72\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert!(result.content.contains("Row 1:"));
assert!(result.content.contains("Row 2:"));
assert!(result.content.contains("Row 3:"));
assert!(
result.content.contains("\n\nRow 2:"),
"Rows should be separated by blank lines"
);
}
#[tokio::test]
async fn test_csv_skips_empty_values() {
let config = ExtractionConfig::default();
let csv = b"Name,Age,City\nAlice,,NYC\nBob,25,LA\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert!(result.content.contains("Name: Alice"));
assert!(result.content.contains("City: NYC"));
let row1 = result.content.split("\n\n").next().unwrap_or("");
assert!(!row1.contains("Age:"), "Empty cells should be skipped");
}
#[tokio::test]
async fn test_csv_tables_field_unchanged() {
let config = ExtractionConfig::default();
let csv = b"Name,Age\nAlice,30\nBob,25\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert_eq!(result.tables.len(), 1);
assert_eq!(result.tables[0].cells.len(), 3);
assert_eq!(result.tables[0].cells[0], vec!["Name", "Age"]);
assert!(!result.tables[0].markdown.is_empty());
}
#[tokio::test]
async fn test_csv_short_row_no_panic() {
let config = ExtractionConfig::default();
let csv = b"Name,Age,City\nAlice,30\nBob,25,LA\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert!(result.content.contains("Name: Alice"));
assert!(result.content.contains("Age: 30"));
let row1 = result.content.split("\n\n").next().unwrap_or("");
assert!(!row1.contains("City:"));
}
#[tokio::test]
async fn test_csv_all_empty_data_rows() {
let config = ExtractionConfig::default();
let csv = b"Name,Age\n,,\nAlice,30\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert!(result.content.contains("Name: Alice"));
}
#[tokio::test]
async fn test_csv_no_header_fallback() {
let config = ExtractionConfig::default();
let csv = b"Alice,NYC,Engineer\nBob,LA,Designer\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert!(
!result.content.contains("Row 1:"),
"No header detected — should not label rows"
);
assert!(result.content.contains("Alice"));
assert!(result.content.contains("Bob"));
}
#[tokio::test]
async fn test_csv_header_only() {
let config = ExtractionConfig::default();
let csv = b"Name,Age,City\n";
let result = extract_bytes_document(csv, "text/csv", &config).await.unwrap();
assert!(!result.content.is_empty());
assert!(result.content.contains("Name"));
}
#[tokio::test]
async fn test_csv_real_file_header_value() {
let path = std::path::Path::new(env!("CARGO_MANIFEST_DIR")).join("../../test_documents/csv/data_table.csv");
if !path.exists() {
return;
}
let content = std::fs::read(&path).unwrap();
let config = ExtractionConfig::default();
let result = extract_bytes_document(&content, "text/csv", &config).await.unwrap();
assert!(result.content.contains("Name: Alice Johnson"));
assert!(result.content.contains("Department: Engineering"));
assert!(result.content.contains("Row 1:"));
}