#include "legato.h"
#include "interfaces.h"



static void avcStatusHandler
(
    le_avdata_SessionState_t updateStatus,
    void* contextPtr
)
{
    LE_INFO("Legato session Handler called");
    switch (updateStatus)
    {
        case LE_AVDATA_SESSION_STARTED:
            LE_INFO("Legato session started successfully");
            break;
        case LE_AVDATA_SESSION_STOPPED:
            LE_INFO("Legato session stopped");
            break;
    }
}

static void PushCallbackHandler
(
    le_avdata_PushStatus_t status,
    void* contextPtr
)
{
    LE_INFO("PushCallbackHandler Handler called .................%d",status);
    if (status == LE_AVDATA_PUSH_SUCCESS)
    {
         LE_INFO("data pushed successfully");
        // data pushed successfully
    }
}
 
static void SendData()
{
    struct timeval tv;
    uint64_t utcMilliSec;
    le_result_t result;

    LE_INFO("Sending the data");
    le_avdata_RecordRef_t recRef = le_avdata_CreateRecord();
     
    gettimeofday(&tv, NULL);
    utcMilliSec = (uint64_t)(tv.tv_sec) * 1000 + (uint64_t)(tv.tv_usec) / 1000; // get current time
    result = le_avdata_RecordFloat(recRef, "speed", 0.08, utcMilliSec);
 
    if (result == LE_OK)
    {
         le_avdata_PushRecord(recRef, PushCallbackHandler, NULL);
    }
 
    le_avdata_DeleteRecord(recRef);
}


    // [StartAVCSession]
COMPONENT_INIT
{
    LE_INFO("Start the applicatio to push the data");
    
    //Register AVC handler
   le_avdata_AddSessionStateHandler(avcStatusHandler, NULL);
    SendData();
   
}