jeans/openHASP
jeans/openHASP
1
0
Fork 0
mirror of https://github.com/HASwitchPlate/openHASP.git synced 2025-07-28 13:46:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implement command scheduling

Browse Source
This commit is contained in:
Kuba Szczodrzyński 2024-02-10 20:30:12 +01:00
parent 3fcae65fad
commit 32c21b9c52
No known key found for this signature in database
GPG Key ID: 43037AC62A600562
1 changed files with 87 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
src/hasp/hasp_dispatch.cpp
View File

@ -37,6 +37,8 @@
#endif
#endif
#include <map>
dispatch_conf_t dispatch_setings = {.teleperiod = 300};
uint16_t dispatchSecondsToNextTeleperiod = 0;
@ -48,6 +50,8 @@ haspCommand_t commands[28];
moodlight_t moodlight = {.brightness = 255};
uint8_t saved_jsonl_page = 0;
static std::map<int, lv_task_t*> scheduled_tasks;
/* Sends the payload out on the state/subtopic
*/
void dispatch_state_subtopic(const char* subtopic, const char* payload)
@ -1414,6 +1418,88 @@ void dispatch_sleep(const char*, const char*, uint8_t source)
hasp_set_wakeup_touch(false);
}
static void dispatch_schedule_runner(lv_task_t* task)
{
dispatch_text_line((const char*)task->user_data, TAG_MSGR);
}
void dispatch_schedule(const char*, const char* payload, uint8_t source)
{
// duplicate the string for modification
char* argline = strdup(payload);
// split argline into argv by whitespace; limit to 4 parts
char* argv[4];
int argn = 0;
argv[argn++] = argline;
while(*argline) {
if(*argline == ' ') {
*argline = '\0';
argv[argn++] = argline + 1;
}
argline++;
if(argn == 4) break;
}
const char* action = argv[0];
uint32_t id = atoi(argv[1]);
if(strcasecmp(action, "set") == 0) {
if(argn != 4) {
LOG_ERROR(TAG_MSGR, F("Usage: schedule set <id> <period(ms)> <cmd...>"));
goto end;
}
uint32_t period = atoi(argv[2]);
const char* command = strdup(argv[3]);
if(scheduled_tasks.find(id) != scheduled_tasks.end()) {
// update an existing task
lv_task_t* task = scheduled_tasks[id];
free(task->user_data);
task->period = period;
task->user_data = (void*)command;
} else {
// create a new task
lv_task_t* task = lv_task_create(dispatch_schedule_runner, period, LV_TASK_PRIO_MID, (void*)command);
scheduled_tasks[id] = task;
}
LOG_INFO(TAG_MSGR, F("Scheduled command ID %u, every %u ms: %s"), id, period, command);
goto end;
}
if(argn != 2) {
LOG_ERROR(TAG_MSGR, F("Usage: schedule <set/del/start/stop> <id>"));
goto end;
}
if(scheduled_tasks.find(id) == scheduled_tasks.end()) {
LOG_ERROR(TAG_MSGR, F("Task by ID %u does not exist"), id);
goto end;
}
{
lv_task_t* task = scheduled_tasks[id];
if(strcasecmp(action, "del") == 0) {
free(task->user_data);
lv_task_del(task);
scheduled_tasks.erase(id);
goto end;
}
if(strcasecmp(action, "start") == 0) {
lv_task_set_prio(task, LV_TASK_PRIO_MID);
goto end;
}
if(strcasecmp(action, "stop") == 0) {
lv_task_set_prio(task, LV_TASK_PRIO_OFF);
goto end;
}
}
end:
// release the duplicated argline
free(argv[0]);
}
void dispatch_idle_state(uint8_t state)
{
char topic[8];
@ -1547,6 +1633,7 @@ void dispatchSetup()
dispatch_add_command(PSTR("moodlight"), dispatch_moodlight);
dispatch_add_command(PSTR("idle"), dispatch_idle);
dispatch_add_command(PSTR("sleep"), dispatch_sleep);
dispatch_add_command(PSTR("schedule"), dispatch_schedule);
dispatch_add_command(PSTR("statusupdate"), dispatch_statusupdate);
dispatch_add_command(PSTR("clearpage"), dispatch_clear_page);
dispatch_add_command(PSTR("clearfont"), dispatch_clear_font);