nik/chorus
1
0
Fork 0
mirror of https://github.com/mikedilger/chorus.git synced 2026-05-03 06:51:42 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Blossom: implement GET/HEAD/DELETE /<sha256>

Browse Source
This commit is contained in:
Mike Dilger 2024-11-17 14:25:00 +13:00
parent bcb0fc1c95
commit 3f26b47008
No known key found for this signature in database
GPG Key ID: 47581A78D4329BA4
1 changed files with 48 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
src/web/blossom/mod.rs
View File

@ -1,4 +1,6 @@
use crate::error::{ChorusError, Error};
use crate::filestore::HashOutput;
use crate::globals::GLOBALS;
use http::header::{
ACCESS_CONTROL_ALLOW_HEADERS, ACCESS_CONTROL_ALLOW_METHODS, ACCESS_CONTROL_ALLOW_ORIGIN,
ACCESS_CONTROL_REQUEST_HEADERS, ACCESS_CONTROL_REQUEST_METHOD, ALLOW, CONTENT_LENGTH, ORIGIN,
@ -12,7 +14,7 @@ use hyper::body::{Bytes, Incoming};
use hyper::{Request, Response};
mod auth;
use auth::verify_auth;
use auth::{verify_auth, AuthVerb};
pub async fn handle(request: &Request<Incoming>) -> Result<Response<BoxBody<Bytes, Error>>, Error> {
match route(request).await {
@ -105,9 +107,52 @@ pub async fn handle_hash(
return options_response(request, "OPTIONS, HEAD, GET, DELETE");
}
let _auth_data = verify_auth(request)?;
// HEAD, GET, DELETE
let p = request.uri().path();
let hashstr: String = p.chars().skip(1).take(64).collect();
let hash = match HashOutput::from_hex(&hashstr) {
Ok(h) => h,
Err(e) => return error_response(e),
};
unimplemented!()
let metadata = GLOBALS.filestore.get().unwrap().metadata(hash).await?;
match request.method() {
&Method::HEAD => Ok(Response::builder()
.header(ACCESS_CONTROL_ALLOW_ORIGIN, "*")
.header(CONTENT_LENGTH, format!("{}", metadata.len()))
.status(StatusCode::OK)
.body(Empty::new().map_err(|e| e.into()).boxed())?),
&Method::GET => {
let body = GLOBALS.filestore.get().unwrap().retrieve(hash).await?;
Ok(Response::builder()
.header(ACCESS_CONTROL_ALLOW_ORIGIN, "*")
.header(CONTENT_LENGTH, format!("{}", metadata.len()))
.status(StatusCode::OK)
.body(body)?)
}
&Method::DELETE => {
let auth_data = verify_auth(request)?;
if auth_data.verb != Some(AuthVerb::Delete) {
return Err(ChorusError::BlossomAuthFailure(
"Delete was not authorized".to_string(),
)
.into());
}
GLOBALS.filestore.get().unwrap().delete(hash).await?;
Ok(Response::builder()
.header(ACCESS_CONTROL_ALLOW_ORIGIN, "*")
.header(CONTENT_LENGTH, "0")
.status(StatusCode::OK)
.body(Empty::new().map_err(|e| e.into()).boxed())?)
}
_ => Ok(Response::builder()
.header(ACCESS_CONTROL_ALLOW_ORIGIN, "*")
.header(CONTENT_LENGTH, "0")
.status(StatusCode::METHOD_NOT_ALLOWED)
.body(Empty::new().map_err(|e| e.into()).boxed())?),
}
}
pub async fn handle_upload(