Skip to content

Commit c7cc3d8

Browse files
committed
Make TestSubscriptionResumptionCapacityStep1 an async test
Eliminate use of ZCLSubscribeAttribute and embrace asyncio.
1 parent c9b88fe commit c7cc3d8

File tree

2 files changed

+9
-7
lines changed

2 files changed

+9
-7
lines changed

src/controller/python/test/test_scripts/base.py

+6-5
Original file line numberDiff line numberDiff line change
@@ -1425,25 +1425,26 @@ def OnValueReport(path: Attribute.TypedAttributePath, transaction: Attribute.Sub
14251425
controller 1 in container 1 while the Step2 is executed in controller 2 in container 2
14261426
'''
14271427

1428-
def TestSubscriptionResumptionCapacityStep1(self, nodeid: int, endpoint: int, passcode: int, subscription_capacity: int):
1428+
async def TestSubscriptionResumptionCapacityStep1(self, nodeid: int, endpoint: int, passcode: int, subscription_capacity: int):
14291429
try:
14301430
# BasicInformation Cluster, NodeLabel Attribute
14311431
for i in range(subscription_capacity):
1432-
self.devCtrl.ZCLSubscribeAttribute(
1433-
"BasicInformation", "NodeLabel", nodeid, endpoint, 1, 50, keepSubscriptions=True, autoResubscribe=False)
1432+
await self.devCtrl.ReadAttribute(nodeid, [(endpoint, Clusters.BasicInformation.Attributes.NodeLabel)], None,
1433+
False, reportInterval=(1, 50),
1434+
keepSubscriptions=True, autoResubscribe=False)
14341435

14351436
logger.info("Send OpenCommissioningWindow command on fist controller")
14361437
discriminator = 3840
14371438
salt = secrets.token_bytes(16)
14381439
iterations = 2000
14391440
verifier = GenerateVerifier(passcode, salt, iterations)
1440-
asyncio.run(self.devCtrl.SendCommand(
1441+
await self.devCtrl.SendCommand(
14411442
nodeid, 0, Clusters.AdministratorCommissioning.Commands.OpenCommissioningWindow(
14421443
commissioningTimeout=180,
14431444
PAKEPasscodeVerifier=verifier,
14441445
discriminator=discriminator,
14451446
iterations=iterations,
1446-
salt=salt), timedRequestTimeoutMs=10000))
1447+
salt=salt), timedRequestTimeoutMs=10000)
14471448
return True
14481449

14491450
except Exception as ex:

src/controller/python/test/test_scripts/subscription_resumption_capacity_test_ctrl1.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919

2020
# Commissioning test.
2121

22+
import asyncio
2223
import os
2324
import sys
2425
from optparse import OptionParser
@@ -113,8 +114,8 @@ def main():
113114
"Failed on on-network commissioing")
114115

115116
FailIfNot(
116-
test.TestSubscriptionResumptionCapacityStep1(
117-
options.nodeid, TEST_ENDPOINT_ID, options.setuppin, options.subscriptionCapacity),
117+
asyncio.run(test.TestSubscriptionResumptionCapacityStep1(
118+
options.nodeid, TEST_ENDPOINT_ID, options.setuppin, options.subscriptionCapacity)),
118119
"Failed on step 1 of testing subscription resumption capacity")
119120

120121
timeoutTicker.stop()

0 commit comments

Comments
 (0)