/*
 * Copyright (c) 2022 Huawei Device Co., Ltd.
 * Licensed 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.
 */

#include "action_processer.h"
#include <chrono>
#include <thread>
#include "sys_installer_manager.h"
#include "log/log.h"

namespace OHOS {
namespace SysInstaller {
using namespace Updater;
bool ActionProcesser::IsRunning()
{
    return isRunning_ || isSuspend_;
}

bool ActionProcesser::WaitActionExit()
{
    using namespace std::chrono_literals;
    const unsigned int WAIT_MAX_SECOND = 4;
    unsigned int count = 0;
    while (IsRunning() && (count < WAIT_MAX_SECOND)) {
        std::this_thread::sleep_for(1s);
        count++;
    }
    if (count == WAIT_MAX_SECOND) {
        LOG(ERROR) << "wait action exit failed for " << WAIT_MAX_SECOND << "s";
        return false;
    }
    LOG(INFO) << "action exit after " << count << "s";
    return true;
}

void ActionProcesser::AddAction(std::unique_ptr<IAction> action)
{
    if (isRunning_ || action == nullptr) {
        LOG(ERROR) << "action running or action empty";
        return;
    }

    LOG(INFO) << "add " << action->GetActionName();
    auto callBack = [this](InstallerErrCode errCode, const std::string &errStr) {
        CompletedAction(errCode, errStr);
    };
    action->SetCallback(callBack);
    actionQue_.push_back(std::move(action));
}

void ActionProcesser::Start()
{
    if (isRunning_ || actionQue_.empty()) {
        LOG(WARNING) << "Action running or queue empty";
        return;
    }

    isRunning_ = true;
    isSuspend_ = false;
    statusManager_->UpdateCallback(UpdateStatus::UPDATE_STATE_ONGOING, 0, "");
    curAction_ = std::move(actionQue_.front());
    actionQue_.pop_front();
    if (curAction_ == nullptr) {
        LOG(WARNING) << "curAction_ nullptr";
        return;
    }
    LOG(INFO) << "Start " << curAction_->GetActionName();
    curAction_->PerformAction();
}

bool ActionProcesser::Stop()
{
    if (!isRunning_) {
        LOG(WARNING) << "Action not running";
        return false;
    }
    bool ret = false;
    if (curAction_ != nullptr) {
        LOG(INFO) << "Stop " << curAction_->GetActionName();
        ret = curAction_->TerminateAction();
    }
    if (!ret || !WaitActionExit()) {
        LOG(INFO) << "Stop action failed, directly returned";
        return false;
    }
    isRunning_ = false;
    isSuspend_ = false;
    curAction_.reset();
    actionQue_.clear();
    return ret;
}

void ActionProcesser::Suspend()
{
    if (!isRunning_ || curAction_ == nullptr) {
        LOG(WARNING) << "ActionProcesser not running or action empty";
        return;
    }

    LOG(INFO) << "Suspend " << curAction_->GetActionName();
    isSuspend_ = true;
    curAction_->SuspendAction();
}

void ActionProcesser::Resume()
{
    if (isSuspend_) {
        LOG(WARNING) << "ActionProcesser is running";
        return;
    }

    isSuspend_ = false;
    if (curAction_ != nullptr) {
        LOG(INFO) << "Resume " << curAction_->GetActionName();
        return curAction_->ResumeAction();
    }

    StartNextAction();
}

void ActionProcesser::CompletedAction(InstallerErrCode errCode, const std::string &errStr)
{
    if (curAction_ == nullptr) {
        LOG(ERROR) << "curAction_ null error ";
        return;
    }

    LOG(INFO) << "Completed " << curAction_->GetActionName();
    curAction_.reset();
    if (errCode != SYS_UPDATE_SUCCESS) {
        isRunning_ = false;
        isSuspend_ = false;
        statusManager_->UpdateCallback(UpdateStatus::UPDATE_STATE_FAILED, 100, errStr); // 100 : action failed
        actionQue_.clear();
        LOG(ERROR) << "CompletedAction errCode:" << errCode << " str:" << errStr;
        SysInstallerManagerInit::GetInstance().InvokeEvent(SYS_POST_EVENT);
        return;
    }

    if (isSuspend_) {
        LOG(INFO) << "suspend";
        return;
    }

    StartNextAction();
}

void ActionProcesser::StartNextAction()
{
    if (actionQue_.empty()) {
        LOG(INFO) << "Action queue empty, successful";
        isRunning_ = false;
        isSuspend_ = false;
        statusManager_->UpdateCallback(UpdateStatus::UPDATE_STATE_SUCCESSFUL, 100, ""); // 100 : action completed
        return;
    }

    curAction_ = std::move(actionQue_.front());
    LOG(INFO) << "StartNextAction " << curAction_->GetActionName();
    actionQue_.pop_front();
    curAction_->PerformAction();
}

bool ActionProcesser::SetCpuAffinity(unsigned int reservedCores)
{
    if (!isRunning_ || curAction_ == nullptr) {
        LOG(WARNING) << "ActionProcesser not running or action empty";
        return false;
    }
    LOG(INFO) << "SetCpuAffinity " << curAction_->GetActionName();
    bool ret = curAction_->SetCpuAffinityAction(reservedCores);
    if (!ret) {
        LOG(WARNING) << "SetCpuAffinity action filed";
        return false;
    }
    return ret;
}
} // namespace SysInstaller
} // namespace OHOS