use async_trait::async_trait;
use mlua::FromLua;
use rumqttc::Publish;
use tokio::sync::mpsc;

#[derive(Debug, Clone)]
pub enum Event {
    MqttMessage(Publish),
}

pub type Sender = mpsc::Sender<Event>;
pub type Receiver = mpsc::Receiver<Event>;

#[derive(Clone, Debug, FromLua)]
pub struct EventChannel(Sender);

impl EventChannel {
    pub fn new() -> (Self, Receiver) {
        let (tx, rx) = mpsc::channel(100);

        (Self(tx), rx)
    }

    pub fn get_tx(&self) -> Sender {
        self.0.clone()
    }
}

impl mlua::UserData for EventChannel {}

#[async_trait]
pub trait OnMqtt: Sync + Send {
    // fn topics(&self) -> Vec<&str>;
    async fn on_mqtt(&self, message: Publish);
}