use std::path::{Path, PathBuf};
use std::sync::atomic::{AtomicU64, Ordering};
use std::sync::{Arc, Mutex};
use crate::config::Config;
use crate::db::connection::Database;
use crate::db::queries;
use crate::player::commands::PlayerCommand;
use crate::player::state::{LoadState, PlaylistItem, QueueItemId, SharedPlayerState};
use crate::remote::client::{SubsonicAuth, SubsonicClient};
pub fn get_remote_password(cfg: &Config) -> Option<String> {
if !cfg.remote.password.is_empty() {
return Some(cfg.remote.password.clone());
}
crate::credentials::get_password(&cfg.remote.url).ok()
}
pub const SUBSONIC_CREDENTIAL_ACCOUNT: &str = "koan-subsonic";
pub fn get_subsonic_password(cfg: &Config) -> Option<String> {
if !cfg.subsonic.password.is_empty() {
return Some(cfg.subsonic.password.clone());
}
crate::credentials::get_password(SUBSONIC_CREDENTIAL_ACCOUNT)
.ok()
.filter(|p| !p.is_empty())
}
pub fn subsonic_auth(cfg: &Config) -> Option<SubsonicAuth> {
if !cfg.remote.enabled || cfg.remote.url.is_empty() {
return None;
}
let password = get_remote_password(cfg)?;
Some(SubsonicAuth::new(
&cfg.remote.url,
&cfg.remote.username,
&password,
))
}
pub fn subsonic_client(cfg: &Config) -> Option<SubsonicClient> {
subsonic_auth(cfg).map(SubsonicClient::from_auth)
}
#[derive(Debug, thiserror::Error)]
pub enum ShareError {
#[error("no remote server is configured")]
NoRemote,
#[error("none of these tracks are on the server, so a link has nothing to point at")]
NothingRemote,
#[error("the server refused to share these: {0}")]
Server(#[from] crate::remote::client::SubsonicError),
#[error(transparent)]
Database(#[from] crate::db::connection::DbError),
}
#[derive(Debug, Clone)]
pub struct ShareOutcome {
pub url: String,
pub id: String,
pub shared: usize,
pub skipped: usize,
}
pub fn create_share(
db: &Database,
cfg: &Config,
track_ids: &[i64],
description: Option<&str>,
) -> Result<ShareOutcome, ShareError> {
let client = subsonic_client(cfg).ok_or(ShareError::NoRemote)?;
let rows = queries::tracks_by_ids(&db.conn, track_ids)?;
let shared = rows.iter().filter(|t| t.remote_id.is_some()).count();
if shared == 0 {
return Err(ShareError::NothingRemote);
}
let one_album = rows
.first()
.and_then(|f| f.album_id)
.filter(|first| rows.iter().all(|t| t.album_id == Some(*first)))
.and_then(|album_id| album_remote_id(&db.conn, album_id, rows.len()));
let remote_ids: Vec<String> = match one_album {
Some(rid) => vec![rid],
None => rows.into_iter().filter_map(|t| t.remote_id).collect(),
};
let refs: Vec<&str> = remote_ids.iter().map(String::as_str).collect();
let share = client.create_share(&refs, description)?;
let url = share
.url
.clone()
.unwrap_or_else(|| format!("{}/s/{}", client.base_url(), share.id));
Ok(ShareOutcome {
url,
id: share.id,
shared,
skipped: track_ids.len().saturating_sub(shared),
})
}
fn album_remote_id(conn: &rusqlite::Connection, album_id: i64, selected: usize) -> Option<String> {
let (remote_id, total): (Option<String>, i64) = conn
.query_row(
"SELECT al.remote_id, (SELECT COUNT(*) FROM tracks WHERE album_id = al.id)
FROM albums al WHERE al.id = ?1",
[album_id],
|row| Ok((row.get(0)?, row.get(1)?)),
)
.ok()?;
(total == selected as i64).then_some(remote_id).flatten()
}
pub fn truncate_bytes(s: &str, max: usize) -> &str {
if s.len() <= max {
return s;
}
let mut end = max;
while end > 0 && !s.is_char_boundary(end) {
end -= 1;
}
&s[..end]
}
pub fn sanitise_filename(s: &str) -> String {
let cleaned: String = s
.chars()
.map(|c| match c {
'/' | '\\' | ':' | '*' | '?' | '"' | '<' | '>' | '|' => '_',
_ => c,
})
.collect::<String>()
.trim()
.to_string();
truncate_bytes(&cleaned, 240).trim_end().to_string()
}
pub fn cache_path_for_track(
cache_dir: &Path,
track: &queries::TrackRow,
album_date: Option<&str>,
) -> PathBuf {
let artist_dir = sanitise_filename(&track.artist_name);
let year = album_date
.and_then(|d| if d.len() >= 4 { Some(&d[..4]) } else { None })
.map(|y| format!("({}) ", y))
.unwrap_or_default();
let codec = track
.codec
.as_deref()
.map(|c| format!(" [{}]", c))
.unwrap_or_default();
let album_dir = sanitise_filename(&format!("{}{}{}", year, track.album_title, codec));
let disc_prefix = match track.disc {
Some(d) if d > 1 => format!("{}-", d),
_ => String::new(),
};
let track_num = track
.track_number
.map(|n| format!("{:02}. ", n))
.unwrap_or_default();
let ext = track
.codec
.as_deref()
.map(|c| c.to_lowercase())
.unwrap_or_else(|| "flac".into());
let filename = sanitise_filename(&format!(
"{}{}{} - {}",
disc_prefix, track_num, track.artist_name, track.title
));
cache_dir
.join(artist_dir)
.join(album_dir)
.join(format!("{}.{}", filename, ext))
}
pub fn resolve_item_path(
db: &Database,
cfg: &Config,
id: i64,
track: &queries::TrackRow,
album_date: Option<&str>,
) -> (PathBuf, LoadState) {
match queries::resolve_playback_path(&db.conn, id) {
Ok(Some(queries::PlaybackSource::Local(p))) => (p, LoadState::Ready),
Ok(Some(queries::PlaybackSource::Cached(p))) => {
let state = if is_cached_audio(&p) {
LoadState::Ready
} else {
LoadState::Pending
};
(p, state)
}
Ok(Some(queries::PlaybackSource::Remote(_))) => {
let dest = cache_path_for_track(&cfg.cache_dir(), track, album_date);
if dest.exists() && is_cached_audio(&dest) {
(dest, LoadState::Ready)
} else {
(dest, LoadState::Pending)
}
}
_ => {
let dest = cache_path_for_track(&cfg.cache_dir(), track, album_date);
(dest, LoadState::Pending)
}
}
}
pub fn playlist_item_from_track(
track: &queries::TrackRow,
album_date: Option<&str>,
dest: PathBuf,
load_state: LoadState,
) -> PlaylistItem {
let year = album_date.and_then(|d| {
if d.len() >= 4 {
Some(d[..4].to_string())
} else {
None
}
});
PlaylistItem {
id: QueueItemId::new(),
db_id: Some(track.id),
path: dest,
title: track.title.clone(),
artist: track.artist_name.clone(),
album_artist: track.album_artist_name.clone(),
album: track.album_title.clone(),
year,
codec: track.codec.clone(),
track_number: track.track_number.map(|n| n as i64),
disc: track.disc.map(|n| n as i64),
duration_ms: track.duration_ms.map(|d| d as u64),
load_state,
}
}
pub fn playlist_items_for_tracks(db: &Database, tracks: &[queries::TrackRow]) -> Vec<PlaylistItem> {
use std::collections::HashMap;
let cfg = Config::load().unwrap_or_default();
let mut album_dates: HashMap<i64, Option<String>> = HashMap::new();
tracks
.iter()
.map(|track| {
let album_date = match track.album_id {
Some(aid) => album_dates
.entry(aid)
.or_insert_with(|| queries::album_date(&db.conn, aid).ok().flatten())
.clone(),
None => None,
};
let (path, load_state) =
resolve_item_path(db, &cfg, track.id, track, album_date.as_deref());
playlist_item_from_track(track, album_date.as_deref(), path, load_state)
})
.collect()
}
pub fn track_to_playlist_item(track: &queries::TrackRow, db: &Database) -> PlaylistItem {
let album_date = track
.album_id
.and_then(|aid| queries::album_date(&db.conn, aid).ok().flatten());
let cfg = Config::load().unwrap_or_default();
let (path, load_state) = resolve_item_path(db, &cfg, track.id, track, album_date.as_deref());
let year = album_date.as_deref().and_then(|d| {
if d.len() >= 4 {
Some(d[..4].to_string())
} else {
None
}
});
PlaylistItem {
id: QueueItemId::new(),
db_id: Some(track.id),
path,
title: track.title.clone(),
artist: track.artist_name.clone(),
album_artist: track.album_artist_name.clone(),
album: track.album_title.clone(),
year,
codec: track.codec.clone(),
track_number: track.track_number.map(|n| n as i64),
disc: track.disc.map(|n| n as i64),
duration_ms: track.duration_ms.map(|d| d as u64),
load_state,
}
}
fn is_cached_audio(path: &std::path::Path) -> bool {
const MIN_PLAUSIBLE_BYTES: u64 = 4096;
match std::fs::metadata(path) {
Ok(meta) if meta.len() >= MIN_PLAUSIBLE_BYTES => true,
Ok(_) => {
let mut first = [0u8; 1];
match std::fs::File::open(path)
.and_then(|mut f| std::io::Read::read_exact(&mut f, &mut first).map(|_| first[0]))
{
Ok(b) => b != b'{' && b != b'<',
Err(_) => false,
}
}
Err(_) => false,
}
}
pub fn download_track(
db_id: i64,
queue_id: QueueItemId,
tx: &crossbeam_channel::Sender<PlayerCommand>,
log_buf: &Arc<Mutex<Vec<String>>>,
state: &Arc<SharedPlayerState>,
cfg: &Config,
client: &SubsonicClient,
) {
let db = match Database::open_default() {
Ok(db) => db,
Err(e) => {
state.update_load_state(queue_id, LoadState::Failed(format!("db error: {}", e)));
return;
}
};
let track = match queries::get_track_row(&db.conn, db_id) {
Ok(Some(t)) => t,
_ => {
state.update_load_state(queue_id, LoadState::Failed("track not found".into()));
return;
}
};
let remote_id = match &track.remote_id {
Some(rid) => rid.clone(),
None => {
if let Some(ref path) = track.path {
let p = std::path::PathBuf::from(path);
if p.exists() {
state.update_paths(&[(queue_id, p)]);
state.update_load_state(queue_id, LoadState::Ready);
if state.is_cursor(queue_id) {
tx.send(PlayerCommand::TrackReady(queue_id)).ok();
}
return;
}
}
state.update_load_state(queue_id, LoadState::Failed("no remote_id".into()));
return;
}
};
if let Some(ref local_path) = track.path {
let p = std::path::PathBuf::from(local_path);
if p.exists() {
log::info!("download_track: local file exists, using {}", p.display());
state.update_paths(&[(queue_id, p)]);
state.update_load_state(queue_id, LoadState::Ready);
if state.is_cursor(queue_id) {
tx.send(PlayerCommand::TrackReady(queue_id)).ok();
}
return;
}
}
let album_date: Option<String> = track
.album_id
.and_then(|aid| queries::album_date(&db.conn, aid).ok().flatten());
let dest = cache_path_for_track(&cfg.cache_dir(), &track, album_date.as_deref());
if dest.exists() && !is_cached_audio(&dest) {
log::warn!(
"discarding non-audio cache entry {} (likely a stored server error)",
dest.display()
);
let _ = std::fs::remove_file(&dest);
}
if dest.exists() {
state.update_paths(&[(queue_id, dest)]);
state.update_load_state(queue_id, LoadState::Ready);
if state.is_cursor(queue_id) {
tx.send(PlayerCommand::TrackReady(queue_id)).ok();
}
return;
}
state.update_paths(&[(queue_id, crate::remote::download::part_path(&dest))]);
let bytes_written: Arc<AtomicU64> = Arc::new(AtomicU64::new(0));
let progress_state = state.clone();
let progress_qid = queue_id;
let bytes_written_progress = bytes_written.clone();
let progress_tx = tx.clone();
let stream_ready_sent = Arc::new(std::sync::atomic::AtomicBool::new(false));
let stream_ready_flag = stream_ready_sent.clone();
let result = client.download_with_progress(&remote_id, &dest, move |downloaded, total| {
bytes_written_progress.store(downloaded, Ordering::Release);
progress_state.update_load_state(
progress_qid,
LoadState::Downloading {
downloaded,
total,
bytes_written: bytes_written_progress.clone(),
},
);
if !stream_ready_flag.load(Ordering::Relaxed)
&& downloaded >= crate::player::state::STREAM_THRESHOLD
{
stream_ready_flag.store(true, Ordering::Relaxed);
progress_tx
.send(PlayerCommand::TrackStreamReady(progress_qid))
.ok();
}
});
if let Err(e) = result {
state.update_load_state(queue_id, LoadState::Failed(e.to_string()));
push_log(log_buf, format!("x {} — {}", track.title, e));
return;
}
state.update_paths(&[(queue_id, dest.clone())]);
state.update_load_state(queue_id, LoadState::Ready);
if let Err(e) = queries::set_cached_path(&db.conn, db_id, &dest.to_string_lossy()) {
log::warn!(
"cached {} but failed to record it ({}) — it will not be evicted",
dest.display(),
e
);
}
push_log(
log_buf,
format!("+ {} — {}", track.title, track.artist_name),
);
if state.is_cursor(queue_id) {
tx.send(PlayerCommand::TrackReady(queue_id)).ok();
}
}
fn push_log(log_buf: &Arc<Mutex<Vec<String>>>, msg: String) {
match log_buf.lock() {
Ok(mut buf) => buf.push(msg),
Err(_) => log::info!("{}", msg),
}
}
pub fn spawn_downloads(
pending: Vec<(i64, QueueItemId)>,
tx: crossbeam_channel::Sender<PlayerCommand>,
state: Arc<SharedPlayerState>,
) {
let log_buf: Arc<Mutex<Vec<String>>> = Arc::new(Mutex::new(Vec::new()));
if let Err(e) = std::thread::Builder::new()
.name("koan-download".into())
.spawn(move || {
let cfg = Config::load().unwrap_or_default();
let Some(client) = subsonic_client(&cfg) else {
log::warn!(
"remote not configured -- skipping {} downloads",
pending.len()
);
return;
};
for (db_id, queue_id) in pending {
download_track(db_id, queue_id, &tx, &log_buf, &state, &cfg, &client);
}
})
{
log::error!("failed to spawn download thread: {}", e);
}
}
#[cfg(test)]
mod share_tests {
use super::*;
use crate::db::queries::sample_meta;
fn test_db() -> Database {
let conn = rusqlite::Connection::open_in_memory().unwrap();
conn.pragma_update(None, "foreign_keys", "on").unwrap();
crate::db::schema::create_tables(&conn).unwrap();
Database { conn }
}
fn album_of_three(db: &Database) -> (i64, Vec<i64>) {
let ids: Vec<i64> = ["One", "Two", "Three"]
.iter()
.enumerate()
.map(|(i, title)| {
let mut meta = sample_meta(title, "Boards of Canada", "Geogaddi");
meta.path = Some(format!("/music/geogaddi/{i}.flac"));
meta.track_number = Some(i as i32 + 1);
queries::upsert_track(&db.conn, &meta).unwrap()
})
.collect();
let album_id: i64 = db
.conn
.query_row("SELECT album_id FROM tracks WHERE id = ?1", [ids[0]], |r| {
r.get(0)
})
.unwrap();
db.conn
.execute(
"UPDATE albums SET remote_id = 'al-1' WHERE id = ?1",
[album_id],
)
.unwrap();
(album_id, ids)
}
#[test]
fn whole_album_collapses_to_the_album_link() {
let db = test_db();
let (album_id, ids) = album_of_three(&db);
assert_eq!(
album_remote_id(&db.conn, album_id, ids.len()),
Some("al-1".into())
);
}
#[test]
fn part_of_an_album_does_not() {
let db = test_db();
let (album_id, _) = album_of_three(&db);
assert_eq!(album_remote_id(&db.conn, album_id, 2), None);
}
#[test]
fn a_local_only_album_has_no_link_to_collapse_to() {
let db = test_db();
let (album_id, ids) = album_of_three(&db);
db.conn
.execute(
"UPDATE albums SET remote_id = NULL WHERE id = ?1",
[album_id],
)
.unwrap();
assert_eq!(album_remote_id(&db.conn, album_id, ids.len()), None);
}
}