3lips/event/event.py

"""
@file event.py
@brief Event loop for 3lips.
@author 30hours
"""

import asyncio
import requests
import threading
import asyncio
import time
import copy
import json
import hashlib

from algorithm.associator.AdsbAssociator import AdsbAssociator
from algorithm.coordreg.EllipsoidParametric import EllipsoidParametric
from common.Message import Message

from data.Ellipsoid import Ellipsoid
from algorithm.geometry.Geometry import Geometry

# init event loop
api = []

# init config
tDelete = 60
adsbAssociator = AdsbAssociator()
ellipsoidParametric = EllipsoidParametric()

async def event():

    global api
    timestamp = int(time.time()*1000)
    api_event = copy.copy(api)

    # list all blah2 radars
    radar_names = []
    for item in api_event:
        for radar in item["server"]:
            radar_names.append(radar)
    radar_names = list(set(radar_names))

    # get detections all radar
    radar_detections_url = [
      "http://" + radar_name + "/api/detection" for radar_name in radar_names]
    radar_detections = []
    for url in radar_detections_url:
        try:
            response = requests.get(url, timeout=1)
            response.raise_for_status()
            data = response.json()
            radar_detections.append(data)
        except requests.exceptions.RequestException as e:
            print(f"Error fetching data from {url}: {e}")
            radar_detections.append(None)

    # get config all radar
    radar_config_url = [
      "http://" + radar_name + "/api/config" for radar_name in radar_names]
    radar_config = []
    for url in radar_config_url:
        try:
            response = requests.get(url, timeout=1)
            response.raise_for_status()
            data = response.json()
            radar_config.append(data)
        except requests.exceptions.RequestException as e:
            print(f"Error fetching data from {url}: {e}")
            radar_config.append(None)

    # store detections in dict
    radar_dict = {}
    for i in range(len(radar_names)):
        radar_dict[radar_names[i]] = {
            "detection": radar_detections[i],
            "config": radar_config[i]
        }

    # main processing
    for item in api_event:

      # extract dict for item
      radar_dict_item =  {
          key: radar_dict[key] 
          for key in item["server"] 
          if key in radar_dict
}

      # associator selection
      if item["associator"] == "adsb-associator":
        associator = adsbAssociator
      else:
        print("Error: Associator invalid.")
        return

      # coord reg selection
      if item["coordreg"] == "ellipsoid-parametric":
        coordreg = ellipsoidParametric
      else:
        print("Error: Coord reg invalid.")
        return

      # processing
      associated_dets = associator.process(item["server"], radar_dict_item)
      localised_dets = coordreg.process(associated_dets, radar_dict_item)

      # tmp test
      localised_dets = {}
      localised_dets["test"] = {}
      x_tx, y_tx, z_tx = Geometry.lla2ecef(
          radar_dict_item['radar4.30hours.dev']["config"]['location']['tx']['latitude'],
          radar_dict_item['radar4.30hours.dev']["config"]['location']['tx']['longitude'],
          radar_dict_item['radar4.30hours.dev']["config"]['location']['tx']['altitude']
      )
      x_rx, y_rx, z_rx = Geometry.lla2ecef(
          radar_dict_item['radar4.30hours.dev']["config"]['location']['rx']['latitude'],
          radar_dict_item['radar4.30hours.dev']["config"]['location']['rx']['longitude'],
          radar_dict_item['radar4.30hours.dev']["config"]['location']['rx']['altitude']
      )
      ellipsoid = Ellipsoid(
          [x_tx, y_tx, z_tx],
          [x_rx, y_rx, z_rx],
          'radar4.30hours.dev'
      )
      localised_dets["test"]["points"] = ellipsoidParametric.sample(ellipsoid, 10000, 5)

      # output data to API
      item["detections_associated"] = associated_dets
      item["detections_localised"] = localised_dets

    # delete old API requests
    api_event = [
      item for item in api_event if timestamp - item["timestamp"] <= tDelete*1000]

    # update API
    api = api_event


# event loop
async def main():

    while True:
        await event()
        await asyncio.sleep(1)

def short_hash(input_string, length=10):

    hash_object = hashlib.sha256(input_string.encode())
    short_hash = hash_object.hexdigest()[:length]
    return short_hash

# message received callback
async def callback_message_received(msg):

    print(f"Callback: Received message in event.py: {msg}", flush=True)

    timestamp = int(time.time()*1000)

    # update timestamp if API entry exists
    for x in api:
      if x["hash"] == short_hash(msg):
        x["timestamp"] = timestamp
        break

    # add API entry if does not exist, split URL
    if not any(x.get("hash") == short_hash(msg) for x in api):
      api.append({})
      api[-1]["hash"] = short_hash(msg)
      url_parts = msg.split("&")
      for part in url_parts:
          key, value = part.split("=")
          if key in api[-1]:
              if not isinstance(api[-1][key], list):
                  api[-1][key] = [api[-1][key]]
              api[-1][key].append(value)
          else:
              api[-1][key] = value
      api[-1]["timestamp"] = timestamp
      if not isinstance(api[-1]["server"], list):
        api[-1]["server"] = [api[-1]["server"]]

    # json dump
    for item in api:
      if item["hash"] == short_hash(msg):
        output = json.dumps(item)
        break

    return output

# init messaging
message_api_request = Message('event', 6969)
message_api_request.set_callback_message_received(callback_message_received)

if __name__ == "__main__":
    threading.Thread(target=message_api_request.start_listener).start()
    asyncio.run(main())