Clear tmp dir

src/main/java/org/commonwl/view/Scheduler.java

@@ -1,6 +1,7 @@
 package org.commonwl.view;
 
 
+import org.commonwl.view.util.StreamGobbler;
 import org.commonwl.view.workflow.QueuedWorkflowRepository;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -9,6 +10,9 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+
+import java.io.IOException;
+
 import java.util.Calendar;
 import java.util.Date;
 
@@ -24,6 +28,9 @@ public class Scheduler {
     @Value("${queuedWorkflowAgeLimitHours}")
     private Integer QUEUED_WORKFLOW_AGE_LIMIT_HOURS;
 
+    @Value("${tmpDirAgeLimitDays}")
+    private Integer TMP_DIR_AGE_LIMIT_DAYS;
+
     @Autowired
     public Scheduler(QueuedWorkflowRepository queuedWorkflowRepository) {
         this.queuedWorkflowRepository = queuedWorkflowRepository;
@@ -55,4 +62,40 @@ public void removeOldQueuedWorkflowEntries() {
         logger.info(queuedWorkflowRepository.deleteByTempRepresentation_RetrievedOnLessThanEqual(removeTime)
                 + " Old queued workflows removed");
     }
+
+
+    @Scheduled(cron = "${cron.clearTmpDir}")
+    public void clearTmpDir() {
+        // TODO: find source of tmp dir creation and delete from there
+
+        // wipe tmp dir and log info
+        try {
+            // Run command
+            String[] command = {"find", "/tmp", "-ctime", "+" + TMP_DIR_AGE_LIMIT_DAYS, "-exec", "rm", "-rf", "{}", "+"};
+            ProcessBuilder clearProcess = new ProcessBuilder(command);
+            logger.info("Clearing /tmp directory for content older than " + TMP_DIR_AGE_LIMIT_DAYS + " day" + (TMP_DIR_AGE_LIMIT_DAYS > 1 ? "s" : "") + "...");
+            Process process = clearProcess.start();
+
+            // Read output from the process using threads
+            StreamGobbler inputGobbler = new StreamGobbler(process.getInputStream());
+            StreamGobbler errorGobbler = new StreamGobbler(process.getErrorStream());
+            errorGobbler.start();
+            inputGobbler.start();
+
+            // Wait for process to complete
+            int exitCode = process.waitFor();
+            if (exitCode == 0) {
+                inputGobbler.join();
+                logger.info(inputGobbler.getContent());
+                logger.info("Successfully Cleared /tmp directory");
+            } else {
+                errorGobbler.join();
+                logger.warn("Could not clear /tmp directory");
+                logger.warn(errorGobbler.getContent());
+
+            }
+        } catch (IOException|InterruptedException e) {
+            logger.error("Error running clear /tmp dir process", e);
+        }
+    }
 }

src/main/java/org/commonwl/view/util/StreamGobbler.java

@@ -32,7 +32,7 @@ public class StreamGobbler extends Thread {
     private final String lineSeparator = System.getProperty("line.separator");
 
     private InputStream is;
-    private String content = "";
+    private String content = ""; // TODO: update to string builder
 
     public StreamGobbler(InputStream is) {
         this.is = is;

src/main/resources/application.properties

@@ -48,6 +48,7 @@ spring.data.mongodb.port = 27017
 sparql.endpoint = http://localhost:3030/cwlviewer/
 
 
+
 #=======================
 # Scheduler settings
 #=======================
@@ -57,5 +58,12 @@ sparql.endpoint = http://localhost:3030/cwlviewer/
 # The expression below implies every hour at the 0th second and 0th minute i.e (01:00:00, 02:00::00,... etc)
 cron.deleteOldQueuedWorkflows = 0 0 * * * ?
 
+# The expression below implies every day at the 0th second, 0th minute and 24th(0th) hour i.e ( time 00:00:00, every day)
+cron.clearTmpDir = 0 0 0 * * ?
+
 # Age limit for queued workflows in hours.
-queuedWorkflowAgeLimitHours = 24
+queuedWorkflowAgeLimitHours = 24
+
+# Age limit for tmp directories in days.
+tmpDirAgeLimitDays = 1
+