diff options
author | Andrei Zeliankou <zelenkov@nginx.com> | 2021-02-15 03:11:26 +0000 |
---|---|---|
committer | Andrei Zeliankou <zelenkov@nginx.com> | 2021-02-15 03:11:26 +0000 |
commit | cf530e19bc5cc0de67bd57a650a0adf3d58e0881 (patch) | |
tree | 98406b3c6d96b6582615d503652a9d7e05211957 | |
parent | 11f7d833a9bad1fb3f066cee815fe9772bed4875 (diff) | |
download | unit-cf530e19bc5cc0de67bd57a650a0adf3d58e0881.tar.gz unit-cf530e19bc5cc0de67bd57a650a0adf3d58e0881.tar.bz2 |
Tests: clear certificates after each test.
Diffstat (limited to '')
-rw-r--r-- | test/conftest.py | 37 |
1 files changed, 29 insertions, 8 deletions
diff --git a/test/conftest.py b/test/conftest.py index 35249a1f..b49fb377 100644 --- a/test/conftest.py +++ b/test/conftest.py @@ -185,7 +185,7 @@ def pytest_sessionstart(session): check_isolation() - assert 'success' in _clear_conf(unit['temp_dir'] + '/control.unit.sock') + _clear_conf(unit['temp_dir'] + '/control.unit.sock') unit_stop() @@ -281,11 +281,7 @@ def run(request): # clean temp_dir before the next test if not option.restart: - conf_resp = _clear_conf(unit['temp_dir'] + '/control.unit.sock') - - if 'success' not in conf_resp: - _print_log(log) - assert 'success' in conf_resp + _clear_conf(unit['temp_dir'] + '/control.unit.sock', log) open(unit['log'], 'w').close() @@ -457,14 +453,39 @@ def _print_log(data=None): sys.stdout.write(data) -def _clear_conf(sock): - return http.put( +def _clear_conf(sock, log=None): + def check_success(resp): + if 'success' not in resp: + _print_log(log) + assert 'success' in resp + + resp = http.put( url='/config', sock_type='unix', addr=sock, body=json.dumps({"listeners": {}, "applications": {}}), )['body'] + check_success(resp) + + try: + certs = json.loads(http.get( + url='/certificates', + sock_type='unix', + addr=sock, + )['body']).keys() + + except json.JSONDecodeError: + pytest.fail('Can\'t parse certificates list.') + + for cert in certs: + resp = http.delete( + url='/certificates/' + cert, + sock_type='unix', + addr=sock, + )['body'] + + check_success(resp) def run_process(target, *args): global _processes |