OpenMQTTGateway/main/blufiSec.cpp

/*
 * SPDX-FileCopyrightText: 2021-2022 Espressif Systems (Shanghai) CO LTD
 *
 * SPDX-License-Identifier: Unlicense OR CC0-1.0
 */

#if defined(ESP32) && defined(USE_BLUFI)

#  include <ArduinoLog.h>

#  include "User_config.h"
#  include "esp_blufi_api.h"
#  include "esp_crc.h"
#  include "esp_random.h"
#  include "mbedtls/aes.h"
#  include "mbedtls/dhm.h"
#  include "mbedtls/md5.h"

/*
   The SEC_TYPE_xxx is for self-defined packet data type in the procedure of "BLUFI negotiate key"
   If user use other negotiation procedure to exchange(or generate) key, should redefine the type by yourself.
 */
#  define SEC_TYPE_DH_PARAM_LEN  0x00
#  define SEC_TYPE_DH_PARAM_DATA 0x01
#  define SEC_TYPE_DH_P          0x02
#  define SEC_TYPE_DH_G          0x03
#  define SEC_TYPE_DH_PUBLIC     0x04

struct blufi_security {
#  define DH_SELF_PUB_KEY_LEN     128
#  define DH_SELF_PUB_KEY_BIT_LEN (DH_SELF_PUB_KEY_LEN * 8)
  uint8_t self_public_key[DH_SELF_PUB_KEY_LEN];
#  define SHARE_KEY_LEN     128
#  define SHARE_KEY_BIT_LEN (SHARE_KEY_LEN * 8)
  uint8_t share_key[SHARE_KEY_LEN];
  size_t share_len;
#  define PSK_LEN 16
  uint8_t psk[PSK_LEN];
  uint8_t* dh_param;
  int dh_param_len;
  uint8_t iv[16];
  mbedtls_dhm_context dhm;
  mbedtls_aes_context aes;
};
static struct blufi_security* blufi_sec;

static int myrand(void* rng_state, unsigned char* output, size_t len) {
  esp_fill_random(output, len);
  return (0);
}

extern "C" void btc_blufi_report_error(esp_blufi_error_state_t state);

void blufi_dh_negotiate_data_handler(uint8_t* data, int len, uint8_t** output_data, int* output_len, bool* need_free) {
  if (data == NULL || len < 3) {
    THEENGS_LOG_ERROR(F("BLUFI Invalid data format" CR));
    btc_blufi_report_error(ESP_BLUFI_DATA_FORMAT_ERROR);
    return;
  }

  int ret;
  uint8_t type = data[0];

  if (blufi_sec == NULL) {
    THEENGS_LOG_ERROR(F("BLUFI Security is not initialized" CR));
    btc_blufi_report_error(ESP_BLUFI_INIT_SECURITY_ERROR);
    return;
  }

  switch (type) {
    case SEC_TYPE_DH_PARAM_LEN:
      blufi_sec->dh_param_len = ((data[1] << 8) | data[2]);
      if (blufi_sec->dh_param) {
        free(blufi_sec->dh_param);
        blufi_sec->dh_param = NULL;
      }
      blufi_sec->dh_param = (uint8_t*)malloc(blufi_sec->dh_param_len);
      if (blufi_sec->dh_param == NULL) {
        blufi_sec->dh_param_len = 0; /* Reset length to avoid using unallocated memory */
        btc_blufi_report_error(ESP_BLUFI_DH_MALLOC_ERROR);
        THEENGS_LOG_ERROR(F("%s, malloc failed\n" CR), __func__);
        return;
      }
      break;
    case SEC_TYPE_DH_PARAM_DATA: {
      if (blufi_sec->dh_param == NULL) {
        THEENGS_LOG_ERROR(F("%s, blufi_sec->dh_param == NULL" CR), __func__);
        btc_blufi_report_error(ESP_BLUFI_DH_PARAM_ERROR);
        return;
      }

      if (len < (blufi_sec->dh_param_len + 1)) {
        THEENGS_LOG_ERROR(F("%s, invalid dh param len" CR), __func__);
        btc_blufi_report_error(ESP_BLUFI_DH_PARAM_ERROR);
        return;
      }

      uint8_t* param = blufi_sec->dh_param;
      memcpy(blufi_sec->dh_param, &data[1], blufi_sec->dh_param_len);
      ret = mbedtls_dhm_read_params(&blufi_sec->dhm, &param, &param[blufi_sec->dh_param_len]);
      if (ret) {
        THEENGS_LOG_ERROR(F("%s read param failed %d" CR), __func__, ret);
        btc_blufi_report_error(ESP_BLUFI_READ_PARAM_ERROR);
        return;
      }
      free(blufi_sec->dh_param);
      blufi_sec->dh_param = NULL;

      const int dhm_len = mbedtls_dhm_get_len(&blufi_sec->dhm);

      if (dhm_len > DH_SELF_PUB_KEY_LEN) {
        THEENGS_LOG_ERROR(F("%s dhm len not support %d" CR), __func__, dhm_len);
        btc_blufi_report_error(ESP_BLUFI_DH_PARAM_ERROR);
        return;
      }

      ret = mbedtls_dhm_make_public(&blufi_sec->dhm, dhm_len, blufi_sec->self_public_key, DH_SELF_PUB_KEY_LEN, myrand, NULL);
      if (ret) {
        THEENGS_LOG_ERROR(F("%s make public failed %d" CR), __func__, ret);
        btc_blufi_report_error(ESP_BLUFI_MAKE_PUBLIC_ERROR);
        return;
      }

      ret = mbedtls_dhm_calc_secret(&blufi_sec->dhm,
                                    blufi_sec->share_key,
                                    SHARE_KEY_BIT_LEN,
                                    &blufi_sec->share_len,
                                    myrand, NULL);
      if (ret) {
        THEENGS_LOG_ERROR(F("%s mbedtls_dhm_calc_secret failed %d" CR), __func__, ret);
        btc_blufi_report_error(ESP_BLUFI_DH_PARAM_ERROR);
        return;
      }

      ret = mbedtls_md5(blufi_sec->share_key, blufi_sec->share_len, blufi_sec->psk);

      if (ret) {
        THEENGS_LOG_ERROR(F("%s mbedtls_md5 failed %d" CR), __func__, ret);
        btc_blufi_report_error(ESP_BLUFI_CALC_MD5_ERROR);
        return;
      }

      mbedtls_aes_setkey_enc(&blufi_sec->aes, blufi_sec->psk, PSK_LEN * 8);

      /* alloc output data */
      *output_data = &blufi_sec->self_public_key[0];
      *output_len = dhm_len;
      *need_free = false;

    } break;
    case SEC_TYPE_DH_P:
      break;
    case SEC_TYPE_DH_G:
      break;
    case SEC_TYPE_DH_PUBLIC:
      break;
  }
}

int blufi_aes_encrypt(uint8_t iv8, uint8_t* crypt_data, int crypt_len) {
  int ret;
  size_t iv_offset = 0;
  uint8_t iv0[16];

  memcpy(iv0, blufi_sec->iv, sizeof(blufi_sec->iv));
  iv0[0] = iv8; /* set iv8 as the iv0[0] */

  ret = mbedtls_aes_crypt_cfb128(&blufi_sec->aes, MBEDTLS_AES_ENCRYPT, crypt_len, &iv_offset, iv0, crypt_data, crypt_data);
  if (ret) {
    return -1;
  }

  return crypt_len;
}

int blufi_aes_decrypt(uint8_t iv8, uint8_t* crypt_data, int crypt_len) {
  int ret;
  size_t iv_offset = 0;
  uint8_t iv0[16];

  memcpy(iv0, blufi_sec->iv, sizeof(blufi_sec->iv));
  iv0[0] = iv8; /* set iv8 as the iv0[0] */

  ret = mbedtls_aes_crypt_cfb128(&blufi_sec->aes, MBEDTLS_AES_DECRYPT, crypt_len, &iv_offset, iv0, crypt_data, crypt_data);
  if (ret) {
    return -1;
  }

  return crypt_len;
}

uint16_t blufi_crc_checksum(uint8_t iv8, uint8_t* data, int len) {
  /* This iv8 ignore, not used */
  return esp_crc16_be(0, data, len);
}

esp_err_t blufi_security_init(void) {
  blufi_sec = (struct blufi_security*)malloc(sizeof(struct blufi_security));
  if (blufi_sec == NULL) {
    return ESP_FAIL;
  }

  memset(blufi_sec, 0x0, sizeof(struct blufi_security));

  mbedtls_dhm_init(&blufi_sec->dhm);
  mbedtls_aes_init(&blufi_sec->aes);

  memset(blufi_sec->iv, 0x0, 16);
  return 0;
}

void blufi_security_deinit(void) {
  if (blufi_sec == NULL) {
    return;
  }
  if (blufi_sec->dh_param) {
    free(blufi_sec->dh_param);
    blufi_sec->dh_param = NULL;
  }
  mbedtls_dhm_free(&blufi_sec->dhm);
  mbedtls_aes_free(&blufi_sec->aes);

  memset(blufi_sec, 0x0, sizeof(struct blufi_security));

  free(blufi_sec);
  blufi_sec = NULL;
}

#endif // defined(ESP32) && defined(USE_BLUFI)