Added search command

Closes #2

build.sbt

@@ -14,11 +14,14 @@ wixProductUpgradeId := "4552fb0e-e257-4dbd-9ecb-dba9dbacf424"
 scalastyleConfig := baseDirectory.value / "project" / "scalastyle_config.xml"
 
 libraryDependencies += "com.github.scopt" %% "scopt" % "3.7.0"
+libraryDependencies += "io.spray" %% "spray-json" % "1.3.3"
 libraryDependencies ++= Seq(
   "com.typesafe.akka" %% "akka-http-core" % "10.1.5",
+  "com.typesafe.akka" %% "akka-http-spray-json" % "10.1.5",
   "com.typesafe.akka" %% "akka-stream" % "2.5.12"
 )
 
+
 debianPackageDependencies := Seq("java8-runtime-headless")
 
 lazy val cli = (project in file(".")).

src/main/scala/de/upb/cs/swt/delphi/cli/DelphiCLI.scala

@@ -19,7 +19,7 @@ package de.upb.cs.swt.delphi.cli
 import akka.actor.ActorSystem
 import akka.http.scaladsl.Http
 import akka.stream.ActorMaterializer
-import de.upb.cs.swt.delphi.cli.commands.{RetrieveCommand, TestCommand}
+import de.upb.cs.swt.delphi.cli.commands.{RetrieveCommand, SearchCommand, TestCommand}
 
 import scala.concurrent.duration.Duration
 import scala.concurrent.{Await, ExecutionContext}
@@ -55,7 +55,11 @@ object DelphiCLI extends App {
             "with the filepath given in place of the ID")
         )
 
-      //cmd("search")
+      cmd("search").action((s, c) => c.copy(mode = "search"))
+        .text("Search artifact using a query.")
+        .children(
+          arg[String]("query").action((x,c) => c.copy(args = List(x))).text("The query to be used")
+        )
     }
   }
 
@@ -66,10 +70,11 @@ object DelphiCLI extends App {
       config.mode match {
         case "test" => TestCommand.execute(config)
         case "retrieve" => RetrieveCommand.execute(config)
-        case _ => println("Unknown command")
+        case "search" => SearchCommand.execute(config)
+        case x => println(s"Unknown command: $x")
       }
 
-    case None => println("nope")
+    case None =>
   }
 
   val poolShutdown = Http().shutdownAllConnectionPools()

src/main/scala/de/upb/cs/swt/delphi/cli/commands/SearchCommand.scala

@@ -0,0 +1,64 @@
+// Copyright (C) 2018 The Delphi Team.
+// See the LICENCE file distributed with this work for additional
+// information regarding copyright ownership.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package de.upb.cs.swt.delphi.cli.commands
+
+import akka.actor.ActorSystem
+import akka.http.scaladsl.Http
+import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport
+import akka.http.scaladsl.marshalling.Marshal
+import akka.http.scaladsl.model._
+import akka.stream.ActorMaterializer
+import akka.util.ByteString
+import de.upb.cs.swt.delphi.cli.Config
+import spray.json.DefaultJsonProtocol
+
+import scala.concurrent.Await
+import scala.concurrent.duration._
+
+object SearchCommand extends Command with SprayJsonSupport with DefaultJsonProtocol {
+  /**
+    * Executes the command implementation
+    *
+    * @param config The current configuration for the command
+    */
+  override def execute(config: Config)(implicit system: ActorSystem): Unit = {
+    implicit val ec = system.dispatcher
+    implicit val materializer = ActorMaterializer()
+
+    def query = config.args.head
+    implicit val queryFormat = jsonFormat2(Query)
+
+    val baseUri = Uri(config.server)
+    val searchUri = baseUri.withPath(baseUri.path + "/search").withQuery(akka.http.scaladsl.model.Uri.Query(Map("pretty"->"")))
+    val responseFuture = Marshal(Query(query)).to[RequestEntity] flatMap { entity =>
+      Http().singleRequest(HttpRequest(uri = searchUri, method = HttpMethods.POST, entity = entity))
+    }
+
+    val result = Await.result(responseFuture, 30 seconds)
+    result match {
+      case HttpResponse(StatusCodes.OK, headers, entity, _) =>
+        entity.dataBytes.runFold(ByteString(""))(_ ++ _).foreach { body =>
+          println(body.utf8String)
+        }
+      case resp @ HttpResponse(code, _, _, _) =>
+        println("Request failed, response code: " + code)
+        resp.discardEntityBytes()
+    }
+  }
+
+  case class Query(query : String, pretty : Option[Boolean] = Some(true))
+}