tools_previewer/ThinPreviewer.cpp

/*
 * Copyright (c) Huawei Technologies Co., Ltd. 2020-2020. All rights reserved.
 * Description: Thin device Main method
 * Create: 2020-03-06
 */

#include <VirtualScreen.h>
#include <cstdint>
#include <cstdlib>
#include <fstream>
#include <vector>

#include "CommandLineFactory.h"
#include "CommandLineInterface.h"
#include "CommandParser.h"
#include "CppTimerManager.h"
#include "CrashHandler.h"
#include "Interrupter.h"
#include "JsAppImpl.h"
#include "ModelManager.h"
#include "PreviewerEngineLog.h"
#include "SharedData.h"
#include "TimerTaskHandler.h"
#include "TraceTool.h"
#include "VirtualScreenImpl.h"
#include "jsi.h"
#include "json.h"

using namespace std;
static const int START_PARAM_INVALID_CODE = 11;

void InitSettings()
{
    CommandParser& parser = CommandParser::GetInstance();
    // Setting the Simulator Model
    ModelManager::SetCurrentDevice(parser.GetDeviceType());

    // Setting the screen resolution
    VirtualScreenImpl::GetInstance().SetOrignalWidth(parser.GetOrignalResolutionWidth());
    VirtualScreenImpl::GetInstance().SetOrignalHeight(parser.GetOrignalResolutionHeight());
    VirtualScreenImpl::GetInstance().SetCompressionWidth(parser.GetCompressionResolutionWidth());
    VirtualScreenImpl::GetInstance().SetCompressionHeight(parser.GetCompressionResolutionHeight());
    VirtualScreenImpl::GetInstance().InitFrameCountTimer();
}

void InitJsApp()
{
    CommandParser& parser = CommandParser::GetInstance();
    string args = parser.GetConfigPath();
    if (args.empty()) {
        ELOG("No persistent properties path found.");
    }

    CommandLineInterface::GetInstance().ReadAndApplyConfig(args);
    // Initialize Image Pipeline Name
    if (parser.IsSet("s")) {
        JsAppImpl::GetInstance().SetPipeName(parser.Value("s"));
    }

    if (parser.IsSet("lws")) {
        JsAppImpl::GetInstance().SetPipePort(parser.Value("lws"));
    }

    // Set the application name.
    JsAppImpl::GetInstance().SetBundleName(parser.GetAppName());

    // Processing JSheap
    JsAppImpl::GetInstance().SetJSHeapSize(parser.GetJsHeapSize());

    // Start JSApp
    if (!parser.IsSet("t")) {
        if (parser.IsSet("d")) {
            JsAppImpl::GetInstance().SetIsDebug(true);
            if (parser.IsSet("p")) {
                JsAppImpl::GetInstance().SetDebugServerPort(static_cast<uint16_t>(atoi(parser.Value("p").c_str())));
            }
        }
        JsAppImpl::GetInstance().SetJsAppPath(parser.Value("j"));
        if (parser.IsSet("url")) {
            JsAppImpl::GetInstance().SetUrlPath(parser.Value("url"));
        }
        JsAppImpl::GetInstance().Start();
    }
}

void DataChangeCheck()
{
    SharedDataManager::CheckTick();
}

void InitSharedData()
{
    // The brightness ranges from 1 to 255. The default value is 255.
    SharedData<uint8_t>(BRIGHTNESS_VALUE, 255, 1, 255);
    SharedData<uint8_t>(BRIGHTNESS_MODE, MANUAL, MANUAL, AUTO);
    SharedData<bool>(KEEP_SCREEN_ON, true);
    SharedData<uint8_t>(BATTERY_STATUS, NOCHARGE, NOCHARGE, CHARGING);
    // Battery level range: 0.0–1.0; default: 1.0
    SharedData<double>(BATTERY_LEVEL, 1.0, 0.0, 1.0);
    // Heart rate range: 0 to 255. The default value is 80.
    SharedData<uint8_t>(HEARTBEAT_VALUE, 80, 0, 255);
    // The value ranges from 0 to 999999. The default value is 0.
    SharedData<uint32_t>(SUMSTEP_VALUE, 0, 0, 999999);
    // The volume ranges from 0.0 to 1.0. The default value is 1.0.
    SharedData<double>(VOLUME_VALUE, 1.0, 0.0, 1.0);
    // The atmospheric pressure ranges from 0 to 999900. The default value is 101325.
    SharedData<uint32_t>(PRESSURE_VALUE, 101325, 0, 999900);
    SharedData<bool>(WEARING_STATE, true);
    SharedData<string>(LANGUAGE, "zh-CN");
    // The value ranges from 180 to 180. The default value is 0.
    SharedData<double>(LONGITUDE, 0, -180, 180);
    // The value ranges from -90 to 90. The default value is 0.
    SharedData<double>(LATITUDE, 0, -90, 90);
}

void SendJsHeapData()
{
    OHOS::ACELite::JSHeapStatus status;
    OHOS::ACELite::JSI::GetJSHeapStatus(status);
    CommandLineInterface::GetInstance().SendJSHeapMemory(status.totalBytes, status.allocBytes, status.peakAllocBytes);
}

int main(int argc, char* argv[])
{
    ILOG("ThinPreviewer enter the main function.");
    // thin device global exception handler
    auto thinCrashHandler = std::make_unique<CrashHandler>();
    if (thinCrashHandler == nullptr) {
        ELOG("ThinPreviewer crashHandler new fail.");
        return 0;
    }
    thinCrashHandler->InitExceptionHandler();
    // Creating a Main Thread Timer Manager
    CppTimerManager& manager = CppTimerManager::GetTimerManager();

    // Parsing User Commands
    CommandParser& parser = CommandParser::GetInstance();
    vector<string> strs;
    for (int i = 1; i < argc; ++i) {
        strs.push_back(argv[i]);
    }

    if (!parser.ProcessCommand(strs)) {
        return 0;
    }

    if (!parser.IsCommandValid()) {
        FLOG("Start args is invalid.");
        return START_PARAM_INVALID_CODE;
    }

    InitSharedData();
    InitSettings();
    if (parser.IsSet("s")) {
        CommandLineInterface::GetInstance().Init(parser.Value("s"));
    }

    InitJsApp();
    TraceTool::GetInstance().HandleTrace("Enter the main function");
    CppTimer dataCheckTimer(DataChangeCheck);
    manager.AddCppTimer(dataCheckTimer);
    dataCheckTimer.Start(100); // 100ms Timer polling period

    CppTimer jsHeapSendTimer(SendJsHeapData);
    if (parser.IsSendJSHeap()) {
        manager.AddCppTimer(jsHeapSendTimer);
        jsHeapSendTimer.Start(1000); // 1000ms Timer polling period
    }

    // Registering and monitoring the changes of the brightness and volume
    thread::id curThreadId = this_thread::get_id();
    SharedData<uint8_t>::AppendNotify(BRIGHTNESS_VALUE, TimerTaskHandler::CheckBrightnessValueChanged, curThreadId);

    while (!Interrupter::IsInterrupt()) {
        CommandLineInterface::GetInstance().ProcessCommand();
        manager.RunTimerTick();
        this_thread::sleep_for(chrono::milliseconds(1));
    }
    JsAppImpl::GetInstance().Stop();
    return 0;
}