Initial TUI implementation (untested)
This commit is contained in:
parent
4f28d97cf3
commit
4303425263
165
Cargo.lock
generated
165
Cargo.lock
generated
@ -22,12 +22,24 @@ dependencies = [
|
|||||||
"winapi",
|
"winapi",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "autocfg"
|
||||||
|
version = "1.1.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "d468802bab17cbc0cc575e9b053f41e72aa36bfa6b7f55e3529ffa43161b97fa"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "bitflags"
|
name = "bitflags"
|
||||||
version = "1.3.2"
|
version = "1.3.2"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
|
checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "cassowary"
|
||||||
|
version = "0.3.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "df8670b8c7b9dae1793364eafadf7239c40d669904660c5960d74cfd80b46a53"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "cc"
|
name = "cc"
|
||||||
version = "1.0.79"
|
version = "1.0.79"
|
||||||
@ -55,6 +67,31 @@ dependencies = [
|
|||||||
"vec_map",
|
"vec_map",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "crossterm"
|
||||||
|
version = "0.26.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "a84cda67535339806297f1b331d6dd6320470d2a0fe65381e79ee9e156dd3d13"
|
||||||
|
dependencies = [
|
||||||
|
"bitflags",
|
||||||
|
"crossterm_winapi",
|
||||||
|
"libc",
|
||||||
|
"mio",
|
||||||
|
"parking_lot",
|
||||||
|
"signal-hook",
|
||||||
|
"signal-hook-mio",
|
||||||
|
"winapi",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "crossterm_winapi"
|
||||||
|
version = "0.9.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "2ae1b35a484aa10e07fe0638d02301c5ad24de82d310ccbd2f3693da5f09bf1c"
|
||||||
|
dependencies = [
|
||||||
|
"winapi",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "errno"
|
name = "errno"
|
||||||
version = "0.3.0"
|
version = "0.3.0"
|
||||||
@ -153,11 +190,44 @@ version = "0.3.0"
|
|||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "cd550e73688e6d578f0ac2119e32b797a327631a42f9433e59d02e139c8df60d"
|
checksum = "cd550e73688e6d578f0ac2119e32b797a327631a42f9433e59d02e139c8df60d"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "lock_api"
|
||||||
|
version = "0.4.9"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "435011366fe56583b16cf956f9df0095b405b82d76425bc8981c0e22e60ec4df"
|
||||||
|
dependencies = [
|
||||||
|
"autocfg",
|
||||||
|
"scopeguard",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "log"
|
||||||
|
version = "0.4.17"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "abb12e687cfb44aa40f41fc3978ef76448f9b6038cad6aef4259d3c095a2382e"
|
||||||
|
dependencies = [
|
||||||
|
"cfg-if",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "mio"
|
||||||
|
version = "0.8.6"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "5b9d9a46eff5b4ff64b45a9e316a6d1e0bc719ef429cbec4dc630684212bfdf9"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
"log",
|
||||||
|
"wasi",
|
||||||
|
"windows-sys",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "musichoard"
|
name = "musichoard"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
|
"crossterm",
|
||||||
"once_cell",
|
"once_cell",
|
||||||
|
"ratatui",
|
||||||
"serde",
|
"serde",
|
||||||
"serde_json",
|
"serde_json",
|
||||||
"structopt",
|
"structopt",
|
||||||
@ -171,6 +241,29 @@ version = "1.17.1"
|
|||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "b7e5500299e16ebb147ae15a00a942af264cf3688f47923b8fc2cd5858f23ad3"
|
checksum = "b7e5500299e16ebb147ae15a00a942af264cf3688f47923b8fc2cd5858f23ad3"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "parking_lot"
|
||||||
|
version = "0.12.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "3742b2c103b9f06bc9fff0a37ff4912935851bee6d36f3c02bcc755bcfec228f"
|
||||||
|
dependencies = [
|
||||||
|
"lock_api",
|
||||||
|
"parking_lot_core",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "parking_lot_core"
|
||||||
|
version = "0.9.7"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "9069cbb9f99e3a5083476ccb29ceb1de18b9118cafa53e90c9551235de2b9521"
|
||||||
|
dependencies = [
|
||||||
|
"cfg-if",
|
||||||
|
"libc",
|
||||||
|
"redox_syscall 0.2.16",
|
||||||
|
"smallvec",
|
||||||
|
"windows-sys",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "proc-macro-error"
|
name = "proc-macro-error"
|
||||||
version = "1.0.4"
|
version = "1.0.4"
|
||||||
@ -213,6 +306,28 @@ dependencies = [
|
|||||||
"proc-macro2",
|
"proc-macro2",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "ratatui"
|
||||||
|
version = "0.20.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "dcc0d032bccba900ee32151ec0265667535c230169f5a011154cdcd984e16829"
|
||||||
|
dependencies = [
|
||||||
|
"bitflags",
|
||||||
|
"cassowary",
|
||||||
|
"crossterm",
|
||||||
|
"unicode-segmentation",
|
||||||
|
"unicode-width",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "redox_syscall"
|
||||||
|
version = "0.2.16"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "fb5a58c1855b4b6819d59012155603f0b22ad30cad752600aadfcb695265519a"
|
||||||
|
dependencies = [
|
||||||
|
"bitflags",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "redox_syscall"
|
name = "redox_syscall"
|
||||||
version = "0.3.5"
|
version = "0.3.5"
|
||||||
@ -242,6 +357,12 @@ version = "1.0.13"
|
|||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "f91339c0467de62360649f8d3e185ca8de4224ff281f66000de5eb2a77a79041"
|
checksum = "f91339c0467de62360649f8d3e185ca8de4224ff281f66000de5eb2a77a79041"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "scopeguard"
|
||||||
|
version = "1.1.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "d29ab0c6d3fc0ee92fe66e2d99f700eab17a8d57d1c1d3b748380fb20baa78cd"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "serde"
|
name = "serde"
|
||||||
version = "1.0.159"
|
version = "1.0.159"
|
||||||
@ -273,6 +394,42 @@ dependencies = [
|
|||||||
"serde",
|
"serde",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "signal-hook"
|
||||||
|
version = "0.3.15"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "732768f1176d21d09e076c23a93123d40bba92d50c4058da34d45c8de8e682b9"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
"signal-hook-registry",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "signal-hook-mio"
|
||||||
|
version = "0.2.3"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "29ad2e15f37ec9a6cc544097b78a1ec90001e9f71b81338ca39f430adaca99af"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
"mio",
|
||||||
|
"signal-hook",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "signal-hook-registry"
|
||||||
|
version = "1.4.1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "d8229b473baa5980ac72ef434c4415e70c4b5e71b423043adb4ba059f89c99a1"
|
||||||
|
dependencies = [
|
||||||
|
"libc",
|
||||||
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "smallvec"
|
||||||
|
version = "1.10.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "a507befe795404456341dfab10cef66ead4c041f62b8b11bbb92bffe5d0953e0"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "strsim"
|
name = "strsim"
|
||||||
version = "0.8.0"
|
version = "0.8.0"
|
||||||
@ -333,7 +490,7 @@ checksum = "b9fbec84f381d5795b08656e4912bec604d162bff9291d6189a78f4c8ab87998"
|
|||||||
dependencies = [
|
dependencies = [
|
||||||
"cfg-if",
|
"cfg-if",
|
||||||
"fastrand",
|
"fastrand",
|
||||||
"redox_syscall",
|
"redox_syscall 0.3.5",
|
||||||
"rustix",
|
"rustix",
|
||||||
"windows-sys",
|
"windows-sys",
|
||||||
]
|
]
|
||||||
@ -386,6 +543,12 @@ version = "0.9.4"
|
|||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "49874b5167b65d7193b8aba1567f5c7d93d001cafc34600cee003eda787e483f"
|
checksum = "49874b5167b65d7193b8aba1567f5c7d93d001cafc34600cee003eda787e483f"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "wasi"
|
||||||
|
version = "0.11.0+wasi-snapshot-preview1"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "9c8d87e72b64a3b4db28d11ce29237c246188f4f51057d65a7eab63b7987e423"
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "winapi"
|
name = "winapi"
|
||||||
version = "0.3.9"
|
version = "0.3.9"
|
||||||
|
|||||||
14
Cargo.toml
14
Cargo.toml
@ -6,11 +6,13 @@ edition = "2021"
|
|||||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
serde = { version = "1.0", features = ["derive"] }
|
crossterm = "0.26.1"
|
||||||
serde_json = "1.0"
|
serde = { version = "1.0.159", features = ["derive"] }
|
||||||
structopt = "0.3"
|
serde_json = "1.0.95"
|
||||||
uuid = { version = "1.3", features = ["serde"] }
|
structopt = "0.3.26"
|
||||||
|
ratatui = "0.20.1"
|
||||||
|
uuid = { version = "1.3.0", features = ["serde"] }
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
once_cell = "1.17"
|
once_cell = "1.17.1"
|
||||||
tempfile = "3.5"
|
tempfile = "3.5.0"
|
||||||
|
|||||||
32
README.md
Normal file
32
README.md
Normal file
@ -0,0 +1,32 @@
|
|||||||
|
# Music Hoard
|
||||||
|
|
||||||
|
## Code Coverage
|
||||||
|
|
||||||
|
### Pre-requisites
|
||||||
|
|
||||||
|
``` sh
|
||||||
|
rustup component add llvm-tools-preview
|
||||||
|
cargo install grcov
|
||||||
|
```
|
||||||
|
|
||||||
|
### Generating
|
||||||
|
|
||||||
|
```sh
|
||||||
|
cargo clean
|
||||||
|
env RUSTFLAGS="-C instrument-coverage" \
|
||||||
|
LLVM_PROFILE_FILE="target/debug/profraw/musichoard-%p-%m.profraw" \
|
||||||
|
cargo test
|
||||||
|
grcov target/debug/profraw \
|
||||||
|
--binary-path ./target/debug/ \
|
||||||
|
--output-types html \
|
||||||
|
--source-dir . \
|
||||||
|
--ignore-not-existing \
|
||||||
|
--ignore "tests/*" \
|
||||||
|
--ignore "src/main.rs" \
|
||||||
|
--excl-start "#\[cfg\(test\)\]" \
|
||||||
|
--output-path ./target/debug/coverage/
|
||||||
|
xdg-open target/debug/coverage/index.html
|
||||||
|
```
|
||||||
|
|
||||||
|
Note that some changes may not be visible until `target/debug/coverage` is removed and the `grcov`
|
||||||
|
command is rerun.
|
||||||
83
src/collection/mod.rs
Normal file
83
src/collection/mod.rs
Normal file
@ -0,0 +1,83 @@
|
|||||||
|
//! Module for managing the music collection, i.e. "The Music Hoard".
|
||||||
|
|
||||||
|
use std::fmt;
|
||||||
|
|
||||||
|
use crate::{
|
||||||
|
database::{self, Database},
|
||||||
|
library::{self, Library, Query},
|
||||||
|
Artist,
|
||||||
|
};
|
||||||
|
|
||||||
|
/// The collection type.
|
||||||
|
pub type Collection = Vec<Artist>;
|
||||||
|
|
||||||
|
/// Error type for collection manager.
|
||||||
|
#[derive(Debug)]
|
||||||
|
pub enum Error {
|
||||||
|
/// The [`CollectionManager`] failed to read/write from/to the library.
|
||||||
|
LibraryError(String),
|
||||||
|
/// The [`CollectionManager`] failed to read/write from/to the database.
|
||||||
|
DatabaseError(String),
|
||||||
|
}
|
||||||
|
|
||||||
|
impl fmt::Display for Error {
|
||||||
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
||||||
|
match *self {
|
||||||
|
Self::LibraryError(ref s) => write!(f, "failed to read/write from/to the library: {s}"),
|
||||||
|
Self::DatabaseError(ref s) => {
|
||||||
|
write!(f, "failed to read/write from/to the database: {s}")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<library::Error> for Error {
|
||||||
|
fn from(err: library::Error) -> Error {
|
||||||
|
Error::LibraryError(err.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<database::Error> for Error {
|
||||||
|
fn from(err: database::Error) -> Error {
|
||||||
|
Error::DatabaseError(err.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// The collection manager. It is responsible for pulling information from both the library and the
|
||||||
|
/// database, ensuring its consistent and writing back any changes.
|
||||||
|
pub struct CollectionManager {
|
||||||
|
library: Box<dyn Library + Send + Sync>,
|
||||||
|
database: Box<dyn Database + Send + Sync>,
|
||||||
|
collection: Collection,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl CollectionManager {
|
||||||
|
/// Create a new [`CollectionManager`] with the provided [`Library`] and [`Database`].
|
||||||
|
pub fn new(
|
||||||
|
library: Box<dyn Library + Send + Sync>,
|
||||||
|
database: Box<dyn Database + Send + Sync>,
|
||||||
|
) -> Self {
|
||||||
|
CollectionManager {
|
||||||
|
library,
|
||||||
|
database,
|
||||||
|
collection: vec![],
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Rescan the library and integrate any updates into the collection.
|
||||||
|
pub fn rescan_library(&mut self) -> Result<(), Error> {
|
||||||
|
self.collection = self.library.list(&Query::default())?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Save the collection state to the database.
|
||||||
|
pub fn save_to_database(&mut self) -> Result<(), Error> {
|
||||||
|
self.database.write(&self.collection)?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Get the current collection.
|
||||||
|
pub fn get_collection(&self) -> &Collection {
|
||||||
|
&self.collection
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -3,10 +3,15 @@
|
|||||||
use std::fs;
|
use std::fs;
|
||||||
use std::path::{Path, PathBuf};
|
use std::path::{Path, PathBuf};
|
||||||
|
|
||||||
use serde::de::DeserializeOwned;
|
use crate::collection::Collection;
|
||||||
use serde::Serialize;
|
|
||||||
|
|
||||||
use super::{Database, DatabaseRead, DatabaseWrite};
|
use super::{Database, DatabaseRead, DatabaseWrite, Error};
|
||||||
|
|
||||||
|
impl From<serde_json::Error> for Error {
|
||||||
|
fn from(err: serde_json::Error) -> Error {
|
||||||
|
Error::SerDeError(err.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// Trait for the JSON database backend.
|
/// Trait for the JSON database backend.
|
||||||
pub trait JsonDatabaseBackend {
|
pub trait JsonDatabaseBackend {
|
||||||
@ -19,21 +24,18 @@ pub trait JsonDatabaseBackend {
|
|||||||
|
|
||||||
/// JSON database.
|
/// JSON database.
|
||||||
pub struct JsonDatabase {
|
pub struct JsonDatabase {
|
||||||
backend: Box<dyn JsonDatabaseBackend + Send>,
|
backend: Box<dyn JsonDatabaseBackend + Send + Sync>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl JsonDatabase {
|
impl JsonDatabase {
|
||||||
/// Create a new JSON database with the provided backend, e.g. [JsonDatabaseFileBackend].
|
/// Create a new JSON database with the provided backend, e.g. [`JsonDatabaseFileBackend`].
|
||||||
pub fn new(backend: Box<dyn JsonDatabaseBackend + Send>) -> Self {
|
pub fn new(backend: Box<dyn JsonDatabaseBackend + Send + Sync>) -> Self {
|
||||||
JsonDatabase { backend }
|
JsonDatabase { backend }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
impl DatabaseRead for JsonDatabase {
|
impl DatabaseRead for JsonDatabase {
|
||||||
fn read<D>(&self, collection: &mut D) -> Result<(), std::io::Error>
|
fn read(&self, collection: &mut Collection) -> Result<(), Error> {
|
||||||
where
|
|
||||||
D: DeserializeOwned,
|
|
||||||
{
|
|
||||||
let serialized = self.backend.read()?;
|
let serialized = self.backend.read()?;
|
||||||
*collection = serde_json::from_str(&serialized)?;
|
*collection = serde_json::from_str(&serialized)?;
|
||||||
Ok(())
|
Ok(())
|
||||||
@ -41,10 +43,7 @@ impl DatabaseRead for JsonDatabase {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl DatabaseWrite for JsonDatabase {
|
impl DatabaseWrite for JsonDatabase {
|
||||||
fn write<S>(&mut self, collection: &S) -> Result<(), std::io::Error>
|
fn write(&mut self, collection: &Collection) -> Result<(), Error> {
|
||||||
where
|
|
||||||
S: Serialize,
|
|
||||||
{
|
|
||||||
let serialized = serde_json::to_string(&collection)?;
|
let serialized = serde_json::to_string(&collection)?;
|
||||||
self.backend.write(&serialized)?;
|
self.backend.write(&serialized)?;
|
||||||
Ok(())
|
Ok(())
|
||||||
@ -59,7 +58,7 @@ pub struct JsonDatabaseFileBackend {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl JsonDatabaseFileBackend {
|
impl JsonDatabaseFileBackend {
|
||||||
/// Create a [JsonDatabaseFileBackend] that will read/write to the provided path.
|
/// Create a [`JsonDatabaseFileBackend`] that will read/write to the provided path.
|
||||||
pub fn new(path: &Path) -> Self {
|
pub fn new(path: &Path) -> Self {
|
||||||
JsonDatabaseFileBackend {
|
JsonDatabaseFileBackend {
|
||||||
path: path.to_path_buf(),
|
path: path.to_path_buf(),
|
||||||
|
|||||||
@ -1,24 +1,47 @@
|
|||||||
//! Module for storing MusicHoard data in a database.
|
//! Module for storing MusicHoard data in a database.
|
||||||
|
|
||||||
use serde::de::DeserializeOwned;
|
use std::fmt;
|
||||||
use serde::Serialize;
|
|
||||||
|
use crate::collection::Collection;
|
||||||
|
|
||||||
pub mod json;
|
pub mod json;
|
||||||
|
|
||||||
|
/// Error type for database calls.
|
||||||
|
#[derive(Debug)]
|
||||||
|
pub enum Error {
|
||||||
|
/// The database experienced an I/O error.
|
||||||
|
IoError(String),
|
||||||
|
/// The database experienced a (de)serialisation error.
|
||||||
|
SerDeError(String),
|
||||||
|
}
|
||||||
|
|
||||||
|
impl fmt::Display for Error {
|
||||||
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
||||||
|
match *self {
|
||||||
|
Self::IoError(ref s) => write!(f, "the database experienced an I/O error: {s}"),
|
||||||
|
Self::SerDeError(ref s) => {
|
||||||
|
write!(f, "the database experienced a (de)serialisation error: {s}")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<std::io::Error> for Error {
|
||||||
|
fn from(err: std::io::Error) -> Error {
|
||||||
|
Error::IoError(err.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// Trait for database reads.
|
/// Trait for database reads.
|
||||||
pub trait DatabaseRead {
|
pub trait DatabaseRead {
|
||||||
/// Read collection from the database.
|
/// Read collection from the database.
|
||||||
fn read<D>(&self, collection: &mut D) -> Result<(), std::io::Error>
|
fn read(&self, collection: &mut Collection) -> Result<(), Error>;
|
||||||
where
|
|
||||||
D: DeserializeOwned;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Trait for database writes.
|
/// Trait for database writes.
|
||||||
pub trait DatabaseWrite {
|
pub trait DatabaseWrite {
|
||||||
/// Write collection to the database.
|
/// Write collection to the database.
|
||||||
fn write<S>(&mut self, collection: &S) -> Result<(), std::io::Error>
|
fn write(&mut self, collection: &Collection) -> Result<(), Error>;
|
||||||
where
|
|
||||||
S: Serialize;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Trait for database reads and writes.
|
/// Trait for database reads and writes.
|
||||||
|
|||||||
@ -3,6 +3,7 @@
|
|||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
|
pub mod collection;
|
||||||
pub mod database;
|
pub mod database;
|
||||||
pub mod library;
|
pub mod library;
|
||||||
|
|
||||||
|
|||||||
@ -91,7 +91,7 @@ pub trait BeetsLibraryExecutor {
|
|||||||
|
|
||||||
/// Beets library.
|
/// Beets library.
|
||||||
pub struct BeetsLibrary {
|
pub struct BeetsLibrary {
|
||||||
executor: Box<dyn BeetsLibraryExecutor + Send>,
|
executor: Box<dyn BeetsLibraryExecutor + Send + Sync>,
|
||||||
}
|
}
|
||||||
|
|
||||||
trait LibraryPrivate {
|
trait LibraryPrivate {
|
||||||
@ -106,8 +106,8 @@ trait LibraryPrivate {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl BeetsLibrary {
|
impl BeetsLibrary {
|
||||||
/// Create a new beets library with the provided executor, e.g. [BeetsLibraryCommandExecutor].
|
/// Create a new beets library with the provided executor, e.g. [`BeetsLibraryCommandExecutor`].
|
||||||
pub fn new(executor: Box<dyn BeetsLibraryExecutor + Send>) -> BeetsLibrary {
|
pub fn new(executor: Box<dyn BeetsLibraryExecutor + Send + Sync>) -> BeetsLibrary {
|
||||||
BeetsLibrary { executor }
|
BeetsLibrary { executor }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -243,7 +243,7 @@ pub struct BeetsLibraryCommandExecutor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl BeetsLibraryCommandExecutor {
|
impl BeetsLibraryCommandExecutor {
|
||||||
/// Create a new [BeetsLibraryCommandExecutor] that uses the provided beets executable.
|
/// Create a new [`BeetsLibraryCommandExecutor`] that uses the provided beets executable.
|
||||||
pub fn new(bin: &str) -> Self {
|
pub fn new(bin: &str) -> Self {
|
||||||
BeetsLibraryCommandExecutor {
|
BeetsLibraryCommandExecutor {
|
||||||
bin: bin.to_string(),
|
bin: bin.to_string(),
|
||||||
@ -259,7 +259,7 @@ impl BeetsLibraryCommandExecutor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl Default for BeetsLibraryCommandExecutor {
|
impl Default for BeetsLibraryCommandExecutor {
|
||||||
/// Create a new [BeetsLibraryCommandExecutor] that uses the system's default beets executable.
|
/// Create a new [`BeetsLibraryCommandExecutor`] that uses the system's default beets executable.
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
BeetsLibraryCommandExecutor::new("beet")
|
BeetsLibraryCommandExecutor::new("beet")
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
//! Module for interacting with the music library.
|
//! Module for interacting with the music library.
|
||||||
|
|
||||||
use std::{num::ParseIntError, str::Utf8Error};
|
use std::{num::ParseIntError, str::Utf8Error, fmt};
|
||||||
|
|
||||||
use crate::Artist;
|
use crate::Artist;
|
||||||
|
|
||||||
@ -17,19 +17,19 @@ pub enum QueryOption<T> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl<T> QueryOption<T> {
|
impl<T> QueryOption<T> {
|
||||||
/// Return `true` if [QueryOption] is not [QueryOption::None].
|
/// Return `true` if [`QueryOption`] is not [`QueryOption::None`].
|
||||||
pub fn is_some(&self) -> bool {
|
pub fn is_some(&self) -> bool {
|
||||||
!matches!(self, QueryOption::None)
|
!matches!(self, QueryOption::None)
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Return `true` if [QueryOption] is [QueryOption::None].
|
/// Return `true` if [`QueryOption`] is [`QueryOption::None`].
|
||||||
pub fn is_none(&self) -> bool {
|
pub fn is_none(&self) -> bool {
|
||||||
matches!(self, QueryOption::None)
|
matches!(self, QueryOption::None)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<T> Default for QueryOption<T> {
|
impl<T> Default for QueryOption<T> {
|
||||||
/// Create a [QueryOption::None] for type `T`.
|
/// Create a [`QueryOption::None`] for type `T`.
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
Self::None
|
Self::None
|
||||||
}
|
}
|
||||||
@ -111,6 +111,18 @@ pub enum Error {
|
|||||||
Utf8Error(String),
|
Utf8Error(String),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl fmt::Display for Error {
|
||||||
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
||||||
|
match *self {
|
||||||
|
Self::CmdExecError(ref s) => write!(f, "the library failed to execute a command: {s}"),
|
||||||
|
Self::InvalidData(ref s) => write!(f, "the library received invalid data: {s}"),
|
||||||
|
Self::IoError(ref s) => write!(f, "the library experienced an I/O error: {s}"),
|
||||||
|
Self::ParseIntError(ref s) => write!(f, "the library received an invalid integer: {s}"),
|
||||||
|
Self::Utf8Error(ref s) => write!(f, "the library received invalid UTF-8: {s}"),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
impl From<std::io::Error> for Error {
|
impl From<std::io::Error> for Error {
|
||||||
fn from(err: std::io::Error) -> Error {
|
fn from(err: std::io::Error) -> Error {
|
||||||
Error::IoError(err.to_string())
|
Error::IoError(err.to_string())
|
||||||
|
|||||||
55
src/main.rs
55
src/main.rs
@ -1,23 +1,30 @@
|
|||||||
|
use ratatui::backend::CrosstermBackend;
|
||||||
|
use ratatui::Terminal;
|
||||||
|
use std::io;
|
||||||
use std::path::PathBuf;
|
use std::path::PathBuf;
|
||||||
|
|
||||||
use structopt::StructOpt;
|
use structopt::StructOpt;
|
||||||
|
|
||||||
use musichoard::{
|
use musichoard::{
|
||||||
database::{
|
collection::CollectionManager,
|
||||||
json::{JsonDatabase, JsonDatabaseFileBackend},
|
database::json::{JsonDatabase, JsonDatabaseFileBackend},
|
||||||
DatabaseWrite,
|
library::beets::{BeetsLibrary, BeetsLibraryCommandExecutor},
|
||||||
},
|
};
|
||||||
library::{
|
|
||||||
beets::{BeetsLibrary, BeetsLibraryCommandExecutor},
|
mod tui;
|
||||||
Library, Query,
|
use tui::{
|
||||||
},
|
app::App,
|
||||||
|
event::{EventChannel, EventListener},
|
||||||
|
handler::EventHandler,
|
||||||
|
ui::Ui,
|
||||||
|
Tui,
|
||||||
};
|
};
|
||||||
|
|
||||||
#[derive(StructOpt)]
|
#[derive(StructOpt)]
|
||||||
struct Opt {
|
struct Opt {
|
||||||
#[structopt(
|
#[structopt(
|
||||||
short = "b",
|
short = "b",
|
||||||
long = "beets-config",
|
long = "beets",
|
||||||
name = "beets config file path",
|
name = "beets config file path",
|
||||||
parse(from_os_str)
|
parse(from_os_str)
|
||||||
)]
|
)]
|
||||||
@ -34,21 +41,33 @@ struct Opt {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn main() {
|
fn main() {
|
||||||
|
// Create the application.
|
||||||
let opt = Opt::from_args();
|
let opt = Opt::from_args();
|
||||||
|
|
||||||
let mut beets = BeetsLibrary::new(Box::new(
|
let beets = BeetsLibrary::new(Box::new(
|
||||||
BeetsLibraryCommandExecutor::default().config(opt.beets_config_file_path.as_deref()),
|
BeetsLibraryCommandExecutor::default().config(opt.beets_config_file_path.as_deref()),
|
||||||
));
|
));
|
||||||
|
|
||||||
let collection = beets
|
let database = JsonDatabase::new(Box::new(JsonDatabaseFileBackend::new(
|
||||||
.list(&Query::new())
|
|
||||||
.expect("failed to query the library");
|
|
||||||
|
|
||||||
let mut database = JsonDatabase::new(Box::new(JsonDatabaseFileBackend::new(
|
|
||||||
&opt.database_file_path,
|
&opt.database_file_path,
|
||||||
)));
|
)));
|
||||||
|
|
||||||
database
|
let collection_manager = CollectionManager::new(Box::new(beets), Box::new(database));
|
||||||
.write(&collection)
|
|
||||||
.expect("failed to write to the database");
|
// Initialize the terminal user interface.
|
||||||
|
let backend = CrosstermBackend::new(io::stdout());
|
||||||
|
let terminal = Terminal::new(backend).expect("failed to initialise terminal");
|
||||||
|
|
||||||
|
let channel = EventChannel::new();
|
||||||
|
let listener = EventListener::new(channel.sender());
|
||||||
|
let handler = EventHandler::new(channel.receiver());
|
||||||
|
|
||||||
|
let ui = Ui::new();
|
||||||
|
|
||||||
|
let app = App::new(collection_manager).expect("failed to initialise app");
|
||||||
|
|
||||||
|
let tui = Tui::new(terminal, listener, handler, ui, app);
|
||||||
|
|
||||||
|
// Run the TUI application.
|
||||||
|
tui.run().expect("failed to run tui");
|
||||||
}
|
}
|
||||||
|
|||||||
324
src/tui/app.rs
Normal file
324
src/tui/app.rs
Normal file
@ -0,0 +1,324 @@
|
|||||||
|
use musichoard::{collection::CollectionManager, Album, AlbumId, Artist, ArtistId, Track};
|
||||||
|
|
||||||
|
use super::Error;
|
||||||
|
|
||||||
|
#[derive(Copy, Clone, PartialEq, Eq)]
|
||||||
|
pub enum Category {
|
||||||
|
Artist,
|
||||||
|
Album,
|
||||||
|
Track,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct TrackSelection {
|
||||||
|
index: u16,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl TrackSelection {
|
||||||
|
fn initialise(tracks: &Vec<Track>) -> Option<TrackSelection> {
|
||||||
|
if !tracks.is_empty() {
|
||||||
|
Some(TrackSelection { index: 0 })
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn increment(&mut self, tracks: &Vec<Track>) {
|
||||||
|
if let Some(result) = self.index.checked_add(1) {
|
||||||
|
if (result as usize) < tracks.len() {
|
||||||
|
self.index = result;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn decrement(&mut self, _tracks: &Vec<Track>) {
|
||||||
|
if let Some(result) = self.index.checked_sub(1) {
|
||||||
|
self.index = result;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
struct AlbumSelection {
|
||||||
|
index: u16,
|
||||||
|
track: Option<TrackSelection>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl AlbumSelection {
|
||||||
|
fn initialise(albums: &Vec<Album>) -> Option<AlbumSelection> {
|
||||||
|
if !albums.is_empty() {
|
||||||
|
Some(AlbumSelection {
|
||||||
|
index: 0,
|
||||||
|
track: TrackSelection::initialise(&albums[0].tracks),
|
||||||
|
})
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn increment(&mut self, albums: &Vec<Album>) {
|
||||||
|
if let Some(result) = self.index.checked_add(1) {
|
||||||
|
if (result as usize) < albums.len() {
|
||||||
|
self.index = result;
|
||||||
|
self.track = TrackSelection::initialise(&albums[self.index as usize].tracks);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn decrement(&mut self, albums: &Vec<Album>) {
|
||||||
|
if let Some(result) = self.index.checked_sub(1) {
|
||||||
|
self.index = result;
|
||||||
|
self.track = TrackSelection::initialise(&albums[self.index as usize].tracks);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
struct ArtistSelection {
|
||||||
|
index: u16,
|
||||||
|
album: Option<AlbumSelection>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl ArtistSelection {
|
||||||
|
fn initialise(artists: &Vec<Artist>) -> Option<ArtistSelection> {
|
||||||
|
if !artists.is_empty() {
|
||||||
|
Some(ArtistSelection {
|
||||||
|
index: 0,
|
||||||
|
album: AlbumSelection::initialise(&artists[0].albums),
|
||||||
|
})
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn increment(&mut self, artists: &Vec<Artist>) {
|
||||||
|
if let Some(result) = self.index.checked_add(1) {
|
||||||
|
if (result as usize) < artists.len() {
|
||||||
|
self.index = result;
|
||||||
|
self.album = AlbumSelection::initialise(&artists[self.index as usize].albums);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn decrement(&mut self, artists: &Vec<Artist>) {
|
||||||
|
if let Some(result) = self.index.checked_sub(1) {
|
||||||
|
self.index = result;
|
||||||
|
self.album = AlbumSelection::initialise(&artists[self.index as usize].albums);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
struct Selection {
|
||||||
|
active: Category,
|
||||||
|
artist: Option<ArtistSelection>,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct App {
|
||||||
|
collection_manager: CollectionManager,
|
||||||
|
selection: Selection,
|
||||||
|
running: bool,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl App {
|
||||||
|
pub fn new(mut collection_manager: CollectionManager) -> Result<Self, Error> {
|
||||||
|
collection_manager.rescan_library()?;
|
||||||
|
let selection = Selection {
|
||||||
|
active: Category::Artist,
|
||||||
|
artist: ArtistSelection::initialise(collection_manager.get_collection()),
|
||||||
|
};
|
||||||
|
Ok(App {
|
||||||
|
collection_manager,
|
||||||
|
selection,
|
||||||
|
running: true,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn is_running(&self) -> bool {
|
||||||
|
self.running
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn increment_category(&mut self) {
|
||||||
|
self.selection.active = match self.selection.active {
|
||||||
|
Category::Artist => Category::Album,
|
||||||
|
Category::Album => Category::Track,
|
||||||
|
Category::Track => Category::Track,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn decrement_category(&mut self) {
|
||||||
|
self.selection.active = match self.selection.active {
|
||||||
|
Category::Artist => Category::Artist,
|
||||||
|
Category::Album => Category::Artist,
|
||||||
|
Category::Track => Category::Album,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn increment_selection(&mut self) {
|
||||||
|
match self.selection.active {
|
||||||
|
Category::Artist => self.increment_artist_selection(),
|
||||||
|
Category::Album => self.increment_album_selection(),
|
||||||
|
Category::Track => self.increment_track_selection(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn decrement_selection(&mut self) {
|
||||||
|
match self.selection.active {
|
||||||
|
Category::Artist => self.decrement_artist_selection(),
|
||||||
|
Category::Album => self.decrement_album_selection(),
|
||||||
|
Category::Track => self.decrement_track_selection(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn increment_artist_selection(&mut self) {
|
||||||
|
if let Some(ref mut artist_selection) = self.selection.artist {
|
||||||
|
let artists = &self.collection_manager.get_collection();
|
||||||
|
artist_selection.increment(artists);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn decrement_artist_selection(&mut self) {
|
||||||
|
if let Some(ref mut artist_selection) = self.selection.artist {
|
||||||
|
let artists = &self.collection_manager.get_collection();
|
||||||
|
artist_selection.decrement(artists);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn increment_album_selection(&mut self) {
|
||||||
|
if let Some(ref mut artist_selection) = self.selection.artist {
|
||||||
|
if let Some(ref mut album_selection) = artist_selection.album {
|
||||||
|
let artists = &self.collection_manager.get_collection();
|
||||||
|
let albums = &artists[artist_selection.index as usize].albums;
|
||||||
|
album_selection.increment(albums);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn decrement_album_selection(&mut self) {
|
||||||
|
if let Some(ref mut artist_selection) = self.selection.artist {
|
||||||
|
if let Some(ref mut album_selection) = artist_selection.album {
|
||||||
|
let artists = &self.collection_manager.get_collection();
|
||||||
|
let albums = &artists[artist_selection.index as usize].albums;
|
||||||
|
album_selection.decrement(albums);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn increment_track_selection(&mut self) {
|
||||||
|
if let Some(ref mut artist_selection) = self.selection.artist {
|
||||||
|
if let Some(ref mut album_selection) = artist_selection.album {
|
||||||
|
if let Some(ref mut track_selection) = album_selection.track {
|
||||||
|
let artists = &self.collection_manager.get_collection();
|
||||||
|
let albums = &artists[artist_selection.index as usize].albums;
|
||||||
|
let tracks = &albums[album_selection.index as usize].tracks;
|
||||||
|
track_selection.increment(tracks);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn decrement_track_selection(&mut self) {
|
||||||
|
if let Some(ref mut artist_selection) = self.selection.artist {
|
||||||
|
if let Some(ref mut album_selection) = artist_selection.album {
|
||||||
|
if let Some(ref mut track_selection) = album_selection.track {
|
||||||
|
let artists = &self.collection_manager.get_collection();
|
||||||
|
let albums = &artists[artist_selection.index as usize].albums;
|
||||||
|
let tracks = &albums[album_selection.index as usize].tracks;
|
||||||
|
track_selection.decrement(tracks);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn get_active_category(&self) -> Category {
|
||||||
|
self.selection.active
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_artists(&self) -> Option<&Vec<Artist>> {
|
||||||
|
Some(&self.collection_manager.get_collection())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_albums(&self) -> Option<&Vec<Album>> {
|
||||||
|
if let Some(artists) = self.get_artists() {
|
||||||
|
if let Some(artist_index) = self.selected_artist() {
|
||||||
|
Some(&artists[artist_index].albums)
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_tracks(&self) -> Option<&Vec<Track>> {
|
||||||
|
if let Some(albums) = self.get_albums() {
|
||||||
|
if let Some(album_index) = self.selected_album() {
|
||||||
|
Some(&albums[album_index].tracks)
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn get_artist_ids(&self) -> Vec<&ArtistId> {
|
||||||
|
if let Some(artists) = self.get_artists() {
|
||||||
|
artists.iter().map(|a| &a.id).collect()
|
||||||
|
} else {
|
||||||
|
vec![]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn get_album_ids(&self) -> Vec<&AlbumId> {
|
||||||
|
if let Some(albums) = self.get_albums() {
|
||||||
|
albums.iter().map(|a| &a.id).collect()
|
||||||
|
} else {
|
||||||
|
vec![]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn get_track_ids(&self) -> Vec<&Track> {
|
||||||
|
if let Some(tracks) = self.get_tracks() {
|
||||||
|
tracks.iter().collect()
|
||||||
|
} else {
|
||||||
|
vec![]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn selected_artist(&self) -> Option<usize> {
|
||||||
|
if let Some(ref artist_selection) = self.selection.artist {
|
||||||
|
Some(artist_selection.index as usize)
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn selected_album(&self) -> Option<usize> {
|
||||||
|
if let Some(ref artist_selection) = self.selection.artist {
|
||||||
|
if let Some(ref album_selection) = artist_selection.album {
|
||||||
|
Some(album_selection.index as usize)
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn selected_track(&self) -> Option<usize> {
|
||||||
|
if let Some(ref artist_selection) = self.selection.artist {
|
||||||
|
if let Some(ref album_selection) = artist_selection.album {
|
||||||
|
if let Some(ref track_selection) = album_selection.track {
|
||||||
|
Some(track_selection.index as usize)
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn quit(&mut self) {
|
||||||
|
self.running = false;
|
||||||
|
}
|
||||||
|
}
|
||||||
119
src/tui/event.rs
Normal file
119
src/tui/event.rs
Normal file
@ -0,0 +1,119 @@
|
|||||||
|
use crossterm::event::{self, Event as CrosstermEvent, KeyEvent, MouseEvent};
|
||||||
|
use std::sync::mpsc;
|
||||||
|
use std::{fmt, thread};
|
||||||
|
|
||||||
|
#[derive(Debug)]
|
||||||
|
pub enum EventError {
|
||||||
|
SendError(Event),
|
||||||
|
RecvError,
|
||||||
|
IoError(std::io::Error),
|
||||||
|
}
|
||||||
|
|
||||||
|
impl fmt::Display for EventError {
|
||||||
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
||||||
|
match *self {
|
||||||
|
Self::SendError(ref e) => write!(f, "failed to send event: {e:?}"),
|
||||||
|
Self::RecvError => write!(f, "receive event call failed"),
|
||||||
|
Self::IoError(ref e) => {
|
||||||
|
write!(f, "an I/O error was triggered during event handling: {e}")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<mpsc::SendError<Event>> for EventError {
|
||||||
|
fn from(err: mpsc::SendError<Event>) -> EventError {
|
||||||
|
EventError::SendError(err.0)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<mpsc::RecvError> for EventError {
|
||||||
|
fn from(_: mpsc::RecvError) -> EventError {
|
||||||
|
EventError::RecvError
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Clone, Copy, Debug)]
|
||||||
|
pub enum Event {
|
||||||
|
Key(KeyEvent),
|
||||||
|
Mouse(MouseEvent),
|
||||||
|
Resize(u16, u16),
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct EventChannel {
|
||||||
|
sender: mpsc::Sender<Event>,
|
||||||
|
receiver: mpsc::Receiver<Event>,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Clone)]
|
||||||
|
pub struct EventSender {
|
||||||
|
sender: mpsc::Sender<Event>,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct EventReceiver {
|
||||||
|
receiver: mpsc::Receiver<Event>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl EventChannel {
|
||||||
|
pub fn new() -> Self {
|
||||||
|
let (sender, receiver) = mpsc::channel();
|
||||||
|
EventChannel { sender, receiver }
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn sender(&self) -> EventSender {
|
||||||
|
EventSender {
|
||||||
|
sender: self.sender.clone(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn receiver(self) -> EventReceiver {
|
||||||
|
EventReceiver {
|
||||||
|
receiver: self.receiver,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl EventSender {
|
||||||
|
pub fn send(&self, event: Event) -> Result<(), EventError> {
|
||||||
|
Ok(self.sender.send(event)?)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl EventReceiver {
|
||||||
|
pub fn recv(&self) -> Result<Event, EventError> {
|
||||||
|
Ok(self.receiver.recv()?)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct EventListener {
|
||||||
|
events: EventSender,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl EventListener {
|
||||||
|
pub fn new(events: EventSender) -> EventListener {
|
||||||
|
EventListener { events }
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn spawn(self) -> thread::JoinHandle<EventError> {
|
||||||
|
thread::spawn(move || {
|
||||||
|
loop {
|
||||||
|
// Put this inside an if event::poll {...} if the display needs to be refreshed on a
|
||||||
|
// periodic basis. See
|
||||||
|
// https://github.com/tui-rs-revival/rust-tui-template/blob/master/src/event.rs.
|
||||||
|
match event::read() {
|
||||||
|
Ok(event) => {
|
||||||
|
if let Err(err) = match event {
|
||||||
|
CrosstermEvent::Key(e) => self.events.send(Event::Key(e)),
|
||||||
|
CrosstermEvent::Mouse(e) => self.events.send(Event::Mouse(e)),
|
||||||
|
CrosstermEvent::Resize(w, h) => self.events.send(Event::Resize(w, h)),
|
||||||
|
_ => unimplemented!(),
|
||||||
|
} {
|
||||||
|
return err;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Err(err) => return EventError::IoError(err),
|
||||||
|
};
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
53
src/tui/handler.rs
Normal file
53
src/tui/handler.rs
Normal file
@ -0,0 +1,53 @@
|
|||||||
|
use crossterm::event::{KeyCode, KeyEvent, KeyModifiers};
|
||||||
|
|
||||||
|
use super::{app::App, event::{Event, EventReceiver, EventError}};
|
||||||
|
|
||||||
|
pub struct EventHandler {
|
||||||
|
events: EventReceiver,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl EventHandler {
|
||||||
|
pub fn new(events: EventReceiver) -> Self {
|
||||||
|
EventHandler { events }
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn handle_next_event(&mut self, app: &mut App) -> Result<(), EventError> {
|
||||||
|
match self.events.recv()? {
|
||||||
|
Event::Key(key_event) => Self::handle_key_event(app, key_event),
|
||||||
|
Event::Mouse(_) => {}
|
||||||
|
Event::Resize(_, _) => {}
|
||||||
|
};
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn handle_key_event(app: &mut App, key_event: KeyEvent) {
|
||||||
|
match key_event.code {
|
||||||
|
// Exit application on `ESC` or `q`.
|
||||||
|
KeyCode::Esc | KeyCode::Char('q') => {
|
||||||
|
app.quit();
|
||||||
|
}
|
||||||
|
// Exit application on `Ctrl-C`.
|
||||||
|
KeyCode::Char('c') | KeyCode::Char('C') => {
|
||||||
|
if key_event.modifiers == KeyModifiers::CONTROL {
|
||||||
|
app.quit();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// Category change.
|
||||||
|
KeyCode::Left => {
|
||||||
|
app.decrement_category();
|
||||||
|
}
|
||||||
|
KeyCode::Right => {
|
||||||
|
app.increment_category();
|
||||||
|
}
|
||||||
|
// Selection change.
|
||||||
|
KeyCode::Up => {
|
||||||
|
app.decrement_selection();
|
||||||
|
}
|
||||||
|
KeyCode::Down => {
|
||||||
|
app.increment_selection();
|
||||||
|
}
|
||||||
|
// Other keys.
|
||||||
|
_ => {}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
129
src/tui/mod.rs
Normal file
129
src/tui/mod.rs
Normal file
@ -0,0 +1,129 @@
|
|||||||
|
use crossterm::event::{DisableMouseCapture, EnableMouseCapture};
|
||||||
|
use crossterm::terminal::{self, EnterAlternateScreen, LeaveAlternateScreen};
|
||||||
|
use musichoard::collection;
|
||||||
|
use ratatui::backend::Backend;
|
||||||
|
use ratatui::Terminal;
|
||||||
|
use std::io;
|
||||||
|
|
||||||
|
pub mod app;
|
||||||
|
pub mod event;
|
||||||
|
pub mod handler;
|
||||||
|
pub mod ui;
|
||||||
|
|
||||||
|
use self::app::App;
|
||||||
|
use self::event::{EventError, EventListener};
|
||||||
|
use self::handler::EventHandler;
|
||||||
|
use self::ui::Ui;
|
||||||
|
|
||||||
|
#[derive(Debug)]
|
||||||
|
pub enum Error {
|
||||||
|
CollectionError(String),
|
||||||
|
IoError(String),
|
||||||
|
EventError(String),
|
||||||
|
ListenerPanic,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<collection::Error> for Error {
|
||||||
|
fn from(err: collection::Error) -> Error {
|
||||||
|
Error::CollectionError(err.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<io::Error> for Error {
|
||||||
|
fn from(err: io::Error) -> Error {
|
||||||
|
Error::IoError(err.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl From<EventError> for Error {
|
||||||
|
fn from(err: EventError) -> Error {
|
||||||
|
Error::EventError(err.to_string())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct Tui<B: Backend> {
|
||||||
|
terminal: Terminal<B>,
|
||||||
|
listener: Option<EventListener>,
|
||||||
|
handler: EventHandler,
|
||||||
|
ui: Ui,
|
||||||
|
app: App,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl<B: Backend> Tui<B> {
|
||||||
|
pub fn new(
|
||||||
|
terminal: Terminal<B>,
|
||||||
|
listener: EventListener,
|
||||||
|
handler: EventHandler,
|
||||||
|
ui: Ui,
|
||||||
|
app: App,
|
||||||
|
) -> Self {
|
||||||
|
Self {
|
||||||
|
terminal,
|
||||||
|
listener: Some(listener),
|
||||||
|
handler,
|
||||||
|
ui,
|
||||||
|
app,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn init(&mut self) -> Result<(), Error> {
|
||||||
|
terminal::enable_raw_mode()?;
|
||||||
|
crossterm::execute!(io::stdout(), EnterAlternateScreen, EnableMouseCapture)?;
|
||||||
|
self.terminal.hide_cursor()?;
|
||||||
|
self.terminal.clear()?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
fn run_loop(&mut self) -> Result<(), Error> {
|
||||||
|
while self.app.is_running() {
|
||||||
|
self.terminal
|
||||||
|
.draw(|frame| self.ui.render(&mut self.app, frame))?;
|
||||||
|
self.handler.handle_next_event(&mut self.app)?;
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn run(mut self) -> Result<(), Error> {
|
||||||
|
self.init()?;
|
||||||
|
|
||||||
|
let listener_handle = self.listener.take().unwrap().spawn();
|
||||||
|
let result = self.run_loop();
|
||||||
|
|
||||||
|
match result {
|
||||||
|
Ok(_) => {
|
||||||
|
self.exit()?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
Err(err) => {
|
||||||
|
// We want to call exit before handling the run_loop result to reset the terminal.
|
||||||
|
// Therefore, we suppress exit errors (if any) to not mask the original error.
|
||||||
|
self.exit_suppress_errors();
|
||||||
|
|
||||||
|
if listener_handle.is_finished() {
|
||||||
|
match listener_handle.join() {
|
||||||
|
Ok(err) => return Err(err.into()),
|
||||||
|
// Calling std::panic::resume_unwind(err) as recommended by the Rust docs
|
||||||
|
// will not produce an error message. The panic error message is printed at
|
||||||
|
// the location of the panic which at the time is hidden by the TUI.
|
||||||
|
Err(_) => return Err(Error::ListenerPanic),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Err(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn exit(&mut self) -> Result<(), Error> {
|
||||||
|
terminal::disable_raw_mode()?;
|
||||||
|
crossterm::execute!(io::stdout(), LeaveAlternateScreen, DisableMouseCapture)?;
|
||||||
|
self.terminal.show_cursor()?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
#[allow(unused_must_use)]
|
||||||
|
fn exit_suppress_errors(&mut self) {
|
||||||
|
self.exit();
|
||||||
|
}
|
||||||
|
}
|
||||||
327
src/tui/ui.rs
Normal file
327
src/tui/ui.rs
Normal file
@ -0,0 +1,327 @@
|
|||||||
|
use musichoard::TrackFormat;
|
||||||
|
use ratatui::{
|
||||||
|
backend::Backend,
|
||||||
|
layout::{Alignment, Rect},
|
||||||
|
style::{Color, Style},
|
||||||
|
widgets::{Block, BorderType, Borders, List, ListItem, ListState, Paragraph},
|
||||||
|
Frame,
|
||||||
|
};
|
||||||
|
|
||||||
|
use super::app::{App, Category};
|
||||||
|
|
||||||
|
struct ArtistArea {
|
||||||
|
list: Rect,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct AlbumArea {
|
||||||
|
list: Rect,
|
||||||
|
info: Rect,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct TrackArea {
|
||||||
|
list: Rect,
|
||||||
|
info: Rect,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct FrameAreas {
|
||||||
|
artists: ArtistArea,
|
||||||
|
albums: AlbumArea,
|
||||||
|
tracks: TrackArea,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct SelectionList<'a> {
|
||||||
|
list: List<'a>,
|
||||||
|
state: ListState,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct ArtistState<'a> {
|
||||||
|
list: SelectionList<'a>,
|
||||||
|
active: bool,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct AlbumState<'a> {
|
||||||
|
list: SelectionList<'a>,
|
||||||
|
info: Paragraph<'a>,
|
||||||
|
active: bool,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct TrackState<'a> {
|
||||||
|
list: SelectionList<'a>,
|
||||||
|
info: Paragraph<'a>,
|
||||||
|
active: bool,
|
||||||
|
}
|
||||||
|
|
||||||
|
struct AppState<'a> {
|
||||||
|
artists: ArtistState<'a>,
|
||||||
|
albums: AlbumState<'a>,
|
||||||
|
tracks: TrackState<'a>,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct Ui {}
|
||||||
|
|
||||||
|
impl Ui {
|
||||||
|
pub fn new() -> Self {
|
||||||
|
Ui {}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn construct_areas(frame: Rect) -> FrameAreas {
|
||||||
|
let width_one_third = frame.width / 3;
|
||||||
|
let height_one_third = frame.height / 3;
|
||||||
|
|
||||||
|
let panel_width = width_one_third;
|
||||||
|
let panel_width_last = frame.width - 2 * panel_width;
|
||||||
|
let panel_height_top = frame.height - height_one_third;
|
||||||
|
let panel_height_bottom = height_one_third;
|
||||||
|
|
||||||
|
let artist_list = Rect {
|
||||||
|
x: frame.x,
|
||||||
|
y: frame.y,
|
||||||
|
width: panel_width,
|
||||||
|
height: frame.height,
|
||||||
|
};
|
||||||
|
|
||||||
|
let album_list = Rect {
|
||||||
|
x: artist_list.x + artist_list.width,
|
||||||
|
y: frame.y,
|
||||||
|
width: panel_width,
|
||||||
|
height: panel_height_top,
|
||||||
|
};
|
||||||
|
|
||||||
|
let album_info = Rect {
|
||||||
|
x: album_list.x,
|
||||||
|
y: album_list.y + album_list.height,
|
||||||
|
width: album_list.width,
|
||||||
|
height: panel_height_bottom,
|
||||||
|
};
|
||||||
|
|
||||||
|
let track_list = Rect {
|
||||||
|
x: album_list.x + album_list.width,
|
||||||
|
y: frame.y,
|
||||||
|
width: panel_width_last,
|
||||||
|
height: panel_height_top,
|
||||||
|
};
|
||||||
|
|
||||||
|
let track_info = Rect {
|
||||||
|
x: track_list.x,
|
||||||
|
y: track_list.y + track_list.height,
|
||||||
|
width: track_list.width,
|
||||||
|
height: panel_height_bottom,
|
||||||
|
};
|
||||||
|
|
||||||
|
FrameAreas {
|
||||||
|
artists: ArtistArea { list: artist_list },
|
||||||
|
albums: AlbumArea {
|
||||||
|
list: album_list,
|
||||||
|
info: album_info,
|
||||||
|
},
|
||||||
|
tracks: TrackArea {
|
||||||
|
list: track_list,
|
||||||
|
info: track_info,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn construct_artist_list(app: &App) -> ArtistState {
|
||||||
|
let artists = app.get_artist_ids();
|
||||||
|
let list = List::new(
|
||||||
|
artists
|
||||||
|
.iter()
|
||||||
|
.map(|id| ListItem::new(id.name.as_str()))
|
||||||
|
.collect::<Vec<ListItem>>(),
|
||||||
|
);
|
||||||
|
|
||||||
|
let selected_artist = app.selected_artist();
|
||||||
|
|
||||||
|
let mut state = ListState::default();
|
||||||
|
state.select(selected_artist);
|
||||||
|
|
||||||
|
let active = app.get_active_category() == Category::Artist;
|
||||||
|
|
||||||
|
ArtistState {
|
||||||
|
list: SelectionList { list, state },
|
||||||
|
active,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn construct_album_list(app: &App) -> AlbumState {
|
||||||
|
let albums = app.get_album_ids();
|
||||||
|
let list = List::new(
|
||||||
|
albums
|
||||||
|
.iter()
|
||||||
|
.map(|id| ListItem::new(id.title.as_str()))
|
||||||
|
.collect::<Vec<ListItem>>(),
|
||||||
|
);
|
||||||
|
|
||||||
|
let selected_album = app.selected_album();
|
||||||
|
|
||||||
|
let mut state = ListState::default();
|
||||||
|
state.select(selected_album);
|
||||||
|
|
||||||
|
let active = app.get_active_category() == Category::Album;
|
||||||
|
|
||||||
|
let album = selected_album.map(|i| albums[i]);
|
||||||
|
let info = Paragraph::new(format!(
|
||||||
|
"Title: {}\n\
|
||||||
|
Year: {}",
|
||||||
|
album.map(|a| a.title.as_str()).unwrap_or(""),
|
||||||
|
album
|
||||||
|
.map(|a| a.year.to_string())
|
||||||
|
.unwrap_or_else(|| "".to_string()),
|
||||||
|
));
|
||||||
|
|
||||||
|
AlbumState {
|
||||||
|
list: SelectionList { list, state },
|
||||||
|
info,
|
||||||
|
active,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn construct_track_list(app: &App) -> TrackState {
|
||||||
|
let tracks = app.get_track_ids();
|
||||||
|
let list = List::new(
|
||||||
|
tracks
|
||||||
|
.iter()
|
||||||
|
.map(|id| ListItem::new(id.title.as_str()))
|
||||||
|
.collect::<Vec<ListItem>>(),
|
||||||
|
);
|
||||||
|
|
||||||
|
let selected_track = app.selected_track();
|
||||||
|
|
||||||
|
let mut state = ListState::default();
|
||||||
|
state.select(selected_track);
|
||||||
|
|
||||||
|
let active = app.get_active_category() == Category::Track;
|
||||||
|
|
||||||
|
let track = selected_track.map(|i| tracks[i]);
|
||||||
|
let info = Paragraph::new(format!(
|
||||||
|
"Track: {}\n\
|
||||||
|
Title: {}\n\
|
||||||
|
Artist: {}\n\
|
||||||
|
Format: {}",
|
||||||
|
track
|
||||||
|
.map(|t| t.number.to_string())
|
||||||
|
.unwrap_or_else(|| "".to_string()),
|
||||||
|
track.map(|t| t.title.as_str()).unwrap_or(""),
|
||||||
|
track
|
||||||
|
.map(|t| t.artist.join("; "))
|
||||||
|
.unwrap_or_else(|| "".to_string()),
|
||||||
|
track
|
||||||
|
.map(|t| match t.format {
|
||||||
|
TrackFormat::Flac => "FLAC",
|
||||||
|
TrackFormat::Mp3 => "MP3",
|
||||||
|
})
|
||||||
|
.unwrap_or(""),
|
||||||
|
));
|
||||||
|
|
||||||
|
TrackState {
|
||||||
|
list: SelectionList { list, state },
|
||||||
|
info,
|
||||||
|
active,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn construct_app_state(app: &App) -> AppState {
|
||||||
|
AppState {
|
||||||
|
artists: Self::construct_artist_list(app),
|
||||||
|
albums: Self::construct_album_list(app),
|
||||||
|
tracks: Self::construct_track_list(app),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn style(_active: bool) -> Style {
|
||||||
|
Style::default().fg(Color::White).bg(Color::Black)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn block_style(active: bool) -> Style {
|
||||||
|
Self::style(active)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn highlight_style(active: bool) -> Style {
|
||||||
|
if active {
|
||||||
|
Style::default().fg(Color::White).bg(Color::DarkGray)
|
||||||
|
} else {
|
||||||
|
Self::style(false)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn block<'a>(title: &str, active: bool) -> Block<'a> {
|
||||||
|
Block::default()
|
||||||
|
.title_alignment(Alignment::Center)
|
||||||
|
.borders(Borders::ALL)
|
||||||
|
.border_type(BorderType::Rounded)
|
||||||
|
.style(Self::block_style(active))
|
||||||
|
.title(format!(" {title} "))
|
||||||
|
}
|
||||||
|
|
||||||
|
fn render_list_widget<B: Backend>(
|
||||||
|
title: &str,
|
||||||
|
mut list: SelectionList,
|
||||||
|
active: bool,
|
||||||
|
area: Rect,
|
||||||
|
frame: &mut Frame<'_, B>,
|
||||||
|
) {
|
||||||
|
frame.render_stateful_widget(
|
||||||
|
list.list
|
||||||
|
.highlight_style(Self::highlight_style(active))
|
||||||
|
.highlight_symbol(">> ")
|
||||||
|
.style(Self::style(active))
|
||||||
|
.block(Self::block(title, active)),
|
||||||
|
area,
|
||||||
|
&mut list.state,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
fn render_info_widget<B: Backend>(
|
||||||
|
title: &str,
|
||||||
|
paragraph: Paragraph,
|
||||||
|
active: bool,
|
||||||
|
area: Rect,
|
||||||
|
frame: &mut Frame<'_, B>,
|
||||||
|
) {
|
||||||
|
frame.render_widget(
|
||||||
|
paragraph
|
||||||
|
.style(Self::style(active))
|
||||||
|
.block(Self::block(title, active)),
|
||||||
|
area,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
fn render_artist_column<B: Backend>(
|
||||||
|
state: ArtistState,
|
||||||
|
area: ArtistArea,
|
||||||
|
frame: &mut Frame<'_, B>,
|
||||||
|
) {
|
||||||
|
Self::render_list_widget("Artists", state.list, state.active, area.list, frame);
|
||||||
|
}
|
||||||
|
|
||||||
|
fn render_album_column<B: Backend>(
|
||||||
|
state: AlbumState,
|
||||||
|
area: AlbumArea,
|
||||||
|
frame: &mut Frame<'_, B>,
|
||||||
|
) {
|
||||||
|
Self::render_list_widget("Albums", state.list, state.active, area.list, frame);
|
||||||
|
Self::render_info_widget("Album info", state.info, state.active, area.info, frame);
|
||||||
|
}
|
||||||
|
|
||||||
|
fn render_track_column<B: Backend>(
|
||||||
|
state: TrackState,
|
||||||
|
area: TrackArea,
|
||||||
|
frame: &mut Frame<'_, B>,
|
||||||
|
) {
|
||||||
|
Self::render_list_widget("Tracks", state.list, state.active, area.list, frame);
|
||||||
|
Self::render_info_widget("Track info", state.info, state.active, area.info, frame);
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn render<B: Backend>(&mut self, app: &App, frame: &mut Frame<'_, B>) {
|
||||||
|
// This is where you add new widgets.
|
||||||
|
// See the following resources:
|
||||||
|
// - https://docs.rs/ratatui/latest/ratatui/widgets/index.html
|
||||||
|
// - https://github.com/tui-rs-revival/ratatui/tree/master/examples
|
||||||
|
let areas = Self::construct_areas(frame.size());
|
||||||
|
let app_state = Self::construct_app_state(app);
|
||||||
|
|
||||||
|
Self::render_artist_column(app_state.artists, areas.artists, frame);
|
||||||
|
Self::render_album_column(app_state.albums, areas.albums, frame);
|
||||||
|
Self::render_track_column(app_state.tracks, areas.tracks, frame);
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue
Block a user