/*
 * Copyright (C) 2021 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 "flash_define.h"
#include "server.h"
#include "server_for_client.h"

using namespace Hdc;

static bool g_isServerMode = false;
static bool g_isPullServer = true;
static bool g_isPcDebugRun = false;
static bool g_isTCPorUSB = false;
static auto g_logLevel = LOG_LEVEL_FULL;
static int g_isTestMethod = 0;
static string g_connectKey = "";
static string g_serverListenString = DEFAULT_SERVER_ADDR;

namespace Hdc {
// return value: 0 == not command, 1 == one command, 2 == double command
int IsRegisterCommand(string &outCommand, const char *cmd, const char *cmdnext)
{
    string sCmdNext = (cmdnext == nullptr) ? string("") : string(cmdnext);
    string doubleCommand = cmd + string(" ") + sCmdNext;
    vector<string> registerCommand;
    registerCommand.push_back(CMDSTR_SOFTWARE_VERSION);
    registerCommand.push_back(CMDSTR_SOFTWARE_HELP);
    registerCommand.push_back(CMDSTR_TARGET_DISCOVER);
    registerCommand.push_back(CMDSTR_LIST_TARGETS);
    registerCommand.push_back(CMDSTR_CONNECT_ANY);
    registerCommand.push_back(CMDSTR_CONNECT_TARGET);
    registerCommand.push_back(CMDSTR_TARGET_REBOOT);
    registerCommand.push_back(CMDSTR_SERVICE_KILL);
    registerCommand.push_back(CMDSTR_SERVICE_START);
    registerCommand.push_back(CMDSTR_TARGET_MODE);

    // flashd
    registerCommand.push_back(CMDSTR_UPDATE_SYSTEM);
    registerCommand.push_back(CMDSTR_FLASH_PARTITION);
    registerCommand.push_back(CMDSTR_ERASE_PARTITION);
    registerCommand.push_back(CMDSTR_FORMAT_PARTITION);
    for (string v : registerCommand) {
        if (doubleCommand == v) {
            outCommand = doubleCommand;
            return 2; // 2 error code
        }
        if (cmd == v) {
            outCommand = cmd;
            return 1;
        }
    }
    return 0;
}

void AppendCwdWhenTransfer(string &outCommand)
{
    if (outCommand != CMDSTR_FILE_SEND && outCommand != CMDSTR_FILE_RECV && outCommand != CMDSTR_APP_INSTALL
        && outCommand != CMDSTR_APP_SIDELOAD) {
        return;
    }
    char path[PATH_MAX] = "";
    size_t size = sizeof(path);
    if (uv_cwd(path, &size) < 0)
        return;
    if (path[strlen(path) - 1] != Base::GetPathSep()) {
        path[strlen(path)] = Base::GetPathSep();
    }
    outCommand = outCommand + (outCommand.size() ? " -cwd " : "-cwd ");
    outCommand += path;
}

int SplitOptionAndCommand(int argc, const char **argv, string &outOption, string &outCommand)
{
    bool foundCommand = false;
    int resultChild = 0;
    // we want to start from 1, ignore argv[0], but it has issue
    for (int i = 0; i < argc; ++i) {
        if (!foundCommand) {
            resultChild = IsRegisterCommand(outCommand, argv[i], (i == argc - 1) ? nullptr : argv[i + 1]);
            if (resultChild > 0) {
                foundCommand = true;
                if (resultChild == 2) { // 2 error code
                    ++i;
                }
                AppendCwdWhenTransfer(outCommand);
                continue;
            }
        }
        if (foundCommand) {
            outCommand += outCommand.size() ? " " : "";
            string rawCmd = argv[i];
            string packageCmd = Base::StringFormat("\"%s\"", argv[i]);
            outCommand += rawCmd.find(" ") == string::npos ? rawCmd : packageCmd;
        } else {
            outOption += outOption.size() ? " " : "";
            outOption += argv[i];
        }
    }
    return 0;
}

int RunServerMode(string &serverListenString)
{
    HdcServer server(true);
    if (!server.Initial(serverListenString.c_str())) {
        Base::PrintMessage("Initial failed");
        return -1;
    }
    server.WorkerPendding();
    return 0;
}

int RunClientMode(string &commands, string &serverListenString, string &connectKey, bool isPullServer)
{
    uv_loop_t loopMain;
    uv_loop_init(&loopMain);
    HdcClient client(false, serverListenString, &loopMain);
    if (!commands.size()) {
        Base::PrintMessage("Unknow operation command...");
        TranslateCommand::Usage();
        return 0;
    }
    if (!strncmp(commands.c_str(), CMDSTR_SERVICE_START.c_str(), CMDSTR_SERVICE_START.size())
        || !strncmp(commands.c_str(), CMDSTR_SERVICE_KILL.c_str(), CMDSTR_SERVICE_KILL.size())
        || !strncmp(commands.c_str(), CMDSTR_GENERATE_KEY.c_str(), CMDSTR_GENERATE_KEY.size())) {
        client.CtrlServiceWork(commands.c_str());
        return 0;
    }
    if (isPullServer && serverListenString == DEFAULT_SERVER_ADDR
        && Base::ProgramMutex(SERVER_NAME.c_str(), true) == 0) {
        // default pullup, just default listenstr.If want to customer listen-string, please use 'hdc -m -s lanip:port'
        HdcServer::PullupServer(DEFAULT_SERVER_ADDR.c_str());
        uv_sleep(300);  // give time to start serverForClient,at least 300ms
    }
    client.Initial(connectKey);
    client.ExecuteCommand(commands.c_str());
    return 0;
}

bool ParseServerListenString(string &serverListenString, char *optarg)
{
    if (strlen(optarg) > 24) { // 24 min len
        Base::PrintMessage("Unknow content of parament '-s'");
        return false;
    }
    char buf[BUF_SIZE_TINY] = "";
    if (strcpy_s(buf, sizeof(buf), optarg) < 0) {
        return false;
    }
    char *p = strchr(buf, ':');
    if (!p) {  // Only port
        if (strlen(buf) > 5) { // 5 port len
            Base::PrintMessage("The port-string's length must < 5");
            return false;
        }
        int port = atoi(buf);
        if (port <= 0 || port > MAX_IP_PORT) {
            Base::PrintMessage("Port range incorrect");
            return false;
        }
        snprintf_s(buf, sizeof(buf), sizeof(buf) - 1, "127.0.0.1:%d", port);
        serverListenString = buf;
    } else {
        *p = '\0';
        int port = atoi(p + 1);
        sockaddr_in addr;
        if ((port <= 0 || port > MAX_IP_PORT) || uv_ip4_addr(buf, port, &addr) < 0) {
            Base::PrintMessage("-s content incorrect.");
            return false;
        }
        serverListenString = optarg;
    }
    return true;
}

bool GetCommandlineOptions(int optArgc, const char *optArgv[])
{
    int ch = 0;
    bool needExit = false;
    opterr = 0;
    // get option parameters first
    while ((ch = getopt(optArgc, (char * const *)optArgv, "hvpfms:d:t:l:")) != -1) {
        switch (ch) {
            case 'h': {
                string usage = Hdc::TranslateCommand::Usage();
                fprintf(stderr, "%s", usage.c_str());
                needExit = true;
                return needExit;
            }
            case 'v': {
                string ver = Base::GetVersion();
                fprintf(stdout, "%s\n", ver.c_str());
                needExit = true;
                return needExit;
            }
            case 'f': {  // [not-publish]
                break;
            }
            case 'l': {
                int logLevel = atoi(optarg);
                if (logLevel < 0 || logLevel > LOG_LAST) {
                    Base::PrintMessage("Loglevel error!");
                    needExit = true;
                    return needExit;
                }
                g_logLevel = logLevel;
                Base::SetLogLevel(logLevel);
                break;
            }
            case 'm': {  // [not-publish] is server mode，or client mode
                g_isServerMode = true;
                break;
            }
            case 'p': {  // [not-publish]  not pullup server
                g_isPullServer = false;
                break;
            }
            case 't': {  // key
                if (strlen(optarg) > MAX_CONNECTKEY_SIZE) {
                    Base::PrintMessage("Sizeo of of parament '-t' %d is too long", strlen(optarg));
                    needExit = true;
                    return needExit;
                }
                g_connectKey = optarg;
                break;
            }
            case 's': {
                if (!Hdc::ParseServerListenString(g_serverListenString, optarg)) {
                    needExit = true;
                    return needExit;
                }
                break;
            }
            case 'd':  // [Undisclosed parameters] debug mode
                g_isPcDebugRun = true;
                if (optarg[0] == 't') {
                    g_isTCPorUSB = true;
                } else if (optarg[0] == 'u') {
                    g_isTCPorUSB = false;
                } else {
                    Base::PrintMessage("Unknown debug parameters");
                    needExit = true;
                    return needExit;
                }
                g_isTestMethod = atoi(optarg + 1);
                break;
            case '?':
                break;
            default: {
                Base::PrintMessage("Unknown parameters");
                needExit = true;
                return needExit;
            }
        }
    }
    return needExit;
}
}

#ifndef UNIT_TEST
// hdc -l4 -m -s ip:port|hdc -l4 -m
// hdc -l4 - s ip:port list targets
int main(int argc, const char *argv[])
{
    string options;
    string commands;
    Hdc::SplitOptionAndCommand(argc, argv, options, commands);
    int optArgc = 0;
    char **optArgv = Base::SplitCommandToArgs(options.c_str(), &optArgc);
    bool cmdOptionResult = GetCommandlineOptions(optArgc, (const char **)optArgv);
    delete[]((char *)optArgv);
    if (cmdOptionResult) {
        return 0;
    }
    if (g_isServerMode) {
        // -m server.Run alone in the background, no -s will be listen loopback address,
        Base::SetLogLevel(g_logLevel); // default level LOG_LEVEL_FULL
        Hdc::RunServerMode(g_serverListenString);
    } else if (!g_isPcDebugRun) {
        Hdc::RunClientMode(commands, g_serverListenString, g_connectKey, g_isPullServer);
    }
    WRITE_LOG(LOG_DEBUG, "!!!!!!!!!Main finish main");
    return 0;
}
#endif  // no UNIT_TEST