1 /*
2 * Copyright (C) 2021-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
16 #include "group_manager.h"
17
18 #include "common_defs.h"
19 #include "data_manager.h"
20 #include "group_operation.h"
21
CreateGroupImpl(int32_t osAccountId,int64_t requestId,const char * appId,const char * createParams)22 int32_t CreateGroupImpl(int32_t osAccountId, int64_t requestId, const char *appId, const char *createParams)
23 {
24 return IsGroupSupport() ? GetGroupImplInstance()->createGroup(osAccountId, requestId, appId, createParams)
25 : HC_ERR_NOT_SUPPORT;
26 }
27
DeleteGroupImpl(int32_t osAccountId,int64_t requestId,const char * appId,const char * disbandParams)28 int32_t DeleteGroupImpl(int32_t osAccountId, int64_t requestId, const char *appId, const char *disbandParams)
29 {
30 return IsGroupSupport() ? GetGroupImplInstance()->deleteGroup(osAccountId, requestId, appId, disbandParams)
31 : HC_ERR_NOT_SUPPORT;
32 }
33
AddMemberToGroupImpl(int32_t osAccountId,int64_t requestId,const char * appId,const char * addParams)34 int32_t AddMemberToGroupImpl(int32_t osAccountId, int64_t requestId, const char *appId, const char *addParams)
35 {
36 return IsGroupSupport() ? GetGroupImplInstance()->addMember(osAccountId, requestId, appId, addParams)
37 : HC_ERR_NOT_SUPPORT;
38 }
39
DeleteMemberFromGroupImpl(int32_t osAccountId,int64_t requestId,const char * appId,const char * deleteParams)40 int32_t DeleteMemberFromGroupImpl(int32_t osAccountId, int64_t requestId, const char *appId, const char *deleteParams)
41 {
42 return IsGroupSupport() ? GetGroupImplInstance()->deleteMember(osAccountId, requestId, appId, deleteParams)
43 : HC_ERR_NOT_SUPPORT;
44 }
45
AddMultiMembersToGroupImpl(int32_t osAccountId,const char * appId,const char * addParams)46 int32_t AddMultiMembersToGroupImpl(int32_t osAccountId, const char *appId, const char *addParams)
47 {
48 return IsGroupSupport() ? GetGroupImplInstance()->addMultiMembers(osAccountId, appId, addParams)
49 : HC_ERR_NOT_SUPPORT;
50 }
51
DelMultiMembersFromGroupImpl(int32_t osAccountId,const char * appId,const char * deleteParams)52 int32_t DelMultiMembersFromGroupImpl(int32_t osAccountId, const char *appId, const char *deleteParams)
53 {
54 return IsGroupSupport() ? GetGroupImplInstance()->delMultiMembers(osAccountId, appId, deleteParams)
55 : HC_ERR_NOT_SUPPORT;
56 }
57
ProcessBindDataImpl(int64_t requestId,const uint8_t * data,uint32_t dataLen)58 int32_t ProcessBindDataImpl(int64_t requestId, const uint8_t *data, uint32_t dataLen)
59 {
60 return IsGroupSupport() ? GetGroupImplInstance()->processBindData(requestId, data, dataLen) : HC_ERR_NOT_SUPPORT;
61 }
62
RegListenerImpl(const char * appId,const DataChangeListener * listener)63 int32_t RegListenerImpl(const char *appId, const DataChangeListener *listener)
64 {
65 return IsGroupSupport() ? GetGroupImplInstance()->regListener(appId, listener) : HC_ERR_NOT_SUPPORT;
66 }
67
UnRegListenerImpl(const char * appId)68 int32_t UnRegListenerImpl(const char *appId)
69 {
70 return IsGroupSupport() ? GetGroupImplInstance()->unRegListener(appId) : HC_ERR_NOT_SUPPORT;
71 }
72
CheckAccessToGroupImpl(int32_t osAccountId,const char * appId,const char * groupId)73 int32_t CheckAccessToGroupImpl(int32_t osAccountId, const char *appId, const char *groupId)
74 {
75 return IsGroupSupport() ? GetGroupImplInstance()->checkAccessToGroup(osAccountId, appId, groupId)
76 : HC_ERR_NOT_SUPPORT;
77 }
78
GetGroupInfoByIdImpl(int32_t osAccountId,const char * appId,const char * groupId,char ** returnGroupInfo)79 int32_t GetGroupInfoByIdImpl(int32_t osAccountId, const char *appId, const char *groupId, char **returnGroupInfo)
80 {
81 return IsGroupSupport() ? GetGroupImplInstance()->getAccessibleGroupInfoById(osAccountId, appId, groupId,
82 returnGroupInfo) : HC_ERR_NOT_SUPPORT;
83 }
84
GetGroupInfoImpl(int32_t osAccountId,const char * appId,const char * queryParams,char ** returnGroupVec,uint32_t * groupNum)85 int32_t GetGroupInfoImpl(int32_t osAccountId, const char *appId, const char *queryParams,
86 char **returnGroupVec, uint32_t *groupNum)
87 {
88 return IsGroupSupport() ? GetGroupImplInstance()->getAccessibleGroupInfo(osAccountId, appId, queryParams,
89 returnGroupVec, groupNum) : HC_ERR_NOT_SUPPORT;
90 }
91
GetJoinedGroupsImpl(int32_t osAccountId,const char * appId,int groupType,char ** returnGroupVec,uint32_t * groupNum)92 int32_t GetJoinedGroupsImpl(int32_t osAccountId, const char *appId, int groupType,
93 char **returnGroupVec, uint32_t *groupNum)
94 {
95 return IsGroupSupport() ? GetGroupImplInstance()->getAccessibleJoinedGroups(osAccountId, appId, groupType,
96 returnGroupVec, groupNum) : HC_ERR_NOT_SUPPORT;
97 }
98
GetRelatedGroupsImpl(int32_t osAccountId,const char * appId,const char * peerDeviceId,char ** returnGroupVec,uint32_t * groupNum)99 int32_t GetRelatedGroupsImpl(int32_t osAccountId, const char *appId, const char *peerDeviceId,
100 char **returnGroupVec, uint32_t *groupNum)
101 {
102 return IsGroupSupport() ? GetGroupImplInstance()->getAccessibleRelatedGroups(osAccountId, appId, peerDeviceId,
103 false, returnGroupVec, groupNum) : HC_ERR_NOT_SUPPORT;
104 }
105
GetDeviceInfoByIdImpl(int32_t osAccountId,const char * appId,const char * deviceId,const char * groupId,char ** returnDeviceInfo)106 int32_t GetDeviceInfoByIdImpl(int32_t osAccountId, const char *appId, const char *deviceId, const char *groupId,
107 char **returnDeviceInfo)
108 {
109 return IsGroupSupport() ? GetGroupImplInstance()->getAccessibleDeviceInfoById(osAccountId, appId, deviceId,
110 false, groupId, returnDeviceInfo) : HC_ERR_NOT_SUPPORT;
111 }
112
GetTrustedDevicesImpl(int32_t osAccountId,const char * appId,const char * groupId,char ** returnDevInfoVec,uint32_t * deviceNum)113 int32_t GetTrustedDevicesImpl(int32_t osAccountId, const char *appId, const char *groupId,
114 char **returnDevInfoVec, uint32_t *deviceNum)
115 {
116 return IsGroupSupport() ? GetGroupImplInstance()->getAccessibleTrustedDevices(osAccountId, appId, groupId,
117 returnDevInfoVec, deviceNum) : HC_ERR_NOT_SUPPORT;
118 }
119
IsDeviceInGroupImpl(int32_t osAccountId,const char * appId,const char * groupId,const char * deviceId)120 bool IsDeviceInGroupImpl(int32_t osAccountId, const char *appId, const char *groupId, const char *deviceId)
121 {
122 return IsGroupSupport() ? GetGroupImplInstance()->isDeviceInAccessibleGroup(osAccountId, appId, groupId,
123 deviceId, false) : false;
124 }
125
GetPkInfoListImpl(int32_t osAccountId,const char * appId,const char * queryParams,char ** returnInfoList,uint32_t * returnInfoNum)126 int32_t GetPkInfoListImpl(int32_t osAccountId, const char *appId, const char *queryParams,
127 char **returnInfoList, uint32_t *returnInfoNum)
128 {
129 return IsGroupSupport() ? GetGroupImplInstance()->getPkInfoList(osAccountId, appId, queryParams,
130 returnInfoList, returnInfoNum) : HC_ERR_NOT_SUPPORT;
131 }
132
CancelRequestImpl(int64_t requestId,const char * appId)133 void CancelRequestImpl(int64_t requestId, const char *appId)
134 {
135 if (IsGroupSupport()) {
136 GetGroupImplInstance()->cancelGroupRequest(requestId, appId);
137 }
138 }
139
DestroyInfoImpl(char ** returnInfo)140 void DestroyInfoImpl(char **returnInfo)
141 {
142 if (IsGroupSupport()) {
143 GetGroupImplInstance()->destroyInfo(returnInfo);
144 }
145 }
146
InitGroupManager(void)147 int32_t InitGroupManager(void)
148 {
149 if (InitDatabase() != HC_SUCCESS) {
150 return HC_ERR_SERVICE_NEED_RESTART;
151 }
152 return IsGroupSupport() ? InitGroupRelatedModule() : HC_SUCCESS;
153 }
154
DestroyGroupManager(void)155 void DestroyGroupManager(void)
156 {
157 if (IsGroupSupport()) {
158 DestroyGroupRelatedModule();
159 }
160 DestroyDatabase();
161 }