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 <[email protected]>
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);
