diff --git a/src/main/java/org/gcube/data/access/storagehub/services/MessageManager.java b/src/main/java/org/gcube/data/access/storagehub/services/MessageManager.java index d407da5..ce0a4b2 100644 --- a/src/main/java/org/gcube/data/access/storagehub/services/MessageManager.java +++ b/src/main/java/org/gcube/data/access/storagehub/services/MessageManager.java @@ -87,7 +87,7 @@ public class MessageManager extends Impersonable{ @Inject Item2NodeConverter item2Node; @Inject TrashHandler trashHandler; - + @GET @Path("{id}") @Produces(MediaType.APPLICATION_JSON) @@ -127,7 +127,7 @@ public class MessageManager extends Impersonable{ Node messageNode = ses.getNodeByIdentifier(id); Message message = node2Item.getMessageItem(messageNode); Node personalNode = checkRights(currentUser, message); - + if (countSharedSet(messageNode)>1) personalNode.removeShare(); else { @@ -279,7 +279,7 @@ public class MessageManager extends Impersonable{ throw new InvalidCallParameters(); log.debug("attachments send are {}",attachments); - + ses = (JackrabbitSession) repository.getRepository().login(CredentialHandler.getAdminCredentials(context)); Message message = new MessageSharable(); @@ -323,11 +323,11 @@ public class MessageManager extends Impersonable{ return messageId; } - - + + private Node saveAttachments(Session ses, Node messageNode , List attachments) throws RepositoryException, BackendGenericError{ Node attachmentNode = messageNode.getNode(Constants.ATTACHMENTNODE_NAME); - + for (String itemId: attachments) { Node node = ses.getNodeByIdentifier(itemId); Item item = node2Item.getItem(node, Excludes.GET_ONLY_CONTENT); @@ -351,7 +351,7 @@ public class MessageManager extends Impersonable{ log.info("message discarded"); continue; } - + if (reduceBody != null && reduceBody>0 && message.getBody().length()>reduceBody ) message.setBody(message.getBody().substring(0, reduceBody)); insertOrdered(messages, message); @@ -360,12 +360,15 @@ public class MessageManager extends Impersonable{ } private void insertOrdered(List messages, Message toInsert) { - if (messages.isEmpty()) messages.add(toInsert); - int i; - for ( i=0 ; i