You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openmeetings.apache.org by so...@apache.org on 2020/10/14 13:58:45 UTC
[openmeetings] branch master updated: [OPENMEETINGS-2478] sonar
should be more happy
This is an automated email from the ASF dual-hosted git repository.
solomax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/openmeetings.git
The following commit(s) were added to refs/heads/master by this push:
new 1c14c66 [OPENMEETINGS-2478] sonar should be more happy
1c14c66 is described below
commit 1c14c6683bcea29c9621c0b9d9204e0b0ec29575
Author: Maxim Solodovnik <so...@gmail.com>
AuthorDate: Wed Oct 14 20:53:24 2020 +0700
[OPENMEETINGS-2478] sonar should be more happy
---
.../apache/openmeetings/core/remote/KStream.java | 36 ++++++++++------------
.../apache/openmeetings/backup/BackupImport.java | 6 ++--
.../apache/openmeetings/web/common/BasePanel.java | 4 +++
.../apache/openmeetings/web/common/MainPanel.java | 2 +-
.../openmeetings/web/common/menu/OmMenuItem.java | 1 +
.../web/common/tree/FileTreePanel.java | 4 +++
.../web/common/tree/OmTreeProvider.java | 4 ++-
.../sidebar/RoomFileUploadResourceReference.java | 2 +-
.../openmeetings/web/user/MessageDialog.java | 2 +-
9 files changed, 35 insertions(+), 26 deletions(-)
diff --git a/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KStream.java b/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KStream.java
index 77a5e2d..754ee15 100644
--- a/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KStream.java
+++ b/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/KStream.java
@@ -48,6 +48,7 @@ import org.apache.openmeetings.db.util.ws.RoomMessage;
import org.apache.openmeetings.db.util.ws.TextRoomMessage;
import org.kurento.client.Continuation;
import org.kurento.client.IceCandidate;
+import org.kurento.client.MediaFlowState;
import org.kurento.client.MediaProfileSpecType;
import org.kurento.client.MediaType;
import org.kurento.client.RecorderEndpoint;
@@ -122,25 +123,22 @@ public class KStream extends AbstractStream {
outgoingMedia.addMediaSessionTerminatedListener(evt -> log.warn("Media stream terminated {}", sd));
outgoingMedia.addMediaFlowOutStateChangeListener(evt -> {
log.info("Media Flow STATE :: {}, type {}, evt {}", evt.getState(), evt.getType(), evt.getMediaType());
- switch (evt.getState()) {
- case NOT_FLOWING:
- log.warn("FlowOut Future is created");
- flowoutFuture = Optional.of(new CompletableFuture<>().completeAsync(() -> {
- log.warn("KStream will be dropped {}", sd);
- if (StreamType.SCREEN == streamType) {
- processor.doStopSharing(sid, uid);
- }
- stopBroadcast();
- return null;
- }, delayedExecutor(getFlowoutTimeout(), TimeUnit.SECONDS)));
- break;
- case FLOWING:
- flowoutFuture.ifPresent(f -> {
- log.warn("FlowOut Future is canceled");
- f.cancel(true);
- flowoutFuture = Optional.empty();
- });
- break;
+ if (MediaFlowState.NOT_FLOWING == evt.getState()) {
+ log.warn("FlowOut Future is created");
+ flowoutFuture = Optional.of(new CompletableFuture<>().completeAsync(() -> {
+ log.warn("KStream will be dropped {}", sd);
+ if (StreamType.SCREEN == streamType) {
+ processor.doStopSharing(sid, uid);
+ }
+ stopBroadcast();
+ return null;
+ }, delayedExecutor(getFlowoutTimeout(), TimeUnit.SECONDS)));
+ } else {
+ flowoutFuture.ifPresent(f -> {
+ log.warn("FlowOut Future is canceled");
+ f.cancel(true);
+ flowoutFuture = Optional.empty();
+ });
}
});
outgoingMedia.addMediaFlowInStateChangeListener(evt -> log.warn("Media FlowIn :: {}", evt));
diff --git a/openmeetings-install/src/main/java/org/apache/openmeetings/backup/BackupImport.java b/openmeetings-install/src/main/java/org/apache/openmeetings/backup/BackupImport.java
index fced538..66836d0 100644
--- a/openmeetings-install/src/main/java/org/apache/openmeetings/backup/BackupImport.java
+++ b/openmeetings-install/src/main/java/org/apache/openmeetings/backup/BackupImport.java
@@ -452,17 +452,17 @@ public class BackupImport {
progressHolder.setProgress(97);
if (ver.compareTo(BackupVersion.get("4.0.0")) < 0) {
- for (BaseFileItem bfi : files) {
+ for (FileItem bfi : files) {
if (bfi.isDeleted()) {
continue;
}
if (BaseFileItem.Type.PRESENTATION == bfi.getType()) {
- convertOldPresentation((FileItem)bfi);
+ convertOldPresentation(bfi);
fileItemDao.updateBase(bfi);
}
if (BaseFileItem.Type.WML_FILE == bfi.getType()) {
try {
- Whiteboard wb = WbConverter.convert((FileItem)bfi);
+ Whiteboard wb = WbConverter.convert(bfi);
wb.save(bfi.getFile().toPath());
} catch (Exception e) {
log.error("Unexpected error while converting WB", e);
diff --git a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/BasePanel.java b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/BasePanel.java
index d492d9a..c6c05fd 100644
--- a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/BasePanel.java
+++ b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/BasePanel.java
@@ -98,6 +98,10 @@ public abstract class BasePanel extends Panel {
protected void process(IPartialPageRequestHandler handler, JSONObject o) throws IOException {
}
+ /**
+ * can be overridden by children to provide custom CSS class
+ * @return custom CSS class
+ */
protected String getCssClass() {
return "";
}
diff --git a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/MainPanel.java b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/MainPanel.java
index edf25a4..87433ec 100644
--- a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/MainPanel.java
+++ b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/MainPanel.java
@@ -390,7 +390,7 @@ public class MainPanel extends Panel {
private BasePanel getCurrentPanel() {
Component prev = contents.get(CHILD_ID);
- if (prev != null && prev instanceof BasePanel) {
+ if (prev instanceof BasePanel) {
return (BasePanel)prev;
}
return null;
diff --git a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/menu/OmMenuItem.java b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/menu/OmMenuItem.java
index 53377ac..d1f05e9 100644
--- a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/menu/OmMenuItem.java
+++ b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/menu/OmMenuItem.java
@@ -134,5 +134,6 @@ public class OmMenuItem implements INavbarComponent {
}
public void onClick(AjaxRequestTarget target) {
+ // no-op by default
}
}
diff --git a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/FileTreePanel.java b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/FileTreePanel.java
index 4b5f821..524426d 100644
--- a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/FileTreePanel.java
+++ b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/FileTreePanel.java
@@ -337,6 +337,10 @@ public abstract class FileTreePanel extends Panel {
response.render(JavaScriptHeaderItem.forReference(new JavaScriptResourceReference(FileTreePanel.class, "filetree.js")));
}
+ /**
+ * can be overridden by children to provide custom containment
+ * @return custom containment
+ */
protected String getContainment() {
return ".file.item.drop.area";
}
diff --git a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/OmTreeProvider.java b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/OmTreeProvider.java
index 48790f6..f24e46d 100644
--- a/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/OmTreeProvider.java
+++ b/openmeetings-web/src/main/java/org/apache/openmeetings/web/common/tree/OmTreeProvider.java
@@ -53,7 +53,9 @@ public class OmTreeProvider implements ITreeProvider<BaseFileItem> {
public static final String FILES_GROUP = "files-group-%s";
private final Long roomId;
private final List<BaseFileItem> roots = new ArrayList<>();
- private final String lblPublic, lblGroupFile, lblGroupRec;
+ private final String lblPublic;
+ private final String lblGroupFile;
+ private final String lblGroupRec;
@SpringBean
private UserDao userDao;
@SpringBean
diff --git a/openmeetings-web/src/main/java/org/apache/openmeetings/web/room/sidebar/RoomFileUploadResourceReference.java b/openmeetings-web/src/main/java/org/apache/openmeetings/web/room/sidebar/RoomFileUploadResourceReference.java
index 784bfaa..7c9278f 100644
--- a/openmeetings-web/src/main/java/org/apache/openmeetings/web/room/sidebar/RoomFileUploadResourceReference.java
+++ b/openmeetings-web/src/main/java/org/apache/openmeetings/web/room/sidebar/RoomFileUploadResourceReference.java
@@ -72,7 +72,7 @@ public class RoomFileUploadResourceReference extends ResourceReference {
private static final String PARAM_CLEAN_NAME = "room-upload-clean";
private static final String PARAM_SID_NAME = "room-upload-sid";
private static final String PARAM_LAST_SELECTED_NAME = "room-upload-last-selected";
- private static enum Status {
+ private enum Status {
SUCCESS
, PROGRESS
, ERROR
diff --git a/openmeetings-web/src/main/java/org/apache/openmeetings/web/user/MessageDialog.java b/openmeetings-web/src/main/java/org/apache/openmeetings/web/user/MessageDialog.java
index f7996b9..9aca029 100644
--- a/openmeetings-web/src/main/java/org/apache/openmeetings/web/user/MessageDialog.java
+++ b/openmeetings-web/src/main/java/org/apache/openmeetings/web/user/MessageDialog.java
@@ -200,7 +200,7 @@ public class MessageDialog extends Modal<PrivateMessage> {
String subj = p.getSubject() == null ? "" : p.getSubject();
handler.send(to.getAddress().getEmail(),
Application.getString("1301", to.getLanguageId()) + subj,
- (p.getMessage() == null ? "" : p.getMessage().replaceAll("\\<.*?>", "")) + aLinkHTML + invitationLink);
+ (p.getMessage() == null ? "" : p.getMessage().replaceAll("\\<[^>]*+>", "")) + aLinkHTML + invitationLink);
}
}
MessageDialog.this.close(target);