X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=inline;f=RO-SDN-juniper_contrail%2Fosm_rosdn_juniper_contrail%2Frest_lib.py;h=c607fea61b380ff42c09ada28916d2d12fcdc706;hb=eaccf71d78032c68f6fb4dadfc98308f007b63af;hp=31ea213b119b398d99627133cc8716f3f00e9a2e;hpb=409d5af00f8c508db5906b696831dd209a2fc633;p=osm%2FRO.git diff --git a/RO-SDN-juniper_contrail/osm_rosdn_juniper_contrail/rest_lib.py b/RO-SDN-juniper_contrail/osm_rosdn_juniper_contrail/rest_lib.py index 31ea213b..c607fea6 100644 --- a/RO-SDN-juniper_contrail/osm_rosdn_juniper_contrail/rest_lib.py +++ b/RO-SDN-juniper_contrail/osm_rosdn_juniper_contrail/rest_lib.py @@ -16,7 +16,6 @@ import copy import json -from time import time import requests from requests.exceptions import ConnectionError @@ -64,30 +63,6 @@ class ContrailHttp(object): return resp.json() - def post_headers_cmd(self, url, headers, post_fields_dict=None): - self._logger.debug("") - - # obfuscate password before logging dict - if ( - post_fields_dict.get("auth", {}) - .get("identity", {}) - .get("password", {}) - .get("user", {}) - .get("password") - ): - post_fields_dict_copy = copy.deepcopy(post_fields_dict) - post_fields_dict["auth"]["identity"]["password"]["user"][ - "password" - ] = "******" - json_data_log = post_fields_dict_copy - else: - json_data_log = post_fields_dict - - self._logger.debug("Request POSTFIELDS: {}".format(json.dumps(json_data_log))) - resp = self._request("POST_HEADERS", url, headers, data=post_fields_dict) - - return resp.text - def post_cmd(self, url, headers, post_fields_dict=None): self._logger.debug("") @@ -118,34 +93,6 @@ class ContrailHttp(object): return resp.text - def _get_token(self, headers): - if self.auth_url: - self._logger.debug("Current Token: {}".format(self.token)) - auth_url = self.auth_url + "auth/tokens" - - if self.token is None or self._token_expired(): - if not self.auth_url: - self.token = "" - - resp = self._request_noauth( - url=auth_url, op="POST", headers=headers, data=self.auth_dict - ) - self.token = resp.headers.get("x-subject-token") - self.last_token_time = time.time() - self._logger.debug("Obtained token: {}".format(self.token)) - - return self.token - - def _token_expired(self): - current_time = time.time() - - if self.last_token_time and ( - current_time - self.last_token_time < self.token_timeout - ): - return False - else: - return True - def _request(self, op, url, http_headers, data=None, retry_auth_error=True): headers = http_headers.copy() @@ -162,9 +109,7 @@ class ContrailHttp(object): except AuthError: # If there is an auth error retry just once if retry_auth_error: - return self._request( - self, op, url, headers, data, retry_auth_error=False - ) + return self._request(op, url, headers, data, retry_auth_error=False) def _request_noauth(self, op, url, headers, data=None): # Method to execute http requests with error control