Story/vspc 204

vspace/pom.xml

@@ -26,7 +26,7 @@
         <db.user>vspace</db.user>
         <db.password>vspace</db.password>
         <uploaded.files.path></uploaded.files.path>
-
+        <downloaded.files.path></downloaded.files.path>
         <email.user></email.user>
         <email.password></email.password>
         <email.host></email.host>

vspace/src/main/java/edu/asu/diging/vspace/config/AsyncConfiguration.java

@@ -0,0 +1,42 @@
+package edu.asu.diging.vspace.config;
+
+import java.util.concurrent.Executor;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+import org.springframework.security.core.context.SecurityContextHolder;
+
+@Configuration
+@EnableAsync
+public class AsyncConfiguration {
+
+    @Value("${async_core_pool_size}")
+    private int corePoolSize;
+
+    @Value("${async_max_pool_size}")
+    private int maxPoolSize;
+
+    @Value("${async_queue_capacity}")
+    private int queueCapacity;
+
+    @Bean(name="asyncExecutor")
+    public Executor getAsyncExecutor() {
+        // Set the strategy so that threads can inherit the authenticated user
+        SecurityContextHolder.setStrategyName(SecurityContextHolder.MODE_INHERITABLETHREADLOCAL);
+        ThreadPoolTaskExecutor asyncExecutor = new ThreadPoolTaskExecutor();
+
+        asyncExecutor.setCorePoolSize(corePoolSize);
+        asyncExecutor.setMaxPoolSize(maxPoolSize);
+        asyncExecutor.setQueueCapacity(queueCapacity);
+
+        asyncExecutor.setThreadNamePrefix("threadAsync");
+        asyncExecutor.setWaitForTasksToCompleteOnShutdown(true);
+        asyncExecutor.initialize();
+
+        return asyncExecutor;
+    }
+
+}

vspace/src/main/java/edu/asu/diging/vspace/config/StorageEngineConfig.java

@@ -0,0 +1,30 @@
+package edu.asu.diging.vspace.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.stereotype.Component;
+
+import edu.asu.diging.vspace.core.file.IStorageEngine;
+import edu.asu.diging.vspace.core.file.impl.StorageEngine;
+
+@Component
+@Configuration
+public class StorageEngineConfig {
+
+    @Value("${downloads_path}")
+    private String downloadsPath;
+
+    @Value("${uploads_path}")
+    private String uploadsPath;
+
+    @Bean(name = "storageEngineDownloads")
+    public IStorageEngine storageEngineDownloads(){
+        return new StorageEngine(downloadsPath);
+    }
+
+    @Bean(name = "storageEngineUploads")
+    public IStorageEngine storageEngineUploads(){
+        return new StorageEngine(uploadsPath); 
+    }
+}

vspace/src/main/java/edu/asu/diging/vspace/core/data/ExhibitionSnapshotRepository.java

@@ -0,0 +1,15 @@
+package edu.asu.diging.vspace.core.data;
+
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.repository.PagingAndSortingRepository;
+
+import edu.asu.diging.vspace.core.model.impl.ExhibitionSnapshot;
+
+public interface ExhibitionSnapshotRepository extends PagingAndSortingRepository<ExhibitionSnapshot, String> {
+
+    Page<ExhibitionSnapshot> findAllByOrderByCreationDateDesc(Pageable requestedPage);
+
+    ExhibitionSnapshot findByFolderName(String exhibitionFolderName);
+
+}

vspace/src/main/java/edu/asu/diging/vspace/core/data/SnapshotTaskRepository.java

@@ -0,0 +1,21 @@
+package edu.asu.diging.vspace.core.data;
+
+import java.util.Optional;
+
+import org.javers.spring.annotation.JaversSpringDataAuditable;
+import org.springframework.data.repository.PagingAndSortingRepository;
+import org.springframework.stereotype.Repository;
+
+import edu.asu.diging.vspace.core.model.impl.SnapshotTask;
+
+@Repository
+@JaversSpringDataAuditable
+public interface SnapshotTaskRepository extends PagingAndSortingRepository<SnapshotTask, String>{
+
+    SnapshotTask findFirstByOrderByCreationDateDesc();
+
+    Optional<SnapshotTask> findById(String id);
+
+    Optional<SnapshotTask> findByExhibitionSnapshotId(String exhibitionSnapshotId);
+
+}

vspace/src/main/java/edu/asu/diging/vspace/core/exception/ExhibitionSnapshotNotFoundException.java

@@ -0,0 +1,30 @@
+package edu.asu.diging.vspace.core.exception;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ResponseStatus;
+
+@ResponseStatus(value = HttpStatus.NOT_FOUND, reason = "Exhibition snapshot folder not found")
+public class ExhibitionSnapshotNotFoundException extends Exception{
+    private static final long serialVersionUID = 1L;
+
+    public ExhibitionSnapshotNotFoundException() {
+        super();
+    }
+
+    public ExhibitionSnapshotNotFoundException(String message, Throwable cause, boolean enableSuppression,
+            boolean writableStackTrace) {
+        super(message, cause, enableSuppression, writableStackTrace);
+    }
+
+    public ExhibitionSnapshotNotFoundException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public ExhibitionSnapshotNotFoundException(Throwable cause) {
+        super(cause);
+    }
+
+    public ExhibitionSnapshotNotFoundException(String id) {
+        super("Exhibition snapshot folder with id " + id + " not found");
+    }
+}

vspace/src/main/java/edu/asu/diging/vspace/core/exception/SnapshotCouldNotBeCreatedException.java

@@ -0,0 +1,16 @@
+package edu.asu.diging.vspace.core.exception;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ResponseStatus;
+
+@ResponseStatus(value = HttpStatus.NOT_FOUND, reason = "Snapshot could not be created")
+public class SnapshotCouldNotBeCreatedException extends Exception{
+    private static final long serialVersionUID = 1L;
+
+    public SnapshotCouldNotBeCreatedException(String id) {
+        super("Snapshot could not be created for snapshot task id " + id + " not found");
+    }
+
+    public SnapshotCouldNotBeCreatedException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

vspace/src/main/java/edu/asu/diging/vspace/core/file/IStorageEngine.java

@@ -1,17 +1,24 @@
 package edu.asu.diging.vspace.core.file;
 
 import java.io.File;
+import java.io.FileNotFoundException;
 import java.io.IOException;
 
 import org.springframework.core.io.Resource;
 
+import edu.asu.diging.vspace.core.exception.ExhibitionSnapshotNotFoundException;
 import edu.asu.diging.vspace.core.exception.FileStorageException;
 import edu.asu.diging.vspace.core.model.IVSImage;
 
 public interface IStorageEngine {
-
     String storeFile(byte[] fileContent, String filename, String directory) throws FileStorageException;
 
+    String createFolder(String relativePath);
+
+    byte[] generateZip(String exhibitionFolderName) throws IOException;
+
+    void copyToFolder(String relativePath, String folderToCopy) throws IOException;
+
     Resource downloadFile(String fileName, String directory) throws IOException;
 
     boolean renameFile(String fileName, String newFileName, String directory);
@@ -25,5 +32,22 @@ public interface IStorageEngine {
     byte[] getMediaContent(String directory, String filename) throws IOException;
 
     boolean renameImage(IVSImage image, String newFileName);
+
+    /**
+     * Deletes the specified folder
+     *
+     *@param folderPath path to the folder to be deleted
+     */
+    void deleteFolder(String folderPath, String folderName) throws IOException;
+
+    /**
+     * To return the zip file
+     * 
+     * @param zipFilename - name of the folder to be zipped
+     * @return byte[] - zipped data as a byte array
+     * @throws ExhibitionSnapshotNotFoundException 
+     * @throws IOException 
+     */
+    byte[] getZip(String zipFilename) throws ExhibitionSnapshotNotFoundException, IOException, FileNotFoundException;
 }
 

vspace/src/main/java/edu/asu/diging/vspace/core/file/IStorageManager.java

@@ -0,0 +1,17 @@
+package edu.asu.diging.vspace.core.file;
+
+import edu.asu.diging.vspace.core.exception.FileStorageException;
+import edu.asu.diging.vspace.core.model.IVSImage;
+
+public interface IStorageManager {
+
+    /**
+     * Copies given image from uploads to exhibition snapshot folder
+     * 
+     * @param image
+     * @param imagesFolderPath
+     * @throws FileStorageException 
+     */
+    void copyImage(IVSImage image, String imagesFolderPath) throws FileStorageException;
+
+}