diff options
| author |   Romain Forlot <romain.forlot@iot.bzh> | 2018-07-20 09:42:50 +0200 |
|---|---|---|
| committer | Romain Forlot <romain.forlot@iot.bzh> | 2018-07-26 09:57:07 +0200 |
| commit | d864062bf79c1c086c1f0ab4f8664d16adabeae0 (patch) | |
| tree | 9c9bf43f04cf0f4b1393d218e1a4baf9cdf8a2cf /conf.d/controller | |
| parent | c96df58a88b60c7501b3c8a758c0277c17088371 (diff) | |
Provide entire history if the option is enabled
Then it is possible to compare an event data with past event
data. Also rationalize the code to invoke the event's callback
Change-Id: I4309e0643d4c21c44d8fef510507e28745a9f83d
Signed-off-by: Romain Forlot <romain.forlot@iot.bzh>
Diffstat (limited to 'conf.d/controller')
| -rw-r--r-- | conf.d/controller/lua.d/aft.lua | 31 |
1 files changed, 15 insertions, 16 deletions
diff --git a/conf.d/controller/lua.d/aft.lua b/conf.d/controller/lua.d/aft.lua index b9061fb..f0c7388 100644 --- a/conf.d/controller/lua.d/aft.lua +++ b/conf.d/controller/lua.d/aft.lua @@ -106,6 +106,17 @@ function _AFT.registerData(dict, eventData) end end +function _AFT.triggerEvtCallback(eventName) + if _AFT.monitored_events[eventName].cb then + local data_n = table_size(_AFT.monitored_events[event.name].data) + if _AFT.event_history == true then + _AFT.monitored_events[event.name].cb(v.name, _AFT.monitored_events[event.name].data[data_n], _AFT.monitored_events[event.name].data) + else + _AFT.monitored_events[event.name].cb(v.name, _AFT.monitored_events[event.name].data[data_n]) + end + end +end + function _AFT.bindingEventHandler(eventObj, uid) local eventName = nil local eventListeners = nil @@ -211,10 +222,7 @@ function _AFT.assertEvtGrpNotReceived(eventGroup, timeout) _AFT.assertIsTrue(count == 0, "One of the following events has been received: '".. eventName .."' but it shouldn't") for _,event in pairs(eventGroup) do - if _AFT.monitored_events[event.name].cb then - local data_n = table_size(_AFT.monitored_events[event.name].data) - _AFT.monitored_events[event.name].cb(v.name, _AFT.monitored_events[event.name].data[data_n]) - end + _AFT.triggerEvtCallback(event.name) end end @@ -239,10 +247,7 @@ function _AFT.assertEvtGrpReceived(eventGroup, timeout) _AFT.assertIsTrue(count >= table_size(eventGroup), "None or one of the following events: '".. eventName .."' has not been received") for _,event in pairs(eventGroup) do - if _AFT.monitored_events[event.name].cb then - local data_n = table_size(_AFT.monitored_events[event.name].data) - _AFT.monitored_events[event.name].cb(v.name, _AFT.monitored_events[event.name].data[data_n]) - end + _AFT.triggerEvtCallback(event.name) end end @@ -254,10 +259,7 @@ function _AFT.assertEvtNotReceived(eventName, timeout) _AFT.assertIsTrue(count == 0, "Event '".. eventName .."' received but it shouldn't") - if _AFT.monitored_events[eventName].cb then - local data_n = #_AFT.monitored_events[eventName].data - _AFT.monitored_events[eventName].cb(eventName, _AFT.monitored_events[eventName].data[data_n]) - end + _AFT.triggerEvtCallback(event.name) end function _AFT.assertEvtReceived(eventName, timeout) @@ -268,10 +270,7 @@ function _AFT.assertEvtReceived(eventName, timeout) _AFT.assertIsTrue(count > 0, "No event '".. eventName .."' received") - if _AFT.monitored_events[eventName].cb then - local data_n = #_AFT.monitored_events[eventName].data - _AFT.monitored_events[eventName].cb(eventName, _AFT.monitored_events[eventName].data[data_n]) - end + _AFT.triggerEvtCallback(event.name) end function _AFT.testEvtNotReceived(testName, eventName, timeout, setUp, tearDown) |