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 #include "client_disc_manager.h"
17
18 #include "disc_server_proxy.h"
19 #include "softbus_adapter_mem.h"
20 #include "softbus_errcode.h"
21 #include "softbus_log.h"
22
23 typedef struct {
24 IPublishCallback publishCb;
25 IDiscoveryCallback subscribeCb;
26 } DiscInfo;
27
28 static DiscInfo *g_discInfo = NULL;
29
PublishServiceInner(const char * packageName,const PublishInfo * info,const IPublishCallback * cb)30 int32_t PublishServiceInner(const char *packageName, const PublishInfo *info, const IPublishCallback *cb)
31 {
32 g_discInfo->publishCb = *cb;
33
34 int32_t ret = ServerIpcPublishService(packageName, info);
35 if (ret != SOFTBUS_OK) {
36 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_ERROR, "Server PublishService failed, ret = %d", ret);
37 return ret;
38 }
39
40 return SOFTBUS_OK;
41 }
42
UnPublishServiceInner(const char * packageName,int32_t publishId)43 int32_t UnPublishServiceInner(const char *packageName, int32_t publishId)
44 {
45 int32_t ret = ServerIpcUnPublishService(packageName, publishId);
46 if (ret != SOFTBUS_OK) {
47 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_ERROR, "Server UnPublishService failed, ret = %d", ret);
48 return ret;
49 }
50
51 return SOFTBUS_OK;
52 }
53
StartDiscoveryInner(const char * packageName,const SubscribeInfo * info,const IDiscoveryCallback * cb)54 int32_t StartDiscoveryInner(const char *packageName, const SubscribeInfo *info, const IDiscoveryCallback *cb)
55 {
56 g_discInfo->subscribeCb = *cb;
57 int32_t ret = ServerIpcStartDiscovery(packageName, info);
58 if (ret != SOFTBUS_OK) {
59 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_ERROR, "Server StartDiscovery failed, ret = %d", ret);
60 return ret;
61 }
62
63 return SOFTBUS_OK;
64 }
65
StopDiscoveryInner(const char * packageName,int32_t subscribeId)66 int32_t StopDiscoveryInner(const char *packageName, int32_t subscribeId)
67 {
68 int32_t ret = ServerIpcStopDiscovery(packageName, subscribeId);
69 if (ret != SOFTBUS_OK) {
70 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_ERROR, "Server StopDiscovery failed, ret = %d", ret);
71 return ret;
72 }
73
74 return SOFTBUS_OK;
75 }
76
DiscClientInit(void)77 int32_t DiscClientInit(void)
78 {
79 if (g_discInfo != NULL) {
80 SoftBusFree(g_discInfo);
81 }
82 g_discInfo = (DiscInfo *)SoftBusCalloc(sizeof(DiscInfo));
83 if (g_discInfo == NULL) {
84 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_ERROR, "Calloc failed");
85 return SOFTBUS_MALLOC_ERR;
86 }
87 if (DiscServerProxyInit() != SOFTBUS_OK) {
88 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_ERROR, "disc server proxy init failed.");
89 return SOFTBUS_ERR;
90 }
91 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_INFO, "Init success as client side");
92 return SOFTBUS_OK;
93 }
94
DiscClientDeinit(void)95 void DiscClientDeinit(void)
96 {
97 if (g_discInfo == NULL) {
98 return;
99 }
100 SoftBusFree(g_discInfo);
101 g_discInfo = NULL;
102 DiscServerProxyDeInit();
103 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_INFO, "DeInit success");
104 }
105
DiscClientOnDeviceFound(const DeviceInfo * device)106 void DiscClientOnDeviceFound(const DeviceInfo *device)
107 {
108 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_INFO, "Sdk OnDeviceFound, capabilityBitmap = %d",
109 device->capabilityBitmap[0]);
110 g_discInfo->subscribeCb.OnDeviceFound(device);
111 }
112
DiscClientOnDiscoverySuccess(int32_t subscribeId)113 void DiscClientOnDiscoverySuccess(int32_t subscribeId)
114 {
115 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_INFO, "Sdk OnDiscoverySuccess, subscribeId = %d", subscribeId);
116 g_discInfo->subscribeCb.OnDiscoverySuccess(subscribeId);
117 }
118
DiscClientOnDiscoverFailed(int32_t subscribeId,DiscoveryFailReason failReason)119 void DiscClientOnDiscoverFailed(int32_t subscribeId, DiscoveryFailReason failReason)
120 {
121 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_INFO, "Sdk OnDiscoverFailed, subscribeId = %d", subscribeId);
122 g_discInfo->subscribeCb.OnDiscoverFailed(subscribeId, failReason);
123 }
124
DiscClientOnPublishSuccess(int32_t publishId)125 void DiscClientOnPublishSuccess(int32_t publishId)
126 {
127 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_INFO, "Sdk OnPublishSuccess, publishId = %d", publishId);
128 g_discInfo->publishCb.OnPublishSuccess(publishId);
129 }
130
DiscClientOnPublishFail(int32_t publishId,PublishFailReason reason)131 void DiscClientOnPublishFail(int32_t publishId, PublishFailReason reason)
132 {
133 SoftBusLog(SOFTBUS_LOG_DISC, SOFTBUS_LOG_INFO, "Sdk OnPublishFail, publishId = %d", publishId);
134 g_discInfo->publishCb.OnPublishFail(publishId, reason);
135 }
136