azure_iot_hub (#444)

Author: ctaggart

sdk/iothub/Cargo.toml renamed to sdk/iot_hub/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "iothub"
+name = "iot_hub"
 version = "0.1.0"
 authors = ["Microsoft Corp."]
 edition = "2018"

sdk/iot_hub/README.md

@@ -0,0 +1,3 @@
+# Azure SDK for Rust - Azure iot_hub crate
+
+Azure iot_hub crate for the unofficial Microsoft Azure SDK for Rust. This crate is part of a collection of crates: for more information please refer to [https://github.com/azure/azure-sdk-for-rust](https://github.com/azure/azure-sdk-for-rust).

sdk/iothub/examples/device_identity.rs renamed to sdk/iot_hub/examples/device_identity.rs

@@ -1,10 +1,10 @@
-use iothub::service::resources::{AuthenticationMechanism, DesiredCapability, Status};
-use iothub::service::ServiceClient;
+use iot_hub::service::resources::{AuthenticationMechanism, DesiredCapability, Status};
+use iot_hub::service::ServiceClient;
 use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
-    let iothub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
+    let iot_hub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
         .expect("Set env variable IOTHUB_CONNECTION_STRING first!");
 
     let device_id = std::env::args()
@@ -14,7 +14,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     println!("Getting device twin for device '{}'", device_id);
     let http_client = azure_core::new_http_client();
     let service_client =
-        ServiceClient::from_connection_string(http_client, iothub_connection_string, 3600)?;
+        ServiceClient::from_connection_string(http_client, iot_hub_connection_string, 3600)?;
     let device = service_client
         .create_device_identity()
         .execute(

sdk/iothub/examples/directmethod.rs renamed to sdk/iot_hub/examples/directmethod.rs

@@ -1,10 +1,10 @@
-use iothub::service::ServiceClient;
+use iot_hub::service::ServiceClient;
 use serde_json;
 use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
-    let iothub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
+    let iot_hub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
         .expect("Set env variable IOTHUB_CONNECTION_STRING first!");
 
     let device_id = std::env::args()
@@ -25,10 +25,10 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
 
     let http_client = azure_core::new_http_client();
     let service_client =
-        ServiceClient::from_connection_string(http_client, iothub_connection_string, 3600)?;
+        ServiceClient::from_connection_string(http_client, iot_hub_connection_string, 3600)?;
     println!(
         "Sending direct method {} to {}:{} on: {}",
-        method_name, device_id, module_id, service_client.iothub_name
+        method_name, device_id, module_id, service_client.iot_hub_name
     );
 
     let direct_method =

sdk/iothub/examples/gettwin.rs renamed to sdk/iot_hub/examples/gettwin.rs

@@ -1,9 +1,9 @@
-use iothub::service::ServiceClient;
+use iot_hub::service::ServiceClient;
 use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
-    let iothub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
+    let iot_hub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
         .expect("Set env variable IOTHUB_CONNECTION_STRING first!");
 
     let device_id = std::env::args()
@@ -14,7 +14,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
 
     let http_client = azure_core::new_http_client();
     let service_client =
-        ServiceClient::from_connection_string(http_client, iothub_connection_string, 3600)?;
+        ServiceClient::from_connection_string(http_client, iot_hub_connection_string, 3600)?;
     let twin = service_client.get_device_twin(device_id).await?;
 
     println!("Received device twin: {:?}", twin);

sdk/iothub/examples/module_identity.rs renamed to sdk/iot_hub/examples/module_identity.rs

@@ -1,10 +1,10 @@
-use iothub::service::resources::AuthenticationMechanism;
-use iothub::service::ServiceClient;
+use iot_hub::service::resources::AuthenticationMechanism;
+use iot_hub::service::ServiceClient;
 use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
-    let iothub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
+    let iot_hub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
         .expect("Set env variable IOTHUB_CONNECTION_STRING first!");
 
     let device_id = std::env::args()
@@ -17,7 +17,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
 
     let http_client = azure_core::new_http_client();
     let service_client =
-        ServiceClient::from_connection_string(http_client, iothub_connection_string, 3600)?;
+        ServiceClient::from_connection_string(http_client, iot_hub_connection_string, 3600)?;
     let module = service_client
         .create_module_identity()
         .execute(

sdk/iothub/examples/query_iothub.rs renamed to sdk/iot_hub/examples/query_iothub.rs

@@ -1,19 +1,19 @@
-use iothub::service::ServiceClient;
+use iot_hub::service::ServiceClient;
 use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     env_logger::init();
 
-    let iothub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
+    let iot_hub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
         .expect("Set env variable IOTHUB_CONNECTION_STRING first!");
 
     let query = "SELECT * FROM devices";
     println!("Invoking query '{}' on the IoT Hub", query);
 
     let http_client = azure_core::new_http_client();
     let service_client =
-        ServiceClient::from_connection_string(http_client, iothub_connection_string, 3600)?;
+        ServiceClient::from_connection_string(http_client, iot_hub_connection_string, 3600)?;
 
     let response = service_client
         .query()

sdk/iothub/examples/updatetwin.rs renamed to sdk/iot_hub/examples/updatetwin.rs

@@ -1,10 +1,10 @@
-use iothub::service::ServiceClient;
+use iot_hub::service::ServiceClient;
 use serde_json;
 use std::error::Error;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
-    let iothub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
+    let iot_hub_connection_string = std::env::var("IOTHUB_CONNECTION_STRING")
         .expect("Set env variable IOTHUB_CONNECTION_STRING first!");
 
     let device_id = std::env::args()
@@ -19,7 +19,7 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
     let http_client = azure_core::new_http_client();
 
     let service_client =
-        ServiceClient::from_connection_string(http_client, iothub_connection_string, 3600)?;
+        ServiceClient::from_connection_string(http_client, iot_hub_connection_string, 3600)?;
     let updated_twin = service_client
         .update_device_twin(device_id)
         .properties(serde_json::from_str(&payload)?)