unobtanium 3.0.0

Opinioated Web search engine library with crawler and viewer companion.
Documentation 
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

use criterium::DirectMatch;
use criterium::NumberCriterium;
use criterium::rusqlite::assembler::*;
use serde::{Serialize,Deserialize};

use crate::criterium::EntityGenerationCriterium;
use crate::database::SummarySchema;
use crate::database::fields::*;
use crate::summary::DuplicateSummary;
use crate::time::UtcTimestamp;

/// Matches a [DuplicateSummary]. Best used with the database.
///
/// The [DirectMatch] on the duplicate summary can only compare the Uuid
/// for the subject and duplicate_od fields, IsNewest will always match,
/// everything else will always not match.
#[derive(Clone,Debug,Serialize,Deserialize)]
#[serde(rename_all="snake_case")]
pub enum DuplicateSummaryCriterium {
	/// Match the Subject of the duplicate summary,
	/// the entity generation that is duplicated
	Subject(EntityGenerationCriterium),
	
	/// Match the EntityGeneration the Subject is a duplicate of
	DuplicateOf(EntityGenerationCriterium),

	/// The first time the duplicate was detected
	DuplicateStatusStart(NumberCriterium<UtcTimestamp>),

	/// The time the duplicate status was confirmed to be over.
	DuplicateStatusEnd(NumberCriterium<UtcTimestamp>),
}

impl AssembleRusqliteQuery<SummarySchema, ()> for DuplicateSummaryCriterium {
	fn assemble_rusqlite_query(
		&self,
		assembly_context: &AssemblyContext,
		_context: &(),
	) -> InvertableRusqliteQuery<SummarySchema> {
	   match self {
		   Self::Subject(c) =>
				c.assemble_rusqlite_query(
					&assembly_context.prefix_with("subject_"),
					&()
				).inner_join(
					None,
					EntityGenerationField::EntityGenerationId.into(),
					Some(assembly_context.prefix()),
					DuplicateSummaryField::SubjectEntityGenerationId.into(),
				),
			Self::DuplicateOf(c) =>
				c.assemble_rusqlite_query(
					&assembly_context.prefix_with("duplicate_of_"),
					&()
				).inner_join(
					None,
					EntityGenerationField::EntityGenerationId.into(),
					Some(assembly_context.prefix()),
					DuplicateSummaryField::DuplicateOfEntityGenerationId.into()
				),
			Self::DuplicateStatusStart(c) =>
				c.assemble_query(
					assembly_context,
					&DuplicateSummaryField::DuplicateStatusStartUnixUtc.into()
				),
			Self::DuplicateStatusEnd(c) =>
				c.assemble_query(
					assembly_context,
					&DuplicateSummaryField::DuplicateStatusEndUnixUtc.into()
				),
	   } 
	}
}

impl DirectMatch<DuplicateSummary> for DuplicateSummaryCriterium {

	type Output = Option<bool>;
	
	fn criterium_match(&self, data: &DuplicateSummary) -> Option<bool> {
	    match self {
		    Self::Subject(c) =>
			    c.criterium_match(&data.subject_entity_generation),
		    Self::DuplicateOf(c) =>
			    c.criterium_match(&data.duplicate_of_entity_generation),
		    Self::DuplicateStatusStart(c) =>
			    c.criterium_match(&data.duplicate_status_start).into(),
		    Self::DuplicateStatusEnd(c) =>
			    c.criterium_match(&data.duplicate_status_end).into(),
	    }
	}
}