|
import asyncio
|
|
import json
|
|
import os
|
|
import re
|
|
import sys
|
|
from datetime import datetime
|
|
from typing import cast
|
|
import threading
|
|
|
|
import tornado.web
|
|
import tornado.websocket
|
|
from tornado import ioloop
|
|
|
|
sys.path.append(os.path.dirname(os.path.realpath(__file__)))
|
|
from generate_traffic_data import generate_data
|
|
|
|
subscriptions = {}
|
|
PATTERN = r'^\d{4}-\d{2}-\d{2}'
|
|
ISO_PATTERN = r'^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$'
|
|
|
|
class MainHandler(tornado.web.RequestHandler):
|
|
"""
|
|
Handler to render the index page
|
|
"""
|
|
def get(self):
|
|
self.render("index.html")
|
|
|
|
class DataGeneratorHandler(tornado.web.RequestHandler):
|
|
"""
|
|
Handler to process the request for generating traffic data
|
|
"""
|
|
def post(self):
|
|
"""
|
|
POST method to process the request for traffic data generation
|
|
"""
|
|
try:
|
|
print(self.request.body)
|
|
run_parameters = json.loads(self.request.body)
|
|
|
|
if run_parameters is None:
|
|
self.write("Invalid parameters: 400")
|
|
self.set_status(400)
|
|
return
|
|
|
|
start_time = cast(str, run_parameters.get("start_time"))
|
|
end_time = cast(str, run_parameters.get("end_time"))
|
|
window_size = cast(str, run_parameters.get("window_size"))
|
|
|
|
if re.match(ISO_PATTERN, start_time) and re.match(ISO_PATTERN, end_time):
|
|
|
|
start_time = datetime.strptime(start_time, "%Y-%m-%d %H:%M:%S")
|
|
end_time = datetime.strptime(end_time, "%Y-%m-%d %H:%M:%S")
|
|
window_size = int(window_size)
|
|
else:
|
|
self.write("Please provide date in the format " + ISO_PATTERN)
|
|
self.set_status(400)
|
|
return
|
|
|
|
dataset = generate_data(start_time, end_time, window_size)
|
|
self.write(json.dumps(dataset))
|
|
|
|
except json.JSONDecodeError:
|
|
self.write("Invalid JSON payload: 400")
|
|
self.set_status(400)
|
|
return
|
|
except Exception as error_message:
|
|
self.set_status(500)
|
|
self.write(f"Error in data generation: {str(error_message)}")
|
|
return
|
|
|
|
def make_app():
|
|
"""
|
|
Create the tornado application
|
|
"""
|
|
return tornado.web.Application([
|
|
(r"/", MainHandler),
|
|
(r"/traffic", DataGeneratorHandler),
|
|
])
|
|
|
|
def start():
|
|
"""
|
|
Start the server
|
|
"""
|
|
def run_server():
|
|
asyncio.set_event_loop(asyncio.new_event_loop())
|
|
try:
|
|
app = make_app()
|
|
app.listen(8889)
|
|
print("Server is running on port 8889")
|
|
ioloop.IOLoop.current().start()
|
|
except Exception as error_message:
|
|
print("An error occurred while starting the server:", error_message)
|
|
|
|
server_thread = threading.Thread(target=run_server)
|
|
server_thread.start()
|
|
|
|
if __name__ == "__main__":
|
|
start()
|
|
|
