1 /* 2 * Copyright (c) 2021 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 16 #ifndef OHOS_HICHAIN_CONNECTOR_H 17 #define OHOS_HICHAIN_CONNECTOR_H 18 19 #include <string> 20 #include <memory> 21 #include <cstdint> 22 23 #include "nlohmann/json.hpp" 24 25 #include "device_auth.h" 26 27 #include "single_instance.h" 28 #include "msg_response_auth.h" 29 30 namespace OHOS { 31 namespace DistributedHardware { 32 enum { 33 HICHAIN_SUCCESS = 0, 34 GROUP_CREATE_FAILED = 1, 35 MEMBER_ADD_FAILED = 2, 36 CREATE_CHANNEL_FAILED = 3, 37 }; 38 39 struct GroupInfo { 40 std::string groupName; 41 std::string groupId; 42 std::string groupOwner; 43 int32_t groupType; 44 int32_t groupVisibility; 45 GroupInfoGroupInfo46 GroupInfo() : groupName(""), groupId(""), groupOwner(""), groupType(0), groupVisibility(0) {} 47 }; 48 49 void from_json(const nlohmann::json& jsonObject, GroupInfo& groupInfo); 50 51 class HichainConnectorCallback { 52 public: 53 virtual void OnGroupCreated(int64_t requestId, const std::string &groupId) = 0; 54 virtual void OnMemberJoin(int64_t requestId, int32_t status) = 0; 55 }; 56 57 class HichainAuthenCallBack { 58 public: 59 static bool onTransmit(int64_t requestId, const uint8_t *data, uint32_t dataLen); 60 static void onSessionKeyReturned(int64_t requestId, const uint8_t *sessionKey, uint32_t sessionKeyLen); 61 static void onFinish(int64_t requestId, int32_t operationCode, const char *returnData); 62 static void onError(int64_t requestId, int32_t operationCode, int32_t errorCode, const char *errorReturn); 63 static char *onRequest(int64_t requestId, int32_t operationCode, const char *reqParams); 64 }; 65 66 class HichainConnector { 67 DECLARE_SINGLE_INSTANCE(HichainConnector); 68 public: 69 int32_t Init(); 70 bool OnTransmit(int64_t requestId, const uint8_t *data, uint32_t dataLen); 71 int64_t GenRequestId(); 72 void RegisterConnectorCallback(std::shared_ptr<HichainConnectorCallback> callback); 73 int32_t CreateGroup(int64_t requestId, const std::string &groupName); 74 int32_t AddMemeber(std::string deviceId, std::shared_ptr<MsgResponseAuth> msgResponseAuth); 75 void GetRelatedGroups(std::string DeviceId, std::vector<GroupInfo> &groupList); 76 void SyncGroups(std::string deviceId, std::vector<std::string> &remoteGroupIdList); 77 int32_t DelMemberFromGroup(std::string groupId, std::string deviceId); 78 void DeleteGroup(std::string &groupId); 79 void OnGroupCreated(int64_t requestId, const std::string &returnData); 80 void GetSyncGroupList(std::vector<GroupInfo> &groupList, std::vector<std::string> &syncGroupList); 81 void OnMemberJoin(int64_t requestId, int32_t status); 82 private: 83 std::string GetConnectPara(std::string deviceId, std::shared_ptr<MsgResponseAuth> msgResponseAuth); 84 bool IsGroupInfoInvalid(GroupInfo &group); 85 bool IsGroupCreated(std::string groupName, GroupInfo &groupInfo); 86 bool GetGroupInfo(const std::string &queryParams, std::vector<GroupInfo> &groupList); 87 88 private: 89 std::atomic<int32_t> requestIdIndex_ {0}; 90 std::shared_ptr<HichainConnectorCallback> hichainConnectorCallback_ = nullptr; 91 const DeviceGroupManager *deviceGroupManager_ = nullptr; 92 DeviceAuthCallback deviceAuthCallback_ = { 93 .onTransmit = nullptr, 94 .onFinish = HichainAuthenCallBack::onFinish, 95 .onError = HichainAuthenCallBack::onError, 96 .onRequest = HichainAuthenCallBack::onRequest, 97 }; 98 }; 99 } // namespace DistributedHardware 100 } // namespace OHOS 101 #endif // OHOS_HICHAIN_ADAPTER_H 102