/**
 * 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 <object/weex_env.h>
#include <task/impl/js_action_task.h>
#include "script_side_in_queue.h"

#include "android/jsengine/task/impl/init_framework_task.h"
#include "android/jsengine/task/impl/create_app_context_task.h"
#include "android/jsengine/task/impl/create_instance_task.h"
#include "android/jsengine/task/impl/call_js_on_app_context_task.h"
#include "android/jsengine/task/impl/destory_app_context_task.h"
#include "android/jsengine/task/impl/destory_instance_task.h"
#include "android/jsengine/task/impl/exe_js_on_app_with_result.h"
#include "android/jsengine/task/impl/update_global_config_task.h"
#include "android/jsengine/task/impl/update_init_framework_params_task.h"
#include "android/jsengine/task/impl/ctime_callback_task.h"
#include "android/jsengine/task/impl/exe_js_services_task.h"
#include "android/jsengine/task/impl/exe_js_on_instance_task.h"
#include "android/jsengine/task/impl/exe_js_task.h"
#include "android/jsengine/task/impl/take_heap_snapshot.h"
#include "android/jsengine/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");
//                return runtime_->initFramework(String::fromUTF8(script), params);
  weexTaskQueue_->addTask(new InitFrameworkTask(String::fromUTF8(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(String::fromUTF8(script), params));
      LOGD("cache initFramework %d", WeexEnv::getEnv()->m_task_cache_.size());
    } else {
      weexTaskQueue_bk_ = new WeexTaskQueue(weexTaskQueue_->isMultiProgress);
      weexTaskQueue_bk_->addTask(new InitFrameworkTask(String::fromUTF8(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(String::fromUTF8(instanceId),
                                                String::fromUTF8(appFramework), params));
  return 1;

//                return runtime_->initAppFramework(String::fromUTF8(instanceId),
//                                                  String::fromUTF8(appFramework), params);
}

int ScriptSideInQueue::CreateAppContext(const char *instanceId,
                                        const char *jsBundle) {
  LOGD("ScriptSideInQueue::CreateAppContext");
  auto script = String::fromUTF8(jsBundle);
  if (script.isEmpty()) {
    return 0;
  }
  weexTaskQueue_->addTask(new CreateAppContextTask(String::fromUTF8(instanceId),
                                                   script));
  return 1;
}

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

  WeexTask *task = new ExeJsOnAppWithResultTask(String::fromUTF8(instanceId),
                                                String::fromUTF8(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(String::fromUTF8(instanceId),
                                                     String::fromUTF8(func), params));

  return 1;
}

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

  weexTaskQueue_->addTask(new DestoryAppContextTask(String::fromUTF8(instanceId)));

  return 1;
}

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

  weexTaskQueue_->addTask(new ExeJsServicesTask(String::fromUTF8(source)));
  if (WeexEnv::getEnv()->enableBackupThread()) {
    ExeJsServicesTask *task = new ExeJsServicesTask(String::fromUTF8(source));
    if (WeexEnv::getEnv()->can_m_cache_task_() && weexTaskQueue_bk_ == nullptr) {
      WeexEnv::getEnv()->m_task_cache_.push_back(task);
      LOGD("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(String::fromUTF8(source)));
  if (WeexEnv::getEnv()->enableBackupThread() && weexTaskQueue_bk_ != nullptr) {
    weexTaskQueue_bk_->addTask(new CTimeCallBackTask(String::fromUTF8(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(instanceId, params);

  task->addExtraArg(String::fromUTF8(nameSpace));
  task->addExtraArg(String::fromUTF8(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());
        LOGD("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(instanceId, params, true);

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

  task->addExtraArg(String::fromUTF8(nameSpace));
  task->addExtraArg(String::fromUTF8(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(instanceId, params, callback_id);

  task->addExtraArg(String::fromUTF8(nameSpace));
  task->addExtraArg(String::fromUTF8(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);
  bool backUpThread = false;
  if (WeexEnv::getEnv()->enableBackupThread()) {
    for (int i = 0; i < params.size(); ++i) {
      auto param = params[i];
      auto type = String::fromUTF8(param->type->content);
      auto value = String::fromUTF8(param->value->content);
      if (type == "use_back_thread") {
        if (value == "true") {
          backUpThread = true;
        }
        break;
      }
    }
  }

  if (backUpThread) {
    useBackUpWeexRuntime(instanceId);
  }

  auto string = String::fromUTF8(script);
  if (string.isEmpty()) {
    LOG_TLOG("jsEngine", "%s id CreateInstance's script is null", instanceId);
    return 0;
  }
  CreateInstanceTask *task = new CreateInstanceTask(String::fromUTF8(instanceId),
                                                    string, params);

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

void ScriptSideInQueue::SetLogType(const int logLevel, const bool isPerf) {
  LOGE("jsEngine setLog Level %d in Performance mode %s", logLevel, isPerf ? "true" : "false");
  weex::base::LogImplement::getLog()->setPrintLevel((WeexCore::LogLevel) logLevel);
  weex::base::LogImplement::getLog()->setPerfMode(isPerf);
};

std::unique_ptr<WeexJSResult> ScriptSideInQueue::ExecJSOnInstance(const char *instanceId,
                                                                  const char *script, int type) {
  LOGD("ScriptSideInQueue::ExecJSOnInstance type:%d", type);
  ExeJsOnInstanceTask *task = new ExeJsOnInstanceTask(String::fromUTF8(instanceId),
                                                      String::fromUTF8(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());
    LOGD("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(String::fromUTF8(instanceId)));
  deleteBackUpRuntimeInstance(instanceId);
  return 1;
}

int ScriptSideInQueue::UpdateGlobalConfig(const char *config) {
  LOGD("ScriptSideInQueue::UpdateGlobalConfig");
  weexTaskQueue_->addTask(new UpdateGlobalConfigTask(String::fromUTF8(config)));
  if (WeexEnv::getEnv()->enableBackupThread()) {
    UpdateGlobalConfigTask *task = new UpdateGlobalConfigTask(String::fromUTF8(config));
    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;
}

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::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("instance %s use back up thread time is %lld", id, microTime());
    }
    return weexTaskQueue_bk_;
  }
  if (log && id != nullptr) {
    LOGE("instance %s use main thread time is %lld", id, microTime());
  }
  return weexTaskQueue_;
}
int64_t ScriptSideInQueue::JsAction(long ctxContainer, int32_t jsActionType, const char *arg) {
  WeexTask *task = new JSActionTask(ctxContainer, jsActionType, arg);
  weexTaskQueue_->addTask(task);
  return 0;
}
}  // namespace js
}  // namespace bridge

}  // namespace weex