# Aquitectura: 4 hilos -> Websocket -> Procesamiento -> Visualización -> Guardado:CSV

# Base: Hilos y datos buffer de datos compartidos
import queue
import threading

from src.cliente_ws import websocket_cliente
from src.graficar import graficar
from src.gurdar import guardar_datos
from src.procesor_data import data_procesor

# Datos globals
ip_server = "10.42.0.100:81"

# Cola de datos compartidos
raw_data = queue.Queue()
data_clean = queue.Queue()
data_grafica = queue.Queue()
i_paquetes = queue.Queue()
buffer_size = queue.Queue()
data_guardar = queue.Queue()

# def debug_print():
#    while True:
#        raw = data_grafica.get()
#        print(raw)


hilo_1 = websocket_cliente(raw_data, i_paquetes, ip_server)
hilo_2 = data_procesor(raw_data, data_clean, data_grafica, buffer_size, data_guardar)
# hilo_3 = threading.Thread(target=debug_print)
hilo_4 = guardar_datos(data_guardar)

hilo_1.daemon = True
hilo_2.daemon = True
# hilo_3.daemon = True
hilo_4.daemon = True

hilo_1.start()
hilo_2.start()
# hilo_3.start()
hilo_4.start()


graficar(data_clean, data_grafica, buffer_size)