/static/xyz.json

/static/xyz

import io.ktor.application.ApplicationCall
import io.ktor.request.header
import kotlinx.coroutines.asContextElement

const val TENANT_HEADER_VALUE = "tenantID";
const val TENANT_HEADER_URL_VALUE = "tenantURL";
const val CLIENT_HEADER_URL_VALUE = "clientURL";
const val TENANTID_DEFAULT_VALUE = "master"

object ContextManager {
    private val context = ThreadLocal<Context>();

    /**
     * Register a request in the context
     */
    fun registerCall(call: ApplicationCall) {

        var requestContext = getContext();

        var tenantID = call.request.header(TENANT_HEADER_VALUE);
        LOGGER.trace("Find ${tenantID} in ${call.request.headers}")
        if (tenantID == null || tenantID.isEmpty()) {
            tenantID = TENANTID_DEFAULT_VALUE;
        }
        requestContext.tenantID = tenantID;
        requestContext.tenantUrl = call.request.header(TENANT_HEADER_URL_VALUE).toString();
        requestContext.clientURL = call.request.header(CLIENT_HEADER_URL_VALUE).toString();


        setContext(requestContext);
    }

    fun setContext(context: Context) {
        this.context.set(context);
        this.context.asContextElement(context);
    }

    fun getContext(): Context {
        var requestContext = context.get();
        if (requestContext == null) {
            requestContext = Context()
        }
        return requestContext;
    }

    fun declareContext(tenantID: String, tenantUrl: String = "", clientURL: String = "") {
        val requestContext = getContext();
        requestContext.tenantUrl = tenantUrl;
        requestContext.tenantID = tenantID;
        requestContext.clientURL = clientURL;
    }

}

class Context {
    var tenantID = TENANTID_DEFAULT_VALUE;
    var tenantUrl = "";
    var clientURL = "";
}

Exception in thread "main" java.lang.IllegalArgumentException: Could not find column mapper for type 'T' of parameter 'parameter #1 value of fun <init>(kotlin.String, T): io.execvision.profile.db.StupidThing<T>' for constructor 'fun <init>(kotlin.String, T): io.execvision.profile.db.StupidThing<T>'
	at org.jdbi.v3.core.kotlin.KotlinMapper$resolveConstructorParameterMapper$2.get(KotlinMapper.kt:197)
	at org.jdbi.v3.core.kotlin.KotlinMapper$resolveConstructorParameterMapper$2.get(KotlinMapper.kt:51)
	at java.util.Optional.orElseThrow(Optional.java:290)
	at org.jdbi.v3.core.kotlin.KotlinMapper.resolveConstructorParameterMapper(KotlinMapper.kt:196)
	at org.jdbi.v3.core.kotlin.KotlinMapper.specialize0(KotlinMapper.kt:98)
	at org.jdbi.v3.core.kotlin.KotlinMapper.specialize(KotlinMapper.kt:73)
	at org.jdbi.v3.core.result.ResultSetResultIterator.<init>(ResultSetResultIterator.java:38)
	at org.jdbi.v3.core.result.ResultIterable.lambda$of$0(ResultIterable.java:54)
	at org.jdbi.v3.core.result.ResultIterable.stream(ResultIterable.java:228)
	at org.jdbi.v3.core.result.ResultIterable.collect(ResultIterable.java:284)
	at org.jdbi.v3.sqlobject.statement.internal.ResultReturner$CollectedResultReturner.mappedResult(ResultReturner.java:267)
	at org.jdbi.v3.sqlobject.statement.internal.SqlQueryHandler.lambda$configureReturner$0(SqlQueryHandler.java:54)
	at 
...

webSocket("/") {
    while (true) {
        delay(3000)
        outgoing.send(Frame.Text("hi"))
    }
}

zt-exec

zt-exec

xpath

call.request.uri

<http://some.url/#access_token=xxx>

TableRecordImpl

UpdatableRecordImpl

embeddedServer(Jetty, 9000) {
    install(ContentNegotiation) {
        gson {}
    }
    routing {
        post("/account/login") {
            // 1. Create URL
            val url = URL("<http://some.server.com/account/login>")
            // 2. Create HTTP URL Connection
            var connection: HttpURLConnection = url.openConnection() as HttpURLConnection
            // 3. Add Request Headers
            connection.addRequestProperty("Host", "<http://some.server.com|some.server.com>")
            connection.addRequestProperty("Content-Type", "application/json;charset=utf-8")
            // 4. Set Request method
            connection.requestMethod = "POST"
            // 5. Set Request Body
            val requestBodyText = call.receiveText()
            val outputInBytes: ByteArray = requestBodyText.toByteArray(Charsets.UTF_8)
            val os: OutputStream = connection.getOutputStream()
            os.write(outputInBytes)
            os.close()
            // 6. Get Response as string from HTTP URL Connection
            val string = connection.getInputStream().reader().readText()
            // 7. Get headers from HTTP URL Connection
            val headerFields =  connection.headerFields
            // 8. Get Cookies Out of response
            val cookiesHeader = headerFields["Set-Cookie"]?.joinToString { "${it};" } ?: ""
            // 9. Respond to Client with JSON Data
            call.respondText(string, ContentType.Text.JavaScript, HttpStatusCode.OK)
            // 10. Add Response headers
            call.response.header("Set-Cookie", cookiesHeader)
        }
    }
}.start(wait = false)