e43e7e7101
Since the default engine used by the new sqlalchemy driver is sqlite, it doesn't make sense to keep the sqlite driver around. This patch replaces all usages of `sqlite` with `sqlalchemy`. Although sqlite is being deprecated, the patch keeps the entry point for backwards compatibility so that environments currently using the sqlite backend won't be suddenly broken. Implement blueprint: sql-storage-driver Change-Id: Ib7e32fa56ab0c6621dc9a888feb6b0e4981b4e91
96 lines
3.2 KiB
Python
96 lines
3.2 KiB
Python
# Copyright (c) 2013 Rackspace, 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 json
|
|
import uuid
|
|
|
|
import falcon
|
|
|
|
from marconi.tests.queues.transport.wsgi import base
|
|
|
|
|
|
class ValidationTest(base.TestBase):
|
|
|
|
config_file = 'wsgi_sqlalchemy_validation.conf'
|
|
|
|
def setUp(self):
|
|
super(ValidationTest, self).setUp()
|
|
|
|
self.project_id = '7e55e1a7e'
|
|
|
|
# NOTE(kgriffs): ATM, validation logic does not key off
|
|
# the API version. Therefore, we just pick '/v1' arbitrarily
|
|
# as the url prefix.
|
|
self.queue_path = '/v1/queues/noein'
|
|
|
|
self.simulate_put(self.queue_path, self.project_id)
|
|
|
|
self.headers = {
|
|
'Client-ID': str(uuid.uuid4()),
|
|
}
|
|
|
|
def tearDown(self):
|
|
self.simulate_delete(self.queue_path, self.project_id)
|
|
super(ValidationTest, self).tearDown()
|
|
|
|
def test_metadata_deserialization(self):
|
|
# Normal case
|
|
self.simulate_put(self.queue_path + '/metadata',
|
|
self.project_id,
|
|
body='{"timespace": "Shangri-la"}')
|
|
|
|
self.assertEqual(self.srmock.status, falcon.HTTP_204)
|
|
|
|
# Too long
|
|
max_queue_metadata = 64
|
|
|
|
doc_tmpl = '{{"Dragon Torc":"{0}"}}'
|
|
doc_tmpl_ws = '{{ "Dragon Torc" : "{0}" }}' # with whitespace
|
|
envelope_length = len(doc_tmpl.format(''))
|
|
|
|
for tmpl in doc_tmpl, doc_tmpl_ws:
|
|
gen = '0' * (max_queue_metadata - envelope_length + 1)
|
|
doc = tmpl.format(gen)
|
|
self.simulate_put(self.queue_path + '/metadata',
|
|
self.project_id,
|
|
body=doc)
|
|
|
|
self.assertEqual(self.srmock.status, falcon.HTTP_400)
|
|
|
|
def test_message_deserialization(self):
|
|
# Normal case
|
|
self.simulate_post(self.queue_path + '/messages',
|
|
self.project_id,
|
|
body='[{"body": "Dragon Knights", "ttl": 100}]',
|
|
headers=self.headers)
|
|
|
|
self.assertEqual(self.srmock.status, falcon.HTTP_201)
|
|
|
|
# Both messages' size are too long
|
|
max_message_size = 256
|
|
|
|
obj = {'a': 0, 'b': ''}
|
|
envelope_length = len(json.dumps(obj, separators=(',', ':')))
|
|
obj['b'] = 'x' * (max_message_size - envelope_length + 1)
|
|
|
|
for long_body in ('a' * (max_message_size - 2 + 1), obj):
|
|
doc = json.dumps([{'body': long_body, 'ttl': 100}])
|
|
self.simulate_post(self.queue_path + '/messages',
|
|
self.project_id,
|
|
body=doc,
|
|
headers=self.headers)
|
|
|
|
self.assertEqual(self.srmock.status, falcon.HTTP_400)
|