lfg2025/archy
1
0
Fork 0
Code Issues 7 Pull Requests Actions Packages Projects Releases 33 Wiki Activity

apps

Browse Source
This commit is contained in:
zazawowow
2026-01-24 23:20:54 +00:00
parent 1ac70634bd
commit a81f655133
28 changed files with 367 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
core/archipelago/src/api/handler.rs
View File

@@ -24,19 +24,18 @@ impl ApiHandler {
})
}
pub async fn handle_request<B>(&self, req: Request<B>) -> Result<Response<Full<Bytes>>>
where
B: http_body::Body<Data = Bytes> + Send + 'static,
B::Error: std::fmt::Display,
{
let path = req.uri().path();
let method = req.method();
pub async fn handle_request(
&self,
req: Request<http_body_util::Incoming>,
) -> Result<Response<Full<Bytes>>> {
// Extract path and method before consuming req
let path = req.uri().path().to_string();
let method = req.method().clone();
// Convert Incoming body to bytes using http_body_util::BodyExt
// Convert body to bytes using http_body_util::BodyExt
let (parts, body) = req.into_parts();
// hyper::body::Incoming implements http_body::Body, and BodyExt extends it
use http_body_util::BodyExt;
let collected = body.collect().await
let collected: http_body_util::Collected<Bytes> = body.collect().await
.map_err(|_e| anyhow::anyhow!("Failed to read body"))?;
let body_bytes = collected.to_bytes();
@@ -47,10 +46,10 @@ impl ApiHandler {
// Route requests
match (method, path.as_str()) {
(&Method::POST, "/rpc/v1") => {
(Method::POST, "/rpc/v1") => {
self.rpc_handler.handle(req_with_bytes).await
}
(&Method::GET, "/health") => {
(Method::GET, "/health") => {
Ok(Response::builder()
.status(StatusCode::OK)
.body(Full::new(Bytes::from("OK")))

14
core/target/debug/.fingerprint/archipelago-d6e22276b7d151e0/output-bin-archipelago
View File

File diff suppressed because one or more lines are too long

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-13080571815649368370.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-13480109837208735393.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-16530815148847034584.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-2571119572960884352.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-258302589074998887.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-3085004636163476733.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-5297176294878950764.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-6440040218073080055.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-887693907502688589.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:84}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:84}, _>, TokioExecutor>

2
core/target/debug/deps/archipelago-d6e22276b7d151e0.long-type-9696284442756867528.txt Normal file
View File

@@ -0,0 +1,2 @@
hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>: hyper::service::service::Service<http::request::Request<hyper::body::incoming::Incoming>>
hyper_util::server::conn::auto::Connection<'_, TokioIo<tokio::net::TcpStream>, hyper::service::util::ServiceFn<{closure@archipelago/src/server.rs:43:42: 43:52}, _>, TokioExecutor>

BIN
core/target/debug/incremental/archipelago-2k8v5whz85vjs/s-hf5vnrc5wt-0o2s9xh-working/dep-graph.part.bin
View File

Binary file not shown.

BIN
core/target/debug/incremental/archipelago-2k8v5whz85vjs/s-hf5vqutdnb-1w63c0p-working/dep-graph.part.bin Normal file
View File

Binary file not shown.

0
core/target/debug/incremental/archipelago-2k8v5whz85vjs/s-hf5vnrc5wt-0o2s9xh.lock → core/target/debug/incremental/archipelago-2k8v5whz85vjs/s-hf5vqutdnb-1w63c0p.lock
View File

BIN
core/target/debug/incremental/archipelago-2k8v5whz85vjs/s-hf5vr0cpqm-1g0np9x-working/dep-graph.part.bin Normal file
View File

Binary file not shown.

0
core/target/debug/incremental/archipelago-2k8v5whz85vjs/s-hf5vr0cpqm-1g0np9x.lock Executable file
View File