Refactor persistence (#113)

* save changes

* Fix tests

Author: carlosthe19916

pom.xml

@@ -40,7 +40,7 @@
         <!--Quarkus-->
         <quarkus.platform.group-id>io.quarkus.platform</quarkus.platform.group-id>
         <quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
-        <quarkus.platform.version>2.6.1.Final</quarkus.platform.version>
+        <quarkus.platform.version>2.6.2.Final</quarkus.platform.version>
 
         <!--plugings-->
         <maven.compiler.parameters>true</maven.compiler.parameters>

src/main/java/io/github/project/openubl/ublhub/builder/XMLBuilderManager.java

@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.github.project.openubl.ublhub.flyway;
+package io.github.project.openubl.ublhub.db;
 
 import io.quarkus.runtime.StartupEvent;
 import org.eclipse.microprofile.config.inject.ConfigProperty;

src/main/java/io/github/project/openubl/ublhub/flyway/RunFlyway.java renamed to src/main/java/io/github/project/openubl/ublhub/db/RunFlyway.java

@@ -16,9 +16,11 @@
  */
 package io.github.project.openubl.ublhub.files;
 
-import io.github.project.openubl.ublhub.exceptions.FetchFileException;
-import io.github.project.openubl.ublhub.exceptions.SaveFileException;
+import io.github.project.openubl.ublhub.files.exceptions.PersistFileException;
+import io.github.project.openubl.ublhub.files.exceptions.ReadFileException;
+import io.github.project.openubl.ublhub.keys.DefaultKeyManager;
 import io.smallrye.mutiny.Uni;
+import org.jboss.logging.Logger;
 
 import javax.enterprise.context.ApplicationScoped;
 import javax.inject.Inject;
@@ -27,20 +29,25 @@
 @ApplicationScoped
 public class FilesMutiny {
 
+    private static final Logger LOGGER = Logger.getLogger(DefaultKeyManager.class);
+
     @Inject
     FilesManager filesManager;
 
     public Uni<String> createFile(byte[] file, boolean shouldZipFile) {
-        return Uni.createFrom().item(file)
-                .onItem().ifNull().failWith(() -> new SaveFileException("Invalid body"))
-                .onItem().ifNotNull().transformToUni((bytes, uniEmitter) -> {
-                    try {
-                        String fileID = filesManager.createFile(file, shouldZipFile);
-                        uniEmitter.complete(fileID);
-                    } catch (Throwable e) {
-                        uniEmitter.fail(new SaveFileException(e));
-                    }
-                });
+        return Uni.createFrom().emitter((emitter) -> {
+            if (file == null) {
+                emitter.fail(new PersistFileException("Can not save null file"));
+            } else {
+                try {
+                    String fileID = filesManager.createFile(file, shouldZipFile);
+                    emitter.complete(fileID);
+                } catch (Throwable e) {
+                    LOGGER.error(e);
+                    emitter.fail(new PersistFileException(e));
+                }
+            }
+        });
     }
 
     public Uni<String> createFile(File file, boolean shouldZipFile) {
@@ -49,7 +56,8 @@ public Uni<String> createFile(File file, boolean shouldZipFile) {
                 String fileID = filesManager.createFile(file, shouldZipFile);
                 uniEmitter.complete(fileID);
             } catch (Throwable e) {
-                uniEmitter.fail(new SaveFileException(e));
+                LOGGER.error(e);
+                uniEmitter.fail(new PersistFileException(e));
             }
         });
     }
@@ -60,7 +68,8 @@ public Uni<byte[]> getFileAsBytesAfterUnzip(String fileID) {
                 byte[] file = filesManager.getFileAsBytesAfterUnzip(fileID);
                 uniEmitter.complete(file);
             } catch (Throwable e) {
-                uniEmitter.fail(new FetchFileException(e));
+                LOGGER.error(e);
+                uniEmitter.fail(new ReadFileException(e));
             }
         });
     }
@@ -71,7 +80,8 @@ public Uni<byte[]> getFileAsBytesWithoutUnzipping(String fileID) {
                 byte[] file = filesManager.getFileAsBytesWithoutUnzipping(fileID);
                 uniEmitter.complete(file);
             } catch (Throwable e) {
-                uniEmitter.fail(new FetchFileException(e));
+                LOGGER.error(e);
+                uniEmitter.fail(new ReadFileException(e));
             }
         });
     }
@@ -82,7 +92,8 @@ public Uni<String> getFileLink(String fileID) {
                 String fileLink = filesManager.getFileLink(fileID);
                 uniEmitter.complete(fileLink);
             } catch (Throwable e) {
-                uniEmitter.fail(new FetchFileException(e));
+                LOGGER.error(e);
+                uniEmitter.fail(new ReadFileException(e));
             }
         });
     }
@@ -93,7 +104,8 @@ public Uni<Void> delete(String fileID) {
                 filesManager.delete(fileID);
                 uniEmitter.complete(null);
             } catch (Throwable e) {
-                uniEmitter.fail(new FetchFileException(e));
+                LOGGER.error(e);
+                uniEmitter.fail(new PersistFileException(e));
             }
         });
     }

src/main/java/io/github/project/openubl/ublhub/exceptions/AbstractSendFileException.java

@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.github.project.openubl.ublhub.exceptions;
+package io.github.project.openubl.ublhub.files.exceptions;
 
-public class EntityOperationException extends Exception {
-    public EntityOperationException(Throwable e) {
+public class PersistFileException extends Exception {
+    public PersistFileException(Throwable e) {
         super(e);
     }
 
-    public EntityOperationException(String message) {
+    public PersistFileException(String message) {
         super(message);
     }
 }

src/main/java/io/github/project/openubl/ublhub/exceptions/FetchFileException.java

@@ -14,10 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.github.project.openubl.ublhub.exceptions;
+package io.github.project.openubl.ublhub.files.exceptions;
 
-public class CheckTicketAtSUNATException extends AbstractSendFileException {
-    public CheckTicketAtSUNATException(String message) {
+public class ReadFileException extends Exception {
+    public ReadFileException(Throwable e) {
+        super(e);
+    }
+
+    public ReadFileException(String message) {
         super(message);
     }
 }