diff --git a/Cargo.lock b/Cargo.lock index 2b761d4..ea4c1f0 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -186,6 +186,15 @@ dependencies = [ "num-traits", ] +[[package]] +name = "crabidy" +version = "0.1.0" +dependencies = [ + "crabidy-core", + "tokio", + "tonic", +] + [[package]] name = "crabidy-core" version = "0.1.0" diff --git a/Cargo.toml b/Cargo.toml index 99447c2..5264d3e 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,2 +1,2 @@ [workspace] -members = ["crabidy-core", "cbd-tui"] +members = ["crabidy-core", "crabidy", "cbd-tui"] diff --git a/crabidy/Cargo.toml b/crabidy/Cargo.toml new file mode 100644 index 0000000..a739972 --- /dev/null +++ b/crabidy/Cargo.toml @@ -0,0 +1,11 @@ +[package] +name = "crabidy" +version = "0.1.0" +edition = "2021" + +# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html + +[dependencies] +crabidy-core = { path = "../crabidy-core" } +tonic = "0.9" +tokio = { version = "1", features = ["full"] } diff --git a/crabidy/src/main.rs b/crabidy/src/main.rs new file mode 100644 index 0000000..07d81a0 --- /dev/null +++ b/crabidy/src/main.rs @@ -0,0 +1,64 @@ +use std::vec; + +use crabidy_core::proto::crabidy::{ + library_service_server::{LibraryService, LibraryServiceServer}, + GetLibraryNodeRequest, GetLibraryNodeResponse, GetTrackRequest, GetTrackResponse, LibraryNode, + LibraryNodeState, +}; +use tonic::{transport::Server, Request, Response, Status}; + +#[derive(Debug, Default)] +pub struct Library {} + +#[tonic::async_trait] +impl LibraryService for Library { + async fn get_library_node( + &self, + request: Request, + ) -> Result, Status> { + println!("Got a library node request: {:?}", request); + + let req = request.into_inner(); + + let reply = GetLibraryNodeResponse { + node: Some(LibraryNode { + uuid: "1".to_owned(), + name: "Tidal".to_owned(), + children: vec![ + "Berlin, Texas".to_owned(), + "Spacefarer".to_owned(), + "Italo Disco".to_owned(), + ], + parent: None, + tracks: vec![], + state: LibraryNodeState::Unspecified.into(), + is_queable: true, + }), + }; + Ok(Response::new(reply)) + } + async fn get_track( + &self, + request: Request, + ) -> Result, Status> { + println!("Got a track request: {:?}", request); + + let req = request.into_inner(); + + let reply = GetTrackResponse { track: None }; + Ok(Response::new(reply)) + } +} + +#[tokio::main] +async fn main() -> Result<(), Box> { + let addr = "[::1]:50051".parse()?; + let crabidy_service = Library::default(); + + Server::builder() + .add_service(LibraryServiceServer::new(crabidy_service)) + .serve(addr) + .await?; + + Ok(()) +}