nes-proj/os/services/lwm2m/lwm2m-firmware.c

/*
 * Copyright (c) 2016, SICS Swedish ICT AB
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. 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.
 * 3. 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 HOLDER 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.
 */

/**
 * \addtogroup lwm2m
 * @{
 *
 * Code for firmware object of lwm2m
 *
 */

#include "lwm2m-engine.h"
#include "lwm2m-firmware.h"
#include "coap.h"
#include <inttypes.h>
#include <string.h>

/* Log configuration */
#include "coap-log.h"
#define LOG_MODULE "lwm2m-firmware"
#define LOG_LEVEL  LOG_LEVEL_LWM2M

#define UPDATE_PACKAGE     0
#define UPDATE_PACKAGE_URI 1
#define UPDATE_UPDATE      2
#define UPDATE_STATE       3
#define UPDATE_RESULT      5

#define STATE_IDLE         1
#define STATE_DOWNLOADING  2
#define STATE_DOWNLOADED   3

#define RESULT_DEFAULT         0
#define RESULT_SUCCESS         1
#define RESULT_NO_STORAGE      2
#define RESULT_OUT_OF_MEM      3
#define RESULT_CONNECTION_LOST 4
#define RESULT_CRC_FAILED      5
#define RESULT_UNSUPPORTED_FW  6
#define RESULT_INVALID_URI     7


static uint8_t state = STATE_IDLE;
static uint8_t result = RESULT_DEFAULT;

static lwm2m_object_instance_t reg_object;

static const lwm2m_resource_id_t resources[] =
  { WO(UPDATE_PACKAGE),
    WO(UPDATE_PACKAGE_URI),
    RO(UPDATE_STATE),
    RO(UPDATE_RESULT),
    EX(UPDATE_UPDATE)
  };

/*---------------------------------------------------------------------------*/
static lwm2m_status_t
lwm2m_callback(lwm2m_object_instance_t *object,
               lwm2m_context_t *ctx)
{
  uint32_t num;
  uint8_t more;
  uint16_t size;
  uint32_t offset;

  LOG_DBG("Got request at: %d/%d/%d lv:%d\n", ctx->object_id,
          ctx->object_instance_id, ctx->resource_id, ctx->level);

  if(ctx->level == 1 || ctx->level == 2) {
    /* Should not happen - as it will be taken care of by the lwm2m engine itself. */
    return LWM2M_STATUS_ERROR;
  }

  if(ctx->operation == LWM2M_OP_READ) {
    switch(ctx->resource_id) {
    case UPDATE_STATE:
      lwm2m_object_write_int(ctx, state); /* 1 means idle */
      return LWM2M_STATUS_OK;
    case UPDATE_RESULT:
      lwm2m_object_write_int(ctx, result); /* 0 means default */
      return LWM2M_STATUS_OK;
    }
  } else if(ctx->operation == LWM2M_OP_WRITE) {

    if(LOG_DBG_ENABLED) {
      if(coap_get_header_block1(ctx->request, &num, &more, &size, &offset)) {
        LOG_DBG("CoAP BLOCK1: %"PRIu32"/%u/%u offset:%"PRIu32
                " LWM2M CTX->offset=%"PRIu32"\n",
                num, more, size, offset, ctx->offset);
      }
    }

    switch(ctx->resource_id) {
    case UPDATE_PACKAGE:
      /* The firmware is written */
      LOG_DBG("Firmware received: %"PRIu32" %d fin:%d\n", ctx->offset,
              (int)ctx->inbuf->size, lwm2m_object_is_final_incoming(ctx));
      if(lwm2m_object_is_final_incoming(ctx)) {
        state = STATE_DOWNLOADED;
      } else {
        state = STATE_DOWNLOADING;
      }
      return LWM2M_STATUS_OK;
    case UPDATE_PACKAGE_URI:
      /* The firmware URI is written */
      LOG_DBG("Firmware URI received: %"PRIu32" %d fin:%d\n", ctx->offset,
              (int)ctx->inbuf->size, lwm2m_object_is_final_incoming(ctx));
      if(LOG_DBG_ENABLED) {
        int i;
        LOG_DBG("Data: '");
        for(i = 0; i < ctx->inbuf->size; i++) {
          LOG_DBG_("%c", ctx->inbuf->buffer[i]);
        }
        LOG_DBG_("'\n");
      }
      return LWM2M_STATUS_OK;
    }
  } else if(ctx->operation == LWM2M_OP_EXECUTE && ctx->resource_id == UPDATE_UPDATE) {
    /* Perform the update operation */
    if(state == STATE_DOWNLOADED) {
      return LWM2M_STATUS_OK;
    }
    /* Failure... */
  }
  return LWM2M_STATUS_ERROR;
}

/*---------------------------------------------------------------------------*/
void
lwm2m_firmware_init(void)
{
  reg_object.object_id = 5;
  reg_object.instance_id = 0;
  reg_object.callback = lwm2m_callback;
  reg_object.resource_ids = resources;
  reg_object.resource_count = sizeof(resources) / sizeof(lwm2m_resource_id_t);

  lwm2m_engine_add_object(&reg_object);
}
/*---------------------------------------------------------------------------*/
/** @} */