chore: wip on using test containers on examples

Author: elliottmurray

examples/e2e/run_pytest.sh

@@ -19,5 +19,4 @@ sleep 3
 
 pytest
 
-teardown()
-
+teardown()

examples/e2e/tests/broker_container.py

@@ -4,6 +4,8 @@
 import os
 import atexit
 
+from testcontainers.compose import DockerCompose
+
 import pytest
 from pact import Consumer, Like, Provider, Term, Format
 
@@ -30,6 +32,25 @@ def consumer():
         .format(host=PACT_MOCK_HOST, port=PACT_MOCK_PORT)
     )
 
+@pytest.fixture(scope='session')
+def broker(request):
+    version = request.config.getoption('--publish-pact')
+    publish = True if version else False
+
+    if not publish:
+        return
+
+    print('Starting broker')
+    with DockerCompose("../broker",
+                       compose_file_name=["docker-compose.yml"],
+                       pull=True) as compose:
+
+        stdout, stderr = compose.get_logs()
+        if stderr:
+            print("Errors\\n:{}".format(stderr))
+        print(stdout)
+        yield
+
 
 @pytest.fixture(scope='session')
 def pact(request):
@@ -43,13 +64,13 @@ def pact(request):
 
     print('start service')
     pact.start_service()
-    atexit.register(pact.stop_service)
+    # atexit.register(pact.stop_service)
 
     yield pact
     print('stop service')
     pact.stop_service()
 
-def test_get_user_non_admin(pact, consumer):
+def test_get_user_non_admin(broker, pact, consumer):
     expected = {
         'name': 'UserA',
         'id': Format().uuid,
@@ -72,7 +93,7 @@ def test_get_user_non_admin(pact, consumer):
         assert user.name == 'UserA'
 
 
-def test_get_non_existing_user(pact, consumer):
+def test_get_non_existing_user(broker, pact, consumer):
     (pact
      .given('UserA does not exist')
      .upon_receiving('a request for UserA')

examples/e2e/tests/consumer/test_user_consumer.py

@@ -2,8 +2,10 @@
 
 import logging
 import os
+from testcontainers.compose import DockerCompose
 
 from pact import Verifier
+import pytest
 
 log = logging.getLogger(__name__)
 logging.basicConfig(level=logging.INFO)
@@ -33,3 +35,17 @@ def test_get_user_non_admin():
                                          provider_states_setup_url="{}/_pact/provider_states".format(PACT_URL))
 
     assert (output == 0)
+
+
+# @pytest.fixture(scope='session')
+# def broker():
+#     print('Starting broker')
+#     with DockerCompose("../broker",
+#                        compose_file_name=["docker-compose.yml"],
+#                        pull=True) as compose:
+
+#         stdout, stderr = compose.get_logs()
+#         if stderr:
+#             print("Errors\\n:{}".format(stderr))
+#         print(stdout)
+#         yield