1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

use crate::into::IntoResponse;

use std::path::Path;
use std::convert::AsRef;

use tokio::{io, fs};

use http::header::Mime;
use http::{Response, Body};


pub struct File {
	file: fs::File,
	mime_type: Mime,
	size: usize
}

impl File {

	pub fn new<M>(file: fs::File, mime_type: M, size: usize) -> Self
	where M: Into<Mime> {
		Self { file, mime_type: mime_type.into(), size }
	}

	/// if the path is directory
	/// returns io::Error NotFound
	pub async fn open<P>(path: P) -> io::Result<Self>
	where P: AsRef<Path> {

		let extension = path.as_ref()
			.extension()
			.and_then( |f| f.to_str() );

		let mime_type = match extension {
			Some(e) => Mime::from_ext(e),
			None => Mime::Binary
		};

		let file = fs::File::open( path ).await?;
		let metadata = file.metadata().await?;

		// make sure we open a file
		if !metadata.is_file() {
			return Err(io::Error::new(
				io::ErrorKind::NotFound,
				"expected file found folder"
			))
		}

		let size = metadata.len() as usize;

		Ok( Self {
			file, mime_type, size
		} )
	}

}

impl IntoResponse for File {
	fn into_response(self) -> Response {
		Response::builder()
			.content_type(self.mime_type)
			.header("content-length", self.size)
			.body(Body::from_async_read(self.file))
			.build()
	}
}