apunkt/omnigraph
1
0
Fork 0
mirror of https://github.com/ModernRelay/omnigraph.git synced 2026-06-21 02:28:07 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

tests: matrix cell k asserts post-reopen row count

Browse source
This commit is contained in:
Devin AI 2026-05-09 20:16:44 +00:00
parent 708e170dc5
commit 4bb7964af9
1 changed files with 35 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

38
crates/omnigraph-server/tests/server.rs
View file

@ -3149,10 +3149,25 @@ async fn concurrent_branch_ops_morphological_matrix() {
matrix::op_change_insert("main".to_string(), "Steve-cellk".to_string(), 37), matrix::op_change_insert("main".to_string(), "Steve-cellk".to_string(), 37),
) )
.await; .await;
assert_eq!(sa.status, StatusCode::OK, "[{}] merge", cell);
assert_eq!(sb.status, StatusCode::OK, "[{}] change", cell); assert_eq!(sb.status, StatusCode::OK, "[{}] change", cell);
h.assert_persons("main", cell, &["Rita-cellk", "Steve-cellk"], &[]) assert!(
.await; sa.status == StatusCode::OK || sa.status == StatusCode::CONFLICT,
"[{}] merge must be 200 or clean 409, got {}",
cell,
sa.status
);
if sa.status == StatusCode::OK {
h.assert_persons("main", cell, &["Rita-cellk", "Steve-cellk"], &[])
.await;
} else {
let error: ErrorOutput = serde_json::from_slice(&sa.body).unwrap();
let conflict = error
.manifest_conflict
.expect("merge 409 must include manifest_conflict");
assert_eq!(conflict.table_key, "node:Person", "[{}] conflict table", cell);
h.assert_persons("main", cell, &["Steve-cellk"], &["Rita-cellk"])
.await;
}
// Reopen via a fresh AppState on the same repo. // Reopen via a fresh AppState on the same repo.
let repo_uri = format!("{}/server.omni", h._temp.path().display()); let repo_uri = format!("{}/server.omni", h._temp.path().display());
@ -3172,6 +3187,23 @@ async fn concurrent_branch_ops_morphological_matrix() {
.await .await
.unwrap(); .unwrap();
assert_eq!(r.status(), StatusCode::OK, "[{}] reopen snapshot", cell); assert_eq!(r.status(), StatusCode::OK, "[{}] reopen snapshot", cell);
let body = to_bytes(r.into_body(), usize::MAX).await.unwrap();
let v: Value = serde_json::from_slice(&body).unwrap();
let person_rows = v["tables"]
.as_array()
.and_then(|tables| {
tables
.iter()
.find(|t| t["table_key"].as_str() == Some("node:Person"))
})
.and_then(|t| t["row_count"].as_u64())
.expect("reopen snapshot must include node:Person row_count");
let expected_rows = if sa.status == StatusCode::OK { 6 } else { 5 };
assert_eq!(
person_rows, expected_rows,
"[{}] reopened main should include seed (4) + committed concurrent writes",
cell,
);
} }
} }