
On running mistral API with SSL, the client SSL options such as cacert and insecure are only passed to the authentication request and are not passed to the mistral client and mistral API subsequently. Change-Id: I35d013c468977fc3df578afcacc7f7a5cc3173c6 Closes-Bug: #1552030
257 lines
6.7 KiB
Python
257 lines
6.7 KiB
Python
# Copyright 2016 - StackStorm, Inc.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
|
|
import copy
|
|
import uuid
|
|
|
|
import mock
|
|
import requests
|
|
import testtools
|
|
|
|
from mistralclient.api import httpclient
|
|
|
|
API_BASE_URL = 'http://localhost:8989/v2'
|
|
API_URL = '/executions'
|
|
|
|
EXPECTED_URL = API_BASE_URL + API_URL
|
|
|
|
AUTH_TOKEN = str(uuid.uuid4())
|
|
PROJECT_ID = str(uuid.uuid4())
|
|
USER_ID = str(uuid.uuid4())
|
|
|
|
EXPECTED_AUTH_HEADERS = {
|
|
'x-auth-token': AUTH_TOKEN,
|
|
'X-Project-Id': PROJECT_ID,
|
|
'X-User-Id': USER_ID
|
|
}
|
|
|
|
EXPECTED_REQ_OPTIONS = {
|
|
'headers': EXPECTED_AUTH_HEADERS
|
|
}
|
|
|
|
EXPECTED_BODY = {
|
|
'k1': 'abc',
|
|
'k2': 123,
|
|
'k3': True
|
|
}
|
|
|
|
|
|
class FakeRequest(object):
|
|
|
|
def __init__(self, method):
|
|
self.method = method
|
|
|
|
|
|
class FakeResponse(object):
|
|
|
|
def __init__(self, method, url, status_code):
|
|
self.request = FakeRequest(method)
|
|
self.url = url
|
|
self.status_code = status_code
|
|
|
|
|
|
class HTTPClientTest(testtools.TestCase):
|
|
|
|
def setUp(self):
|
|
super(HTTPClientTest, self).setUp()
|
|
self.client = httpclient.HTTPClient(
|
|
API_BASE_URL,
|
|
AUTH_TOKEN,
|
|
PROJECT_ID,
|
|
USER_ID
|
|
)
|
|
|
|
@mock.patch.object(
|
|
requests,
|
|
'get',
|
|
mock.MagicMock(return_value=FakeResponse('get', EXPECTED_URL, 200))
|
|
)
|
|
def test_get_request_options(self):
|
|
self.client.get(API_URL)
|
|
|
|
requests.get.assert_called_with(
|
|
EXPECTED_URL,
|
|
**EXPECTED_REQ_OPTIONS
|
|
)
|
|
|
|
@mock.patch.object(
|
|
requests,
|
|
'get',
|
|
mock.MagicMock(return_value=FakeResponse('get', EXPECTED_URL, 200))
|
|
)
|
|
def test_get_request_options_with_headers_for_get(self):
|
|
headers = {'foo': 'bar'}
|
|
|
|
self.client.get(API_URL, headers=headers)
|
|
|
|
expected_options = copy.deepcopy(EXPECTED_REQ_OPTIONS)
|
|
expected_options['headers'].update(headers)
|
|
|
|
requests.get.assert_called_with(
|
|
EXPECTED_URL,
|
|
**expected_options
|
|
)
|
|
|
|
@mock.patch.object(
|
|
requests,
|
|
'post',
|
|
mock.MagicMock(return_value=FakeResponse('post', EXPECTED_URL, 201))
|
|
)
|
|
def test_get_request_options_with_headers_for_post(self):
|
|
headers = {'foo': 'bar'}
|
|
|
|
self.client.post(API_URL, EXPECTED_BODY, headers=headers)
|
|
|
|
expected_options = copy.deepcopy(EXPECTED_REQ_OPTIONS)
|
|
expected_options['headers'].update(headers)
|
|
expected_options['headers']['content-type'] = 'application/json'
|
|
|
|
requests.post.assert_called_with(
|
|
EXPECTED_URL,
|
|
EXPECTED_BODY,
|
|
**expected_options
|
|
)
|
|
|
|
@mock.patch.object(
|
|
requests,
|
|
'put',
|
|
mock.MagicMock(return_value=FakeResponse('put', EXPECTED_URL, 200))
|
|
)
|
|
def test_get_request_options_with_headers_for_put(self):
|
|
headers = {'foo': 'bar'}
|
|
|
|
self.client.put(API_URL, EXPECTED_BODY, headers=headers)
|
|
|
|
expected_options = copy.deepcopy(EXPECTED_REQ_OPTIONS)
|
|
expected_options['headers'].update(headers)
|
|
expected_options['headers']['content-type'] = 'application/json'
|
|
|
|
requests.put.assert_called_with(
|
|
EXPECTED_URL,
|
|
EXPECTED_BODY,
|
|
**expected_options
|
|
)
|
|
|
|
@mock.patch.object(
|
|
requests,
|
|
'delete',
|
|
mock.MagicMock(return_value=FakeResponse('delete', EXPECTED_URL, 200))
|
|
)
|
|
def test_get_request_options_with_headers_for_delete(self):
|
|
headers = {'foo': 'bar'}
|
|
|
|
self.client.delete(API_URL, headers=headers)
|
|
|
|
expected_options = copy.deepcopy(EXPECTED_REQ_OPTIONS)
|
|
expected_options['headers'].update(headers)
|
|
|
|
requests.delete.assert_called_with(
|
|
EXPECTED_URL,
|
|
**expected_options
|
|
)
|
|
|
|
@mock.patch.object(
|
|
httpclient.HTTPClient,
|
|
'_get_request_options',
|
|
mock.MagicMock(return_value=copy.deepcopy(EXPECTED_REQ_OPTIONS))
|
|
)
|
|
@mock.patch.object(
|
|
requests,
|
|
'get',
|
|
mock.MagicMock(return_value=FakeResponse('get', EXPECTED_URL, 200))
|
|
)
|
|
def test_http_get(self):
|
|
self.client.get(API_URL)
|
|
|
|
httpclient.HTTPClient._get_request_options.assert_called_with(
|
|
'get',
|
|
None
|
|
)
|
|
|
|
requests.get.assert_called_with(
|
|
EXPECTED_URL,
|
|
**EXPECTED_REQ_OPTIONS
|
|
)
|
|
|
|
@mock.patch.object(
|
|
httpclient.HTTPClient,
|
|
'_get_request_options',
|
|
mock.MagicMock(return_value=copy.deepcopy(EXPECTED_REQ_OPTIONS))
|
|
)
|
|
@mock.patch.object(
|
|
requests,
|
|
'post',
|
|
mock.MagicMock(return_value=FakeResponse('post', EXPECTED_URL, 201))
|
|
)
|
|
def test_http_post(self):
|
|
self.client.post(API_URL, EXPECTED_BODY)
|
|
|
|
httpclient.HTTPClient._get_request_options.assert_called_with(
|
|
'post',
|
|
None
|
|
)
|
|
|
|
requests.post.assert_called_with(
|
|
EXPECTED_URL,
|
|
EXPECTED_BODY,
|
|
**EXPECTED_REQ_OPTIONS
|
|
)
|
|
|
|
@mock.patch.object(
|
|
httpclient.HTTPClient,
|
|
'_get_request_options',
|
|
mock.MagicMock(return_value=copy.deepcopy(EXPECTED_REQ_OPTIONS))
|
|
)
|
|
@mock.patch.object(
|
|
requests,
|
|
'put',
|
|
mock.MagicMock(return_value=FakeResponse('put', EXPECTED_URL, 200))
|
|
)
|
|
def test_http_put(self):
|
|
self.client.put(API_URL, EXPECTED_BODY)
|
|
|
|
httpclient.HTTPClient._get_request_options.assert_called_with(
|
|
'put',
|
|
None
|
|
)
|
|
|
|
requests.put.assert_called_with(
|
|
EXPECTED_URL,
|
|
EXPECTED_BODY,
|
|
**EXPECTED_REQ_OPTIONS
|
|
)
|
|
|
|
@mock.patch.object(
|
|
httpclient.HTTPClient,
|
|
'_get_request_options',
|
|
mock.MagicMock(return_value=copy.deepcopy(EXPECTED_REQ_OPTIONS))
|
|
)
|
|
@mock.patch.object(
|
|
requests,
|
|
'delete',
|
|
mock.MagicMock(return_value=FakeResponse('delete', EXPECTED_URL, 200))
|
|
)
|
|
def test_http_delete(self):
|
|
self.client.delete(API_URL)
|
|
|
|
httpclient.HTTPClient._get_request_options.assert_called_with(
|
|
'delete',
|
|
None
|
|
)
|
|
|
|
requests.delete.assert_called_with(
|
|
EXPECTED_URL,
|
|
**EXPECTED_REQ_OPTIONS
|
|
)
|