Method post_json

gateway/src/kv/https_client.rs:197–229

Send a POST request with JSON body and receive JSON response

(
        &self,
        url: &str,
        body: &T,
    )

    /// Send a POST request with JSON body and receive JSON response
    pub async fn post_json<T: Serialize, R: DeserializeOwned>(
        &self,
        url: &str,
        body: &T,
    ) -> Result<R> {
        let body = serde_json::to_vec(body).context("failed to serialize request body")?;

        let request = hyper::Request::builder()
            .method(hyper::Method::POST)
            .uri(url)
            .header("content-type", "application/json")
            .body(Full::new(Bytes::from(body)))
            .context("failed to build request")?;

        let response = self
            .client
            .request(request)
            .await
            .with_context(|| format!("failed to send request to {url}"))?;

        if !response.status().is_success() {
            anyhow::bail!("request failed: {}", response.status());
        }

        let body = response
            .into_body()
            .collect()
            .await
            .context("failed to read response body")?
            .to_bytes();

        serde_json::from_slice(&body).context("failed to parse response")
    }

    /// Send a POST request with msgpack + gzip encoded body and receive msgpack + gzip response
    pub async fn post_compressed_msg<T: Serialize, R: DeserializeOwned>(