Commit b9d9c26a authored by Jérome Perrin's avatar Jérome Perrin

ERP5Type/tests: support Zope4's Testing.makerequest.makerequest

On Zope2, there was support for starting a ZServer (in
Testing.ZopeTestCase.utils.startZServer) and there was another makerequest
(in Testing.ZopeTestCase.utils.makerequest) which had knowledge of this
ZServer address. We are using our own implementation of startZServer,
which also knows how to start a WSGI server, but we we were interacting
with Testing.ZopeTestCase.utils so that its makerequest knows about
our web server.

On Zope4 there is no utility to start an http server from the tests and
the makerequest is also gone.

This revisits the web server from test interaction with makerequest:
 - no longer use PortalTestCase._app which creates an app with a request
   to http://nohost, but implement our own _app which creates a request
   to our web server
  - store our server address as class attributes on ProcessingNodeTestCase
   instead of patching pseudo constants in utils (these pseudo constants
   no longer exist)
  - in the case of ERP5TypeLiveTestCase, also rewrap the site to use a
  request to our web server (which was done on Zope2 by using
  Testing.ZopeTestCase.utils.makerequest and not
  Testing.makerequest.makerequest directly)
parent 9f5d5640
...@@ -89,12 +89,20 @@ class ERP5TypeLiveTestCase(ERP5TypeTestCaseMixin): ...@@ -89,12 +89,20 @@ class ERP5TypeLiveTestCase(ERP5TypeTestCaseMixin):
site = getSite() site = getSite()
# reconstruct the acquistion chain with an independant request. # reconstruct the acquistion chain with an independant request.
# RequestContainer -> Application -> Site # RequestContainer -> Application -> Site
from Testing.ZopeTestCase.utils import makerequest from Testing.makerequest import makerequest
environ = {}
if self._server_address:
host, port = self._server_address
environ={
'SERVER_NAME': host,
'SERVER_PORT': port,
}
portal = getattr( portal = getattr(
makerequest(aq_base(site.aq_parent)), makerequest(aq_base(site.aq_parent), environ=environ),
site.getId()) site.getId())
# Make the various get_request patches return this request. # Make the various get_request patches return this request.
# TODO: check this is still needed
# This is for ERP5TypeTestCase patch # This is for ERP5TypeTestCase patch
from Testing.ZopeTestCase.connections import registry from Testing.ZopeTestCase.connections import registry
if registry: if registry:
......
...@@ -57,7 +57,8 @@ getRequest.__code__ = (lambda: get_request()).__code__ ...@@ -57,7 +57,8 @@ getRequest.__code__ = (lambda: get_request()).__code__
from zope.site.hooks import setSite from zope.site.hooks import setSite
from Testing import ZopeTestCase from Testing import ZopeTestCase
from Testing.ZopeTestCase import PortalTestCase, user_name from Testing.makerequest import makerequest
from Testing.ZopeTestCase import PortalTestCase, user_name, ZopeLite
from Products.ERP5Type.Core.Workflow import ValidationFailed from Products.ERP5Type.Core.Workflow import ValidationFailed
from Products.PythonScripts.PythonScript import PythonScript from Products.PythonScripts.PythonScript import PythonScript
from Products.ERP5Type.Accessor.Constant import PropertyGetter as ConstantGetter from Products.ERP5Type.Accessor.Constant import PropertyGetter as ConstantGetter
...@@ -1032,9 +1033,25 @@ class ERP5TypeCommandLineTestCase(ERP5TypeTestCaseMixin): ...@@ -1032,9 +1033,25 @@ class ERP5TypeCommandLineTestCase(ERP5TypeTestCaseMixin):
def _app(self): def _app(self):
'''Opens a ZODB connection and returns the app object. '''Opens a ZODB connection and returns the app object.
We override it to patch HTTP_ACCEPT_CHARSET into REQUEST to get the zpt We override this method so that the request knows about the address of
unicode conflict resolver to work properly''' our http server and also to set HTTP_ACCEPT_CHARSET set in REQUEST, to
app = PortalTestCase._app(self) get the zpt unicode conflict resolver to
work properly.
We reimplement PortalTestCase._app instead of calling it, because it
opens a ZODB connection and wrap the root object a request to
http://nohost, but we prefer to create directly a connection to the
app wrapped in a request to our web server.
'''
app = ZopeLite.app()
environ = {}
if self._server_address:
host, port = self._server_address
environ['SERVER_NAME'] = host
environ['SERVER_PORT'] = port
app = makerequest(app, environ=environ)
registry.register(app)
app.REQUEST['HTTP_ACCEPT_CHARSET'] = 'utf-8' app.REQUEST['HTTP_ACCEPT_CHARSET'] = 'utf-8'
return app return app
......
...@@ -6,11 +6,6 @@ from UserDict import IterableUserDict ...@@ -6,11 +6,6 @@ from UserDict import IterableUserDict
import Lifetime import Lifetime
import transaction import transaction
from Testing import ZopeTestCase from Testing import ZopeTestCase
try:
from Testing.makerequest import _Z2HOST # XXX only on Zope4
from Testing import makerequest as utils
except: # BBB Zope 2.12
from Testing.ZopeTestCase import utils
from ZODB.POSException import ConflictError from ZODB.POSException import ConflictError
from zLOG import LOG, ERROR from zLOG import LOG, ERROR
from Products.CMFActivity.Activity.Queue import VALIDATION_ERROR_DELAY from Products.CMFActivity.Activity.Queue import VALIDATION_ERROR_DELAY
...@@ -143,6 +138,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase): ...@@ -143,6 +138,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase):
the node running the unit tests to tell other nodes on which portal activities the node running the unit tests to tell other nodes on which portal activities
should be processed. should be processed.
""" """
_server_address = None # (host, port) of the http server if it was started, None otherwise
@staticmethod @staticmethod
def asyncore_loop(): def asyncore_loop():
...@@ -154,7 +150,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase): ...@@ -154,7 +150,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase):
def startZServer(self, verbose=False): def startZServer(self, verbose=False):
"""Start HTTP ZServer in background""" """Start HTTP ZServer in background"""
if utils._Z2HOST is None: if self._server_address is None:
from Products.ERP5Type.tests.runUnitTest import log_directory from Products.ERP5Type.tests.runUnitTest import log_directory
log = os.path.join(log_directory, "Z2.log") log = os.path.join(log_directory, "Z2.log")
message = "Running %s server at %s:%s\n" message = "Running %s server at %s:%s\n"
...@@ -196,7 +192,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase): ...@@ -196,7 +192,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase):
logger.propagate = False logger.propagate = False
hs = createServer(app_wrapper(webdav_ports=webdav_ports), hs = createServer(app_wrapper(webdav_ports=webdav_ports),
logger, sockets=sockets) logger, sockets=sockets)
utils._Z2HOST, utils._Z2PORT = hs.addr ProcessingNodeTestCase._server_address = hs.addr
t = Thread(target=hs.run) t = Thread(target=hs.run)
t.setDaemon(1) t.setDaemon(1)
t.start() t.start()
...@@ -208,7 +204,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase): ...@@ -208,7 +204,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase):
except RuntimeError as e: except RuntimeError as e:
ZopeTestCase._print(str(e)) ZopeTestCase._print(str(e))
else: else:
utils._Z2HOST, utils._Z2PORT = hs.server_name, hs.server_port ProcessingNodeTestCase._server_address = hs.server_name, hs.server_port
_print(hs) _print(hs)
try: try:
_print(createZServer(log, zserver_type='webdav')) _print(createZServer(log, zserver_type='webdav'))
...@@ -224,7 +220,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase): ...@@ -224,7 +220,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase):
if ActivityTool.currentNode == ActivityTool._server_address: if ActivityTool.currentNode == ActivityTool._server_address:
ActivityTool.currentNode = None ActivityTool.currentNode = None
ActivityTool._server_address = None ActivityTool._server_address = None
return utils._Z2HOST, utils._Z2PORT return self._server_address
def _registerNode(self, distributing, processing): def _registerNode(self, distributing, processing):
"""Register node to process and/or distribute activities""" """Register node to process and/or distribute activities"""
...@@ -245,7 +241,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase): ...@@ -245,7 +241,7 @@ class ProcessingNodeTestCase(ZopeTestCase.TestCase):
@classmethod @classmethod
def unregisterNode(cls): def unregisterNode(cls):
if utils._Z2HOST is not None: if cls._server_address is not None:
self = cls('unregisterNode') self = cls('unregisterNode')
self.app = self._app() self.app = self._app()
self._registerNode(distributing=0, processing=0) self._registerNode(distributing=0, processing=0)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment