object_binding.hxx

// dawn/src/proto/wakaama/object_binding.hxx
//
// SPDX-License-Identifier: Apache-2.0
//
 
#pragma once
 
#include "internal.hxx"
 
#include <vector>
 
#include "dawn/io/ddata.hxx"
 
namespace dawn
{
namespace wakaama_internal
{
class ObjectBinding
{
public:
  struct Resource
  {
    uint16_t instanceId;
    uint16_t resourceId;
    uint16_t access;
    SObjectId::ObjectId objid;
    CIOCommon *io;
    io_ddata_t *data;
  };
 
#ifdef CONFIG_DAWN_IO_NOTIFY
  struct NotifyContext
  {
    CProtoWakaama *proto;
    CIOCommon *io;
    uint16_t objectId;
    uint16_t instanceId;
    uint16_t resourceId;
  };
#endif
 
  struct Instance
  {
    Instance *next;
    uint16_t id;
    size_t resourceCount;
  };
 
  ObjectBinding(const SObjectCfg::SObjectCfgItem *item, CProtoWakaama *proto);
 
  ~ObjectBinding();
 
  int configureStatus() const
  {
    return configStatus;
  }
 
  int init();
 
  int deinit();
 
  lwm2m_object_t *object()
  {
    return &lwm2m;
  }
 
private:
  CProtoWakaama *proto;
  int configStatus;
  lwm2m_object_t lwm2m;
  std::vector<Instance *> instances;
  std::vector<Resource> resources;
#ifdef CONFIG_DAWN_IO_NOTIFY
  std::vector<NotifyContext *> notifyContexts;
#endif
 
  int configureDesc(const SObjectCfg::SObjectCfgItem *item);
 
  int allocObject(const SProtoWakaamaIOBind &bind);
 
  Resource *findResource(uint16_t instanceId, uint16_t resourceId);
 
  Instance *findOrCreateInstance(uint16_t instanceId);
 
  int readResource(Resource &res, lwm2m_data_t &data);
 
  int writeResource(Resource &res, const lwm2m_data_t &data);
 
  int executeResource(Resource &res, const uint8_t *buffer, int length);
#ifdef CONFIG_DAWN_IO_NOTIFY
  void setupNotifications();
 
  void destroyNotifications();
 
  static int notifierCb(void *priv, io_ddata_t *data);
#endif
 
  static uint8_t readCb(lwm2m_context_t *ctx,
                        uint16_t instanceId,
                        int *numData,
                        lwm2m_data_t **dataArray,
                        lwm2m_object_t *object);
 
  static uint8_t discoverCb(lwm2m_context_t *ctx,
                            uint16_t instanceId,
                            int *numData,
                            lwm2m_data_t **dataArray,
                            lwm2m_object_t *object);
 
  static uint8_t writeCb(lwm2m_context_t *ctx,
                         uint16_t instanceId,
                         int numData,
                         lwm2m_data_t *dataArray,
                         lwm2m_object_t *object,
                         lwm2m_write_type_t writeType);
 
  static uint8_t executeCb(lwm2m_context_t *ctx,
                           uint16_t instanceId,
                           uint16_t resourceId,
                           uint8_t *buffer,
                           int length,
                           lwm2m_object_t *object);
};
 
} // namespace wakaama_internal
} // namespace dawn