08-ssl-connect-no-auth.py 1.8 KB

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