Change sorting logic and refactor code.

src/main/scala/Main.scala

@@ -3,7 +3,7 @@ import com.typesafe.config.{Config, ConfigFactory}
 import scala.xml._
 import scala.xml._
 import java.nio.file.{Files, Paths, StandardOpenOption}
 import java.nio.file.{Files, Paths, StandardOpenOption}
 import java.io.{File, FileInputStream, InputStream}
 import java.io.{File, FileInputStream, InputStream}
-import java.util.zip.ZipFile
+import java.util.zip.{ZipEntry, ZipFile}
 import java.time.LocalDateTime
 import java.time.LocalDateTime
 
 
 import scala.util.{Failure, Success, Try}
 import scala.util.{Failure, Success, Try}
@@ -35,74 +35,102 @@ object Main {
         .filter {
         .filter {
           !_.isDirectory
           !_.isDirectory
         }
         }
-        .sortBy {
-          _.lastModified
-        }
 
 
-      val start = LocalDateTime.now().toString
-
-      val successSourcesName = s"${args(0)}/${start}_success"
-      val successSources = new File(successSourcesName)
-      val errorSourcesName = s"${args(0)}/${start}_error"
-      val errorSources = new File(errorSourcesName)
-
-      if (successSources.mkdir() && errorSources.mkdir()) {
-
-        for (f <- files) {
-          val fSourceName = f.getName
-          val fSourceNameArray = fSourceName.split('.')
-          val fSourceNameExtension = fSourceNameArray.last.toLowerCase
-          val now = LocalDateTime.now().toString
-
-          if (fSourceNameExtension == "zip") Try {
-            val fZip = new ZipFile(f)
-            val fZipEntries = fZip.entries
-
-            while (fZipEntries.hasMoreElements) {
-              val e = fZipEntries.nextElement
-              if (!e.isDirectory) {
-                val fZipEntryName = e.getName
-                val nowForZip = LocalDateTime.now().toString
-
-                Try {
-                  convert(
-                    fZip.getInputStream(e),
-                    s"${fSourceName}_$fZipEntryName",
-                    s"Converted_${fSourceName}_$fZipEntryName",
-                    nsdXmlValid,
-                    rtsXmlValid,
-                    p)
-                } match {
-                  case Success((oXml, ti)) =>
-                    XML.save(Paths.get(args(1), s"Converted_${fSourceName}_$fZipEntryName").toString, oXml, xmlDecl = true)
-                    logString += s"$nowForZip\n$ti"
-                    Files.copy(fZip.getInputStream(e), Paths.get(successSourcesName, s"${fSourceName}_$fZipEntryName"))
-                  case Failure(ex) =>
-                    logString += s"'$nowForZip\nImpossible to convert '${fSourceName}_$fZipEntryName': ${ex.getMessage}\n\n"
-                    Files.copy(fZip.getInputStream(e), Paths.get(errorSourcesName, s"${fSourceName}_$fZipEntryName"))
-                }
+      val start = LocalDateTime.now.toString
+
+      val sourceNameValidated = s"${args(0)}/${start}_validated"
+      val sourceValidated = new File(sourceNameValidated)
+      val sourceNameNotValidated = s"${args(0)}/${start}_not_validated"
+      val sourceNotValidated = new File(sourceNameNotValidated)
+      val sourceNameError = s"${args(0)}/${start}_error"
+      val sourceError = new File(sourceNameError)
+
+      val outputNameValidated = s"${args(1)}/${start}_validated"
+      val outputValidated = new File(outputNameValidated)
+      val outputNameNotValidated = s"${args(1)}/${start}_not_validated"
+      val outputNotValidated = new File(outputNameNotValidated)
+
+      if (sourceValidated.mkdir
+        && sourceNotValidated.mkdir
+        && sourceError.mkdir
+        && outputValidated.mkdir
+        && outputNotValidated.mkdir) {
+
+        val sourceArray = {
+          for (f <- files) yield {
+            val name = f.getName
+            val ext = name.split('.').last.toLowerCase
+
+            if (ext == "zip") {
+              Try {
+                val zip = new ZipFile(f)
+
+                zip.stream.toArray
+                  .map {
+                    z => z.asInstanceOf[ZipEntry]
+                  }
+                  .map {
+                    e =>
+                      FileEntry(
+                        s"${name}_${e.getName}",
+                        e.getLastModifiedTime.toMillis,
+                        Some(zip.getInputStream(e)),
+                        zip.getInputStream(e),
+                        None)
+                  }
+              } match {
+                case Success(v) =>
+                  v
+                case Failure(ex) =>
+                  Array(FileEntry(name, f.lastModified, None, new FileInputStream(f), Some(ex.getMessage)))
               }
               }
-            }
-          } match {
-            case Success(_) =>
-            case Failure(ex) => logString += s"'$now\nImpossible to convert '$fSourceName': ${ex.getMessage}\n\n"
+            } else
+              Array(FileEntry(name, f.lastModified, Some(new FileInputStream(f)), new FileInputStream(f), None))
           }
           }
-          else Try {
-            convert(
-              new FileInputStream(f),
-              s"$fSourceName",
-              s"Converted_$fSourceName",
-              nsdXmlValid,
-              rtsXmlValid,
-              p)
-          } match {
-            case Success((oXml, ti)) =>
-              XML.save(Paths.get(args(1), s"Converted_$fSourceName").toString, oXml, xmlDecl = true)
-              logString += s"$now\n$ti"
-              Files.copy(f.toPath, Paths.get(successSourcesName, f.getName))
-            case Failure(ex) =>
-              logString += s"'$now\nImpossible to convert '$fSourceName': ${ex.getMessage}\n\n"
-              Files.copy(f.toPath, Paths.get(errorSourcesName, f.getName))
+        }
+          .flatten
+          .sortWith { (a, b) => (a.modified == b.modified && a.name <= b.name) || (a.modified < b.modified) }
+
+        for (f <- sourceArray) {
+          val now = LocalDateTime.now.toString
+
+          f.msg match {
+            case Some(msg) =>
+              logString += s"$now\nImpossible to convert '${f.name}': $msg\n\n"
+              Files.copy(f.streamMove, Paths.get(sourceNameError, f.name))
+
+            case None =>
+              Try {
+                convert(
+                  f.streamConvert.get,
+                  f.name,
+                  s"converted_${f.name}",
+                  nsdXmlValid,
+                  rtsXmlValid,
+                  p)
+              } match {
+                case Success((oXml, ti)) if ti.contains("isn`t wellformed or invalid") =>
+                  XML.save(
+                    Paths.get(outputNameNotValidated, s"converted_${f.name}").toString,
+                    oXml,
+                    xmlDecl = true
+                  )
+                  logString += s"$now\n$ti"
+                  Files.copy(f.streamMove, Paths.get(sourceNameNotValidated, f.name))
+
+                case Success((oXml, ti)) =>
+                  XML.save(
+                    Paths.get(outputNameValidated, s"converted_${f.name}").toString,
+                    oXml,
+                    xmlDecl = true
+                  )
+                  logString += s"$now\n$ti"
+                  Files.copy(f.streamMove, Paths.get(sourceNameValidated, f.name))
+
+                case Failure(ex) =>
+                  logString += s"$now\nImpossible to convert '${f.name}': ${ex.getMessage}\n\n"
+                  Files.copy(f.streamMove, Paths.get(sourceNameError, f.name))
+              }
           }
           }
         }
         }
 
 
@@ -115,18 +143,22 @@ object Main {
             StandardOpenOption.CREATE,
             StandardOpenOption.CREATE,
             StandardOpenOption.TRUNCATE_EXISTING)
             StandardOpenOption.TRUNCATE_EXISTING)
 
 
-          if (successSources.listFiles.nonEmpty)
-            Files.copy(Paths.get(args(0), logFileName), Paths.get(successSourcesName, logFileName))
+          if (sourceValidated.listFiles.nonEmpty)
+            Files.copy(Paths.get(args(0), logFileName), Paths.get(sourceNameValidated, logFileName))
           else
           else
-            successSources.delete
+            sourceValidated.delete
+
+          if (sourceNotValidated.listFiles.isEmpty) sourceNotValidated.delete
+          if (sourceError.listFiles.isEmpty) sourceError.delete
+          if (outputValidated.listFiles.isEmpty) outputValidated.delete
+          if (outputNotValidated.listFiles.isEmpty) outputNotValidated.delete
 
 
-          if (errorSources.listFiles.isEmpty) errorSources.delete
         } match {
         } match {
           case Success(_) => println(s"Converting has been finished. $logFileName located in ${args(0)}")
           case Success(_) => println(s"Converting has been finished. $logFileName located in ${args(0)}")
           case Failure(ex) => println(s"Error. Converting hasn`t been finished: ${ex.getMessage}")
           case Failure(ex) => println(s"Error. Converting hasn`t been finished: ${ex.getMessage}")
         }
         }
       } else
       } else
-        println(s"Error. Converting hasn`t been finished: unable to create source moving directory.")
+        println(s"Error. Converting hasn`t been finished: unable to create moving directories.")
     }
     }
   }
   }
 
 
@@ -211,4 +243,12 @@ object Main {
 
 
     (outputXml, template.info(s"$msgCheckSource\n$msgCheckOutput") + "\n\n")
     (outputXml, template.info(s"$msgCheckSource\n$msgCheckOutput") + "\n\n")
   }
   }
+
+  case class FileEntry(
+      name: String,
+      modified: Long,
+      streamConvert: Option[InputStream],
+      streamMove: InputStream,
+      msg: Option[String]
+  )
 }
 }