[IoT] Increase SDK and API version

src/azure-cli-core/azure/cli/core/profiles/_shared.py

@@ -243,7 +243,7 @@ def default_api_version(self):
         }),
         ResourceType.MGMT_MSI: '2022-01-31-preview',
         ResourceType.MGMT_APPSERVICE: '2022-03-01',
-        ResourceType.MGMT_IOTHUB: '2021-07-02',
+        ResourceType.MGMT_IOTHUB: '2022-04-30-preview',
         ResourceType.MGMT_IOTDPS: '2021-10-15',
         ResourceType.MGMT_IOTCENTRAL: '2021-11-01-preview',
         ResourceType.MGMT_ARO: '2022-04-01',

src/azure-cli/azure/cli/command_modules/iot/commands.py

@@ -184,7 +184,7 @@ def load_command_table(self, _):  # pylint: disable=too-many-statements
 
     # iot hub device stream commands
     with self.command_group('iot hub devicestream', client_factory=iot_hub_service_factory,
-                            min_api="2019-07-01-preview") as g:
+                            min_api="2019-07-01-preview", is_preview=True) as g:
         g.custom_show_command('show', 'iot_hub_devicestream_show')
 
     # iot central commands

src/azure-cli/azure/cli/command_modules/iot/custom.py

@@ -4,6 +4,7 @@
 # --------------------------------------------------------------------------------------------
 # pylint: disable=no-self-use,no-member,line-too-long,too-few-public-methods,too-many-lines,too-many-arguments,too-many-locals
 
+import json
 import re
 from enum import Enum
 from knack.log import get_logger
@@ -278,7 +279,10 @@ def iot_dps_linked_hub_create(
                 raise InvalidArgumentValueError("Please provide a valid IoT Hub connection string.")
 
         hub_client = iot_hub_service_factory(cmd.cli_ctx)
-        location = iot_hub_get(cmd, hub_client, hub_name=hub_name, resource_group_name=hub_resource_group).location
+        try:
+            location = iot_hub_get(cmd, hub_client, hub_name=hub_name, resource_group_name=hub_resource_group).location
+        except CLIError:
+            raise RequiredArgumentMissingError("Please provide the IoT Hub location.")
 
     resource_group_name = _ensure_dps_resource_group_name(client, resource_group_name, dps_name)
 
@@ -491,7 +495,6 @@ def iot_hub_create(cmd, client, hub_name, resource_group_name, location=None,
                    fileupload_storage_container_name=None,
                    fileupload_sas_ttl=1,
                    fileupload_storage_authentication_type=None,
-                   fileupload_storage_container_uri=None,
                    fileupload_storage_identity=None,
                    min_tls_version=None,
                    tags=None,
@@ -546,7 +549,6 @@ def iot_hub_create(cmd, client, hub_name, resource_group_name, location=None,
         connection_string=fileupload_storage_connectionstring if fileupload_storage_connectionstring else '',
         container_name=fileupload_storage_container_name if fileupload_storage_container_name else '',
         authentication_type=fileupload_storage_authentication_type if fileupload_storage_authentication_type else None,
-        container_uri=fileupload_storage_container_uri if fileupload_storage_container_uri else '',
         identity=ManagedIdentity(user_assigned_identity=fileupload_storage_identity) if fileupload_storage_identity else None)
 
     properties = IotHubProperties(event_hub_endpoints=event_hub_dic,
@@ -1129,6 +1131,10 @@ def iot_hub_route_update(cmd, client, hub_name, route_name, source_type=None, en
 
 def iot_hub_route_test(cmd, client, hub_name, route_name=None, source_type=None, body=None, app_properties=None,
                        system_properties=None, resource_group_name=None):
+    if app_properties:
+        app_properties = json.loads(app_properties)
+    if system_properties:
+        system_properties = json.loads(system_properties)
     resource_group_name = _ensure_hub_resource_group_name(client, resource_group_name, hub_name)
     route_message = RoutingMessage(
         body=body,

src/azure-cli/azure/cli/command_modules/iot/tests/latest/test_iot_commands.py

@@ -3,6 +3,7 @@
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
 # pylint: disable=too-many-statements
+import json
 from unittest import mock
 
 from azure.cli.testsdk import ResourceGroupPreparer, ScenarioTest, StorageAccountPreparer
@@ -24,6 +25,7 @@ def __init__(self, method_name):
     @ResourceGroupPreparer(location='westus2')
     @StorageAccountPreparer()
     def test_iot_hub(self, resource_group, resource_group_location, storage_account):
+        # for some reason the recording is missing a ] and a } after the routing.endpoints.eventHubs
         hub = self.create_random_name(prefix='iot-hub-for-test-11', length=32)
         rg = resource_group
         location = resource_group_location
@@ -343,6 +345,12 @@ def test_iot_hub(self, resource_group, resource_group_location, storage_account)
         self.cmd('iot hub route test --hub-name {0} -g {1} -n {2}'.format(hub, rg, route_name),
                  checks=[self.check('result', 'true')])
 
+        # Test 'az iot hub route test'
+        self.kwargs["route_properties"] = json.dumps({"body": 4})
+        props = "--sp '{route_properties}' --ap '{route_properties}'"
+        self.cmd('iot hub route test --hub-name {0} -g {1} -n {2} {3}'.format(hub, rg, route_name, props),
+                 checks=[self.check('result', 'true')])
+
         # Test 'az iot hub route test'
         self.cmd('iot hub route test --hub-name {0} -g {1} -s {2}'.format(hub, rg, source_type),
                  checks=[self.check('length(routes[*])', 1),

src/azure-cli/azure/cli/command_modules/iot/tests/latest/test_iot_dps_commands.py

@@ -9,6 +9,7 @@
 from azure.cli.command_modules.iot.tests.latest._test_utils import (
     _create_test_cert, _delete_test_cert, _create_verification_cert, _create_fake_chain_cert
 )
+from azure.cli.testsdk.scenario_tests import AllowLargeResponse
 from azure.cli.command_modules.iot.tests.latest.recording_processors import KeyReplacer
 from azure.core.exceptions import HttpResponseError
 import random
@@ -210,7 +211,7 @@ def test_dps_certificate_lifecycle(self, group_name, group_location):
         # Delete DPS
         self.cmd('az iot dps delete -g {} -n {}'.format(group_name, dps_name))
 
-
+    @AllowLargeResponse(size_kb=4096)
     @ResourceGroupPreparer(parameter_name='group_name', parameter_name_for_location='group_location')
     def test_dps_linked_hub_lifecycle(self, group_name, group_location):
         dps_name = self.create_random_name('dps', 20)
@@ -258,11 +259,6 @@ def test_dps_linked_hub_lifecycle(self, group_name, group_location):
                  .format(dps_name, group_name, connection_string))
         self.cmd('az iot dps linked-hub delete --dps-name {} -g {} --linked-hub {}'.format(dps_name, group_name, hub_name))
 
-        # Create linked-hub using only connection string in lower case
-        self.cmd('az iot dps linked-hub create --dps-name {} -g {} --connection-string {}'
-                 .format(dps_name, group_name, connection_string.lower()))
-        self.cmd('az iot dps linked-hub delete --dps-name {} -g {} --linked-hub {}'.format(dps_name, group_name, hub_name))
-
         # Create linked-hub using connection string and location
         self.cmd('az iot dps linked-hub create --dps-name {} -g {} --connection-string {} -l {}'
                  .format(dps_name, group_name, connection_string, group_location))