mirror
/
Riven
mirror of https://github.com/MingweiSamuel/Riven
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity
Riven/riven/examples/proxy/main.rs

199 lines
6.3 KiB
Rust
Raw Normal View History

Adding example API proxy project
2020-06-05 08:51:25 +00:00
// #![deny(warnings)]
use std::convert::Infallible;
chore: replace `lazy_static` with std `OnceLock`
2024-02-24 17:46:11 +00:00
use std::sync::OnceLock;
Adding example API proxy project
2020-06-05 08:51:25 +00:00
cargo fmt
2023-05-10 18:20:15 +00:00
use http::{Method, Request, Response, StatusCode};
Adding example API proxy project
2020-06-05 08:51:25 +00:00
use hyper::header::HeaderValue;
cargo fmt
2023-05-10 18:20:15 +00:00
use hyper::service::{make_service_fn, service_fn};
Add rustfmt.toml
2024-01-21 03:41:46 +00:00
use hyper::{http, Body, Server};
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
use riven::consts::Route;
cargo fmt
2023-05-10 18:20:15 +00:00
use riven::{RiotApi, RiotApiConfig};
Add rustfmt.toml
2024-01-21 03:41:46 +00:00
use tracing as log;
Adding example API proxy project
2020-06-05 08:51:25 +00:00
chore: replace `lazy_static` with std `OnceLock`
2024-02-24 17:46:11 +00:00
static RIOT_API: OnceLock<RiotApi> = OnceLock::new();
pub fn riot_api() -> &'static RiotApi {
RIOT_API.get_or_init(|| {
let api_key = std::env::var("RGAPI_KEY")
.ok()
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
.or_else(|| {
chore: replace `lazy_static` with std `OnceLock`
2024-02-24 17:46:11 +00:00
use std::iter::FromIterator;
let path =
std::path::PathBuf::from_iter([env!("CARGO_MANIFEST_DIR"), "../apikey.txt"]);
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
std::fs::read_to_string(path).ok()
})
Adding example API proxy project
2020-06-05 08:51:25 +00:00
.expect("Failed to find RGAPI_KEY env var or apikey.txt.");
Add RiotApi::new(impl Into<RiotApiConfig>), deprecate old constructors, update docs - Adds `From<AsRef<[u8]>> for RiotApiConfig` for API keys for the above.
2021-09-19 18:22:09 +00:00
RiotApi::new(RiotApiConfig::with_key(api_key.trim()).preconfig_burst())
chore: replace `lazy_static` with std `OnceLock`
2024-02-24 17:46:11 +00:00
})
Adding example API proxy project
2020-06-05 08:51:25 +00:00
}
/// Helper to create JSON error responses.
fn create_json_response(body: &'static str, status: StatusCode) -> Response<Body> {
let mut resp = Response::new(Body::from(body));
*resp.status_mut() = status;
cargo fmt
2023-05-10 18:20:15 +00:00
resp.headers_mut().insert(
hyper::header::CONTENT_TYPE,
HeaderValue::from_static("application/json"),
);
Cleanup per clippy recommendations
2021-10-30 05:38:48 +00:00
resp
Adding example API proxy project
2020-06-05 08:51:25 +00:00
}
/// Main request handler service.
async fn handle_request(req: Request<Body>) -> Result<Response<Body>, Infallible> {
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
let (parts, body) = req.into_parts();
let http::request::Parts { method, uri, .. } = parts;
Adding example API proxy project
2020-06-05 08:51:25 +00:00
// Handle path.
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
let path_data_opt = parse_path(&method, uri.path());
cargo fmt
2023-05-10 18:20:15 +00:00
let (route, method_id, req_path) = match path_data_opt {
None => {
return Ok(create_json_response(
r#"{"error":"Riot API endpoint method not found."}"#,
StatusCode::NOT_FOUND,
))
}
Adding example API proxy project
2020-06-05 08:51:25 +00:00
Some(path_data) => path_data,
};
cargo fmt
2023-05-10 18:20:15 +00:00
log::debug!(
"Request to route {:?}, method ID {:?}: {} {:?}.",
route,
method_id,
method,
req_path
);
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
// Convert http:request::Parts from hyper to reqwest's RequestBuilder.
let body = match hyper::body::to_bytes(body).await {
Err(err) => {
log::info!("Error handling request body: {:#?}", err);
return Ok(create_json_response(
cargo fmt
2023-05-10 18:20:15 +00:00
r#"{"error":"Failed to handle request body."}"#,
StatusCode::BAD_REQUEST,
));
}
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
Ok(bytes) => bytes,
};
chore: replace `lazy_static` with std `OnceLock`
2024-02-24 17:46:11 +00:00
let req_builder = riot_api()
.request(method, route.into(), req_path)
.body(body);
Adding example API proxy project
2020-06-05 08:51:25 +00:00
// Send request to Riot API.
chore: replace `lazy_static` with std `OnceLock`
2024-02-24 17:46:11 +00:00
let resp_result = riot_api()
cargo fmt
2023-05-10 18:20:15 +00:00
.execute_raw(method_id, route.into(), req_builder)
.await;
Adding example API proxy project
2020-06-05 08:51:25 +00:00
let resp_info = match resp_result {
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
Err(err) => {
log::info!("Riot API error: {:#?}", err.source_reqwest_error());
return Ok(create_json_response(
cargo fmt
2023-05-10 18:20:15 +00:00
r#"{"error":"Riot API request failed."}"#,
StatusCode::INTERNAL_SERVER_ERROR,
));
}
Adding example API proxy project
2020-06-05 08:51:25 +00:00
Ok(resp_info) => resp_info,
};
// Write output.
let api_response = resp_info.response;
let mut out_response = Response::default();
*out_response.headers_mut() = api_response.headers().clone();
// If None, write "null" to body to be extra nice.
if resp_info.status_none {
*out_response.body_mut() = Body::from("null");
}
// Otherwise copy body.
else {
cargo fmt
2023-05-10 18:20:15 +00:00
*out_response.status_mut() = api_response.status();
Adding example API proxy project
2020-06-05 08:51:25 +00:00
// Using streams would be faster.
let bytes_result = api_response.bytes().await;
let bytes = match bytes_result {
cargo fmt
2023-05-10 18:20:15 +00:00
Err(_err) => {
return Ok(create_json_response(
r#"{"error":"Failed to get body from Riot API response."}"#,
StatusCode::INTERNAL_SERVER_ERROR,
))
}
Adding example API proxy project
2020-06-05 08:51:25 +00:00
Ok(bytes) => bytes,
};
cargo clippy fixes, enable lints in CI
2023-05-10 18:27:57 +00:00
*out_response.body_mut() = Body::from(bytes);
Adding example API proxy project
2020-06-05 08:51:25 +00:00
}
Cleanup per clippy recommendations
2021-10-30 05:38:48 +00:00
Ok(out_response)
Adding example API proxy project
2020-06-05 08:51:25 +00:00
}
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
/// Gets the region, method_id, and Riot API path based on the given http method and path.
cargo fmt
2023-05-10 18:20:15 +00:00
fn parse_path<'a>(
http_method: &Method,
req_path: &'a str,
) -> Option<(Route, &'static str, &'a str)> {
Adding example API proxy project
2020-06-05 08:51:25 +00:00
// Split URI into region and rest of path.
let req_path = req_path.trim_start_matches('/');
cargo fmt
2023-05-10 18:20:15 +00:00
let (route, req_path) = req_path.split_at(req_path.find('/')?);
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
let route: Route = route.to_uppercase().parse().ok()?;
Adding example API proxy project
2020-06-05 08:51:25 +00:00
// Find method_id for given path.
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
let method_id = find_matching_method_id(http_method, req_path)?;
Adding example API proxy project
2020-06-05 08:51:25 +00:00
cargo fmt
2023-05-10 18:20:15 +00:00
Some((route, method_id, req_path))
Adding example API proxy project
2020-06-05 08:51:25 +00:00
}
/// Finds the method_id given the request path.
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
fn find_matching_method_id(http_method: &Method, req_path: &str) -> Option<&'static str> {
cargo fmt
2023-05-10 18:20:15 +00:00
for (endpoint_http_method, ref_path, method_id) in &riven::meta::ALL_ENDPOINTS {
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
if http_method == endpoint_http_method && paths_match(ref_path, req_path) {
Adding example API proxy project
2020-06-05 08:51:25 +00:00
return Some(method_id);
}
}
None
}
/// Checks if the request path (req_path) matches the reference path (ref_path).
fn paths_match(ref_path: &str, req_path: &str) -> bool {
let mut ref_iter = ref_path.split('/');
let mut req_iter = req_path.split('/');
loop {
Clean up double if-lets with tuple matches
2022-03-14 20:05:54 +00:00
match (ref_iter.next(), req_iter.next()) {
(None, None) => return true,
(Some(ref_seg), Some(req_seg)) => {
if ref_seg.starts_with('{') || ref_seg == req_seg {
continue;
}
return false;
Adding example API proxy project
2020-06-05 08:51:25 +00:00
}
Clean up double if-lets with tuple matches
2022-03-14 20:05:54 +00:00
_ => return false,
}
Adding example API proxy project
2020-06-05 08:51:25 +00:00
}
}
#[tokio::main]
pub async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
// Setup loggers.
// env_logger::init();
tracing_subscriber::fmt::init();
chore: replace `lazy_static` with std `OnceLock`
2024-02-24 17:46:11 +00:00
// Trigger initialization.
let _ = riot_api();
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
Adding example API proxy project
2020-06-05 08:51:25 +00:00
// For every connection, we must make a `Service` to handle all
// incoming HTTP requests on said connection.
let make_svc = make_service_fn(|_conn| {
// This is the `Service` that will handle the connection.
// `service_fn` is a helper to convert a function that
// returns a Response into a `Service`.
async { Ok::<_, Infallible>(service_fn(handle_request)) }
});
cargo fmt
2023-05-10 18:20:15 +00:00
let addr = ([127, 0, 0, 1], 3000).into();
Adding example API proxy project
2020-06-05 08:51:25 +00:00
let server = Server::bind(&addr).serve(make_svc);
Update example proxy for v2, use workspaces. - `example/proxy` is new folder for `example_proxy`. - `riven` is new folder for the main riven lib. - Updated metadata to be an array and include HTTP method.
2021-09-09 21:31:39 +00:00
log::info!("Listening on http://{}", addr);
Adding example API proxy project
2020-06-05 08:51:25 +00:00
server.await?;
Ok(())
}