/***************************************************************************
 *
 * Copyright 2015-2019 BES.
 * All rights reserved. All unpublished rights reserved.
 *
 * No part of this work may be used or reproduced in any form or by any
 * means, or stored in a database or retrieval system, without prior written
 * permission of BES.
 *
 * Use of this work is governed by a license granted by BES.
 * This work contains confidential and proprietary information of
 * BES. which is protected by copyright, trade secret,
 * trademark and other intellectual property rights.
 *
 ****************************************************************************/
//#include "mbed.h"
#include <assert.h>
#include <stdio.h>

#include "analog.h"
#include "app_audio.h"
#include "app_bt_stream.h"
#include "app_overlay.h"
#include "app_utils.h"
#include "apps.h"
#include "audioflinger.h"
#include "cmsis_os.h"
#include "hal_chipid.h"
#include "hal_cmu.h"
#include "hal_codec.h"
#include "hal_timer.h"
#include "hal_trace.h"
#include "hal_uart.h"
#include "lockcqueue.h"
#include "nvrecord.h"
#include "nvrecord_env.h"
#include "tgt_hardware.h"

#include "app_ring_merge.h"

#include "app_bt_func.h"
#include "app_mic.h"
#include "besbt.h"
#include "bt_drv.h"
#include "bt_xtal_sync.h"

#include "app_bt_media_manager.h"
#include "app_hfp.h"
#include "app_thread.h"
#include "btapp.h"
#include "cqueue.h"
#include "hal_codec.h"
#include "hal_location.h"
#include "hal_sleep.h"
#include "string.h"

extern bool app_hfp_siri_is_active(void);
extern int a2dp_volume_2_level_convert(uint8_t vol);
extern bool mic_is_already_on;

typedef enum {
  MIC_EVENT_START,
  MIC_EVENT_STOP,
  MIC_EVENT_CHECK,
} MIC_EVENT_TYPE;

static MIC_APP_TYPE current_mictype = MIC_APP_NONE;
static struct AF_STREAM_CONFIG_T mic_config[MIC_APP_MAX];
osMutexId app_mic_mutex_id = NULL;
osMutexDef(app_mic_mutex);

// flag of is first mic date, if true ,will delete to avoid POP voice
bool first_mic_in = false;

static int internal_mic_start(MIC_APP_TYPE new_mictype) {
  TRACE(1, "MIC_EVENT_START,current_mictype=%d", current_mictype);
  assert(new_mictype != MIC_APP_NONE);
  if (current_mictype != MIC_APP_NONE) {
    TRACE(0, "MIC START ERROR################");
    return false;
  }
  if (new_mictype == MIC_APP_SOC_CALL) {
    if (btapp_hfp_get_call_state() || app_hfp_siri_is_active()) {
      TRACE(2, "[%s] tws_mic_start_telephone_call: %d", __func__,
            mic_config[new_mictype].sample_rate);
      if (mic_config[new_mictype].data_ptr != NULL) {
      } else {
        TRACE(1, "[%s] Warning sco play not started", __func__);
      }
      current_mictype = MIC_APP_SOC_CALL;
    }
  } else if (new_mictype == MIC_APP_SPEECH_RECO) {
  } else if (new_mictype == MIC_APP_CSPOTTER) {
    first_mic_in = true;
    current_mictype = MIC_APP_CSPOTTER;
  } else if (new_mictype == MIC_APP_MICRECORD) {
    current_mictype = MIC_APP_MICRECORD;
  } else if (new_mictype == MIC_APP_OTHER) {
    TRACE(0, "~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~");
  }

  af_stream_open(AUD_STREAM_ID_0, AUD_STREAM_CAPTURE, &mic_config[new_mictype]);
  af_stream_start(AUD_STREAM_ID_0, AUD_STREAM_CAPTURE);
  return false;
}

static int internal_mic_stop(MIC_APP_TYPE new_mictype) {
  TRACE(1, "MIC_EVENT_STOP,current_mictype=%d", current_mictype);
  // assert(currentMicStauts == currentStatus);
  if (new_mictype != current_mictype) {
    TRACE(0, "MIC STOP ERROR ################");
    return false;
  }
  af_stream_stop(AUD_STREAM_ID_0, AUD_STREAM_CAPTURE);
  af_stream_close(AUD_STREAM_ID_0, AUD_STREAM_CAPTURE);
  first_mic_in = false;
  current_mictype = MIC_APP_NONE;
  app_sysfreq_req(APP_SYSFREQ_USER_APP_3, APP_SYSFREQ_32K);
  return true;
}

static int app_mic_process(APP_MESSAGE_BODY *msg_body) {
  MIC_EVENT_TYPE mic_event = (MIC_EVENT_TYPE)msg_body->message_id;
  MIC_APP_TYPE new_mictype = (MIC_APP_TYPE)msg_body->message_ptr;
  int ret = -1;
  TRACE(4, "%s mic_event:%d new_mictype:%d current_mictype:%d", __func__,
        mic_event, new_mictype, current_mictype);

  osMutexWait(app_mic_mutex_id, osWaitForever);
  if (mic_event == MIC_EVENT_START)
    ret = internal_mic_start(new_mictype);
  else if (mic_event == MIC_EVENT_STOP)
    ret = internal_mic_stop(new_mictype);
  else if (mic_event == MIC_EVENT_CHECK) {
    TRACE(1, "MIC_EVENT_CHECK,current_mictype=%d", current_mictype);
    if (current_mictype != new_mictype) {
      if (current_mictype != MIC_APP_NONE)
        internal_mic_stop(current_mictype);
      if (new_mictype != MIC_APP_CSPOTTER)
        internal_mic_start(new_mictype);
      ret = 0;
    }
  } else
    assert(0);
  osMutexRelease(app_mic_mutex_id);
  return ret;
}

void app_mic_init() {
  app_mic_mutex_id = osMutexCreate((osMutex(app_mic_mutex)));
  app_set_threadhandle(APP_MODUAL_MIC, app_mic_process);
}

int app_mic_register(MIC_APP_TYPE mic_type,
                     struct AF_STREAM_CONFIG_T *newStream) {
  TRACE(2, "app_mic_registration mic_type:%d,newStream=%p\n", mic_type,
        newStream);
  if (mic_type > MIC_APP_NONE && mic_type < MIC_APP_MAX) {
    osMutexWait(app_mic_mutex_id, osWaitForever);
    if (memcmp(&mic_config[mic_type], newStream,
               sizeof(struct AF_STREAM_CONFIG_T)) != 0) {
      TRACE(0, "app_mic_registration Warning mic stream config changed!!!");
    }
    memcpy(&mic_config[mic_type], newStream, sizeof(struct AF_STREAM_CONFIG_T));
    osMutexRelease(app_mic_mutex_id);
    return 0;
  }
  return -1;
}

int app_mic_deregister(MIC_APP_TYPE mic_type) {
  TRACE(1, "app_mic_deregister mic_type:%d\n", mic_type);
  if (mic_type > MIC_APP_NONE && mic_type < MIC_APP_MAX) {
    osMutexWait(app_mic_mutex_id, osWaitForever);
    memset(&mic_config[mic_type], 0, sizeof(struct AF_STREAM_CONFIG_T));
    osMutexRelease(app_mic_mutex_id);
    return 0;
  }
  return -1;
}

bool app_mic_is_registed(MIC_APP_TYPE mic_type) {
  TRACE(1, "app_mic_is_registed mic_type:%d\n", mic_type);
  bool ret = false;
  if (mic_type > MIC_APP_NONE && mic_type < MIC_APP_MAX) {
    osMutexWait(app_mic_mutex_id, osWaitForever);
    ret = mic_config[mic_type].data_ptr != NULL;
    osMutexRelease(app_mic_mutex_id);
  }
  return ret;
}

bool app_mic_start(MIC_APP_TYPE mic_type) {
  APP_MESSAGE_BLOCK msg;
  msg.mod_id = APP_MODUAL_MIC;
  msg.msg_body.message_id = MIC_EVENT_START;
  msg.msg_body.message_ptr = mic_type;
  app_mailbox_put(&msg);
  return true;
}

bool app_mic_stop(MIC_APP_TYPE mic_type) {
  APP_MESSAGE_BLOCK msg;
  msg.mod_id = APP_MODUAL_MIC;
  msg.msg_body.message_id = MIC_EVENT_STOP;
  msg.msg_body.message_ptr = mic_type;
  app_mailbox_put(&msg);
  return true;
}

void app_mic_check(MIC_APP_TYPE mic_type) {
  APP_MESSAGE_BLOCK msg;
  msg.mod_id = APP_MODUAL_MIC;
  msg.msg_body.message_id = MIC_EVENT_CHECK;
  msg.msg_body.message_ptr = mic_type;
  app_mailbox_put(&msg);
}

MIC_APP_TYPE app_mic_status(void) {
  MIC_APP_TYPE ret;
  osMutexWait(app_mic_mutex_id, osWaitForever);
  ret = current_mictype;
  osMutexRelease(app_mic_mutex_id);
  return ret;
}