2
0

server.py 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121
  1. #!/usr/bin/python
  2. # -*- coding: utf-8 -*-
  3. from __future__ import print_function
  4. from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
  5. from storage import Storage
  6. import json
  7. import re
  8. class BatcaveHttpRequestHandler(BaseHTTPRequestHandler):
  9. def do_GET(self):
  10. url = self.path
  11. if url == '/':
  12. self.respond_index()
  13. return
  14. if url == '/list':
  15. self.respond_list()
  16. return
  17. m = re.match(r'^/node/([a-f0-9]{12})\.json$', url)
  18. if m != None:
  19. self.respond_node(m.group(1))
  20. return
  21. self.send_error(404, 'The URL \'{0}\' was not found here.'.format(url))
  22. def send_nocache_headers(self):
  23. self.send_header('Cache-Control', 'no-cache, no-store, must-revalidate')
  24. self.send_header('Pragma', 'no-cache')
  25. self.send_header('Expires', '0')
  26. def respond_index(self):
  27. storage = self.server.storage
  28. self.send_response(200)
  29. self.send_header('Content-Type', 'text/html; charset=utf-8')
  30. self.send_nocache_headers()
  31. self.end_headers()
  32. self.wfile.write('<!DOCTYPE html><html><head><title>BATCAVE</title></head>\n')
  33. self.wfile.write('<body>\n')
  34. self.wfile.write('<H1 title="Batman/Alfred Transmission Collection, Aggregation & Value Engine">BATCAVE</H1>\n')
  35. self.wfile.write('<p>Dies ist ein interner Hintergrund-Dienst. Er wird nur von anderen Diensten\n')
  36. self.wfile.write('angesprochen und sollte aus einer Mehrzahl von Gr&uuml;nden nicht &ouml;ffentlich\n')
  37. self.wfile.write('zug&auml;nglich sein.</p>\n')
  38. self.wfile.write('<H2>Status</H2>\n')
  39. self.wfile.write('Daten: <span id="datacount" class="value">')
  40. self.wfile.write(len(storage.data))
  41. self.wfile.write('</span>\n')
  42. self.wfile.write('<H2>API</H2>\n')
  43. self.wfile.write('<p>Grundsätzlich ist das Antwort-Format JSON und alle Daten sind Live-Daten (kein Cache) die ggf. etwas Bearbeitungs-Zeit erfordern.</p>')
  44. self.wfile.write('<dl>\n')
  45. self.wfile.write('<dt><a href="/nodes.json">nodes.json</a></dt><dd>zur Verwendung mit ffmap (MACs anonymisiert)</dd>\n')
  46. self.wfile.write('<dt><a href="/node/ff00ff00ff00.json">/node/&lt;id&gt;.json</a></dt><dd><u>alle</u> vorhandenen Information zu der gewünschten Node</dd>\n')
  47. self.wfile.write('</dl>\n')
  48. self.wfile.write('</body></html>')
  49. def respond_list(self):
  50. storage = self.server.storage
  51. self.send_response(200)
  52. self.send_header('Content-Type', 'text/html')
  53. self.send_nocache_headers()
  54. self.end_headers()
  55. self.wfile.write('<!DOCTYPE html><html><head><title>BATCAVE</title></head>\n')
  56. self.wfile.write('<body>\n')
  57. self.wfile.write('<H1>BATCAVE - LIST</H1>\n')
  58. self.wfile.write('<table>\n')
  59. self.wfile.write('<thead><tr><th>ID</th><th>Name</th></tr></thead>\n')
  60. self.wfile.write('<tbody>\n')
  61. for nodeid in storage.data:
  62. nodename = storage.data[nodeid]['hostname'] if 'hostname' in storage.data[nodeid] else '&lt;?&gt;'
  63. self.wfile.write('<tr><td><a href="/node/' + nodeid + '.json">' + nodeid + '</a></td><td>' + nodename + '</td></tr>')
  64. self.wfile.write('</tbody>\n')
  65. self.wfile.write('</table>\n')
  66. def respond_node(self, nodeid):
  67. storage = self.server.storage
  68. if nodeid == 'ff00ff00ff00':
  69. self.send_response(200)
  70. self.send_header('Content-Type', 'text/json')
  71. self.send_nocache_headers()
  72. self.end_headers()
  73. self.wfile.write(json.dumps({
  74. 'name': 'API-Example',
  75. 'nodeid': nodeid,
  76. 'META': 'Dies ist ein minimaler Beispiel-Datensatz. Herzlichen Glückwunsch, du hast das Prinzip der API kapiert.',
  77. }))
  78. return
  79. if not nodeid in storage.data:
  80. self.send_error(404, 'No node with id \'' + nodeid + '\' present.')
  81. return
  82. self.send_response(200)
  83. self.send_header('Content-Type', 'text/json')
  84. self.send_nocache_headers()
  85. self.end_headers()
  86. self.wfile.write(json.dumps(storage.data[nodeid]))
  87. class ApiServer(HTTPServer):
  88. def __init__(self, endpoint, storage):
  89. HTTPServer.__init__(self, endpoint, BatcaveHttpRequestHandler)
  90. self.storage = storage
  91. if __name__ == '__main__':
  92. dummystorage = Storage()
  93. server = ApiServer(('0.0.0.0', 8888), dummystorage)
  94. print("Server:", str(server))
  95. server.serve_forever()