3,4 There's nothing to tie lenses to Http4k. You can write a custom lens implementation which unmarshalls the JSON 5 this will be tricky unless you can inject the http client manually into the connect client- then you'd provide a thin Http4k adapter wrapper - which is the pattern we use for the AwsSdkClient and AWS SDK v2z 6 see above 7 you can use an approver without the test runner wrapper. All the JsonApprovalTest does is to configure the approver and then inject it into the test case. The code is all there in the approval test module. Alternatively use OkeyDoke or JSONAssert. For the individual values - there are a couple of ways but nothing Http4k specific.

Are there any digest auth client filters anywhere? I know there's an okhttp authenticator I can wrap into a filter, but it would be a pain.

out of curiosity - why is this global RequestContexts store with a concurrent hashmap needed? Wouldn't it just be enough to attach an immutable

Map<Key,Any>

as context to each request?

Hey team, Is there a a built in or best practice way to handle graceful shutdowns?

hey team! is there a way of having an optional request body parameter?

The docs in https://github.com/http4k/http4k.github.io seem autogenerated. Is there another place we're supposed to contribute to the docs?

Yes - this is exactly correct. For multiple examples to be rendered you need to provide all of them. It's a bit of a limitation.

The reason is because normally filters are only applied AFTER you match (in a routing context)

PSA - we've added search back into the http4k site - powered by Algolia. Hopefully it's useful - but feedback appreciated 😄

Hi, is there a way to configure timeouts for requests?

@dave I can't run the GraphQL example any idea why... I see you changed it not long ago... I copy pasted it move it in the right package yet still got:

Exception in thread "main" java.lang.ExceptionInInitializerError
	at guide.reference.graphql.TmpKt.main(Tmp.kt:32)
	at guide.reference.graphql.TmpKt.main(Tmp.kt)
Caused by: com.expediagroup.graphql.generator.exceptions.EmptyQueryTypeException: Invalid query object type - no valid queries are available.

Hi... super impressed with how quickly you guys are able to add new integrations. Trying out the AWS Lambda by converting a working API. 2 questions... can it be run locally? There is no

main()

when the entry point is

class HelloServerlessHttp4k : ApiGatewayV1LambdaFunction(http4kApp)

. Also, how to import the

LambdaHttpClient

? thank you

totally separate question - can you define a Lens with add'l function or post-processing? example:

val myLens = Query.nonEmptyString().required("ids")...split(";")

Within the route I can insert the request then add functions:

myLens(myRequest).split(";")

but is it possible to add the

split

to the Lens definition?

Hi, I'm getting a bit crazy here, any clue at what can go wrong ? (yep already invalidated caches) In a file got this contract route:

private val bodyTokenResponseLens = Body.auto<TokenResponse>().toLens()

    fun createTokenRoute(): ContractRoute = "/token" meta {
        returning(OK, bodyTokenResponseLens to TokenResponse("A", "B", 1800))
    } bindContract <http://Method.POST|Method.POST> to createTokenHandler2()
    private fun createTokenHandler2(): HttpHandler = { req -> Response(OK) }

try to use it in with a openApi3 render I get a

Exception in thread "main" java.lang.NullPointerException
	at org.http4k.contract.RouteMetaDsl.returningStatus(routeMeta.kt:85)
	at org.http4k.contract.RouteMetaDsl.returningStatus$default(routeMeta.kt:83)

If i comment the return line is all OK, if it take the code and move it in test class it runs...

About OpenApi, if i create my one BasicAuthSecurity like copy paste of the existent one

class FakeBasicAuthSecurity(realm: String,  credentials: Credentials, val name: String = "basicAuth") : Security {
        override val filter: Filter = ServerFilters.BasicAuth(realm, credentials )
        companion object
    }

and I use it in

security = FakeBasicAuthSecurity("Backbone", Credentials("tom", "jerry"))

No Security is added generated spec, any reason why ?

Hello, I'm new to this and having a little trouble wrapping my head around a basic concept. So I have the generated ExampleContractRoute,

object ExampleContractRoute {
    // this specifies the route contract, including examples of the input and output body objects - they will
    // get exploded into JSON schema in the OpenAPI docs
    private val spec = "/echo" meta {
        summary = "echoes the name and message sent to it"
        receiving(nameAndMessageLens to NameAndMessage("jim", "hello!"))
        returning(OK, nameAndMessageLens to NameAndMessage("jim", "hello!"))
    } bindContract POST

    // note that because we don't have any dynamic parameters, we can use a HttpHandler instance instead of a function
    private val echo: HttpHandler = { request: Request ->
        val received: NameAndMessage = nameAndMessageLens(request)
        Response(OK).with(nameAndMessageLens of received)
    }

    operator fun invoke(): ContractRoute = spec to echo
}

which is being called inside contract in my app function

"/" bind contract {
        renderer = OpenApi3(ApiInfo("Test API", "v1.0"), Jackson)

        // Return Swagger API definition under /swagger.json
        descriptionPath = "/swagger.json"

        // Add contract routes
        routes += ExampleContractRoute()
        routes += HealthRoute()
    },

and I'm trying to add a nested route to the ExampleContract route, like

/echo/excited

just as a toy example What would be idiomatic way to do that?

Hello all, is it possible to stack filters which apply to specific routes? For example, could I have a stack of BasicAuth filters, each for a specific route?

Hi, I am a newbie to serverless and this example from the documentation is very helpful: http4k Tutorial: Serverless http4k with AWS Lambda I am able to quickly deploy and understand the nuances. Thanks for this great library and documentation. Now I am looking for an example where a db is used with AWS lambda in Http4k, are there any sample codebases which can help? Thanks!

Hello all, I have a simple ContractRoute based on the example in the docs (https://www.http4k.org/guide/reference/contracts/). If I send a request to the echo route with the Accept header set to application/xml I get the JSON response back. My expectation was that I would get a 406. I was also expecting to get a 405 if I try to make a request to a defined route using the wrong HTTP method. What do I need to do to implement this behaviour?

So a few days ago, you said you'd suggest applying the correct filter to the correct route. Is that possible with a ContractRoute? I have

fun partnerAccountTaskRoute(): ContractRoute {
    return spec to ::partnerAccountTaskHandler
}
fun partnerAccountTaskHandler(partnerAccountId: Long, task: String, taskType: String): HttpHandler = { request: Request ->
...
}
and
fun validTaskTypeFilter() = Filter { next ->
...
}

but I can't figure out how to compose the

spec to ::function

with the filter on it

One of my apps is hosted on Heroku and has one route that kicks off a long-running process. Heroku requires at least some data to be returned to the client within 30 seconds or it returns a timeout error. Is there a recommended pattern for periodically sending a small response back to the client (i.e. "waiting...") in order to avoid the connection timeout? I think this might be a case for using "server-sent events" but not sure how to integrate into a running route. thank you

Hi all, recently stumbled upon the http4k library and looking forward to try it in one of my pet projects!

Hi all. Question: I'm trying to stream a JDBC Blob as a response. The database transactions are handled in a http4k filter. However, when Jetty tries to create the HttpServletResponse and reads the Inputstream, we're not in the context of the http4k transaction filter anymore. At that point, the JDBC resultset is closed and the inputstream cannot be read anymore. Is there any way out of this?

We are using http4k with OpenApi doc generation with custom jackson. That is great as the examples in OpenApi are 100% equal to responses. However, this is not true for enum models. For example this enum model for DonutSize correctly show "example: d4" in lowercase (as we use jackson enum transformer to lowercase), but the individual enums are rendered uppercase. Is there something special we need to do for the enum models to be generated lowercase? Thanks!

Actually, the

+

appears to be valid for

application/x-www-form-urlencoded

content such as query args, so http4k's implementation is valid. A workaround would still be great, if possible.

I have a question regarding frame size for web sockets, how does one set this?

Is it possible to serve SSE using KtorCIO?

I have the following code:

object HelloWorldQueryHandler {
  fun hello(yourname: String) = "Hello $yourname"
}

class GraphQLHandler: GraphQLHandler {
  private val graphql = newGraphQL(
    toSchema(
      SchemaGeneratorConfig(supportedPackages = listOf("no.example.capgemini")),
      listOf(TopLevelObject(HelloWorldQueryHandler))
    )
  ).build()

  override fun invoke(request: GraphQLRequest): GraphQLResponse =
    GraphQLResponse.from(
      graphql.execute {
        Builder()
          .query(request.query)
          .variables(request.variables)
      }
    )
}

fun main() {
  val app = routes("/graphql" bind graphQL(GraphQLHandler()))
  app.asServer(Netty()).start()
}

Now, this works when I use the GraphQL playground, but not when I use the Graphiql client. For the Graphiql client, this just returns an empty response. Am I missing something? Why is there a difference?

heyo 👋 just a quick one - What is the correct way to remove the timeout for a websocket? Can't see it in the wshandler or websocket classes but am getting the following after the connection is chilling for a while:

Error: org.eclipse.jetty.websocket.api.CloseException: java.util.concurrent.TimeoutException: Idle timeout expired: 300008/300000 ms

Have you tried sending something back from the endpoint? eg:

val sse = sse(
            "/hello" bind sse(
                "/{name}" bind { sse: Sse ->
                    val name = sse.connectRequest.path("name")!!
                    sse.send(Event("event1", "hello $name", "123"))
                    sse.send(Event("event2", "again $name", "456"))
                    sse.send(Data("goodbye $name".byteInputStream()))
                }
            )
        )