Format all Java in WebRTC.

webrtc/examples/androidapp/src/org/appspot/apprtc/DirectRTCClient.java

 /*
  *  Copyright 2016 The WebRTC Project Authors. All rights reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 17 matching lines @@
 /**
  * Implementation of AppRTCClient that uses direct TCP connection as the signaling channel.
  * This eliminates the need for an external server. This class does not support loopback
  * connections.
  */
 public class DirectRTCClient implements AppRTCClient, TCPChannelClient.TCPChannelEvents {
   private static final String TAG = "DirectRTCClient";
   private static final int DEFAULT_PORT = 8888;
 
   // Regex pattern used for checking if room id looks like an IP.
-  static final Pattern IP_PATTERN = Pattern.compile(
-      "("
-        // IPv4
-        + "((\\d+\\.){3}\\d+)|"
-        // IPv6
-        + "\\[((([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?::"
-              + "(([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?)\\]|"
-        + "\\[(([0-9a-fA-F]{1,4}:){7}[0-9a-fA-F]{1,4})\\]|"
-        // IPv6 without []
-        + "((([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?::(([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?)|"
-        + "(([0-9a-fA-F]{1,4}:){7}[0-9a-fA-F]{1,4})|"
-        // Literals
-        + "localhost"
+  static final Pattern IP_PATTERN = Pattern.compile("("
+      // IPv4
+      + "((\\d+\\.){3}\\d+)|"
+      // IPv6
+      + "\\[((([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?::"
+      + "(([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?)\\]|"
+      + "\\[(([0-9a-fA-F]{1,4}:){7}[0-9a-fA-F]{1,4})\\]|"
+      // IPv6 without []
+      + "((([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?::(([0-9a-fA-F]{1,4}:)*[0-9a-fA-F]{1,4})?)|"
+      + "(([0-9a-fA-F]{1,4}:){7}[0-9a-fA-F]{1,4})|"
+      // Literals
+      + "localhost"
       + ")"
       // Optional port number
-      + "(:(\\d+))?"
-  );
+      + "(:(\\d+))?");
 
   private final ExecutorService executor;
   private final SignalingEvents events;
   private TCPChannelClient tcpClient;
   private RoomConnectionParameters connectionParameters;
 
-  private enum ConnectionState {
-    NEW, CONNECTED, CLOSED, ERROR
-  };
+  private enum ConnectionState { NEW, CONNECTED, CLOSED, ERROR }
 
   // All alterations of the room state should be done from inside the looper thread.
   private ConnectionState roomState;
 
   public DirectRTCClient(SignalingEvents events) {
     this.events = events;
 
     executor = Executors.newSingleThreadExecutor();
     roomState = ConnectionState.NEW;
   }
@@ skipping 128 matching lines @@
   }
 
   /** Send removed Ice candidates to the other participant. */
   @Override
   public void sendLocalIceCandidateRemovals(final IceCandidate[] candidates) {
     executor.execute(new Runnable() {
       @Override
       public void run() {
         JSONObject json = new JSONObject();
         jsonPut(json, "type", "remove-candidates");
-        JSONArray jsonArray =  new JSONArray();
+        JSONArray jsonArray = new JSONArray();
         for (final IceCandidate candidate : candidates) {
           jsonArray.put(toJsonCandidate(candidate));
         }
         jsonPut(json, "candidates", jsonArray);
 
         if (roomState != ConnectionState.CONNECTED) {
           reportError("Sending ICE candidate removals in non connected state.");
           return;
         }
         sendMessage(json.toString());
@@ skipping 14 matching lines @@
 
       SignalingParameters parameters = new SignalingParameters(
           // Ice servers are not needed for direct connections.
           new LinkedList<PeerConnection.IceServer>(),
           isServer, // Server side acts as the initiator on direct connections.
           null, // clientId
           null, // wssUrl
           null, // wwsPostUrl
           null, // offerSdp
           null // iceCandidates
-      );
+          );
       events.onConnectedToRoom(parameters);
     }
   }
 
   @Override
   public void onTCPMessage(String msg) {
     try {
       JSONObject json = new JSONObject(msg);
       String type = json.optString("type");
       if (type.equals("candidate")) {
         events.onRemoteIceCandidate(toJavaCandidate(json));
       } else if (type.equals("remove-candidates")) {
         JSONArray candidateArray = json.getJSONArray("candidates");
         IceCandidate[] candidates = new IceCandidate[candidateArray.length()];
         for (int i = 0; i < candidateArray.length(); ++i) {
           candidates[i] = toJavaCandidate(candidateArray.getJSONObject(i));
         }
         events.onRemoteIceCandidatesRemoved(candidates);
       } else if (type.equals("answer")) {
         SessionDescription sdp = new SessionDescription(
-            SessionDescription.Type.fromCanonicalForm(type),
-            json.getString("sdp"));
+            SessionDescription.Type.fromCanonicalForm(type), json.getString("sdp"));
         events.onRemoteDescription(sdp);
       } else if (type.equals("offer")) {
         SessionDescription sdp = new SessionDescription(
-            SessionDescription.Type.fromCanonicalForm(type),
-            json.getString("sdp"));
+            SessionDescription.Type.fromCanonicalForm(type), json.getString("sdp"));
 
         SignalingParameters parameters = new SignalingParameters(
             // Ice servers are not needed for direct connections.
             new LinkedList<PeerConnection.IceServer>(),
             false, // This code will only be run on the client side. So, we are not the initiator.
             null, // clientId
             null, // wssUrl
             null, // wssPostUrl
             sdp, // offerSdp
             null // iceCandidates
-        );
+            );
         roomState = ConnectionState.CONNECTED;
         events.onConnectedToRoom(parameters);
       } else {
         reportError("Unexpected TCP message: " + msg);
       }
     } catch (JSONException e) {
       reportError("TCP message JSON parsing error: " + e.toString());
     }
   }
 
@@ skipping 44 matching lines @@
   private static JSONObject toJsonCandidate(final IceCandidate candidate) {
     JSONObject json = new JSONObject();
     jsonPut(json, "label", candidate.sdpMLineIndex);
     jsonPut(json, "id", candidate.sdpMid);
     jsonPut(json, "candidate", candidate.sdp);
     return json;
   }
 
   // Converts a JSON candidate to a Java object.
   private static IceCandidate toJavaCandidate(JSONObject json) throws JSONException {
-    return new IceCandidate(json.getString("id"),
-        json.getInt("label"),
-        json.getString("candidate"));
+    return new IceCandidate(
+        json.getString("id"), json.getInt("label"), json.getString("candidate"));
   }
 }