diff options
author | Robert Jaros <rjaros@finn.pl> | 2018-06-02 00:07:39 +0200 |
---|---|---|
committer | Robert Jaros <rjaros@finn.pl> | 2018-06-02 00:07:39 +0200 |
commit | 93cfdf0dcf6404eb636037fbb59fbff8389a434a (patch) | |
tree | 8d25e6a099811e2fd771d49f4b5fb62ceaea9e2e /kvision-server/src/main | |
parent | 656e823d91301f637feff2edea3920d3625b43c2 (diff) | |
download | kvision-93cfdf0dcf6404eb636037fbb59fbff8389a434a.tar.gz kvision-93cfdf0dcf6404eb636037fbb59fbff8389a434a.tar.bz2 kvision-93cfdf0dcf6404eb636037fbb59fbff8389a434a.zip |
Generate automatic routes names.
Diffstat (limited to 'kvision-server/src/main')
-rw-r--r-- | kvision-server/src/main/kotlin/pl/treksoft/kvision/remote/ServiceManager.kt | 55 |
1 files changed, 31 insertions, 24 deletions
diff --git a/kvision-server/src/main/kotlin/pl/treksoft/kvision/remote/ServiceManager.kt b/kvision-server/src/main/kotlin/pl/treksoft/kvision/remote/ServiceManager.kt index 6c1b47e7..50ef770f 100644 --- a/kvision-server/src/main/kotlin/pl/treksoft/kvision/remote/ServiceManager.kt +++ b/kvision-server/src/main/kotlin/pl/treksoft/kvision/remote/ServiceManager.kt @@ -33,7 +33,7 @@ import org.slf4j.LoggerFactory * Multiplatform service manager. */ @Suppress("EXPERIMENTAL_FEATURE_WARNING") -actual open class ServiceManager<out T> actual constructor(val service: T?) { +actual open class ServiceManager<out T> actual constructor(val service: T) { companion object { val LOG: Logger = LoggerFactory.getLogger(ServiceManager::class.java.name) @@ -41,20 +41,22 @@ actual open class ServiceManager<out T> actual constructor(val service: T?) { protected val routes: MutableList<JoobyServer.() -> Unit> = mutableListOf() val mapper = jacksonObjectMapper() + var counter: Int = 0 /** * Binds a given route with a function of the receiver. - * @param route a route * @param function a function of the receiver + * @param route a route * @param method a HTTP method * @param prefix an URL address prefix */ protected actual inline fun <reified RET> bind( - route: String, - noinline function: T.(Request?) -> Deferred<RET>, method: RpcHttpMethod, prefix: String + noinline function: T.(Request?) -> Deferred<RET>, + route: String?, method: RpcHttpMethod, prefix: String ) { + val routeDef = if (route != null) route else "route${this::class.simpleName}${counter++}" routes.add({ - call(method, "$prefix$route") { req, res -> + call(method, "$prefix$routeDef") { req, res -> if (service != null) { val jsonRpcRequest = req.body(JsonRpcRequest::class.java) try { @@ -78,17 +80,18 @@ actual open class ServiceManager<out T> actual constructor(val service: T?) { /** * Binds a given route with a function of the receiver. - * @param route a route * @param function a function of the receiver + * @param route a route * @param method a HTTP method * @param prefix an URL address prefix */ protected actual inline fun <reified PAR, reified RET> bind( - route: String, - noinline function: T.(PAR, Request?) -> Deferred<RET>, method: RpcHttpMethod, prefix: String + noinline function: T.(PAR, Request?) -> Deferred<RET>, + route: String?, method: RpcHttpMethod, prefix: String ) { + val routeDef = if (route != null) route else "route${this::class.simpleName}${counter++}" routes.add({ - call(method, "$prefix$route") { req, res -> + call(method, "$prefix$routeDef") { req, res -> if (service != null) { val jsonRpcRequest = req.body(JsonRpcRequest::class.java) if (jsonRpcRequest.params.size == 1) { @@ -117,17 +120,18 @@ actual open class ServiceManager<out T> actual constructor(val service: T?) { /** * Binds a given route with a function of the receiver. - * @param route a route * @param function a function of the receiver + * @param route a route * @param method a HTTP method * @param prefix an URL address prefix */ protected actual inline fun <reified PAR1, reified PAR2, reified RET> bind( - route: String, - noinline function: T.(PAR1, PAR2, Request?) -> Deferred<RET>, method: RpcHttpMethod, prefix: String + noinline function: T.(PAR1, PAR2, Request?) -> Deferred<RET>, + route: String?, method: RpcHttpMethod, prefix: String ) { + val routeDef = if (route != null) route else "route${this::class.simpleName}${counter++}" routes.add({ - call(method, "$prefix$route") { req, res -> + call(method, "$prefix$routeDef") { req, res -> if (service != null) { val jsonRpcRequest = req.body(JsonRpcRequest::class.java) if (jsonRpcRequest.params.size == 2) { @@ -157,17 +161,18 @@ actual open class ServiceManager<out T> actual constructor(val service: T?) { /** * Binds a given route with a function of the receiver. - * @param route a route * @param function a function of the receiver + * @param route a route * @param method a HTTP method * @param prefix an URL address prefix */ protected actual inline fun <reified PAR1, reified PAR2, reified PAR3, reified RET> bind( - route: String, - noinline function: T.(PAR1, PAR2, PAR3, Request?) -> Deferred<RET>, method: RpcHttpMethod, prefix: String + noinline function: T.(PAR1, PAR2, PAR3, Request?) -> Deferred<RET>, + route: String?, method: RpcHttpMethod, prefix: String ) { + val routeDef = if (route != null) route else "route${this::class.simpleName}${counter++}" routes.add({ - call(method, "$prefix$route") { req, res -> + call(method, "$prefix$routeDef") { req, res -> if (service != null) { val jsonRpcRequest = req.body(JsonRpcRequest::class.java) if (jsonRpcRequest.params.size == 3) { @@ -198,17 +203,18 @@ actual open class ServiceManager<out T> actual constructor(val service: T?) { /** * Binds a given route with a function of the receiver. - * @param route a route * @param function a function of the receiver + * @param route a route * @param method a HTTP method * @param prefix an URL address prefix */ protected actual inline fun <reified PAR1, reified PAR2, reified PAR3, reified PAR4, reified RET> bind( - route: String, - noinline function: T.(PAR1, PAR2, PAR3, PAR4, Request?) -> Deferred<RET>, method: RpcHttpMethod, prefix: String + noinline function: T.(PAR1, PAR2, PAR3, PAR4, Request?) -> Deferred<RET>, + route: String?, method: RpcHttpMethod, prefix: String ) { + val routeDef = if (route != null) route else "route${this::class.simpleName}${counter++}" routes.add({ - call(method, "$prefix$route") { req, res -> + call(method, "$prefix$routeDef") { req, res -> if (service != null) { val jsonRpcRequest = req.body(JsonRpcRequest::class.java) if (jsonRpcRequest.params.size == 4) { @@ -241,20 +247,21 @@ actual open class ServiceManager<out T> actual constructor(val service: T?) { /** * Binds a given route with a function of the receiver. - * @param route a route * @param function a function of the receiver + * @param route a route * @param method a HTTP method * @param prefix an URL address prefix */ protected actual inline fun <reified PAR1, reified PAR2, reified PAR3, reified PAR4, reified PAR5, reified RET> bind( - route: String, noinline function: T.(PAR1, PAR2, PAR3, PAR4, PAR5, Request?) -> Deferred<RET>, + route: String?, method: RpcHttpMethod, prefix: String ) { + val routeDef = if (route != null) route else "route${this::class.simpleName}${counter++}" routes.add({ - call(method, "$prefix$route") { req, res -> + call(method, "$prefix$routeDef") { req, res -> if (service != null) { val jsonRpcRequest = req.body(JsonRpcRequest::class.java) if (jsonRpcRequest.params.size == 5) { |