summa 0.8.8

Fast full-text search server
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use crate::errors::{Error, SummaResult};
use crate::search_engine::scorers::SegmentEvalScorer;
use fasteval2::Evaler;
use std::collections::HashSet;
use tantivy::schema::Schema as Fields;
use tantivy::SegmentReader;

lazy_static! {
    static ref RESERVED_WORDS: HashSet<&'static str> = HashSet::from(["now", "original_score", "fastsigm"]);
}

/// Instantiates `SegmentEvalScorer` for each segment
pub struct EvalScorer {
    eval_expr: String,
    fields: Fields,
    parser: fasteval2::Parser,
    var_names: Vec<String>,
}

impl EvalScorer {
    pub fn new(eval_expr: &str, fields: &Fields) -> SummaResult<EvalScorer> {
        let parser = fasteval2::Parser::new();

        // Create `Slab` for extracting variable names
        let mut slab = fasteval2::Slab::new();
        let parsed = parser.parse(eval_expr, &mut slab.ps)?.from(&slab.ps);
        let mut var_names = vec![];
        for var_name in parsed.var_names(&slab).iter().filter(|var_name| !RESERVED_WORDS.contains((*var_name).as_str())) {
            fields.get_field(var_name).ok_or_else(|| Error::FieldDoesNotExist(var_name.to_owned()))?;
            var_names.push(var_name.to_owned());
        }

        Ok(EvalScorer {
            eval_expr: eval_expr.to_owned(),
            fields: fields.clone(),
            parser,
            var_names,
        })
    }

    pub fn get_for_segment_reader(&self, segment_reader: &SegmentReader) -> SummaResult<SegmentEvalScorer> {
        SegmentEvalScorer::for_segment(segment_reader, &self.fields, &self.parser, &self.eval_expr, &self.var_names)
    }
}