How can i get request body?

[Adrift001]

I can't find a method to get request body. Can anyone help me?

[Lukasa]

HTTPClient.Request.body is where the request body will be stored.

Can you provide an example of your code where you'd like access to the request body?

[Adrift001]

public final class AuthorizationPlugin: PluginType {
    public func prepare(_ request: Request, target: TargetType) -> Request {
        var request = request
        let method = request.method
        let path = request.url.path
        let query = request.url.query == nil ? "" : "?\(request.url.query ?? "")"
        let host = request.host
        let contentType = request.headers["Content-Type"].first ?? ""
        
        #warning("Can't get request body")
        let signingStr = """
        \(method) \(path)\(query)
        Host: \(host)
        Content-Type: \(contentType)
        Body: body

        """
        request.headers.add(name: "Authorization", value: "Qiniu \(Auth.accessToken(signingStr: signingStr))")
        return request
    }
}

I need body data for generating token.

[Lukasa]

Body data will be available at request.body.

[Adrift001]

OK, thanks

[Adrift001]

How can i convert body to String?

[Lukasa]

body.readString(length: body.readableBytes).

[Adrift001]

I want convert Request.Body to String, not Response Body.
Request Body don't have this method.

[Lukasa]

Oh, I'm sorry.

This is not straightforward. Because Request.Body may be streamed, it is not trivial to convert it to a String. What do you need the String for?

[Adrift001]

I need body string to generate authorization token

[Lukasa]

Ok, so the only way to achieve this in full generality will be to consume the entire request body. Note that this may potentially invalidate the request, so you should also overwrite the request body.

To consume the request body you can do something like this:

import NIO
import AsyncHTTPClient

extension HTTPClient.Body {
    func consume(on loop: EventLoop) -> EventLoopFuture<String> {
        var string = ""
        let streamWriter = StreamWriter { data in
            switch data {
            case .fileRegion:
                preconditionFailure("not supporting reading from files today")
            case .byteBuffer(var data):
                string += data.readString(length: data.readableBytes)!
                return loop.makeSucceededFuture(())
            }
        }

        return self.stream(streamWriter).map { string }
    }
}

Note that this is a potentially destructive operation: nothing guarantees that streams can be replayed. This means your code will also need to create a new body using HTTPClient.Body.string with the returned string.

[Adrift001]

OK, thanks!