Add delete by date retrieved on method to queued workflow repository

Author: obasekiosa

src/main/java/org/commonwl/view/workflow/QueuedWorkflowRepository.java

@@ -4,6 +4,9 @@
 import org.springframework.data.mongodb.repository.Query;
 import org.springframework.data.repository.PagingAndSortingRepository;
 
+import java.util.Date;
+import java.util.List;
+
 /**
  * Stores workflows in the queue waiting for cwltool
  */
@@ -24,4 +27,20 @@ public interface QueuedWorkflowRepository extends PagingAndSortingRepository<Que
     @Query("{tempRepresentation.retrievedFrom: ?0}")
     void deleteByRetrievedFrom(GitDetails retrievedFrom);
 
+    /**
+     * Deletes all queued workflows with date retrieved on older or equal to the Date argument passed.
+     * @param retrievedOn Date of when the queued workflow was retrieved
+     * @return The number of queued workflows deleted
+     */
+    Long deleteByTempRepresentation_RetrievedOnLessThanEqual(Date retrievedOn);
+
+
+    /**
+     * Finds and returns all queued workflows with date retrieved on older or equal to the Date argument passed.
+     * @param retrievedOn Details of where the queued workflow is from
+     * @return A list of queued workflows
+     */
+    List<QueuedWorkflow> findByTempRepresentation_RetrievedOnLessThanEqual(Date retrievedOn);
+
+
 }