From 2f9219dfa44982779990e13c177a703f2239b488 Mon Sep 17 00:00:00 2001 From: boucherv Date: Wed, 23 Aug 2017 16:23:34 +0200 Subject: New testcase creation named "cloudify_ims_perf" * IMS deployment with "cloudify_ims" testcase * IXIA infrastructure creation with SNAPS * Module configuration with REST API * Configure and run the perf tests with REST API Change-Id: I3dfddda87f9e9f4f03df375f6a032ded26a627b3 Signed-off-by: boucherv Co-Authored-By: Arturo Sordo Miralles --- .../opnfv_tests/vnf/ims/ixia/utils/IxRestUtils.py | 192 +++++++++++++++++++++ 1 file changed, 192 insertions(+) create mode 100644 functest/opnfv_tests/vnf/ims/ixia/utils/IxRestUtils.py (limited to 'functest/opnfv_tests/vnf/ims/ixia/utils/IxRestUtils.py') diff --git a/functest/opnfv_tests/vnf/ims/ixia/utils/IxRestUtils.py b/functest/opnfv_tests/vnf/ims/ixia/utils/IxRestUtils.py new file mode 100644 index 00000000..63db403b --- /dev/null +++ b/functest/opnfv_tests/vnf/ims/ixia/utils/IxRestUtils.py @@ -0,0 +1,192 @@ +#!/usr/bin/env python + +# Copyright (c) 2017 IXIA and others. +# +# All rights reserved. This program and the accompanying materials +# are made available under the terms of the Apache License, Version 2.0 +# which accompanies this distribution, and is available at +# http://www.apache.org/licenses/LICENSE-2.0 + +from urlparse import urljoin +import requests + + +def getConnection(server, port): + """ + Gets a Connection instance, that will be used to + make the HTTP requests to the application + """ + connectionUrl = 'http://%s:%s/' % (server, port) + + conn = Connection(connectionUrl, 'v0') + return conn + + +def formatDictToJSONPayload(dictionary): + """ + Converts a given python dict instance to a string + JSON payload that can be sent to a REST API. + """ + jsonPayload = '{' + optionsList = [] + for (key, val) in dictionary.items(): + valStr = str(val) + if type(val) is str: + valStr = '"%s"' % val + if type(val) is bool: + valStr = valStr.lower() + optionsList.append('"%s":%s' % (key, valStr)) + + jsonPayload += ','.join(optionsList) + jsonPayload += '}' + + return jsonPayload + + +class Connection(object): + + """ + Class that executes the HTTP requests to the application instance. + It handles creating the HTTP session and executing HTTP methods. + """ + + kHeaderContentType = 'content-type' + kContentJson = 'application/json' + + def __init__(self, siteUrl, apiVersion): + self.httpSession = None + + self.url = Connection.urljoin(siteUrl, 'api') + self.url = Connection.urljoin(self.url, apiVersion) + + def _getHttpSession(self): + """ + This is a lazy initializer for the HTTP session. + It does not need to be active until it is required. + """ + + if self.httpSession is None: + self.httpSession = requests.Session() + return self.httpSession + + @classmethod + def urljoin(cls, base, end): + """ Join two URLs. If the second URL is absolute, the base is ignored. + + Use this instead of urlparse.urljoin directly so that we can customize + its behavior if necessary. + Currently differs in that it + 1. appends a / to base if not present. + 2. casts end to a str as a convenience + """ + + if base and not base.endswith('/'): + base = base + '/' + return urljoin(base, str(end)) + + def httpRequest(self, method, url='', data='', params={}, headers={}): + """ + Method for making a HTTP request. + The method type (GET, POST, PATCH, DELETE) will be sent as a parameter. + Along with the url and request data. The HTTP response is returned + """ + + headers[Connection.kHeaderContentType] = Connection.kContentJson + + absUrl = Connection.urljoin(self.url, url) + result = self._getHttpSession().request(method, + absUrl, + data=str(data), + params=params, + headers=headers) + return result + + def httpGet(self, url='', data='', params={}, headers={}): + """ + Method for calling HTTP GET. + This will return a WebObject that has the fields returned + in JSON format by the GET operation. + """ + + reply = self.httpRequest('GET', url, data, params, headers) + return _WebObject(reply.json()) + + def httpPost(self, url='', data='', params={}, headers={}): + """ + Method for calling HTTP POST. Will return the HTTP reply. + """ + + return self.httpRequest('POST', url, data, params, headers) + + def httpPatch(self, url='', data='', params={}, headers={}): + """ + Method for calling HTTP PATCH. Will return the HTTP reply. + """ + + return self.httpRequest('PATCH', url, data, params, headers) + + def httpDelete(self, url='', data='', params={}, headers={}): + """ + Method for calling HTTP DELETE. Will return the HTTP reply. + """ + + return self.httpRequest('DELETE', url, data, params, headers) + + +def _WebObject(value): + """ + Method used for creating a wrapper object corresponding to the JSON string + received on a GET request. + """ + + if isinstance(value, dict): + result = WebObject(**value) + elif isinstance(value, list): + result = WebList(entries=value) + else: + result = value + return result + + +class WebList(list): + + """ + Using this class a JSON list will be transformed + in a list of WebObject instances. + """ + + def __init__(self, entries=[]): + """ + Create a WebList from a list of items that + are processed by the _WebObject function + """ + + for item in entries: + self.append(_WebObject(item)) + + +class WebObject(object): + + """ + A WebObject instance will have its fields set to correspond to + the JSON format received on a GET request. + """ + + def __init__(self, **entries): + """ + Create a WebObject instance by providing a dict having a + property - value structure. + """ + + self.jsonOptions = {} + for (key, value) in entries.iteritems(): + webObj = _WebObject(value) + self.jsonOptions[key] = webObj + self.__dict__[key] = webObj + + def getOptions(self): + ''' + Get the JSON dictionary which represents the WebObject Instance + ''' + + return self.jsonOptions -- cgit 1.2.3-korg