spacepaste

Paste details

reply | raw

  1.  
  2. """ Implements various cloud servers simultaneously.
  4. Currently implements two servers:
  6. 1) DeviceHTTPServer: The IoT device uploads data to the cloud via this HTTP
  7. server.
  9. 2) WebPortalHTTPServer: A server for a user to access using a web browser
  10. to see data from the IoT device.
  12. All data is received from IoT devices and appended to a perpetually growing
  13. list. When a user browses to the web portal, they are presented with all of
  14. the data received so far.
  15. """
  17. """
  18. # GDB code to pause on ctrl+c
  19. # http://stackoverflow.com/questions/10239760/interrupt-pause-running-python-program-in-pdb
  20. def debug_signal_handler(signal, frame):
  21. import pdb
  22. pdb.set_trace()
  23. import signal
  24. signal.signal(signal.SIGINT, debug_signal_handler)
  25. """
  27. import OpenSSL
  28. import sys
  29. from twisted.internet import endpoints, reactor, ssl
  30. from twisted.python import log
  31. from twisted.python.modules import getModule
  32. from twisted.web import resource, server
  35. PORT_DEVICE_UPLOAD = 5555
  36. PORT_WEB_PORTAL = 5556
  39. # All temperature readings received from IoT device connections.
  40. temperature_readings = []
  43. class DeviceHTTPServer(resource.Resource):
  44. """ HTTP Server for IoT device to upload data.
  46. Stores response bodies in global list variable temperature_readings.
  47. """
  49. isLeaf = True
  51. def render_POST(self, request):
  52. print "Received something"
  53. #for header in request.responseHeaders.getAllRawHeaders():
  54. # request.responseHeaders.removeHeader(header[0])
  55. reading = request.content.read()
  56. print "Received:", reading
  57. temperature_readings.append(reading)
  58. return "" # Empty response
  61. class WebPortalHTTPServer(resource.Resource):
  62. """ HTTP Server for users to browse.
  64. Currently prints out all the data received so far from devices.
  65. """
  67. isLeaf = True
  69. def render_GET(self, request):
  70. # Print all of the readings so far.
  71. return ("<HTML><BODY>"
  72. + ''.join([str(t) for t in temperature_readings])
  73. + "</BODY></HTML>")
  76. log.startLogging(sys.stdout)
  78. # DeviceSite - The site the device connects to
  80. deviceSite = server.Site(DeviceHTTPServer())
  82. #endpoint = endpoints.TCP4ServerEndpoint(reactor, PORT_DEVICE_UPLOAD)
  83. #endpoint = endpoints.serverFromString(reactor,
  84. # "ssl:port=%d"
  85. # ":privateKey=certs/middlebox.key"
  86. # ":certKey=certs/middlebox.crt"
  87. # ":extraCertChain=certs/ca_send_chain.crt"
  88. # ":sslmethod=TLSv1_2_METHOD"
  89. # % (PORT_DEVICE_UPLOAD,))
  90. #endpoint.listen(deviceSite)
  92. def load_cert(file_name):
  93. filepath = getModule(__name__).filePath
  94. data = filepath.sibling('certs').child(file_name).getContent()
  95. return OpenSSL.crypto.load_certificate(OpenSSL.crypto.FILETYPE_PEM, data)
  97. def load_key(file_name):
  98. filepath = getModule(__name__).filePath
  99. data = filepath.sibling('certs').child(file_name).getContent()
  100. return OpenSSL.crypto.load_privatekey(OpenSSL.crypto.FILETYPE_PEM, data)
  102. client_cert = load_cert('client_for_server.crt')
  103. server_cert = load_cert('server.crt')
  104. server_key = load_key('server.key')
  105. chain_filenames = ['ca-int1.crt', 'ca-int2.crt']
  106. chain_certs = [load_cert(filename) for filename in chain_filenames]
  108. reactor.listenSSL(PORT_DEVICE_UPLOAD, deviceSite,
  109. ssl.CertificateOptions(privateKey=server_key,
  110. certificate=server_cert,
  111. extraCertChain=chain_certs,
  112. method=OpenSSL.SSL.TLSv1_2_METHOD,
  113. # verify=True,
  114. # requireCertificate=True,
  115. # caCerts=[client_cert]
  116. )
  117. )
  119. # PortalSite - The web site for browsers
  121. portalSite = server.Site(WebPortalHTTPServer())
  122. endpoint = endpoints.TCP4ServerEndpoint(reactor, PORT_WEB_PORTAL)
  123. endpoint.listen(portalSite)
  125. reactor.run()
  126.  
Powered by spacepaste. Paste removal.