use docs_core::{apply_update, fragment_html, fragment_json, snapshot_bytes, verify_snapshot};
use yrs::{Doc, Options};

fn receiver(client: u64) -> Doc {
    Doc::with_options(Options::with_guid_and_client_id(
        "native-rule".into(),
        client,
    ))
}

#[test]
fn native_rule_updates_converge_through_server_rendering_and_snapshot_reload() {
    let doc = receiver(900);
    let fixture =
        std::path::Path::new(env!("CARGO_MANIFEST_DIR")).join("../fixtures/vectors/native-rule");
    for step in 0..=6 {
        apply_update(
            &doc,
            &std::fs::read(fixture.join(format!("{step}.bin"))).unwrap(),
        )
        .unwrap();
        if step == 0 {
            continue;
        }
        let expected = receiver(901);
        apply_update(
            &expected,
            &std::fs::read(fixture.join(format!("{step}.snapshot"))).unwrap(),
        )
        .unwrap();
        assert_eq!(
            fragment_json(&doc),
            fragment_json(&expected),
            "incremental step {step}"
        );
        let snapshot = snapshot_bytes(&doc);
        assert!(verify_snapshot(&doc, &snapshot, "native-rule", 902));
        let reloaded = receiver(903);
        apply_update(&reloaded, &snapshot).unwrap();
        assert_eq!(
            fragment_json(&reloaded),
            fragment_json(&expected),
            "reloaded step {step}"
        );
    }
    assert_eq!(fragment_html(&doc), "<p>- Alpha</p><p>Beta</p>");
}