aboutsummaryrefslogtreecommitdiff
path: root/server/src/routes/api
diff options
context:
space:
mode:
Diffstat (limited to 'server/src/routes/api')
-rw-r--r--server/src/routes/api/error.rs57
-rw-r--r--server/src/routes/api/mod.rs51
2 files changed, 108 insertions, 0 deletions
diff --git a/server/src/routes/api/error.rs b/server/src/routes/api/error.rs
new file mode 100644
index 0000000..ef5374c
--- /dev/null
+++ b/server/src/routes/api/error.rs
@@ -0,0 +1,57 @@
+// TODO: Slightâ„¢ code duplication with `ui/error.rs`
+
+use rocket::{
+ response::{self, Responder},
+ Request,
+};
+use serde_json::{json, Value};
+use std::fmt::Display;
+
+use crate::routes::ui::error::MyError;
+
+pub type ApiResult<T> = Result<T, ApiError>;
+
+#[derive(Debug)]
+pub struct ApiError(pub anyhow::Error);
+
+impl<'r> Responder<'r, 'static> for ApiError {
+ fn respond_to(self, req: &'r Request<'_>) -> response::Result<'static> {
+ json!({ "error": format!("{}", self.0) }).respond_to(req)
+ }
+}
+
+impl Display for ApiError {
+ fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+ self.0.fmt(f)
+ }
+}
+impl From<anyhow::Error> for ApiError {
+ fn from(err: anyhow::Error) -> ApiError {
+ ApiError(err)
+ }
+}
+impl From<std::fmt::Error> for ApiError {
+ fn from(err: std::fmt::Error) -> ApiError {
+ ApiError(anyhow::anyhow!("{err}"))
+ }
+}
+impl From<std::io::Error> for ApiError {
+ fn from(err: std::io::Error) -> Self {
+ ApiError(anyhow::anyhow!("{err}"))
+ }
+}
+impl From<sled::Error> for ApiError {
+ fn from(err: sled::Error) -> Self {
+ ApiError(anyhow::anyhow!("{err}"))
+ }
+}
+impl From<serde_json::Error> for ApiError {
+ fn from(err: serde_json::Error) -> Self {
+ ApiError(anyhow::anyhow!("{err}"))
+ }
+}
+impl From<MyError> for ApiError {
+ fn from(value: MyError) -> Self {
+ Self(value.0)
+ }
+}
diff --git a/server/src/routes/api/mod.rs b/server/src/routes/api/mod.rs
new file mode 100644
index 0000000..5f48873
--- /dev/null
+++ b/server/src/routes/api/mod.rs
@@ -0,0 +1,51 @@
+pub mod error;
+
+use std::path::PathBuf;
+
+use super::ui::account::{login_logic, LoginForm};
+use crate::{
+ database::Database,
+ library::{Library, Node},
+ routes::{api::error::ApiResult, ui::account::session::Session},
+};
+use anyhow::Context;
+use rocket::{get, http::CookieJar, post, serde::json::Json, State};
+use serde_json::{json, Value};
+
+#[get("/api/version")]
+pub fn r_api_version() -> &'static str {
+ "1"
+}
+
+#[post("/api/account/login", data = "<data>")]
+pub fn r_api_account_login(
+ database: &State<Database>,
+ jar: &CookieJar,
+ data: Json<LoginForm>,
+) -> ApiResult<Value> {
+ login_logic(jar, database, &data.username, &data.password)?;
+ Ok(json!({ "ok": true }))
+}
+
+#[get("/api/library/<path..>")]
+pub fn r_api_library_node(
+ _sess: Session,
+ path: PathBuf,
+ library: &State<Library>,
+) -> ApiResult<Value> {
+ let node = library
+ .nested_path(&path)
+ .context("retrieving library node")?;
+
+ match node.as_ref() {
+ Node::Directory(d) => Ok(json!({
+ "identifier": d.identifier,
+ "info": d.info,
+ "children": d.children.iter().map(|c| c.identifier().to_string()).collect::<Vec<_>>()
+ })),
+ Node::Item(i) => Ok(json!({
+ "identifier": i.identifier,
+ "info": i.info,
+ })),
+ }
+}