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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154

use crate::util::auth::{sign, sign_device, SIGN_METHOD};
use serde::{Deserialize, Serialize};
use std::{
    fmt::format,
    time::{SystemTime, UNIX_EPOCH},
};

#[derive(Deserialize, Serialize, Debug, Clone)]
#[serde(rename_all = "camelCase")]
pub struct DeviceInfoId {
    /// 设备名
    pub device_name: String,
    /// 产品key
    pub product_key: String,
}

#[derive(Deserialize, Serialize, Debug, Clone)]
#[serde(rename_all = "camelCase")]
pub struct DeviceInfoWithSecret {
    /// 设备名
    pub device_name: String,
    /// 产品key
    pub product_key: String,
    /// 设备密钥
    pub device_secret: String,
}

impl From<DeviceInfoWithSecret> for DeviceInfoId {
    fn from(r: DeviceInfoWithSecret) -> Self {
        DeviceInfoId {
            device_name: r.device_name,
            product_key: r.product_key,
        }
    }
}

#[derive(Deserialize, Serialize, Debug, Clone)]
#[serde(rename_all = "camelCase")]
pub struct DeviceInfo {
    /// 设备名
    pub device_name: String,
    /// 产品Key
    pub product_key: String,
    /// 签名
    pub sign: String,
    /// 签名方法
    pub sign_method: String,
    /// 时间戳
    pub timestamp: String,
    /// client_id
    pub client_id: Option<String>,
    // 如果取值是true，则清理所有子设备离线时的消息，即所有未接收的QoS1消息将被清除。如果取值是false，则不清理子设备离线时的消息。
    pub clean_session: Option<String>,
}

#[derive(Deserialize, Serialize, Debug, Clone)]
#[serde(rename_all = "camelCase")]
pub struct DeviceInfoNoCS {
    /// 设备名
    pub device_name: String,
    /// 产品Key
    pub product_key: String,
    /// 签名
    pub sign: String,
    /// 签名方法
    pub sign_method: String,
    /// 时间戳
    pub timestamp: String,
    /// client_id
    pub client_id: Option<String>,
}

impl DeviceInfo {
    pub fn new(
        product_key: String,
        device_name: String,
        clean_session: Option<bool>,
        device_secret: String,
        client_id: Option<String>,
    ) -> Self {
        // client_id+device_name+product_key+timestamp;
        let client_id = client_id.unwrap_or(format!("{}.{}", product_key, device_name));
        let start = SystemTime::now();
        let since_the_epoch = start
            .duration_since(UNIX_EPOCH)
            .expect("Time went backwards");
        let timestamp = since_the_epoch.as_millis();
        // let res = format!(
        // 	"clientId{}deviceName{}productKey{}timestamp{}",
        // 	client_id,
        // 	device_name,
        // 	product_key,
        // 	timestamp
        // );
        // let sign = sign(&res, &device_secret);
        let sign = sign_device(
            &client_id,
            &device_name,
            &product_key,
            &device_secret,
            timestamp,
        );
        Self {
            device_name,
            product_key,
            sign,
            sign_method: SIGN_METHOD.to_string(),
            timestamp: timestamp.to_string(),
            client_id: Some(client_id),
            clean_session: clean_session.map(|n| String::from(if n { "true" } else { "false" })),
        }
    }
}

impl DeviceInfoNoCS {
    pub fn new(
        product_key: String,
        device_name: String,
        device_secret: String,
        client_id: Option<String>,
    ) -> Self {
        // client_id+device_name+product_key+timestamp;
        let client_id = client_id.unwrap_or(format!("{}.{}", product_key, device_name));
        let start = SystemTime::now();
        let since_the_epoch = start
            .duration_since(UNIX_EPOCH)
            .expect("Time went backwards");
        let timestamp = since_the_epoch.as_millis();

        // let res = format!(
        // 	"clientId{}deviceName{}productKey{}timestamp{}",
        // 	client_id,
        // 	device_name,
        // 	product_key,
        // 	timestamp
        // );
        // let sign = sign(&res, &device_secret);
        let sign = sign_device(
            &client_id,
            &device_name,
            &product_key,
            &device_secret,
            timestamp,
        );
        Self {
            device_name,
            product_key,
            sign,
            sign_method: SIGN_METHOD.to_string(),
            timestamp: timestamp.to_string(),
            client_id: Some(client_id),
        }
    }
}