use crate::alink::aiot_module::{AiotModule, ModuleRecvKind};
use crate::alink::{AlinkRequest, AlinkResponse};
use crate::mqtt::MqttConnection;
use crate::{Error, Result, ThreeTuple};
use enum_iterator::IntoEnumIterator;
use log::*;
use regex::Regex;
use rumqttc::{AsyncClient, QoS};
use serde::{Deserialize, Serialize};
use std::sync::Arc;
use tokio::sync::mpsc;
use tokio::sync::mpsc::{Receiver, Sender};
use self::base::RemoteAccessOptions;
use self::recv::*;
pub mod base;
pub mod push;
pub mod recv;
pub type Recv = RemoteAccessRecv;
pub type RecvKind = RemoteAccessRecvKind;
pub type Module = AiotModule<Recv>;
impl Module {
pub async fn init(&mut self) -> Result<()> {
self.sub_all::<RecvKind>().await?;
self.proxy_request().await?;
Ok(())
}
}
impl MqttConnection {
pub fn remote_access(&mut self) -> Result<Module> {
let (tx, rx) = mpsc::channel(16);
let ra = RemoteAccessOptions::new(self.mqtt_client.three.clone());
let executor = Executor {
tx,
three: self.mqtt_client.three.clone(),
};
let module = self.module(Box::new(executor), rx, ())?;
Ok(module)
}
}
pub struct Executor {
three: Arc<ThreeTuple>,
tx: Sender<Recv>,
}
#[async_trait::async_trait]
impl crate::Executor for Executor {
async fn execute(&mut self, topic: &str, payload: &[u8]) -> crate::Result<()> {
let data = crate::execute::<RecvKind>(&self.three, topic, payload)?;
self.tx.send(data).await.map_err(|_| Error::MpscSendError)
}
}