aiot 0.10.0

Rust Link SDK (Aliyun IoT) based on Alink Protocol.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use super::base::*;
use crate::alink::aiot_module::{get_aiot_json, ModuleRecvKind};
use crate::alink::alink_topic::ALinkSubscribeTopic;
use crate::alink::{AlinkRequest, AlinkResponse, ParamsRequest, SimpleResponse};
use crate::{Error, Result, ThreeTuple};
use enum_iterator::IntoEnumIterator;
use enum_kinds::EnumKind;
use regex::Regex;
use rumqttc::{AsyncClient, QoS};
use serde::{Deserialize, Serialize};
use std::any::TypeId;
use std::sync::Arc;
use tokio::sync::mpsc;
use tokio::sync::mpsc::{Receiver, Sender};

/// 设备请求上传文件
/// 响应Topic：`/sys/${productKey}/${deviceName}/thing/file/upload/mqtt/init_reply`。
pub type InitReply = AlinkResponse<InitData, Option<String>>;

/// 设备上传文件分片
/// 响应Topic：`/sys/${productKey}/${deviceName}/thing/file/upload/mqtt/send_reply`。
pub type SendReply = AlinkResponse<SendReplyData, Option<String>>;

/// 设备取消上传文件
/// 响应Topic：`/sys/${productKey}/${deviceName}/thing/file/upload/mqtt/cancel_reply`。
pub type CancelReply = AlinkResponse<UploadId, Option<String>>;

#[derive(Debug, EnumKind, Clone)]
#[enum_kind(FileRecvKind, derive(Serialize, IntoEnumIterator, Deserialize))]
pub enum FileRecv {
    InitReply(InitReply),
    SendReply(SendReply),
    CancelReply(CancelReply),
}

impl ModuleRecvKind for super::RecvKind {
    type Recv = super::Recv;

    fn to_payload(&self, payload: &[u8], _: &Vec<String>) -> crate::Result<FileRecv> {
        let s = get_aiot_json(payload);
        match *self {
            Self::InitReply => Ok(Self::Recv::InitReply(serde_json::from_str(&s)?)),
            Self::SendReply => Ok(Self::Recv::SendReply(serde_json::from_str(&s)?)),
            Self::CancelReply => Ok(Self::Recv::CancelReply(serde_json::from_str(&s)?)),
        }
    }

    fn get_topic(&self) -> ALinkSubscribeTopic {
        match *self {
            Self::InitReply => {
                ALinkSubscribeTopic::new("/sys/+/+/thing/file/upload/mqtt/init_reply")
            }
            Self::SendReply => {
                ALinkSubscribeTopic::new("/sys/+/+/thing/file/upload/mqtt/send_reply")
            }
            Self::CancelReply => {
                ALinkSubscribeTopic::new("/sys/+/+/thing/file/upload/mqtt/cancel_reply")
            }
        }
    }
}