tests/testthat/working_tests/test-expt-smk_ds.write.R

In patRyserWelch8/dsShareClient: Sharing data between servers in a privacy-preserving manner

context("ds.write::expt::incorrect_param")
test_that("ds.write::expt::incorrect_param",
{
  expect_false(ds.write())
  expect_false(ds.write(data.to.server = pi))
  expect_false(ds.write(data.to.server = "var.on.server"))
  expect_false(ds.write(data.to.server = "var.on.server",
                        class.type.server = "data.frame",
                        client.side.variable = "myVar"))
  expect_false(ds.write(data.to.server = "var.on.server",
                        class.type.server = "data.frame",
                        no.rows        = "albert"))
  expect_false(ds.write(data.to.server = "var.on.server",
                        class.type.server = "data.frame",
                        no.rows        = 10,
                        client.side.variable = "myVar"))
  expect_false(ds.write(data.to.server = "var.on.server",
                        class.type.server = "data.frame",
                        no.rows        = 10,
                        client.side.variable = "myVar",
                        column.server = "mycolumn"))
  expect_false(ds.write(data.to.server = "var.on.server",
                        class.type.server = "data.frame",
                        no.rows        = 10,
                        client.side.variable = "myVar",
                        column.server = "mycolumn",
                        datasources   = "My lovely ..."))
  expect_false(ds.write(data.to.server = "var.on.server",
                        class.type.server = "data.frame",
                        no.rows        = 10,
                        client.side.variable = "myVar",
                        column.server = "mycolumn",
                        datasources   = list()))

})

connection   <- connect.all.datasets(ds.test_env)
context("ds.write::expt::correct_param::multiple")
test_that("ds.write::expt:correct_param::multiple",
{
  data  <- data.frame(a = c(1:12000), b = c(1:12000), c = c(1:12000), x = 1:3)
  assign("myVar",data,  pos = 1)
  expect_true(exists("myVar", where = 1))

  expect_true(ds.assign.sharing.settings(connection))
  expect_true(dsConnectClient::ds.exists.on.server(variable.name = "settings_ds_share",
                                                   class.type = "list",
                                                   error.stop = TRUE,
                                                   datasources = connection))
  expect_true(ds.write(data.to.server = "var.on.server",
                        no.rows        = 10000,
                        client.side.variable = "myVar",
                        column.server = "x",
                        datasources   = connection))

  expect_true(dsConnectClient::ds.exists.on.server(variable.name = "var.on.server",
                                                   class.type = "data.frame",
                                                   error.stop = TRUE,
                                                   datasources = connection))



  data_2 <- data.frame(a = c(1:3), b = c(1:3), c = c(1:3), x = 2)
  data   <- rbind(data,data_2)

  assign("myVar",data,  pos = 1)
  expect_true(exists("myVar", where = 1))

  expect_true(ds.write(data.to.server = "var.on.server",
                       no.rows        = 10000,
                       client.side.variable = "myVar",
                       column.server = "x",
                       datasources   = connection))

  expect_true(dsConnectClient::ds.exists.on.server(variable.name = "var.on.server",
                                                   class.type = "data.frame",
                                                   error.stop = TRUE,
                                                   datasources = connection))



})


context("dswr.check.param::expt::incorrect_param")
test_that("dswr.check.param::expt::incorrect_param",
{
            expect_error(dswr.check.param())
            expect_error(dswr.check.param(data.to.server = pi))
            expect_error(dswr.check.param(data.to.server = "var.on.server"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                  client.side.variable = "myVar"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                  no.rows        = "albert"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                  no.rows        = 10,
                                  client.side.variable = "myVar"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                  no.rows        = 10,
                                  client.side.variable = "myVar",
                                  column.server = "mycolumn"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                  no.rows        = 10,
                                  client.side.variable = "myVar",
                                  column  = "mycolumn",
                                  datasources   = "My lovely ..."))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                  no.rows        = 10,
                                  client.side.variable = "myVar",
                                  column = "mycolumn",
                                  datasources   = list()))

})

connection   <- connect.all.datasets(ds.test_env)
context("dswr.check.param::expt::correct_param::multiple")
test_that("dswr.check.param::expt:correct_param::multiple",
{

  assign("myVar",data,  pos = 1)
  expect_true(exists("myVar", where = 1))

  expect_true(ds.assign.sharing.settings(connection))

  expect_true(dsConnectClient::ds.exists.on.server(variable.name = "settings_ds_share",
                                                   class.type = "list",
                                                   error.stop = TRUE,
                                                   datasources = connection))

            data  <- data.frame(a = c(1:12), b = c(1:12), c = c(1:12), x = 1:3)
            assign("myVar",data,  pos = 1)
            expect_true(exists("myVar", where = 1))

            expect_true(dswr.check.param(data.to.server = "var.on.server",
                                 no.rows        = 2,
                                 client.side.variable = "myVar",
                                 column = "x",
                                 client.side.split = "myVar_split",
                                 datasources   = connection))




            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                         no.rows        = 10,
                                         client.side.variable = "myVar",
                                         column = "z", #incorrect column
                                         client.side.split = "myVar_split",
                                         datasources   = connection))

})


log.out.data.server()


connection   <- connect.dataset.2(ds.test_env)
context("dswr.check.param::expt::incorrect_param")
test_that("dswr.check.param::expt::incorrect_param",
{
            expect_error(dswr.check.param())
            expect_error(dswr.check.param(data.to.server = pi))
            expect_error(dswr.check.param(data.to.server = "var.on.server"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                          client.side.variable = "myVar"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                          no.rows        = "albert"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                          no.rows        = 10,
                                          client.side.variable = "myVar"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                          no.rows        = 10,
                                          client.side.variable = "myVar",
                                          column.server = "mycolumn"))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                          no.rows        = 10,
                                          client.side.variable = "myVar",
                                          column  = "mycolumn",
                                          datasources   = "My lovely ..."))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                          no.rows        = 10,
                                          client.side.variable = "myVar",
                                          column = "mycolumn",
                                          datasources   = connection))

})


context("dswr.check.param::expt::correct_param::single")
test_that("dswr.check.param::expt:correct_param::single",
{
            data  <- data.frame(a = c(1:12000), b = c(1:12000), c = c(1:12000), x = 1:3)
            assign("myVar",data,  pos = 1)
            expect_true(exists("myVar", where = 1))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                         no.rows        = 10000,
                                         client.side.variable = "myVar",
                                         column = "x",
                                         client.side.split = "myVar_split",
                                         datasources   = connection))
            expect_error(dswr.check.param(data.to.server = "var.on.server",
                                          no.rows        = 10,
                                          client.side.variable = "myVar",
                                          column = "z", #incorrect column
                                          client.side.split = "myVar_split",
                                          datasources   = connection))
            #incorrect number of servers
            data  <- data.frame(a = c(1:12000), b = c(1:12000), c = c(1:12000), x = 1)
            assign("myVar",data,  pos = 1)
            expect_true(exists("myVar", where = 1))

             expect_true(dswr.check.param(data.to.server = "var.on.server",
                                          no.rows        = 1000,
                                          client.side.variable = "myVar",
                                          column = "x",
                                          client.side.split = "myVar_split",
                                          datasources   = connection))

})


context("ds.write::expt::correct_param::single")
test_that("ds.write::expt:correct_param::single",
{
  data  <- data.frame(a = c(1:1200), b = c(1:1200), c = c(1:1200), x = 1)
  assign("myVar",data,  pos = 1)
  expect_true(exists("myVar", where = 1))

  expect_true(ds.assign.sharing.settings(connection))

  expect_true(dsConnectClient::ds.exists.on.server(variable.name = "settings_ds_share",
                                                   class.type = "list",
                                                   error.stop = TRUE,
                                                   datasources = connection))

  expect_true(ds.write(data.to.server       = "var.on.server",
                       class.type.server    = "data.frame",
                       no.rows              = 1000,
                       client.side.variable = "myVar",
                       column.server        = "x",
                       datasources          = connection))


  expect_true(dsConnectClient::ds.exists.on.server(variable.name = "var.on.server",
                                                  class.type = "data.frame",
                                                  error.stop = TRUE,
                                                  datasources = connection))




  expect_true(ds.write(data.to.server       = "var.on.server",
                       class.type.server    = "data.frame",
                       no.rows              = 1000,
                       client.side.variable = "myVar",
                       column.server        = "x",
                       datasources          = connection))


  # the number of servers is incorrect for each label
  data  <- data.frame(a = c(1:12000), b = c(1:12000), c = c(1:12000), x = 1:3)
  assign("myVar",data,  pos = 1)
  expect_true(exists("myVar", where = 1))

  expect_false(ds.write(data.to.server = "var.on.server",
                       no.rows        = 1000,
                       client.side.variable = "myVar",
                       column.server = "x",
                       datasources   = connection))
})

log.out.data.server()