mirror of
https://github.com/meilisearch/MeiliSearch
synced 2024-12-25 14:10:06 +01:00
107 lines
3.4 KiB
Rust
107 lines
3.4 KiB
Rust
#![no_main]
|
|
|
|
use std::collections::HashSet;
|
|
use std::io::{BufWriter, Cursor, Read, Seek, Write};
|
|
|
|
use anyhow::{bail, Result};
|
|
use arbitrary_json::ArbitraryValue;
|
|
use heed::EnvOpenOptions;
|
|
use libfuzzer_sys::fuzz_target;
|
|
use milli::documents::{DocumentBatchBuilder, DocumentBatchReader};
|
|
use milli::update::UpdateBuilder;
|
|
use milli::Index;
|
|
use serde_json::Value;
|
|
|
|
#[cfg(target_os = "linux")]
|
|
#[global_allocator]
|
|
static ALLOC: jemallocator::Jemalloc = jemallocator::Jemalloc;
|
|
|
|
/// reads json from input and write an obkv batch to writer.
|
|
pub fn read_json(input: impl Read, writer: impl Write + Seek) -> Result<usize> {
|
|
let writer = BufWriter::new(writer);
|
|
let mut builder = DocumentBatchBuilder::new(writer)?;
|
|
builder.extend_from_json(input)?;
|
|
|
|
if builder.len() == 0 {
|
|
bail!("Empty payload");
|
|
}
|
|
|
|
let count = builder.finish()?;
|
|
|
|
Ok(count)
|
|
}
|
|
|
|
fn index_documents(
|
|
index: &mut milli::Index,
|
|
documents: DocumentBatchReader<Cursor<Vec<u8>>>,
|
|
) -> Result<()> {
|
|
let update_builder = UpdateBuilder::new();
|
|
let mut wtxn = index.write_txn()?;
|
|
let builder = update_builder.index_documents(&mut wtxn, &index);
|
|
|
|
builder.execute(documents, |_| ())?;
|
|
wtxn.commit()?;
|
|
Ok(())
|
|
}
|
|
|
|
fn create_index() -> Result<milli::Index> {
|
|
let dir = tempfile::tempdir().unwrap();
|
|
let mut options = EnvOpenOptions::new();
|
|
options.map_size(10 * 1024 * 1024 * 1024); // 10 GB
|
|
options.max_readers(1);
|
|
let index = Index::new(options, dir.path())?;
|
|
|
|
let update_builder = UpdateBuilder::new();
|
|
let mut wtxn = index.write_txn().unwrap();
|
|
let mut builder = update_builder.settings(&mut wtxn, &index);
|
|
|
|
let displayed_fields =
|
|
["id", "title", "album", "artist", "genre", "country", "released", "duration"]
|
|
.iter()
|
|
.map(|s| s.to_string())
|
|
.collect();
|
|
builder.set_displayed_fields(displayed_fields);
|
|
|
|
let searchable_fields = ["title", "album", "artist"].iter().map(|s| s.to_string()).collect();
|
|
builder.set_searchable_fields(searchable_fields);
|
|
|
|
let faceted_fields: HashSet<String> =
|
|
["released-timestamp", "duration-float", "genre", "country", "artist"]
|
|
.iter()
|
|
.map(|s| s.to_string())
|
|
.collect();
|
|
builder.set_filterable_fields(faceted_fields.clone());
|
|
builder.set_sortable_fields(faceted_fields);
|
|
|
|
builder.set_distinct_field("same".to_string());
|
|
|
|
builder.execute(|_| ()).unwrap();
|
|
wtxn.commit().unwrap();
|
|
|
|
Ok(index)
|
|
}
|
|
|
|
fuzz_target!(|batches: Vec<Vec<ArbitraryValue>>| {
|
|
if let Ok(mut index) = create_index() {
|
|
for batch in batches {
|
|
let documents: Vec<Value> =
|
|
batch.into_iter().map(|value| serde_json::Value::from(value)).collect();
|
|
let json = Value::Array(documents);
|
|
let json = serde_json::to_string(&json).unwrap();
|
|
|
|
let mut documents = Cursor::new(Vec::new());
|
|
|
|
// We ignore all malformed documents
|
|
if let Ok(_) = read_json(json.as_bytes(), &mut documents) {
|
|
documents.rewind().unwrap();
|
|
let documents = DocumentBatchReader::from_reader(documents).unwrap();
|
|
// A lot of errors can come out of milli and we don't know which ones are normal or not
|
|
// so we are only going to look for the unexpected panics.
|
|
let _ = index_documents(&mut index, documents);
|
|
}
|
|
}
|
|
|
|
index.prepare_for_closing().wait();
|
|
}
|
|
});
|