mirror of
https://github.com/Jackzmc/storage.git
synced 2025-05-10 11:53:22 +00:00
Get icons working
This commit is contained in:
parent
fdebc535a0
commit
c6006dd592
9 changed files with 170 additions and 22 deletions
|
@ -1,5 +1,5 @@
|
|||
use std::sync::Arc;
|
||||
use log::debug;
|
||||
use log::{debug, error, info, trace, warn};
|
||||
use rocket::{catch, launch, routes, Request, State};
|
||||
use rocket::data::ByteUnit;
|
||||
use rocket::fs::{relative, FileServer};
|
||||
|
@ -34,7 +34,11 @@ async fn rocket() -> _ {
|
|||
setup_logger();
|
||||
dotenvy::dotenv().ok();
|
||||
|
||||
let handlebars = Handlebars::new();
|
||||
trace!("trace");
|
||||
debug!("debug");
|
||||
info!("info");
|
||||
warn!("warn");
|
||||
error!("error");
|
||||
|
||||
let pool = PgPoolOptions::new()
|
||||
.max_connections(5)
|
||||
|
@ -61,13 +65,16 @@ async fn rocket() -> _ {
|
|||
.manage(repo_manager)
|
||||
.manage(libraries_manager)
|
||||
.mount("/static", FileServer::from(relative!("static")))
|
||||
.mount("/api/library", routes![
|
||||
api::library::move_file, api::library::upload_file, api::library::download_file, api::library::list_files, api::library::get_file, api::library::delete_file,
|
||||
])
|
||||
.mount("/", routes![
|
||||
ui::user::index, ui::user::list_library_files
|
||||
])
|
||||
.mount("/api", routes![
|
||||
api::library::move_file, api::library::upload_file, api::library::download_file, api::library::list_files, api::library::get_file, api::library::delete_file,
|
||||
])
|
||||
.attach(Template::fairing())
|
||||
.attach(Template::custom(|engines| {
|
||||
let _ = engines
|
||||
.handlebars;
|
||||
}))
|
||||
|
||||
}
|
||||
|
||||
|
|
|
@ -17,12 +17,39 @@ pub enum StorageBackendMap {
|
|||
}
|
||||
|
||||
#[derive(Debug, Serialize, Deserialize)]
|
||||
pub struct FileEntry {
|
||||
pub file_name: String,
|
||||
// last_modified:
|
||||
pub file_size: u64,
|
||||
#[serde(rename_all = "lowercase")]
|
||||
pub enum FileType {
|
||||
File,
|
||||
Folder,
|
||||
Symlink,
|
||||
Other
|
||||
}
|
||||
|
||||
impl From<std::fs::FileType> for FileType {
|
||||
fn from(value: std::fs::FileType) -> Self {
|
||||
if value.is_file() {
|
||||
FileType::File
|
||||
} else if value.is_dir() {
|
||||
FileType::Folder
|
||||
} else if value.is_symlink() {
|
||||
FileType::Symlink
|
||||
} else {
|
||||
FileType::Other
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Debug, Serialize, Deserialize)]
|
||||
pub struct FileEntry {
|
||||
pub path: String,
|
||||
// last_modified:
|
||||
pub size: u64,
|
||||
#[serde(rename="type")]
|
||||
pub _type: FileType,
|
||||
}
|
||||
|
||||
|
||||
|
||||
pub fn get_backend(storage_type: &str, settings: &JsonValue) -> Result<Option<Box<dyn StorageBackend + Send + Sync>>, anyhow::Error> {
|
||||
Ok(match storage_type {
|
||||
"local" => Some(Box::new(LocalStorage::new(settings)?)),
|
||||
|
|
|
@ -19,7 +19,10 @@ impl LocalStorage {
|
|||
}
|
||||
}
|
||||
|
||||
fn get_path(folder_root: &PathBuf, library_id: &str, path: &PathBuf) -> Result<PathBuf, anyhow::Error> {
|
||||
fn get_path(folder_root: &PathBuf, library_id: &str, mut path: &Path) -> Result<PathBuf, anyhow::Error> {
|
||||
if path.starts_with("/") {
|
||||
path = path.strip_prefix("/")?
|
||||
}
|
||||
let path = folder_root.join(library_id).join(path);
|
||||
// Prevent path traversal
|
||||
debug!("root={:?}", folder_root);
|
||||
|
@ -51,9 +54,12 @@ impl StorageBackend for LocalStorage {
|
|||
.map(|entry| entry.unwrap())
|
||||
.map(|entry| {
|
||||
let meta = entry.metadata().unwrap();
|
||||
let file_type = meta.file_type().into();
|
||||
// TODO: filter out 'other'
|
||||
FileEntry {
|
||||
file_name: entry.file_name().into_string().unwrap(),
|
||||
file_size: meta.size()
|
||||
_type: file_type,
|
||||
path: entry.file_name().into_string().unwrap(),
|
||||
size: meta.size()
|
||||
}
|
||||
})
|
||||
.collect())
|
||||
|
|
|
@ -1,8 +1,11 @@
|
|||
use std::fs;
|
||||
use std::io::Cursor;
|
||||
use rocket::http::{ContentType, Status};
|
||||
use rocket::{response, Request, Response};
|
||||
use rocket::fs::relative;
|
||||
use rocket::response::Responder;
|
||||
use rocket::serde::Serialize;
|
||||
use rocket_dyn_templates::handlebars::Handlebars;
|
||||
use sqlx::Error;
|
||||
use tracing_subscriber::layer::SubscriberExt;
|
||||
use tracing_subscriber::util::SubscriberInitExt;
|
||||
|
@ -12,12 +15,32 @@ pub(crate) fn setup_logger() {
|
|||
tracing_subscriber::registry()
|
||||
.with(
|
||||
tracing_subscriber::filter::EnvFilter::try_from_default_env()
|
||||
.unwrap_or_else(|_| format!("warn,rocket=trace,storage-server=trace").into()),
|
||||
.unwrap_or_else(|_| format!("warn,rocket=trace,storage_server=trace").into()),
|
||||
)
|
||||
.with(tracing_subscriber::fmt::layer())
|
||||
.init();
|
||||
}
|
||||
|
||||
// pub(crate) fn setup_template_engine() -> Handlebars<'static> {
|
||||
// let mut hb = Handlebars::new();
|
||||
// #[cfg(debug_assertions)]
|
||||
// hb.set_dev_mode(true);
|
||||
//
|
||||
// let templates = fs::read_dir(relative!("templates")).unwrap();
|
||||
// let mut ok = true;
|
||||
// for file in templates {
|
||||
// let file = file.unwrap();
|
||||
// if let Err(e) = hb.register_template_file(file.path().to_str().unwrap(), ) {
|
||||
// error!(template, path = %path.display(),
|
||||
// "failed to register Handlebars template: {e}");
|
||||
//
|
||||
// ok = false;
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// hb
|
||||
// }
|
||||
|
||||
#[derive(Debug, Clone, Serialize)]
|
||||
pub struct JsonErrorResponse {
|
||||
pub(crate) code: String,
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue