/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
//
// Created by Darin on 2018/7/22.
//

#include "android/jsengine/object/weex_env.h"
#include "android/jsengine/bridge/script/script_side_in_queue.h"

#include "js_runtime/weex/task/impl/init_framework_task.h"
#include "js_runtime/weex/task/impl/create_app_context_task.h"
#include "js_runtime/weex/task/impl/create_instance_task.h"
#include "js_runtime/weex/task/impl/call_js_on_app_context_task.h"
#include "js_runtime/weex/task/impl/destory_app_context_task.h"
#include "js_runtime/weex/task/impl/destory_instance_task.h"
#include "js_runtime/weex/task/impl/exe_js_on_app_with_result.h"
#include "js_runtime/weex/task/impl/update_global_config_task.h"
#include "js_runtime/weex/task/impl/update_init_framework_params_task.h"
#include "js_runtime/weex/task/impl/ctime_callback_task.h"
#include "js_runtime/weex/task/impl/exe_js_services_task.h"
#include "js_runtime/weex/task/impl/exe_js_on_instance_task.h"
#include "js_runtime/weex/task/impl/exe_js_task.h"
#include "js_runtime/weex/task/impl/take_heap_snapshot.h"
#include "js_runtime/weex/task/impl/native_timer_task.h"

namespace weex {
namespace bridge {
namespace js {
int ScriptSideInQueue::InitFramework(
    const char *script, std::vector<INIT_FRAMEWORK_PARAMS *> &params) {
  LOGD("ScriptSideInQueue::InitFramework");
  weexTaskQueue_->addTask(new InitFrameworkTask(char2String(script), params));
  weexTaskQueue_->init();

  if (WeexEnv::getEnv()->enableBackupThread()) {
    WeexEnv::getEnv()->locker()->lock();
    while (!WeexEnv::getEnv()->is_jsc_init_finished()) {
      WeexEnv::getEnv()->locker()->wait();
    }
    WeexEnv::getEnv()->locker()->unlock();

    if(WeexEnv::getEnv()->can_m_cache_task_()) {
      WeexEnv::getEnv()->m_task_cache_.push_back(new InitFrameworkTask(char2String(script), params));
      LOGE("cache initFramework %d", WeexEnv::getEnv()->m_task_cache_.size());
    } else {
      weexTaskQueue_bk_ = new WeexTaskQueue(weexTaskQueue_->isMultiProgress);
      weexTaskQueue_bk_->addTask(new InitFrameworkTask(char2String(script), params));
      weexTaskQueue_bk_->init();
    }

  }

  return 1;
}

int ScriptSideInQueue::InitAppFramework(
    const char *instanceId, const char *appFramework,
    std::vector<INIT_FRAMEWORK_PARAMS *> &params) {
  LOGD("ScriptSideInQueue::InitAppFramework");
  weexTaskQueue_->addTask(new InitFrameworkTask(instanceId, appFramework, params));
  return 1;

}

int ScriptSideInQueue::CreateAppContext(const char *instanceId,
                                        const char *jsBundle) {
  LOGD("ScriptSideInQueue::CreateAppContext");
  if (jsBundle == nullptr || strlen(jsBundle) == 0) {
    return 0;
  }
  weexTaskQueue_->addTask(new CreateAppContextTask(instanceId, jsBundle));
  return 1;
}

std::unique_ptr<WeexJSResult> ScriptSideInQueue::ExecJSOnAppWithResult(const char *instanceId,
                                                                       const char *jsBundle) {
  LOGD("ScriptSideInQueue::ExecJSOnAppWithResult");

  WeexTask *task = new ExeJsOnAppWithResultTask((instanceId),
                                                (jsBundle));

  auto future = std::unique_ptr<WeexTask::Future>(new WeexTask::Future());
  task->set_future(future.get());

  weexTaskQueue_->addTask(task);

  return std::move(future->waitResult());
}

int ScriptSideInQueue::CallJSOnAppContext(
    const char *instanceId, const char *func,
    std::vector<VALUE_WITH_TYPE *> &params) {
  LOGD("ScriptSideInQueue::CallJSOnAppContext");

  weexTaskQueue_->addTask(new CallJsOnAppContextTask(instanceId,
                                                     func, params));

  return 1;
}

int ScriptSideInQueue::DestroyAppContext(const char *instanceId) {
  LOGE("ScriptSideInQueue::DestroyAppContext");

  weexTaskQueue_->addTask(new DestoryAppContextTask(instanceId));

  return 1;
}

int ScriptSideInQueue::ExecJsService(const char *source) {
  LOGD("ScriptSideInQueue::ExecJsService");

  weexTaskQueue_->addTask(new ExeJsServicesTask((source)));
  if (WeexEnv::getEnv()->enableBackupThread()) {
    ExeJsServicesTask *task = new ExeJsServicesTask((source));
    if(WeexEnv::getEnv()->can_m_cache_task_() && weexTaskQueue_bk_ == nullptr){
      WeexEnv::getEnv()->m_task_cache_.push_back(task);
      LOGE("cache ExecJsService %d", WeexEnv::getEnv()->m_task_cache_.size());
    } else {
      weexTaskQueue_bk_->addTask(task);
    }
    
  }

  return 1;
}

int ScriptSideInQueue::ExecTimeCallback(const char *source) {
  LOGD("ScriptSideInQueue::ExecTimeCallback");

  weexTaskQueue_->addTask(new CTimeCallBackTask(char2String(source)));
  if (WeexEnv::getEnv()->enableBackupThread() && weexTaskQueue_bk_ != nullptr) {
    weexTaskQueue_bk_->addTask(new CTimeCallBackTask(char2String(source)));
  }

  return 1;
}

int ScriptSideInQueue::ExecJS(const char *instanceId, const char *nameSpace,
                              const char *func,
                              std::vector<VALUE_WITH_TYPE *> &params) {
  LOGD("ScriptSideInQueue::ExecJS");
  ExeJsTask *task = new ExeJsTask(char2String(instanceId), params);

  task->addExtraArg(char2String(nameSpace));
  task->addExtraArg(char2String(func));

  if (instanceId == nullptr || strlen(instanceId) == 0) {
    if (WeexEnv::getEnv()->enableBackupThread()) {
      if(WeexEnv::getEnv()->can_m_cache_task_() && weexTaskQueue_bk_ == nullptr){
        WeexEnv::getEnv()->m_task_cache_.push_back(task->clone());
        LOGE("cache ExecJS %d", WeexEnv::getEnv()->m_task_cache_.size());
      } else {
        weexTaskQueue_bk_->addTask(task->clone());
      }
    }

    weexTaskQueue_->addTask(task);
  } else {
    taskQueue(instanceId, false)->addTask(task);
  }
  return 1;
}

std::unique_ptr<WeexJSResult> ScriptSideInQueue::ExecJSWithResult(
    const char *instanceId, const char *nameSpace, const char *func,
    std::vector<VALUE_WITH_TYPE *> &params) {
  LOGD("ScriptSideInQueue::ExecJSWithResult");

  ExeJsTask *task = new ExeJsTask(char2String(instanceId), params, true);

  auto future = std::unique_ptr<WeexTask::Future>(new WeexTask::Future());
  task->set_future(future.get());

  task->addExtraArg(char2String(nameSpace));
  task->addExtraArg(char2String(func));
  taskQueue(instanceId, false)->addTask(task);
  return std::move(future->waitResult());
}

void ScriptSideInQueue::ExecJSWithCallback(
    const char *instanceId, const char *nameSpace, const char *func,
    std::vector<VALUE_WITH_TYPE *> &params, long callback_id) {
  LOGD("ScriptSideInQueue::ExecJSWithCallback");

  ExeJsTask *task = new ExeJsTask(char2String(instanceId), params, callback_id);

  task->addExtraArg(char2String(nameSpace));
  task->addExtraArg(char2String(func));
  taskQueue(instanceId, false)->addTask(task);
}

int ScriptSideInQueue::CreateInstance(const char *instanceId,
                                      const char *func,
                                      const char *script,
                                      const char *opts,
                                      const char *initData,
                                      const char *extendsApi,
                                      std::vector<INIT_FRAMEWORK_PARAMS *> &params) {
  LOGD(
      "CreateInstance id = %s, func = %s, script = %s, opts = %s, initData = "
      "%s, extendsApi = %s",
      instanceId, func, script, opts, initData, extendsApi);
  if (script == nullptr || strlen(script) == 0) {
    return 0;
  }
  
  bool backUpThread = false;
  if (WeexEnv::getEnv()->enableBackupThread()) {
    for (int i = 0; i < params.size(); ++i) {
      auto param = params[i];
      std::string type = param->type->content;
      std::string value = param->value->content;
      if (type == "use_back_thread") {
        if (value == "true") {
          backUpThread = true;
        }
        break;
      }
    }
  }

  if(backUpThread) {
    useBackUpWeexRuntime(instanceId);
  }

  CreateInstanceTask *task = new CreateInstanceTask(char2String(instanceId),
                                                    script, params);

  task->addExtraArg(char2String(func));
  task->addExtraArg(char2String(opts));
  task->addExtraArg(char2String(initData));
  task->addExtraArg(char2String(extendsApi));
  auto pQueue = taskQueue(instanceId, true);
  pQueue->addTask(task);
  if (!pQueue->isInitOk) {
    pQueue->init();
  }
  return 1;
}

std::unique_ptr<WeexJSResult> ScriptSideInQueue::ExecJSOnInstance(const char *instanceId,
                                                                  const char *script,int type) {
  LOGD("ScriptSideInQueue::ExecJSOnInstance");
  ExeJsOnInstanceTask *task = new ExeJsOnInstanceTask(instanceId,
                                                      script);
  taskQueue(instanceId, false)->addTask(task);
  if (type == -1){
      //don't need wait. just run js.
    std::unique_ptr<WeexJSResult> returnResult;
    returnResult.reset(new WeexJSResult());
    LOGE("test-> return default result");
    return returnResult;
  }
  auto future = std::unique_ptr<WeexTask::Future>(new WeexTask::Future());
  task->set_future(future.get());
  return std::move(future->waitResult());
}

int ScriptSideInQueue::DestroyInstance(const char *instanceId) {
  LOGD("ScriptSideInQueue::DestroyInstance instanceId: %s \n", instanceId);
  taskQueue(instanceId,
            false)->addTask(new DestoryInstanceTask(instanceId));
  deleteBackUpRuntimeInstance(instanceId);
  return 1;
}

int ScriptSideInQueue::UpdateGlobalConfig(const char *config) {
  LOGD("ScriptSideInQueue::UpdateGlobalConfig");
  weexTaskQueue_->addTask(new UpdateGlobalConfigTask(config));
  if (WeexEnv::getEnv()->enableBackupThread() && weexTaskQueue_bk_ != nullptr) {
    weexTaskQueue_bk_->addTask(new UpdateGlobalConfigTask(config));
  }

  return 1;
}

int ScriptSideInQueue::UpdateInitFrameworkParams(const std::string& key, const std::string& value, const std::string& desc){
  LOGD("ScriptSideInQueue::UpdateInitFrameworkParams");
  weexTaskQueue_->addTask(new UpdateInitFrameworkParamsTask(key, value, desc));
  if (WeexEnv::getEnv()->enableBackupThread()) {
    UpdateInitFrameworkParamsTask* task = new UpdateInitFrameworkParamsTask(key, value, desc);
    if(WeexEnv::getEnv()->can_m_cache_task_() && weexTaskQueue_bk_ == nullptr){
      WeexEnv::getEnv()->m_task_cache_.push_back(task);
    } else {
      weexTaskQueue_bk_->addTask(task);
    }
  }

  return 1;
}

void ScriptSideInQueue::SetLogType(const int logLevel, const bool isPerf) {
  // do nothing;
};


void ScriptSideInQueue::useBackUpWeexRuntime(std::string id) {
  usingBackThreadId.push_back(id);
}

bool ScriptSideInQueue::shouldUseBackUpWeexRuntime(std::string id) {
  if (id.empty() || !WeexEnv::getEnv()->enableBackupThread())
    return false;
  auto iter = std::find(usingBackThreadId.begin(), usingBackThreadId.end(), id);
  return iter != usingBackThreadId.end();
}

void ScriptSideInQueue::deleteBackUpRuntimeInstance(std::string id) {
  if (!WeexEnv::getEnv()->enableBackupThread()) {
    return;
  }

  auto iter = std::find(usingBackThreadId.begin(), usingBackThreadId.end(), id);
  if (iter != usingBackThreadId.end()) {
    usingBackThreadId.erase(iter);
  }
}

WeexTaskQueue *ScriptSideInQueue::taskQueue(const char *id, bool log) {
  if (!WeexEnv::getEnv()->enableBackupThread()) {
    return weexTaskQueue_;
  }

  if (id != nullptr && shouldUseBackUpWeexRuntime(id)) {
    if (weexTaskQueue_bk_ == nullptr) {
      weexTaskQueue_bk_ = new WeexTaskQueue(weexTaskQueue_->isMultiProgress);
      WeexEnv::getEnv()->set_m_cache_task_(false);
      for (std::deque<WeexTask *>::iterator it = WeexEnv::getEnv()->m_task_cache_.begin(); it < WeexEnv::getEnv()->m_task_cache_.end(); ++it) {
        auto reference = *it;
        weexTaskQueue_bk_->addTask(std::move(reference));
      }
      WeexEnv::getEnv()->m_task_cache_.clear();
    }
    if (log) {
      LOGE("dyyLog instance %s use back up thread time is %lld", id, microTime());
    }
    return weexTaskQueue_bk_;
  }
  if (log && id != nullptr) {
    LOGE("dyyLog instance %s use main thread time is %lld", id, microTime());
  }
  return weexTaskQueue_;
}
}  // namespace js
}  // namespace bridge

}  // namespace weex