feat: add FilesController and FilesService

Author: midhunadarvin

quartz-manager-parent/quartz-manager-web-showcase/pom.xml

@@ -112,6 +112,11 @@
           <groupId>org.apache.commons</groupId>
           <artifactId>commons-lang3</artifactId>
         </dependency>
+        <dependency>
+          <groupId>org.python</groupId>
+          <artifactId>jython-slim</artifactId>
+          <version>2.7.3b1</version>
+        </dependency>
 
         <!-- TEST -->
         <dependency>

quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/controllers/FilesController.java

@@ -0,0 +1,38 @@
+package it.fabioformosa.quartzmanager.controllers;
+
+import it.fabioformosa.quartzmanager.services.FileService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+@Slf4j
+@RestController
+@RequestMapping("/files")
+public class FilesController {
+
+  @Autowired
+  private FileService fileService;
+
+  public FilesController() {
+  }
+
+  @PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
+  public ResponseEntity<String> handleFileUpload(@RequestParam("file") MultipartFile file) {
+
+    try {
+      fileService.uploadFile(file);
+      // Return a success message
+      return ResponseEntity.ok("File uploaded successfully!");
+    } catch (Exception e) {
+      // Handle file IO exceptions
+      System.out.println(e.getMessage());
+      return ResponseEntity.status(500).body("Failed to upload the file");
+    }
+  }
+}

quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/jobs/myjobs/PythonJob.java

@@ -0,0 +1,33 @@
+package it.fabioformosa.quartzmanager.jobs.myjobs;
+
+import it.fabioformosa.quartzmanager.api.jobs.AbstractQuartzManagerJob;
+import it.fabioformosa.quartzmanager.api.jobs.entities.LogRecord;
+import org.quartz.JobExecutionContext;
+
+import javax.script.ScriptContext;
+import javax.script.ScriptEngine;
+import javax.script.ScriptEngineManager;
+import javax.script.SimpleScriptContext;
+import java.io.File;
+import java.io.FileReader;
+import java.io.StringWriter;
+
+public class PythonJob extends AbstractQuartzManagerJob {
+  @Override
+  public LogRecord doIt(JobExecutionContext jobExecutionContext) {
+    StringWriter writer = new StringWriter();
+    ScriptContext context = new SimpleScriptContext();
+    context.setWriter(writer);
+
+    ScriptEngineManager manager = new ScriptEngineManager();
+    ScriptEngine engine = manager.getEngineByName("python");
+    // 1. Load as File
+    File file = new File(jobExecutionContext.getTrigger().getJobDataMap().getString("file"));
+    try {
+      engine.eval(new FileReader(file), context);
+      return new LogRecord(LogRecord.LogType.INFO, writer.toString().trim());
+    } catch (Exception e) {
+      throw new RuntimeException(e);
+    }
+  }
+}

quartz-manager-parent/quartz-manager-web-showcase/src/main/java/it/fabioformosa/quartzmanager/services/FileService.java

@@ -0,0 +1,45 @@
+package it.fabioformosa.quartzmanager.services;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+
+@Slf4j
+@Service
+public class FileService {
+  String uploadsDirectory;
+  public FileService(@Value("${chista-scheduler.uploadFolder}") String uploadsDirectory) {
+    this.uploadsDirectory = uploadsDirectory;
+    createUploadsFolderIfNotExists();
+  }
+
+  public String getUploadsDirectory() {
+    return this.uploadsDirectory;
+  }
+
+  public void uploadFile(MultipartFile file) throws Exception {
+      if (file.isEmpty()) {
+        throw new Exception("Please select a file to upload");
+      }
+      // Get the file's original name
+      String originalFileName = file.getOriginalFilename();
+
+      // Construct the path where you want to save the file
+      Path filePath = Paths.get(uploadsDirectory, originalFileName);
+
+      // Save the file to the specified location
+      file.transferTo(filePath.toFile());
+  }
+
+  private void createUploadsFolderIfNotExists() {
+    File uploadDir = new File(uploadsDirectory);
+    if (!uploadDir.exists()) {
+      uploadDir.mkdir();
+    }
+  }
+}

quartz-manager-parent/quartz-manager-web-showcase/src/main/resources/application.yml

@@ -1,3 +1,5 @@
+chista-scheduler:
+  uploadFolder: /Users/midhundarvin/workplace/uploads
 quartz-manager:
   jobClassPackages: it.fabioformosa.quartzmanager.jobs
   oas:
@@ -29,6 +31,11 @@ spring:
     cache: false
     mode: LEGACYHTML5
   jpa.open-in-view: false
+  servlet:
+    # application.properties
+    multipart:
+      max-file-size: 10MB
+      max-request-size: 10MB
 
 logging:
   level:

quartz-manager-parent/quartz-manager-web-showcase/src/main/resources/managed-quartz.properties

@@ -1,2 +1,3 @@
 org.quartz.scheduler.instanceName=example
+org.quartz.scheduler.isAutoStartup=true
 org.quartz.threadPool.threadCount=1

quartz-manager-parent/quartz-manager-web-showcase/src/test/java/it/fabioformosa/QuartManagerApplicationTests.java

@@ -4,6 +4,17 @@
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.web.WebAppConfiguration;
 
+import javax.script.ScriptContext;
+import javax.script.ScriptEngine;
+import javax.script.ScriptEngineManager;
+import javax.script.SimpleScriptContext;
+import java.io.FileReader;
+import java.io.StringWriter;
+import java.net.URL;
+import java.nio.file.Paths;
+
+import static org.springframework.test.util.AssertionErrors.assertEquals;
+
 @SpringBootTest(classes = QuartzManagerDemoApplication.class)
 @WebAppConfiguration
 class QuartManagerApplicationTests {
@@ -12,4 +23,17 @@ class QuartManagerApplicationTests {
     void contextLoads() {
     }
 
+  @Test
+  public void givenPythonScriptEngineIsAvailable_whenScriptInvoked_thenOutputDisplayed() throws Exception {
+    StringWriter writer = new StringWriter();
+    ScriptContext context = new SimpleScriptContext();
+    context.setWriter(writer);
+
+    ScriptEngineManager manager = new ScriptEngineManager();
+    ScriptEngine engine = manager.getEngineByName("python");
+    URL resource = getClass().getClassLoader().getResource("hello.py");
+    engine.eval(new FileReader(Paths.get(resource.toURI()).toFile()), context);
+    assertEquals("Should contain script output: ", "Hello Baeldung Readers!!", writer.toString().trim());
+  }
+
 }

quartz-manager-parent/quartz-manager-web-showcase/src/test/resources/hello.py

@@ -0,0 +1 @@
+print("Hello Baeldung Readers!!")