iot/sprocket-plugin-gpio
1
0
Fork 0
mirror of https://gitlab.com/wirelos/sprocket-plugin-gpio.git synced 2025-12-14 21:32:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

add default subscriptions

Browse Source
This commit is contained in:
0x1d
2018-11-17 16:54:06 +01:00
parent ea3a2deb55
commit e0ad7ca823
3 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/inputs/analog/AnalogInputPlugin.cpp
View File

@@ -5,9 +5,14 @@ AnalogInputPlugin::AnalogInputPlugin(GpioConfig cfg){
} }
void AnalogInputPlugin::activate(Scheduler *userScheduler) void AnalogInputPlugin::activate(Scheduler *userScheduler)
{ {
// add update task
inputTask.set(TASK_MILLISECOND * config.updateInterval, TASK_FOREVER, std::bind(&AnalogInputPlugin::checkInput, this)); inputTask.set(TASK_MILLISECOND * config.updateInterval, TASK_FOREVER, std::bind(&AnalogInputPlugin::checkInput, this));
userScheduler->addTask(inputTask); userScheduler->addTask(inputTask);
inputTask.enable(); inputTask.enable();
// add dummy subscription
subscribe(config.topic, [](String msg){});
PRINT_MSG(Serial, "PLUGIN", "AnalogInputPlugin activated"); PRINT_MSG(Serial, "PLUGIN", "AnalogInputPlugin activated");
} }

5
src/inputs/digital/DigitalInputPlugin.cpp
View File

@@ -10,9 +10,14 @@ DigitalInputPlugin::DigitalInputPlugin(GpioConfig cfg)
} }
void DigitalInputPlugin::activate(Scheduler *userScheduler) void DigitalInputPlugin::activate(Scheduler *userScheduler)
{ {
// add update task
inputTask.set(TASK_MILLISECOND * config.updateInterval, TASK_FOREVER, std::bind(&DigitalInputPlugin::checkInput, this)); inputTask.set(TASK_MILLISECOND * config.updateInterval, TASK_FOREVER, std::bind(&DigitalInputPlugin::checkInput, this));
userScheduler->addTask(inputTask); userScheduler->addTask(inputTask);
inputTask.enable(); inputTask.enable();
// add dummy subscription
subscribe(config.topic, [](String msg){});
PRINT_MSG(Serial, "PLUGIN", "DigitalInputPlugin activated"); PRINT_MSG(Serial, "PLUGIN", "DigitalInputPlugin activated");
} }

6
src/inputs/rotary/RotaryPlugin.cpp
View File

@@ -10,9 +10,15 @@ RotaryPlugin::RotaryPlugin(RotaryConfig cfg)
void RotaryPlugin::activate(Scheduler *userScheduler) void RotaryPlugin::activate(Scheduler *userScheduler)
{ {
// add update task
inputTask.set(TASK_MILLISECOND * config.updateInterval, TASK_FOREVER, std::bind(&RotaryPlugin::checkInput, this)); inputTask.set(TASK_MILLISECOND * config.updateInterval, TASK_FOREVER, std::bind(&RotaryPlugin::checkInput, this));
userScheduler->addTask(inputTask); userScheduler->addTask(inputTask);
inputTask.enable(); inputTask.enable();
// add dummy subscription
subscribe(config.topic, [](String msg){});
subscribe(String(config.topic) + "/btn", [](String msg){});
PRINT_MSG(Serial, "PLUGIN", "RotaryPlugin activated"); PRINT_MSG(Serial, "PLUGIN", "RotaryPlugin activated");
} }