Merge pull request #33 from bitrockteam/feature/rename-to-dvs

Replace flightstream occurrencies with dvs
bitrockteam · Jan 15, 2020 · 0d8dcdb · 0d8dcdb
2 parents 62efe6a + 240e5fe
commit 0d8dcdb
Show file tree

Hide file tree

Showing 28 changed files with 85 additions and 85 deletions.
diff --git a/Dockerfile b/Dockerfile
@@ -19,7 +19,7 @@ COPY .scalafmt.conf .
 RUN sbt compile && \
   sbt test && \
   sbt universal:packageBin && \
-  mv "target/universal/kafka-flightstream-producer-$(sbt -no-colors version | tail -1 | cut -d ' ' -f 2).zip" /app.zip
+  mv "target/universal/kafka-dvs-producer-$(sbt -no-colors version | tail -1 | cut -d ' ' -f 2).zip" /app.zip
 
 # end of build stage
 
@@ -32,6 +32,6 @@ ENV JAVA_OPTS="-Xmx512m"
 COPY --from=sbt-build /app.zip .
 RUN unzip app.zip
 
-RUN chmod u+x bin/kafka-flightstream-producer
+RUN chmod u+x bin/kafka-dvs-producer
 
-ENTRYPOINT ["./bin/kafka-flightstream-producer"]
+ENTRYPOINT ["./bin/kafka-dvs-producer"]
diff --git a/Jenkinsfile b/Jenkinsfile
@@ -5,7 +5,7 @@ pipeline {
         AWS_REGION = 'eu-west-1'
         GITHUB_CREDENTIALS = 'BitrockCI token'
         GITHUB_ACCOUNT = 'bitrockteam'
-        GITHUB_REPO = 'kafka-flightstream-producer'
+        GITHUB_REPO = 'kafka-dvs-producer'
         GITHUB_SSH = "centos"
         RELEASE_BRANCH = "master"
         SBT_OPTS="-Xmx2048M"
@@ -96,7 +96,7 @@ pipeline {
                         sh "docker push ${DOCKER_REPOSITORY}/${GITHUB_REPO}:${tagAfter}"
                         sh "docker tag ${DOCKER_REPOSITORY}/${GITHUB_REPO}:${tagAfter} ${DOCKER_REPOSITORY}/${GITHUB_REPO}:latest"
                         sh "docker push ${DOCKER_REPOSITORY}/${GITHUB_REPO}:latest"
-                        sh "printf '[{\"name\":\"kafka-flightstream-producer\",\"imageUri\":\"%s\"}]' \$(git describe --tags --abbrev=0 | sed 's/^v//') > imagedefinitions.json"
+                        sh "printf '[{\"name\":\"kafka-dvs-producer\",\"imageUri\":\"%s\"}]' \$(git describe --tags --abbrev=0 | sed 's/^v//') > imagedefinitions.json"
                     }
                 }
             }
@@ -111,7 +111,7 @@ pipeline {
                 }
             }
             steps {
-		build job: 'kafka-flightstream-cd/master', 
+		build job: 'kafka-dvs-cd/master',
 			    parameters: [[$class: 'StringParameterValue', name: 'deployment', value: "${GITHUB_REPO}@${tagAfter}"]],
 			    wait: false
 	    }

diff --git a/README.md b/README.md
@@ -1,4 +1,4 @@
-# FlightStream Producer
+# DVS Producer
 
 ## Configuration
 
@@ -13,7 +13,7 @@ The application references the following environment variables:
 
 ### Resolvers
 
-Some dependencies are downloaded from a private Nexus repository. Make sure to provide a `~/.sbt/.credentials.flightstream` file containing valid credentials:
+Some dependencies are downloaded from a private Nexus repository. Make sure to provide a `~/.sbt/.credentials.bitrock` file containing valid credentials:
 
 ```properties
 realm=Sonatype Nexus Repository Manager

diff --git a/build.sbt b/build.sbt
@@ -24,7 +24,7 @@ lazy val compileSettings = Seq(
 lazy val dependenciesSettings = Seq(
   credentials ++= Seq(
     baseDirectory.value / ".sbt" / ".credentials",
-    Path.userHome / ".sbt" / ".credentials.flightstream"
+    Path.userHome / ".sbt" / ".credentials.bitrock"
   ).collect {
     case c if c.exists => Credentials(c)
   },
@@ -57,8 +57,8 @@ lazy val testSettings = Seq(
 
 lazy val root = (project in file("."))
   .settings(
-    name := "kafka-flightstream-producer",
-    organization := "it.bitrock.kafkaflightstream"
+    name := "kafka-dvs-producer",
+    organization := "it.bitrock.dvs"
   )
   .settings(compileSettings: _*)
   .settings(dependenciesSettings: _*)

diff --git a/dev/start_services.sh b/dev/start_services.sh
@@ -4,7 +4,7 @@ echo -e "Building and starting the services...\n" >&2
 sleep 1
 
 docker-compose build && \
-  docker-compose up -d kafka-flightstream-producer kafka-flightstream-streams
+  docker-compose up -d kafka-dvs-producer kafka-dvs-streams
 
 docker_cmd_status=$?
 

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -20,13 +20,13 @@ object Dependencies {
     lazy val ConfluentPlatform = "5.1.0"
     lazy val JakartaWsRs       = "2.1.4"
     lazy val Kafka             = "2.1.0"
-    lazy val KafkaCommons      = "0.0.3"
-    lazy val KafkaFlightStream = "0.1.11"
+    lazy val KafkaCommons      = "0.0.5"
+    lazy val KafkaDVS          = "0.1.14"
     lazy val LogbackClassic    = "1.2.3"
     lazy val PureConfig        = "0.10.2"
     lazy val ScalaLogging      = "3.9.2"
     lazy val Slf4j             = "1.7.26"
-    lazy val TestCommons       = "0.0.3"
+    lazy val TestCommons       = "0.0.5"
 
   }
 
@@ -46,23 +46,23 @@ object Dependencies {
   }
 
   lazy val prodDeps: Seq[ModuleID] = Seq(
-    "com.github.pureconfig"        %% "pureconfig"                      % Versions.PureConfig,
-    "com.typesafe.akka"            %% "akka-http"                       % Versions.AkkaHttp,
-    "com.typesafe.akka"            %% "akka-stream"                     % Versions.Akka,
-    "com.typesafe.akka"            %% "akka-http-spray-json"            % Versions.AkkaHttp,
-    "io.confluent"                 % "kafka-avro-serializer"            % Versions.ConfluentPlatform,
-    "it.bitrock.kafkaflightstream" %% "kafka-flightstream-avro-schemas" % Versions.KafkaFlightStream,
-    "it.bitrock.kafkageostream"    %% "kafka-commons"                   % Versions.KafkaCommons,
-    "org.apache.kafka"             % "kafka-clients"                    % Versions.Kafka,
-    "com.typesafe.akka"            %% "akka-stream-kafka"               % Versions.Alpakka
+    "com.github.pureconfig" %% "pureconfig"             % Versions.PureConfig,
+    "com.typesafe.akka"     %% "akka-http"              % Versions.AkkaHttp,
+    "com.typesafe.akka"     %% "akka-stream"            % Versions.Akka,
+    "com.typesafe.akka"     %% "akka-http-spray-json"   % Versions.AkkaHttp,
+    "io.confluent"          % "kafka-avro-serializer"   % Versions.ConfluentPlatform,
+    "it.bitrock.dvs"        %% "kafka-dvs-avro-schemas" % Versions.KafkaDVS,
+    "it.bitrock"            %% "kafka-commons"          % Versions.KafkaCommons,
+    "org.apache.kafka"      % "kafka-clients"           % Versions.Kafka,
+    "com.typesafe.akka"     %% "akka-stream-kafka"      % Versions.Alpakka
   ) ++ Logging.prodDeps
 
   lazy val testDeps: Seq[ModuleID] = Seq(
-    "com.typesafe.akka"         %% "akka-http-testkit"              % Versions.AkkaHttp,
-    "com.typesafe.akka"         %% "akka-stream-testkit"            % Versions.Akka,
-    "io.github.embeddedkafka"   %% "embedded-kafka-schema-registry" % Versions.ConfluentPlatform,
-    "jakarta.ws.rs"             % "jakarta.ws.rs-api"               % Versions.JakartaWsRs, // mandatory when javax.ws.rs-api gets excluded
-    "it.bitrock.kafkageostream" %% "test-commons"                   % Versions.TestCommons
+    "com.typesafe.akka"       %% "akka-http-testkit"              % Versions.AkkaHttp,
+    "com.typesafe.akka"       %% "akka-stream-testkit"            % Versions.Akka,
+    "io.github.embeddedkafka" %% "embedded-kafka-schema-registry" % Versions.ConfluentPlatform,
+    "jakarta.ws.rs"           % "jakarta.ws.rs-api"               % Versions.JakartaWsRs, // mandatory when javax.ws.rs-api gets excluded
+    "it.bitrock"              %% "test-commons"                   % Versions.TestCommons
   ).map(_ % Test)
 
   lazy val excludeDeps: Seq[ExclusionRule] = Seq(

diff --git a/src/main/resources/application.conf b/src/main/resources/application.conf
@@ -19,7 +19,7 @@ kafka {
   city-raw-topic = "city_raw"
 }
 
-application-id = "kafka-flightstream-producer"
+application-id = "kafka-dvs-producer"
 
 aviation {
   host = ""

diff --git a/...ock/kafkaflightstream/producer/Main.scala → .../scala/it/bitrock/dvs/producer/Main.scala b/...ock/kafkaflightstream/producer/Main.scala → .../scala/it/bitrock/dvs/producer/Main.scala
@@ -1,17 +1,17 @@
-package it.bitrock.kafkaflightstream.producer
+package it.bitrock.dvs.producer
 
 import akka.actor.ActorSystem
 import akka.stream.ActorMaterializer
 import com.typesafe.scalalogging.LazyLogging
-import it.bitrock.kafkaflightstream.producer.model._
-import it.bitrock.kafkaflightstream.producer.services.MainFunctions._
+import it.bitrock.dvs.producer.model._
+import it.bitrock.dvs.producer.services.MainFunctions._
 
 import scala.concurrent.duration._
 import scala.concurrent.{Await, ExecutionContext}
 
 object Main extends App with LazyLogging {
 
-  implicit val system: ActorSystem    = ActorSystem("KafkaFlightstreamProducer")
+  implicit val system: ActorSystem    = ActorSystem("KafkaDVSProducer")
   implicit val mat: ActorMaterializer = ActorMaterializer()
   implicit val ec: ExecutionContext   = system.dispatcher
 

diff --git a/...ghtstream/producer/config/AppConfig.scala → ...trock/dvs/producer/config/AppConfig.scala b/...ghtstream/producer/config/AppConfig.scala → ...trock/dvs/producer/config/AppConfig.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.config
+package it.bitrock.dvs.producer.config
 
 import pureconfig.generic.auto._
 

diff --git a/...ream/producer/config/AviationConfig.scala → .../dvs/producer/config/AviationConfig.scala b/...ream/producer/config/AviationConfig.scala → .../dvs/producer/config/AviationConfig.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.config
+package it.bitrock.dvs.producer.config
 
 import pureconfig.generic.auto._
 import java.net.URI

diff --git a/...tstream/producer/config/KafkaConfig.scala → ...ock/dvs/producer/config/KafkaConfig.scala b/...tstream/producer/config/KafkaConfig.scala → ...ock/dvs/producer/config/KafkaConfig.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.config
+package it.bitrock.dvs.producer.config
 
 import java.net.URI
 

diff --git a/...stream/producer/config/ServerConfig.scala → ...ck/dvs/producer/config/ServerConfig.scala b/...stream/producer/config/ServerConfig.scala → ...ck/dvs/producer/config/ServerConfig.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.config
+package it.bitrock.dvs.producer.config
 
 final case class ServerConfig(
     host: String,

diff --git a/...eam/producer/kafka/KafkaSinkFactory.scala → ...dvs/producer/kafka/KafkaSinkFactory.scala b/...eam/producer/kafka/KafkaSinkFactory.scala → ...dvs/producer/kafka/KafkaSinkFactory.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.kafka
+package it.bitrock.dvs.producer.kafka
 
 import akka.Done
 import akka.kafka.ProducerSettings

diff --git a/...ghtstream/producer/kafka/KafkaTypes.scala → ...trock/dvs/producer/kafka/KafkaTypes.scala b/...ghtstream/producer/kafka/KafkaTypes.scala → ...trock/dvs/producer/kafka/KafkaTypes.scala
@@ -1,6 +1,6 @@
-package it.bitrock.kafkaflightstream.producer.kafka
+package it.bitrock.dvs.producer.kafka
 
-import it.bitrock.kafkaflightstream.model.{AirlineRaw, AirplaneRaw, AirportRaw, CityRaw, FlightRaw}
+import it.bitrock.dvs.model.avro.{AirlineRaw, AirplaneRaw, AirportRaw, CityRaw, FlightRaw}
 
 object KafkaTypes {
 

diff --git a/...htstream/producer/kafka/ToValuePair.scala → ...rock/dvs/producer/kafka/ToValuePair.scala b/...htstream/producer/kafka/ToValuePair.scala → ...rock/dvs/producer/kafka/ToValuePair.scala
@@ -1,8 +1,8 @@
-package it.bitrock.kafkaflightstream.producer.kafka
+package it.bitrock.dvs.producer.kafka
 
-import it.bitrock.kafkaflightstream.producer.kafka.KafkaTypes._
-import it.bitrock.kafkaflightstream.producer.kafka.models.RawImplicitConversions._
-import it.bitrock.kafkaflightstream.producer.model.{
+import KafkaTypes._
+import it.bitrock.dvs.producer.kafka.models.RawImplicitConversions._
+import it.bitrock.dvs.producer.model.{
   AirlineMessageJson,
   AirplaneMessageJson,
   AirportMessageJson,

diff --git a/...kafka/models/RawImplicitConversions.scala → ...kafka/models/RawImplicitConversions.scala b/...kafka/models/RawImplicitConversions.scala → ...kafka/models/RawImplicitConversions.scala
@@ -1,7 +1,7 @@
-package it.bitrock.kafkaflightstream.producer.kafka.models
+package it.bitrock.dvs.producer.kafka.models
 
-import it.bitrock.kafkaflightstream.model._
-import it.bitrock.kafkaflightstream.producer.model._
+import it.bitrock.dvs.model.avro._
+import it.bitrock.dvs.producer.model._
 
 object RawImplicitConversions {
 

diff --git a/...ghtstream/producer/model/Definition.scala → ...trock/dvs/producer/model/Definition.scala b/...ghtstream/producer/model/Definition.scala → ...trock/dvs/producer/model/Definition.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.model
+package it.bitrock.dvs.producer.model
 
 sealed trait AviationStream
 case object FlightStream   extends AviationStream

diff --git a/...htstream/producer/model/MessageJson.scala → ...rock/dvs/producer/model/MessageJson.scala b/...htstream/producer/model/MessageJson.scala → ...rock/dvs/producer/model/MessageJson.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.model
+package it.bitrock.dvs.producer.model
 
 sealed trait MessageJson extends Product
 

diff --git a/...flightstream/producer/routes/Routes.scala → .../bitrock/dvs/producer/routes/Routes.scala b/...flightstream/producer/routes/Routes.scala → .../bitrock/dvs/producer/routes/Routes.scala
@@ -1,10 +1,10 @@
-package it.bitrock.kafkaflightstream.producer.routes
+package it.bitrock.dvs.producer.routes
 
 import akka.http.scaladsl.model.StatusCodes
 import akka.http.scaladsl.server.Directives.{get, path}
 import akka.http.scaladsl.server.Route
 import akka.http.scaladsl.server.directives.RouteDirectives.complete
-import it.bitrock.kafkaflightstream.producer.config.ServerConfig
+import it.bitrock.dvs.producer.config.ServerConfig
 
 class Routes(serverConfig: ServerConfig) {
 

diff --git a/...ream/producer/services/AviationFlow.scala → .../dvs/producer/services/AviationFlow.scala b/...ream/producer/services/AviationFlow.scala → .../dvs/producer/services/AviationFlow.scala
@@ -1,4 +1,4 @@
-package it.bitrock.kafkaflightstream.producer.services
+package it.bitrock.dvs.producer.services
 
 import java.util.Calendar
 
@@ -10,7 +10,7 @@ import akka.http.scaladsl.unmarshalling.Unmarshal
 import akka.stream.ActorMaterializer
 import akka.stream.scaladsl.Flow
 import com.typesafe.scalalogging.LazyLogging
-import it.bitrock.kafkaflightstream.producer.model.{MessageJson, Tick}
+import it.bitrock.dvs.producer.model.{MessageJson, Tick}
 import JsonSupport._
 
 import scala.concurrent.{ExecutionContext, Future}

diff --git a/...ucer/services/AviationStreamContext.scala → ...ucer/services/AviationStreamContext.scala b/...ucer/services/AviationStreamContext.scala → ...ucer/services/AviationStreamContext.scala
@@ -1,14 +1,14 @@
-package it.bitrock.kafkaflightstream.producer.services
+package it.bitrock.dvs.producer.services
 
 import akka.Done
 import akka.actor.ActorSystem
 import akka.kafka.ProducerSettings
 import akka.stream.scaladsl.Sink
-import it.bitrock.kafkaflightstream.producer.config.{AviationConfig, AviationStreamConfig, KafkaConfig}
-import it.bitrock.kafkaflightstream.producer.kafka.KafkaSinkFactory
-import it.bitrock.kafkaflightstream.producer.kafka.KafkaTypes._
-import it.bitrock.kafkaflightstream.producer.model._
-import it.bitrock.kafkageostream.kafkacommons.serialization.AvroSerdes
+import it.bitrock.dvs.producer.config.{AviationConfig, AviationStreamConfig, KafkaConfig}
+import it.bitrock.dvs.producer.kafka.KafkaSinkFactory
+import it.bitrock.dvs.producer.kafka.KafkaTypes._
+import it.bitrock.dvs.producer.model._
+import it.bitrock.kafkacommons.serialization.AvroSerdes
 import org.apache.kafka.common.serialization.Serdes
 
 import scala.concurrent.Future

diff --git a/...tream/producer/services/JsonSupport.scala → ...k/dvs/producer/services/JsonSupport.scala b/...tream/producer/services/JsonSupport.scala → ...k/dvs/producer/services/JsonSupport.scala
@@ -1,7 +1,7 @@
-package it.bitrock.kafkaflightstream.producer.services
+package it.bitrock.dvs.producer.services
 
 import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport
-import it.bitrock.kafkaflightstream.producer.model._
+import it.bitrock.dvs.producer.model._
 import spray.json._
 
 object JsonSupport extends SprayJsonSupport with DefaultJsonProtocol {

diff --git a/...eam/producer/services/MainFunctions.scala → ...dvs/producer/services/MainFunctions.scala b/...eam/producer/services/MainFunctions.scala → ...dvs/producer/services/MainFunctions.scala
@@ -1,11 +1,11 @@
-package it.bitrock.kafkaflightstream.producer.services
+package it.bitrock.dvs.producer.services
 
 import akka.actor.{ActorSystem, Cancellable}
 import akka.http.scaladsl.Http
 import akka.stream.ActorMaterializer
-import it.bitrock.kafkaflightstream.producer.config.{AppConfig, AviationConfig, KafkaConfig, ServerConfig}
-import it.bitrock.kafkaflightstream.producer.model._
-import it.bitrock.kafkaflightstream.producer.routes.Routes
+import it.bitrock.dvs.producer.config.{AppConfig, AviationConfig, KafkaConfig, ServerConfig}
+import it.bitrock.dvs.producer.model._
+import it.bitrock.dvs.producer.routes.Routes
 
 import scala.concurrent.{ExecutionContext, Future}
 

diff --git a/...stream/producer/services/TickSource.scala → ...ck/dvs/producer/services/TickSource.scala b/...stream/producer/services/TickSource.scala → ...ck/dvs/producer/services/TickSource.scala
@@ -1,8 +1,8 @@
-package it.bitrock.kafkaflightstream.producer.services
+package it.bitrock.dvs.producer.services
 
 import akka.actor.Cancellable
 import akka.stream.scaladsl.Source
-import it.bitrock.kafkaflightstream.producer.model.Tick
+import it.bitrock.dvs.producer.model.Tick
 
 import scala.concurrent.duration._
 

diff --git a/...fkaflightstream/producer/TestValues.scala → .../it/bitrock/dvs/producer/TestValues.scala b/...fkaflightstream/producer/TestValues.scala → .../it/bitrock/dvs/producer/TestValues.scala
@@ -1,7 +1,6 @@
-package it.bitrock.kafkaflightstream.producer
+package it.bitrock.dvs.producer
 
-import it.bitrock.kafkaflightstream.model.{Aircraft, CommonCode, Flight, FlightRaw, Geography, Speed, System}
-import it.bitrock.kafkaflightstream.producer.model.{
+import it.bitrock.dvs.producer.model.{
   AircraftJson,
   AirlineMessageJson,
   CommonCodeJson,
@@ -11,6 +10,7 @@ import it.bitrock.kafkaflightstream.producer.model.{
   SpeedJson,
   SystemJson
 }
+import it.bitrock.dvs.model.avro.{Aircraft, CommonCode, Flight, FlightRaw, Geography, Speed, System}
 
 trait TestValues {
 

diff --git a/...er/kafka/KafkaFlightSinkFactorySpec.scala → ...er/kafka/KafkaFlightSinkFactorySpec.scala b/...er/kafka/KafkaFlightSinkFactorySpec.scala → ...er/kafka/KafkaFlightSinkFactorySpec.scala
@@ -1,16 +1,16 @@
-package it.bitrock.kafkaflightstream.producer.kafka
+package it.bitrock.dvs.producer.kafka
 
 import akka.actor.ActorSystem
 import akka.kafka.ProducerSettings
 import akka.stream.ActorMaterializer
 import akka.stream.scaladsl.Source
 import akka.testkit.TestKit
 import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig
-import it.bitrock.kafkaflightstream.producer.TestValues
-import it.bitrock.kafkaflightstream.producer.kafka.KafkaTypes.{Key, Flight => KafkaTypesFlight}
-import it.bitrock.kafkaflightstream.producer.model._
-import it.bitrock.kafkageostream.kafkacommons.serialization.ImplicitConversions._
-import it.bitrock.kafkageostream.testcommons.{FixtureLoanerAnyResult, Suite}
+import it.bitrock.dvs.producer.model.MessageJson
+import it.bitrock.dvs.producer.TestValues
+import it.bitrock.dvs.producer.kafka.KafkaTypes.{Key, Flight => KafkaTypesFlight}
+import it.bitrock.kafkacommons.serialization.ImplicitConversions._
+import it.bitrock.testcommons.{FixtureLoanerAnyResult, Suite}
 import net.manub.embeddedkafka.schemaregistry.{EmbeddedKafka, EmbeddedKafkaConfig, _}
 import org.apache.kafka.common.serialization.{Serde, Serdes}
 import org.scalatest.{BeforeAndAfterAll, WordSpecLike}

diff --git a/.../producer/services/AviationFlowSpec.scala → .../producer/services/AviationFlowSpec.scala b/.../producer/services/AviationFlowSpec.scala → .../producer/services/AviationFlowSpec.scala
@@ -1,14 +1,14 @@
-package it.bitrock.kafkaflightstream.producer.services
+package it.bitrock.dvs.producer.services
 
 import akka.actor.ActorSystem
 import akka.stream.ActorMaterializer
 import akka.stream.scaladsl.{Keep, Sink, Source}
 import akka.stream.testkit.TestSubscriber.Probe
 import akka.stream.testkit.scaladsl.TestSink
 import akka.testkit.TestKit
-import it.bitrock.kafkaflightstream.producer.model._
-import it.bitrock.kafkaflightstream.producer.services.AviationFlowSpec.Resource
-import it.bitrock.kafkageostream.testcommons.{FixtureLoanerAnyResult, Suite}
+import it.bitrock.dvs.producer.model._
+import AviationFlowSpec.Resource
+import it.bitrock.testcommons.{FixtureLoanerAnyResult, Suite}
 import org.scalatest.WordSpecLike
 
 import scala.concurrent.duration._