21
21
22
22
import chip .clusters as Clusters
23
23
from chip .clusters .Types import NullValue
24
- from matter_testing_support import MatterBaseTest , TestStep , async_test_body , default_matter_test_main
24
+ from matter_testing_support import EventChangeCallback , MatterBaseTest , TestStep , async_test_body , default_matter_test_main
25
25
from mobly import asserts
26
- from TC_EEVSE_Utils import EEVSEBaseTestHelper , EventChangeCallback
26
+ from TC_EEVSE_Utils import EEVSEBaseTestHelper
27
27
28
28
logger = logging .getLogger (__name__ )
29
29
@@ -123,7 +123,7 @@ async def test_TC_EEVSE_2_2(self):
123
123
124
124
self .step ("4" )
125
125
await self .send_test_event_trigger_pluggedin ()
126
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EVConnected )
126
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EVConnected )
127
127
128
128
self .step ("4a" )
129
129
await self .check_evse_attribute ("State" , Clusters .EnergyEvse .Enums .StateEnum .kPluggedInNoDemand )
@@ -147,7 +147,7 @@ async def test_TC_EEVSE_2_2(self):
147
147
148
148
self .step ("6" )
149
149
await self .send_test_event_trigger_charge_demand ()
150
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStarted )
150
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStarted )
151
151
152
152
self .step ("6a" )
153
153
await self .check_evse_attribute ("State" , expected_state )
@@ -172,7 +172,7 @@ async def test_TC_EEVSE_2_2(self):
172
172
# Sleep for the charging duration plus a couple of seconds to check it has stopped
173
173
time .sleep (charging_duration + 2 )
174
174
# check EnergyTransferredStoped (EvseStopped)
175
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStopped )
175
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStopped )
176
176
expected_reason = Clusters .EnergyEvse .Enums .EnergyTransferStoppedReasonEnum .kEVSEStopped
177
177
self .validate_energy_transfer_stopped_event (event_data , session_id , expected_state , expected_reason )
178
178
@@ -188,7 +188,7 @@ async def test_TC_EEVSE_2_2(self):
188
188
max_charge_current = 12000
189
189
190
190
await self .send_enable_charge_command (charge_until = charge_until , min_charge = min_charge_current , max_charge = max_charge_current )
191
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStarted )
191
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStarted )
192
192
193
193
self .step ("8a" )
194
194
await self .check_evse_attribute ("State" , Clusters .EnergyEvse .Enums .StateEnum .kPluggedInCharging )
@@ -228,7 +228,7 @@ async def test_TC_EEVSE_2_2(self):
228
228
229
229
self .step ("10" )
230
230
await self .send_test_event_trigger_charge_demand_clear ()
231
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStopped )
231
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStopped )
232
232
expected_reason = Clusters .EnergyEvse .Enums .EnergyTransferStoppedReasonEnum .kEVStopped
233
233
self .validate_energy_transfer_stopped_event (event_data , session_id , expected_state , expected_reason )
234
234
@@ -239,15 +239,15 @@ async def test_TC_EEVSE_2_2(self):
239
239
await self .send_test_event_trigger_charge_demand ()
240
240
# Check we get EnergyTransferStarted again
241
241
await self .send_enable_charge_command (charge_until = charge_until , min_charge = min_charge_current , max_charge = max_charge_current )
242
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStarted )
242
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStarted )
243
243
self .validate_energy_transfer_started_event (event_data , session_id , expected_state , expected_max_charge )
244
244
245
245
self .step ("11a" )
246
246
await self .check_evse_attribute ("State" , Clusters .EnergyEvse .Enums .StateEnum .kPluggedInCharging )
247
247
248
248
self .step ("12" )
249
249
await self .send_test_event_trigger_charge_demand_clear ()
250
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStopped )
250
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStopped )
251
251
expected_reason = Clusters .EnergyEvse .Enums .EnergyTransferStoppedReasonEnum .kEVStopped
252
252
self .validate_energy_transfer_stopped_event (event_data , session_id , expected_state , expected_reason )
253
253
@@ -256,7 +256,7 @@ async def test_TC_EEVSE_2_2(self):
256
256
257
257
self .step ("13" )
258
258
await self .send_test_event_trigger_pluggedin_clear ()
259
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EVNotDetected )
259
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EVNotDetected )
260
260
expected_state = Clusters .EnergyEvse .Enums .StateEnum .kPluggedInNoDemand
261
261
self .validate_ev_not_detected_event (event_data , session_id , expected_state , expected_duration = 0 , expected_charged = 0 )
262
262
@@ -280,13 +280,13 @@ async def test_TC_EEVSE_2_2(self):
280
280
session_id = session_id + 1
281
281
282
282
# Check we get a new EVConnected event with updated session ID
283
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EVConnected )
283
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EVConnected )
284
284
self .validate_ev_connected_event (event_data , session_id )
285
285
286
286
self .step ("14a" )
287
287
await self .send_test_event_trigger_charge_demand ()
288
288
expected_state = Clusters .EnergyEvse .Enums .StateEnum .kPluggedInCharging # This is the value at the event time
289
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStarted )
289
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStarted )
290
290
self .validate_energy_transfer_started_event (event_data , session_id , expected_state , expected_max_charge )
291
291
292
292
self .step ("14b" )
@@ -295,7 +295,7 @@ async def test_TC_EEVSE_2_2(self):
295
295
self .step ("15" )
296
296
await self .send_disable_command ()
297
297
expected_state = Clusters .EnergyEvse .Enums .StateEnum .kPluggedInCharging # This is the value prior to stopping
298
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EnergyTransferStopped )
298
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EnergyTransferStopped )
299
299
expected_reason = Clusters .EnergyEvse .Enums .EnergyTransferStoppedReasonEnum .kEVSEStopped
300
300
self .validate_energy_transfer_stopped_event (event_data , session_id , expected_state , expected_reason )
301
301
@@ -307,7 +307,7 @@ async def test_TC_EEVSE_2_2(self):
307
307
308
308
self .step ("17" )
309
309
await self .send_test_event_trigger_pluggedin_clear ()
310
- event_data = events_callback .WaitForEventReport (Clusters .EnergyEvse .Events .EVNotDetected )
310
+ event_data = events_callback .wait_for_event_report (Clusters .EnergyEvse .Events .EVNotDetected )
311
311
expected_state = Clusters .EnergyEvse .Enums .StateEnum .kPluggedInNoDemand
312
312
self .validate_ev_not_detected_event (event_data , session_id , expected_state , expected_duration = 0 , expected_charged = 0 )
313
313
0 commit comments