Skip to content

add library for managing flow and custom ipso objects for Motion sensor #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
onkarkshirsagar wants to merge 1 commit into from
Closed

add library for managing flow and custom ipso objects for Motion sensor #8

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion Makefile.libobjects
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@
libobjects_src = lwm2m-client-flow-object.c lwm2m-client-flow-access-object.c \
lwm2m-client-ipso-digital-input.c lwm2m-client-ipso-light-control.c
lwm2m-client-ipso-digital-input.c lwm2m-client-ipso-light-control.c \
lwm2m-client-ipso-motion-sensor.c
375 changes: 375 additions & 0 deletions lwm2m-client-ipso-motion-sensor.c
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,375 @@
/**
* @file
* LightWeightM2M LWM2M test client
*
* @author Imagination Technologies
*
* @copyright Copyright (c) 2016, Imagination Technologies Limited
*
* All rights reserved.
*
* Redistribution and use of the Software in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* 1. The Software (including after any modifications that you make to it) must support the
* FlowCloud Web Service API provided by Licensor and accessible at http://ws-uat.flowworld.com
* and/or some other location(s) that we specify.
*
* 2. Redistributions of source code must retain the above copyright notice, this list of
* conditions and the following disclaimer.
*
* 3. Redistributions in binary form must reproduce the above copyright notice, this list of
* conditions and the following disclaimer in the documentation and/or other materials
* provided with the distribution.
*
* 4. Neither the name of the copyright holder nor the names of its contributors may be used to
* endorse or promote products derived from this Software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS
* OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
* AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER
* IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/

/***************************************************************************************************
* Includes
**************************************************************************************************/

#include <stdio.h>
#include <stdint.h>
#include <stdbool.h>
#include <string.h>
#include "lwm2m_core.h"
#include "coap_abstraction.h"
#include "common.h"
#include "lwm2m-client-ipso-motion-sensor.h"

/***************************************************************************************************
* Definitions
**************************************************************************************************/

#define IPSO_PRESENCE_SENSOR 3302
#define IPSO_DIGITAL_INPUT_COUNTER 5501
#define IPSO_DIGITAL_INPUT_COUNTER_RESET 5505

#define IPSO_APPICATION_TYPE 5750
#define IPSO_SENSOR_TYPE 5751

#define NUM_OF_SENSOR 1

#define MAX_STR_SIZE 128

#define REGISTER_MOTION_SENSOR_RESOURCE(context, name, id, type, operations) \
REGISTER_RESOURCE(context, name, IPSO_PRESENCE_SENSOR, id, type, \
MultipleInstancesEnum_Single, MandatoryEnum_Optional, operations, \
&MotionSensorResourceOperationHandlers)

#define CREATE_MOTION_SENSOR_OPTIONAL_RESOURCE(context, objectInstanceId, resourcId) \
CREATE_OPTIONAL_RESOURCE(context, IPSO_PRESENCE_SENSOR, objectInstanceId, resourcId)

/***************************************************************************************************
* Typedefs
**************************************************************************************************/

typedef struct
{
int64_t Counter;
char ApplicationType[MAX_STR_SIZE];
char SensoryType[MAX_STR_SIZE];
} IPSOMotionSensor;

/***************************************************************************************************
* Prototypes
**************************************************************************************************/

static int MotionSensor_ResourceReadHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID,
ResourceInstanceIDType resourceInstanceID, uint8_t *destBuffer, int destBufferLen);

static int MotionSensor_ResourceGetLengthHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID,
ResourceInstanceIDType resourceInstanceID);

static int MotionSensor_ResourceWriteHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID,
ResourceInstanceIDType resourceInstanceID, uint8_t *srcBuffer, int srcBufferLen, bool *changed);

static int MotionSensor_ResourceExecuteHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID, uint8_t *srcBuffer,
int srcBufferLen);

static int MotionSensor_ResourceCreateHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID);

static int MotionSensor_ObjectCreateInstanceHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID);

static int MotionSensor_ObjectDeleteHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID);

/***************************************************************************************************
* Globals
**************************************************************************************************/

static ObjectOperationHandlers MotionSensorObjectOperationHandlers =
{
.CreateInstance = MotionSensor_ObjectCreateInstanceHandler,
.Delete = MotionSensor_ObjectDeleteHandler,
};

static ResourceOperationHandlers MotionSensorResourceOperationHandlers =
{
.Read = MotionSensor_ResourceReadHandler,
.GetLength = MotionSensor_ResourceGetLengthHandler,
.Write = MotionSensor_ResourceWriteHandler,
.CreateOptionalResource = MotionSensor_ResourceCreateHandler,
.Execute = MotionSensor_ResourceExecuteHandler,
};

static IPSOMotionSensor digitalInputs[NUM_OF_SENSOR];

/***************************************************************************************************
* Implementation
**************************************************************************************************/

static int MotionSensor_ObjectCreateInstanceHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID)
{
if(objectInstanceID >= NUM_OF_SENSOR)
{
Lwm2m_Error("MotionSensor_ResourceCreateHandler instance number %d out of range (max %d)",
objectInstanceID, NUM_OF_SENSOR - 1);
return -1;
}
return objectInstanceID;
}

static int MotionSensor_ResourceCreateHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID)
{
return 0;
}

static int MotionSensor_ObjectDeleteHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID)
{
if (objectID != IPSO_PRESENCE_SENSOR)
{
Lwm2m_Error("MotionSensor_ObjectDeleteHandler Invalid OIR: %d/%d/%d\n", objectID,
objectInstanceID, resourceID);
return -1;
}

if(objectInstanceID >= NUM_OF_SENSOR)
{
Lwm2m_Error("MotionSensor_ObjectDeleteHandler instance number %d out of range (max %d)",
objectInstanceID, NUM_OF_SENSOR - 1);
return -1;
}

if (resourceID == -1)
{
memset(&digitalInputs[objectInstanceID], 0, sizeof(IPSOMotionSensor));
}
else
{
//TODO
}

return 0;
}

static int MotionSensor_ResourceReadHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID,
ResourceInstanceIDType resourceInstanceID, uint8_t *destBuffer, int destBufferLen)
{
int result = 0;

switch (resourceID)
{
case IPSO_DIGITAL_INPUT_COUNTER:
result = sizeof(digitalInputs[objectInstanceID].Counter);
memcpy(destBuffer, &digitalInputs[objectInstanceID].Counter, result);
break;

case IPSO_APPICATION_TYPE:
result = strlen(digitalInputs[objectInstanceID].ApplicationType) + 1;
memcpy(destBuffer, digitalInputs[objectInstanceID].ApplicationType, result);
break;

case IPSO_SENSOR_TYPE:
result = strlen(digitalInputs[objectInstanceID].SensoryType) + 1;
memcpy(destBuffer, digitalInputs[objectInstanceID].SensoryType, result);
break;

default:
result = -1;
break;
}

return result;
}

static int MotionSensor_ResourceGetLengthHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID,
ResourceInstanceIDType resourceInstanceID)
{
int result = 0;

switch (resourceID)
{
case IPSO_DIGITAL_INPUT_COUNTER:
result = sizeof(digitalInputs[objectInstanceID].Counter);
break;

case IPSO_APPICATION_TYPE:
result = strlen(digitalInputs[objectInstanceID].ApplicationType) + 1;
break;

case IPSO_SENSOR_TYPE:
result = strlen(digitalInputs[objectInstanceID].SensoryType) + 1;
break;

default:
result = -1;
break;
}

return result;
}

static int MotionSensor_ResourceWriteHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID,
ResourceInstanceIDType resourceInstanceID, uint8_t *srcBuffer, int srcBufferLen, bool *changed)
{
int result;

switch(resourceID)
{
case IPSO_DIGITAL_INPUT_COUNTER:
result = srcBufferLen;
memcpy(&digitalInputs[objectInstanceID].Counter, srcBuffer, result);
Lwm2m_Debug("Motion event counter incremented to %d.\n",
(int)digitalInputs[objectInstanceID].Counter);
break;

case IPSO_APPICATION_TYPE:
result = srcBufferLen;
if(result < sizeof(digitalInputs[objectInstanceID].ApplicationType))
{
memcpy(digitalInputs[objectInstanceID].ApplicationType, srcBuffer, result);
}
else
{
Lwm2m_Error("MotionSensor_ResourceWriteHandler Application Type string too long: "
"%d", result);
result = -1;
}
break;

case IPSO_SENSOR_TYPE:
result = srcBufferLen;
if(result < sizeof(digitalInputs[objectInstanceID].SensoryType))
{
memcpy(digitalInputs[objectInstanceID].SensoryType, srcBuffer, result);
}
else
{
Lwm2m_Error("MotionSensor_ResourceWriteHandler Sensor Type string too long: %d",
result);
result = -1;
}
break;

default:
result = -1;
break;
}

if(result > 0)
*changed = true;

return result;
}

static int MotionSensor_ResourceExecuteHandler(void *context, ObjectIDType objectID,
ObjectInstanceIDType objectInstanceID, ResourceIDType resourceID, uint8_t *srcBuffer,
int srcBufferLen)
{
if(resourceID == IPSO_DIGITAL_INPUT_COUNTER_RESET)
{
int64_t zero = 0;
if (Lwm2mCore_SetResourceInstanceValue(context, objectID, objectInstanceID,
IPSO_DIGITAL_INPUT_COUNTER, 0, &zero, sizeof(zero)) == -1)
{
Lwm2m_Error("Failed to set Counter to %" PRId64 "\n", zero);
return -1;
}
}
else
return -1;

return 0;
}

/***************************************************************************************************
* Implementation - Public
**************************************************************************************************/

int MotionSensor_RegisterMotionSensorObject(Lwm2mContextType * context)
{

REGISTER_OBJECT(context, "MotionSensor", IPSO_PRESENCE_SENSOR, \
MultipleInstancesEnum_Multiple, MandatoryEnum_Optional, \
&MotionSensorObjectOperationHandlers);

REGISTER_MOTION_SENSOR_RESOURCE(context, "Counter", IPSO_DIGITAL_INPUT_COUNTER, \
ResourceTypeEnum_TypeInteger, Operations_R);
REGISTER_MOTION_SENSOR_RESOURCE(context, "CounterReset", IPSO_DIGITAL_INPUT_COUNTER_RESET, \
ResourceTypeEnum_TypeNone, Operations_E);
REGISTER_MOTION_SENSOR_RESOURCE(context, "ApplicationType", IPSO_APPICATION_TYPE, \
ResourceTypeEnum_TypeString, Operations_R);
REGISTER_MOTION_SENSOR_RESOURCE(context, "SensorType", IPSO_SENSOR_TYPE, \
ResourceTypeEnum_TypeString, Operations_R);

return 0;
}

int MotionSensor_AddDigitialInput(Lwm2mContextType *context, ObjectInstanceIDType objectInstanceID)
{
if(objectInstanceID < NUM_OF_SENSOR)
{
CREATE_OBJECT_INSTANCE(context, IPSO_PRESENCE_SENSOR, objectInstanceID);
CREATE_MOTION_SENSOR_OPTIONAL_RESOURCE(context, objectInstanceID, \
IPSO_DIGITAL_INPUT_COUNTER);
CREATE_MOTION_SENSOR_OPTIONAL_RESOURCE(context, objectInstanceID, \
IPSO_DIGITAL_INPUT_COUNTER_RESET);
CREATE_MOTION_SENSOR_OPTIONAL_RESOURCE(context, objectInstanceID, IPSO_SENSOR_TYPE);

memset(&digitalInputs[objectInstanceID], 0, sizeof(IPSOMotionSensor));
snprintf(digitalInputs[objectInstanceID].SensoryType, MAX_STR_SIZE, "MotionSensor");
}
else
{
Lwm2m_Error("%d instance of Digital Input exceeds max instances %d\n", objectInstanceID,
NUM_OF_SENSOR);
return -1;
}
return 0;
}

int MotionSensor_IncrementCounter(Lwm2mContextType *context, ObjectInstanceIDType objectInstanceID)
{
int64_t counter = digitalInputs[objectInstanceID].Counter + 1;
if (Lwm2mCore_SetResourceInstanceValue(context, IPSO_PRESENCE_SENSOR, objectInstanceID,
IPSO_DIGITAL_INPUT_COUNTER, 0, &counter, sizeof(counter)) == -1)
{
Lwm2m_Error("Failed to increment Counter resource\n");
return -1;
}
return 0;
}
Loading