@@ -27,7 +27,6 @@ const dbEnum = require('../../src-shared/db-enum.js')
27
27
const queryZcl = require ( './query-zcl.js' )
28
28
const queryUpgrade = require ( '../sdk/matter.js' )
29
29
const queryDeviceType = require ( './query-device-type' )
30
- const querySession = require ( './query-session' )
31
30
const queryCommand = require ( './query-command.js' )
32
31
const restApi = require ( '../../src-shared/rest-api.js' )
33
32
const _ = require ( 'lodash' )
@@ -577,18 +576,16 @@ async function selectCountOfEndpointsWithGivenEndpointIdentifier(
577
576
/**
578
577
* Promises to add an endpoint type.
579
578
*
579
+ * @export
580
580
* @param {* } db
581
- * @param {* } sessionPartitionInfo
581
+ * @param {* } sessionId
582
582
* @param {* } name
583
583
* @param {* } deviceTypeRef
584
- * @param {* } deviceTypeIdentifier
585
- * @param {* } deviceTypeVersion
586
- * @param {* } doTransaction
587
584
* @returns Promise to update endpoints.
588
585
*/
589
586
async function insertEndpointType (
590
587
db ,
591
- sessionPartitionInfo ,
588
+ sessionId ,
592
589
name ,
593
590
deviceTypeRef ,
594
591
deviceTypeIdentifier ,
@@ -607,8 +604,8 @@ async function insertEndpointType(
607
604
// Insert endpoint type
608
605
let newEndpointTypeId = await dbApi . dbInsert (
609
606
db ,
610
- 'INSERT OR REPLACE INTO ENDPOINT_TYPE ( SESSION_PARTITION_REF , NAME ) VALUES ( ?, ?)' ,
611
- [ sessionPartitionInfo . sessionPartitionId , name ]
607
+ 'INSERT OR REPLACE INTO ENDPOINT_TYPE ( SESSION_REF , NAME ) VALUES ( ?, ?)' ,
608
+ [ sessionId , name ]
612
609
)
613
610
614
611
// Creating endpoint type and device type ref combinations along with order of insertion
@@ -638,7 +635,7 @@ async function insertEndpointType(
638
635
db ,
639
636
'ERROR' ,
640
637
isErrorStringPresent ? err . split ( 'Error:' ) [ 1 ] : err ,
641
- sessionPartitionInfo . sessionRef ,
638
+ sessionId ,
642
639
1 ,
643
640
1
644
641
)
@@ -659,7 +656,7 @@ async function insertEndpointType(
659
656
for ( const dtRef of deviceTypeRefs ) {
660
657
await setEndpointDefaults (
661
658
db ,
662
- sessionPartitionInfo . sessionRef ,
659
+ sessionId ,
663
660
newEndpointTypeId ,
664
661
dtRef ,
665
662
doTransaction
@@ -682,8 +679,7 @@ async function duplicateEndpointType(db, endpointTypeId) {
682
679
db ,
683
680
`
684
681
SELECT
685
- SESSION_PARTITION.SESSION_REF,
686
- SESSION_PARTITION.SESSION_PARTITION_ID,
682
+ ENDPOINT_TYPE.SESSION_REF,
687
683
ENDPOINT_TYPE.NAME,
688
684
ENDPOINT_TYPE_DEVICE.DEVICE_TYPE_REF,
689
685
ENDPOINT_TYPE_DEVICE.DEVICE_IDENTIFIER,
@@ -694,10 +690,6 @@ async function duplicateEndpointType(db, endpointTypeId) {
694
690
ENDPOINT_TYPE_DEVICE
695
691
ON
696
692
ENDPOINT_TYPE.ENDPOINT_TYPE_ID = ENDPOINT_TYPE_DEVICE.ENDPOINT_TYPE_REF
697
- INNER JOIN
698
- SESSION_PARTITION
699
- ON
700
- ENDPOINT_TYPE.SESSION_PARTITION_REF = SESSION_PARTITION.SESSION_PARTITION_ID
701
693
WHERE
702
694
ENDPOINT_TYPE_DEVICE.ENDPOINT_TYPE_REF = ?` ,
703
695
[ endpointTypeId ]
@@ -707,12 +699,9 @@ async function duplicateEndpointType(db, endpointTypeId) {
707
699
// Enter into the endpoint_type table
708
700
newEndpointTypeId = await dbApi . dbInsert (
709
701
db ,
710
- `INSERT INTO ENDPOINT_TYPE (SESSION_PARTITION_REF , NAME)
702
+ `INSERT INTO ENDPOINT_TYPE (SESSION_REF , NAME)
711
703
VALUES (?, ?)` ,
712
- [
713
- endpointTypeDeviceInfo [ 0 ] . SESSION_PARTITION_ID ,
714
- endpointTypeDeviceInfo [ 0 ] . NAME ,
715
- ]
704
+ [ endpointTypeDeviceInfo [ 0 ] . SESSION_REF , endpointTypeDeviceInfo [ 0 ] . NAME ]
716
705
)
717
706
718
707
// Enter into the endpoint_type_device table to establish the endpoint_type
@@ -769,12 +758,8 @@ async function updateEndpointType(db, sessionId, endpointTypeId, changesArray) {
769
758
INNER JOIN
770
759
ENDPOINT_TYPE_DEVICE
771
760
ON ENDPOINT_TYPE.ENDPOINT_TYPE_ID = ENDPOINT_TYPE_DEVICE.ENDPOINT_TYPE_REF
772
- INNER JOIN
773
- SESSION_PARTITION
774
- ON
775
- ENDPOINT_TYPE.SESSION_PARTITION_REF = SESSION_PARTITION.SESSION_PARTITION_ID
776
761
WHERE
777
- ENDPOINT_TYPE. ENDPOINT_TYPE_ID = ? AND SESSION_PARTITION. SESSION_REF = ?
762
+ ENDPOINT_TYPE_ID = ? AND SESSION_REF = ?
778
763
ORDER BY
779
764
ENDPOINT_TYPE_DEVICE.DEVICE_TYPE_ORDER` ,
780
765
[ endpointTypeId , sessionId ]
@@ -888,10 +873,7 @@ async function updateEndpointType(db, sessionId, endpointTypeId, changesArray) {
888
873
/**
889
874
* Promise to set the default attributes and clusters for a endpoint type.
890
875
* @param {* } db
891
- * @param {* } sessionId
892
876
* @param {* } endpointTypeId
893
- * @param {* } deviceTypeRef
894
- * @param {* } doTransaction
895
877
*/
896
878
async function setEndpointDefaults (
897
879
db ,
@@ -911,20 +893,7 @@ async function setEndpointDefaults(
911
893
if ( pkgs == null || pkgs . length < 1 )
912
894
throw new Error ( 'Could not locate package id for a given session.' )
913
895
914
- let deviceTypeInfo =
915
- await querySession . selectDeviceTypePackageInfoFromDeviceTypeId (
916
- db ,
917
- deviceTypeRef
918
- )
919
- let endpointTypeCategory =
920
- deviceTypeInfo . length > 0 ? deviceTypeInfo [ 0 ] . category : null
921
896
let packageId = pkgs [ 0 ] . id
922
- for ( let i = 0 ; i < pkgs . length ; i ++ ) {
923
- if ( pkgs [ i ] . category == endpointTypeCategory ) {
924
- packageId = pkgs [ i ] . id
925
- break
926
- }
927
- }
928
897
let clusters = await queryDeviceType . selectDeviceTypeClustersByDeviceTypeRef (
929
898
db ,
930
899
deviceTypeRef
@@ -1247,16 +1216,7 @@ async function resolveNonOptionalAndReportableAttributes(
1247
1216
async function selectEndpointTypeCount ( db , sessionId ) {
1248
1217
let x = await dbApi . dbGet (
1249
1218
db ,
1250
- `SELECT
1251
- COUNT(ENDPOINT_TYPE_ID) AS CNT
1252
- FROM
1253
- ENDPOINT_TYPE
1254
- INNER JOIN
1255
- SESSION_PARTITION
1256
- ON
1257
- SESSION_PARTITION.SESSION_PARTITION_ID = ENDPOINT_TYPE.SESSION_PARTITION_REF
1258
- WHERE
1259
- SESSION_PARTITION.SESSION_REF = ?` ,
1219
+ 'SELECT COUNT(ENDPOINT_TYPE_ID) AS CNT FROM ENDPOINT_TYPE WHERE SESSION_REF = ?' ,
1260
1220
[ sessionId ]
1261
1221
)
1262
1222
return x [ 'CNT' ]
@@ -1283,11 +1243,7 @@ SELECT
1283
1243
COUNT(ENDPOINT_TYPE_ID)
1284
1244
FROM
1285
1245
ENDPOINT_TYPE
1286
- INNER JOIN
1287
- SESSION_PARTITION
1288
- ON
1289
- SESSION_PARTITION.SESSION_PARTITION_ID = ENDPOINT_TYPE.SESSION_PARTITION_REF
1290
- WHERE SESSION_PARTITION.SESSION_REF = ?
1246
+ WHERE SESSION_REF = ?
1291
1247
AND ENDPOINT_TYPE_ID IN
1292
1248
(SELECT ENDPOINT_TYPE_REF
1293
1249
FROM ENDPOINT_TYPE_CLUSTER
@@ -1448,12 +1404,8 @@ JOIN
1448
1404
ATTRIBUTE AS A ON ETA.ATTRIBUTE_REF = A.ATTRIBUTE_ID
1449
1405
JOIN
1450
1406
ENDPOINT_TYPE AS ET ON ETA.ENDPOINT_TYPE_REF = ET.ENDPOINT_TYPE_ID
1451
- INNER JOIN
1452
- SESSION_PARTITION
1453
- ON
1454
- ET.SESSION_PARTITION_REF = SESSION_PARTITION.SESSION_PARTITION_ID
1455
1407
WHERE
1456
- SESSION_PARTITION .SESSION_REF = ? AND ETA.INCLUDED = 1
1408
+ ET .SESSION_REF = ? AND ETA.INCLUDED = 1
1457
1409
ORDER BY
1458
1410
CLUSTER_CODE, ATTRIBUTE_CODE
1459
1411
` ,
0 commit comments