[Testing]Add e2e test for multi connect

Add multi_connection_test to ensure that the code logic can still connect normally in the case of multiple connections.

Author: RovicnowYoyi

test/connect_test/check_android_connection_ci.py

@@ -79,11 +79,21 @@ def TestAndroidCon(args):
   if (args.conection_type == "websocket"):
     print('start: websocket common test.')
     command_run = "../../../buildtools/node/bin/npm install && ../../../buildtools/node/bin/node websocket.js"
+    CheckExecute(command_run)
+    print('start: websocket multi connection test')
+    command_run = "../../../buildtools/node/bin/npm install && ../../../buildtools/node/bin/node multi_connection_test.js"
+    CheckExecute(command_run)
   else:
     if(args.conection_type == "usb"):
-      print('start: usb common test and large message test.')
-      command_run = "../../../buildtools/node/bin/npm install && ../../../buildtools/node/bin/node usb.js && ../../../buildtools/node/bin/node large_message_test.js"
-  CheckExecute(command_run)
+      print('start: usb common test.')
+      command_run = "../../../buildtools/node/bin/npm install && ../../../buildtools/node/bin/node usb.js"
+      CheckExecute(command_run)
+      print('start: usb large message test')
+      command_run = "../../../buildtools/node/bin/npm install && ../../../buildtools/node/bin/node large_message_test.js"
+      CheckExecute(command_run)
+      print('start: usb multi connection test')
+      command_run = "../../../buildtools/node/bin/npm install && ../../../buildtools/node/bin/node multi_connection_test.js"
+      CheckExecute(command_run)
 
 def CheckBuildDebugRouterTestApk(args):
   command = './gradlew clean'

test/e2e_test/connector_test/multi_connection_test.js

@@ -0,0 +1,79 @@
+const DebugRouterConnector = require("@lynx-js/debug-router-connector").DebugRouterConnector;
+
+const util = require('./util.js');
+
+function sleep(ms) {
+    return new Promise(resolve => setTimeout(resolve, ms));
+}
+
+
+async function TryConnect(driver, serial, num) {
+  console.log('TryConnect start: ', num);
+  await sleep(3000);
+  const clients = await driver.connectUsbClients(serial, 5000);
+  if (clients && clients.length > 0) {
+    console.log(clients[0].info.query.raw_info);
+    if (num < 10) {
+      return;
+    }
+    sleep(3000);
+    console.log('TryConnect check the last connect start: ', num);
+    const message = 'a'.repeat(20);
+    const result = await clients[0].sendCustomizedMessage("App.GetCloseCoverageUploadSwitch", { message: message }, -1, "App");
+    console.log(result);
+    if (!result) {
+      console.error('sendCustomizedMessage failed');
+      process.exit(-1);
+    } else {
+      console.log('sendCustomizedMessage success');
+    }
+  } else {
+    console.error('no clients connected');
+  }
+  console.log('TryConnect end:  ', num);
+}
+
+async function main() {
+  const startActivity = 'adb shell am start -n com.lynx.debugrouter.testapp/com.lynx.debugrouter.testapp.MainActivity'
+  util.exec(startActivity, 10000).then((data) => {
+    console.log("startActivity:" + data);
+  }).catch((reason) => {
+    console.log("startActivity FAILED:" + reason);
+    process.exit(-1);
+  });
+
+  const driver = new DebugRouterConnector({
+    manualConnect: true,
+    enableWebSocket: false,
+    enableAndroid: true,
+    enableIOS: true,
+    enableDesktop: false,
+    websocketOption: {}
+  });
+
+  try {
+    const devicesArray = await driver.connectDevices(5000);
+    if (devicesArray.length === 0) {
+      console.error('no devices connected');
+      return;
+    }
+    var serial = devicesArray[0].serial;
+    const Connect0 = TryConnect(driver, serial, 1);
+    const Connect1 = TryConnect(driver, serial, 2);
+    const Connect2 = TryConnect(driver, serial, 3);
+    const Connect3 = TryConnect(driver, serial, 4);
+    const Connect4 = TryConnect(driver, serial, 5);
+    const Connect5 = TryConnect(driver, serial, 6);
+    const Connect6 = TryConnect(driver, serial, 7);
+    const Connect7 = TryConnect(driver, serial, 8);
+    const Connect8 = TryConnect(driver, serial, 9);
+    const Connect9 = TryConnect(driver, serial, 10);
+    await Promise.all([Connect0, Connect1, Connect2, Connect3, Connect4, Connect5, Connect6, Connect7, Connect8, Connect9]);
+    console.log('TryConnect test end.');
+  } catch (error) {
+    console.error('Call tryConnect error: ', error);
+  }
+  process.exit(0);
+}
+
+main();