code

Author: lorenzo

src/main/java/com/reedelk/file/component/FileDelete.java

@@ -29,6 +29,9 @@
         attributes = FileAttribute.class,
         payload = String.class,
         description = "The path and name of the deleted file.")
+@ComponentInput(
+        payload = Object.class,
+        description = "The input payload is used to evaluate the file name to delete.")
 @Description("Deletes a file from the file system with the given File name. " +
                 "An error is raised if the given file could not be found. " +
                 "The file name can be a dynamic expression.")
@@ -51,11 +54,16 @@ public void initialize() {
 
     @Override
     public Message apply(FlowContext flowContext, Message message) {
+
         return service.evaluate(fileName, flowContext, message).flatMap(evaluatedFileNameToRemove -> {
             Path filePathToDelete;
+
             try {
+
                 filePathToDelete = Paths.get(evaluatedFileNameToRemove);
+
                 Files.delete(filePathToDelete);
+
             } catch (Exception exception) {
                 String errorMessage = ERROR_FILE_DELETE.format(exception.getMessage());
                 throw new FileDeleteException(errorMessage, exception);

src/main/java/com/reedelk/file/component/FileExists.java

@@ -28,6 +28,9 @@
         attributes = FileAttribute.class,
         payload = boolean.class,
         description = "True if the file exists, false otherwise.")
+@ComponentInput(
+        payload = Object.class,
+        description = "The input payload is used to evaluate the file name to check for existence.")
 @Description("The File Exists component Tests whether a file with the given path exists. " +
         "The file path can be a text only or dynamic expression.")
 @Component(service = FileExists.class, scope = ServiceScope.PROTOTYPE)

src/main/java/com/reedelk/file/component/FileRead.java

@@ -29,6 +29,9 @@
         attributes = FileAttribute.class,
         payload = byte[].class,
         description = "The content of the file read from the file system from the given path and file name.")
+@ComponentInput(
+        payload = Object.class,
+        description = "The input payload is used to evaluate the file name to read.")
 @Description("Reads a file from the file system from the given file name and optionally provided base path. " +
                 "The file read strategy determines if the file should be streamed from the file system or " +
                 "loaded into memory before continuing with the execution of the flow. " +

src/main/java/com/reedelk/file/component/FileWrite.java

@@ -33,6 +33,9 @@
 @ComponentOutput(
         attributes = FileAttribute.class,
         payload = Void.class)
+@ComponentInput(
+        payload = Object.class,
+        description = "The input payload is used to evaluate the file name to write.")
 @Description("Writes a file to the file system to the given File name and optionally provided Base path. " +
                 "The write mode can be used to override an existing file, create new file if it does not exists " +
                 "or append to the existing file if exists already.")
@@ -43,7 +46,7 @@ public class FileWrite implements ProcessorAsync {
     @Hint("/var/logs/log1.txt")
     @Example("/var/logs/log1.txt")
     @Description("The path and name of the file to be written on the file system.")
-    private DynamicString filePath;
+    private DynamicString fileName;
 
     @Property("Base path")
     @Hint("/var/logs")
@@ -74,7 +77,7 @@ public class FileWrite implements ProcessorAsync {
     public void apply(FlowContext flowContext, Message message, OnResult callback) {
 
 
-        Optional<String> evaluated = scriptService.evaluate(filePath, flowContext, message);
+        Optional<String> evaluated = scriptService.evaluate(fileName, flowContext, message);
 
         if (evaluated.isPresent()) {
 
@@ -110,8 +113,8 @@ public void apply(FlowContext flowContext, Message message, OnResult callback) {
         }
     }
 
-    public void setFilePath(DynamicString filePath) {
-        this.filePath = filePath;
+    public void setFileName(DynamicString fileName) {
+        this.fileName = fileName;
     }
 
     public void setBasePath(String basePath) {