Function compact_deduplicates_by_key

nodedb/src/event/cdc/compaction.rs:124–149

()

    #[test]
    fn compact_deduplicates_by_key() {
        let buf = StreamBuffer::new(
            "test".into(),
            RetentionConfig {
                max_events: 1000,
                max_age_secs: 3600,
            },
        );

        // Three updates to the same key "alice"
        buf.push(make_event(1, "alice", "INSERT"));
        buf.push(make_event(2, "alice", "UPDATE"));
        buf.push(make_event(3, "alice", "UPDATE"));
        // One event for key "bob"
        buf.push(make_event(4, "bob", "INSERT"));

        assert_eq!(buf.len(), 4);

        let removed = buf.compact("id", 86_400);
        assert_eq!(removed, 2); // Two older "alice" events removed.
        assert_eq!(buf.len(), 2); // Latest "alice" + "bob" remain.

        let events = buf.read_from_lsn(0, 10);
        // Latest alice (seq 3) and bob (seq 4) remain.
        assert_eq!(events.len(), 2);
    }

    #[test]
    fn compact_retains_tombstones_within_grace_period() {