To be completely fair, for what we do (simple tables without joins between them) JOOQ is an overkill and IntelliJ Sql support is great. Still it would be nice to have a sensible Kotlinesque wrap around JDBC api... 🙂

Hey @dave For some reason this snippet of code is not compiling for me, it fails the += operator. I am using it from: https://www.http4k.org/cookbook/typesafe_http_contracts/

"Unresolved reference. None of the following candidates is applicable because of receiver type mismatch"

I wonder if the issue is me injecting also other things into the handler that returns an HttpHandler

thanks @dave. started playing around a bit and I see those methods, however I don't see how to turn the resulting string back into a new Request. I also note there is

toCurl()

which might be even more useful, given that Curl clearly identifies headers, form fields, etc with

-H

,

--data

, etc. Plus Curl is a universal spec, a quick search shows a number of Curl to XXX interpreters in various languages.

Agreed on the oa2/oa3 but you cant control what somebody else gives you...

Should the hot reload base sir be sec/main/resources?

Hmm. Musing for you -

ClientFilters.Gzip

currently compresses the request, and decompresses the response. Which is great, but request compression is pretty esoteric (as you can't guarantee the remote end will support it). Secondly, I don't see us setting an

accept-encoding:gzip

on the request, which means we shouldn't expect to get GZip back. As such, I suggest two changes (i.e. I'm happy to do it, but need a sanity check) a) Change

ClientFilters.Gzip

to set

accept-encoding:gzip

on request, but not to compress the request b) Add a new

ClientFilters.RequestCompressingGzip

to do the above, and additionally compress the request Seem fair? Or am I being daft?

@dave I’m running into a similar issue that was resolved in 3.193.1, where specifying an optional in an a environment lens throws exception in runtime. Only this time it’s happening in a composite environment object. Version Used: 3.193.1

Caused by: org.http4k.lens.LensFailure: location 'NON_OPTIONAL_VAR' must be object
	at org.http4k.lens.Lens.invoke(lens.kt:17)
	at config.CompositeEnvironmentHandler$$special$$inlined$composite$1.invoke(lensSpec.kt:262)
	at config.CompositeEnvironmentHandler$$special$$inlined$composite$1.invoke(lensSpec.kt)
	at org.http4k.lens.LensGet$invoke$1.invoke(lensSpec.kt:15)
	at org.http4k.lens.LensGet$invoke$1.invoke(lensSpec.kt:14)
	at org.http4k.lens.LensSpec$required$1.invoke(lensSpec.kt:99)
	at org.http4k.lens.Lens.invoke(lens.kt:13)

@Razi Kheir AFK, but at first glance it looks like you're not using the API quite correctly. Is there a reason you're not specifying the composite EnvironmentKey like the one in this test? https://github.com/http4k/http4k/blob/master/http4k-cloudnative/src/test/kotlin/org/http4k/cloudnative/env/EnvironmentKeyTest.kt

@Razi Kheir I've just rewritten the composite test to check that it works:

@Test
    fun `composite can use a mixture of overridden and non overridden values`() {
        data class Target(val foo: String, val bar: Int, var foobar: Int?)

        val finalEnv = from("bar" to "123") overrides from("FOO" to "bill")

        val key = EnvironmentKey.composite {
            Target(
                required("FOO")(it),
                int().required("BAR")(it),
                int().optional("FOOBAR")(it)
            )
        }

        assertThat(key(finalEnv), equalTo(Target("bill", 123, null)))
    }
}

Btw Is there a way to do nestable contract routes? I see nestable routes and contracts but I don’t see a way to do both?

Hi everyone 😉 I know that http4k can generate

responseLens

and use

returning

to specify it in contract route. But I want to know is it possible to constraint and auto-marshalling for request? like

data class LoginRequest(val email: String, val password: String) {
    init {
        require(EmailValidator.getInstance().isValid(email))
    }
}

val requestLens = Body.auto<LoginRequest>("Login essentials.")
fun handler(login: LoginRequest): HttpHandler =  { req: Request -> ... }

"/login" / Body.of(requestLens) meta {
   ...
} bindContract <http://Method.POST|Method.POST> to ::handler

Many thanks.

ah, kinda disappointing... I now use

jacksonObjectMapper().writeValueAsString(e)

to manually convert the object, and it works fine now. i feel somewhat strange about the origin behavior. use

writeValueAsString

will format the stacktrace into a well-organized json but

.with(error of e)

will output the stacktrace solely which will crash the json parser. why

with

is designed to work in this way...? 😕

Probably not http4k but... I built a JAR file using http4k w/embedded Undertow server. Deployed it behind an HAProxy load balancer. Currently just 1 instance, no SSL, just testing the connection. Works, but getting

[XNIO-1 task-12] DEBUG <http://io.undertow.request.io|io.undertow.request.io> - UT005013: An IOException occurred

<http://java.net|java.net>.SocketException: Connection reset

immediately after every request. Have tried various HAProxy options but cannot fix.

However, should clarify that the CORS error isn’t coming from http4k server which I fixed by adding the right CORS policy - it’s coming from github

hey everyone. is there any way to mark a field as optional in auto-modeled http body message? like, define:

data class ApproveRequest(val roleId: Int, val extraPermissions: List<InboundPermission> = emptyList())

and

private val requestLens = Body.auto<ApproveRequest>().toLens()

want i want is the field

extraPermissions

will be marked as

optional

instead of

required

in generated OpenApi doc because it have a default value. this may seems somewhat unreasonable, but i just met this in my backend application 😅

Hi, is there a noticable performance or resource penalty when adding websockets and using a PolyHandler? Any plans to add Undertow as a WsServer (currently only Jetty)? Still exploring all the features of http4k 🙂 Thanks!

I know this is everyone's "favorite" question, but are there any updates on async server support, either via coroutines or some other mechanism? Last mention of coroutines in this room (that I could find) was back in September, the GitHub issue was last updated in June, and the v4 Spike branch was last updated in October. Is anyone working on async server support or has that been put on hold?

Hi! We are responding with an input stream from a temporary file on disk.

Response(OK).body(tempFile.inputStream())

Is there any way to detect when the response has been fully read so that we can then delete the temp file on disk?

Could anybody help that what is wrong with this code?

val app = { request: Request -> Response(OK).body("Hello, ${request.query("name")}!") }

val jettyServer = app.asServer(Jetty(9006)).start()
 val client = WebsocketClient.blocking(Uri.of("<wss://echo.websocket.org>"), headers = listOf(Pair("a header", "value")))

        
        client.send(WsMessage("hello"))

        // read all of the messages from the socket until it is closed (by the server).
        // we expect to get one message back before the stream is closed.
        client.received().toList().forEach(::println)

I am able to connect but I am not receiving any message. I want to develop a websocket client always send and receive messages to/from the server

Hi David, How to create custom JsonErrorResponseRenderer in OpenApi3 ?

@Uberto Barbini We never got around implementing that parser because http4k itself doesn't tend to act based on content type, whereas applications do. Having a parser would be handy though and I'd be happy to incorporate a PR on that area.

Generating API documentation with OpenApi3, how can I add a description to JSON schema properties? I tried @JsonPropertyDescription annotation but that doesn't work

Hey everyone - currently I'm using micrometer & http4k-metrics for my metrics data collecting. i've noticed seems the default collecting interval is 10s, is there any way to change this interval? many thanks 😉

@s4nchez I looked at the documents you provided and got lost ... I have to parse a string in json format like this one '{"name" : "some-name", "age": 30}" what is the simplest way to get "some-name" and 30 ?

Does anyone have some hints on how to configure a server(JETTY) to require SSL in http4k?🆘 (edited)

I have a Kotlin code using http4k imports which provides running JVM executable suing gradle. Is there a way to make it provide JS executable ? It seems that kotlin(stdlib-js) does not resolve any of the http4k import. Did I miss to provide some gradle item ?

the default jetty implementation will not give you access to the certificates. If you really "need" the cert inside your app (rather than just rejecting requests without it), then I suggest using an RequestContext. OTOH, if you just want to reject, you can write a custom Jetty Handler which will do it and just handle it in that layer

Could you please share a sample showing how to dockerify a http4k application?

@sahil Lone There's no need to define the

/tokens

path twice. This should work:

class TokensRouter(private val tokensCommandHandler: TokensCommandHandler) {
    operator fun invoke(): RoutingHttpHandler =
        ServerFilters.Cors(CorsPolicy.UnsafeGlobalPermissive).then(routes(
            "/tokens" bind <http://Method.POST|Method.POST> to tokensCommandHandler::invoke
        ))
}

Hi @dave how would you handle sessions in http4k? I am trying to a simple string that should persist in the session