1 /* 2 * Copyright (c) 2022 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 #ifndef SINGLE_VER_DATA_SYNC_UTIL_H 16 #define SINGLE_VER_DATA_SYNC_UTIL_H 17 18 #include "message.h" 19 #include "single_ver_data_packet.h" 20 #include "single_ver_sync_task_context.h" 21 namespace DistributedDB { 22 class SingleVerDataSyncUtils { 23 public: 24 static bool QuerySyncCheck(const SingleVerSyncTaskContext *context); 25 26 static int AckMsgErrnoCheck(const SingleVerSyncTaskContext *context, const Message *message); 27 28 static int RequestQueryCheck(const DataRequestPacket *packet, SyncGenericInterface *storage); 29 30 static bool IsPermitLocalDeviceRecvData(const std::string &deviceId, const SecurityOption &remoteSecOption); 31 32 static bool IsPermitRemoteDeviceRecvData(const std::string &deviceId, const SecurityOption &remoteSecOption, 33 SyncGenericInterface *storage); 34 35 static void TransDbDataItemToSendDataItem(const std::string &localHashName, 36 std::vector<SendDataItem> &outData); 37 38 static std::string TransferForeignOrigDevName(const std::string &deviceName, const std::string &localHashName); 39 40 static void TransSendDataItemToLocal(const SingleVerSyncTaskContext *context, 41 const std::string &localHashName, const std::vector<SendDataItem> &data); 42 43 static void TranslateErrCodeIfNeed(int mode, uint32_t version, int &errCode); 44 45 static int RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, 46 const std::string &label, const DataRequestPacket *packet); 47 48 static bool CheckPermitReceiveData(const SingleVerSyncTaskContext *context, const ICommunicator *communicator); 49 50 static void SetPacketId(DataRequestPacket *packet, SingleVerSyncTaskContext *context, uint32_t version); 51 52 static int GetMessageId(SyncType syncType); 53 54 static void PushAndPullKeyRevokHandle(SingleVerSyncTaskContext *context); 55 56 static int GetReSendMode(int mode, uint32_t sequenceId, SyncType syncType); 57 58 static void FillControlRequestPacket(ControlRequestPacket *packet, SingleVerSyncTaskContext *context); 59 60 static ControlCmdType GetControlCmdType(int mode); 61 62 static int GetModeByControlCmdType(ControlCmdType controlCmd); 63 64 static bool IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query); 65 66 static void ControlAckErrorHandle(const SingleVerSyncTaskContext *context, 67 const std::shared_ptr<SubscribeManager> &subManager); 68 69 static void SetMessageHeadInfo(Message &message, uint16_t inMsgType, 70 const std::string &inTarget, uint32_t inSequenceId, uint32_t inSessionId); 71 72 static bool IsGetDataSuccessfully(int errCode); 73 74 static Timestamp GetMaxSendDataTime(const std::vector<SendDataItem> &inData); 75 76 static SyncTimeRange GetFullSyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark localMark, 77 UpdateWaterMark &isUpdate); 78 79 static SyncTimeRange GetQuerySyncDataTimeRange(const std::vector<SendDataItem> &inData, WaterMark localMark, 80 WaterMark deleteLocalMark, UpdateWaterMark &isUpdate); 81 82 static SyncTimeRange ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataTimeRange, 83 UpdateWaterMark updateMark); 84 85 static SyncTimeRange GetRecvDataTimeRange(SyncType syncType, 86 const std::vector<SendDataItem> &data, UpdateWaterMark &isUpdate); 87 88 static SyncTimeRange GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, WaterMark deleteMark, 89 const std::vector<SendDataItem> &inData, UpdateWaterMark &isUpdate); 90 }; 91 } 92 #endif // SINGLE_VER_DATA_SYNC_UTIL_H