From 2587d7b9c2adf5e38316bee2bd62d0982980dda6 Mon Sep 17 00:00:00 2001
From: Jin1K <1061208093@qq.com>
Date: Sun, 15 Jun 2025 20:27:11 +0800
Subject: [PATCH] encrypt

Signed-off-by: Jin1K <1061208093@qq.com>
Change-Id: I8f8173b46fc8bb1782f868679b5a54c96f376003
---
 .../service/data_share/data_share_service_impl.cpp          | 6 +++---
 .../subscriber_managers/rdb_subscriber_manager.cpp          | 3 ++-
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/services/distributeddataservice/service/data_share/data_share_service_impl.cpp b/services/distributeddataservice/service/data_share/data_share_service_impl.cpp
index 97757d4da..b21bd620d 100644
--- a/services/distributeddataservice/service/data_share/data_share_service_impl.cpp
+++ b/services/distributeddataservice/service/data_share/data_share_service_impl.cpp
@@ -127,7 +127,7 @@ std::pair<int32_t, int32_t> DataShareServiceImpl::InsertEx(const std::string &ur
         if (errCode == E_OK && ret > 0) {
             NotifyChange(uri, providerInfo.visitedUserId);
             RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.visitedUserId, metaData);
-        } 
+        }
         if (errCode != E_OK) {
             ReportExcuteFault(callingTokenId, providerInfo, errCode, func);
         }
@@ -175,7 +175,7 @@ std::pair<int32_t, int32_t> DataShareServiceImpl::UpdateEx(const std::string &ur
         if (errCode == E_OK && ret > 0) {
             NotifyChange(uri, providerInfo.visitedUserId);
             RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.visitedUserId, metaData);
-        } 
+        }
         if (errCode != E_OK) {
             ReportExcuteFault(callingTokenId, providerInfo, errCode, func);
         }
@@ -204,7 +204,7 @@ std::pair<int32_t, int32_t> DataShareServiceImpl::DeleteEx(const std::string &ur
         if (errCode == E_OK && ret > 0) {
             NotifyChange(uri, providerInfo.visitedUserId);
             RdbSubscriberManager::GetInstance().Emit(uri, providerInfo.visitedUserId, metaData);
-        } 
+        }
         if (errCode != E_OK) {
             ReportExcuteFault(callingTokenId, providerInfo, errCode, func);
         }
diff --git a/services/distributeddataservice/service/data_share/subscriber_managers/rdb_subscriber_manager.cpp b/services/distributeddataservice/service/data_share/subscriber_managers/rdb_subscriber_manager.cpp
index 054513fdb..1fb04a571 100644
--- a/services/distributeddataservice/service/data_share/subscriber_managers/rdb_subscriber_manager.cpp
+++ b/services/distributeddataservice/service/data_share/subscriber_managers/rdb_subscriber_manager.cpp
@@ -350,7 +350,6 @@ int RdbSubscriberManager::Notify(const Key &key, int32_t userId, const std::vect
         return E_TEMPLATE_NOT_EXIST;
     }
     DistributedData::StoreMetaData meta = metaData;
-    meta.bundleName = key.bundleName;
     meta.user = std::to_string(userId);
     auto delegate = DBDelegate::Create(meta, key.uri);
     if (delegate == nullptr) {
@@ -428,6 +427,8 @@ DistributedData::StoreMetaData RdbSubscriberManager::GenMetaDataFromContext(cons
     metaData.dataDir = context->calledSourceDir;
     metaData.storeId = context->calledStoreName;
     metaData.haMode = context->haMode;
+    metaData.isEncrypt = context->isEncryptDb;
+    metaData.bundleName = context->calledBundleName;
     return metaData;
 }
 
-- 
Gitee