Moved delete tests to client.
Some checks failed
Gitea Actions Demo / Explore-Gitea-Actions (push) Has been cancelled
Some checks failed
Gitea Actions Demo / Explore-Gitea-Actions (push) Has been cancelled
This commit is contained in:
@@ -11,16 +11,17 @@ use support::{setup_range, TestDocument};
|
|||||||
fn can_delete() {
|
fn can_delete() {
|
||||||
let data = "fred";
|
let data = "fred";
|
||||||
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]);
|
||||||
mtt.create_document(test_doc.get_docdef()).unwrap();
|
client.create_document(test_doc.get_docdef()).unwrap();
|
||||||
test_doc.populate(mtt.clone(), vec![data]);
|
test_doc.populate(mtt.clone(), vec![data]);
|
||||||
let delete = Delete::new(test_doc.get_doc_name());
|
let delete = Delete::new(test_doc.get_doc_name());
|
||||||
let result = mtt.records(delete).unwrap();
|
let result = client.records(delete).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(), data.into());
|
assert_eq!(rec.get(test_doc.get_field_name(0)).unwrap(), data.into());
|
||||||
let qry = Query::new(test_doc.get_doc_name());
|
let qry = Query::new(test_doc.get_doc_name());
|
||||||
let qresult = mtt.records(qry).unwrap();
|
let qresult = client.records(qry).unwrap();
|
||||||
assert_eq!(qresult.len(), 0);
|
assert_eq!(qresult.len(), 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -29,13 +30,14 @@ fn can_delete_specific() {
|
|||||||
let selected = 1;
|
let selected = 1;
|
||||||
let (test_env, test_doc) = setup_range(3);
|
let (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();
|
||||||
let mut calc = Calculation::new(Operand::Equal);
|
let mut calc = Calculation::new(Operand::Equal);
|
||||||
calc.add_value(selected.clone()).unwrap();
|
calc.add_value(selected.clone()).unwrap();
|
||||||
calc.add_value(CalcValue::Existing(FieldType::Integer))
|
calc.add_value(CalcValue::Existing(FieldType::Integer))
|
||||||
.unwrap();
|
.unwrap();
|
||||||
let mut delete = Delete::new(test_doc.get_doc_name());
|
let mut delete = Delete::new(test_doc.get_doc_name());
|
||||||
delete.get_query_mut().add(test_doc.get_field_name(0), calc);
|
delete.get_query_mut().add(test_doc.get_field_name(0), calc);
|
||||||
let result = mtt.records(delete).unwrap();
|
let result = client.records(delete).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!(
|
||||||
@@ -43,7 +45,7 @@ fn can_delete_specific() {
|
|||||||
selected.into()
|
selected.into()
|
||||||
);
|
);
|
||||||
let qry = Query::new(test_doc.get_doc_name());
|
let qry = Query::new(test_doc.get_doc_name());
|
||||||
let qresult = mtt.records(qry).unwrap();
|
let qresult = client.records(qry).unwrap();
|
||||||
assert_eq!(qresult.len(), 2);
|
assert_eq!(qresult.len(), 2);
|
||||||
let mut expected: HashSet<Field> = HashSet::new();
|
let mut expected: HashSet<Field> = HashSet::new();
|
||||||
expected.insert(0.into());
|
expected.insert(0.into());
|
||||||
@@ -68,13 +70,14 @@ fn can_delete_multiple() {
|
|||||||
let bound = selected + 1;
|
let bound = selected + 1;
|
||||||
let (test_env, test_doc) = setup_range(count.clone().try_into().unwrap());
|
let (test_env, test_doc) = setup_range(count.clone().try_into().unwrap());
|
||||||
let mut mtt = test_env.get_morethantext();
|
let mut mtt = test_env.get_morethantext();
|
||||||
|
let client = mtt.client();
|
||||||
let mut calc = Calculation::new(Operand::GreaterThan);
|
let mut calc = Calculation::new(Operand::GreaterThan);
|
||||||
calc.add_value(CalcValue::Existing(FieldType::Integer))
|
calc.add_value(CalcValue::Existing(FieldType::Integer))
|
||||||
.unwrap();
|
.unwrap();
|
||||||
calc.add_value(selected.clone()).unwrap();
|
calc.add_value(selected.clone()).unwrap();
|
||||||
let mut delete = Delete::new(test_doc.get_doc_name());
|
let mut delete = Delete::new(test_doc.get_doc_name());
|
||||||
delete.get_query_mut().add(test_doc.get_field_name(0), calc);
|
delete.get_query_mut().add(test_doc.get_field_name(0), calc);
|
||||||
let result = mtt.records(delete).unwrap();
|
let result = client.records(delete).unwrap();
|
||||||
assert_eq!(result.len(), 2);
|
assert_eq!(result.len(), 2);
|
||||||
let mut expected: HashSet<Field> = HashSet::new();
|
let mut expected: HashSet<Field> = HashSet::new();
|
||||||
for i in bound..count {
|
for i in bound..count {
|
||||||
@@ -87,7 +90,7 @@ fn can_delete_multiple() {
|
|||||||
}
|
}
|
||||||
assert_eq!(expected.len(), 0, "{:?} should have been deleted", expected);
|
assert_eq!(expected.len(), 0, "{:?} should have been deleted", expected);
|
||||||
let qry = Query::new(test_doc.get_doc_name());
|
let qry = Query::new(test_doc.get_doc_name());
|
||||||
let qresult = mtt.records(qry).unwrap();
|
let qresult = client.records(qry).unwrap();
|
||||||
assert_eq!(qresult.len(), bound.clone().try_into().unwrap());
|
assert_eq!(qresult.len(), bound.clone().try_into().unwrap());
|
||||||
let mut qexpected: HashSet<Field> = HashSet::new();
|
let mut qexpected: HashSet<Field> = HashSet::new();
|
||||||
for i in 0..bound {
|
for i in 0..bound {
|
||||||
@@ -110,6 +113,7 @@ fn can_delete_multiple() {
|
|||||||
fn does_delete_error_on_a_bad_query() {
|
fn does_delete_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 delete = Delete::new(test_doc.get_doc_name());
|
let mut delete = Delete::new(test_doc.get_doc_name());
|
||||||
let mut qry_calc = Calculation::new(Operand::Equal);
|
let mut qry_calc = Calculation::new(Operand::Equal);
|
||||||
@@ -121,7 +125,7 @@ fn does_delete_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(delete).unwrap_err();
|
let result = client.records(delete).unwrap_err();
|
||||||
assert_eq!(result.to_string(), expected.to_string());
|
assert_eq!(result.to_string(), expected.to_string());
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -129,15 +133,18 @@ fn does_delete_error_on_a_bad_query() {
|
|||||||
fn does_delete_update_indexes() {
|
fn does_delete_update_indexes() {
|
||||||
let id = "something";
|
let id = "something";
|
||||||
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).unwrap();
|
client.create_document(docdef).unwrap();
|
||||||
test_doc.populate(mtt.clone(), vec![id]);
|
test_doc.populate(mtt.clone(), vec![id]);
|
||||||
mtt.records(Delete::new(test_doc.get_doc_name())).unwrap();
|
client
|
||||||
|
.records(Delete::new(test_doc.get_doc_name()))
|
||||||
|
.unwrap();
|
||||||
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);
|
||||||
let result = mtt.records(add).unwrap();
|
let result = client.records(add).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(), id.into());
|
assert_eq!(rec.get(test_doc.get_field_name(0)).unwrap(), id.into());
|
||||||
@@ -148,6 +155,7 @@ fn does_delete_send_trigger() {
|
|||||||
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()),
|
||||||
@@ -159,7 +167,7 @@ fn does_delete_send_trigger() {
|
|||||||
.unwrap();
|
.unwrap();
|
||||||
let mut delete = Delete::new(test_doc.get_doc_name());
|
let mut delete = Delete::new(test_doc.get_doc_name());
|
||||||
delete.get_query_mut().add(test_doc.get_field_name(0), calc);
|
delete.get_query_mut().add(test_doc.get_field_name(0), calc);
|
||||||
let delete_result = mtt.records(delete).unwrap();
|
let delete_result = client.records(delete).unwrap();
|
||||||
let trigger_result = test_env.get_trigger_records(Action::OnDelete);
|
let trigger_result = test_env.get_trigger_records(Action::OnDelete);
|
||||||
assert_eq!(trigger_result.len(), delete_result.len());
|
assert_eq!(trigger_result.len(), delete_result.len());
|
||||||
assert_eq!(
|
assert_eq!(
|
||||||
|
|||||||
Reference in New Issue
Block a user