custom_app/app.c

/* Copyright 2017 Wirepas Ltd. All Rights Reserved.
 *
 * See file LICENSE.txt for full license details.
 */
 
/*
 * \file    app.c
 * \brief   This file is a template for writing a custom application
 */
 
#include <stdlib.h>
 
#include "api.h"
#include "node_configuration.h"
#include "shared_data.h"
#include "app_scheduler.h"
 
 
#define DEBUG_LOG_MODULE_NAME "CUSTOM_APP"
 
#define DEBUG_LOG_MAX_LEVEL LVL_NOLOG
 
#include "debug_log.h"
 
#define DEFAULT_PERIOD_S    10
#define DEFAULT_PERIOD_MS   (DEFAULT_PERIOD_S*1000)
 
#define EXECUTION_TIME_US 500
 
#define SET_PERIOD_EP  10
 
#define DATA_EP 1
 
static uint32_t period_ms;
 
typedef struct __attribute__((packed))
{
    uint32_t period_ms;
} payload_periodic_t;
 
static uint32_t send_data_task(void)
{
    static uint32_t id = 0; // Value to send
 
    // Create a data packet to send
    app_lib_data_to_send_t data_to_send;
    data_to_send.bytes = (const uint8_t *) &id;
    data_to_send.num_bytes = sizeof(id);
    data_to_send.dest_address = APP_ADDR_ANYSINK;
    data_to_send.src_endpoint = DATA_EP;
    data_to_send.dest_endpoint = DATA_EP;
    data_to_send.qos = APP_LIB_DATA_QOS_HIGH;
    data_to_send.flags = APP_LIB_DATA_SEND_FLAG_NONE;
    data_to_send.tracking_id = APP_LIB_DATA_NO_TRACKING_ID;
 
    // Send the data packet
    Shared_Data_sendData(&data_to_send, NULL);
 
    // Increment value to send
    id++;
 
    // Inform the stack that this function should be called again in
    // period_ms microseconds. By returning APP_SCHEDULER_STOP_TASK,
    // the stack won't call this function again.
    return period_ms;
}
 
static app_lib_data_receive_res_e dataReceivedCb(
    const shared_data_item_t * item,
    const app_lib_data_received_t * data)
{
    LOG(LVL_INFO, "dataReceivedCb");
    if ((data->num_bytes < 1) || (data->num_bytes!= sizeof(payload_periodic_t)))
    {
        // Data was not for this application
        LOG(LVL_INFO, "dataReceiveCb - data was not for this application");
        return APP_LIB_DATA_RECEIVE_RES_NOT_FOR_APP;
    }
 
    LOG(LVL_INFO, "dataReceivedCb");
    payload_periodic_t payload = *((payload_periodic_t *)data->bytes);
 
    /* Change the period for a new one */
    period_ms = payload.period_ms;
 
    // Data handled successfully
    return APP_LIB_DATA_RECEIVE_RES_HANDLED;
}
 
/*Unicast messages filter*/
static shared_data_item_t alltype_packets_filter =
{
    .cb = dataReceivedCb,
    .filter = {
        .mode = SHARED_DATA_NET_MODE_ALL,
        /* Filtering by source endpoint. */
        .src_endpoint = SET_PERIOD_EP,
        /* Filtering by destination endpoint. */
        .dest_endpoint = SET_PERIOD_EP,
        .multicast_cb = NULL
    }
};
 
 
void App_init(const app_global_functions_t * functions)
{
    LOG_INIT();
    LOG(LVL_INFO, "App_init");
    // Basic configuration of the node with a unique node address
    if (configureNodeFromBuildParameters() != APP_RES_OK)
    {
        // Could not configure the node
        // It should not happen except if one of the config value is invalid
        return;
    }
 
    // Set a periodic callback to be called after DEFAULT_PERIOD_MS
    period_ms = DEFAULT_PERIOD_MS;
    App_Scheduler_addTask_execTime(send_data_task,
                                   APP_SCHEDULER_SCHEDULE_ASAP,
                                   EXECUTION_TIME_US);
 
    // Set callback for received unicast messages
    Shared_Data_addDataReceivedCb(&alltype_packets_filter);
 
    // Start the stack
    lib_state->startStack();
}