R/ecs-route.R

In ECSFargateProvider: The 'ECS Fargate' Cloud Provider for the 'DockerParallel' Package

createRoute <- function(cidr, gatewayId, routeTableId, ...){
    response <- ec2_create_route(DestinationCidrBlock = cidr,
                                 GatewayId = gatewayId,
                                 RouteTableId = routeTableId,
                                 ...)
    response
}

deleteRoute <- function(routeTableId, cidr, ...){
    response <- ec2_delete_route(DestinationCidrBlock = cidr,
                                 RouteTableId = routeTableId,
                                 ...)
    response
}

listRoute<-function(routeTableId = NULL, ...){
    response <- ec2_describe_route_tables(RouteTableId=routeTableId, ...)
    route_set <- response$item$routeSet

    destCidr <- lapply(route_set, function(x) x$destinationCidrBlock[[1]])
    destIpv6Cidr <- lapply(route_set, function(x) x$destinationIpv6CidrBlock[[1]])
    for(i in seq_along(destCidr)){
        if(is.null(destCidr[[i]])){
            destCidr[[i]] <- destIpv6Cidr[[i]]
        }
    }
    destCidr <- unlist(destCidr)
    gatewayIds <- vapply(route_set, function(x) x$gatewayId[[1]], character(1))
    states <- vapply(route_set, function(x) x$state[[1]], character(1))
    destCidr <- destCidr[states=="active"]
    gatewayIds <- gatewayIds[states=="active"]

    data.frame(cidr =destCidr,
               gateway = gatewayIds)
}



configDefaultRoute<-function(x, ...){
    internetGatewayId <- configInternetGateway(x, ...)
    routeTableId <- configRouteTable(x, ...)
    if(!x$routeVerified){
        routeList <- listRoute(routeTableId, ...)
        if(!any(routeList$cidr=="0.0.0.0/0"&
                routeList$gateway==internetGatewayId)){
            createRoute("0.0.0.0/0",
                        internetGatewayId,
                        routeTableId,
                        ...)
        }
        x$routeVerified <- TRUE
    }
}