Function test_checkpoint_overwrite

finalizer/src/db.rs:889–928

()

            db.commit().await.unwrap();

            // Latest should still be epoch 5, not 3
            let (latest, _) = db.get_latest_finalized_checkpoint().await.0.unwrap();
            assert_eq!(latest.digest, checkpoint5.digest);

            // Store epoch 7 (newer than current latest)
            db.store_finalized_checkpoint(7, &checkpoint7, Block::genesis([0; 32]))
                .await
                .unwrap();
            db.commit().await.unwrap();

            // Latest should now be epoch 7
            let (latest, _) = db.get_latest_finalized_checkpoint().await.0.unwrap();
            assert_eq!(latest.digest, checkpoint7.digest);

            // All checkpoints should still be individually accessible
            let (cp3, _) = db.get_finalized_checkpoint(3).await.unwrap();
            let (cp5, _) = db.get_finalized_checkpoint(5).await.unwrap();
            let (cp7, _) = db.get_finalized_checkpoint(7).await.unwrap();
            assert_eq!(cp3.digest, checkpoint3.digest);
            assert_eq!(cp5.digest, checkpoint5.digest);
            assert_eq!(cp7.digest, checkpoint7.digest);
        });
    }

    #[test]
    fn test_checkpoint_overwrite() {
        let cfg = commonware_runtime::deterministic::Config::default().with_seed(7);
        let executor = Runner::from(cfg);
        executor.start(|context| async move {
            let mut db =
                create_test_db_with_context::<_, MinPk>("test_checkpoint_overwrite", context).await;

            // Create two different checkpoints for the same epoch
            let mut state1 = ConsensusState::default();
            state1.set_latest_height(100);

            let checkpoint1 = summit_types::checkpoint::Checkpoint::new(&state1);

            let mut state2 = ConsensusState::default();
            state2.set_latest_height(200);
            let checkpoint2 = summit_types::checkpoint::Checkpoint::new(&state2);

            // Store first checkpoint for epoch 2