mirror of
https://github.com/denoland/deno.git
synced 2025-09-21 09:59:48 +00:00
76ce7768ab
1. Removes the access check callback, which was kind of confusing. 1. Requires `CheckedPath` for everything in the `FileSystem` trait to ensure we're always checking permissions.
89 lines
2.4 KiB
Rust
89 lines
2.4 KiB
Rust
// Copyright 2018-2025 the Deno authors. MIT license.
|
|
|
|
use std::borrow::Cow;
|
|
use std::rc::Rc;
|
|
|
|
use deno_core::CancelFuture;
|
|
use deno_core::OpState;
|
|
use deno_core::futures::FutureExt;
|
|
use deno_core::futures::TryFutureExt;
|
|
use deno_core::futures::TryStreamExt;
|
|
use deno_core::url::Url;
|
|
use deno_error::JsErrorBox;
|
|
use deno_fs::OpenOptions;
|
|
use deno_fs::open_options_for_checked_path;
|
|
use deno_permissions::OpenAccessKind;
|
|
use deno_permissions::PermissionsContainer;
|
|
use http::StatusCode;
|
|
use http_body_util::BodyExt;
|
|
use tokio_util::io::ReaderStream;
|
|
|
|
use crate::CancelHandle;
|
|
use crate::CancelableResponseFuture;
|
|
use crate::FetchHandler;
|
|
|
|
/// An implementation which tries to read file URLs from the file system via
|
|
/// tokio::fs.
|
|
#[derive(Clone)]
|
|
pub struct FsFetchHandler;
|
|
|
|
impl FetchHandler for FsFetchHandler {
|
|
fn fetch_file(
|
|
&self,
|
|
state: &mut OpState,
|
|
url: &Url,
|
|
) -> (CancelableResponseFuture, Option<Rc<CancelHandle>>) {
|
|
let cancel_handle = CancelHandle::new_rc();
|
|
let path = match url.to_file_path() {
|
|
Ok(path) => path,
|
|
Err(_) => {
|
|
let fut = async move { Err::<_, _>(()) };
|
|
return (
|
|
fut
|
|
.map_err(move |_| super::FetchError::NetworkError)
|
|
.or_cancel(&cancel_handle)
|
|
.boxed_local(),
|
|
Some(cancel_handle),
|
|
);
|
|
}
|
|
};
|
|
let path_and_opts_result = {
|
|
state
|
|
.borrow::<PermissionsContainer>()
|
|
.check_open(Cow::Owned(path), OpenAccessKind::Read, Some("fetch()"))
|
|
.map(|path| {
|
|
(
|
|
open_options_for_checked_path(
|
|
OpenOptions {
|
|
read: true,
|
|
..Default::default()
|
|
},
|
|
&path,
|
|
),
|
|
path.into_owned(),
|
|
)
|
|
})
|
|
};
|
|
let response_fut = async move {
|
|
let (opts, path) = path_and_opts_result?;
|
|
let file = tokio::fs::OpenOptions::from(opts)
|
|
.open(path)
|
|
.await
|
|
.map_err(|_| super::FetchError::NetworkError)?;
|
|
let stream = ReaderStream::new(file)
|
|
.map_ok(hyper::body::Frame::data)
|
|
.map_err(JsErrorBox::from_err);
|
|
|
|
let body = http_body_util::StreamBody::new(stream).boxed();
|
|
let response = http::Response::builder()
|
|
.status(StatusCode::OK)
|
|
.body(body)
|
|
.map_err(move |_| super::FetchError::NetworkError)?;
|
|
Ok::<_, _>(response)
|
|
}
|
|
.or_cancel(&cancel_handle)
|
|
.boxed_local();
|
|
|
|
(response_fut, Some(cancel_handle))
|
|
}
|
|
}
|