1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

try {
    client = server.accept();
    Logger.debug("Client connected");
    in = new BufferedReader(new InputStreamReader(client.getInputStream(), "UTF-8"));
    out = new BufferedWriter(new OutputStreamWriter(client.getOutputStream(), "UTF-8"));
    while (keepListening) {
      handleClientData();
    }
    in.close();
    out.close();
    client.close();
    Logger.debug("Closed client connection");
  } catch (final IOException e) {
    throw new SocketServerException("Error when client was trying to connect");
  }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

private static HashMap<String, CommandHandler> map = new HashMap<String, CommandHandler>();

  static {
    map.put("waitForIdle", new WaitForIdle());
    map.put("clear", new Clear());
    map.put("orientation", new Orientation());
    map.put("swipe", new Swipe());
    map.put("flick", new Flick());
    map.put("drag", new Drag());
    map.put("pinch", new Pinch());
    map.put("click", new Click());
    map.put("touchLongClick", new TouchLongClick());
    map.put("touchDown", new TouchDown());
    map.put("touchUp", new TouchUp());
    map.put("touchMove", new TouchMove());
    map.put("getText", new GetText());
    map.put("setText", new SetText());
    map.put("getName", new GetName());
    map.put("getAttribute", new GetAttribute());
    map.put("getDeviceSize", new GetDeviceSize());
    map.put("scrollTo", new ScrollTo());
    map.put("find", new Find());
    map.put("getLocation", new GetLocation());
    map.put("getSize", new GetSize());
    map.put("wake", new Wake());
    map.put("pressBack", new PressBack());
    map.put("pressKeyCode", new PressKeyCode());
    map.put("longPressKeyCode", new LongPressKeyCode());
    map.put("takeScreenshot", new TakeScreenshot());
    map.put("updateStrings", new UpdateStrings());
    map.put("getDataDir", new GetDataDir());
    map.put("performMultiPointerGesture", new MultiPointerGesture());
    map.put("openNotification", new OpenNotification());
    map.put("source", new Source());
    map.put("compressedLayoutHierarchy", new CompressedLayoutHierarchy());
    map.put("configurator", new ConfiguratorHandler());
  }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

public AndroidCommandResult execute(final AndroidCommand command) {
  try {
    Logger.debug("Got command action: " + command.action());

    if (map.containsKey(command.action())) {
      return map.get(command.action()).execute(command);
    } else {
      return new AndroidCommandResult(WDStatus.UNKNOWN_COMMAND,
          "Unknown command: " + command.action());
    }
  } catch (final JSONException e) {
    Logger.error("Could not decode action/params of command");
    return new AndroidCommandResult(WDStatus.JSON_DECODER_ERROR,
        "Could not decode action/params of command, please check format!");
  }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

public void registerAnrAndCrashWatchers() {
  UiDevice.getInstance().registerWatcher("ANR", new UiWatcher() {
    @Override
    public boolean checkForCondition() {
      UiObject window = new UiObject(new UiSelector()
          .className("com.android.server.am.AppNotRespondingDialog"));
      String errorText = null;
      if (window.exists()) {
        try {
          errorText = window.getText();
        } catch (UiObjectNotFoundException e) {
          Log.e(LOG_TAG, "dialog gone?", e);
        }
        onAnrDetected(errorText);
        postHandler();
        return true; // triggered
      }
      return false; // no trigger
    }
  });