1 /*
2 * Copyright (c) 2021-2024 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 "distributed_input_sourcetrans_test.h"
17
18 #include <cstdlib>
19
20 #include "dinput_errcode.h"
21 #include "dinput_softbus_define.h"
22 #include "distributed_input_source_manager.h"
23 #include "distributed_input_transport_base.h"
24
25 using namespace testing::ext;
26 using namespace OHOS::DistributedHardware::DistributedInput;
27 using namespace std;
28 namespace OHOS {
29 namespace DistributedHardware {
30 namespace DistributedInput {
SetUp()31 void DistributedInputSourceTransTest::SetUp()
32 {
33 }
34
TearDown()35 void DistributedInputSourceTransTest::TearDown()
36 {
37 }
38
SetUpTestCase()39 void DistributedInputSourceTransTest::SetUpTestCase()
40 {
41 }
42
TearDownTestCase()43 void DistributedInputSourceTransTest::TearDownTestCase()
44 {
45 }
46
47 HWTEST_F(DistributedInputSourceTransTest, Init01, testing::ext::TestSize.Level0)
48 {
49 int32_t ret = DistributedInputSourceTransport::GetInstance().Init();
50 EXPECT_EQ(DH_SUCCESS, ret);
51 }
52
53 HWTEST_F(DistributedInputSourceTransTest, OpenInputSoftbus01, testing::ext::TestSize.Level0)
54 {
55 std::string remoteDevId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
56 int32_t ret = DistributedInputSourceTransport::GetInstance().OpenInputSoftbus(remoteDevId, false);
57 EXPECT_EQ(DH_SUCCESS, ret);
58 DistributedInputSourceTransport::GetInstance().Release();
59 }
60
61 HWTEST_F(DistributedInputSourceTransTest, OpenInputSoftbus02, testing::ext::TestSize.Level0)
62 {
63 std::string remoteDevId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
64 int32_t ret = DistributedInputSourceTransport::GetInstance().OpenInputSoftbus(remoteDevId, true);
65 EXPECT_EQ(DH_SUCCESS, ret);
66 }
67
68 HWTEST_F(DistributedInputSourceTransTest, OpenInputSoftbus03, testing::ext::TestSize.Level0)
69 {
70 std::string remoteDevId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
71 DistributedInputSourceTransport::GetInstance().latencyThreadNum = 1;
72 DistributedInputSourceTransport::GetInstance().injectThreadNum = 1;
73 int32_t ret = DistributedInputSourceTransport::GetInstance().OpenInputSoftbus(remoteDevId, false);
74 EXPECT_EQ(DH_SUCCESS, ret);
75 }
76
77 HWTEST_F(DistributedInputSourceTransTest, PrepareRemoteInput_01, testing::ext::TestSize.Level0)
78 {
79 std::string deviceId = "";
80 int32_t ret = DistributedInputSourceTransport::GetInstance().PrepareRemoteInput(deviceId);
81 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_PREPARE_FAIL, ret);
82 }
83
84 HWTEST_F(DistributedInputSourceTransTest, PrepareRemoteInput_02, testing::ext::TestSize.Level1)
85 {
86 int32_t sessionId = 1;
87 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
88 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[deviceId] = sessionId;
89 int32_t ret = DistributedInputSourceTransport::GetInstance().PrepareRemoteInput(deviceId);
90 EXPECT_EQ(DH_SUCCESS, ret);
91 }
92
93 HWTEST_F(DistributedInputSourceTransTest, PrepareRemoteInput_03, testing::ext::TestSize.Level1)
94 {
95 std::string deviceId = "";
96 int32_t srcTsrcSeId = 1;
97 int32_t ret = DistributedInputSourceTransport::GetInstance().PrepareRemoteInput(srcTsrcSeId, deviceId);
98 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_PREPARE_FAIL, ret);
99 }
100
101 HWTEST_F(DistributedInputSourceTransTest, PrepareRemoteInput_04, testing::ext::TestSize.Level1)
102 {
103 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
104 int32_t srcTsrcSeId = 1;
105 int32_t ret = DistributedInputSourceTransport::GetInstance().PrepareRemoteInput(srcTsrcSeId, deviceId);
106 EXPECT_EQ(DH_SUCCESS, ret);
107 }
108
109 HWTEST_F(DistributedInputSourceTransTest, UnprepareRemoteInput_01, testing::ext::TestSize.Level0)
110 {
111 std::string deviceId = "";
112 int32_t ret = DistributedInputSourceTransport::GetInstance().UnprepareRemoteInput(deviceId);
113 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_UNPREPARE_FAIL, ret);
114 }
115
116 HWTEST_F(DistributedInputSourceTransTest, UnprepareRemoteInput_02, testing::ext::TestSize.Level0)
117 {
118 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
119 int32_t ret = DistributedInputSourceTransport::GetInstance().UnprepareRemoteInput(deviceId);
120 EXPECT_EQ(DH_SUCCESS, ret);
121 }
122
123 HWTEST_F(DistributedInputSourceTransTest, UnprepareRemoteInput_03, testing::ext::TestSize.Level1)
124 {
125 std::string deviceId = "";
126 int32_t srcTsrcSeId = 1;
127 int32_t ret = DistributedInputSourceTransport::GetInstance().UnprepareRemoteInput(srcTsrcSeId, deviceId);
128 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_UNPREPARE_FAIL, ret);
129 }
130
131 HWTEST_F(DistributedInputSourceTransTest, UnprepareRemoteInput_04, testing::ext::TestSize.Level1)
132 {
133 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
134 int32_t srcTsrcSeId = 1;
135 int32_t ret = DistributedInputSourceTransport::GetInstance().UnprepareRemoteInput(srcTsrcSeId, deviceId);
136 EXPECT_EQ(DH_SUCCESS, ret);
137 }
138
139 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInput01, testing::ext::TestSize.Level0)
140 {
141 std::string deviceId = "";
142 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInput(
143 deviceId, static_cast<uint32_t>(DInputDeviceType::ALL));
144 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_START_FAIL, ret);
145 }
146
147 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInput02, testing::ext::TestSize.Level0)
148 {
149 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
150 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInput(
151 deviceId, static_cast<uint32_t>(DInputDeviceType::ALL));
152 EXPECT_EQ(DH_SUCCESS, ret);
153 }
154
155 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInput03, testing::ext::TestSize.Level0)
156 {
157 std::string deviceId = "";
158 std::string dhid = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
159 std::vector<std::string> dhids;
160 dhids.push_back(dhid);
161 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInput(deviceId, dhids);
162 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_START_FAIL, ret);
163 }
164
165 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInput04, testing::ext::TestSize.Level0)
166 {
167 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
168 std::string dhid = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
169 std::vector<std::string> dhids;
170 dhids.push_back(dhid);
171 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInput(deviceId, dhids);
172 EXPECT_EQ(DH_SUCCESS, ret);
173 }
174
175 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInputDhids_01, testing::ext::TestSize.Level1)
176 {
177 int32_t srcTsrcSeId = 1;
178 const std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
179 const std::string dhids = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
180 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInputDhids(srcTsrcSeId, deviceId, dhids);
181 EXPECT_EQ(DH_SUCCESS, ret);
182 }
183
184 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInputDhids_02, testing::ext::TestSize.Level1)
185 {
186 int32_t srcTsrcSeId = 1;
187 const std::string deviceId = "";
188 const std::string dhids = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
189 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInputDhids(srcTsrcSeId, deviceId, dhids);
190 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_START_FAIL, ret);
191 }
192
193 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInputType_01, testing::ext::TestSize.Level1)
194 {
195 int32_t srcTsrcSeId = 1;
196 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
197 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInputType(srcTsrcSeId, deviceId,
198 static_cast<uint32_t>(DInputDeviceType::ALL));
199 EXPECT_EQ(DH_SUCCESS, ret);
200 }
201
202 HWTEST_F(DistributedInputSourceTransTest, StartRemoteInputType_02, testing::ext::TestSize.Level1)
203 {
204 int32_t srcTsrcSeId = 1;
205 std::string deviceId = "";
206 int32_t ret = DistributedInputSourceTransport::GetInstance().StartRemoteInputType(srcTsrcSeId, deviceId,
207 static_cast<uint32_t>(DInputDeviceType::ALL));
208 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_START_FAIL, ret);
209 }
210
211 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInput01, testing::ext::TestSize.Level0)
212 {
213 std::string deviceId = "";
214 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInput(
215 deviceId, static_cast<uint32_t>(DInputDeviceType::ALL));
216 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_STOP_FAIL, ret);
217 }
218
219 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInput02, testing::ext::TestSize.Level0)
220 {
221 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
222 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInput(
223 deviceId, static_cast<uint32_t>(DInputDeviceType::ALL));
224 EXPECT_EQ(DH_SUCCESS, ret);
225 }
226
227 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInput03, testing::ext::TestSize.Level0)
228 {
229 std::string deviceId = "";
230 std::vector<std::string> dhids;
231 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
232 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInput(deviceId, dhids);
233 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_STOP_FAIL, ret);
234 }
235
236 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInput04, testing::ext::TestSize.Level0)
237 {
238 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
239 std::vector<std::string> dhids;
240 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
241 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInput(deviceId, dhids);
242 EXPECT_EQ(DH_SUCCESS, ret);
243 }
244
245 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInputDhids_01, testing::ext::TestSize.Level1)
246 {
247 int32_t srcTsrcSeId = 1;
248 const std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
249 const std::string dhids = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
250 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInputDhids(srcTsrcSeId, deviceId, dhids);
251 EXPECT_EQ(DH_SUCCESS, ret);
252 }
253
254 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInputDhids_02, testing::ext::TestSize.Level1)
255 {
256 int32_t srcTsrcSeId = 1;
257 const std::string deviceId = "";
258 const std::string dhids = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
259 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInputDhids(srcTsrcSeId, deviceId, dhids);
260 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_STOP_FAIL, ret);
261 }
262
263 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInputType_01, testing::ext::TestSize.Level1)
264 {
265 int32_t srcTsrcSeId = 1;
266 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
267 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInputType(srcTsrcSeId, deviceId,
268 static_cast<uint32_t>(DInputDeviceType::ALL));
269 EXPECT_EQ(DH_SUCCESS, ret);
270 }
271
272 HWTEST_F(DistributedInputSourceTransTest, StopRemoteInputType_02, testing::ext::TestSize.Level1)
273 {
274 int32_t srcTsrcSeId = 1;
275 std::string deviceId = "";
276 int32_t ret = DistributedInputSourceTransport::GetInstance().StopRemoteInputType(srcTsrcSeId, deviceId,
277 static_cast<uint32_t>(DInputDeviceType::ALL));
278 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_STOP_FAIL, ret);
279 }
280
281 HWTEST_F(DistributedInputSourceTransTest, NotifyOriginPrepareResult01, testing::ext::TestSize.Level0)
282 {
283 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
284 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
285 int32_t sessionId = 2;
286 int32_t ret = DistributedInputSourceTransport::GetInstance().NotifyOriginPrepareResult(
287 sessionId, srcId, sinkId, DH_SUCCESS);
288 EXPECT_EQ(DH_SUCCESS, ret);
289 }
290
291 HWTEST_F(DistributedInputSourceTransTest, NotifyOriginUnprepareResult01, testing::ext::TestSize.Level0)
292 {
293 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
294 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
295 int32_t sessionId = 2;
296 int32_t ret = DistributedInputSourceTransport::GetInstance().NotifyOriginUnprepareResult(
297 sessionId, srcId, sinkId, DH_SUCCESS);
298 EXPECT_EQ(DH_SUCCESS, ret);
299 }
300
301 HWTEST_F(DistributedInputSourceTransTest, NotifyOriginStartDhidResult01, testing::ext::TestSize.Level0)
302 {
303 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
304 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
305 int32_t sessionId = 2;
306 std::string dhIds = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
307 int32_t ret = DistributedInputSourceTransport::GetInstance().NotifyOriginStartDhidResult(
308 sessionId, srcId, sinkId, DH_SUCCESS, dhIds);
309 EXPECT_EQ(DH_SUCCESS, ret);
310 }
311
312 HWTEST_F(DistributedInputSourceTransTest, NotifyOriginStopDhidResult01, testing::ext::TestSize.Level0)
313 {
314 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
315 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
316 int32_t sessionId = 2;
317 std::string dhIds = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
318 int32_t ret = DistributedInputSourceTransport::GetInstance().NotifyOriginStopDhidResult(
319 sessionId, srcId, sinkId, DH_SUCCESS, dhIds);
320 EXPECT_EQ(DH_SUCCESS, ret);
321 }
322
323 HWTEST_F(DistributedInputSourceTransTest, NotifyOriginStartTypeResult_01, testing::ext::TestSize.Level1)
324 {
325 int32_t srcTsrcSeId = 2;
326 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
327 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
328 int32_t ret = DistributedInputSourceTransport::GetInstance().NotifyOriginStartTypeResult(srcTsrcSeId, srcId,
329 sinkId, DH_SUCCESS, static_cast<uint32_t>(DInputDeviceType::ALL));
330 EXPECT_EQ(DH_SUCCESS, ret);
331 }
332
333 HWTEST_F(DistributedInputSourceTransTest, NotifyOriginStopTypeResult_01, testing::ext::TestSize.Level1)
334 {
335 int32_t srcTsrcSeId = 2;
336 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
337 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
338 int32_t ret = DistributedInputSourceTransport::GetInstance().NotifyOriginStopTypeResult(srcTsrcSeId, srcId,
339 sinkId, DH_SUCCESS, static_cast<uint32_t>(DInputDeviceType::ALL));
340 EXPECT_EQ(DH_SUCCESS, ret);
341 }
342
343 HWTEST_F(DistributedInputSourceTransTest, SendRelayPrepareRequest_01, testing::ext::TestSize.Level1)
344 {
345 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
346 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
347 DistributedInputSourceTransport::GetInstance().OpenInputSoftbus(srcId, true);
348 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayPrepareRequest(srcId, sinkId);
349 EXPECT_EQ(DH_SUCCESS, ret);
350 }
351
352 HWTEST_F(DistributedInputSourceTransTest, SendRelayPrepareRequest_02, testing::ext::TestSize.Level1)
353 {
354 std::string srcId = "";
355 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
356 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayPrepareRequest(srcId, sinkId);
357 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_PREPARE_FAIL, ret);
358 }
359
360 HWTEST_F(DistributedInputSourceTransTest, SendRelayUnprepareRequest_01, testing::ext::TestSize.Level1)
361 {
362 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
363 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
364 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayUnprepareRequest(srcId, sinkId);
365 EXPECT_EQ(DH_SUCCESS, ret);
366 }
367
368 HWTEST_F(DistributedInputSourceTransTest, SendRelayUnprepareRequest_02, testing::ext::TestSize.Level1)
369 {
370 std::string srcId = "";
371 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
372 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayUnprepareRequest(srcId, sinkId);
373 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_PREPARE_FAIL, ret);
374 }
375
376 HWTEST_F(DistributedInputSourceTransTest, SendRelayStartDhidRequest_01, testing::ext::TestSize.Level1)
377 {
378 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
379 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
380 std::vector<std::string> dhids;
381 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
382 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStartDhidRequest(srcId, sinkId, dhids);
383 EXPECT_EQ(DH_SUCCESS, ret);
384 }
385
386 HWTEST_F(DistributedInputSourceTransTest, SendRelayStartTypeRequest_01, testing::ext::TestSize.Level1)
387 {
388 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
389 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
390 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStartTypeRequest(srcId, sinkId,
391 static_cast<uint32_t>(DInputDeviceType::ALL));
392 EXPECT_EQ(DH_SUCCESS, ret);
393 }
394
395 HWTEST_F(DistributedInputSourceTransTest, SendRelayStopDhidRequest_01, testing::ext::TestSize.Level1)
396 {
397 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
398 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
399 std::vector<std::string> dhids;
400 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
401 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStopDhidRequest(srcId, sinkId, dhids);
402 EXPECT_EQ(DH_SUCCESS, ret);
403 }
404
405 HWTEST_F(DistributedInputSourceTransTest, SendRelayStopTypeRequest_01, testing::ext::TestSize.Level1)
406 {
407 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
408 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
409 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStopTypeRequest(srcId, sinkId,
410 static_cast<uint32_t>(DInputDeviceType::ALL));
411 EXPECT_EQ(DH_SUCCESS, ret);
412 }
413
414 HWTEST_F(DistributedInputSourceTransTest, LatencyCount01, testing::ext::TestSize.Level0)
415 {
416 std::string deviceId = "deviceId";
417 int32_t ret = DistributedInputSourceTransport::GetInstance().LatencyCount(deviceId);
418 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_LATENCY_FAIL, ret);
419 }
420
421 HWTEST_F(DistributedInputSourceTransTest, LatencyCount02, testing::ext::TestSize.Level0)
422 {
423 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
424 int32_t sessionId = 2;
425 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[deviceId] = sessionId;
426 int32_t ret = DistributedInputSourceTransport::GetInstance().LatencyCount(deviceId);
427 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
428 DistributedInputSourceTransport::GetInstance().StopLatencyThread();
429 EXPECT_EQ(DH_SUCCESS, ret);
430 }
431
432 HWTEST_F(DistributedInputSourceTransTest, SendRelayStartDhidRequest_02, testing::ext::TestSize.Level1)
433 {
434 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
435 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
436 std::vector<std::string> dhids;
437 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
438 int32_t sessionId = -1;
439 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[srcId] = sessionId;
440 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStartDhidRequest(srcId, sinkId, dhids);
441 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
442 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_START_FAIL, ret);
443 }
444
445 HWTEST_F(DistributedInputSourceTransTest, SendRelayStopDhidRequest_02, testing::ext::TestSize.Level1)
446 {
447 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
448 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
449 std::vector<std::string> dhids;
450 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
451 int32_t sessionId = -1;
452 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[srcId] = sessionId;
453 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStopDhidRequest(srcId, sinkId, dhids);
454 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
455 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_STOP_FAIL, ret);
456 }
457
458 HWTEST_F(DistributedInputSourceTransTest, SendRelayStartTypeRequest_02, testing::ext::TestSize.Level1)
459 {
460 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
461 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
462 std::vector<std::string> dhids;
463 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
464 int32_t sessionId = -1;
465 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[srcId] = sessionId;
466 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStartTypeRequest(srcId, sinkId,
467 static_cast<uint32_t>(DInputDeviceType::ALL));
468 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
469 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_START_FAIL, ret);
470 }
471
472 HWTEST_F(DistributedInputSourceTransTest, SendRelayStopTypeRequest_02, testing::ext::TestSize.Level1)
473 {
474 std::string srcId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
475 std::string sinkId = "networkidc08647073e02e7a78f09473aa122ff57fc81c00";
476 std::vector<std::string> dhids;
477 dhids.push_back("Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8");
478 int32_t sessionId = -1;
479 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[srcId] = sessionId;
480 int32_t ret = DistributedInputSourceTransport::GetInstance().SendRelayStopTypeRequest(srcId, sinkId,
481 static_cast<uint32_t>(DInputDeviceType::ALL));
482 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
483 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_STOP_FAIL, ret);
484 }
485
486 HWTEST_F(DistributedInputSourceTransTest, NotifyResponsePrepareRemoteInput01, testing::ext::TestSize.Level0)
487 {
488 int32_t sessionId = 0;
489 nlohmann::json recMsg;
490 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
491 recMsg[DINPUT_SOFTBUS_KEY_WHITE_LIST] = false;
492 DistributedInputSourceTransport::GetInstance().NotifyResponsePrepareRemoteInput(sessionId, recMsg);
493 std::string message(MSG_MAX_SIZE + 1, 'a');
494 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
495 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
496 }
497
498 HWTEST_F(DistributedInputSourceTransTest, NotifyResponsePrepareRemoteInput02, testing::ext::TestSize.Level0)
499 {
500 int32_t sessionId = 0;
501 nlohmann::json recMsg;
502 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
503 recMsg[DINPUT_SOFTBUS_KEY_WHITE_LIST] = "false";
504 DistributedInputSourceTransport::GetInstance().NotifyResponsePrepareRemoteInput(sessionId, recMsg);
505 std::string message(MSG_MAX_SIZE + 1, 'a');
506 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
507 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
508 }
509
510 HWTEST_F(DistributedInputSourceTransTest, NotifyResponsePrepareRemoteInput03, testing::ext::TestSize.Level0)
511 {
512 int32_t sessionId = 0;
513 nlohmann::json recMsg;
514 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
515 recMsg[DINPUT_SOFTBUS_KEY_WHITE_LIST] = "false";
516 std::string remoteId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
517 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[remoteId] = sessionId;
518 DistributedInputSourceManager srcMgr(4810, false);
519 std::shared_ptr<DInputSourceListener> srcListener =
520 std::make_shared<DInputSourceListener>(&srcMgr);
521 DistributedInputSourceTransport::GetInstance().callback_ = srcListener;
522 DistributedInputSourceTransport::GetInstance().NotifyResponsePrepareRemoteInput(sessionId, recMsg);
523 std::string message(MSG_MAX_SIZE + 1, 'a');
524 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
525 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
526 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
527 }
528
529 HWTEST_F(DistributedInputSourceTransTest, NotifyResponsePrepareRemoteInput04, testing::ext::TestSize.Level0)
530 {
531 int32_t sessionId = 0;
532 nlohmann::json recMsg;
533 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
534 recMsg[DINPUT_SOFTBUS_KEY_WHITE_LIST] = false;
535 DistributedInputSourceTransport::GetInstance().NotifyResponsePrepareRemoteInput(sessionId, recMsg);
536 std::string message(MSG_MAX_SIZE + 1, 'a');
537 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
538 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
539 }
540
541 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseUnprepareRemoteInput01, testing::ext::TestSize.Level0)
542 {
543 int32_t sessionId = 0;
544 nlohmann::json recMsg;
545 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
546 DistributedInputSourceTransport::GetInstance().NotifyResponseUnprepareRemoteInput(sessionId, recMsg);
547
548 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
549 DistributedInputSourceTransport::GetInstance().NotifyResponseUnprepareRemoteInput(sessionId, recMsg);
550 std::string message(MSG_MAX_SIZE + 1, 'a');
551 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
552 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
553 }
554
555 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseStartRemoteInput01, testing::ext::TestSize.Level0)
556 {
557 int32_t sessionId = 0;
558 nlohmann::json recMsg;
559 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
560 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = "input_type";
561 DistributedInputSourceTransport::GetInstance().NotifyResponseStartRemoteInput(sessionId, recMsg);
562
563 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
564 DistributedInputSourceTransport::GetInstance().NotifyResponseStartRemoteInput(sessionId, recMsg);
565
566 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = 1;
567 DistributedInputSourceTransport::GetInstance().NotifyResponseStartRemoteInput(sessionId, recMsg);
568 std::string remoteId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
569 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[remoteId] = sessionId;
570 DistributedInputSourceTransport::GetInstance().NotifyResponseStartRemoteInput(sessionId, recMsg);
571 std::string message(MSG_MAX_SIZE + 1, 'a');
572 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
573 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
574 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
575 }
576
577 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseStopRemoteInput01, testing::ext::TestSize.Level0)
578 {
579 int32_t sessionId = 0;
580 nlohmann::json recMsg;
581 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
582 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = "input_type";
583 DistributedInputSourceTransport::GetInstance().NotifyResponseStopRemoteInput(sessionId, recMsg);
584
585 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
586 DistributedInputSourceTransport::GetInstance().NotifyResponseStopRemoteInput(sessionId, recMsg);
587
588 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = 1;
589 DistributedInputSourceTransport::GetInstance().NotifyResponseStopRemoteInput(sessionId, recMsg);
590 std::string remoteId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
591 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[remoteId] = sessionId;
592 DistributedInputSourceTransport::GetInstance().NotifyResponseStopRemoteInput(sessionId, recMsg);
593 std::string message(MSG_MAX_SIZE + 1, 'a');
594 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
595 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
596 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
597 }
598
599 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseStartRemoteInputDhid01, testing::ext::TestSize.Level0)
600 {
601 int32_t sessionId = 0;
602 nlohmann::json recMsg;
603 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
604 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 1;
605 DistributedInputSourceTransport::GetInstance().NotifyResponseStartRemoteInputDhid(sessionId, recMsg);
606
607 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
608 DistributedInputSourceTransport::GetInstance().NotifyResponseStartRemoteInputDhid(sessionId, recMsg);
609
610 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
611 DistributedInputSourceTransport::GetInstance().NotifyResponseStartRemoteInputDhid(sessionId, recMsg);
612 std::string message(MSG_MAX_SIZE + 1, 'a');
613 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
614 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
615 }
616
617 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseStopRemoteInputDhid01, testing::ext::TestSize.Level0)
618 {
619 int32_t sessionId = 0;
620 nlohmann::json recMsg;
621 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
622 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 1;
623 DistributedInputSourceTransport::GetInstance().NotifyResponseStopRemoteInputDhid(sessionId, recMsg);
624
625 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
626 DistributedInputSourceTransport::GetInstance().NotifyResponseStopRemoteInputDhid(sessionId, recMsg);
627
628 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
629 DistributedInputSourceTransport::GetInstance().NotifyResponseStopRemoteInputDhid(sessionId, recMsg);
630 std::string message(MSG_MAX_SIZE + 1, 'a');
631 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
632 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
633 }
634
635 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseKeyState01, testing::ext::TestSize.Level0)
636 {
637 int32_t sessionId = 0;
638 nlohmann::json recMsg;
639 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_DHID] = 1;
640 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_TYPE] = "false";
641 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_CODE] = "false";
642 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_VALUE] = "false";
643 DistributedInputSourceTransport::GetInstance().NotifyResponseKeyState(sessionId, recMsg);
644
645 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_DHID] = "Input_1ds56v18e1v21v8v1erv15r1v8r1j1ty8";
646 DistributedInputSourceTransport::GetInstance().NotifyResponseKeyState(sessionId, recMsg);
647
648 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_TYPE] = 1;
649 DistributedInputSourceTransport::GetInstance().NotifyResponseKeyState(sessionId, recMsg);
650
651 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_CODE] = 1;
652
653 DistributedInputSourceTransport::GetInstance().NotifyResponseKeyState(sessionId, recMsg);
654
655 recMsg[DINPUT_SOFTBUS_KEY_KEYSTATE_VALUE] = 1;
656 DistributedInputSourceTransport::GetInstance().NotifyResponseKeyState(sessionId, recMsg);
657 std::string remoteId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
658 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[remoteId] = sessionId;
659 DistributedInputSourceTransport::GetInstance().NotifyResponseKeyState(sessionId, recMsg);
660 std::string message(MSG_MAX_SIZE + 1, 'a');
661 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
662 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
663 }
664
665 HWTEST_F(DistributedInputSourceTransTest, NotifyReceivedEventRemoteInput01, testing::ext::TestSize.Level1)
666 {
667 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
668 int32_t sessionId = 1;
669 nlohmann::json recMsg;
670 int32_t inputData = 100;
671 recMsg[DINPUT_SOFTBUS_KEY_INPUT_DATA] = inputData;
672 DistributedInputSourceTransport::GetInstance().NotifyReceivedEventRemoteInput(sessionId, recMsg);
673 std::string inputDatas = "inputDatas_test";
674 recMsg[DINPUT_SOFTBUS_KEY_INPUT_DATA] = inputDatas;
675 DistributedInputSourceTransport::GetInstance().NotifyReceivedEventRemoteInput(sessionId, recMsg);
676 DistributedInputSourceTransport::GetInstance().CalculateLatency(sessionId, recMsg);
677 std::string remoteId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
678 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[remoteId] = sessionId;
679 DistributedInputSourceTransport::GetInstance().NotifyReceivedEventRemoteInput(sessionId, recMsg);
680 DistributedInputSourceTransport::GetInstance().CalculateLatency(sessionId, recMsg);
681 std::string message(MSG_MAX_SIZE + 1, 'a');
682 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
683 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
684 }
685
686 HWTEST_F(DistributedInputSourceTransTest, ReceiveSrcTSrcRelayUnprepare01, testing::ext::TestSize.Level1)
687 {
688 int32_t sessionId = 1;
689 int32_t devId = 100;
690 nlohmann::json recMsg;
691 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = devId;
692 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayPrepare(sessionId, recMsg);
693 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayUnprepare(sessionId, recMsg);
694 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
695 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = deviceId;
696 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayUnprepare(sessionId, recMsg);
697 std::string message(MSG_MAX_SIZE + 1, 'a');
698 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
699 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
700 }
701
702 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseRelayPrepareRemoteInput01, testing::ext::TestSize.Level1)
703 {
704 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
705 int32_t sessionId = 1;
706 nlohmann::json recMsg;
707 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
708 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = "sessionId";
709 recMsg[DINPUT_SOFTBUS_KEY_WHITE_LIST] = 1;
710 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayPrepareRemoteInput(sessionId, recMsg);
711 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
712 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayPrepareRemoteInput(sessionId, recMsg);
713 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = sessionId;
714 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayPrepareRemoteInput(sessionId, recMsg);
715 recMsg[DINPUT_SOFTBUS_KEY_WHITE_LIST] = "white_list_test";
716 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayPrepareRemoteInput(sessionId, recMsg);
717 std::string message(MSG_MAX_SIZE + 1, 'a');
718 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
719 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
720 }
721
722 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseRelayUnprepareRemoteInput01, testing::ext::TestSize.Level1)
723 {
724 int32_t sessionId = 1;
725 std::string remoteId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
726 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[remoteId] = sessionId;
727 nlohmann::json recMsg;
728 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
729 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = "sessionId";
730 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayUnprepareRemoteInput(sessionId, recMsg);
731 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
732 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayUnprepareRemoteInput(sessionId, recMsg);
733 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = sessionId;
734 sessionId = 2;
735 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayUnprepareRemoteInput(sessionId, recMsg);
736 std::string message(MSG_MAX_SIZE + 1, 'a');
737 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
738 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
739 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
740 }
741
742 HWTEST_F(DistributedInputSourceTransTest, ReceiveRelayPrepareResult01, testing::ext::TestSize.Level1)
743 {
744 int32_t sessionId = 1;
745 nlohmann::json recMsg;
746 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] = 100;
747 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = 100;
748 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "resp_value_test";
749 DistributedInputSourceTransport::GetInstance().ReceiveRelayPrepareResult(sessionId, recMsg);
750 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] = "src_devid_test";
751 DistributedInputSourceTransport::GetInstance().ReceiveRelayPrepareResult(sessionId, recMsg);
752 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = "sink_devid_test";
753 DistributedInputSourceTransport::GetInstance().ReceiveRelayPrepareResult(sessionId, recMsg);
754 std::string message(MSG_MAX_SIZE + 1, 'a');
755 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
756 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
757 }
758
759 HWTEST_F(DistributedInputSourceTransTest, ReceiveRelayUnprepareResult01, testing::ext::TestSize.Level1)
760 {
761 int32_t sessionId = 1;
762 nlohmann::json recMsg;
763 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] = 100;
764 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = 100;
765 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "resp_value_test";
766 DistributedInputSourceTransport::GetInstance().ReceiveRelayUnprepareResult(sessionId, recMsg);
767 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] = "src_devid_test";
768 DistributedInputSourceTransport::GetInstance().ReceiveRelayUnprepareResult(sessionId, recMsg);
769 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = "sink_devid_test";
770 DistributedInputSourceTransport::GetInstance().ReceiveRelayUnprepareResult(sessionId, recMsg);
771 std::string message(MSG_MAX_SIZE + 1, 'a');
772 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
773 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
774 }
775
776 HWTEST_F(DistributedInputSourceTransTest, ReceiveSrcTSrcRelayStartDhid01, testing::ext::TestSize.Level1)
777 {
778 int32_t sessionId = 1;
779 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
780 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[deviceId] = sessionId;
781 nlohmann::json recMsg;
782 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = 100;
783 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 200;
784 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartDhid(sessionId, recMsg);
785 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = deviceId;
786 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartDhid(sessionId, recMsg);
787 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = "vector_dhId_test";
788 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartDhid(sessionId, recMsg);
789 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
790 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartDhid(sessionId, recMsg);
791 std::string message(MSG_MAX_SIZE + 1, 'a');
792 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
793 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
794 }
795
796 HWTEST_F(DistributedInputSourceTransTest, ReceiveSrcTSrcRelayStopDhid01, testing::ext::TestSize.Level1)
797 {
798 int32_t sessionId = 1;
799 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
800 nlohmann::json recMsg;
801 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = 100;
802 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 200;
803 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopDhid(sessionId, recMsg);
804 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = deviceId;
805 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopDhid(sessionId, recMsg);
806 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = "vector_dhId_test";
807 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopDhid(sessionId, recMsg);
808 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[deviceId] = sessionId;
809 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopDhid(sessionId, recMsg);
810 std::string message(MSG_MAX_SIZE + 1, 'a');
811 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
812 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
813 }
814
815 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseRelayStartDhidRemoteInput01, testing::ext::TestSize.Level1)
816 {
817 int32_t sessionId = 1;
818 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
819 nlohmann::json recMsg;
820 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
821 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = "1";
822 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 1;
823 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartDhidRemoteInput(sessionId, recMsg);
824 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
825 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartDhidRemoteInput(sessionId, recMsg);
826 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = sessionId;
827 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartDhidRemoteInput(sessionId, recMsg);
828 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = "vector_dhId_test";
829 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartDhidRemoteInput(sessionId, recMsg);
830 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
831 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartDhidRemoteInput(sessionId, recMsg);
832 std::string message(MSG_MAX_SIZE + 1, 'a');
833 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
834 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
835 }
836
837 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseRelayStopDhidRemoteInput01, testing::ext::TestSize.Level1)
838 {
839 int32_t sessionId = 1;
840 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
841 nlohmann::json recMsg;
842 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
843 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = "1";
844 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 1;
845 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopDhidRemoteInput(sessionId, recMsg);
846 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
847 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopDhidRemoteInput(sessionId, recMsg);
848 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = sessionId;
849 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopDhidRemoteInput(sessionId, recMsg);
850 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = "vector_dhId_test";
851 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopDhidRemoteInput(sessionId, recMsg);
852 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[deviceId] = sessionId;
853 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopDhidRemoteInput(sessionId, recMsg);
854 std::string message(MSG_MAX_SIZE + 1, 'a');
855 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
856 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
857 }
858
859 HWTEST_F(DistributedInputSourceTransTest, ReceiveRelayStartDhidResult01, testing::ext::TestSize.Level1)
860 {
861 int32_t sessionId = 1;
862 nlohmann::json recMsg;
863 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] = 100;
864 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = 200;
865 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "value";
866 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 300;
867 DistributedInputSourceTransport::GetInstance().ReceiveRelayStartDhidResult(sessionId, recMsg);
868 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] = "src_devId_test";
869 DistributedInputSourceTransport::GetInstance().ReceiveRelayStartDhidResult(sessionId, recMsg);
870 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = "sink_devId_test";
871 DistributedInputSourceTransport::GetInstance().ReceiveRelayStartDhidResult(sessionId, recMsg);
872 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = 1;
873 DistributedInputSourceTransport::GetInstance().ReceiveRelayStartDhidResult(sessionId, recMsg);
874 std::string message(MSG_MAX_SIZE + 1, 'a');
875 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
876 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
877 }
878
879 HWTEST_F(DistributedInputSourceTransTest, ReceiveRelayStopDhidResult01, testing::ext::TestSize.Level1)
880 {
881 int32_t sessionId = 1;
882 nlohmann::json recMsg;
883 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] = 100;
884 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = 200;
885 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "value";
886 recMsg[DINPUT_SOFTBUS_KEY_VECTOR_DHID] = 300;
887 DistributedInputSourceTransport::GetInstance().ReceiveRelayStopDhidResult(sessionId, recMsg);
888 recMsg[DINPUT_SOFTBUS_KEY_SRC_DEV_ID] ="src_devId_test";
889 DistributedInputSourceTransport::GetInstance().ReceiveRelayStopDhidResult(sessionId, recMsg);
890 recMsg[DINPUT_SOFTBUS_KEY_SINK_DEV_ID] = "sink_devId_test";
891 DistributedInputSourceTransport::GetInstance().ReceiveRelayStopDhidResult(sessionId, recMsg);
892 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = 1;
893 DistributedInputSourceTransport::GetInstance().ReceiveRelayStopDhidResult(sessionId, recMsg);
894 std::string message(MSG_MAX_SIZE + 1, 'a');
895 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
896 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
897 }
898
899 HWTEST_F(DistributedInputSourceTransTest, ReceiveSrcTSrcRelayStartType01, testing::ext::TestSize.Level1)
900 {
901 int32_t sessionId = 1;
902 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
903 nlohmann::json recMsg;
904 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = 1;
905 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = "input_type_test";
906 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartType(sessionId, recMsg);
907 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = deviceId;
908 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartType(sessionId, recMsg);
909 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = 1;
910 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartType(sessionId, recMsg);
911 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
912 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStartType(sessionId, recMsg);
913 std::string message(MSG_MAX_SIZE + 1, 'a');
914 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
915 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
916 }
917
918 HWTEST_F(DistributedInputSourceTransTest, ReceiveSrcTSrcRelayStopType01, testing::ext::TestSize.Level1)
919 {
920 int32_t sessionId = 1;
921 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
922 nlohmann::json recMsg;
923 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = 1;
924 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = "input_type_test";
925 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopType(sessionId, recMsg);
926 recMsg[DINPUT_SOFTBUS_KEY_DEVICE_ID] = deviceId;
927 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopType(sessionId, recMsg);
928 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = 1;
929 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopType(sessionId, recMsg);
930 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[deviceId] = sessionId;
931 DistributedInputSourceTransport::GetInstance().ReceiveSrcTSrcRelayStopType(sessionId, recMsg);
932 std::string message(MSG_MAX_SIZE + 1, 'a');
933 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
934 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
935 }
936
937 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseRelayStartTypeRemoteInput01, testing::ext::TestSize.Level1)
938 {
939 int32_t sessionId = 1;
940 nlohmann::json recMsg;
941 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
942 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = "1";
943 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = "input_type_test";
944 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartTypeRemoteInput(sessionId, recMsg);
945 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
946 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartTypeRemoteInput(sessionId, recMsg);
947 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = sessionId;
948 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartTypeRemoteInput(sessionId, recMsg);
949 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = 1;
950 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartTypeRemoteInput(sessionId, recMsg);
951 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_.clear();
952 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStartTypeRemoteInput(sessionId, recMsg);
953 std::string message(MSG_MAX_SIZE + 1, 'a');
954 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
955 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
956 }
957
958 HWTEST_F(DistributedInputSourceTransTest, NotifyResponseRelayStopTypeRemoteInput01, testing::ext::TestSize.Level1)
959 {
960 int32_t sessionId = 1;
961 std::string deviceId = "f6d4c08647073e02e7a78f09473aa122ff57fc81c00981fcf5be989e7d112591";
962 nlohmann::json recMsg;
963 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = "false";
964 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = "1";
965 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = "input_type_test";
966 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopTypeRemoteInput(sessionId, recMsg);
967 recMsg[DINPUT_SOFTBUS_KEY_RESP_VALUE] = false;
968 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopTypeRemoteInput(sessionId, recMsg);
969 recMsg[DINPUT_SOFTBUS_KEY_SESSION_ID] = sessionId;
970 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopTypeRemoteInput(sessionId, recMsg);
971 recMsg[DINPUT_SOFTBUS_KEY_INPUT_TYPE] = 1;
972 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopTypeRemoteInput(sessionId, recMsg);
973 DistributedInputTransportBase::GetInstance().remoteDevSessionMap_[deviceId] = sessionId;
974 DistributedInputSourceTransport::GetInstance().NotifyResponseRelayStopTypeRemoteInput(sessionId, recMsg);
975 std::string message(MSG_MAX_SIZE + 1, 'a');
976 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
977 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
978 }
979
980 HWTEST_F(DistributedInputSourceTransTest, HandleData01, testing::ext::TestSize.Level1)
981 {
982 int32_t sessionId = 1;
983 nlohmann::json recMsg;
984 recMsg[DINPUT_SOFTBUS_KEY_CMD_TYPE] = TRANS_SOURCE_MSG_PREPARE;
985 DistributedInputSourceTransport::GetInstance().HandleData(sessionId, recMsg.dump());
986 recMsg[DINPUT_SOFTBUS_KEY_CMD_TYPE] = TRANS_SINK_MSG_ONPREPARE;
987 DistributedInputSourceTransport::GetInstance().HandleData(sessionId, recMsg.dump());
988 DistributedInputSourceTransport::GetInstance().callback_ = nullptr;
989 DistributedInputSourceTransport::GetInstance().HandleData(sessionId, recMsg.dump());
990 std::string message(MSG_MAX_SIZE + 1, 'a');
991 int32_t ret = DistributedInputSourceTransport::GetInstance().SendMessage(sessionId, message);
992 EXPECT_EQ(ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE, ret);
993 }
994 } // namespace DistributedInput
995 } // namespace DistributedHardware
996 } // namespace OHOS
997