erik/kobalt
erik/kobalt
1
0
Fork 0
mirror of https://github.com/ethauvin/kobalt.git synced 2025-04-25 16:07:12 -07:00
Code Releases Activity

Servers.

Browse source
This commit is contained in:
Cedric Beust 2016-04-28 05:22:40 -08:00
parent e6a2ad98f7
commit 40d9e9ffdd
3 changed files with 127 additions and 76 deletions
Download patch file Download diff file Expand all files Collapse all files

148
src/main/kotlin/com/beust/kobalt/app/remote/JerseyServer.kt
View file

@ -1,74 +1,74 @@
package com.beust.kobalt.app.remote
import com.beust.kobalt.Args
import com.beust.kobalt.api.Kobalt
import com.beust.kobalt.api.Project
import com.google.gson.Gson
import org.glassfish.jersey.jetty.JettyHttpContainerFactory
import org.glassfish.jersey.server.ResourceConfig
import org.glassfish.jersey.server.ServerProperties
import javax.ws.rs.GET
import javax.ws.rs.Path
import javax.ws.rs.Produces
import javax.ws.rs.QueryParam
import javax.ws.rs.core.MediaType
import javax.ws.rs.core.UriBuilder
class JerseyServer(val initCallback: (String) -> List<Project>, val cleanUpCallback: () -> Unit)
: KobaltServer .IServer {
companion object {
lateinit var initCallback: (String) -> List<Project>
lateinit var cleanUpCallback: () -> Unit
}
init {
JerseyServer.initCallback = initCallback
JerseyServer.cleanUpCallback = cleanUpCallback
}
override fun run(port: Int) {
val baseUri = UriBuilder.fromUri("http://localhost/").port(port).build()
val config = ResourceConfig(KobaltResource::class.java)
with (JettyHttpContainerFactory.createServer(baseUri, config)) {
try {
start()
join()
} finally {
destroy()
}
}
}
}
@Path("/v0")
class KobaltResource : ResourceConfig() {
init {
property(ServerProperties.TRACING, "ALL")
}
@GET
@Path("ping")
@Produces(MediaType.TEXT_PLAIN)
fun getDependencies() = "pong"
@GET
@Path("getDependencies")
@Produces(MediaType.APPLICATION_JSON)
fun getDependencies(@QueryParam("buildFile") buildFile: String) : String {
try {
val dependencyData = Kobalt.INJECTOR.getInstance(DependencyData::class.java)
val args = Kobalt.INJECTOR.getInstance(Args::class.java)
val projects = JerseyServer.initCallback(buildFile)
val dd = dependencyData.dependenciesDataFor(buildFile, args)
val result = Gson().toJson(dd)
return result
} catch(ex: Exception) {
return "Error: " + ex.message
} finally {
JerseyServer.cleanUpCallback()
}
}
}
//package com.beust.kobalt.app.remote
//
//import com.beust.kobalt.Args
//import com.beust.kobalt.api.Kobalt
//import com.beust.kobalt.api.Project
//import com.google.gson.Gson
//import org.glassfish.jersey.jetty.JettyHttpContainerFactory
//import org.glassfish.jersey.server.ResourceConfig
//import org.glassfish.jersey.server.ServerProperties
//import javax.ws.rs.GET
//import javax.ws.rs.Path
//import javax.ws.rs.Produces
//import javax.ws.rs.QueryParam
//import javax.ws.rs.core.MediaType
//import javax.ws.rs.core.UriBuilder
//
//class JerseyServer(val initCallback: (String) -> List<Project>, val cleanUpCallback: () -> Unit)
// : KobaltServer .IServer {
//
// companion object {
// lateinit var initCallback: (String) -> List<Project>
// lateinit var cleanUpCallback: () -> Unit
// }
//
// init {
// JerseyServer.initCallback = initCallback
// JerseyServer.cleanUpCallback = cleanUpCallback
// }
//
// override fun run(port: Int) {
// val baseUri = UriBuilder.fromUri("http://localhost/").port(port).build()
// val config = ResourceConfig(KobaltResource::class.java)
// with (JettyHttpContainerFactory.createServer(baseUri, config)) {
// try {
// start()
// join()
// } finally {
// destroy()
// }
// }
//
// }
//}
//
//@Path("/v0")
//class KobaltResource : ResourceConfig() {
// init {
// property(ServerProperties.TRACING, "ALL")
// }
//
// @GET
// @Path("ping")
// @Produces(MediaType.TEXT_PLAIN)
// fun getDependencies() = "pong"
//
// @GET
// @Path("getDependencies")
// @Produces(MediaType.APPLICATION_JSON)
// fun getDependencies(@QueryParam("buildFile") buildFile: String) : String {
// try {
// val dependencyData = Kobalt.INJECTOR.getInstance(DependencyData::class.java)
// val args = Kobalt.INJECTOR.getInstance(Args::class.java)
//
// val projects = JerseyServer.initCallback(buildFile)
// val dd = dependencyData.dependenciesDataFor(buildFile, args)
// val result = Gson().toJson(dd)
// return result
// } catch(ex: Exception) {
// return "Error: " + ex.message
// } finally {
// JerseyServer.cleanUpCallback()
// }
// }
//}

6
src/main/kotlin/com/beust/kobalt/app/remote/KobaltServer.kt
View file

@ -30,14 +30,16 @@ class KobaltServer(val force: Boolean, val givenPort: Int? = null,
val port = givenPort ?: ProcessUtil.findAvailablePort(1234)
try {
if (createServerFile(port, force)) {
log(1, "KobaltServer listening on port $port")
// OldServer(initCallback, cleanUpCallback).run(port)
JerseyServer(initCallback, cleanUpCallback).run(port)
// JerseyServer(initCallback, cleanUpCallback).run(port)
SparkServer(initCallback, cleanUpCallback).run(port)
// WasabiServer(initCallback, cleanUpCallback).run(port)
}
} catch(ex: Exception) {
ex.printStackTrace()
} finally {
deleteServerFile()
// deleteServerFile()
}
return port
}

49
src/main/kotlin/com/beust/kobalt/app/remote/SparkServer.kt Normal file
View file

@ -0,0 +1,49 @@
package com.beust.kobalt.app.remote
import com.beust.kobalt.Args
import com.beust.kobalt.api.Kobalt
import com.beust.kobalt.api.Project
import com.google.gson.Gson
import spark.Route
import spark.Spark
class SparkServer(val initCallback: (String) -> List<Project>, val cleanUpCallback: () -> Unit)
: KobaltServer .IServer {
companion object {
lateinit var initCallback: (String) -> List<Project>
lateinit var cleanUpCallback: () -> Unit
}
init {
SparkServer.initCallback = initCallback
SparkServer.cleanUpCallback = cleanUpCallback
}
override fun run(port: Int) {
Spark.port(port)
Spark.get("/hello", Route { req, res -> "Hello world" })
Spark.get("/v0/getDependencies", { request, response ->
val buildFile = request.queryParams("buildFile")
if (buildFile != null) {
val projects = initCallback(buildFile)
val result = try {
val dependencyData = Kobalt.INJECTOR.getInstance(DependencyData::class.java)
val args = Kobalt.INJECTOR.getInstance(Args::class.java)
val dd = dependencyData.dependenciesDataFor(buildFile, args)
Gson().toJson(dd)
} catch(ex: Exception) {
"Error: " + ex.message
} finally {
cleanUpCallback()
}
result
} else {
"error"
}
})
}
}