Fdariasm/#415 generalized csv reader 4ci

src/main/scala/beam/agentsim/infrastructure/ZonalParkingManager.scala

@@ -14,7 +14,7 @@ import beam.agentsim.infrastructure.TAZTreeMap.TAZ
 import beam.agentsim.infrastructure.ZonalParkingManager.ParkingAlternative
 import beam.router.BeamRouter.Location
 import beam.sim.{BeamServices, HasServices}
-import beam.utils.CsvUtils
+import beam.utils.{FileUtils}
 import org.matsim.api.core.v01.Id
 import org.supercsv.cellprocessor.ift.CellProcessor
 import org.supercsv.io.{CsvMapReader, CsvMapWriter, ICsvMapReader, ICsvMapWriter}
@@ -321,11 +321,9 @@ class ZonalParkingManager(
   def selectStallWithCharger(inquiry: ParkingInquiry, startRadius: Double): ParkingStall = ???
 
   def readCsvFile(filePath: String): mutable.Map[StallAttributes, StallValues] = {
-    var mapReader: ICsvMapReader = null
     val res: mutable.Map[StallAttributes, StallValues] = mutable.Map()
-    try {
-      mapReader =
-        new CsvMapReader(CsvUtils.readerFromFile(filePath), CsvPreference.STANDARD_PREFERENCE)
+
+    FileUtils.using(new CsvMapReader(FileUtils.readerFromFile(filePath), CsvPreference.STANDARD_PREFERENCE)) { mapReader =>
       val header = mapReader.getHeader(true)
       var line: java.util.Map[String, String] = mapReader.read(header: _*)
       while (null != line) {
@@ -347,10 +345,6 @@ class ZonalParkingManager(
 
         line = mapReader.read(header: _*)
       }
-
-    } finally {
-      if (null != mapReader)
-        mapReader.close()
     }
     res
   }

src/main/scala/beam/utils/FileUtils.scala

@@ -85,7 +85,11 @@ object FileUtils extends LazyLogging {
     }
 
   def safeLines(fileLoc: String): stream.Stream[String] = {
-    using(CsvUtils.readerFromFile(fileLoc))(_.lines)
+    using(readerFromFile(fileLoc))(_.lines)
+  }
+
+  def readerFromFile(filePath: String): java.io.BufferedReader = {
+    IOUtils.getBufferedReader(filePath)
   }
 
   def downloadFile(source: String): Unit = {
@@ -97,4 +101,9 @@ object FileUtils extends LazyLogging {
     assert(target != null)
     copyURLToFile(new URL(source), Paths.get(target).toFile)
   }
+
+  def getHash(concatParams: Any*): Int = {
+    val concatString = concatParams.foldLeft("")(_ + _)
+    concatString.hashCode
+  }
 }

src/test/scala/beam/integration/ParkingSpec.scala

@@ -16,7 +16,19 @@ import beam.agentsim.events.{
   ParkEventAttrs,
   PathTraversalEvent
 }
+import java.io.File
+
+import beam.agentsim.events.{LeavingParkingEventAttrs, ModeChoiceEvent, ParkEventAttrs, PathTraversalEvent}
 import beam.sim.BeamHelper
+import com.typesafe.config.ConfigValueFactory
+import org.apache.commons.io.FileUtils
+import org.matsim.api.core.v01.events.Event
+import org.matsim.core.events.{EventsUtils, MatsimEventsReader}
+import org.matsim.core.events.handler.BasicEventHandler
+import org.scalatest.{BeforeAndAfterAll, Matchers, WordSpecLike}
+
+import scala.collection.immutable.Queue
+import scala.collection.mutable.ArrayBuffer
 
 class ParkingSpec
     extends WordSpecLike
@@ -71,19 +83,24 @@ class ParkingSpec
       )
       .resolve()
 
-    val matsimConfig = runBeamWithConfig(config)._1
+    val (matsimConfig, outputDirectory) = runBeamWithConfig(config)
+
     val queueEvents = ArrayBuffer[Queue[Event]]()
     for (i <- 0 until iterations) {
       val filePath = getEventsFilePath(matsimConfig, "xml", i).getAbsolutePath
       queueEvents.append(collectEvents(filePath))
     }
+
+    val outputDirectoryFile = new File(outputDirectory)
+    FileUtils.copyDirectory(outputDirectoryFile, new File(s"${outputDirectory}_$parkingScenario"))
+
     queueEvents
   }
 
-  lazy val limitedEvents = runAndCollectForIterations("limited", 10)
-  lazy val defaultEvents = runAndCollectForIterations("default", 10)
-  lazy val expensiveEvents = runAndCollectForIterations("expensive", 10)
-  lazy val emptyEvents = runAndCollectForIterations("empty", 10)
+  val limitedEvents = runAndCollectForIterations("limited", 10)
+  val defaultEvents = runAndCollectForIterations("default", 10)
+  val expensiveEvents = runAndCollectForIterations("expensive", 10)
+  val emptyEvents = runAndCollectForIterations("empty", 10)
 
   val filterForCarMode: Seq[Event] => Int = { events =>
     events.count { e =>