diff options
author | Gary Wu <gary.i.wu@huawei.com> | 2018-10-23 14:41:11 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2018-10-23 14:41:11 +0000 |
commit | 37e3c0b51e55f84d4f9838c42b7433f2554632ee (patch) | |
tree | d81e3feead4508a1dae42047e69530faf5c2da01 /tests/dcaegen2/prh-testcases/resources/simulator/httpServerLib.py | |
parent | 5d59d1bf48fa2f0fbd433e8b25a207d62ddf8d22 (diff) | |
parent | e416584e6f4acdc0ea3351add5d4bc08a5476af3 (diff) |
Merge "tests for ssl connection for PRH, AAI and DmaaP"
Diffstat (limited to 'tests/dcaegen2/prh-testcases/resources/simulator/httpServerLib.py')
-rw-r--r-- | tests/dcaegen2/prh-testcases/resources/simulator/httpServerLib.py | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/tests/dcaegen2/prh-testcases/resources/simulator/httpServerLib.py b/tests/dcaegen2/prh-testcases/resources/simulator/httpServerLib.py new file mode 100644 index 00000000..dcfdb7ca --- /dev/null +++ b/tests/dcaegen2/prh-testcases/resources/simulator/httpServerLib.py @@ -0,0 +1,34 @@ +import _thread +import ssl +from http.server import HTTPServer + + +def header_200_and_json(self): + self.send_response(200) + self.send_header('Content-Type', 'application/json') + self.end_headers() + + +def start_http_endpoint(port, handler_class): + _thread.start_new_thread(init_http_endpoints, (port, handler_class)) + + +def start_https_endpoint(port, handler_class, keyfile="certs/server.key", + certfile="certs/server.crt", ca_certs="certs/client.crt"): + _thread.start_new_thread(init_https_endpoints, (port, handler_class, keyfile, certfile, ca_certs)) + + +def init_http_endpoints(port, handler_class, server_class=HTTPServer): + server = server_class(('', port), handler_class) + sa = server.socket.getsockname() + print("Serving HTTP on", sa[0], "port", sa[1], "for", handler_class, "...") + server.serve_forever() + + +def init_https_endpoints(port, handler_class, keyfile, certfile, ca_certs, server_class=HTTPServer): + server = server_class(('', port), handler_class) + server.socket = ssl.wrap_socket(server.socket, keyfile=keyfile, certfile=certfile, + ca_certs=ca_certs, server_side=True) + sa = server.socket.getsockname() + print("Serving HTTPS on", sa[0], "port", sa[1], "for", handler_class, "...") + server.serve_forever() |