aboutsummaryrefslogtreecommitdiff
path: root/kvision-server
diff options
context:
space:
mode:
authorRobert Jaros <rjaros@finn.pl>2018-06-02 00:07:39 +0200
committerRobert Jaros <rjaros@finn.pl>2018-06-02 00:07:39 +0200
commit93cfdf0dcf6404eb636037fbb59fbff8389a434a (patch)
tree8d25e6a099811e2fd771d49f4b5fb62ceaea9e2e /kvision-server
parent656e823d91301f637feff2edea3920d3625b43c2 (diff)
downloadkvision-93cfdf0dcf6404eb636037fbb59fbff8389a434a.tar.gz
kvision-93cfdf0dcf6404eb636037fbb59fbff8389a434a.tar.bz2
kvision-93cfdf0dcf6404eb636037fbb59fbff8389a434a.zip
Generate automatic routes names.
Diffstat (limited to 'kvision-server')
-rw-r--r--kvision-server/src/main/kotlin/pl/treksoft/kvision/remote/ServiceManager.kt55
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) {