DMX512_engine.c

/***============================================================================================================================
 * Depedencies inclusion
 * Necessary dependencies should be declared here. Header file should contain as little dependecies declarations as possible
 *=============================================================================================================================*/
 
#if cueOS_CONFIG_NODETYPE == cueOS_NODETYPE_SLAVE_DMX
 
#include "cueos_config.h"
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include "cmsis_os.h"
#include "DMX512_driver.h"
#include "DMX512_engine.h"
#include "leds_driver.h"
#include "QLSF_manager.h"
 
 
/***============================================================================================================================
 * Private variables definitions
 * These variables are only accessible from within the file's scope
 *=============================================================================================================================*/
 
static DMX512_engine_s engine;
static osThreadId_t DMX512engineThread = NULL;
 
 
/***============================================================================================================================
 * Private functions definitions
 * These functions are only accessible from within the file's scope
 *=============================================================================================================================*/
 
static void _DMX512_engine_manage(void *arg){
    for(;;){
        DMX512_scene_pool_manage(engine.scenes);
        DMX512_chaser_pool_manage(engine.chasers);
        osDelay(DMX512_ENGINE_THREAD_DELAY);
    }
}
 
//TODO: add engine reset to clear everything ?
 
/***============================================================================================================================
 * Public functions definitions
 * These functions can be accessed outside of the file's scope
 * @see DMX512_engine.h for declarations
 *=============================================================================================================================*/
 
void DMX512_engine_init(void){
 
    //TODO: modify pool instances to return value instead of pointer to value since engine is a singleton
    //and should keep the values safe until it is exited
 
    engine.fixtures       = DMX512_fixture_pool_new();
    engine.scenes         = DMX512_scene_pool_new();
    engine.chasers        = DMX512_chaser_pool_new();
 
    QLFS_manager_load("show.qlsf");
 
    if(DMX512_driver_get_status() != DMX512_DRIVER_INITIALISED){
        DMX512_driver_init();
    }
 
    DMX512_engine_start();
 
}
 
//TODO: maybe add a "started state" to prevent recursive calls to start/stop function
 
void DMX512_engine_start(void){
    osThreadAttr_t attr = {.stack_size = 2048,.priority = (osPriority_t) osPriorityNormal};
    DMX512_driver_start();
    DMX512engineThread = osThreadNew(_DMX512_engine_manage, NULL, &attr);
}
 
void DMX512_engine_stop(void){
    DMX512_driver_stop();
    osThreadTerminate(DMX512engineThread);
}
 
DMX512_engine_err_e DMX512_engine_patch_add(uint16_t fixture_id, uint16_t address, uint16_t ch_count){
    DMX512_fixture_s fixture = DMX512_fixture_new(fixture_id, address, ch_count);
    return DMX512_fixture_pool_add(engine.fixtures, fixture);
}
 
DMX512_engine_err_e DMX512_engine_patch_get(uint16_t fixture_id, DMX512_fixture_s **fixture){
    return DMX512_fixture_pool_get(engine.fixtures, fixture_id, fixture);
}
 
DMX512_fixture_pool_s *DMX512_engine_patch_get_all(void){
    return engine.fixtures;
}
 
DMX512_engine_err_e DMX512_engine_patch_delete(uint16_t fixture_id){
    return DMX512_fixture_pool_del(engine.fixtures, fixture_id);
}
 
DMX512_engine_err_e DMX512_engine_scene_add(uint16_t scene_id, uint16_t fadein_time, uint16_t fadeout_time){
    DMX512_scene_s scene = DMX512_scene_new(scene_id, fadein_time, fadeout_time);
    return DMX512_scene_pool_add(engine.scenes, scene);
}
 
DMX512_engine_err_e DMX512_engine_scene_add_preset(uint16_t scene_id, uint16_t fixture_id, uint16_t channel_count, uint16_t *channels, uint8_t *values){
 
    DMX512_scene_s *scene       = NULL;
    DMX512_fixture_s *fixture   = NULL;
 
    DMX512_fixture_pool_get(engine.fixtures, fixture_id, &fixture);
    DMX512_scene_pool_get(engine.scenes, scene_id, &scene);
 
    DMX512_fixture_preset_s preset = DMX512_fixture_preset_new(fixture, channel_count, channels, values);
 
    return DMX512_scene_add_fixture_preset(scene, preset);
 
}
 
DMX512_engine_err_e DMX512_engine_scene_get(uint16_t scene_id, DMX512_scene_s **scene){
    return DMX512_scene_pool_get(engine.scenes, scene_id, scene);
}
 
DMX512_scene_pool_s *DMX512_engine_scene_get_all(void){
    return engine.scenes;
}
 
DMX512_engine_err_e DMX512_engine_scene_delete(uint16_t scene_id){
    return DMX512_fixture_pool_del(engine.fixtures, scene_id);
}
 
DMX512_engine_err_e DMX512_engine_chaser_add(uint16_t chaser_id, DMX512_chaser_mode_e mode, DMX512_chaser_direction_e direction){
    DMX512_chaser_s chaser = DMX512_chaser_new(chaser_id, mode, direction);
    return DMX512_chaser_pool_add(engine.chasers, chaser);
}
 
DMX512_engine_err_e DMX512_engine_chaser_get(uint16_t chaser_id, DMX512_chaser_s **chaser){
    return DMX512_chaser_pool_get(engine.chasers, chaser_id, chaser);
}
 
DMX512_chaser_pool_s *DMX512_engine_chaser_get_all(void){
    return engine.chasers;
}
 
DMX512_engine_err_e DMX512_engine_chaser_delete(uint16_t chaser_id){
    return DMX512_fixture_pool_del(engine.fixtures, chaser_id);
}
 
void DMX512_engine_reset(void){
 
    DMX512_engine_stop();
 
    DMX512_chaser_pool_free(engine.chasers);
    DMX512_scene_pool_free(engine.scenes);
    DMX512_fixture_pool_free(engine.fixtures);
 
    engine.fixtures       = DMX512_fixture_pool_new();
    engine.scenes         = DMX512_scene_pool_new();
    engine.chasers        = DMX512_chaser_pool_new();
 
    DMX512_engine_start();
 
}
 
#endif