OpenHarmony-v6.0-Release/s

/*
 * Copyright (c) 2022-2025 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 "ext_backup.h"

#include <algorithm>
#include <cstdio>
#include <sstream>

#include <sys/stat.h>
#include <sys/types.h>

#include "bundle_mgr_client.h"
#include "unique_fd.h"

#include "b_anony/b_anony.h"
#include "b_error/b_error.h"
#include "b_error/b_excep_utils.h"
#include "b_json/b_json_cached_entity.h"
#include "b_json/b_json_entity_extension_config.h"
#include "b_resources/b_constants.h"
#include "ext_backup_ani.h"
#include "ext_backup_js.h"
#include "ext_extension.h"
#include "filemgmt_libhilog.h"
#include "service_common.h"
#include "iservice.h"

namespace OHOS::FileManagement::Backup {
using namespace std;

CreatorFunc ExtBackup::creator_ = nullptr;
void ExtBackup::SetCreator(const CreatorFunc &creator)
{
    creator_ = creator;
}

void ExtBackup::SetBackupExtExtension(const wptr<BackupExtExtension> &extExtension)
{
    bakExtExtension_ = extExtension;
}

void ExtBackup::Init(const shared_ptr<AbilityRuntime::AbilityLocalRecord> &record,
                     const shared_ptr<AbilityRuntime::OHOSApplication> &application,
                     shared_ptr<AbilityRuntime::AbilityHandler> &handler,
                     const sptr<IRemoteObject> &token)
{
    HILOGI("Init the BackupExtensionAbility(Base)");
    AbilityRuntime::ExtensionBase<ExtBackupContext>::Init(record, application, handler, token);
}

ExtBackup *ExtBackup::Create(const unique_ptr<AbilityRuntime::Runtime> &runtime)
{
    if (!runtime) {
        HILOGD("Create as BackupExtensionAbility(base)");
        return new ExtBackup();
    }

    if (creator_) {
        HILOGD("Create as BackupExtensionAbility(creater)");
        return creator_(runtime);
    }

    switch (runtime->GetLanguage()) {
        case AbilityRuntime::Runtime::Language::JS:
            HILOGD("Create as BackupExtensionAbility(JS)");
            return ExtBackupJs::Create(runtime);
        case AbilityRuntime::Runtime::Language::ETS:
            HILOGD("Create as BackupExtensionAbility(ETS)");
            return ExtBackupAni::Create(runtime);
        default:
            HILOGD("Create as BackupExtensionAbility(base)");
            return new ExtBackup();
    }
}

void ExtBackup::OnStart(const AAFwk::Want &want)
{
    HILOGI("BackupExtensionAbility was started");
    Extension::OnStart(want);
}

void ExtBackup::OnCommand(const AAFwk::Want &want, bool restart, int startId)
{
    HILOGI("BackupExtensionAbility was invoked. restart=%{public}d, startId=%{public}d", restart, startId);

    // REM: 处理返回结果 ret
    // REM: 通过杀死进程实现 Stop
}

string ExtBackup::GetUsrConfig() const
{
    vector<string> config;
    AppExecFwk::BundleMgrClient client;
    BExcepUltils::BAssert(abilityInfo_, BError::Codes::EXT_BROKEN_FRAMEWORK, "Invalid abilityInfo_");
    const AppExecFwk::AbilityInfo &info = *abilityInfo_;
    if (!client.GetProfileFromAbility(info, "ohos.extension.backup", config)) {
        throw BError(BError::Codes::EXT_INVAL_ARG, "Failed to invoke the GetProfileFromAbility method.");
    }
    if (config.empty()) {
        HILOGE("GetUsrConfig empty.");
    } else {
        HILOGI("GetUsrConfig:%{public}s", config[0].c_str());
    }

    return config.empty() ? "" : config[0];
}

bool ExtBackup::AllowToBackupRestore()
{
    string usrConfig = GetUsrConfig();
    BJsonCachedEntity<BJsonEntityExtensionConfig> cachedEntity(usrConfig);
    auto cache = cachedEntity.Structuralize();
    if (cache.GetAllowToBackupRestore() || WasFromSpecialVersion() || SpecialVersionForCloneAndCloud()) {
        return true;
    }
    return false;
}

bool ExtBackup::UseFullBackupOnly(void) const
{
    string usrConfig = GetUsrConfig();
    BJsonCachedEntity<BJsonEntityExtensionConfig> cachedEntity(usrConfig);
    auto cache = cachedEntity.Structuralize();
    if (cache.GetFullBackupOnly()) {
        HILOGI("backup use fullBackupOnly.");
        return true;
    }
    HILOGI("backup not use fullBackupOnly.");
    return false;
}

BConstants::ExtensionAction ExtBackup::GetExtensionAction() const
{
    return extAction_;
}

BConstants::ExtensionAction ExtBackup::VerifyAndGetAction(const AAFwk::Want &want,
                                                          std::shared_ptr<AppExecFwk::AbilityInfo> abilityInfo)
{
    string pendingMsg = "Received an empty ability. You must missed the init proc";
    BExcepUltils::BAssert(abilityInfo, BError::Codes::EXT_INVAL_ARG, pendingMsg);
    using namespace BConstants;
    ExtensionAction extAction {want.GetIntParam(EXTENSION_ACTION_PARA, static_cast<int>(ExtensionAction::INVALID))};
    if (extAction == ExtensionAction::INVALID) {
        int extActionInt = static_cast<int>(extAction);
        pendingMsg = string("Want must specify a valid action instead of ").append(to_string(extActionInt));
        throw BError(BError::Codes::EXT_INVAL_ARG, pendingMsg);
    }
    return extAction;
}

ErrCode ExtBackup::GetParament(const AAFwk::Want &want)
{
    if (extAction_ == BConstants::ExtensionAction::RESTORE) {
        appVersionStr_ = want.GetStringParam(BConstants::EXTENSION_VERSION_NAME_PARA);
        appVersionCode_ = want.GetLongParam(BConstants::EXTENSION_VERSION_CODE_PARA, 0);
        restoreType_ = want.GetIntParam(BConstants::EXTENSION_RESTORE_TYPE_PARA, 0);
        restoreExtInfo_ = want.GetStringParam(BConstants::EXTENSION_RESTORE_EXT_INFO_PARA);
        oldBackupVersion_ = want.GetStringParam(BConstants::EXTENSION_OLD_BACKUP_VERSION_PARA);
        HILOGI("restoreExtInfo_ is %{public}s", GetAnonyString(restoreExtInfo_).c_str());
        HILOGI("Get version %{public}s type %{public}d from want when restore.", appVersionStr_.c_str(), restoreType_);
        HILOGI("oldBackupVersion_ is %{public}s", oldBackupVersion_.c_str());
    } else if (extAction_ == BConstants::ExtensionAction::BACKUP) {
        backupExtInfo_ = want.GetStringParam(BConstants::EXTENSION_BACKUP_EXT_INFO_PARA);
        HILOGI("backupExtInfo_ is %{public}s", backupExtInfo_.c_str());
    }
    /* backup don't need parament. */
    return ERR_OK;
}

sptr<IRemoteObject> ExtBackup::OnConnect(const AAFwk::Want &want)
{
    try {
        HILOGI("begin connect");
        BExcepUltils::BAssert(abilityInfo_, BError::Codes::EXT_BROKEN_FRAMEWORK, "Invalid abilityInfo_");
        // 发起者必须是备份服务
        auto extAction = VerifyAndGetAction(want, abilityInfo_);
        if (extAction_ != BConstants::ExtensionAction::INVALID && extAction == BConstants::ExtensionAction::INVALID &&
            extAction_ != extAction) {
            HILOGE("Verification action failed.");
            return nullptr;
        }
        extAction_ = extAction;
        GetParament(want);
        // 应用必须配置支持备份恢复
        if (!AllowToBackupRestore()) {
            HILOGE("The application does not allow to backup and restore.");
            return nullptr;
        }

        Extension::OnConnect(want);

        auto remoteObject =
            sptr<BackupExtExtension>(new BackupExtExtension(std::static_pointer_cast<ExtBackup>(shared_from_this()),
            want.GetBundle()));
        return remoteObject->AsObject();
    } catch (const BError &e) {
        return nullptr;
    } catch (const exception &e) {
        HILOGE("%{public}s", e.what());
        return nullptr;
    } catch (...) {
        HILOGE("");
        return nullptr;
    }
}

void ExtBackup::OnDisconnect(const AAFwk::Want &want)
{
    try {
        HILOGI("begin disconnect");
        sptr<BackupExtExtension> extExtension = bakExtExtension_.promote();
        if (extExtension != nullptr) {
            extExtension->ExtClear();
        }
        Extension::OnDisconnect(want);
        extAction_ = BConstants::ExtensionAction::INVALID;
        HILOGI("end");
    } catch (const BError &e) {
        return;
    } catch (const exception &e) {
        HILOGE("%{public}s", e.what());
        return;
    } catch (...) {
        HILOGE("");
        return;
    }
}

bool ExtBackup::WasFromSpecialVersion(void)
{
    if (appVersionStr_.empty()) {
        HILOGE("App version name is empty");
        return false;
    }
    std::string appVersionFlag_ =
        appVersionStr_.substr(0, appVersionStr_.find_first_of(BConstants::VERSION_NAME_SEPARATOR_CHAR));
    if (appVersionFlag_ == BConstants::DEFAULT_VERSION_NAME) {
        return true;
    }
    return false;
}

bool ExtBackup::SpecialVersionForCloneAndCloud(void)
{
    if (appVersionStr_.empty()) {
        HILOGE("App version name is empty");
        return false;
    }
    std::string appVersionFlag_ =
        appVersionStr_.substr(0, appVersionStr_.find_first_of(BConstants::VERSION_NAME_SEPARATOR_CHAR));
    auto iter =
        find_if(BConstants::DEFAULT_VERSION_NAMES_VEC.begin(), BConstants::DEFAULT_VERSION_NAMES_VEC.end(),
                [appVersionFlag {appVersionFlag_}](const auto &versionName) { return versionName == appVersionFlag; });
    if (iter != BConstants::DEFAULT_VERSION_NAMES_VEC.end()) {
        return true;
    }
    return false;
}

bool ExtBackup::RestoreDataReady()
{
    return restoreType_ == RestoreTypeEnum::RESTORE_DATA_READDY;
}

ErrCode ExtBackup::OnBackup(function<void(ErrCode, std::string)> callback)
{
    HILOGI("BackupExtensionAbility(base) OnBackup.");
    return ERR_OK;
}

ErrCode ExtBackup::OnBackup(std::function<void(ErrCode, std::string)> callback,
    std::function<void(ErrCode, const std::string)> callbackEx)
{
    HILOGI("BackupExtensionAbility(base) OnBackup with Ex");
    return ERR_OK;
}

ErrCode ExtBackup::OnRestore(function<void(ErrCode, std::string)> callback,
    std::function<void(ErrCode, const std::string)> callbackEx)
{
    HILOGI("BackupExtensionAbility(base) OnRestore with Ex.");
    return ERR_OK;
}

ErrCode ExtBackup::OnRestore(function<void(ErrCode, std::string)> callback)
{
    HILOGI("BackupExtensionAbility(base) OnRestore.");
    return ERR_OK;
}

ErrCode ExtBackup::GetBackupInfo(function<void(ErrCode, std::string)> callback)
{
    HILOGI("BackupExtensionAbility(base) GetBackupInfo.");
    return ERR_OK;
}

ErrCode ExtBackup::InvokeAppExtMethod(ErrCode errCode, const std::string result)
{
    HILOGI("BackupExtensionAbility(base) InvokeAppExtMethod.");
    return ERR_OK;
}

ErrCode ExtBackup::OnProcess(std::function<void(ErrCode, std::string)> callback)
{
    HILOGI("BackupExtensionAbility(base) OnProcess.");
    return ERR_OK;
}

ErrCode ExtBackup::OnRelease(std::function<void(ErrCode, std::string)> callback, int32_t scenario)
{
    HILOGI("BackupExtensionAbility(base) OnRelease.");
    return ERR_OK;
}

ErrCode ExtBackup::GetBackupCompatibilityInfo(std::function<void(ErrCode, const std::string)> callbackEx,
    std::string extInfo)
{
    HILOGI("BackupExtensionAbility(base) GetBackupCompatibilityInfo.");
    return ERR_OK;
}

ErrCode ExtBackup::GetRestoreCompatibilityInfo(std::function<void(ErrCode, const std::string)> callbackEx,
    std::string extInfo)
{
    HILOGI("BackupExtensionAbility(base) GetRestoreCompatibilityInfo.");
    return ERR_OK;
}
} // namespace OHOS::FileManagement::Backup