diff options
author | Robert Jaros <rjaros@finn.pl> | 2019-10-22 23:18:59 +0200 |
---|---|---|
committer | Robert Jaros <rjaros@finn.pl> | 2019-10-22 23:18:59 +0200 |
commit | 69958b1a08f46aecd6ceda54780f362019150052 (patch) | |
tree | f42d65c65b832a9aef1a7e2e40f8bf8ac6e7224d /kvision-modules/kvision-server-jooby/src/main | |
parent | 5f109a1e92cd02df8b5588743ed141bc93542817 (diff) | |
download | kvision-69958b1a08f46aecd6ceda54780f362019150052.tar.gz kvision-69958b1a08f46aecd6ceda54780f362019150052.tar.bz2 kvision-69958b1a08f46aecd6ceda54780f362019150052.zip |
Send additional state with SelectRemote request.
Diffstat (limited to 'kvision-modules/kvision-server-jooby/src/main')
-rw-r--r-- | kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt b/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt index e2a26967..fd95be3e 100644 --- a/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt +++ b/kvision-modules/kvision-server-jooby/src/main/kotlin/pl/treksoft/kvision/remote/KVServiceManager.kt @@ -417,20 +417,21 @@ actual open class KVServiceManager<T : Any> actual constructor(val serviceClass: */ @Suppress("TooGenericExceptionCaught") protected actual fun bind( - function: T.(String?, String?) -> List<RemoteOption> + function: T.(String?, String?, String?) -> List<RemoteOption> ) { val routeDef = "route${this::class.simpleName}${counter++}" routes.add { call(HttpMethod.POST, "/kv/$routeDef") { req, res -> val jsonRpcRequest = req.body(JsonRpcRequest::class.java) - if (jsonRpcRequest.params.size == 2) { + if (jsonRpcRequest.params.size == 3) { val param1 = getParameter<String?>(jsonRpcRequest.params[0]) val param2 = getParameter<String?>(jsonRpcRequest.params[1]) + val param3 = getParameter<String?>(jsonRpcRequest.params[2]) val injector = req.require(Injector::class.java) val service = injector.getInstance(serviceClass.java) GlobalScope.launch(start = CoroutineStart.UNDISPATCHED) { try { - val result = function.invoke(service, param1, param2) + val result = function.invoke(service, param1, param2, param3) res.send( JsonRpcResponse( id = jsonRpcRequest.id, |