Function test_multiple_consecutive_ops

src/models/wal.rs:522–556

()

    #[test]
    fn test_multiple_consecutive_ops() {
        let dir = tempdir().unwrap();
        let version = 0;

        let entries: Vec<VectorOp> = (0..10)
            .map(|i| {
                if i % 2 == 0 {
                    VectorOp::Upsert(vec![random_vector()])
                } else {
                    VectorOp::Delete(VectorId::from(random_string(8)))
                }
            })
            .collect();

        {
            let wal = WALFile::new().unwrap();
            for op in &entries {
                wal.append(op.clone()).unwrap();
            }
            wal.flush(dir.as_ref(), VersionNumber::from(version))
                .unwrap();
        }

        {
            let wal = reopen_wal(dir.path(), version);
            for expected in &entries {
                let read = wal.read().unwrap().expect("Expected some op");
                match (expected, &read) {
                    (VectorOp::Upsert(ev), VectorOp::Upsert(rv)) => assert_eq!(ev[0].id, rv[0].id),
                    (VectorOp::Delete(eid), VectorOp::Delete(rid)) => assert_eq!(eid, rid),
                    _ => panic!("Mismatched operation types"),
                }
            }
        }
    }
}