o
|
^13j
|
ã @ s< d dl mZmZmZ d dlmZ eddgdZdefddZe d ¡defd
|
d Z e
|
d ¡ded e fddZ e d¡ded e fddZ e d¡defddZe d¡ded e fddZe d¡ded e fddZe d ¡ded e fd d Ze d ¡ded e d efd!d"Ze d#¡ded e d efd$d%Zd&S )'é )Ú APIRouterÚ HTTPExceptionÚRequest)Ú MqttCommandz/api/v1/devicesÚdevices)ÚprefixÚtagsÚrequestc C s
|
| j jjS )N)ÚappÚstateÚmqtt)r © r ú2D:\apps\smartlearning\server\app\routes\devices.pyÚ _get_mqtt s
|
r z /initializedc à s | j jj}d| ¡ iS )Nr )r
|
r Ú init_registryZlist_initialized)r Úregistryr r r Úlist_initialized_devices s
|
r z/initialized/{device_id}Ú device_idc à s, | j jj}| |¡stddd|ddS )Né z"Device not in initialized registry©Ú status_codeÚdetailÚremoved)r Ústatus)r
|
r r Úremover )r r r r r r Úreset_initialized_device s
|
|
|
|
r z/{device_id}/init-statusc à s& | j jj}| |¡}||d u|dS )N)r Z initializedÚrecord)r
|
r r Z
|
get_record)r r r r r r r Úget_device_init_status s
|
|
ýr Ú c à s" | j jj}ddd | ¡ D iS )Nr c S s g | ]}| ¡ qS r )Ú
|
model_dump)Ú.0Údr r r Ú
|
<listcomp>( s z list_devices.<locals>.<listcomp>)r
|
r Ú device_storeÚ list_devices)r Ústorer r r r$ % s
|
r$ z /{device_id}c à s* | j jj}| |¡}|stddd|S )Nr zDevice not foundr )r
|
r r# Ú
|
get_devicer )r r r% Zdevicer r r r& + s
|
|
r& z/{device_id}/acksc à ó | j jj}|| |¡dS )N)r Zacks)r
|
r r# Úget_acks©r r r% r r r Úget_device_acks4 ó
|
r* z/{device_id}/eventsc à r' )N)r Úevents)r
|
r r# Ú
|
get_eventsr) r r r Úget_device_events: r+ r. z/{device_id}/cmdÚcommandc à ó* t | }| ||j|j|jjpd¡}|S )Né< )r Ú publish_ctlÚactionÚpayloadÚheaderÚttl©r r r/ r Úresultr r r Ú send_command@ ó r9 z/{device_id}/taskc à r0 )Ni )r Ú publish_taskr3 r4 r5 r6 r7 r r r Ú send_taskG r: r< N)Úfastapir r r Úapp.models.schemasr Úrouterr Úgetr ÚdeleteÚstrr r r$ r& r* r. Úpostr9 r< r r r r Ú<module> s,
|
|
