|
|
@@ -582,11 +582,11 @@ class KVSView(View):
|
|
|
sdp_offer = request_dict.get('sdp_offer', None)
|
|
|
if not all([uid, sdp_offer]):
|
|
|
return response.json(444)
|
|
|
- if uid == '517J385BNUGP3CPP111A':
|
|
|
- uid = 'NUWGTV5TUK8G8VSS111A'
|
|
|
+
|
|
|
try:
|
|
|
serial = CommonService.get_serial_number_by_uid(uid)
|
|
|
- kvs_qs = KVS.objects.filter(stream_name=serial).values('channel_arn')
|
|
|
+ channel_name = 'Ansjer_Device_{}'.format(serial)
|
|
|
+ kvs_qs = KVS.objects.filter(channel_name=channel_name).values('channel_arn')
|
|
|
if not kvs_qs.exists():
|
|
|
return response.json(173)
|
|
|
channel_arn = kvs_qs[0]['channel_arn']
|
