test_that("`dm_wrap_tbl()` and `dm_unwrap_tbl()` work", { skip_if_remote_src() dm1 <- dm_for_filter() dm_wrapped <- dm_wrap_tbl(dm1, tf_4) expect_length(dm_wrapped, 1) expect_equal(names(dm_wrapped), "tf_4") dm_unwrap_tblped <- dm_unwrap_tbl(dm_wrapped, dm1) expect_equivalent_dm(dm_unwrap_tblped, dm_unwrap_tbl(dm_wrapped, dm1)) # to tibble expect_snapshot({ wrapped <- dm_wrap_tbl(dm_for_filter(), tf_4) wrapped wrapped$tf_4 wrapped$tf_4$tf_3$tf_2[[3]] wrapped$tf_4$tf_5[[2]] }) # back to dm expect_snapshot({ unwrapped <- dm_unwrap_tbl(dm_wrap_tbl(dm_for_filter(), tf_4), dm_for_filter()) unwrapped unwrapped$tf_4 unwrapped$tf_1 unwrapped$tf_6 }) }) test_that("`dm_wrap_tbl()` and `dm_unwrap_tbl()` round trip", { skip_if_remote_src() dm <- dm_for_filter() reduced_dm <- dm %>% dm_filter(tf_1 = TRUE) roundtrip_dm <- dm_unwrap_tbl(dm_wrap_tbl(dm, tf_1), dm) expect_equivalent_dm(roundtrip_dm, reduced_dm, sort = TRUE, ignore_on_delete = TRUE, ignore_autoincrement = TRUE) dm <- dm_for_filter() reduced_dm <- dm %>% dm_filter(tf_2 = TRUE) roundtrip_dm <- dm_unwrap_tbl(dm_wrap_tbl(dm, tf_2), dm) expect_equivalent_dm(roundtrip_dm, reduced_dm, sort = TRUE, ignore_on_delete = TRUE, ignore_autoincrement = TRUE) dm <- dm_for_filter() reduced_dm <- dm %>% dm_filter(tf_3 = TRUE) roundtrip_dm <- dm_unwrap_tbl(dm_wrap_tbl(dm, tf_3), dm) expect_equivalent_dm(roundtrip_dm, reduced_dm, sort = TRUE, ignore_on_delete = TRUE, ignore_autoincrement = TRUE) dm <- dm_for_filter() reduced_dm <- dm %>% dm_filter(tf_4 = TRUE) roundtrip_dm <- dm_unwrap_tbl(dm_wrap_tbl(dm, tf_4), dm) expect_equivalent_dm(roundtrip_dm, reduced_dm, sort = TRUE, ignore_on_delete = TRUE, ignore_autoincrement = TRUE) dm <- dm_for_filter() reduced_dm <- dm %>% dm_filter(tf_5 = TRUE) roundtrip_dm <- dm_unwrap_tbl(dm_wrap_tbl(dm, tf_5), dm) expect_equivalent_dm(roundtrip_dm, reduced_dm, sort = TRUE, ignore_on_delete = TRUE, ignore_autoincrement = TRUE) dm <- dm_for_filter() reduced_dm <- dm %>% dm_filter(tf_6 = TRUE) roundtrip_dm <- dm_unwrap_tbl(dm_wrap_tbl(dm, tf_6), dm) expect_equivalent_dm(roundtrip_dm, reduced_dm, sort = TRUE, ignore_on_delete = TRUE, ignore_autoincrement = TRUE) }) test_that("`node_type_from_graph()` works", { dm1 <- dm_for_filter() graph <- create_graph_from_dm(dm1, directed = TRUE) expect_snapshot({ node_type_from_graph(graph) }) expect_snapshot({ node_type_from_graph(graph, drop = "tf_4") }) })