Separate dependencies (#50)
Closes #39 Reviewed-on: https://git.wojciechkozlowski.eu/wojtek/musichoard/pulls/50
This commit is contained in:
parent
ad18c7e384
commit
e31b44d31d
25
Cargo.toml
25
Cargo.toml
@ -6,16 +6,29 @@ edition = "2021"
|
||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||
|
||||
[dependencies]
|
||||
crossterm = "0.26.1"
|
||||
openssh = { version = "0.9.9", features = ["native-mux"], default-features = false }
|
||||
crossterm = { version = "0.26.1", optional = true}
|
||||
openssh = { version = "0.9.9", features = ["native-mux"], default-features = false, optional = true}
|
||||
ratatui = { version = "0.20.1", optional = true}
|
||||
serde = { version = "1.0.159", features = ["derive"] }
|
||||
serde_json = "1.0.95"
|
||||
structopt = "0.3.26"
|
||||
ratatui = "0.20.1"
|
||||
tokio = { version = "1.27.0", features = ["rt"] }
|
||||
serde_json = { version = "1.0.95", optional = true}
|
||||
structopt = { version = "0.3.26", optional = true}
|
||||
tokio = { version = "1.27.0", features = ["rt"], optional = true}
|
||||
uuid = { version = "1.3.0", features = ["serde"] }
|
||||
|
||||
[dev-dependencies]
|
||||
mockall = "0.11.4"
|
||||
once_cell = "1.17.1"
|
||||
tempfile = "3.5.0"
|
||||
|
||||
[features]
|
||||
bin = ["structopt"]
|
||||
database-json = ["serde_json"]
|
||||
library-ssh = ["openssh", "tokio"]
|
||||
tui = ["crossterm", "ratatui"]
|
||||
|
||||
[[bin]]
|
||||
name = "musichoard"
|
||||
required-features = ["bin", "database-json", "library-ssh", "tui"]
|
||||
|
||||
[package.metadata.docs.rs]
|
||||
all-features = true
|
||||
|
@ -17,7 +17,7 @@ env CARGO_TARGET_DIR=codecov \
|
||||
env RUSTFLAGS="-C instrument-coverage" \
|
||||
LLVM_PROFILE_FILE="codecov/debug/profraw/musichoard-%p-%m.profraw" \
|
||||
CARGO_TARGET_DIR=codecov \
|
||||
cargo test
|
||||
cargo test --all-features
|
||||
grcov codecov/debug/profraw \
|
||||
--binary-path ./codecov/debug/ \
|
||||
--output-types html \
|
||||
|
@ -7,6 +7,7 @@ use serde::{de::DeserializeOwned, Serialize};
|
||||
#[cfg(test)]
|
||||
use mockall::automock;
|
||||
|
||||
#[cfg(feature = "database-json")]
|
||||
pub mod json;
|
||||
|
||||
/// Error type for database calls.
|
||||
|
@ -8,9 +8,6 @@ use std::{
|
||||
str,
|
||||
};
|
||||
|
||||
use openssh::{KnownHosts, Session};
|
||||
use tokio::runtime::{self, Runtime};
|
||||
|
||||
use super::{BeetsLibraryExecutor, Error};
|
||||
|
||||
const BEET_DEFAULT: &str = "beet";
|
||||
@ -77,64 +74,73 @@ impl BeetsLibraryExecutor for BeetsLibraryProcessExecutor {
|
||||
impl BeetsLibraryExecutorPrivate for BeetsLibraryProcessExecutor {}
|
||||
|
||||
// GRCOV_EXCL_START
|
||||
/// Beets library executor that executes beets commands over SSH.
|
||||
pub struct BeetsLibrarySshExecutor {
|
||||
rt: Runtime,
|
||||
session: Session,
|
||||
bin: String,
|
||||
config: Option<String>,
|
||||
}
|
||||
#[cfg(feature = "library-ssh")]
|
||||
pub mod ssh {
|
||||
|
||||
impl From<openssh::Error> for Error {
|
||||
fn from(err: openssh::Error) -> Error {
|
||||
Error::Executor(err.to_string())
|
||||
}
|
||||
}
|
||||
use openssh::{KnownHosts, Session};
|
||||
use tokio::runtime::{self, Runtime};
|
||||
|
||||
impl BeetsLibrarySshExecutor {
|
||||
/// Create a new [`BeetsLibrarySshExecutor`] that uses the default beets executable over an SSH
|
||||
/// connection. This call will attempt to establish the connection and will fail if the
|
||||
/// connection fails.
|
||||
pub fn new<H: AsRef<str>>(host: H) -> Result<Self, Error> {
|
||||
Self::bin(host, BEET_DEFAULT)
|
||||
use super::*;
|
||||
|
||||
/// Beets library executor that executes beets commands over SSH.
|
||||
pub struct BeetsLibrarySshExecutor {
|
||||
rt: Runtime,
|
||||
session: Session,
|
||||
bin: String,
|
||||
config: Option<String>,
|
||||
}
|
||||
|
||||
/// Create a new [`BeetsLibrarySshExecutor`] that uses the provided beets executable over an SSH
|
||||
/// connection. This call will attempt to establish the connection and will fail if the
|
||||
/// connection fails.
|
||||
pub fn bin<H: AsRef<str>, S: Into<String>>(host: H, bin: S) -> Result<Self, Error> {
|
||||
let rt = runtime::Builder::new_current_thread()
|
||||
.enable_all()
|
||||
.build()
|
||||
.unwrap();
|
||||
let session = rt.block_on(Session::connect_mux(host, KnownHosts::Strict))?;
|
||||
Ok(BeetsLibrarySshExecutor {
|
||||
rt,
|
||||
session,
|
||||
bin: bin.into(),
|
||||
config: None,
|
||||
})
|
||||
}
|
||||
|
||||
/// Update the configuration file passed to the beets executable.
|
||||
pub fn config<P: Into<String>>(mut self, path: Option<P>) -> Self {
|
||||
self.config = path.map(|p| p.into());
|
||||
self
|
||||
}
|
||||
}
|
||||
|
||||
impl BeetsLibraryExecutor for BeetsLibrarySshExecutor {
|
||||
fn exec<S: AsRef<str> + 'static>(&mut self, arguments: &[S]) -> Result<Vec<String>, Error> {
|
||||
let mut cmd = self.session.command(&self.bin);
|
||||
if let Some(ref path) = self.config {
|
||||
cmd.arg("--config");
|
||||
cmd.arg(path);
|
||||
impl From<openssh::Error> for Error {
|
||||
fn from(err: openssh::Error) -> Error {
|
||||
Error::Executor(err.to_string())
|
||||
}
|
||||
cmd.args(arguments.iter().map(|s| s.as_ref()));
|
||||
let output = self.rt.block_on(cmd.output())?;
|
||||
Self::output(output)
|
||||
}
|
||||
}
|
||||
|
||||
impl BeetsLibraryExecutorPrivate for BeetsLibrarySshExecutor {}
|
||||
impl BeetsLibrarySshExecutor {
|
||||
/// Create a new [`BeetsLibrarySshExecutor`] that uses the default beets executable over an
|
||||
/// SSH connection. This call will attempt to establish the connection and will fail if the
|
||||
/// connection fails.
|
||||
pub fn new<H: AsRef<str>>(host: H) -> Result<Self, Error> {
|
||||
Self::bin(host, BEET_DEFAULT)
|
||||
}
|
||||
|
||||
/// Create a new [`BeetsLibrarySshExecutor`] that uses the provided beets executable over an
|
||||
/// SSH connection. This call will attempt to establish the connection and will fail if the
|
||||
/// connection fails.
|
||||
pub fn bin<H: AsRef<str>, S: Into<String>>(host: H, bin: S) -> Result<Self, Error> {
|
||||
let rt = runtime::Builder::new_current_thread()
|
||||
.enable_all()
|
||||
.build()
|
||||
.unwrap();
|
||||
let session = rt.block_on(Session::connect_mux(host, KnownHosts::Strict))?;
|
||||
Ok(BeetsLibrarySshExecutor {
|
||||
rt,
|
||||
session,
|
||||
bin: bin.into(),
|
||||
config: None,
|
||||
})
|
||||
}
|
||||
|
||||
/// Update the configuration file passed to the beets executable.
|
||||
pub fn config<P: Into<String>>(mut self, path: Option<P>) -> Self {
|
||||
self.config = path.map(|p| p.into());
|
||||
self
|
||||
}
|
||||
}
|
||||
|
||||
impl BeetsLibraryExecutor for BeetsLibrarySshExecutor {
|
||||
fn exec<S: AsRef<str> + 'static>(&mut self, arguments: &[S]) -> Result<Vec<String>, Error> {
|
||||
let mut cmd = self.session.command(&self.bin);
|
||||
if let Some(ref path) = self.config {
|
||||
cmd.arg("--config");
|
||||
cmd.arg(path);
|
||||
}
|
||||
cmd.args(arguments.iter().map(|s| s.as_ref()));
|
||||
let output = self.rt.block_on(cmd.output())?;
|
||||
Self::output(output)
|
||||
}
|
||||
}
|
||||
|
||||
impl BeetsLibraryExecutorPrivate for BeetsLibrarySshExecutor {}
|
||||
}
|
||||
// GRCOV_EXCL_STOP
|
||||
|
@ -12,7 +12,7 @@ use musichoard::{
|
||||
},
|
||||
library::{
|
||||
beets::{
|
||||
executor::{BeetsLibraryProcessExecutor, BeetsLibrarySshExecutor},
|
||||
executor::{ssh::BeetsLibrarySshExecutor, BeetsLibraryProcessExecutor},
|
||||
BeetsLibrary,
|
||||
},
|
||||
Library,
|
||||
|
@ -1 +1,2 @@
|
||||
#[cfg(feature = "database-json")]
|
||||
mod json;
|
||||
|
Loading…
Reference in New Issue
Block a user