OpenHarmony-v6.0-Release/s

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

#include <algorithm>

#ifdef PREFERENCES_ENABLE
#include "preferences_errno.h"
#include "preferences_helper.h"
#include "preferences_value.h"
#endif
#include "sam_log.h"
#include "sa_profiles.h"
#include "system_ability_manager.h"
#include "samgr_time_handler.h"
#include <cinttypes>

using namespace std;

namespace OHOS {
namespace {
constexpr const char* LOOP_EVENT = "loopevent";
constexpr const char* AWAKE_LOOP_EVENT = "awakeloopevent";
constexpr const char* ORDER_TIMED_EVENT = "timedevent";
constexpr int32_t MIN_INTERVAL = 30;
constexpr int32_t MIN_AWAKE_INTERVAL = 3600;
}

DeviceTimedCollect::DeviceTimedCollect(const sptr<IReport>& report)
    : ICollectPlugin(report)
{
}

void DeviceTimedCollect::Init(const std::list<SaProfile>& saProfiles)
{
    for (auto& saProfile : saProfiles) {
        for (auto& onDemandEvent : saProfile.startOnDemand.onDemandEvents) {
            SaveTimedEvent(onDemandEvent);
        }
        for (auto& onDemandEvent : saProfile.stopOnDemand.onDemandEvents) {
            SaveTimedEvent(onDemandEvent);
        }
    }
    HILOGD("DeviceTimedCollect timedSet count: %{public}zu", nonPersitenceLoopEventSet_.size());
}

void DeviceTimedCollect::ProcessPersistenceTasks()
{
#ifdef PREFERENCES_ENABLE
    preferencesUtil_ = PreferencesUtil::GetInstance();
    std::map<std::string, NativePreferences::PreferencesValue> allData = preferencesUtil_->ObtainAll();
    int64_t currentTime = TimeUtils::GetTimestamp();
    for (const auto& [strInterval, triggerTime] : allData) {
        if (strInterval.find("_") != std::string::npos) {
            continue;
        }
        int64_t disTime = static_cast<int64_t>(triggerTime) - currentTime;
        if (strInterval.find(':') != string::npos) {
            ProcessPersistenceTimedTask(disTime, strInterval);
            return;
        }
        ProcessPersistenceLoopTask(disTime, static_cast<int64_t>(triggerTime), strInterval);
    }
#endif
}

void DeviceTimedCollect::ProcessPersistenceTimedTask(int64_t disTime, std::string timeString)
{
#ifdef PREFERENCES_ENABLE
    if (disTime <= 0) {
        OnDemandEvent event = { TIMED_EVENT, ORDER_TIMED_EVENT, timeString, -1, true };
        ReportEvent(event);
        preferencesUtil_->Remove(timeString);
        return;
    }
    auto timedTask = [this, timeString] () {
        OnDemandEvent event = { TIMED_EVENT, ORDER_TIMED_EVENT, timeString, -1, true };
        ReportEvent(event);
        preferencesUtil_->Remove(timeString);
    };
    if (!SamgrTimeHandler::GetInstance()->PostTask(timedTask, disTime)) {
        PostDelayTask(timedTask, disTime);
    }
#endif
}

void DeviceTimedCollect::ProcessPersistenceLoopTask(int64_t disTime, int64_t triggerTime, std::string strInterval)
{
    int64_t interval = atoi(strInterval.c_str());
    {
        lock_guard<samgr::mutex> autoLock(persitenceLoopEventSetLock_);
        if (persitenceLoopTasks_.count(interval) > 0) {
            return;
        }
    }
#ifdef PREFERENCES_ENABLE
    int64_t currentTime = TimeUtils::GetTimestamp();
    if (static_cast<int64_t>(triggerTime) - interval > currentTime) {
        HILOGW("currentTime is not true");
        return;
    }
#endif
    if (interval < MIN_INTERVAL) {
        HILOGW("interval is not true");
        return;
    }
    auto task = [this, interval] () {
        lock_guard<samgr::mutex> autoLock(persitenceLoopEventSetLock_);
        if (persitenceLoopTasks_.find(interval) != persitenceLoopTasks_.end()) {
            HILOGI("DeviceTimedCollect Persistence ReportEvent interval: %{public}" PRId64, interval);
            ReportEventByTimeInfo(interval, true);
            PostPersistenceDelayTask(persitenceLoopTasks_[interval], interval, interval);
        } else {
            HILOGI("DeviceTimedCollect Persistence interval %{public}" PRId64 " has been remove", interval);
        }
    };
    {
        lock_guard<samgr::mutex> autoLock(persitenceLoopEventSetLock_);
        persitenceLoopTasks_[interval] = task;
    }
    if (disTime <= 0) {
        ReportEventByTimeInfo(interval, true);
        // In order to enable the timer to start on time next time and make up for the missing time
        disTime = interval - abs(disTime) % interval;
        PostPersistenceDelayTask(task, interval, disTime);
    } else {
        PostDelayTaskByTimeInfo(task, interval, disTime);
    }
}

void DeviceTimedCollect::ReportEventByTimeInfo(int32_t interval, bool persistence)
{
    lock_guard<samgr::mutex> autoLock(timeInfosLock_);
    if (timeInfos_.count(interval) == 0) {
        return;
    }
    if (timeInfos_[interval].normal) {
        OnDemandEvent event = { TIMED_EVENT, LOOP_EVENT, to_string(interval), -1, persistence };
        HILOGI("report normal:%{public}d ,persistence:%{public}d", interval, persistence);
        ReportEvent(event);
    }
    if (timeInfos_[interval].awake) {
        OnDemandEvent event = { TIMED_EVENT, AWAKE_LOOP_EVENT, to_string(interval), -1, persistence };
        HILOGI("report awake:%{public}d ,persistence:%{public}d", interval, persistence);
        ReportEvent(event);
    }
}

void DeviceTimedCollect::SaveTimedInfos(const OnDemandEvent& onDemandEvent, int32_t interval)
{
    lock_guard<samgr::mutex> autoLock(timeInfosLock_);
    if (timeInfos_.count(interval) == 0) {
        TimeInfo info;
        timeInfos_[interval] = info;
    }
    if (onDemandEvent.name == LOOP_EVENT) {
        timeInfos_[interval].normal = true;
    }
    if (onDemandEvent.name == AWAKE_LOOP_EVENT) {
        timeInfos_[interval].awake = true;
    }
    HILOGI("SaveTimedInfos : %{public}d : %{public}d , %{public}d", interval,
        timeInfos_[interval].normal, timeInfos_[interval].awake);
}

void DeviceTimedCollect::SaveTimedEvent(const OnDemandEvent& onDemandEvent)
{
    if (onDemandEvent.eventId == TIMED_EVENT &&
        (onDemandEvent.name == LOOP_EVENT || onDemandEvent.name == AWAKE_LOOP_EVENT)) {
        HILOGI("DeviceTimedCollect save timed task: %{public}s", onDemandEvent.value.c_str());
        int32_t interval = atoi(onDemandEvent.value.c_str());
        if (interval < MIN_INTERVAL) {
            HILOGE("DeviceTimedCollect invalid interval %{public}s", onDemandEvent.value.c_str());
            return;
        }
        if (interval < MIN_AWAKE_INTERVAL && onDemandEvent.name == AWAKE_LOOP_EVENT) {
            HILOGE("SaveTimedEvent awake clock invalid interval: %{public}d", interval);
            return;
        }
        if (onDemandEvent.persistence) {
            lock_guard<samgr::mutex> autoLock(persitenceLoopEventSetLock_);
            persitenceLoopEventSet_.insert(interval);
        } else {
            lock_guard<samgr::mutex> autoLock(nonPersitenceLoopEventSetLock_);
            nonPersitenceLoopEventSet_.insert(interval);
        }
        SaveTimedInfos(onDemandEvent, interval);
    }
}

void DeviceTimedCollect::PostPersistenceLoopTaskLocked(int32_t interval)
{
    if (persitenceLoopTasks_.count(interval) > 0) {
        return;
    }
    persitenceLoopTasks_[interval] = [this, interval] () {
        lock_guard<samgr::mutex> autoLock(persitenceLoopEventSetLock_);
        if (persitenceLoopTasks_.find(interval) != persitenceLoopTasks_.end()) {
            HILOGI("DeviceTimedCollect PostPersistence ReportEvent interval: %{public}d", interval);
            ReportEventByTimeInfo(interval, true);
            PostPersistenceDelayTask(persitenceLoopTasks_[interval], interval, interval);
        } else {
            HILOGI("DeviceTimedCollect PostPersistence interval %{public}d has been remove", interval);
        }
    };
    PostPersistenceDelayTask(persitenceLoopTasks_[interval], interval, interval);
}

void DeviceTimedCollect::PostNonPersistenceLoopTaskLocked(int32_t interval)
{
    if (nonPersitenceLoopTasks_.count(interval) > 0) {
        HILOGE("DeviceTimedCollect interval has been post");
        return;
    }
    nonPersitenceLoopTasks_[interval] = [this, interval] () {
        lock_guard<samgr::mutex> autoLock(nonPersitenceLoopEventSetLock_);
        if (nonPersitenceLoopEventSet_.find(interval) != nonPersitenceLoopEventSet_.end()) {
            HILOGI("DeviceTimedCollect ReportEvent interval: %{public}d", interval);
            ReportEventByTimeInfo(interval, false);
            PostDelayTaskByTimeInfo(nonPersitenceLoopTasks_[interval], interval, interval);
        } else {
            HILOGI("DeviceTimedCollect interval %{public}d has been remove", interval);
        }
    };
    PostDelayTaskByTimeInfo(nonPersitenceLoopTasks_[interval], interval, interval);
}

void DeviceTimedCollect::PostDelayTaskByTimeInfo(std::function<void()> callback,
    int32_t interval, int32_t disTime)
{
    lock_guard<samgr::mutex> autoLock(timeInfosLock_);
    if (timeInfos_.count(interval) == 0) {
        return;
    }
    if (timeInfos_[interval].awake) {
        if (!SamgrTimeHandler::GetInstance()->PostTask(callback, disTime)) {
            PostDelayTask(callback, disTime);
        }
    } else {
        PostDelayTask(callback, disTime);
    }
}

void DeviceTimedCollect::PostPersistenceDelayTask(std::function<void()> postTask,
    int32_t interval, int32_t disTime)
{
#ifdef PREFERENCES_ENABLE
    int64_t currentTime = TimeUtils::GetTimestamp();
    int64_t upgradeTime = currentTime + static_cast<int64_t>(disTime);
    preferencesUtil_->SaveLong(to_string(interval), upgradeTime);
    PostDelayTaskByTimeInfo(postTask, interval, disTime);
    HILOGI("save persistence time %{public}d, interval time %{public}d", static_cast<int32_t>(upgradeTime), interval);
#endif
}

int32_t DeviceTimedCollect::OnStart()
{
    HILOGI("DeviceTimedCollect OnStart called");
    ProcessPersistenceTasks();
    PostNonPersistenceLoopTasks();
    PostPersistenceLoopTasks();
    return ERR_OK;
}

void DeviceTimedCollect::PostNonPersistenceLoopTasks()
{
    lock_guard<samgr::mutex> autoLock(nonPersitenceLoopEventSetLock_);
    for (auto it = nonPersitenceLoopEventSet_.begin(); it != nonPersitenceLoopEventSet_.end(); ++it) {
        HILOGI("DeviceTimedCollect send task: %{public}d", *it);
        PostNonPersistenceLoopTaskLocked(*it);
    }
}

void DeviceTimedCollect::PostPersistenceLoopTasks()
{
    lock_guard<samgr::mutex> autoLock(persitenceLoopEventSetLock_);
    for (auto it = persitenceLoopEventSet_.begin(); it != persitenceLoopEventSet_.end(); ++it) {
        HILOGI("DeviceTimedCollect send persitence task: %{public}d", *it);
        PostPersistenceLoopTaskLocked(*it);
    }
}

int32_t DeviceTimedCollect::OnStop()
{
    HILOGI("DeviceTimedCollect OnStop called");
    return ERR_OK;
}

int64_t DeviceTimedCollect::CalculateDelayTime(const std::string& timeString)
{
    std::tm inputTime;
    strptime(const_cast<char*>(timeString.c_str()), "%Y-%m-%d-%H:%M:%S", &inputTime);
    std::time_t orderTime = mktime(&inputTime);
    int64_t timeGap = orderTime - time(nullptr);
    return timeGap;
}

void DeviceTimedCollect::PostPersistenceTimedTaskLocked(std::string timeString, int64_t timeGap)
{
#ifdef PREFERENCES_ENABLE
    if (timeGap <= 0) {
        HILOGE("PostPersistenceTimedTask invalid timeGap: %{public}" PRId64 "ms", timeGap);
        return;
    }
    auto timedTask = [this, timeString] () {
        OnDemandEvent event = { TIMED_EVENT, ORDER_TIMED_EVENT, timeString, -1, true };
        ReportEvent(event);
        preferencesUtil_->Remove(timeString);
    };
    int64_t currentTime = TimeUtils::GetTimestamp();
    int64_t upgradeTime = currentTime + timeGap;
    preferencesUtil_->SaveLong(timeString, upgradeTime);
    if (!SamgrTimeHandler::GetInstance()->PostTask(timedTask, timeGap)) {
        PostDelayTask(timedTask, timeGap);
    }
#endif
}

void DeviceTimedCollect::PostNonPersistenceTimedTaskLocked(std::string timeString, int64_t timeGap)
{
    auto timedTask = [this, timeString] () {
        OnDemandEvent event = { TIMED_EVENT, ORDER_TIMED_EVENT, timeString };
        ReportEvent(event);
    };
    if (timeGap <= 0) {
        HILOGE("PostNonPersistenceTimedTask invalid timeGap: %{public}" PRId64 "ms", timeGap);
        return;
    }
    if (!SamgrTimeHandler::GetInstance()->PostTask(timedTask, timeGap)) {
        PostDelayTask(timedTask, timeGap);
    }
}

int32_t DeviceTimedCollect::AddCollectEvent(const std::vector<OnDemandEvent>& events)
{
    for (auto& event : events) {
        if (event.name != LOOP_EVENT && event.name != ORDER_TIMED_EVENT && event.name != AWAKE_LOOP_EVENT) {
            HILOGE("DeviceTimedCollect invalid event name: %{public}s", event.name.c_str());
            return ERR_INVALID_VALUE;
        }
        if (event.name == ORDER_TIMED_EVENT) {
            int64_t timeGap = CalculateDelayTime(event.value);
#ifdef PREFERENCES_ENABLE
            if (event.persistence) {
                std::lock_guard<samgr::mutex> autoLock(persitenceTimedEventSetLock_);
                PostPersistenceTimedTaskLocked(event.value, timeGap);
                continue;
            }
#endif
            std::lock_guard<samgr::mutex> autoLock(nonPersitenceTimedEventSetLock);
            PostNonPersistenceTimedTaskLocked(event.value, timeGap);
            continue;
        }
        if (event.persistence) {
            HILOGE("invalid event persistence, loopevent is not support persistence");
            return ERR_INVALID_VALUE;
        }
        int32_t interval = atoi(event.value.c_str());
        if (interval < MIN_INTERVAL) {
            HILOGE("DeviceTimedCollect invalid interval: %{public}d", interval);
            return ERR_INVALID_VALUE;
        }
        if (interval < MIN_AWAKE_INTERVAL && event.name == AWAKE_LOOP_EVENT) {
            HILOGE("DeviceTimedCollect awake clock invalid interval: %{public}d", interval);
            return ERR_INVALID_VALUE;
        }
        SaveTimedInfos(event, interval);
        std::lock_guard<samgr::mutex> autoLock(nonPersitenceLoopEventSetLock_);
        auto iter = nonPersitenceLoopEventSet_.find(interval);
        if (iter != nonPersitenceLoopEventSet_.end()) {
            continue;
        }
        HILOGI("DeviceTimedCollect add collect events: %{public}d", interval);
        nonPersitenceLoopEventSet_.insert(interval);
        PostNonPersistenceLoopTaskLocked(interval);
    }
    return ERR_OK;
}

int32_t DeviceTimedCollect::RemoveUnusedEvent(const OnDemandEvent& event)
{
    if (event.name != LOOP_EVENT && event.name != AWAKE_LOOP_EVENT) {
        HILOGE("DeviceTimedCollect invalid event name: %{public}s", event.name.c_str());
        return ERR_INVALID_VALUE;
    }
    int32_t interval = atoi(event.value.c_str());
    if (event.persistence) {
        RemovePersistenceLoopTask(interval);
    } else {
        RemoveNonPersistenceLoopTask(interval);
    }
    RemoveTimesInfo(event, interval);
    return ERR_OK;
}

void DeviceTimedCollect::RemoveTimesInfo(const OnDemandEvent& onDemandEvent, int32_t interval)
{
    lock_guard<samgr::mutex> autoLock(timeInfosLock_);
    if (timeInfos_.count(interval) == 0) {
        return;
    }
    if (onDemandEvent.name == LOOP_EVENT) {
        timeInfos_[interval].normal = false;
    }
    if (onDemandEvent.name == AWAKE_LOOP_EVENT) {
        timeInfos_[interval].awake = false;
    }
    HILOGI("RemoveTimesInfo : %{public}d : %{public}d , %{public}d", interval,
        timeInfos_[interval].normal, timeInfos_[interval].awake);
    if (!timeInfos_[interval].normal && !timeInfos_[interval].awake) {
        timeInfos_.erase(interval);
    }
}

void DeviceTimedCollect::RemoveNonPersistenceLoopTask(int32_t interval)
{
    std::lock_guard<samgr::mutex> autoLock(nonPersitenceLoopEventSetLock_);
    auto iter = nonPersitenceLoopEventSet_.find(interval);
    if (iter != nonPersitenceLoopEventSet_.end()) {
        nonPersitenceLoopEventSet_.erase(iter);
        nonPersitenceLoopTasks_.erase(interval);
    }
}

void DeviceTimedCollect::RemovePersistenceLoopTask(int32_t interval)
{
    std::lock_guard<samgr::mutex> autoLock(persitenceLoopEventSetLock_);
    auto iter = persitenceLoopEventSet_.find(interval);
    if (iter != persitenceLoopEventSet_.end()) {
        persitenceLoopEventSet_.erase(iter);
        persitenceLoopTasks_.erase(interval);
    }
}
}