MoreThanText/morethantext
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Moved update tests to client.
Some checks failed
Gitea Actions Demo / Explore-Gitea-Actions (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Jeff Baskin
2026-03-25 11:15:31 -04:00
parent e95f5220b3
commit 6a06672697
1 changed files with 34 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
tests/update_test.rs
View File

@@ -14,6 +14,7 @@ fn is_it_possible_to_update_nothing() {
let outside: i128 = (count + 2).try_into().unwrap(); let outside: i128 = (count + 2).try_into().unwrap();
let (test_env, test_doc) = setup_range(count); let (test_env, test_doc) = setup_range(count);
let mut mtt = test_env.get_morethantext(); let mut mtt = test_env.get_morethantext();
let client = mtt.client();
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
update.add_field(test_doc.get_field_name(0), 20); update.add_field(test_doc.get_field_name(0), 20);
let mut calc = Calculation::new(Operand::Equal); let mut calc = Calculation::new(Operand::Equal);
@@ -21,15 +22,16 @@ fn is_it_possible_to_update_nothing() {
calc.add_value(CalcValue::Existing(FieldType::Integer)) calc.add_value(CalcValue::Existing(FieldType::Integer))
.unwrap(); .unwrap();
update.get_query_mut().add(test_doc.get_field_name(0), calc); update.get_query_mut().add(test_doc.get_field_name(0), calc);
let result = mtt.records(update).unwrap(); let result = client.records(update).unwrap();
assert_eq!(result.len(), 0); assert_eq!(result.len(), 0);
} }
#[test] #[test]
fn does_it_update_information() { fn does_it_update_information() {
let mut mtt = MoreThanText::new(); let mut mtt = MoreThanText::new();
let client = mtt.client();
let test_doc = TestDocument::new(vec![FieldType::Uuid, FieldType::StaticString]); let test_doc = TestDocument::new(vec![FieldType::Uuid, FieldType::StaticString]);
mtt.create_document(test_doc.get_docdef()); client.create_document(test_doc.get_docdef());
let field0 = Uuid::new_v4(); let field0 = Uuid::new_v4();
let field1 = "new"; let field1 = "new";
let mut input: Vec<Field> = Vec::new(); let mut input: Vec<Field> = Vec::new();
@@ -52,8 +54,8 @@ fn does_it_update_information() {
); );
assert_eq!(rec.get(test_doc.get_field_name(1)).unwrap(), field1.into()); assert_eq!(rec.get(test_doc.get_field_name(1)).unwrap(), field1.into());
}; };
tester(mtt.records(update).unwrap()); tester(client.records(update).unwrap());
tester(mtt.records(Query::new(test_doc.get_doc_name())).unwrap()); tester(client.records(Query::new(test_doc.get_doc_name())).unwrap());
} }
#[test] #[test]
@@ -63,6 +65,7 @@ fn are_the_updates_limited_to_the_queried() {
let changed = 20; let changed = 20;
let (test_env, test_doc) = setup_range(count); let (test_env, test_doc) = setup_range(count);
let mut mtt = test_env.get_morethantext(); let mut mtt = test_env.get_morethantext();
let client = mtt.client();
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
update.add_field(test_doc.get_field_name(0), changed.clone()); update.add_field(test_doc.get_field_name(0), changed.clone());
let mut calc = Calculation::new(Operand::Equal); let mut calc = Calculation::new(Operand::Equal);
@@ -70,7 +73,7 @@ fn are_the_updates_limited_to_the_queried() {
calc.add_value(CalcValue::Existing(FieldType::Integer)) calc.add_value(CalcValue::Existing(FieldType::Integer))
.unwrap(); .unwrap();
update.get_query_mut().add(test_doc.get_field_name(0), calc); update.get_query_mut().add(test_doc.get_field_name(0), calc);
let result = mtt.records(update).unwrap(); let result = client.records(update).unwrap();
assert_eq!(result.len(), 1); assert_eq!(result.len(), 1);
let rec = result.iter().last().unwrap(); let rec = result.iter().last().unwrap();
assert_eq!(rec.get(test_doc.get_field_name(0)).unwrap(), changed.into()); assert_eq!(rec.get(test_doc.get_field_name(0)).unwrap(), changed.into());
@@ -78,7 +81,7 @@ fn are_the_updates_limited_to_the_queried() {
expected.insert(0.into()); expected.insert(0.into());
expected.insert(2.into()); expected.insert(2.into());
expected.insert(20.into()); expected.insert(20.into());
let docs = mtt.records(Query::new(test_doc.get_doc_name())).unwrap(); let docs = client.records(Query::new(test_doc.get_doc_name())).unwrap();
for doc_data in docs.iter() { for doc_data in docs.iter() {
let id = doc_data.get(test_doc.get_field_name(0)).unwrap(); let id = doc_data.get(test_doc.get_field_name(0)).unwrap();
expected.remove(&id); expected.remove(&id);
@@ -98,6 +101,7 @@ fn can_multiple_documents_be_update() {
let choice = 1; let choice = 1;
let (test_env, test_doc) = setup_range(count); let (test_env, test_doc) = setup_range(count);
let mut mtt = test_env.get_morethantext(); let mut mtt = test_env.get_morethantext();
let client = mtt.client();
let mut add_up = Calculation::new(Operand::Add); let mut add_up = Calculation::new(Operand::Add);
add_up add_up
.add_value(CalcValue::Existing(FieldType::Integer)) .add_value(CalcValue::Existing(FieldType::Integer))
@@ -110,7 +114,7 @@ fn can_multiple_documents_be_update() {
calc.add_value(CalcValue::Existing(FieldType::Integer)) calc.add_value(CalcValue::Existing(FieldType::Integer))
.unwrap(); .unwrap();
update.get_query_mut().add(test_doc.get_field_name(0), calc); update.get_query_mut().add(test_doc.get_field_name(0), calc);
let result = mtt.records(update).unwrap(); let result = client.records(update).unwrap();
assert_eq!(result.len(), 2); assert_eq!(result.len(), 2);
for rec in result.iter() { for rec in result.iter() {
assert!(rec.get(test_doc.get_field_name(0)).unwrap() > 10.into()); assert!(rec.get(test_doc.get_field_name(0)).unwrap() > 10.into());
@@ -119,7 +123,7 @@ fn can_multiple_documents_be_update() {
expected.insert(2.into()); expected.insert(2.into());
expected.insert(20.into()); expected.insert(20.into());
expected.insert(21.into()); expected.insert(21.into());
let docs = mtt.records(Query::new(test_doc.get_doc_name())).unwrap(); let docs = client.records(Query::new(test_doc.get_doc_name())).unwrap();
for doc_data in docs.iter() { for doc_data in docs.iter() {
let id = doc_data.get(test_doc.get_field_name(0)).unwrap(); let id = doc_data.get(test_doc.get_field_name(0)).unwrap();
expected.remove(&id); expected.remove(&id);
@@ -137,6 +141,7 @@ fn can_multiple_documents_be_update() {
fn does_update_error_on_a_bad_query() { fn does_update_error_on_a_bad_query() {
let (test_env, test_doc) = setup_range(1); let (test_env, test_doc) = setup_range(1);
let mut mtt = test_env.get_morethantext(); let mut mtt = test_env.get_morethantext();
let client = mtt.client();
let bad_name = Name::japanese("正しくない"); let bad_name = Name::japanese("正しくない");
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
let mut qry_calc = Calculation::new(Operand::Equal); let mut qry_calc = Calculation::new(Operand::Equal);
@@ -149,7 +154,7 @@ fn does_update_error_on_a_bad_query() {
let mut expected = MTTError::new(ErrorID::NameNotFound(bad_name.clone().into())); let mut expected = MTTError::new(ErrorID::NameNotFound(bad_name.clone().into()));
expected.add_parent(ErrorID::Field(bad_name.into())); expected.add_parent(ErrorID::Field(bad_name.into()));
expected.add_parent(ErrorID::Document(test_doc.get_doc_name().into())); expected.add_parent(ErrorID::Document(test_doc.get_doc_name().into()));
let result = mtt.records(update).unwrap_err(); let result = client.records(update).unwrap_err();
assert_eq!(result.to_string(), expected.to_string()); assert_eq!(result.to_string(), expected.to_string());
} }
@@ -157,6 +162,7 @@ fn does_update_error_on_a_bad_query() {
fn does_update_error_on_a_bad_field_name() { fn does_update_error_on_a_bad_field_name() {
let (test_env, test_doc) = setup_range(1); let (test_env, test_doc) = setup_range(1);
let mut mtt = test_env.get_morethantext(); let mut mtt = test_env.get_morethantext();
let client = mtt.client();
let bad_name = Name::japanese("正しくない"); let bad_name = Name::japanese("正しくない");
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
let mut qry_calc = Calculation::new(Operand::Equal); let mut qry_calc = Calculation::new(Operand::Equal);
@@ -171,7 +177,7 @@ fn does_update_error_on_a_bad_field_name() {
let mut expected = MTTError::new(ErrorID::NameNotFound(bad_name.clone().into())); let mut expected = MTTError::new(ErrorID::NameNotFound(bad_name.clone().into()));
expected.add_parent(ErrorID::Field(bad_name.into())); expected.add_parent(ErrorID::Field(bad_name.into()));
expected.add_parent(ErrorID::Document(test_doc.get_doc_name().into())); expected.add_parent(ErrorID::Document(test_doc.get_doc_name().into()));
let result = mtt.records(update).unwrap_err(); let result = client.records(update).unwrap_err();
assert_eq!(result.to_string(), expected.to_string()); assert_eq!(result.to_string(), expected.to_string());
} }
@@ -179,6 +185,7 @@ fn does_update_error_on_a_bad_field_name() {
fn does_update_error_on_a_bad_field_type() { fn does_update_error_on_a_bad_field_type() {
let (test_env, test_doc) = setup_range(1); let (test_env, test_doc) = setup_range(1);
let mut mtt = test_env.get_morethantext(); let mut mtt = test_env.get_morethantext();
let client = mtt.client();
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
let mut qry_calc = Calculation::new(Operand::Equal); let mut qry_calc = Calculation::new(Operand::Equal);
qry_calc.add_value(0).unwrap(); qry_calc.add_value(0).unwrap();
@@ -192,24 +199,25 @@ fn does_update_error_on_a_bad_field_type() {
let mut expected = MTTError::new(ErrorID::FieldTypeExpected(FieldType::Integer)); let mut expected = MTTError::new(ErrorID::FieldTypeExpected(FieldType::Integer));
expected.add_parent(ErrorID::Field(test_doc.get_field_name(0).into())); expected.add_parent(ErrorID::Field(test_doc.get_field_name(0).into()));
expected.add_parent(ErrorID::Document(test_doc.get_doc_name().into())); expected.add_parent(ErrorID::Document(test_doc.get_doc_name().into()));
let result = mtt.records(update).unwrap_err(); let result = client.records(update).unwrap_err();
assert_eq!(result.to_string(), expected.to_string()); assert_eq!(result.to_string(), expected.to_string());
} }
#[test] #[test]
fn does_update_maintain_unique_index() { fn does_update_maintain_unique_index() {
let mut mtt = MoreThanText::new(); let mut mtt = MoreThanText::new();
let client = mtt.client();
let test_doc = TestDocument::new(vec![FieldType::StaticString]); let test_doc = TestDocument::new(vec![FieldType::StaticString]);
let mut docdef = test_doc.get_docdef(); let mut docdef = test_doc.get_docdef();
docdef.add_index(&test_doc.get_field_name(0), IndexType::Unique); docdef.add_index(&test_doc.get_field_name(0), IndexType::Unique);
mtt.create_document(docdef); client.create_document(docdef);
let old_data = "old"; let old_data = "old";
let new_data = "new"; let new_data = "new";
test_doc.populate(mtt.clone(), vec![old_data]); test_doc.populate(mtt.clone(), vec![old_data]);
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
update.add_field(test_doc.get_field_name(0), new_data); update.add_field(test_doc.get_field_name(0), new_data);
mtt.records(update).unwrap(); client.records(update).unwrap();
let result = mtt.records(Query::new(test_doc.get_doc_name())).unwrap(); let result = client.records(Query::new(test_doc.get_doc_name())).unwrap();
assert_eq!(result.len(), 1); assert_eq!(result.len(), 1);
let rec = result.iter().last().unwrap(); let rec = result.iter().last().unwrap();
assert_eq!( assert_eq!(
@@ -221,11 +229,11 @@ fn does_update_maintain_unique_index() {
let mut err = MTTError::new(ErrorID::IndexEntryAlreadyExists(new_data.into())); let mut err = MTTError::new(ErrorID::IndexEntryAlreadyExists(new_data.into()));
err.add_parent(ErrorID::Field(test_doc.get_field_name(0).into())); err.add_parent(ErrorID::Field(test_doc.get_field_name(0).into()));
err.add_parent(ErrorID::Document(test_doc.get_doc_name().into())); err.add_parent(ErrorID::Document(test_doc.get_doc_name().into()));
let error = mtt.records(add_new).unwrap_err(); let error = client.records(add_new).unwrap_err();
assert_eq!(error.to_string(), err.to_string()); assert_eq!(error.to_string(), err.to_string());
let mut add_old = Addition::new(test_doc.get_doc_name()); let mut add_old = Addition::new(test_doc.get_doc_name());
add_old.add_field(test_doc.get_field_name(0), old_data); add_old.add_field(test_doc.get_field_name(0), old_data);
let result = mtt.records(add_old).unwrap(); let result = client.records(add_old).unwrap();
assert_eq!(result.len(), 1); assert_eq!(result.len(), 1);
let add_rec = result.iter().last().unwrap(); let add_rec = result.iter().last().unwrap();
assert_eq!( assert_eq!(
@@ -237,23 +245,24 @@ fn does_update_maintain_unique_index() {
#[test] #[test]
fn does_index_remain_unchanged_on_update_failure() { fn does_index_remain_unchanged_on_update_failure() {
let mut mtt = MoreThanText::new(); let mut mtt = MoreThanText::new();
let client = mtt.client();
let test_doc = TestDocument::new(vec![FieldType::StaticString, FieldType::StaticString]); let test_doc = TestDocument::new(vec![FieldType::StaticString, FieldType::StaticString]);
let mut docdef = test_doc.get_docdef(); let mut docdef = test_doc.get_docdef();
docdef.add_index(&test_doc.get_field_name(0), IndexType::Unique); docdef.add_index(&test_doc.get_field_name(0), IndexType::Unique);
mtt.create_document(docdef); client.create_document(docdef);
let id = "one"; let id = "one";
test_doc.populate(mtt.clone(), vec!["one", "data"]); test_doc.populate(mtt.clone(), vec!["one", "data"]);
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
update.add_field(test_doc.get_field_name(0), "two"); update.add_field(test_doc.get_field_name(0), "two");
update.add_field(test_doc.get_field_name(1), 2); update.add_field(test_doc.get_field_name(1), 2);
mtt.records(update).unwrap_err(); client.records(update).unwrap_err();
let mut add = Addition::new(test_doc.get_doc_name()); let mut add = Addition::new(test_doc.get_doc_name());
add.add_field(test_doc.get_field_name(0), id); add.add_field(test_doc.get_field_name(0), id);
add.add_field(test_doc.get_field_name(1), "something"); add.add_field(test_doc.get_field_name(1), "something");
let mut err = MTTError::new(ErrorID::IndexEntryAlreadyExists(id.into())); let mut err = MTTError::new(ErrorID::IndexEntryAlreadyExists(id.into()));
err.add_parent(ErrorID::Field(test_doc.get_field_name(0).into())); err.add_parent(ErrorID::Field(test_doc.get_field_name(0).into()));
err.add_parent(ErrorID::Document(test_doc.get_doc_name().into())); err.add_parent(ErrorID::Document(test_doc.get_doc_name().into()));
let error = mtt.records(add).unwrap_err(); let error = client.records(add).unwrap_err();
assert_eq!(error.to_string(), err.to_string()); assert_eq!(error.to_string(), err.to_string());
} }
@@ -262,10 +271,11 @@ fn does_index_remain_unchanged_on_update_failure() {
fn does_update_error_when_it_overrides_unique_index() { fn does_update_error_when_it_overrides_unique_index() {
let count = 3; let count = 3;
let mut mtt = MoreThanText::new(); let mut mtt = MoreThanText::new();
let client = mtt.client();
let test_doc = TestDocument::new(vec![FieldType::Integer]); let test_doc = TestDocument::new(vec![FieldType::Integer]);
let mut docdef = test_doc.get_docdef(); let mut docdef = test_doc.get_docdef();
docdef.add_index(&test_doc.get_field_name(0), IndexType::Unique); docdef.add_index(&test_doc.get_field_name(0), IndexType::Unique);
mtt.create_document(docdef); client.create_document(docdef);
let mut input: Vec<Vec<i128>> = Vec::new(); let mut input: Vec<Vec<i128>> = Vec::new();
for i in 0..count { for i in 0..count {
input.push(vec![i]); input.push(vec![i]);
@@ -277,7 +287,7 @@ fn does_update_error_when_it_overrides_unique_index() {
let mut err = MTTError::new(ErrorID::IndexEntryAlreadyExists(new_data.into())); let mut err = MTTError::new(ErrorID::IndexEntryAlreadyExists(new_data.into()));
err.add_parent(ErrorID::Field(test_doc.get_field_name(0).into())); err.add_parent(ErrorID::Field(test_doc.get_field_name(0).into()));
err.add_parent(ErrorID::Document(test_doc.get_doc_name().into())); err.add_parent(ErrorID::Document(test_doc.get_doc_name().into()));
let result = mtt.records(update).unwrap_err(); let result = client.records(update).unwrap_err();
assert_eq!(result.to_string(), err.to_string()); assert_eq!(result.to_string(), err.to_string());
for i in 0..count { for i in 0..count {
let mut calc = Calculation::new(Operand::Equal); let mut calc = Calculation::new(Operand::Equal);
@@ -286,7 +296,7 @@ fn does_update_error_when_it_overrides_unique_index() {
.unwrap(); .unwrap();
let mut qry = Query::new(test_doc.get_doc_name()); let mut qry = Query::new(test_doc.get_doc_name());
qry.add(test_doc.get_field_name(0), calc); qry.add(test_doc.get_field_name(0), calc);
let holder = mtt.records(qry).unwrap(); let holder = client.records(qry).unwrap();
assert_eq!(holder.len(), 1); assert_eq!(holder.len(), 1);
let rec = holder.iter().last().unwrap(); let rec = holder.iter().last().unwrap();
assert_eq!(rec.get(test_doc.get_field_name(0)).unwrap(), i.into()); assert_eq!(rec.get(test_doc.get_field_name(0)).unwrap(), i.into());
@@ -298,6 +308,7 @@ fn does_update_send_on_update_message() {
let selected = 2; let selected = 2;
let (mut test_env, test_doc) = setup_range(3); let (mut test_env, test_doc) = setup_range(3);
let mut mtt = test_env.get_morethantext(); let mut mtt = test_env.get_morethantext();
let client = mtt.client();
test_env.register_channel(vec![Path::new( test_env.register_channel(vec![Path::new(
Include::All, Include::All,
Include::Just(test_doc.get_doc_name().into()), Include::Just(test_doc.get_doc_name().into()),
@@ -310,7 +321,7 @@ fn does_update_send_on_update_message() {
let mut update = Update::new(test_doc.get_doc_name()); let mut update = Update::new(test_doc.get_doc_name());
update.get_query_mut().add(test_doc.get_field_name(0), calc); update.get_query_mut().add(test_doc.get_field_name(0), calc);
update.add_field(test_doc.get_field_name(0), 5); update.add_field(test_doc.get_field_name(0), 5);
let update_result = mtt.records(update).unwrap(); let update_result = client.records(update).unwrap();
let trigger_result = test_env.get_trigger_records(Action::OnUpdate); let trigger_result = test_env.get_trigger_records(Action::OnUpdate);
assert_eq!(trigger_result.len(), update_result.len()); assert_eq!(trigger_result.len(), update_result.len());
assert_eq!( assert_eq!(