mirror of
https://github.com/neondatabase/neon.git
synced 2026-05-18 05:30:37 +00:00
b23742e09c
Add HTTP endpoint to get full safekeeper state of all existing timelines (all in-memory values and info about all files stored on disk). Example: https://gist.github.com/petuhovskiy/3cbb8f870401e9f486731d145161c286
45 lines
1.3 KiB
Rust
45 lines
1.3 KiB
Rust
use std::fmt::Display;
|
|
|
|
use anyhow::Context;
|
|
use bytes::Buf;
|
|
use hyper::{header, Body, Request, Response, StatusCode};
|
|
use serde::{Deserialize, Serialize, Serializer};
|
|
|
|
use super::error::ApiError;
|
|
|
|
pub async fn json_request<T: for<'de> Deserialize<'de>>(
|
|
request: &mut Request<Body>,
|
|
) -> Result<T, ApiError> {
|
|
let whole_body = hyper::body::aggregate(request.body_mut())
|
|
.await
|
|
.context("Failed to read request body")
|
|
.map_err(ApiError::BadRequest)?;
|
|
serde_json::from_reader(whole_body.reader())
|
|
.context("Failed to parse json request")
|
|
.map_err(ApiError::BadRequest)
|
|
}
|
|
|
|
pub fn json_response<T: Serialize>(
|
|
status: StatusCode,
|
|
data: T,
|
|
) -> Result<Response<Body>, ApiError> {
|
|
let json = serde_json::to_string(&data)
|
|
.context("Failed to serialize JSON response")
|
|
.map_err(ApiError::InternalServerError)?;
|
|
let response = Response::builder()
|
|
.status(status)
|
|
.header(header::CONTENT_TYPE, "application/json")
|
|
.body(Body::from(json))
|
|
.map_err(|e| ApiError::InternalServerError(e.into()))?;
|
|
Ok(response)
|
|
}
|
|
|
|
/// Serialize through Display trait.
|
|
pub fn display_serialize<S, F>(z: &F, s: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: Serializer,
|
|
F: Display,
|
|
{
|
|
s.serialize_str(&format!("{}", z))
|
|
}
|