Function test_views

crates/engine/src/relational_db.rs:2625–2703

()

    #[test]
    fn test_views() -> ResultTest<()> {
        let stdb = TestDB::durable()?;

        let (view_id, table_id, _, _) = setup_view(&stdb)?;

        let sender1 = Identity::ONE;

        // Sender 1 insert
        insert_view_row(&stdb, view_id, table_id, sender1, 42)?;

        assert_eq!(
            project_views(&stdb, table_id, sender1)[0],
            product![42u8],
            "View row not inserted correctly"
        );

        // Sender 2 insert
        let sender2 = Identity::ZERO;
        let before_sender2 = Instant::now();
        insert_view_row(&stdb, view_id, table_id, sender2, 84)?;

        assert_eq!(
            project_views(&stdb, table_id, sender2)[0],
            product![84u8],
            "Sender 2 view row not inserted correctly"
        );

        // Restart database (view rows should NOT persist)
        let stdb = stdb.reopen()?;

        assert!(
            project_views(&stdb, table_id, sender1).is_empty(),
            "Sender 1 rows should NOT persist after reopen"
        );
        assert!(
            project_views(&stdb, table_id, sender2).is_empty(),
            "Sender 2 rows should NOT persist after reopen"
        );

        let tx = begin_mut_tx(&stdb);
        let st = tx.lookup_st_view_subs(view_id)?;
        assert!(st.is_empty(), "st_view_subs should also be cleared after restart");
        stdb.commit_tx(tx)?;

        // Reinsert after restart
        insert_view_row(&stdb, view_id, table_id, sender2, 91)?;
        assert_eq!(
            project_views(&stdb, table_id, sender2)[0],
            product![91u8],
            "Post-restart inserted rows must appear"
        );

        // Clean expired rows
        let mut tx = begin_mut_tx(&stdb);
        tx.clear_expired_views(
            Instant::now().saturating_duration_since(before_sender2),
            VIEW_CLEANUP_BUDGET,
        )?;