Function document_roundtrip

nodedb/tests/sql_backup_restore_wire.rs:94–128

()

#[tokio::test]
async fn document_roundtrip() {
    let server = TestServer::start().await;
    server
        .exec(
            "CREATE COLLECTION wire_docs  \
             (id TEXT PRIMARY KEY, content TEXT) WITH (engine='document_strict')",
        )
        .await
        .ok();
    server
        .exec("INSERT INTO wire_docs (id, content) VALUES ('a','alpha')")
        .await
        .expect("insert a");
    server
        .exec("INSERT INTO wire_docs (id, content) VALUES ('b','beta')")
        .await
        .expect("insert b");

    let bytes = drain_backup(&server, TENANT).await.expect("BACKUP");

    // Restore over the *same* server is a valid sanity check — restore is
    // idempotent at the engine level (PointPut overwrites).
    push_restore(&server, TENANT, bytes, false)
        .await
        .expect("RESTORE");

    let rows = server
        .query_text("SELECT content FROM wire_docs WHERE id='a'")
        .await
        .expect("post-restore SELECT");
    assert!(
        rows.iter().any(|r| r.contains("alpha")),
        "expected post-restore rows to contain 'alpha', got: {rows:?}"
    );
}

// ────────────────────────────────────────────────────────────────────
// Dry run — validates envelope, must not mutate state.