use crate::api_result::APIResult; use crate::nextcloud::card::{AddLabel, Create}; use crate::nextcloud::model::{ Board, Card, NextcloudBoardId, NextcloudCardId, NextcloudHostname, NextcloudPassword, NextcloudStackId, NextcloudUsername, Stack, }; use crate::{f, FullCtx}; use bytes::Bytes; use kxio::net::{Net, ReqBuilder}; use serde_json::json; pub(crate) struct DeckClient<'ctx> { ctx: &'ctx FullCtx, hostname: &'ctx NextcloudHostname, username: &'ctx NextcloudUsername, password: &'ctx NextcloudPassword, } impl DeckClient<'_> {} // Uses the API described here: https://deck.readthedocs.io/en/stable/API/#cards impl<'ctx> DeckClient<'ctx> { pub fn new(ctx: &'ctx FullCtx) -> Self { Self { ctx, hostname: &ctx.cfg.nextcloud.hostname, username: &ctx.cfg.nextcloud.username, password: &ctx.cfg.nextcloud.password, } } fn url(&self, path: impl Into) -> String { f!( "https://{}/index.php/apps/deck/api/v1.0/{}", self.hostname, path.into() ) } async fn request serde::Deserialize<'a>>( &self, url: impl Into, custom: fn(&Net, String) -> ReqBuilder, ) -> APIResult { APIResult::new( custom(&self.ctx.net, self.url(url)) .basic_auth(self.username.as_str(), Some(self.password.as_str())) .header("accept", "application/json") .header("content-type", "application/json") .send() .await, &self.ctx.prt, ) .await } async fn request_with_body serde::Deserialize<'a>>( &self, url: impl Into, body: impl Into, custom: fn(&Net, String) -> ReqBuilder, ) -> APIResult { APIResult::new( custom(&self.ctx.net, self.url(url)) .basic_auth(self.username.as_str(), Some(self.password.as_str())) .header("accept", "application/json") .header("content-type", "application/json") .body(body) .send() .await, &self.ctx.prt, ) .await } pub(crate) async fn add_label_to_card(&self, add_label: &AddLabel) -> APIResult<()> { let board_id = self.ctx.cfg.nextcloud.board_id; let stack_id = add_label.stack_id; let card_id = add_label.card_id; let label_id = add_label.label_id; self.request_with_body( f!("boards/{board_id}/stacks/{stack_id}/cards/{card_id}/assignLabel"), json!({ "labelId": label_id }) .to_string(), |net, url| net.put(url), ) .await } pub(crate) async fn get_boards(&self) -> APIResult> { self.request("boards", |net, url| net.get(url)).await } pub(crate) async fn get_stacks(&self, board_id: NextcloudBoardId) -> APIResult> { self.request(f!("boards/{board_id}/stacks"), |net, url| net.get(url)) .await } pub(crate) async fn get_stack( &self, board_id: NextcloudBoardId, stack_id: NextcloudStackId, ) -> APIResult { self.request(f!("boards/{board_id}/stacks/{stack_id}"), |net, url| { net.get(url) }) .await } pub(crate) async fn create_card(&self, create: &Create) -> APIResult { let mut body = json!({ "title": create.title, }); if let Some(desc) = &create.description { body["description"] = serde_json::Value::String(desc.to_string()); } self.request_with_body( format!( "boards/{}/stacks/{}/cards", self.ctx.cfg.nextcloud.board_id, create.stack_id ), body.to_string(), |net, url| net.post(url), ) .await } pub(crate) async fn get_card( &self, board_id: NextcloudBoardId, stack_id: NextcloudStackId, card_id: NextcloudCardId, ) -> APIResult { self.request( f!("boards/{board_id}/stacks/{stack_id}/cards/{card_id}"), |net, url| net.get(url), ) .await } }