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

//! aws-iot-core-sdk-rust aims to be a well-functioning and easy to use AWS IoT device SDK.
//! At its core it uses the pure Rust MQTT client Rumqtt, as well as Serde for (de)serializing
//! JSON. The name is chosen to match its C, C++, Python and JS counterparts.
//! * Use this to easily connect your  IoT devices to AWS IoT Core.
//! * Publish and subscribe to any topic you want.
//! * Register callback functions that will be called to handle incoming messages on any topic.
//!
//! The crate re-exports Mqtt311s Quality of Service enum. These are used when subscribing and
//! publish. The variants are:
//! * AtMostOnce (0)
//! * AtLeastOnce (1)
//! * ExactlyOnce (2)
//!
//! ## Publish and subscribe
//! ```no_run
//! use aws_iot_device_sdk_rust::client;
//!
//! fn main() {
//!     let mut iot_core_client = client::AWSIoTClient::new(
//!         "myClientId",
//!         "root-CA.crt",
//!         "device.cert.pem",
//!         "device.private.key",
//!         "myendpoint.iot.eu-west-1.amazonaws.com"
//!         ).unwrap();
//!
//!     iot_core_client.start_listening();
//!     iot_core_client.subscribe("thing/light/status", QoS::AtLeastOnce);
//!     iot_core_client.publish("thing/light/status", "on");
//! }
//!```
//!
//! ## Add callback
//! ```no_run
//! use aws_iot_device_sdk_rust::client;
//!
//! fn my_callback() {
//!     println!("Someone or something published to thing/light/status!");
//! }
//! fn main() {
//!     let mut iot_core_client = client::AWSIoTClient::new(
//!         "myClientId",
//!         "root-CA.crt",
//!         "device.cert.pem",
//!         "device.private.key",
//!         "myendpoint.iot.eu-west-1.amazonaws.com"
//!         ).unwrap();
//!
//!     iot_core_client.start_listening();
//!     iot_core_client.add_callback("thing/light/status", my_callback).unwrap();
//! }
//!```
//!
//! ## Get shadow updates
//! ```no_run
//! use aws_iot_device_sdk_rust::{client, shadow};
//!
//! fn print_shadow_updates(shadow: String) {
//!     println!("{:?}", shadow);
//! }
//!
//! fn main() {
//!     let mut iot_core_client = client::AWSIoTClient::new(
//!         "myClientId",
//!         "root-CA.crt",
//!         "device.cert.pem",
//!         "device.private.key",
//!         "myendpoint.iot.eu-west-1.amazonaws.com"
//!         ).unwrap();
//!
//!     let mut shadow_manager = shadow::AWSShadowManager::new(&mut iot_core_client,
//!         String::from("MyThing"));
//!     shadow_manager.add_listen_on_delta_callback(print_shadow_updates);
//! }
//!```

pub mod client;
pub mod shadow;

pub use crate::client::AWSIoTClient;
pub use crate::shadow::AWSShadowManager;
pub use serde_json::json;
pub use rumqtt::QoS;