summaryrefslogtreecommitdiffstats
path: root/conf.d/controller
diff options
context:
space:
mode:
authorRomain Forlot <romain.forlot@iot.bzh>2018-07-20 09:42:50 +0200
committerRomain Forlot <romain.forlot@iot.bzh>2018-07-26 09:57:07 +0200
commitd864062bf79c1c086c1f0ab4f8664d16adabeae0 (patch)
tree9c9bf43f04cf0f4b1393d218e1a4baf9cdf8a2cf /conf.d/controller
parentc96df58a88b60c7501b3c8a758c0277c17088371 (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.lua31
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)