08-ssl-connect-cert-auth-enc.py 1.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. #!/usr/bin/env python3
  2. # Test whether a client produces a correct connect and subsequent disconnect when using SSL.
  3. # Client must provide a certificate.
  4. # The client should connect to port 1888 with keepalive=60, clean session set,
  5. # and client id 08-ssl-connect-crt-auth
  6. # It should use the CA certificate ssl/test-root-ca.crt for verifying the server.
  7. # The test will send a CONNACK message to the client with rc=0. Upon receiving
  8. # the CONNACK and verifying that rc=0, the client should send a DISCONNECT
  9. # message. If rc!=0, the client should exit with an error.
  10. from mosq_test_helper import *
  11. port = mosq_test.get_lib_port()
  12. if sys.version < '2.7':
  13. print("WARNING: SSL not supported on Python 2.6")
  14. exit(0)
  15. rc = 1
  16. keepalive = 60
  17. connect_packet = mosq_test.gen_connect("08-ssl-connect-crt-auth-enc", keepalive=keepalive)
  18. connack_packet = mosq_test.gen_connack(rc=0)
  19. disconnect_packet = mosq_test.gen_disconnect()
  20. sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  21. sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
  22. ssock = ssl.wrap_socket(sock, ca_certs="../ssl/all-ca.crt",
  23. keyfile="../ssl/server.key", certfile="../ssl/server.crt",
  24. server_side=True, cert_reqs=ssl.CERT_REQUIRED)
  25. ssock.settimeout(10)
  26. ssock.bind(('', port))
  27. ssock.listen(5)
  28. client_args = sys.argv[1:]
  29. env = dict(os.environ)
  30. env['LD_LIBRARY_PATH'] = '../../lib:../../lib/cpp'
  31. try:
  32. pp = env['PYTHONPATH']
  33. except KeyError:
  34. pp = ''
  35. env['PYTHONPATH'] = '../../lib/python:'+pp
  36. client = mosq_test.start_client(filename=sys.argv[1].replace('/', '-'), cmd=client_args, env=env, port=port)
  37. try:
  38. (conn, address) = ssock.accept()
  39. conn.settimeout(10)
  40. mosq_test.do_receive_send(conn, connect_packet, connack_packet, "connect")
  41. mosq_test.expect_packet(conn, "disconnect", disconnect_packet)
  42. rc = 0
  43. conn.close()
  44. except mosq_test.TestError:
  45. pass
  46. finally:
  47. client.terminate()
  48. client.wait()
  49. ssock.close()
  50. exit(rc)