From 6e56731f15f962e939307c9f92331c822278d67b Mon Sep 17 00:00:00 2001 From: Andy Scherzinger Date: Thu, 20 May 2021 11:18:53 +0200 Subject: [PATCH] use short-syntax for loops and reformat code to 120 character line limt Signed-off-by: Andy Scherzinger --- .../talk/controllers/CallController.java | 195 +++++++++--------- .../CallNotificationController.java | 34 +-- 2 files changed, 121 insertions(+), 108 deletions(-) diff --git a/app/src/main/java/com/nextcloud/talk/controllers/CallController.java b/app/src/main/java/com/nextcloud/talk/controllers/CallController.java index b0819a69a..4c7143d52 100644 --- a/app/src/main/java/com/nextcloud/talk/controllers/CallController.java +++ b/app/src/main/java/com/nextcloud/talk/controllers/CallController.java @@ -445,12 +445,12 @@ public class CallController extends BaseController { .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer() { @Override - public void onSubscribe(Disposable d) { - + public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) { + // unused atm } @Override - public void onNext(RoomsOverall roomsOverall) { + public void onNext(@io.reactivex.annotations.NonNull RoomsOverall roomsOverall) { for (Conversation conversation : roomsOverall.getOcs().getData()) { if (roomId.equals(conversation.getRoomId())) { roomToken = conversation.getToken(); @@ -462,13 +462,13 @@ public class CallController extends BaseController { } @Override - public void onError(Throwable e) { - + public void onError(@io.reactivex.annotations.NonNull Throwable e) { + // unused atm } @Override public void onComplete() { - + // unused atm } }); } @@ -500,7 +500,6 @@ public class CallController extends BaseController { pipVideoView.setScalingType(RendererCommon.ScalingType.SCALE_ASPECT_FIT); pipVideoView.setOnTouchListener(new SelfVideoTouchListener()); - } gridView.setOnTouchListener(new View.OnTouchListener() { @@ -942,17 +941,16 @@ public class CallController extends BaseController { } } - if (isConnectionEstablished()) { + if (isConnectionEstablished() && magicPeerConnectionWrapperList != null) { if (!hasMCU) { - for (int i = 0; i < magicPeerConnectionWrapperList.size(); i++) { - magicPeerConnectionWrapperList.get(i).sendChannelData(new DataChannelMessage(message)); + for (MagicPeerConnectionWrapper magicPeerConnectionWrapper : magicPeerConnectionWrapperList) { + magicPeerConnectionWrapper.sendChannelData(new DataChannelMessage(message)); } } else { - for (int i = 0; i < magicPeerConnectionWrapperList.size(); i++) { - if (magicPeerConnectionWrapperList.get(i).getSessionId().equals(webSocketClient.getSessionId())) { - magicPeerConnectionWrapperList.get(i).sendChannelData(new DataChannelMessage(message)); + for (MagicPeerConnectionWrapper magicPeerConnectionWrapper : magicPeerConnectionWrapperList) { + if (magicPeerConnectionWrapper.getSessionId().equals(webSocketClient.getSessionId())) { + magicPeerConnectionWrapper.sendChannelData(new DataChannelMessage(message)); break; - } } } @@ -1103,13 +1101,12 @@ public class CallController extends BaseController { .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer() { @Override - public void onSubscribe(Disposable d) { - + public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) { + // unused atm } @Override - public void onNext(SignalingSettingsOverall signalingSettingsOverall) { - IceServer iceServer; + public void onNext(@io.reactivex.annotations.NonNull SignalingSettingsOverall signalingSettingsOverall) { if (signalingSettingsOverall != null && signalingSettingsOverall.getOcs() != null && signalingSettingsOverall.getOcs().getSettings() != null) { @@ -1142,36 +1139,38 @@ public class CallController extends BaseController { } } - if (apiVersion == ApiUtils.APIv3) { - if (signalingSettingsOverall.getOcs().getSettings().getStunServers() != null) { - for (int i = 0; i < signalingSettingsOverall.getOcs().getSettings().getStunServers().size(); - i++) { - iceServer = signalingSettingsOverall.getOcs().getSettings().getStunServers().get(i); - for (int j = 0; j < iceServer.getUrls().size(); j++) { - iceServers.add(new PeerConnection.IceServer(iceServer.getUrls().get(j))); + if (signalingSettingsOverall.getOcs().getSettings().getStunServers() != null) { + List stunServers = + signalingSettingsOverall.getOcs().getSettings().getStunServers(); + if (apiVersion == ApiUtils.APIv3) { + if (signalingSettingsOverall.getOcs().getSettings().getStunServers() != null) { + for (IceServer stunServer : stunServers) { + if (stunServer.getUrls() != null) { + for (String url : stunServer.getUrls()) { + iceServers.add(new PeerConnection.IceServer(url)); + } + } } } - } - } else { - if (signalingSettingsOverall.getOcs().getSettings().getStunServers() != null) { - for (int i = 0; i < signalingSettingsOverall.getOcs().getSettings().getStunServers().size(); - i++) { - iceServer = signalingSettingsOverall.getOcs().getSettings().getStunServers().get(i); - iceServers.add(new PeerConnection.IceServer(iceServer.getUrl())); + } else { + if (signalingSettingsOverall.getOcs().getSettings().getStunServers() != null) { + for (IceServer stunServer : stunServers) { + iceServers.add(new PeerConnection.IceServer(stunServer.getUrl())); + } } } } if (signalingSettingsOverall.getOcs().getSettings().getTurnServers() != null) { - for (int i = 0; i < signalingSettingsOverall.getOcs().getSettings().getTurnServers().size(); - i++) { - iceServer = signalingSettingsOverall.getOcs().getSettings().getTurnServers().get(i); - for (int j = 0; j < iceServer.getUrls().size(); j++) { - iceServers.add(new PeerConnection.IceServer( - iceServer.getUrls().get(j), - iceServer.getUsername(), - iceServer.getCredential() - )); + List turnServers = + signalingSettingsOverall.getOcs().getSettings().getTurnServers(); + for (IceServer turnServer : turnServers) { + if (turnServer.getUrls() != null) { + for (String url : turnServer.getUrls()) { + iceServers.add(new PeerConnection.IceServer( + url, turnServer.getUsername(), turnServer.getCredential() + )); + } } } } @@ -1181,13 +1180,13 @@ public class CallController extends BaseController { } @Override - public void onError(Throwable e) { + public void onError(@io.reactivex.annotations.NonNull Throwable e) { Log.e(TAG, e.getMessage(), e); } @Override public void onComplete() { - + // unused atm } }); } @@ -1199,12 +1198,12 @@ public class CallController extends BaseController { .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer() { @Override - public void onSubscribe(Disposable d) { - + public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) { + // unused atm } @Override - public void onNext(CapabilitiesOverall capabilitiesOverall) { + public void onNext(@io.reactivex.annotations.NonNull CapabilitiesOverall capabilitiesOverall) { // FIXME check for compatible Call API version if (hasExternalSignalingServer) { setupAndInitiateWebSocketsConnection(); @@ -1214,13 +1213,13 @@ public class CallController extends BaseController { } @Override - public void onError(Throwable e) { - + public void onError(@io.reactivex.annotations.NonNull Throwable e) { + // unused atm } @Override public void onComplete() { - + // unused atm } }); } @@ -1238,12 +1237,12 @@ public class CallController extends BaseController { .retry(3) .subscribe(new Observer() { @Override - public void onSubscribe(Disposable d) { - + public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) { + // unused atm } @Override - public void onNext(RoomOverall roomOverall) { + public void onNext(@io.reactivex.annotations.NonNull RoomOverall roomOverall) { callSession = roomOverall.getOcs().getData().getSessionId(); ApplicationWideCurrentRoomHolder.getInstance().setSession(callSession); ApplicationWideCurrentRoomHolder.getInstance().setCurrentRoomId(roomId); @@ -1253,13 +1252,13 @@ public class CallController extends BaseController { } @Override - public void onError(Throwable e) { - + public void onError(@io.reactivex.annotations.NonNull Throwable e) { + // unused atm } @Override public void onComplete() { - + // unused atm } }); } else { @@ -1292,27 +1291,31 @@ public class CallController extends BaseController { .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer() { @Override - public void onSubscribe(Disposable d) { - + public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) { + // unused atm } @Override - public void onNext(GenericOverall genericOverall) { + public void onNext(@io.reactivex.annotations.NonNull GenericOverall genericOverall) { if (!currentCallStatus.equals(CallStatus.LEAVING)) { setCallState(CallStatus.JOINED); ApplicationWideCurrentRoomHolder.getInstance().setInCall(true); if (!TextUtils.isEmpty(roomToken)) { - NotificationUtils.INSTANCE.cancelExistingNotificationsForRoom(getApplicationContext(), conversationUser, roomToken); + NotificationUtils.INSTANCE.cancelExistingNotificationsForRoom(getApplicationContext(), + conversationUser, + roomToken); } if (!hasExternalSignalingServer) { int apiVersion = ApiUtils.getSignalingApiVersion(conversationUser, new int[] {ApiUtils.APIv3, 2, 1}); - ncApi.pullSignalingMessages(credentials, ApiUtils.getUrlForSignaling(apiVersion, - baseUrl, roomToken)) + ncApi.pullSignalingMessages(credentials, + ApiUtils.getUrlForSignaling(apiVersion, + baseUrl, + roomToken)) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .repeatWhen(observable -> observable) @@ -1320,26 +1323,19 @@ public class CallController extends BaseController { .retry(3, observable -> isConnectionEstablished()) .subscribe(new Observer() { @Override - public void onSubscribe(Disposable d) { + public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) { signalingDisposable = d; } @Override - public void onNext(SignalingOverall signalingOverall) { - if (signalingOverall.getOcs().getSignalings() != null) { - for (int i = 0; i < signalingOverall.getOcs().getSignalings().size(); i++) { - try { - receivedSignalingMessage(signalingOverall.getOcs().getSignalings().get(i)); - } catch (IOException e) { - Log.e(TAG, "Failed to process received signaling" + - " message"); - } - } - } + public void onNext( + @io.reactivex.annotations.NonNull + SignalingOverall signalingOverall) { + receivedSignalingMessages(signalingOverall.getOcs().getSignalings()); } @Override - public void onError(Throwable e) { + public void onError(@io.reactivex.annotations.NonNull Throwable e) { dispose(signalingDisposable); } @@ -1348,19 +1344,18 @@ public class CallController extends BaseController { dispose(signalingDisposable); } }); - - } } } @Override - public void onError(Throwable e) { + public void onError(@io.reactivex.annotations.NonNull Throwable e) { + // unused atm } @Override public void onComplete() { - + // unused atm } }); } @@ -1402,7 +1397,6 @@ public class CallController extends BaseController { } else { initiateCall(); } - } else { } break; case "roomJoined": @@ -1414,14 +1408,19 @@ public class CallController extends BaseController { break; case "participantsUpdate": if (webSocketCommunicationEvent.getHashMap().get("roomToken").equals(roomToken)) { - processUsersInRoom((List>) webSocketClient.getJobWithId(Integer.valueOf(webSocketCommunicationEvent.getHashMap().get("jobId")))); + processUsersInRoom( + (List>) webSocketClient + .getJobWithId( + Integer.valueOf(webSocketCommunicationEvent.getHashMap().get("jobId")))); } break; case "signalingMessage": - processMessage((NCSignalingMessage) webSocketClient.getJobWithId(Integer.valueOf(webSocketCommunicationEvent.getHashMap().get("jobId")))); + processMessage((NCSignalingMessage) webSocketClient.getJobWithId( + Integer.valueOf(webSocketCommunicationEvent.getHashMap().get("jobId")))); break; case "peerReadyForRequestingOffer": - webSocketClient.requestOfferForSessionIdWithType(webSocketCommunicationEvent.getHashMap().get("sessionId"), "video"); + webSocketClient.requestOfferForSessionIdWithType( + webSocketCommunicationEvent.getHashMap().get("sessionId"), "video"); break; } } @@ -1442,6 +1441,18 @@ public class CallController extends BaseController { } } + private void receivedSignalingMessages(@Nullable List signalingList) { + if (signalingList != null) { + for (Signaling signaling : signalingList) { + try { + receivedSignalingMessage(signaling); + } catch (IOException e) { + Log.e(TAG, "Failed to process received signaling message", e); + } + } + } + } + private void receivedSignalingMessage(Signaling signaling) throws IOException { String messageType = signaling.getType(); @@ -2013,31 +2024,23 @@ public class CallController extends BaseController { .subscribeOn(Schedulers.io()) .subscribe(new Observer() { @Override - public void onSubscribe(Disposable d) { - + public void onSubscribe(@io.reactivex.annotations.NonNull Disposable d) { + // unused atm } @Override - public void onNext(SignalingOverall signalingOverall) { - if (signalingOverall.getOcs().getSignalings() != null) { - for (int i = 0; i < signalingOverall.getOcs().getSignalings().size(); i++) { - try { - receivedSignalingMessage(signalingOverall.getOcs().getSignalings().get(i)); - } catch (IOException e) { - Log.e(TAG, "", e); - } - } - } + public void onNext(@io.reactivex.annotations.NonNull SignalingOverall signalingOverall) { + receivedSignalingMessages(signalingOverall.getOcs().getSignalings()); } @Override - public void onError(Throwable e) { + public void onError(@io.reactivex.annotations.NonNull Throwable e) { Log.e(TAG, "", e); } @Override public void onComplete() { - + // unused atm } }); } else { diff --git a/app/src/main/java/com/nextcloud/talk/controllers/CallNotificationController.java b/app/src/main/java/com/nextcloud/talk/controllers/CallNotificationController.java index 35ff72f70..e6e64f84e 100644 --- a/app/src/main/java/com/nextcloud/talk/controllers/CallNotificationController.java +++ b/app/src/main/java/com/nextcloud/talk/controllers/CallNotificationController.java @@ -385,8 +385,11 @@ public class CallNotificationController extends BaseController { avatarImageView.setVisibility(View.VISIBLE); ImageRequest imageRequest = - DisplayUtils.getImageRequestForUrl(ApiUtils.getUrlForAvatarWithName(userBeingCalled.getBaseUrl(), - currentConversation.getName(), R.dimen.avatar_size_very_big), null); + DisplayUtils.getImageRequestForUrl( + ApiUtils.getUrlForAvatarWithName(userBeingCalled.getBaseUrl(), + currentConversation.getName(), + R.dimen.avatar_size_very_big), + null); ImagePipeline imagePipeline = Fresco.getImagePipeline(); DataSource> dataSource = imagePipeline.fetchDecodedImage(imageRequest, null); @@ -399,11 +402,12 @@ public class CallNotificationController extends BaseController { true); if (getResources() != null) { - incomingTextRelativeLayout.setBackground(getResources().getDrawable(R.drawable - .incoming_gradient)); + incomingTextRelativeLayout.setBackground( + getResources().getDrawable(R.drawable.incoming_gradient)); } - if (AvatarStatusCodeHolder.getInstance().getStatusCode() == 200 || AvatarStatusCodeHolder.getInstance().getStatusCode() == 0) { + if (AvatarStatusCodeHolder.getInstance().getStatusCode() == 200 || + AvatarStatusCodeHolder.getInstance().getStatusCode() == 0) { if (getActivity() != null) { Bitmap backgroundBitmap = bitmap.copy(bitmap.getConfig(), true); new BlurPostProcessor(5, getActivity()).process(backgroundBitmap); @@ -425,6 +429,7 @@ public class CallNotificationController extends BaseController { @Override protected void onFailureImpl(DataSource> dataSource) { + // unused atm } }, UiThreadImmediateExecutorService.getInstance()); @@ -467,10 +472,11 @@ public class CallNotificationController extends BaseController { } private void dispose() { - Disposable disposable; - for (int i = 0; i < disposablesList.size(); i++) { - if (!(disposable = disposablesList.get(i)).isDisposed()) { - disposable.dispose(); + if (disposablesList != null) { + for (Disposable disposable : disposablesList) { + if (!disposable.isDisposed()) { + disposable.dispose(); + } } } } @@ -486,7 +492,8 @@ public class CallNotificationController extends BaseController { "/raw/librem_by_feandesign_call"); } else { try { - RingtoneSettings ringtoneSettings = LoganSquare.parse(callRingtonePreferenceString, RingtoneSettings.class); + RingtoneSettings ringtoneSettings = LoganSquare.parse( + callRingtonePreferenceString, RingtoneSettings.class); ringtoneUri = ringtoneSettings.getRingtoneUri(); } catch (IOException e) { Log.e(TAG, "Failed to parse ringtone settings"); @@ -501,8 +508,11 @@ public class CallNotificationController extends BaseController { mediaPlayer.setDataSource(getActivity(), ringtoneUri); mediaPlayer.setLooping(true); - AudioAttributes audioAttributes = new AudioAttributes.Builder().setContentType(AudioAttributes - .CONTENT_TYPE_SONIFICATION).setUsage(AudioAttributes.USAGE_NOTIFICATION_RINGTONE).build(); + AudioAttributes audioAttributes = new AudioAttributes + .Builder() + .setContentType(AudioAttributes.CONTENT_TYPE_SONIFICATION) + .setUsage(AudioAttributes.USAGE_NOTIFICATION_RINGTONE) + .build(); mediaPlayer.setAudioAttributes(audioAttributes); mediaPlayer.setOnPreparedListener(mp -> mediaPlayer.start());