Fix a couple JavaScript errors

Bump rustix from 0.37.23 to 0.37.25

.github/ISSUE_TEMPLATE/bug_report.md

@@ -0,0 +1,33 @@
+---
+name: Bug report
+about: Create a report to help us improve
+title: ''
+labels: bug
+assignees: ''
+
+---
+
+**Describe the bug**
+A clear and concise description of what the bug is.
+
+**To Reproduce**
+Steps to reproduce the behavior:
+1. Go to '...'
+2. Click on '....'
+3. Scroll down to '....'
+4. See error
+
+**Expected behavior**
+A clear and concise description of what you expected to happen.
+
+**Screenshots**
+If applicable, add screenshots to help explain your problem.
+
+**Version information (please complete the following information):**
+ - OS: [e.g. NixOS 23.11]
+ - Browser [e.g. firefox, chrome]
+ - Empede version [e.g. v0.2.1]
+ - MPD version [e.g. 0.23.15]
+
+**Additional context**
+Add any other context about the problem here.

.github/ISSUE_TEMPLATE/feature_request.md

@@ -0,0 +1,20 @@
+---
+name: Feature request
+about: Suggest an idea for this project
+title: ''
+labels: ''
+assignees: ''
+
+---
+
+**Is your feature request related to a problem? Please describe.**
+A clear and concise description of what the problem is. Ex. I'm always frustrated when [...]
+
+**Describe the solution you'd like**
+A clear and concise description of what you want to happen.
+
+**Describe alternatives you've considered**
+A clear and concise description of any alternative solutions or features you've considered.
+
+**Additional context**
+Add any other context or screenshots about the feature request here.

.github/dependabot.yml

@@ -0,0 +1,7 @@
+# https://docs.github.com/github/administering-a-repository/configuration-options-for-dependency-updates
+version: 2
+updates:
+  - package-ecosystem: "cargo"
+    directory: "/"
+    schedule:
+      interval: "daily"

CODE_OF_CONDUCT.md

@@ -0,0 +1,128 @@
+# Contributor Covenant Code of Conduct
+
+## Our Pledge
+
+We as members, contributors, and leaders pledge to make participation in our
+community a harassment-free experience for everyone, regardless of age, body
+size, visible or invisible disability, ethnicity, sex characteristics, gender
+identity and expression, level of experience, education, socio-economic status,
+nationality, personal appearance, race, religion, or sexual identity
+and orientation.
+
+We pledge to act and interact in ways that contribute to an open, welcoming,
+diverse, inclusive, and healthy community.
+
+## Our Standards
+
+Examples of behavior that contributes to a positive environment for our
+community include:
+
+* Demonstrating empathy and kindness toward other people
+* Being respectful of differing opinions, viewpoints, and experiences
+* Giving and gracefully accepting constructive feedback
+* Accepting responsibility and apologizing to those affected by our mistakes,
+  and learning from the experience
+* Focusing on what is best not just for us as individuals, but for the
+  overall community
+
+Examples of unacceptable behavior include:
+
+* The use of sexualized language or imagery, and sexual attention or
+  advances of any kind
+* Trolling, insulting or derogatory comments, and personal or political attacks
+* Public or private harassment
+* Publishing others' private information, such as a physical or email
+  address, without their explicit permission
+* Other conduct which could reasonably be considered inappropriate in a
+  professional setting
+
+## Enforcement Responsibilities
+
+Community leaders are responsible for clarifying and enforcing our standards of
+acceptable behavior and will take appropriate and fair corrective action in
+response to any behavior that they deem inappropriate, threatening, offensive,
+or harmful.
+
+Community leaders have the right and responsibility to remove, edit, or reject
+comments, commits, code, wiki edits, issues, and other contributions that are
+not aligned to this Code of Conduct, and will communicate reasons for moderation
+decisions when appropriate.
+
+## Scope
+
+This Code of Conduct applies within all community spaces, and also applies when
+an individual is officially representing the community in public spaces.
+Examples of representing our community include using an official e-mail address,
+posting via an official social media account, or acting as an appointed
+representative at an online or offline event.
+
+## Enforcement
+
+Instances of abusive, harassing, or otherwise unacceptable behavior may be
+reported to the community leaders responsible for enforcement at
+coc@vijf.life.
+All complaints will be reviewed and investigated promptly and fairly.
+
+All community leaders are obligated to respect the privacy and security of the
+reporter of any incident.
+
+## Enforcement Guidelines
+
+Community leaders will follow these Community Impact Guidelines in determining
+the consequences for any action they deem in violation of this Code of Conduct:
+
+### 1. Correction
+
+**Community Impact**: Use of inappropriate language or other behavior deemed
+unprofessional or unwelcome in the community.
+
+**Consequence**: A private, written warning from community leaders, providing
+clarity around the nature of the violation and an explanation of why the
+behavior was inappropriate. A public apology may be requested.
+
+### 2. Warning
+
+**Community Impact**: A violation through a single incident or series
+of actions.
+
+**Consequence**: A warning with consequences for continued behavior. No
+interaction with the people involved, including unsolicited interaction with
+those enforcing the Code of Conduct, for a specified period of time. This
+includes avoiding interactions in community spaces as well as external channels
+like social media. Violating these terms may lead to a temporary or
+permanent ban.
+
+### 3. Temporary Ban
+
+**Community Impact**: A serious violation of community standards, including
+sustained inappropriate behavior.
+
+**Consequence**: A temporary ban from any sort of interaction or public
+communication with the community for a specified period of time. No public or
+private interaction with the people involved, including unsolicited interaction
+with those enforcing the Code of Conduct, is allowed during this period.
+Violating these terms may lead to a permanent ban.
+
+### 4. Permanent Ban
+
+**Community Impact**: Demonstrating a pattern of violation of community
+standards, including sustained inappropriate behavior,  harassment of an
+individual, or aggression toward or disparagement of classes of individuals.
+
+**Consequence**: A permanent ban from any sort of public interaction within
+the community.
+
+## Attribution
+
+This Code of Conduct is adapted from the [Contributor Covenant][homepage],
+version 2.0, available at
+https://www.contributor-covenant.org/version/2/0/code_of_conduct.html.
+
+Community Impact Guidelines were inspired by [Mozilla's code of conduct
+enforcement ladder](https://github.com/mozilla/diversity).
+
+[homepage]: https://www.contributor-covenant.org
+
+For answers to common questions about this code of conduct, see the FAQ at
+https://www.contributor-covenant.org/faq. Translations are available at
+https://www.contributor-covenant.org/translations.

Cargo.toml

@@ -1,22 +1,25 @@
 [package]
 name = "empede"
 description = "A web client for MPD"
-version = "0.1.12"
+version = "0.2.3"
 edition = "2021"
 license = "MIT"
 repository = "https://github.com/vijfhoek/empede"
 
 [dependencies]
 anyhow = "1.0.70"
-askama = { version = "0.12.0", default-features = false }
+askama = { version = "0.12.0", default-features = false, features = ["serde-json"] }
-askama_tide = "0.15.0"
+infer = { version = "0.15.0", default-features = false }
-async-std = { version = "1.12.0", features = ["attributes"] }
-infer = { version = "0.13.0", default-features = false }
-mpdrs = "0.1.0"
 percent-encoding = "2.2.0"
 serde = { version = "1.0.160", features = ["derive"] }
 serde_qs = "0.12.0"
-tide = "0.16.0"
+askama_actix = "0.14.0"
-tide-tracing = "0.0.12"
+tokio = { version = "1.35.1", features = ["full"] }
-tracing = { version = "0.1.37", default-features = false, features = ["std"] }
+actix-web = "4.4.0"
-tracing-subscriber = { version = "0.3.17", default-features = false, features = ["std", "fmt"] }
+thiserror = "1.0.51"
+actix-files = "0.6.2"
+actix-web-lab = "0.20.1"
+tokio-stream = "0.1.14"
+futures = "0.3.29"
+async-stream = "0.3.5"
+env_logger = "0.10.1"

Dockerfile

@@ -1,9 +1,9 @@
-FROM rust:1.69-alpine as builder
+FROM rust:alpine AS builder
 WORKDIR /usr/src/empede
 RUN apk add --no-cache build-base
 COPY ./src ./src
 COPY ./templates ./templates
-COPY ./Cargo.* ./
+COPY ./Cargo.toml ./Cargo.lock ./
 RUN cargo install --path .
 
 FROM alpine:latest

README.md

@@ -26,7 +26,7 @@ Empede is configured using environment variables:
 
 ### Windows
 1. Download and extract the [latest release](https://git.sijman.nl/_/empede/releases)
-3. Run `.\empede` in a PowerShell (To specify a host and port, first set the `$env:MPD_HOST` and `$env:MPD_PORT` variables)
+3. Run `.\empede.exe` in a PowerShell (To specify a host and port, first set the `$env:MPD_HOST` and `$env:MPD_PORT` variables)
 3. Go to http://localhost:8080
 
 ### Building from source

src/crate_version.rs

@@ -0,0 +1,6 @@
+#[macro_export]
+macro_rules! crate_version {
+    () => {
+        env!("CARGO_PKG_VERSION")
+    };
+}

src/main.rs

@@ -1,245 +1,43 @@
-use std::path::Path;
+use actix_web::{middleware::Logger, web, App, HttpServer};
-
-use askama::Template;
-use percent_encoding::percent_decode_str;
-use serde::Deserialize;
 
+mod crate_version;
 mod mpd;
+mod routes;
 
-#[derive(Template)]
+#[actix_web::main]
-#[template(path = "index.html")]
+async fn main() -> std::io::Result<()> {
-struct IndexTemplate;
+    let bind = std::env::var("EMPEDE_BIND").unwrap_or("0.0.0.0:8080".into());
+    let (host, port) = bind.split_once(':').unwrap();
 
-#[derive(Deserialize, Default)]
+    env_logger::init_from_env(env_logger::Env::new().default_filter_or("info"));
-#[serde(default)]
-struct IndexQuery {
-    path: String,
-}
 
-async fn get_index(_req: tide::Request<()>) -> tide::Result {
+    HttpServer::new(|| {
-    Ok(askama_tide::into_response(&IndexTemplate))
+        App::new().wrap(Logger::default()).service(
-}
+            web::scope("")
-
+                .service(routes::index::get_index)
-#[derive(Template)]
+                .service(routes::player::get_player)
-#[template(path = "queue.html")]
+                .service(routes::browser::get_browser)
-struct QueueTemplate {
+                .service(routes::art::get_art)
-    queue: Vec<mpd::QueueItem>,
+                .service(routes::sse::idle)
-}
+                .service(routes::queue::get_queue)
-
+                .service(routes::queue::post_queue)
-async fn get_queue(_req: tide::Request<()>) -> tide::Result {
+                .service(routes::queue::delete_queue)
-    let queue = mpd::playlist()?;
+                .service(routes::queue::post_queue_move)
-    let template = QueueTemplate { queue };
+                .service(routes::controls::post_play)
-    Ok(template.into())
+                .service(routes::controls::post_pause)
-}
+                .service(routes::controls::post_previous)
-
+                .service(routes::controls::post_next)
-#[derive(Template)]
+                .service(routes::controls::post_consume)
-#[template(path = "player.html")]
+                .service(routes::controls::post_random)
-struct PlayerTemplate {
+                .service(routes::controls::post_repeat)
-    song: Option<mpdrs::Song>,
+                .service(routes::controls::post_single)
-    name: Option<String>,
+                .service(routes::controls::post_shuffle)
-    state: mpdrs::State,
+                .service(actix_files::Files::new("/static", "./static")),
-    elapsed: f32,
+        )
-    duration: f32,
+    })
-}
+    .bind((host, port.parse().unwrap()))?
-
+    .run()
-async fn get_player(_req: tide::Request<()>) -> tide::Result {
+    .await?;
-    let mut mpd = mpd::connect()?;
-    let song = mpd.currentsong()?;
-    let status = mpd.status()?;
-
-    let elapsed = status.elapsed.map(|d| d.as_secs_f32()).unwrap_or(0.0);
-    let duration = status.duration.map(|d| d.as_secs_f32()).unwrap_or(0.0);
-
-    let mut template = PlayerTemplate {
-        song: song.clone(),
-        name: None,
-        state: status.state,
-        elapsed,
-        duration,
-    };
-
-    if let Some(song) = song {
-        let name = song.title.unwrap_or(song.file);
-        template.name = Some(name);
-    }
-
-    Ok(template.into())
-}
-
-#[derive(Template)]
-#[template(path = "browser.html")]
-struct BrowserTemplate {
-    path: Vec<String>,
-    entries: Vec<mpd::Entry>,
-}
-
-async fn get_browser(req: tide::Request<()>) -> tide::Result {
-    let query: IndexQuery = req.query()?;
-    let path = percent_decode_str(&query.path).decode_utf8_lossy();
-    let entries = mpd::ls(&path)?;
-
-    let template = BrowserTemplate {
-        path: Path::new(&*path)
-            .iter()
-            .map(|s| s.to_string_lossy().to_string())
-            .collect(),
-        entries,
-    };
-
-    Ok(template.into())
-}
-
-#[derive(Deserialize)]
-struct PostQueueQuery {
-    path: String,
-    #[serde(default)]
-    replace: bool,
-    #[serde(default)]
-    next: bool,
-    #[serde(default)]
-    play: bool,
-}
-
-async fn post_queue(req: tide::Request<()>) -> tide::Result {
-    let query: PostQueueQuery = req.query()?;
-    let path = percent_decode_str(&query.path).decode_utf8_lossy();
-    let mut mpd = mpd::Mpd::connect().await?;
-
-    if query.replace {
-        mpd.clear().await?;
-    }
-
-    if query.next {
-        mpd.add_pos(&path, "+0").await?;
-    } else {
-        mpd.add(&path).await?;
-    }
-
-    if query.play {
-        mpd.play().await?;
-    }
-
-    Ok("".into())
-}
-
-#[derive(Deserialize)]
-struct DeleteQueueQuery {
-    #[serde(default)]
-    id: Option<u32>,
-}
-
-async fn delete_queue(req: tide::Request<()>) -> tide::Result {
-    let query: DeleteQueueQuery = req.query()?;
-
-    let mut mpd = mpd::connect()?;
-    if let Some(id) = query.id {
-        mpd.deleteid(id)?;
-    } else {
-        mpd.clear()?;
-    }
-
-    Ok("".into())
-}
-
-async fn post_play(_req: tide::Request<()>) -> tide::Result {
-    mpd::connect()?.play()?;
-    Ok("".into())
-}
-
-async fn post_pause(_req: tide::Request<()>) -> tide::Result {
-    mpd::connect()?.pause(true)?;
-    Ok("".into())
-}
-
-async fn post_previous(_req: tide::Request<()>) -> tide::Result {
-    mpd::connect()?.prev()?;
-    Ok("".into())
-}
-
-async fn post_next(_req: tide::Request<()>) -> tide::Result {
-    mpd::connect()?.next()?;
-    Ok("".into())
-}
-
-#[derive(Deserialize, Debug)]
-struct UpdateQueueBody {
-    from: u32,
-    to: u32,
-}
-
-async fn post_queue_move(mut req: tide::Request<()>) -> tide::Result {
-    let body: UpdateQueueBody = req.body_json().await?;
-    let mut mpd = mpd::connect()?;
-    mpd.move_range(
-        mpdrs::song::Range(Some(body.from), Some(body.from + 1)),
-        body.to as usize,
-    )?;
-    Ok("".into())
-}
-
-async fn get_art(req: tide::Request<()>) -> tide::Result {
-    let query: IndexQuery = req.query()?;
-    let path = percent_decode_str(&query.path).decode_utf8_lossy();
-    let resp = if let Ok(art) = mpd::connect()?.albumart(&path) {
-        let mime = infer::get(&art)
-            .map(|k| k.mime_type())
-            .unwrap_or("application/octet-stream");
-
-        tide::Response::builder(tide::StatusCode::Ok)
-            .body(art)
-            .content_type(mime)
-            .header("cache-control", "max-age=3600")
-    } else {
-        tide::Response::builder(tide::StatusCode::NotFound)
-    };
-    Ok(resp.into())
-}
-
-async fn sse(_req: tide::Request<()>, sender: tide::sse::Sender) -> tide::Result<()> {
-    // Update everything on connect
-    sender.send("playlist", "", None).await?;
-    sender.send("player", "", None).await?;
-
-    let mut mpd = mpd::Mpd::connect().await?;
-
-    loop {
-        let systems = mpd.idle(&["playlist", "player", "database"]).await?;
-        for system in systems {
-            sender.send(&system, "", None).await?;
-        }
-    }
-}
-
-#[async_std::main]
-async fn main() -> tide::Result<()> {
-    tracing_subscriber::fmt()
-        .with_max_level(tracing::Level::WARN)
-        .init();
-
-    let mut app = tide::new();
-    app.with(tide_tracing::TraceMiddleware::new());
-
-    app.at("/").get(get_index);
-    app.at("/queue").get(get_queue);
-    app.at("/player").get(get_player);
-    app.at("/art").get(get_art);
-    app.at("/browser").get(get_browser);
-
-    app.at("/sse").get(tide::sse::endpoint(sse));
-
-    app.at("/queue").post(post_queue);
-    app.at("/queue").delete(delete_queue);
-    app.at("/queue/move").post(post_queue_move);
-
-    app.at("/play").post(post_play);
-    app.at("/pause").post(post_pause);
-    app.at("/previous").post(post_previous);
-    app.at("/next").post(post_next);
-
-    app.at("/static").serve_dir("static/")?;
-
-    let bind = std::env::var("EMPEDE_BIND").unwrap_or("0.0.0.0:8080".to_string());
-    app.listen(bind).await?;
 
     Ok(())
 }

src/mpd.rs

@@ -1,9 +1,11 @@
+use std::collections::HashMap;
+
 use anyhow::anyhow;
-use async_std::{
+use tokio::{
-    io::{prelude::BufReadExt, BufReader, WriteExt},
+    io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt, BufStream},
     net::TcpStream,
+    sync::{Mutex, MutexGuard, OnceCell},
 };
-use mpdrs::lsinfo::LsInfoResponse;
 
 pub fn host() -> String {
     let host = std::env::var("MPD_HOST").unwrap_or("localhost".to_string());
@@ -11,79 +13,19 @@ pub fn host() -> String {
     format!("{host}:{port}")
 }
 
-pub fn connect() -> Result<mpdrs::Client, mpdrs::error::Error> {
-    let mut client = mpdrs::Client::connect(host())?;
-
-    let password = std::env::var("MPD_PASSWORD").unwrap_or(String::new());
-    if !password.is_empty() {
-        client.login(&password)?;
-    }
-
-    Ok(client)
-}
-
-pub fn ls(path: &str) -> anyhow::Result<Vec<Entry>> {
-    let info = connect()?.lsinfo(path)?;
-
-    fn filename(path: &str) -> String {
-        std::path::Path::new(path)
-            .file_name()
-            .map(|x| x.to_string_lossy().to_string())
-            .unwrap_or("n/a".to_string())
-    }
-
-    Ok(info
-        .iter()
-        .map(|e| match e {
-            LsInfoResponse::Song(song) => Entry::Song {
-                name: song.title.as_ref().unwrap_or(&filename(&song.file)).clone(),
-                artist: song.artist.clone().unwrap_or(String::new()),
-                path: song.file.clone(),
-            },
-
-            LsInfoResponse::Directory { path, .. } => Entry::Directory {
-                name: filename(path),
-                path: path.to_string(),
-            },
-
-            LsInfoResponse::Playlist { path, .. } => Entry::Playlist {
-                name: filename(path),
-                path: path.to_string(),
-            },
-        })
-        .collect())
-}
-
 pub struct QueueItem {
     pub id: u32,
+    pub position: i32,
     pub file: String,
     pub title: String,
     pub artist: Option<String>,
     pub playing: bool,
 }
 
-pub fn playlist() -> anyhow::Result<Vec<QueueItem>> {
+#[derive(Debug)]
-    let mut client = connect()?;
-
-    let current = client.status()?.song;
-
-    let queue = client
-        .queue()?
-        .into_iter()
-        .map(|song| QueueItem {
-            id: song.place.unwrap().id,
-            file: song.file.clone(),
-            title: song.title.as_ref().unwrap_or(&song.file).clone(),
-            artist: song.artist.clone(),
-            playing: current == song.place,
-        })
-        .collect();
-
-    Ok(queue)
-}
-
 pub enum Entry {
     Song {
+        track: Option<i32>,
         name: String,
         artist: String,
         path: String,
@@ -98,9 +40,76 @@ pub enum Entry {
     },
 }
 
+#[derive(Debug)]
 pub struct Mpd {
-    stream: TcpStream,
+    bufstream: Option<BufStream<TcpStream>>,
-    reader: BufReader<TcpStream>,
+}
+
+pub static INSTANCE: OnceCell<Mutex<Mpd>> = OnceCell::const_new();
+
+pub async fn get_instance() -> MutexGuard<'static, Mpd> {
+    INSTANCE
+        .get_or_init(|| async {
+            let mut mpd = Mpd::new();
+            mpd.connect().await.unwrap();
+            Mutex::from(mpd)
+        })
+        .await
+        .lock()
+        .await
+}
+
+pub async fn command(command: &str) -> anyhow::Result<CommandResult> {
+    get_instance().await.command(command).await
+}
+
+pub struct CommandResult {
+    properties: Vec<(String, String)>,
+    binary: Option<Vec<u8>>,
+}
+
+impl CommandResult {
+    pub fn new(properties: Vec<(String, String)>) -> Self {
+        Self {
+            properties,
+            binary: None,
+        }
+    }
+
+    pub fn new_binary(properties: Vec<(String, String)>, binary: Vec<u8>) -> Self {
+        Self {
+            properties,
+            binary: Some(binary),
+        }
+    }
+
+    pub fn into_hashmap(self) -> HashMap<String, String> {
+        self.properties.into_iter().collect()
+    }
+
+    pub fn into_hashmaps(self, split_at: &[&str]) -> Vec<HashMap<String, String>> {
+        let mut output = Vec::new();
+        let mut current = None;
+
+        for (key, value) in self.properties {
+            if split_at.contains(&key.as_str()) {
+                if let Some(current) = current {
+                    output.push(current);
+                }
+                current = Some(HashMap::new());
+            }
+
+            if let Some(current) = current.as_mut() {
+                current.insert(key, value);
+            }
+        }
+
+        if let Some(current) = current {
+            output.push(current);
+        }
+
+        output
+    }
 }
 
 impl Mpd {
@@ -108,87 +117,255 @@ impl Mpd {
         s.replace('\"', "\\\"").replace('\'', "\\'")
     }
 
-    pub async fn connect() -> anyhow::Result<Self> {
+    pub fn new() -> Self {
-        let mut stream = TcpStream::connect(host()).await?;
+        Self { bufstream: None }
-        let mut reader = BufReader::new(stream.clone());
+    }
+
+    pub async fn connect(&mut self) -> anyhow::Result<()> {
+        let stream = TcpStream::connect(host()).await?;
+        let mut bufstream = BufStream::new(stream);
 
         // skip OK MPD line
         // TODO check if it is indeed OK
         let mut buffer = String::new();
-        reader.read_line(&mut buffer).await?;
+        bufstream.read_line(&mut buffer).await?;
 
-        let password = std::env::var("MPD_PASSWORD").unwrap_or(String::new());
+        let password = std::env::var("MPD_PASSWORD").unwrap_or_default();
         if !password.is_empty() {
             let password = Self::escape_str(&password);
-            let command = format!("password \"{password}\"\n");
+            bufstream
-            stream.write_all(command.as_bytes()).await?;
+                .write_all(format!("password \"{password}\"\n").as_bytes())
-
+                .await?;
-            buffer.clear();
+            bufstream.flush().await?;
-            reader.read_line(&mut buffer).await?;
+            bufstream.read_line(&mut buffer).await?;
         }
 
-        Ok(Self { stream, reader })
+        bufstream
+            .write_all("binarylimit 1048576\n".as_bytes())
+            .await?;
+        bufstream.flush().await?;
+        bufstream.read_line(&mut buffer).await?;
+
+        self.bufstream = Some(bufstream);
+
+        Ok(())
     }
 
-    pub async fn command(&mut self, command: &str) -> anyhow::Result<()> {
+    async fn read_binary_data(&mut self, size: usize) -> anyhow::Result<Vec<u8>> {
-        self.stream
+        let mut binary = vec![0u8; size];
-            .write_all(format!("{command}\n").as_bytes())
+        self.bufstream
+            .as_mut()
+            .unwrap()
+            .read_exact(&mut binary)
             .await?;
 
         let mut buffer = String::new();
+
+        // Skip the newline after the binary data
+        self.bufstream
+            .as_mut()
+            .unwrap()
+            .read_line(&mut buffer)
+            .await?;
+
+        // Skip the "OK" after the binary data
+        // TODO Check if actually OK
+        self.bufstream
+            .as_mut()
+            .unwrap()
+            .read_line(&mut buffer)
+            .await?;
+
+        Ok(binary)
+    }
+
+    pub async fn command(&mut self, command: &str) -> anyhow::Result<CommandResult> {
+        let mut properties = Vec::new();
+
+        'retry: loop {
+            self.bufstream
+                .as_mut()
+                .unwrap()
+                .write_all(format!("{command}\n").as_bytes())
+                .await?;
+            self.bufstream.as_mut().unwrap().flush().await?;
+
+            let mut buffer = String::new();
+            break 'retry (loop {
+                buffer.clear();
+                self.bufstream
+                    .as_mut()
+                    .unwrap()
+                    .read_line(&mut buffer)
+                    .await?;
+
+                if let Some((key, value)) = buffer.split_once(": ") {
+                    let value = value.trim_end();
+                    properties.push((key.to_string(), value.to_string()));
+
+                    if key == "binary" {
+                        let binary = self.read_binary_data(value.parse()?).await?;
+                        break Ok(CommandResult::new_binary(properties, binary));
+                    }
+                } else if buffer.starts_with("OK") {
+                    break Ok(CommandResult::new(properties));
+                } else if buffer.starts_with("ACK") {
+                    break Err(anyhow!(buffer));
+                } else {
+                    println!("Unexpected MPD response '{buffer}'");
+                    self.connect().await.unwrap();
+                    continue 'retry;
+                }
+            });
+        }
+    }
+
+    pub async fn command_binary(&mut self, command: &str) -> anyhow::Result<CommandResult> {
+        let mut buffer = Vec::new();
+
         loop {
-            buffer.clear();
+            let command = format!("{} {}", command, buffer.len());
-            self.reader.read_line(&mut buffer).await?;
+            let result = self.command(&command).await?;
 
-            let split: Vec<_> = buffer.trim_end().split_ascii_whitespace().collect();
+            if let Some(mut binary) = result.binary {
-
+                if !binary.is_empty() {
-            if split[0] == "OK" {
+                    buffer.append(&mut binary);
-                break Ok(());
+                } else {
-            } else if split[0] == "ACK" {
+                    return Ok(CommandResult::new_binary(result.properties, buffer));
-                break Err(anyhow!(buffer));
+                }
+            } else {
+                return Ok(CommandResult::new(result.properties));
             }
         }
     }
 
     pub async fn clear(&mut self) -> anyhow::Result<()> {
-        self.command("clear").await
+        self.command("clear").await?;
+        Ok(())
     }
 
     pub async fn add(&mut self, path: &str) -> anyhow::Result<()> {
         let path = Self::escape_str(path);
-        self.command(&format!("add \"{path}\"")).await
+        self.command(&format!("add \"{path}\"")).await?;
+        Ok(())
     }
 
-    pub async fn add_pos(&mut self, path: &str, pos: &str) -> anyhow::Result<()> {
+    pub async fn add_position(&mut self, path: &str, position: &str) -> anyhow::Result<()> {
         let path = Self::escape_str(path);
-        let pos = Self::escape_str(pos);
+        let position = Self::escape_str(position);
-        self.command(&format!("add \"{path}\" \"{pos}\"")).await
+        self.command(&format!(r#"add "{path}" "{position}""#))
+            .await?;
+        Ok(())
     }
 
-    pub async fn play(&mut self) -> anyhow::Result<()> {
+    pub async fn play(&mut self, position: Option<&str>) -> anyhow::Result<()> {
-        self.command("play").await
+        let command = match position {
+            Some(position) => format!(r#"play "{position}""#),
+            None => "play".into(),
+        };
+        self.command(&command).await?;
+        Ok(())
     }
 
     pub async fn idle(&mut self, systems: &[&str]) -> anyhow::Result<Vec<String>> {
-        let mut buffer = String::new();
-
         let systems = systems.join(" ");
-        let command = format!("idle {systems}\n");
+        let result = self.command(&format!("idle {systems}")).await?;
-        self.stream.write_all(command.as_bytes()).await?;
+        let changed = result
+            .properties
+            .iter()
+            .filter(|(key, _)| key == "changed")
+            .map(|(_, value)| value.clone())
+            .collect();
+        Ok(changed)
+    }
 
-        let mut updated = vec![];
+    pub async fn albumart(&mut self, path: &str) -> anyhow::Result<Vec<u8>> {
-        loop {
+        let path = Self::escape_str(path);
-            buffer.clear();
+        let result = self
-            self.reader.read_line(&mut buffer).await?;
+            .command_binary(&format!(r#"albumart "{path}""#))
-            if buffer == "OK\n" {
+            .await?;
-                break Ok(updated);
-            }
 
-            let (_, changed) = buffer
+        match result.binary {
-                .trim_end()
+            Some(binary) => Ok(binary),
-                .split_once(": ")
+            None => Err(anyhow!("no album art")),
-                .ok_or(anyhow!("unexpected response from MPD"))?;
-            updated.push(changed.to_string());
         }
     }
+
+    pub async fn readpicture(&mut self, path: &str) -> anyhow::Result<Vec<u8>> {
+        let path = Self::escape_str(path);
+        let result = self
+            .command_binary(&format!(r#"readpicture "{path}""#))
+            .await?;
+
+        match result.binary {
+            Some(binary) => Ok(binary),
+            None => Err(anyhow!("no album art")),
+        }
+    }
+
+    #[allow(clippy::manual_map)]
+    pub async fn ls(&mut self, path: &str) -> anyhow::Result<Vec<Entry>> {
+        fn get_filename(path: &str) -> String {
+            std::path::Path::new(path)
+                .file_name()
+                .map(|x| x.to_string_lossy().to_string())
+                .unwrap_or("n/a".to_string())
+        }
+
+        let path = Self::escape_str(path);
+        let result = self
+            .command(&format!(r#"lsinfo "{path}""#))
+            .await?
+            .into_hashmaps(&["file", "directory", "playlist"]);
+
+        let files = result
+            .iter()
+            .flat_map(|prop| {
+                if let Some(file) = prop.get("file") {
+                    Some(Entry::Song {
+                        track: prop.get("Track").and_then(|track| track.parse().ok()),
+                        name: prop.get("Title").unwrap_or(&get_filename(file)).clone(),
+                        artist: prop.get("Artist").unwrap_or(&String::new()).clone(),
+                        path: file.to_string(),
+                    })
+                } else if let Some(file) = prop.get("directory") {
+                    Some(Entry::Directory {
+                        name: get_filename(file),
+                        path: file.to_string(),
+                    })
+                } else if let Some(file) = prop.get("playlist") {
+                    Some(Entry::Playlist {
+                        name: get_filename(file),
+                        path: file.to_string(),
+                    })
+                } else {
+                    None
+                }
+            })
+            .collect();
+
+        Ok(files)
+    }
+
+    pub async fn playlist(&mut self) -> anyhow::Result<Vec<QueueItem>> {
+        let status = self.command("status").await?.into_hashmap();
+        let current_songid = status.get("songid");
+
+        let playlistinfo = self.command("playlistinfo").await?;
+        let queue = playlistinfo.into_hashmaps(&["file"]);
+
+        let queue = queue
+            .iter()
+            .map(|song| QueueItem {
+                id: song["Id"].parse().unwrap(),
+                position: song["Pos"].parse().unwrap(),
+                file: song["file"].clone(),
+                title: song.get("Title").unwrap_or(&song["file"]).clone(),
+                artist: song.get("Artist").cloned(),
+                playing: current_songid == song.get("Id"),
+            })
+            .collect();
+
+        Ok(queue)
+    }
 }

src/routes/art.rs

@@ -0,0 +1,42 @@
+use crate::mpd;
+use actix_web::{
+    get,
+    http::header::{self, CacheDirective},
+    web, HttpResponse, Responder,
+};
+use percent_encoding::percent_decode_str;
+use serde::Deserialize;
+
+#[derive(Deserialize, Default)]
+#[serde(default)]
+struct ArtQuery {
+    path: String,
+}
+
+#[get("/art")]
+pub async fn get_art(query: web::Query<ArtQuery>) -> impl Responder {
+    let path = percent_decode_str(&query.path).decode_utf8_lossy();
+    let mut mpd = mpd::get_instance().await;
+
+    if let Ok(art) = mpd.albumart(&path).await {
+        let mime = infer::get(&art)
+            .map(|k| k.mime_type())
+            .unwrap_or("application/octet-stream");
+
+        HttpResponse::Ok()
+            .content_type(mime)
+            .append_header(header::CacheControl(vec![CacheDirective::MaxAge(3600)]))
+            .body(art)
+    } else if let Ok(art) = mpd.readpicture(&path).await {
+        let mime = infer::get(&art)
+            .map(|k| k.mime_type())
+            .unwrap_or("application/octet-stream");
+
+        HttpResponse::Ok()
+            .content_type(mime)
+            .append_header(header::CacheControl(vec![CacheDirective::MaxAge(3600)]))
+            .body(art)
+    } else {
+        HttpResponse::NotFound().finish()
+    }
+}

src/routes/browser.rs

@@ -0,0 +1,34 @@
+use crate::mpd;
+use actix_web::{get, web, Responder};
+use askama::Template;
+use percent_encoding::percent_decode_str;
+use serde::Deserialize;
+use std::path::Path;
+
+#[derive(Template)]
+#[template(path = "browser.html")]
+struct BrowserTemplate {
+    path: Vec<String>,
+    entries: Vec<mpd::Entry>,
+}
+
+#[derive(Deserialize, Default)]
+#[serde(default)]
+struct BrowserQuery {
+    path: String,
+}
+
+#[get("/browser")]
+pub async fn get_browser(query: web::Query<BrowserQuery>) -> impl Responder {
+    let path = percent_decode_str(&query.path).decode_utf8_lossy();
+    let mut mpd = mpd::get_instance().await;
+    let entries = mpd.ls(&path).await.unwrap();
+
+    BrowserTemplate {
+        path: Path::new(&*path)
+            .iter()
+            .map(|s| s.to_string_lossy().to_string())
+            .collect(),
+        entries,
+    }
+}

src/routes/controls.rs

@@ -0,0 +1,76 @@
+use actix_web::{post, web, HttpResponse, Responder};
+use serde::Deserialize;
+
+use crate::mpd;
+
+async fn toggle_setting(setting: &str) -> anyhow::Result<()> {
+    let mut mpd = mpd::get_instance().await;
+
+    let status = mpd.command("status").await?.into_hashmap();
+    let value = status[setting] == "1";
+
+    mpd.command(&format!("{} {}", setting, if value { 0 } else { 1 }))
+        .await?;
+    Ok(())
+}
+
+#[derive(Deserialize)]
+struct PostPlayQuery {
+    #[serde(default)]
+    position: Option<String>,
+}
+
+#[post("/play")]
+pub async fn post_play(query: web::Query<PostPlayQuery>) -> impl Responder {
+    let mut mpd = mpd::get_instance().await;
+    mpd.play(query.position.as_deref()).await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/pause")]
+pub async fn post_pause() -> impl Responder {
+    mpd::command("pause 1").await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/previous")]
+pub async fn post_previous() -> impl Responder {
+    mpd::command("previous").await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/next")]
+pub async fn post_next() -> impl Responder {
+    mpd::command("next").await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/consume")]
+pub async fn post_consume() -> impl Responder {
+    toggle_setting("consume").await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/random")]
+pub async fn post_random() -> impl Responder {
+    toggle_setting("random").await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/repeat")]
+pub async fn post_repeat() -> impl Responder {
+    toggle_setting("repeat").await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/shuffle")]
+pub async fn post_shuffle() -> impl Responder {
+    mpd::command("shuffle").await.unwrap();
+    HttpResponse::NoContent()
+}
+
+#[post("/single")]
+pub async fn post_single() -> impl Responder {
+    toggle_setting("single").await.unwrap();
+    HttpResponse::NoContent()
+}

src/routes/index.rs

@@ -0,0 +1,19 @@
+use crate::crate_version;
+use actix_web::{get, Responder};
+use askama::Template;
+use serde::Deserialize;
+
+#[derive(Template)]
+#[template(path = "index.html")]
+struct IndexTemplate;
+
+#[derive(Deserialize, Default)]
+#[serde(default)]
+struct IndexQuery {
+    path: String,
+}
+
+#[get("/")]
+pub async fn get_index() -> impl Responder {
+    IndexTemplate
+}

src/routes/mod.rs

@@ -0,0 +1,7 @@
+pub mod art;
+pub mod browser;
+pub mod controls;
+pub mod index;
+pub mod player;
+pub mod queue;
+pub mod sse;

src/routes/player.rs

@@ -0,0 +1,57 @@
+use crate::mpd;
+use actix_web::{get, Responder};
+use askama::Template;
+use std::collections::HashMap;
+
+#[derive(Template)]
+#[template(path = "player.html")]
+struct PlayerTemplate {
+    song: Option<HashMap<String, String>>,
+    name: Option<String>,
+    state: String,
+    consume: bool,
+    random: bool,
+    repeat: bool,
+    single: bool,
+    elapsed: f32,
+    duration: f32,
+}
+
+#[get("/player")]
+pub async fn get_player() -> impl Responder {
+    let mut mpd = mpd::get_instance().await;
+    let song = mpd.command("currentsong").await.unwrap().into_hashmap();
+    let status = mpd.command("status").await.unwrap().into_hashmap();
+
+    let elapsed = status
+        .get("elapsed")
+        .and_then(|e| e.parse().ok())
+        .unwrap_or(0.0);
+    let duration = status
+        .get("duration")
+        .and_then(|e| e.parse().ok())
+        .unwrap_or(1.0);
+
+    let mut template = PlayerTemplate {
+        song: if song.is_empty() {
+            None
+        } else {
+            Some(song.clone())
+        },
+        name: None,
+        state: status["state"].clone(),
+        consume: status["consume"] == "1",
+        random: status["random"] == "1",
+        repeat: status["repeat"] == "1",
+        single: status["single"] == "1",
+        elapsed,
+        duration,
+    };
+
+    if !song.is_empty() {
+        let name = song.get("Title").unwrap_or(&song["file"]).to_string();
+        template.name = Some(name);
+    }
+
+    template
+}

src/routes/queue.rs

@@ -0,0 +1,84 @@
+use crate::mpd;
+use actix_web::{delete, get, post, web, HttpResponse, Responder};
+use askama::Template;
+use percent_encoding::percent_decode_str;
+use serde::Deserialize;
+
+#[derive(Template)]
+#[template(path = "queue.html")]
+struct QueueTemplate {
+    queue: Vec<mpd::QueueItem>,
+}
+
+#[get("/queue")]
+pub async fn get_queue() -> impl Responder {
+    let mut mpd = mpd::get_instance().await;
+    let queue = mpd.playlist().await.unwrap();
+    QueueTemplate { queue }
+}
+
+#[derive(Deserialize)]
+struct PostQueueQuery {
+    path: String,
+    #[serde(default)]
+    replace: bool,
+    #[serde(default)]
+    next: bool,
+    #[serde(default)]
+    play: bool,
+}
+
+#[post("/queue")]
+pub async fn post_queue(query: web::Query<PostQueueQuery>) -> impl Responder {
+    let path = percent_decode_str(&query.path).decode_utf8_lossy();
+    let mut mpd = mpd::get_instance().await;
+
+    if query.replace {
+        mpd.clear().await.unwrap();
+    }
+
+    if query.next {
+        mpd.add_position(&path, "+0").await.unwrap();
+    } else {
+        mpd.add(&path).await.unwrap();
+    }
+
+    if query.play {
+        mpd.play(None).await.unwrap();
+    }
+
+    HttpResponse::NoContent()
+}
+
+#[derive(Deserialize)]
+struct DeleteQueueQuery {
+    #[serde(default)]
+    id: Option<u32>,
+}
+
+#[delete("/queue")]
+pub async fn delete_queue(query: web::Query<DeleteQueueQuery>) -> impl Responder {
+    let mut mpd = mpd::get_instance().await;
+    if let Some(id) = query.id {
+        mpd.command(&format!("deleteid {id}")).await.unwrap();
+    } else {
+        mpd.command("clear").await.unwrap();
+    }
+
+    HttpResponse::NoContent()
+}
+
+#[derive(Deserialize, Debug)]
+struct UpdateQueueBody {
+    from: u32,
+    to: u32,
+}
+
+#[post("/queue/move")]
+pub async fn post_queue_move(body: web::Json<UpdateQueueBody>) -> impl Responder {
+    let mut mpd = mpd::get_instance().await;
+    mpd.command(&format!("move {} {}", body.from, body.to))
+        .await
+        .unwrap();
+    HttpResponse::NoContent()
+}

src/routes/sse.rs

@@ -0,0 +1,33 @@
+use std::time::Duration;
+
+use actix_web::{get, Responder};
+use actix_web_lab::sse;
+
+use crate::mpd::Mpd;
+
+#[get("/idle")]
+pub async fn idle() -> impl Responder {
+    let mut mpd = Mpd::new();
+    mpd.connect().await.unwrap();
+
+    const SYSTEMS: &[&str] = &["playlist", "player", "database", "options"];
+
+    let (tx, rx) = tokio::sync::mpsc::channel(10);
+    for system in SYSTEMS {
+        _ = tx
+            .send(sse::Data::new("").event(system.to_owned()).into())
+            .await;
+    }
+
+    actix_web::rt::spawn(async move {
+        loop {
+            let systems = mpd.idle(SYSTEMS).await.unwrap();
+
+            for system in systems {
+                _ = tx.send(sse::Data::new("").event(system).into()).await;
+            }
+        }
+    });
+
+    sse::Sse::from_infallible_receiver(rx).with_retry_duration(Duration::from_secs(10))
+}

static/style.css

@@ -28,16 +28,26 @@ button {
   background-color: transparent;
   border: none;
   color: inherit;
-  padding: 0;
   font-weight: bold;
   display: flex;
   line-height: 24px;
   cursor: pointer;
+  padding: 0.25rem 0.5rem;
 }
+
+button:hover {
+  background-color: rgba(255, 255, 255, 0.1);
+  border-radius: 0.25rem;
+}
+
 button .material-symbols-outlined {
   margin-right: 0.25rem;
 }
 
+.active {
+  color: #99f;
+}
+
 .browser {
   flex: 1;
   display: flex;
@@ -86,6 +96,7 @@ ul {
 .queue {
   margin-top: 0.5rem;
   overflow: auto;
+  scroll-behavior: smooth;
 }
 
 .queue ul li {
@@ -93,6 +104,10 @@ ul {
   border-radius: .25rem;
   display: flex;
   align-items: center;
+  cursor: grab;
+}
+.queue ul li:hover {
+  background-color: #223;
 }
 
 .queue ul li.playing {
@@ -124,26 +139,35 @@ ul {
   display: none;
 }
 
+.queue .remove button {
+  padding: 0.25rem;
+}
+
 .browser .header {
   display: flex;
   flex-flow: column;
   background-color: #334;
   border-radius: 0.25rem;
-  padding: 0.75rem 1rem;
+  padding: 0.75rem 0.5rem;
   margin: 16px 16px 0;
 }
 
 .browser .buttons {
   display: flex;
   flex-flow: row;
-  margin-top: 0.75rem;
+  margin-top: 0.25rem;
 }
 .browser .buttons button {
-  margin-right: 1.0rem;
+  margin-right: 0.5rem;
 }
 
-ul.breadcrumb {  position: relative;
+ul.breadcrumb {
-  rast: more) {
+  display: flex;
+  flex-wrap: wrap;
+  list-style: none;
+  margin-left: 0.5rem;
+}
+@media (prefers-contrast: more) {
   ul.breadcrumb {
     background-color: black;
     border: 2px solid white;
@@ -203,6 +227,10 @@ ul.dir li .material-symbols-outlined {
 
 .albumart img {
   visibility: hidden;
+  border-radius: 0.25rem;
+  width: 100%;
+  height: 100%;
+  object-fit: cover;
 }
 
 .queue .albumart {
@@ -214,11 +242,8 @@ ul.dir li .material-symbols-outlined {
   margin-right: 0.75rem;
 }
 
-.albumart img {
+.track {
-  border-radius: 0.25rem;
+  margin-right: 0.75rem;
-  width: 100%;
-  height: 100%;
-  object-fit: cover;
 }
 
 .player {
@@ -234,7 +259,7 @@ ul.dir li .material-symbols-outlined {
   flex-flow: column;
   background-color: #334;
   border-radius: 0.25rem;
-  height: 10.0rem;
+  height: 13.0rem;
 }
 @media (prefers-contrast: more) {
   .player .nowplaying {
@@ -254,15 +279,23 @@ ul.dir li .material-symbols-outlined {
   bottom: 0;
 }
 
-.player .controls {
+.player .controls,
+.player .settings {
   display: flex;
   justify-content: space-around;
-  padding: 0 0.5rem 1.0rem;
+  padding: 0 0.5rem 0.25rem;
 }
 
-.player .control {
+.player .settings {
+  margin-bottom: 0.5rem;
+}
+
+.player .controls button {
   font-size: 40px;
 }
+.player .settings button {
+  font-size: 25px;
+}
 
 .player .current {
   display: flex;

static/vendor/htmx-sse.js

@@ -5,7 +5,7 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 
 */
 
-(function(){
+(function() {
 
 	/** @type {import("../htmx").HtmxInternalApi} */
 	var api;
@@ -39,17 +39,19 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 
 			switch (name) {
 
-			// Try to remove remove an EventSource when elements are removed
+				case "htmx:beforeCleanupElement":
-			case "htmx:beforeCleanupElement":
+					var internalData = api.getInternalData(evt.target)
-				var internalData = api.getInternalData(evt.target)
+					// Try to remove remove an EventSource when elements are removed
-				if (internalData.sseEventSource) {
+					if (internalData.sseEventSource) {
-					internalData.sseEventSource.close();
+						internalData.sseEventSource.close();
-				}
+					}
-				return;
 
-			// Try to create EventSources when elements are processed
+					return;
-			case "htmx:afterProcessNode":
+
-				createEventSourceOnElement(evt.target);
+				// Try to create EventSources when elements are processed
+				case "htmx:afterProcessNode":
+					ensureEventSourceOnElement(evt.target);
+					registerSSE(evt.target);
 			}
 		}
 	});
@@ -66,8 +68,8 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 	 * @param {string} url 
 	 * @returns EventSource
 	 */
-	 function createEventSource(url) {
+	function createEventSource(url) {
-		return new EventSource(url, {withCredentials:true});
+		return new EventSource(url, { withCredentials: true });
 	}
 
 	function splitOnWhitespace(trigger) {
@@ -90,7 +92,7 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 	function getLegacySSESwaps(elt) {
 		var legacySSEValue = api.getAttributeValue(elt, "hx-sse");
 		var returnArr = [];
-		if (legacySSEValue) {
+		if (legacySSEValue != null) {
 			var values = splitOnWhitespace(legacySSEValue);
 			for (var i = 0; i < values.length; i++) {
 				var value = values[i].split(/:(.+)/);
@@ -103,63 +105,24 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 	}
 
 	/**
-	 * createEventSourceOnElement creates a new EventSource connection on the provided element.
+	 * registerSSE looks for attributes that can contain sse events, right 
-	 * If a usable EventSource already exists, then it is returned.  If not, then a new EventSource
+	 * now hx-trigger and sse-swap and adds listeners based on these attributes too
-	 * is created and stored in the element's internalData.
+	 * the closest event source
+	 *
 	 * @param {HTMLElement} elt
-	 * @param {number} retryCount
-	 * @returns {EventSource | null}
 	 */
-	function createEventSourceOnElement(elt, retryCount) {
+	function registerSSE(elt) {
-
+		// Find closest existing event source
-		if (elt == null) {
+		var sourceElement = api.getClosestMatch(elt, hasEventSource);
-			return null;
+		if (sourceElement == null) {
+			// api.triggerErrorEvent(elt, "htmx:noSSESourceError")
+			return null; // no eventsource in parentage, orphaned element
 		}
 
-		var internalData = api.getInternalData(elt);
+		// Set internalData and source
+		var internalData = api.getInternalData(sourceElement);
+		var source = internalData.sseEventSource;
 
-		// get URL from element's attribute
-		var sseURL = api.getAttributeValue(elt, "sse-connect");
-
-
-		if (sseURL == undefined) {
-			var legacyURL = getLegacySSEURL(elt)
-			if (legacyURL) {
-				sseURL = legacyURL;
-			} else {
-				return null;
-			}
-		}
-
-		// Connect to the EventSource
-		var source = htmx.createEventSource(sseURL);
-		internalData.sseEventSource = source;
-
-		// Create event handlers
-		source.onerror = function (err) {
-
-			// Log an error event
-			api.triggerErrorEvent(elt, "htmx:sseError", {error:err, source:source});
-
-			// If parent no longer exists in the document, then clean up this EventSource
-			if (maybeCloseSSESource(elt)) {
-				return;
-			}
-
-			// Otherwise, try to reconnect the EventSource
-			if (source.readyState === EventSource.CLOSED) {
-				retryCount = retryCount || 0;
-				var timeout = Math.random() * (2 ^ retryCount) * 500;
-				window.setTimeout(function() {
-					createEventSourceOnElement(elt, Math.min(7, retryCount+1));
-				}, timeout);
-			}			
-		};
-
-		source.onopen = function (evt) {
-			api.triggerEvent(elt, "htmx::sseOpen", {source: source});
-		}
-		
 		// Add message handlers for every `sse-swap` attribute
 		queryAttributeOnThisOrChildren(elt, "sse-swap").forEach(function(child) {
 
@@ -170,23 +133,27 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 				var sseEventNames = getLegacySSESwaps(child);
 			}
 
-			for (var i = 0 ; i < sseEventNames.length ; i++) {
+			for (var i = 0; i < sseEventNames.length; i++) {
 				var sseEventName = sseEventNames[i].trim();
 				var listener = function(event) {
 
-					// If the parent is missing then close SSE and remove listener
+					// If the source is missing then close SSE
-					if (maybeCloseSSESource(elt)) {
+					if (maybeCloseSSESource(sourceElement)) {
-						source.removeEventListener(sseEventName, listener);
 						return;
 					}
 
+					// If the body no longer contains the element, remove the listener
+					if (!api.bodyContains(child)) {
+						source.removeEventListener(sseEventName, listener);
+					}
+
 					// swap the response into the DOM and trigger a notification
 					swap(child, event.data);
 					api.triggerEvent(elt, "htmx:sseMessage", event);
 				};
 
 				// Register the new listener
-				api.getInternalData(elt).sseEventListener = listener;
+				api.getInternalData(child).sseEventListener = listener;
 				source.addEventListener(sseEventName, listener);
 			}
 		});
@@ -203,24 +170,86 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 			if (sseEventName.slice(0, 4) != "sse:") {
 				return;
 			}
+			
+			// remove the sse: prefix from here on out
+			sseEventName = sseEventName.substr(4);
 
-			var listener = function(event) {
+			var listener = function() {
-
+				if (maybeCloseSSESource(sourceElement)) {
-				// If parent is missing, then close SSE and remove listener
+					return
-				if (maybeCloseSSESource(elt)) {
-					source.removeEventListener(sseEventName, listener);
-					return;
 				}
 
-				// Trigger events to be handled by the rest of htmx
+				if (!api.bodyContains(child)) {
-				htmx.trigger(child, sseEventName, event);
+					source.removeEventListener(sseEventName, listener);
-				htmx.trigger(child, "htmx:sseMessage", event);
+				}
+			}
+		});
+	}
+
+	/**
+	 * ensureEventSourceOnElement creates a new EventSource connection on the provided element.
+	 * If a usable EventSource already exists, then it is returned.  If not, then a new EventSource
+	 * is created and stored in the element's internalData.
+	 * @param {HTMLElement} elt
+	 * @param {number} retryCount
+	 * @returns {EventSource | null}
+	 */
+	function ensureEventSourceOnElement(elt, retryCount) {
+
+		if (elt == null) {
+			return null;
+		}
+
+		// handle extension source creation attribute
+		queryAttributeOnThisOrChildren(elt, "sse-connect").forEach(function(child) {
+			var sseURL = api.getAttributeValue(child, "sse-connect");
+			if (sseURL == null) {
+				return;
 			}
 
-			// Register the new listener
+			ensureEventSource(child, sseURL, retryCount);
-			api.getInternalData(elt).sseEventListener = listener;
-			source.addEventListener(sseEventName.slice(4), listener);
 		});
+
+		// handle legacy sse, remove for HTMX2
+		queryAttributeOnThisOrChildren(elt, "hx-sse").forEach(function(child) {
+			var sseURL = getLegacySSEURL(child);
+			if (sseURL == null) {
+				return;
+			}
+
+			ensureEventSource(child, sseURL, retryCount);
+		});
+
+	}
+
+	function ensureEventSource(elt, url, retryCount) {
+		var source = htmx.createEventSource(url);
+
+		source.onerror = function(err) {
+
+			// Log an error event
+			api.triggerErrorEvent(elt, "htmx:sseError", { error: err, source: source });
+
+			// If parent no longer exists in the document, then clean up this EventSource
+			if (maybeCloseSSESource(elt)) {
+				return;
+			}
+
+			// Otherwise, try to reconnect the EventSource
+			if (source.readyState === EventSource.CLOSED) {
+				retryCount = retryCount || 0;
+				var timeout = Math.random() * (2 ^ retryCount) * 500;
+				window.setTimeout(function() {
+					ensureEventSourceOnElement(elt, Math.min(7, retryCount + 1));
+				}, timeout);
+			}
+		};
+
+		source.onopen = function(evt) {
+			api.triggerEvent(elt, "htmx:sseOpen", { source: source });
+		}
+
+		api.getInternalData(elt).sseEventSource = source;
 	}
 
 	/**
@@ -253,12 +282,12 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 		var result = [];
 
 		// If the parent element also contains the requested attribute, then add it to the results too.
-		if (api.hasAttribute(elt, attributeName) || api.hasAttribute(elt, "hx-sse")) {
+		if (api.hasAttribute(elt, attributeName)) {
 			result.push(elt);
 		}
 
 		// Search all child nodes that match the requested attribute
-		elt.querySelectorAll("[" + attributeName + "], [data-" + attributeName + "], [hx-sse], [data-hx-sse]").forEach(function(node) {
+		elt.querySelectorAll("[" + attributeName + "], [data-" + attributeName + "]").forEach(function(node) {
 			result.push(node);
 		});
 
@@ -281,7 +310,7 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 
 		api.selectAndSwap(swapSpec.swapStyle, target, elt, content, settleInfo);
 
-		settleInfo.elts.forEach(function (elt) {
+		settleInfo.elts.forEach(function(elt) {
 			if (elt.classList) {
 				elt.classList.add(htmx.config.settlingClass);
 			}
@@ -306,11 +335,11 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 	function doSettle(settleInfo) {
 
 		return function() {
-			settleInfo.tasks.forEach(function (task) {
+			settleInfo.tasks.forEach(function(task) {
 				task.call();
 			});
 
-			settleInfo.elts.forEach(function (elt) {
+			settleInfo.elts.forEach(function(elt) {
 				if (elt.classList) {
 					elt.classList.remove(htmx.config.settlingClass);
 				}
@@ -319,4 +348,8 @@ This extension adds support for Server Sent Events to htmx.  See /www/extensions
 		}
 	}
 
-})();
+	function hasEventSource(node) {
+		return api.getInternalData(node).sseEventSource != null;
+	}
+
+})();

templates/browser.html

@@ -48,7 +48,7 @@
 <ul class="dir" hx-boost="true" tabindex="-1">
   {% for entry in entries %}
   {% match entry %}
-  {% when mpd::Entry::Song with { name, path, artist } %}
+  {% when mpd::Entry::Song with { track, name, path, artist } %}
   <li 
     hx-post="/queue?path={{ path|urlencode }}"
     hx-trigger="click,keyup[key=='Enter']"
@@ -64,6 +64,11 @@
         alt="Album art"
       >
     </div>
+    {% if let Some(track) = track %}
+    <div class="track">
+      {{ track }}.
+    </div>
+    {% endif %}
     <div class="song">
       <div class="song__name">{{ name }}</div>
       <div class="song__artist">{{ artist }}</div>

templates/index.html

@@ -3,6 +3,8 @@
 <html lang="en">
   <head>
     <title>Empede</title>
+
+    <!-- Empede version: {{ crate_version!() }} -->
     
     <!-- Source: https://github.com/bigskysoftware/htmx -->
     <script src="/static/vendor/htmx.min.js"></script>
@@ -22,7 +24,7 @@
     </script>
   </head>
 
-  <body hx-ext="sse" sse-connect="/sse">
+  <body hx-ext="sse" sse-connect="/idle">
     <div 
       class="browser" 
       hx-trigger="load,sse:database"
@@ -31,14 +33,18 @@
     ></div>
 
     <div class="player">
-      <div class="nowplaying" hx-trigger="sse:player" hx-get="/player"></div>
+      <div class="nowplaying" hx-trigger="sse:player,sse:options" hx-get="/player"></div>
 
       <div class="queue-header">
         <div class="queue-next">Next in queue</div>
-        <button class="queue-clear" hx-delete="/queue" hx-swap="none">
+        <button hx-delete="/queue" hx-swap="none">
           <span class="material-symbols-outlined">playlist_remove</span>
           Clear
         </button>
+        <button hx-post="/shuffle" hx-swap="none">
+          <span class="material-symbols-outlined">shuffle</span>
+          Shuffle
+        </button>
       </div>
 
       <div class="queue" hx-trigger="sse:playlist,sse:player" hx-get="/queue"></div>

templates/player.html

@@ -4,9 +4,9 @@
 <div class="current">
   {% if let Some(song) = song %}
   <div class="albumart">
-    <a href="/art?path={{ song.file|urlencode }}" target="_blank">
+    <a href="/art?path={{ song["file"]|urlencode }}" target="_blank">
       <img
-        src="/art?path={{ song.file|urlencode }}"
+        src="/art?path={{ song["file"]|urlencode }}"
         onload="this.style.visibility = 'visible'"
         alt="Album art"
       >
@@ -17,7 +17,7 @@
     {% if let Some(name) = name %}
     <div class="song__name" title="Song name">{{ name }}</div>
     {% endif %}
-    {% if let Some(artist) = song.artist %}
+    {% if let Some(artist) = song.get("Artist") %}
     <div class="song__artist" title="Artist">{{ artist }}</div>
     {% endif %}
   </div>
@@ -34,7 +34,7 @@
     class="control material-symbols-outlined" role="button" title="Previous track"
   >skip_previous</button>
 
-  {% if state == mpdrs::State::Play %}
+  {% if state == "play" %}
   <button
     hx-post="/pause"
     class="control material-symbols-outlined" role="button" title="Pause"
@@ -52,20 +52,47 @@
   >skip_next</button>
 </div>
 
+<div class="settings" hx-swap="none" hx-trigger="click,keyUp[key=='Enter']">
+  <button
+    hx-post="/consume"
+    class="control material-symbols-outlined {% if consume %}active{% endif %}"
+    role="button" title="Consume"
+    style="font-size: 32px"
+  >delete_sweep</button>
+
+  <button 
+    hx-post="/random"
+    class="control material-symbols-outlined {% if random %}active{% endif %}"
+    role="button" title="Shuffle"
+  >shuffle</button>
+
+  <button 
+    hx-post="/repeat"
+    class="control material-symbols-outlined {% if repeat %}active{% endif %}"
+    role="button" title="Repeat"
+  >repeat</button>
+
+  <button 
+    hx-post="/single"
+    class="control material-symbols-outlined {% if single %}active{% endif %}"
+    role="button" title="Single"
+  >filter_1</button>
+</div>
+
 <div class="progress" style="width: {{ elapsed / duration * 100.0 }}%"></div>
 
 <script>
   {% if let Some(name) = name %}
-  {% if state == mpdrs::State::Play %}
+  {% if state == "play" %}
-  document.title = decodeURI("▶ {{ name|urlencode }} - Empede");
+  document.title = "▶ " + {{ name|json|safe }} + " - Empede";
   {% else %}
-  document.title = decodeURI("⏸ {{ name|urlencode }} - Empede");
+  document.title = "⏸ " + {{ name|json|safe }} + " - Empede";
   {% endif %}
   {% else %}
   document.title = "Empede";
   {% endif %}
 
-  {% if state == mpdrs::State::Play %}
+  {% if state == "play" %}
   progressBar = document.querySelector(".nowplaying .progress");
   elapsed = {{ elapsed }};
   duration = {{ duration }};

templates/queue.html

@@ -3,7 +3,12 @@
 
 <ul>
   {% for item in queue %}
-  <li {% if item.playing %}class="playing"{% endif %}>
+  <li
+    {% if item.playing %}class="playing"{% endif %}
+    hx-post="/play?position={{ item.position|urlencode }}"
+    hx-trigger="click,keyup[key='Enter']"
+    hx-swap="none"
+  >
     <div class="albumart">
       <img
         src="/art?path={{ item.file|urlencode }}"
@@ -26,6 +31,14 @@
 
 <script>
 htmx.onLoad(() => {
+  const scrollCurrentSongIntoView = () => {
+    const hoveredSong = document.querySelector(".queue li:hover");
+    if (hoveredSong === null) {
+      const currentSong = document.querySelector(".queue li.playing");
+      currentSong?.scrollIntoView({ block: "nearest" });
+    }
+  }
+
   const isReduced = window
     .matchMedia("(prefers-reduced-motion: reduce)")
     .matches;
@@ -38,5 +51,7 @@ htmx.onLoad(() => {
       body: JSON.stringify({from: event.oldIndex, to: event.newIndex}),
     }),
   });
+
+  scrollCurrentSongIntoView();
 });
 </script>