Added component's metadata @annotations.

Author: lorenzo

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

@@ -2,26 +2,33 @@
 
 import com.reedelk.file.internal.attribute.FileAttribute;
 import com.reedelk.file.internal.exception.FileDeleteException;
+import com.reedelk.file.internal.exception.NotValidFileException;
 import com.reedelk.runtime.api.annotation.*;
 import com.reedelk.runtime.api.component.ProcessorSync;
 import com.reedelk.runtime.api.flow.FlowContext;
 import com.reedelk.runtime.api.message.Message;
-import com.reedelk.runtime.api.message.MessageAttributes;
 import com.reedelk.runtime.api.message.MessageBuilder;
+import com.reedelk.runtime.api.message.content.MimeType;
 import com.reedelk.runtime.api.script.ScriptEngineService;
 import com.reedelk.runtime.api.script.dynamicvalue.DynamicString;
 import org.osgi.service.component.annotations.Component;
 import org.osgi.service.component.annotations.Reference;
 import org.osgi.service.component.annotations.ServiceScope;
 
 import java.nio.file.Files;
+import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.Optional;
 
 import static com.reedelk.file.internal.commons.Messages.FileDelete.ERROR_FILE_DELETE;
+import static com.reedelk.file.internal.commons.Messages.FileDelete.FILE_NAME_ERROR;
 import static com.reedelk.runtime.api.commons.ComponentPrecondition.Configuration.requireNotNull;
 
 @ModuleComponent("File Delete")
+@ComponentOutput(
+        attributes = FileAttribute.class,
+        payload = String.class,
+        description = "The path and name of the deleted file.")
 @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.")
@@ -45,23 +52,25 @@ public void initialize() {
     @Override
     public Message apply(FlowContext flowContext, Message message) {
         return service.evaluate(fileName, flowContext, message).flatMap(evaluatedFileNameToRemove -> {
+            Path filePathToDelete;
             try {
-                Files.delete(Paths.get(evaluatedFileNameToRemove));
+                filePathToDelete = Paths.get(evaluatedFileNameToRemove);
+                Files.delete(filePathToDelete);
             } catch (Exception exception) {
                 String errorMessage = ERROR_FILE_DELETE.format(exception.getMessage());
                 throw new FileDeleteException(errorMessage, exception);
             }
 
-            MessageAttributes attributes = new FileAttribute(evaluatedFileNameToRemove);
+            FileAttribute attributes = new FileAttribute(evaluatedFileNameToRemove);
 
             Message outMessage = MessageBuilder.get(FileDelete.class)
                     .attributes(attributes)
-                    .empty()
+                    .withString(filePathToDelete.toString(), MimeType.TEXT_PLAIN)
                     .build();
 
             return Optional.of(outMessage);
 
-        }).orElse(MessageBuilder.get(FileDelete.class).empty().build());
+        }).orElseThrow(() -> new NotValidFileException(FILE_NAME_ERROR.format(fileName.toString())));
     }
 
     public void setFileName(DynamicString fileName) {

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

@@ -7,7 +7,6 @@
 import com.reedelk.runtime.api.component.ProcessorSync;
 import com.reedelk.runtime.api.flow.FlowContext;
 import com.reedelk.runtime.api.message.Message;
-import com.reedelk.runtime.api.message.MessageAttributes;
 import com.reedelk.runtime.api.message.MessageBuilder;
 import com.reedelk.runtime.api.script.ScriptEngineService;
 import com.reedelk.runtime.api.script.dynamicvalue.DynamicString;
@@ -25,6 +24,10 @@
 
 
 @ModuleComponent("File Exists")
+@ComponentOutput(
+        attributes = FileAttribute.class,
+        payload = boolean.class,
+        description = "True if the file exists, false otherwise.")
 @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)
@@ -75,7 +78,7 @@ public Message apply(FlowContext flowContext, Message message) {
                 return message;
 
             } else {
-                MessageAttributes attributes = new FileAttribute(path.toString());
+                FileAttribute attributes = new FileAttribute(path.toString());
                 return MessageBuilder.get(FileExists.class)
                         .attributes(attributes)
                         .withJavaObject(exists)

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

@@ -8,7 +8,6 @@
 import com.reedelk.runtime.api.component.ProcessorSync;
 import com.reedelk.runtime.api.flow.FlowContext;
 import com.reedelk.runtime.api.message.Message;
-import com.reedelk.runtime.api.message.MessageAttributes;
 import com.reedelk.runtime.api.message.MessageBuilder;
 import com.reedelk.runtime.api.message.content.MimeType;
 import com.reedelk.runtime.api.script.ScriptEngineService;
@@ -26,7 +25,11 @@
 import static com.reedelk.runtime.api.commons.StringUtils.isBlank;
 
 @ModuleComponent("File Read")
-@Description("Reads a file from the file system from the given File name and optionally provided Base path. " +
+@ComponentOutput(
+        attributes = FileAttribute.class,
+        payload = byte[].class,
+        description = "The content of the file read from the file system from the given path and file name.")
+@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. " +
                 "The component can also be configured to acquire a lock before reading the file.")
@@ -100,7 +103,7 @@ public Message apply(FlowContext flowContext, Message message) {
 
             ReadConfigurationDecorator config = new ReadConfigurationDecorator(configuration);
 
-            MessageAttributes attributes = new FileAttribute(path.toString());
+            FileAttribute attributes = new FileAttribute(path.toString());
 
             Publisher<byte[]> data = strategy.read(path, config);
 

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

@@ -1,5 +1,6 @@
 package com.reedelk.file.component;
 
+import com.reedelk.file.internal.attribute.FileAttribute;
 import com.reedelk.file.internal.exception.FileWriteException;
 import com.reedelk.file.internal.write.WriteConfiguration;
 import com.reedelk.file.internal.write.WriteMode;
@@ -29,6 +30,9 @@
 import static com.reedelk.runtime.api.commons.StringUtils.isBlank;
 
 @ModuleComponent("File Write")
+@ComponentOutput(
+        attributes = FileAttribute.class,
+        payload = Void.class)
 @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.")

src/main/java/com/reedelk/file/internal/commons/Messages.java

@@ -47,6 +47,7 @@ public String template() {
 
     public enum FileDelete implements FormattedMessage {
 
+        FILE_NAME_ERROR("Could not evaluate file with with name=[%s]"),
         ERROR_FILE_DELETE("The file could not be deleted, cause=[%s].");
 
         private String message;

src/main/java/com/reedelk/file/internal/write/Writer.java

@@ -10,7 +10,6 @@
 import com.reedelk.runtime.api.component.OnResult;
 import com.reedelk.runtime.api.flow.FlowContext;
 import com.reedelk.runtime.api.message.Message;
-import com.reedelk.runtime.api.message.MessageAttributes;
 import com.reedelk.runtime.api.message.MessageBuilder;
 import com.reedelk.runtime.api.message.content.TypedPublisher;
 import reactor.core.Exceptions;
@@ -111,7 +110,7 @@ public void write(WriteConfiguration config, FlowContext flowContext, OnResult c
         }).doOnSuccess(initial -> {
 
             // On success build the message and invoke the callback.
-            MessageAttributes attributes = new FileAttribute(path.toString());
+            FileAttribute attributes = new FileAttribute(path.toString());
 
             Message outMessage = MessageBuilder.get(FileWrite.class)
                     .attributes(attributes)