customer/uk-it-15

.pre-commit-config.yaml

@@ -0,0 +1,9 @@
+repos:
+-   repo: local
+    hooks:
+      - id: mvn-checkstyle
+        verbose: true
+        entry: python scripts/pre-commit/checkstyle.py
+        name: Runs maven checkstyle
+        language: python
+        files: \.(java)$

dspace-api/src/main/java/org/dspace/content/clarin/ClarinUserMetadataServiceImpl.java

@@ -10,6 +10,8 @@
 import java.sql.SQLException;
 import java.util.List;
 import java.util.Objects;
+import java.util.UUID;
+import java.util.stream.Collectors;
 
 import org.apache.commons.lang.NullArgumentException;
 import org.dspace.authorize.AuthorizeException;
@@ -76,4 +78,44 @@ public void delete(Context context, ClarinUserMetadata clarinUserMetadata) throw
         }
         clarinUserMetadataDAO.delete(context, clarinUserMetadata);
     }
+
+    @Override
+    public List<ClarinUserMetadata> findByUserRegistrationAndBitstream(Context context, Integer userRegUUID,
+                                                                       UUID bitstreamUUID, boolean lastTransaction)
+            throws SQLException {
+        if (lastTransaction) {
+            return getLastTransactionUserMetadata(clarinUserMetadataDAO.findByUserRegistrationAndBitstream(context,
+                    userRegUUID, bitstreamUUID));
+        }
+        return clarinUserMetadataDAO.findByUserRegistrationAndBitstream(context, userRegUUID, bitstreamUUID);
+    }
+
+    private List<ClarinUserMetadata> getLastTransactionUserMetadata(List<ClarinUserMetadata> userMetadataList) {
+        Integer latestTransactionId = getIdOfLastTransaction(userMetadataList);
+        if (latestTransactionId == null) {
+            return userMetadataList;
+        }
+
+        List<ClarinUserMetadata> filteredUserMetadata = null;
+        // Filter all user metadata by the last transaction
+        try {
+            filteredUserMetadata = userMetadataList.stream()
+                    .filter(clarinUserMetadata -> clarinUserMetadata.getTransaction().getID()
+                            .equals(latestTransactionId))
+                    .collect(Collectors.toList());
+        } catch (Exception e) {
+            log.error("Error filtering user metadata by the last transaction", e);
+        }
+        return filteredUserMetadata;
+    }
+
+    private Integer getIdOfLastTransaction(List<ClarinUserMetadata> userMetadataList) {
+        // userMetadataList is filtered by the last transaction - first element is the last transaction
+        try {
+            return userMetadataList.get(0).getTransaction().getID();
+        } catch (IndexOutOfBoundsException e) {
+            log.error("No transaction found for the user metadata");
+            return null;
+        }
+    }
 }

dspace-api/src/main/java/org/dspace/content/dao/clarin/ClarinUserMetadataDAO.java

@@ -7,8 +7,15 @@
  */
 package org.dspace.content.dao.clarin;
 
+import java.sql.SQLException;
+import java.util.List;
+import java.util.UUID;
+
 import org.dspace.content.clarin.ClarinUserMetadata;
+import org.dspace.core.Context;
 import org.dspace.core.GenericDAO;
 
 public interface ClarinUserMetadataDAO extends GenericDAO<ClarinUserMetadata> {
+    List<ClarinUserMetadata> findByUserRegistrationAndBitstream(Context context, Integer userRegUUID,
+                                                                UUID bitstreamUUID) throws SQLException;
 }

dspace-api/src/main/java/org/dspace/content/dao/impl/clarin/ClarinUserMetadataDAOImpl.java

@@ -7,14 +7,38 @@
  */
 package org.dspace.content.dao.impl.clarin;
 
+import java.sql.SQLException;
+import java.util.List;
+import java.util.UUID;
+import javax.persistence.Query;
+
 import org.dspace.content.clarin.ClarinUserMetadata;
 import org.dspace.content.dao.clarin.ClarinUserMetadataDAO;
 import org.dspace.core.AbstractHibernateDAO;
+import org.dspace.core.Context;
 
 public class ClarinUserMetadataDAOImpl extends AbstractHibernateDAO<ClarinUserMetadata>
         implements ClarinUserMetadataDAO {
 
     protected ClarinUserMetadataDAOImpl() {
         super();
     }
+
+    @Override
+    public List<ClarinUserMetadata> findByUserRegistrationAndBitstream(Context context, Integer userRegUUID,
+                                                                       UUID bitstreamUUID) throws SQLException {
+        Query query = createQuery(context, "SELECT cum FROM ClarinUserMetadata as cum " +
+                "JOIN cum.eperson as ur " +
+                "JOIN cum.transaction as clrua " +
+                "JOIN clrua.licenseResourceMapping as map " +
+                "WHERE ur.id = :userRegUUID " +
+                "AND map.bitstream.id = :bitstreamUUID " +
+                "ORDER BY clrua.id DESC");
+
+        query.setParameter("userRegUUID", userRegUUID);
+        query.setParameter("bitstreamUUID", bitstreamUUID);
+        query.setHint("org.hibernate.cacheable", Boolean.TRUE);
+
+        return list(query);
+    }
 }

dspace-api/src/main/java/org/dspace/content/service/clarin/ClarinUserMetadataService.java

@@ -9,6 +9,7 @@
 
 import java.sql.SQLException;
 import java.util.List;
+import java.util.UUID;
 
 import org.dspace.authorize.AuthorizeException;
 import org.dspace.content.clarin.ClarinUserMetadata;
@@ -22,4 +23,8 @@ public interface ClarinUserMetadataService {
     List<ClarinUserMetadata> findAll(Context context) throws SQLException;
     void update(Context context, ClarinUserMetadata clarinUserMetadata) throws SQLException;
     void delete(Context context, ClarinUserMetadata clarinUserMetadata) throws SQLException, AuthorizeException;
+
+    List<ClarinUserMetadata> findByUserRegistrationAndBitstream(Context context, Integer userRegUUID,
+                                                                UUID bitstreamUUID, boolean lastTransaction)
+            throws SQLException;
 }