custom_event.cpp File Reference

#include <string.h>
#include "custom_event.hpp"
#include "appd_iot_interface.h"
#include "log.hpp"
#include "config.hpp"
#include "utils.hpp"

Functions
appd_iot_error_code_t	appd_iot_add_custom_event (appd_iot_custom_event_t custom_event)
	converts custom event data to beacon format and adds to beacon More...
appd_iot_error_code_t	appd_iot_clear_event_data (data_t *data)
	Clear event data. More...
appd_iot_error_code_t	appd_iot_copy_event_data (data_t *destdata, appd_iot_data_t *srcdata, int srcdata_count)
	Copies User Defined Event Data to SDK Defined Event Data. More...
appd_iot_error_code_t	appd_iot_send_all_events (void)
	send all events to collector More...
appd_iot_error_code_t	appd_iot_clear_all_events (void)
	Clear all events to collector. More...

Function Documentation

appd_iot_add_custom_event()

appd_iot_error_code_t appd_iot_add_custom_event

(

appd_iot_custom_event_t

custom_event

)

converts custom event data to beacon format and adds to beacon

This method adds custom event data
Each call to add event will create a new event.

Parameters

custom_event

contains event data

Returns

appd_iot_error_code_t indicating function execution status

{
  appd_iot_error_code_t retcode;
  appd_iot_sdk_state_t sdk_state;
  custom_event_t event;

  if ((sdk_state = appd_iot_get_sdk_state()) != APPD_IOT_SDK_ENABLED)
  {
    appd_iot_log(APPD_IOT_LOG_ERROR, "Add Custom Event Failed. SDK Not in Enabled State:%s",
                 appd_iot_sdk_state_to_str(sdk_state));

    return APPD_IOT_ERR_SDK_NOT_ENABLED;
  }

  if (custom_event.type != NULL)
  {
    event.type = appd_iot_remove_character(custom_event.type, '|');
  }
  else
  {
    appd_iot_log(APPD_IOT_LOG_WARN, "Custom Event Type cannot be NULL");
  }

  if (custom_event.summary != NULL)
  {
    event.summary = custom_event.summary;
  }
  else
  {
    appd_iot_log(APPD_IOT_LOG_WARN, "Custom Event Summary is NULL");
  }

  event.timestamp_ms = custom_event.timestamp_ms;
  event.duration_ms = custom_event.duration_ms;
  retcode = APPD_IOT_SUCCESS;

  if (custom_event.data_count > 0)
  {
    retcode = appd_iot_copy_event_data(&event.data, custom_event.data,
                                       custom_event.data_count);

    if (retcode != APPD_IOT_SUCCESS)
    {
      appd_iot_log(APPD_IOT_LOG_WARN, "Failed to parse custom event data, error:%s",
                   appd_iot_error_code_to_str(retcode));

      appd_iot_clear_event_data(&event.data);
    }
  }

  appd_iot_log(APPD_IOT_LOG_INFO, "Adding Custom Event with Type:%s", event.type.c_str());

  retcode = appd_iot_add_custom_event_to_beacon(event);

  return retcode;
}

appd_iot_clear_event_data()

appd_iot_error_code_t appd_iot_clear_event_data

(

data_t *

data

)

Clear event data.

Parameters

data	that needs to be cleared

Returns

appd_iot_error_code_t indicating function execution status

{
  data->stringmap.clear();
  data->integermap.clear();
  data->boolmap.clear();
  data->datetimemap.clear();
  data->doublemap.clear();

  return APPD_IOT_SUCCESS;
}

appd_iot_copy_event_data()

appd_iot_error_code_t appd_iot_copy_event_data	(	data_t *	destdata,
		appd_iot_data_t *	srcdata,
		int	srcdata_count
	)

Copies User Defined Event Data to SDK Defined Event Data.

Parameters

destdata	contains event data to be copied to
srcdata	contains event data to be copied from
srcdata_count	contains number of key-value pairs in user defined event data

Returns

appd_iot_error_code_t indicating function execution status

{
  if (destdata == NULL)
  {
    appd_iot_log(APPD_IOT_LOG_ERROR, "Destination Data Pointer in NULL");
    return APPD_IOT_ERR_INTERNAL;
  }

  if (srcdata == NULL)
  {
    appd_iot_log(APPD_IOT_LOG_ERROR, "Source Data Pointer is NULL");
    return APPD_IOT_ERR_NULL_PTR;
  }

  for (int i = 0; i < srcdata_count; i++)
  {
    if ((srcdata + i) == NULL)
    {
      appd_iot_log(APPD_IOT_LOG_ERROR, "Event Data at Index:%d is NULL", i);
      return APPD_IOT_ERR_NULL_PTR;
    }

    if (srcdata[i].key == NULL)
    {
      appd_iot_log(APPD_IOT_LOG_ERROR, "Event <Key> at Index:%d is NULL", i);
      return APPD_IOT_ERR_NULL_PTR;
    }

    std::string key = appd_iot_remove_character(srcdata[i].key, '|');

    switch (srcdata[i].value_type)
    {
      case APPD_IOT_INTEGER:
      {
        destdata->integermap[key] = srcdata[i].intval;
        break;
      }

      case APPD_IOT_DOUBLE:
      {
        destdata->doublemap[key] = srcdata[i].doubleval;
        break;
      }

      case APPD_IOT_BOOLEAN:
      {
        destdata->boolmap[key] = srcdata[i].boolval;
        break;
      }

      case APPD_IOT_STRING:
      {
        if (srcdata[i].strval != NULL)
        {
          destdata->stringmap[key] = srcdata[i].strval;
        }
        else
        {
          appd_iot_log(APPD_IOT_LOG_WARN, "String Value is NULL for key %s", srcdata[i].key);
        }

        break;
      }

      case APPD_IOT_DATETIME:
      {
        destdata->datetimemap[key] = srcdata[i].datetimeval;
        break;
      }

      default:
      {
        appd_iot_log(APPD_IOT_LOG_ERROR, "Skip Adding event field:%s due to invalid data type:%d",
                     srcdata[i].key, srcdata[i].value_type);
        break;
      }
    }

    appd_iot_log(APPD_IOT_LOG_INFO, "Added Key :%s with value type:%d", key.c_str(), srcdata[i].value_type);
  }

  return APPD_IOT_SUCCESS;
}

appd_iot_send_all_events()

appd_iot_error_code_t appd_iot_send_all_events

(

void

)

send all events to collector

This method sends all event data.
If events are sent successfuly to collector then they will be flushed out of memory.
If there is a network reject with response codes 402, 403 or 429 then events are flushed out of memory and SDK state set to DISABLED. If there is any other network error, events remain in memory for retry. Repeated calls to this API in SDK ENABLED State will retry sending the data in memory to the collector.
Use the API appd_iot_clear_all_events() to clear out events in memory if retries are unsuccessful.

Returns

appd_iot_error_code_t indicating function execution status

{
  appd_iot_sdk_state_t sdk_state;

  if ((sdk_state = appd_iot_get_sdk_state()) != APPD_IOT_SDK_ENABLED)
  {
    appd_iot_log(APPD_IOT_LOG_ERROR, "Send All Events Failed. SDK Not in Enabled State:%s",
                 appd_iot_sdk_state_to_str(sdk_state));

    return APPD_IOT_ERR_SDK_NOT_ENABLED;
  }

  return appd_iot_send_all_beacons();
}

appd_iot_clear_all_events()

appd_iot_error_code_t appd_iot_clear_all_events

(

void

)

Clear all events to collector.

This method removes all event data stored in memory
This call is not needed if appd_iot_send_all_events return SUCCESS.

Returns

appd_iot_error_code_t indicating function execution status

{
  appd_iot_sdk_state_t sdk_state;

  if ((sdk_state = appd_iot_get_sdk_state()) != APPD_IOT_SDK_ENABLED)
  {
    appd_iot_log(APPD_IOT_LOG_ERROR, "Clear All Events Failed. SDK Not in Enabled State:%s",
                 appd_iot_sdk_state_to_str(sdk_state));

    return APPD_IOT_ERR_SDK_NOT_ENABLED;
  }

  return appd_iot_clear_all_beacons();
}