/*
 * Copyright (c) 2020 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 "sys_param.h"

#include <ctype.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <sys/types.h>
#include <unistd.h>

#include "param_manager.h"
#include "param_trie.h"

#define LABEL "Manager"
#define MAX_BUFF 256

typedef struct {
    WorkSpace *workSpace;
    WorkSpace *persistWorkSpace;
    char *buffer;
} PersistContext;

static ParamPersistWorkSpace g_persistWorkSpace = {ATOMIC_VAR_INIT(0), };

static int ProcessParamTraversal(WorkSpace *workSpace, TrieNode *node, void *cookie)
{
    PARAM_CHECK(workSpace != 0 && node != NULL && cookie != NULL, return -1, "Invalid param");
    TrieDataNode *current = (TrieDataNode *)node;
    if (current == NULL || current->dataIndex == 0) {
        return 0;
    }
    DataEntry *entry = (DataEntry *)GetTrieNode(workSpace, &current->dataIndex);
    if (entry == NULL) {
        return -1;
    }
    PersistContext *persistContext = (PersistContext *)cookie;
    int ret = GetDataName(entry, persistContext->buffer, MAX_BUFF);
    if (strncmp(persistContext->buffer, "persist.", strlen("persist.")) != 0) {
        return 0;
    }
    ret |= GetDataValue(entry, persistContext->buffer + MAX_BUFF, MAX_BUFF);
    if (ret == 0) { // 只支持新建
        //PARAM_LOGI("Insert new persist param from normal param %s %s",
        //    persistContext->buffer, persistContext->buffer + MAX_BUFF);
        ret = AddParam(persistContext->persistWorkSpace, persistContext->buffer, persistContext->buffer + MAX_BUFF);
    }
    PARAM_CHECK(ret == 0, return ret, "Failed to add persist param");
    return ret;
}

static int ProcessPersistPropertTraversal(WorkSpace *workSpace, TrieNode *node, void *cookie)
{
    TrieDataNode *current = (TrieDataNode *)node;
    if (current == NULL || current->dataIndex == 0) {
        return 0;
    }
    DataEntry *entry = (DataEntry *)GetTrieNode(workSpace, &current->dataIndex);
    if (entry == NULL) {
        return -1;
    }
    PersistContext *persistContext = (PersistContext *)cookie;
    int ret = GetDataName(entry, persistContext->buffer, MAX_BUFF);
    ret |= GetDataValue(entry, persistContext->buffer + MAX_BUFF, MAX_BUFF);
    if (ret == 0) {
        //PARAM_LOGI("update normal param %s %s from persist param %u",
        //    persistContext->buffer, persistContext->buffer + MAX_BUFF, current->dataIndex);
        ret = WriteParam(persistContext->workSpace, persistContext->buffer, persistContext->buffer + MAX_BUFF);
    }
    PARAM_CHECK(ret == 0, return ret, "Failed to add persist param");
    return ret;
}

int InitPersistParamWorkSpace(const char *context)
{
    u_int32_t flags = atomic_load_explicit(&g_persistWorkSpace.flags, memory_order_relaxed);
    if ((flags & WORKSPACE_FLAGS_INIT) == WORKSPACE_FLAGS_INIT) {
        return 0;
    }
    g_persistWorkSpace.persistWorkSpace.compareTrieNode = CompareTrieDataNode;
    g_persistWorkSpace.persistWorkSpace.allocTrieNode = AllocateTrieDataNode;
    int ret = InitPersistWorkSpace(PARAM_PERSIST_PATH, &g_persistWorkSpace.persistWorkSpace);
    PARAM_CHECK(ret == 0, return ret, "Failed to init persist param");
    atomic_store_explicit(&g_persistWorkSpace.flags, WORKSPACE_FLAGS_INIT, memory_order_release);
    return ret;
}

int RefreshPersistParams(ParamWorkSpace *workSpace, const char *context)
{
    int ret = InitPersistParamWorkSpace(context);
    PARAM_CHECK(ret == 0, return ret, "Failed to init persist param");
    u_int32_t flags = atomic_load_explicit(&g_persistWorkSpace.flags, memory_order_relaxed);
    if ((flags & WORKSPACE_FLAGS_LOADED) == WORKSPACE_FLAGS_LOADED) {
        PARAM_LOGE("RefreshPersistParams has been loaded");
        return 0;
    }

    // 申请临时的缓存，用于数据读取
    char *buffer = (char *)malloc(MAX_BUFF + MAX_BUFF);
    PARAM_CHECK(buffer != NULL, return -1, "Failed to malloc memory for param");
    PersistContext persistContext = {
        &workSpace->paramSpace, &g_persistWorkSpace.persistWorkSpace, buffer
    };

    // 遍历当前的参数，并把persist的写入
    ret = TraversalTrieDataNode(&workSpace->paramSpace,
        (TrieDataNode *)workSpace->paramSpace.rootNode, ProcessParamTraversal, &persistContext);

    // 修改默认参数值
    ret = TraversalTrieDataNode(&g_persistWorkSpace.persistWorkSpace,
        (TrieDataNode *)g_persistWorkSpace.persistWorkSpace.rootNode, ProcessPersistPropertTraversal, &persistContext);

    atomic_store_explicit(&g_persistWorkSpace.flags, flags | WORKSPACE_FLAGS_LOADED, memory_order_release);
    free(buffer);
    return ret;
}

void ClosePersistParamWorkSpace()
{
    CloseWorkSpace(&g_persistWorkSpace.persistWorkSpace);
    atomic_store_explicit(&g_persistWorkSpace.flags, 0, memory_order_release);
}

int WritePersistParam(const char *name, const char *value)
{
    PARAM_CHECK(value != NULL && name != NULL, return PARAM_CODE_INVALID_PARAM, "Invalid param");
    if (strncmp(name, "persist.", strlen("persist.")) != 0) {
        return 0;
    }
    int ret = InitPersistParamWorkSpace("");
    PARAM_CHECK(ret == 0, return ret, "Failed to init persist param");
    u_int32_t flags = atomic_load_explicit(&g_persistWorkSpace.flags, memory_order_relaxed);
    if ((flags & WORKSPACE_FLAGS_LOADED) != WORKSPACE_FLAGS_LOADED) {
        return 0;
    }
    return WriteParam(&g_persistWorkSpace.persistWorkSpace, name, value);
}