Function test_debug_edit_fencing

src/catalog/tests/debug.rs:364–449

(state_builder: TestCatalogStateBuilder)

}

async fn test_debug_edit_fencing(state_builder: TestCatalogStateBuilder) {
    let mut state = state_builder
        .clone()
        .with_default_deploy_generation()
        .unwrap_build()
        .await
        .open(SYSTEM_TIME().into(), &test_bootstrap_args())
        .await
        .unwrap()
        .0;

    let mut debug_state = state_builder
        .clone()
        .unwrap_build()
        .await
        .open_debug()
        .await
        .unwrap();

    // State isn't fenced yet.
    assert_ok!(state.snapshot().await);
    assert_ok!(state.transaction().await);

    // Edit catalog via debug_state.
    debug_state
        .edit::<SettingCollection>(
            proto::SettingKey {
                name: "joe".to_string(),
            },
            proto::SettingValue {
                value: "koshakow".to_string(),
            },
        )
        .await
        .unwrap();

    // Now state should be fenced.
    let err = state.snapshot().await.unwrap_err();
    assert!(
        matches!(
            err,
            CatalogError::Durable(DurableCatalogError::Fence(FenceError::Epoch { .. }))
        ),
        "unexpected err: {err:?}"
    );

    let err = state.transaction().await.unwrap_err();
    assert!(
        matches!(
            err,
            CatalogError::Durable(DurableCatalogError::Fence(FenceError::Epoch { .. }))
        ),
        "unexpected err: {err:?}"
    );

    // Open another state to fence the debug state.
    let _state = state_builder
        .clone()