tests/testthat/test_ecs.R

In aws.ecx: Communicating with AWS EC2 and ECS using AWS REST APIs

context("test ecs functions")

if(aws_has_credentials()){
    aws_set_network_timeout(10)
    cluster_names <- paste0("unit-test-cluster", 1:4)
    tags <- list(
        list( key = "unit-test-cluster",
              value = "unit-test-cluster")
    )
    test_that("Delete the cluster if exist",{
        expect_error(response <- ecs_list_clusters(),NA)

        idx <- c()
        if(!is.null(response)){
            for(i in cluster_names){
                idx <- c(idx,  which(endsWith(response,paste0("/",i))))
            }
        }
        if(length(idx)!=0){
            expect_error(response <- ecs_delete_cluster(cluster = i),NA)
        }
    })

    test_that("Create the cluster",{
        for(i in cluster_names){
            expect_error(
                response <- ecs_create_cluster(clusterName = i,tags=tags)
                , NA)
        }
    })

    test_that("list the cluster",{
        expect_error(response <- ecs_list_clusters(),NA)
        idx <- c()
        for(i in cluster_names){
            idx <- c(idx,  which(endsWith(response,paste0("/",i))))
        }
        expect_true(length(idx)==length(cluster_names))
    })

    test_that("list the cluster with token",{
        expect_error(response <- ecs_list_clusters(maxResults = 2),NA)
        idx <- c()
        for(i in cluster_names){
            idx <- c(idx,  which(endsWith(response,paste0("/",i))))
        }
        expect_true(length(idx)==length(cluster_names))
    })

    test_that("describe the cluster",{
        expect_error(
            response <- ecs_describe_clusters(clusters = cluster_names[2],
                                              include = list("TAGS")),
            NA
        )
        expect_equal(
            response$clusters[[1]]$tags,
            list(list(key = "unit-test-cluster", value = "unit-test-cluster"))
        )
    })

    test_that("Delete the cluster",{
        for(i in cluster_names){
            expect_error(response <- ecs_delete_cluster(cluster = i),NA)
        }
    })

    test_that("list the cluster again",{
        expect_error(response <- ecs_list_clusters(),NA)
        idx <- c()
        if(!is.null(response)){
            for(i in cluster_names){
                idx <- c(idx,  which(endsWith(response,paste0("/",i))))
            }
        }
        expect_true(length(idx)==0)
    })
}