Skip to content

Commit 692d198

Browse files
committed
registry-device
1 parent 5ab7938 commit 692d198

17 files changed

Lines changed: 2377 additions & 282 deletions

azext_iot/adr/_help.py

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -398,60 +398,60 @@ def load_adr_help():
398398
"""
399399

400400
helps[
401-
"iot adr ns adaptive-device"
401+
"iot adr ns registry-device"
402402
] = """
403403
type: group
404-
short-summary: Manage Device Registry namespace adaptive devices.
404+
short-summary: Manage Device Registry namespace registry devices.
405405
"""
406406

407407
helps[
408-
"iot adr ns adaptive-device create"
408+
"iot adr ns registry-device create"
409409
] = """
410410
type: command
411-
short-summary: Create an adaptive device in a Device Registry namespace.
411+
short-summary: Create a registry device in a Device Registry namespace.
412412
examples:
413-
- name: Create an adaptive device with descriptive metadata
414-
text: az iot adr ns adaptive-device create -n myDevice --ns myNamespace -g myResourceGroup --manufacturer Contoso --model X1 --external-device-id ext-123
413+
- name: Create a registry device with descriptive metadata
414+
text: az iot adr ns registry-device create -n myDevice --ns myNamespace -g myResourceGroup --manufacturer Contoso --model X1 --external-device-id ext-123
415415
"""
416416

417417
helps[
418-
"iot adr ns adaptive-device show"
418+
"iot adr ns registry-device show"
419419
] = """
420420
type: command
421-
short-summary: Show the details of an adaptive device.
421+
short-summary: Show the details of a registry device.
422422
examples:
423-
- name: Show an adaptive device
424-
text: az iot adr ns adaptive-device show -n myDevice --ns myNamespace -g myResourceGroup
423+
- name: Show a registry device
424+
text: az iot adr ns registry-device show -n myDevice --ns myNamespace -g myResourceGroup
425425
"""
426426

427427
helps[
428-
"iot adr ns adaptive-device list"
428+
"iot adr ns registry-device list"
429429
] = """
430430
type: command
431-
short-summary: List the adaptive devices in a Device Registry namespace.
431+
short-summary: List the registry devices in a Device Registry namespace.
432432
examples:
433-
- name: List adaptive devices
434-
text: az iot adr ns adaptive-device list --ns myNamespace -g myResourceGroup
433+
- name: List registry devices
434+
text: az iot adr ns registry-device list --ns myNamespace -g myResourceGroup
435435
"""
436436

437437
helps[
438-
"iot adr ns adaptive-device update"
438+
"iot adr ns registry-device update"
439439
] = """
440440
type: command
441-
short-summary: Update an adaptive device.
441+
short-summary: Update a registry device.
442442
examples:
443-
- name: Update an adaptive device's software revision
444-
text: az iot adr ns adaptive-device update -n myDevice --ns myNamespace -g myResourceGroup --software-revision 2.0
443+
- name: Update a registry device's software revision
444+
text: az iot adr ns registry-device update -n myDevice --ns myNamespace -g myResourceGroup --software-revision 2.0
445445
"""
446446

447447
helps[
448-
"iot adr ns adaptive-device delete"
448+
"iot adr ns registry-device delete"
449449
] = """
450450
type: command
451-
short-summary: Delete an adaptive device from a Device Registry namespace.
451+
short-summary: Delete a registry device from a Device Registry namespace.
452452
examples:
453-
- name: Delete an adaptive device
454-
text: az iot adr ns adaptive-device delete -n myDevice --ns myNamespace -g myResourceGroup
453+
- name: Delete a registry device
454+
text: az iot adr ns registry-device delete -n myDevice --ns myNamespace -g myResourceGroup
455455
"""
456456

457457
helps[

azext_iot/adr/command_map.py

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@
3333
client_factory=adr_service_factory,
3434
)
3535

36-
adr_adaptive_device_ops = CliCommandType(
37-
operations_tmpl="azext_iot.adr.commands_adaptive_device#{}",
36+
adr_registry_device_ops = CliCommandType(
37+
operations_tmpl="azext_iot.adr.commands_registry_device#{}",
3838
client_factory=adr_service_factory,
3939
)
4040

@@ -120,15 +120,15 @@ def load_adr_commands(self, _):
120120
cmd_group.command("update", "adr_ca_policy_update", supports_no_wait=True)
121121
cmd_group.command("delete", "adr_ca_policy_delete", confirmation=True, supports_no_wait=True)
122122

123-
# Adaptive Device commands
123+
# Registry Device commands
124124
with self.command_group(
125-
"iot adr ns adaptive-device", command_type=adr_adaptive_device_ops
125+
"iot adr ns registry-device", command_type=adr_registry_device_ops
126126
) as cmd_group:
127-
cmd_group.command("create", "adr_adaptive_device_create")
128-
cmd_group.show_command("show", "adr_adaptive_device_show")
129-
cmd_group.command("list", "adr_adaptive_device_list")
130-
cmd_group.command("update", "adr_adaptive_device_update")
131-
cmd_group.command("delete", "adr_adaptive_device_delete", confirmation=True, supports_no_wait=True)
127+
cmd_group.command("create", "adr_registry_device_create")
128+
cmd_group.show_command("show", "adr_registry_device_show")
129+
cmd_group.command("list", "adr_registry_device_list")
130+
cmd_group.command("update", "adr_registry_device_update")
131+
cmd_group.command("delete", "adr_registry_device_delete", confirmation=True, supports_no_wait=True)
132132

133133
# Device commands
134134
with self.command_group("iot adr ns device", command_type=adr_device_ops) as cmd_group:
Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -8,14 +8,14 @@
88

99
from knack.log import get_logger
1010

11-
from azext_iot.adr.providers.adaptive_device import AdaptiveDeviceProvider
11+
from azext_iot.adr.providers.registry_device import RegistryDeviceProvider
1212

1313
logger = get_logger(__name__)
1414

1515

16-
def adr_adaptive_device_create(
16+
def adr_registry_device_create(
1717
cmd,
18-
adaptive_device_name: str,
18+
registry_device_name: str,
1919
namespace_name: str,
2020
resource_group_name: str,
2121
external_device_id: Optional[str] = None,
@@ -27,9 +27,9 @@ def adr_adaptive_device_create(
2727
tags: Optional[Dict[str, str]] = None,
2828
**kwargs,
2929
):
30-
provider = AdaptiveDeviceProvider(cmd)
30+
provider = RegistryDeviceProvider(cmd)
3131
return provider.create(
32-
adaptive_device_name=adaptive_device_name,
32+
registry_device_name=registry_device_name,
3333
namespace_name=namespace_name,
3434
resource_group_name=resource_group_name,
3535
external_device_id=external_device_id,
@@ -43,28 +43,28 @@ def adr_adaptive_device_create(
4343
)
4444

4545

46-
def adr_adaptive_device_show(
47-
cmd, adaptive_device_name: str, namespace_name: str, resource_group_name: str
46+
def adr_registry_device_show(
47+
cmd, registry_device_name: str, namespace_name: str, resource_group_name: str
4848
):
49-
provider = AdaptiveDeviceProvider(cmd)
49+
provider = RegistryDeviceProvider(cmd)
5050
return provider.show(
51-
adaptive_device_name=adaptive_device_name,
51+
registry_device_name=registry_device_name,
5252
namespace_name=namespace_name,
5353
resource_group_name=resource_group_name,
5454
)
5555

5656

57-
def adr_adaptive_device_list(cmd, namespace_name: str, resource_group_name: str):
58-
provider = AdaptiveDeviceProvider(cmd)
57+
def adr_registry_device_list(cmd, namespace_name: str, resource_group_name: str):
58+
provider = RegistryDeviceProvider(cmd)
5959
return provider.list(
6060
namespace_name=namespace_name,
6161
resource_group_name=resource_group_name,
6262
)
6363

6464

65-
def adr_adaptive_device_update(
65+
def adr_registry_device_update(
6666
cmd,
67-
adaptive_device_name: str,
67+
registry_device_name: str,
6868
namespace_name: str,
6969
resource_group_name: str,
7070
external_device_id: Optional[str] = None,
@@ -75,9 +75,9 @@ def adr_adaptive_device_update(
7575
tags: Optional[Dict[str, str]] = None,
7676
**kwargs,
7777
):
78-
provider = AdaptiveDeviceProvider(cmd)
78+
provider = RegistryDeviceProvider(cmd)
7979
return provider.update(
80-
adaptive_device_name=adaptive_device_name,
80+
registry_device_name=registry_device_name,
8181
namespace_name=namespace_name,
8282
resource_group_name=resource_group_name,
8383
external_device_id=external_device_id,
@@ -90,12 +90,12 @@ def adr_adaptive_device_update(
9090
)
9191

9292

93-
def adr_adaptive_device_delete(
94-
cmd, adaptive_device_name: str, namespace_name: str, resource_group_name: str, **kwargs
93+
def adr_registry_device_delete(
94+
cmd, registry_device_name: str, namespace_name: str, resource_group_name: str, **kwargs
9595
):
96-
provider = AdaptiveDeviceProvider(cmd)
96+
provider = RegistryDeviceProvider(cmd)
9797
return provider.delete(
98-
adaptive_device_name=adaptive_device_name,
98+
registry_device_name=registry_device_name,
9999
namespace_name=namespace_name,
100100
resource_group_name=resource_group_name,
101101
**kwargs,

azext_iot/adr/params.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -207,21 +207,21 @@ def load_adr_arguments(self, _):
207207
validator=get_default_location_from_resource_group,
208208
)
209209

210-
# Adaptive Device arguments
211-
with self.argument_context("iot adr ns adaptive-device") as context:
210+
# Registry Device arguments
211+
with self.argument_context("iot adr ns registry-device") as context:
212212
context.argument(
213213
"namespace_name",
214214
options_list=["--namespace", "--ns"],
215215
help="Name of the Device Registry namespace.",
216216
)
217217
context.argument(
218-
"adaptive_device_name",
218+
"registry_device_name",
219219
options_list=["--name", "-n"],
220-
help="Name of the adaptive device.",
220+
help="Name of the registry device.",
221221
)
222222
context.argument("tags", arg_type=tags_type)
223223

224-
for cmd in ["iot adr ns adaptive-device create", "iot adr ns adaptive-device update"]:
224+
for cmd in ["iot adr ns registry-device create", "iot adr ns registry-device update"]:
225225
with self.argument_context(cmd) as context:
226226
context.argument(
227227
"external_device_id",
@@ -249,7 +249,7 @@ def load_adr_arguments(self, _):
249249
help="Device software revision.",
250250
)
251251

252-
with self.argument_context("iot adr ns adaptive-device create") as context:
252+
with self.argument_context("iot adr ns registry-device create") as context:
253253
context.argument(
254254
"location",
255255
arg_type=get_location_type(self.cli_ctx),

azext_iot/adr/providers/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ def _resolve_location(
6464
):
6565
"""Resolve a child resource location from its parent Device Registry namespace.
6666
67-
Child resources (certificate authorities, certificate policies, adaptive devices) must be
67+
Child resources (certificate authorities, certificate policies, registry devices) must be
6868
co-located with their parent namespace, so default to the namespace's location when the
6969
caller does not specify one explicitly. Use this when a parent namespace is guaranteed to
7070
exist; use ``_ensure_location`` instead when only the resource group is available.

azext_iot/adr/providers/adaptive_device.py renamed to azext_iot/adr/providers/registry_device.py

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -11,9 +11,9 @@
1111
from azext_iot.adr.providers.base import ADRProvider, console
1212

1313

14-
class AdaptiveDeviceProvider(ADRProvider):
14+
class RegistryDeviceProvider(ADRProvider):
1515
def __init__(self, cmd):
16-
super(AdaptiveDeviceProvider, self).__init__(cmd)
16+
super(RegistryDeviceProvider, self).__init__(cmd)
1717

1818
@staticmethod
1919
def _build_properties(
@@ -38,7 +38,7 @@ def _build_properties(
3838

3939
def create(
4040
self,
41-
adaptive_device_name: str,
41+
registry_device_name: str,
4242
namespace_name: str,
4343
resource_group_name: str,
4444
external_device_id: Optional[str] = None,
@@ -66,33 +66,33 @@ def create(
6666
resource["tags"] = tags
6767

6868
with console.status(
69-
f"Creating adaptive device '{adaptive_device_name}' on namespace {namespace_name}..."
69+
f"Creating registry device '{registry_device_name}' on namespace {namespace_name}..."
7070
):
71-
return self.client.namespace_adaptive_devices.create_or_replace(
71+
return self.client.registry_devices.create_or_replace(
7272
resource_group_name=resource_group_name,
7373
namespace_name=namespace_name,
74-
adaptive_device_name=adaptive_device_name,
74+
registry_device_name=registry_device_name,
7575
resource=resource,
7676
)
7777

78-
def show(self, adaptive_device_name: str, namespace_name: str, resource_group_name: str):
79-
return self.client.namespace_adaptive_devices.get(
78+
def show(self, registry_device_name: str, namespace_name: str, resource_group_name: str):
79+
return self.client.registry_devices.get(
8080
resource_group_name=resource_group_name,
8181
namespace_name=namespace_name,
82-
adaptive_device_name=adaptive_device_name,
82+
registry_device_name=registry_device_name,
8383
)
8484

8585
def list(self, namespace_name: str, resource_group_name: str):
8686
return list(
87-
self.client.namespace_adaptive_devices.list_by_namespace(
87+
self.client.registry_devices.list_by_namespace(
8888
resource_group_name=resource_group_name,
8989
namespace_name=namespace_name,
9090
)
9191
)
9292

9393
def update(
9494
self,
95-
adaptive_device_name: str,
95+
registry_device_name: str,
9696
namespace_name: str,
9797
resource_group_name: str,
9898
external_device_id: Optional[str] = None,
@@ -121,23 +121,23 @@ def update(
121121
body["tags"] = tags
122122

123123
with console.status(
124-
f"Updating adaptive device '{adaptive_device_name}' on namespace {namespace_name}..."
124+
f"Updating registry device '{registry_device_name}' on namespace {namespace_name}..."
125125
):
126-
return self.client.namespace_adaptive_devices.update(
126+
return self.client.registry_devices.update(
127127
resource_group_name=resource_group_name,
128128
namespace_name=namespace_name,
129-
adaptive_device_name=adaptive_device_name,
129+
registry_device_name=registry_device_name,
130130
properties=body,
131131
)
132132

133-
def delete(self, adaptive_device_name: str, namespace_name: str, resource_group_name: str, **kwargs):
134-
poller = self.client.namespace_adaptive_devices.begin_delete(
133+
def delete(self, registry_device_name: str, namespace_name: str, resource_group_name: str, **kwargs):
134+
poller = self.client.registry_devices.begin_delete(
135135
resource_group_name=resource_group_name,
136136
namespace_name=namespace_name,
137-
adaptive_device_name=adaptive_device_name,
137+
registry_device_name=registry_device_name,
138138
)
139139
return self._wait(
140140
poller,
141-
f"Deleting adaptive device '{adaptive_device_name}' from namespace {namespace_name}...",
141+
f"Deleting registry device '{registry_device_name}' from namespace {namespace_name}...",
142142
**kwargs,
143143
)

azext_iot/sdk/deviceregistry/_client.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
NamespaceDevicesOperations,
2626
NamespacesOperations,
2727
PoliciesOperations,
28+
RegistryDevicesOperations,
2829
)
2930

3031
if TYPE_CHECKING:
@@ -51,6 +52,8 @@ class MicrosoftDeviceRegistryManagementService: # pylint: disable=too-many-inst
5152
:vartype policies: azext_iot.sdk.deviceregistry.operations.PoliciesOperations
5253
:ivar namespace_devices: NamespaceDevicesOperations operations
5354
:vartype namespace_devices: azext_iot.sdk.deviceregistry.operations.NamespaceDevicesOperations
55+
:ivar registry_devices: RegistryDevicesOperations operations
56+
:vartype registry_devices: azext_iot.sdk.deviceregistry.operations.RegistryDevicesOperations
5457
:param credential: Credential needed for the client to connect to Azure. Required.
5558
:type credential: ~azure.core.credentials.TokenCredential
5659
:param subscription_id: The ID of the target subscription. The value must be an UUID. Required.
@@ -112,6 +115,9 @@ def __init__(
112115
self.namespace_devices = NamespaceDevicesOperations(
113116
self._client, self._config, self._serialize, self._deserialize
114117
)
118+
self.registry_devices = RegistryDevicesOperations(
119+
self._client, self._config, self._serialize, self._deserialize
120+
)
115121

116122
def send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs: Any) -> HttpResponse:
117123
"""Runs the network request through the client's chained policies.

0 commit comments

Comments
 (0)