Synnefo

def _get_user_id():

    """Authenticate to astakos and get unique users id"""

    astakos = AstakosClient(AUTH_URL, TOKEN)

    authenticate = astakos.authenticate()

    return authenticate['access']['user']['id']

    @classmethod

    def setUpClass(cls):

        cls.astakos = AstakosClient(AUTH_URL, TOKEN)

        cls.compute_url = \

            cls.astakos.get_service_endpoints('compute')['publicURL']

        cls.result_dict = dict()

        log.info("Authentication test")

        falseToken = '12345'

        c = ComputeClient(self.compute_url, falseToken)

        with self.assertRaises(ClientError) as cm:

            c.list_servers()

        """Initialize kamaki, get (detailed) list of images"""

        log.info("Getting simple and detailed list of images")

        cls.astakos_client = AstakosClient(AUTH_URL, TOKEN)

        # Compute Client

        compute_url = \

            cls.astakos_client.get_service_endpoints('compute')['publicURL']

        cls.compute_client = ComputeClient(compute_url, TOKEN)

        # Image Client

        image_url = \

            cls.astakos_client.get_service_endpoints('image')['publicURL']

        cls.image_client = ImageClient(image_url, TOKEN)

        # Pithos Client

        pithos_url = cls.astakos_client.\

            get_service_endpoints('object-store')['publicURL']

        """Initialize kamaki, get (detailed) list of flavors"""

        log.info("Getting simple and detailed list of flavors")

        cls.astakos_client = AstakosClient(AUTH_URL, TOKEN)

        # Compute Client

        compute_url = \

            cls.astakos_client.get_service_endpoints('compute')['publicURL']

        cls.compute_client = ComputeClient(compute_url, TOKEN)

        cls.flavors = cls.compute_client.list_flavors()

        cls.dflavors = cls.compute_client.list_flavors(detail=True)

        cls.result_dict = dict()

        log.info("Getting simple and detailed list of servers")

        cls.astakos_client = AstakosClient(AUTH_URL, TOKEN)

        # Compute Client

        compute_url = \

            cls.astakos_client.get_service_endpoints('compute')['publicURL']

        cls.compute_client = ComputeClient(compute_url, TOKEN)

        cls.servers = cls.compute_client.list_servers()

        cls.dservers = cls.compute_client.list_servers(detail=True)

        cls.result_dict = dict()

        log.info("Getting list of containers")

        cls.astakos_client = AstakosClient(AUTH_URL, TOKEN)

        # Pithos Client

        pithos_url = cls.astakos_client.\

            get_service_endpoints('object-store')['publicURL']

        log.info("Spawning server for image `%s'" % cls.imagename)

        cls.astakos_client = AstakosClient(AUTH_URL, TOKEN)

        # Cyclades Client

        compute_url = \

            cls.astakos_client.get_service_endpoints('compute')['publicURL']

        cls.cyclades_client = CycladesClient(compute_url, TOKEN)

        cls.result_dict = dict()

        "Initialize kamaki, get list of current networks"

        cls.astakos_client = AstakosClient(AUTH_URL, TOKEN)

        # Cyclades Client

        compute_url = \

            cls.astakos_client.get_service_endpoints('compute')['publicURL']

        cls.cyclades_client = CycladesClient(compute_url, TOKEN)

        cls.servername = "%s%s for %s" % (SNF_TEST_PREFIX,

                                          TEST_RUN_ID,

def cleanup_servers(timeout, query_interval, delete_stale=False):

    astakos_client = AstakosClient(AUTH_URL, TOKEN)

    # Compute Client

    compute_url = astakos_client.get_service_endpoints('compute')['publicURL']

    compute_client = ComputeClient(compute_url, TOKEN)

    servers = compute_client.list_servers()

    stale = [s for s in servers if s["name"].startswith(SNF_TEST_PREFIX)]

def cleanup_networks(action_timeout, query_interval, delete_stale=False):

    astakos_client = AstakosClient(AUTH_URL, TOKEN)

    # Cyclades Client

    compute_url = astakos_client.get_service_endpoints('compute')['publicURL']

    cyclades_client = CycladesClient(compute_url, TOKEN)

    networks = cyclades_client.list_networks()

    stale = [n for n in networks if n["name"].startswith(SNF_TEST_PREFIX)]

    # Initialize a kamaki instance, get flavors, images

    astakos_client = AstakosClient(AUTH_URL, TOKEN)

    # Compute Client

    compute_url = astakos_client.get_service_endpoints('compute')['publicURL']

    compute_client = ComputeClient(compute_url, TOKEN)

    DIMAGES = compute_client.list_images(detail=True)

    DFLAVORS = compute_client.list_flavors(detail=True)