Compare commits

...

30 Commits

Author SHA1 Message Date
krolxon 5e61e0fad5 fix #10: remove exec perms from LICENSE and README 2024-06-20 11:44:46 +05:30
krolxon 9941e1e42b v0.1.6 2024-06-19 15:23:10 +05:30
krolxon df10c2cf63 fix #9 2024-06-19 10:42:52 +05:30
krolxon f2b9051489 change event to event_handler 2024-06-15 00:06:35 +05:30
krolxon 5795d00831 add CHANGELOG.md 2024-06-15 00:06:15 +05:30
krolxon e1dc925ecc comply with clippy 2024-06-13 15:31:40 +05:30
krolxon 3862d5d324 update append_list when new playlist is created 2024-06-13 14:17:30 +05:30
krolxon 65f76181d3 new feature: add to new playlist 2024-06-12 18:13:05 +05:30
krolxon 8a8176e97b v0.1.5 2024-06-12 15:06:06 +05:30
krolxon a63845bae8 ui: volume mute state 2024-06-11 23:09:08 +05:30
krolxon a6fa8add79 add toggle mute keymap 2024-06-11 21:49:35 +05:30
krolxon 3e3ae64c72 fix crash when using playlist append 2024-06-08 00:00:53 +05:30
krolxon 8f41c6e1d0 seperate UI states into App 2024-06-07 23:50:05 +05:30
krolxon faaddc2bd7 add mouse scrolling 2024-06-07 23:49:51 +05:30
krolxon 53522c936d change String to &str in get_full_path() 2024-06-04 15:24:36 +05:30
krolxon a2f44eb6e6 v0.1.4 2024-06-01 20:52:44 +05:30
krolxon 15be9357da move FileExtension to utils.rs 2024-06-01 20:25:35 +05:30
krolxon 7ae0a2cc19 remove unnecessary variables from Connection 2024-06-01 16:27:52 +05:30
krolxon dc3f561de3 fix #8 2024-06-01 15:58:53 +05:30
krolxon 311cbc2631 workaround for #7, fix error when using 'Space' 2024-05-31 12:51:06 +05:30
krolxon def91deabe pl_append remove get_full_path() usage of Queue #7 2024-05-31 12:36:41 +05:30
krolxon 7b14b68164 workaround for #7, fix error when using 'Space' 2024-05-30 16:36:04 +05:30
krolxon 6ae0aca868 queue: highlight current playing song initially 2024-05-30 16:18:54 +05:30
krolxon b31e16554c workaround for #7 2024-05-25 11:09:54 +05:30
krolxon 48fd5a7508 fix #6 2024-05-24 15:15:52 +05:30
krolxon e3ba0169ea fix #5 2024-05-24 15:04:26 +05:30
krolxon 230c75790c update_status() on pause 2024-05-22 20:00:20 +05:30
krolxon 380a4193c9 fix sorting 2024-05-22 19:36:49 +05:30
krolxon c3dc9931d5 sort contents in filetree 2024-05-22 19:28:10 +05:30
krolxon 6a9e3d9801 v0.1.3 2024-05-21 12:04:35 +05:30
20 changed files with 442 additions and 160 deletions

4
CHANGELOG.md Normal file
View File

@ -0,0 +1,4 @@
## rmptui-v0.1.6
- Add songs to new playlist feature
- Code refactoring
- fix #9

2
Cargo.lock generated
View File

@ -282,7 +282,7 @@ dependencies = [
[[package]]
name = "rmptui"
version = "0.1.2"
version = "0.1.6"
dependencies = [
"crossterm",
"mpd",

View File

@ -5,7 +5,7 @@ description = """
a fast and minimal tui mpd client
"""
readme = "README.md"
version = "0.1.3"
version = "0.1.6"
edition = "2021"
repository = "https://github.com/krolyxon/rmptui"
keywords = ["rmptui", "mpd", "music", "cli", "tui", "client"]

0
LICENSE Executable file → Normal file
View File

3
README.md Executable file → Normal file
View File

@ -15,6 +15,7 @@ rmptui is a minimal tui mpd client made with rust.
| `p` | Toggle pause |
| `+`/`=` | Increase volume |
| `-` | Decrease volume |
| `m` | Toggle Mute |
| `D` | Get dmenu prompt |
| `j`/`Down` | Scroll down |
| `k`/`Up` | Scroll up |
@ -37,6 +38,7 @@ rmptui is a minimal tui mpd client made with rust.
| `r` | Toggle repeat |
| `z` | Toggle random |
| `/` | Search |
| `R` | Rename Playlist |
| `g` | Go to top of list |
| `G` | Go to bottom of list |
@ -53,4 +55,5 @@ rmptui is a minimal tui mpd client made with rust.
- [x] metadata based tree view
- [x] view playlist
- [x] change playlist name
- [x] add to new playlist
- [ ] add lyrics fetcher

View File

@ -1,10 +1,12 @@
use std::time::Duration;
use std::{path::Path, time::Duration};
use crate::browser::FileBrowser;
use crate::connection::Connection;
use crate::list::ContentList;
use crate::ui::InputMode;
use crate::utils::FileExtension;
use mpd::{Client, Song};
use ratatui::widgets::{ListState, TableState};
// Application result type
pub type AppResult<T> = std::result::Result<T, Box<dyn std::error::Error>>;
@ -23,13 +25,26 @@ pub struct App {
pub inputmode: InputMode, // Defines input mode, Normal or Search
pub search_input: String, // Stores the userinput to be searched
pub search_cursor_pos: usize, // Stores the cursor position for searching
pub pl_newname_input: String, // Stores the new name of the playlist
pub pl_cursor_pos: usize, // Stores the cursor position for renaming playlist
pub pl_new_pl_input: String, // Stores the name of new playlist to be created
pub pl_new_pl_cursor_pos: usize, // Stores the cursor position of new playlist to be created
pub pl_new_pl_songs_buffer: Vec<Song>, // Buffer for songs that need to be added to the newly created playlist
// playlist variables
// used to show playlist popup
pub playlist_popup: bool,
pub append_list: ContentList<String>,
// Determines if the database should be updated or not
pub should_update_song_list: bool,
// States
pub queue_state: TableState,
pub browser_state: TableState,
pub playlists_state: ListState,
}
#[derive(Debug, PartialEq, Clone)]
@ -53,6 +68,10 @@ impl App {
let browser = FileBrowser::new();
let queue_state = TableState::new();
let browser_state = TableState::new();
let playlists_state = ListState::default();
Ok(Self {
running: true,
conn,
@ -66,13 +85,38 @@ impl App {
search_cursor_pos: 0,
pl_cursor_pos: 0,
playlist_popup: false,
pl_new_pl_input: String::new(),
pl_new_pl_cursor_pos: 0,
pl_new_pl_songs_buffer: Vec::new(),
append_list,
should_update_song_list: false,
queue_state,
browser_state,
playlists_state,
})
}
pub fn tick(&mut self) {
pub fn tick(&mut self) -> AppResult<()> {
self.conn.update_status();
self.update_queue();
// Deals with database update
if self.should_update_song_list && self.conn.status.updating_db.is_none() {
// Update the songs list
self.conn.songs_filenames = self
.conn
.conn
.listall()?
.into_iter()
.map(|x| x.file)
.collect();
self.browser.update_directory(&mut self.conn)?;
self.should_update_song_list = false;
}
Ok(())
}
pub fn quit(&mut self) {
@ -99,6 +143,7 @@ impl App {
pub fn get_append_list(conn: &mut Client) -> AppResult<ContentList<String>> {
let mut list = ContentList::new();
list.list.push("Current Playlist".to_string());
list.list.push("New Playlist".to_string());
for item in Self::get_playlist(conn)? {
list.list.push(item.to_string());
}
@ -116,17 +161,22 @@ impl App {
let file = format!("{}/{}", self.browser.path, content);
let songs = self.conn.conn.listfiles(&file).unwrap_or_default();
for (t, f) in songs.iter() {
if t == "file" {
if let Some(full_path) = &self.conn.get_full_path(f) {
let song = self.conn.get_song_with_only_filename(full_path);
self.conn.conn.push(&song)?;
}
if t == "file"
&& Path::new(&f).has_extension(&[
"mp3", "ogg", "flac", "m4a", "wav", "aac", "opus", "ape", "wma",
"mpc", "aiff", "dff", "mp2", "mka",
])
{
let path = file.clone() + "/" + f;
let full_path = path.strip_prefix("./").unwrap_or("");
let song = self.conn.get_song_with_only_filename(full_path);
self.conn.conn.push(&song)?;
}
}
} else if content_type == "file" {
let mut status = false;
for (i, song) in self.queue_list.list.clone().iter().enumerate() {
let song_path = song.file.split("/").last().unwrap_or_default();
let song_path = song.file.split('/').last().unwrap_or_default();
if song_path.eq(content) {
self.conn.conn.delete(i as u32).unwrap();
status = true;
@ -134,10 +184,17 @@ impl App {
}
if !status {
if let Some(full_path) = &self.conn.get_full_path(content) {
let song = self.conn.get_song_with_only_filename(full_path);
self.conn.conn.push(&song)?;
}
let mut filename = format!("{}/{}", self.browser.path, content);
// Remove "./" from the beginning of filename
filename.remove(0);
filename.remove(0);
let song = self.conn.get_song_with_only_filename(&filename);
self.conn.conn.push(&song)?;
// updating queue, to avoid multiple pushes of the same songs if we enter multiple times before the queue gets updated
self.update_queue();
}
}
@ -194,7 +251,7 @@ impl App {
let (t, path) = browser.filetree.get(browser.selected).unwrap();
if t == "directory" {
if path != "." {
browser.prev_path = browser.path.clone();
browser.prev_path.clone_from(&browser.path);
browser.path = browser.prev_path.clone() + "/" + path;
browser.update_directory(&mut self.conn)?;
browser.prev_selected = browser.selected;
@ -202,7 +259,7 @@ impl App {
}
} else {
let index = self.queue_list.list.iter().position(|x| {
let file = x.file.split("/").last().unwrap_or_default();
let file = x.file.split('/').last().unwrap_or_default();
file.eq(path)
});
@ -236,6 +293,10 @@ impl App {
let cursor_moved_left = self.search_cursor_pos.saturating_sub(1);
self.search_cursor_pos = self.clamp_cursor(cursor_moved_left);
}
InputMode::NewPlaylist => {
let cursor_moved_left = self.pl_new_pl_cursor_pos.saturating_sub(1);
self.pl_new_pl_cursor_pos = self.clamp_cursor(cursor_moved_left);
}
_ => {}
}
}
@ -250,6 +311,12 @@ impl App {
let cursor_moved_right = self.search_cursor_pos.saturating_add(1);
self.search_cursor_pos = self.clamp_cursor(cursor_moved_right);
}
InputMode::NewPlaylist => {
let cursor_moved_right = self.pl_new_pl_cursor_pos.saturating_add(1);
self.pl_new_pl_cursor_pos = self.clamp_cursor(cursor_moved_right);
}
_ => {}
}
}
@ -258,19 +325,24 @@ impl App {
match self.inputmode {
InputMode::PlaylistRename => {
self.pl_newname_input.insert(self.pl_cursor_pos, new_char);
self.move_cursor_right();
}
InputMode::NewPlaylist => {
self.pl_new_pl_input
.insert(self.pl_new_pl_cursor_pos, new_char);
}
InputMode::Editing => {
self.search_input.insert(self.search_cursor_pos, new_char);
self.move_cursor_right();
}
_ => {}
}
self.move_cursor_right();
}
pub fn delete_char(&mut self) {
let is_not_cursor_leftmost = match self.inputmode {
InputMode::PlaylistRename => self.pl_cursor_pos != 0,
InputMode::NewPlaylist => self.pl_new_pl_cursor_pos != 0,
InputMode::Editing => self.search_cursor_pos != 0,
_ => false,
};
@ -283,27 +355,35 @@ impl App {
let current_index = match self.inputmode {
InputMode::Editing => self.search_cursor_pos,
InputMode::PlaylistRename => self.pl_cursor_pos,
InputMode::NewPlaylist => self.pl_new_pl_cursor_pos,
_ => 0,
};
let from_left_to_current_index = current_index - 1;
if self.inputmode == InputMode::PlaylistRename {
// Getting all characters before the selected character.
let before_char_to_delete = self
.pl_newname_input
.chars()
.take(from_left_to_current_index);
// Getting all characters after selected character.
let after_char_to_delete = self.pl_newname_input.chars().skip(current_index);
// Put all characters together except the selected one.
// By leaving the selected one out, it is forgotten and therefore deleted.
self.pl_newname_input = before_char_to_delete.chain(after_char_to_delete).collect();
self.move_cursor_left();
} else if self.inputmode == InputMode::NewPlaylist {
let before_char_to_delete = self
.pl_new_pl_input
.chars()
.take(from_left_to_current_index);
let after_char_to_delete = self.pl_new_pl_input.chars().skip(current_index);
self.pl_new_pl_input = before_char_to_delete.chain(after_char_to_delete).collect();
self.move_cursor_left();
} else if self.inputmode == InputMode::Editing {
let before_char_to_delete =
self.search_input.chars().take(from_left_to_current_index);
let after_char_to_delete = self.search_input.chars().skip(current_index);
self.search_input = before_char_to_delete.chain(after_char_to_delete).collect();
self.move_cursor_left();
}
@ -313,6 +393,7 @@ impl App {
pub fn clamp_cursor(&self, new_cursor_pos: usize) -> usize {
match self.inputmode {
InputMode::PlaylistRename => new_cursor_pos.clamp(0, self.pl_newname_input.len()),
InputMode::NewPlaylist => new_cursor_pos.clamp(0, self.pl_new_pl_input.len()),
InputMode::Editing => new_cursor_pos.clamp(0, self.search_input.len()),
_ => 0,
}
@ -326,6 +407,9 @@ impl App {
InputMode::PlaylistRename => {
self.pl_cursor_pos = 0;
}
InputMode::NewPlaylist => {
self.pl_new_pl_cursor_pos = 0;
}
_ => {}
}
}
@ -343,10 +427,36 @@ impl App {
}
}
pub fn change_playlist_name(&mut self) -> AppResult<()> {
if self.selected_tab == SelectedTab::Playlists {
self.inputmode = InputMode::PlaylistRename;
// Mouse event handlers
pub fn handle_scroll_up(&mut self) {
match self.selected_tab {
SelectedTab::Queue => {
self.queue_list.prev();
}
SelectedTab::DirectoryBrowser => {
self.browser.prev();
}
SelectedTab::Playlists => {
self.pl_list.prev();
}
}
}
pub fn handle_scroll_down(&mut self) {
match self.selected_tab {
SelectedTab::Queue => {
self.queue_list.next();
}
SelectedTab::DirectoryBrowser => {
self.browser.next();
}
SelectedTab::Playlists => {
self.pl_list.next();
}
}
}
pub fn handle_mouse_left_click(&mut self, _x: u16, _y: u16) -> AppResult<()> {
Ok(())
}
}

View File

@ -1,9 +1,8 @@
use std::ffi::OsStr;
use std::path::Path;
use mpd::Song;
use crate::{app::AppResult, connection::Connection};
use crate::{app::AppResult, connection::Connection, utils::FileExtension};
#[derive(Debug)]
/// struct for working with directory browser tab in rmptui
@ -16,23 +15,6 @@ pub struct FileBrowser {
pub songs: Vec<Song>,
}
// https://stackoverflow.com/questions/72392835/check-if-a-file-is-of-a-given-type
pub trait FileExtension {
fn has_extension<S: AsRef<str>>(&self, extensions: &[S]) -> bool;
}
impl<P: AsRef<Path>> FileExtension for P {
fn has_extension<S: AsRef<str>>(&self, extensions: &[S]) -> bool {
if let Some(extension) = self.as_ref().extension().and_then(OsStr::to_str) {
return extensions
.iter()
.any(|x| x.as_ref().eq_ignore_ascii_case(extension));
}
false
}
}
impl FileBrowser {
pub fn new() -> FileBrowser {
FileBrowser {
@ -50,7 +32,7 @@ impl FileBrowser {
let mut file_vec: Vec<(String, String)> = vec![];
let mut dir_vec: Vec<(String, String)> = vec![];
for (t, f) in conn.conn.listfiles(self.path.as_str())?.into_iter() {
if t == "directory" && !f.starts_with(".") {
if t == "directory" && !f.starts_with('.') {
dir_vec.push((t, f));
} else if t == "file"
&& Path::new(&f).has_extension(&[
@ -62,19 +44,37 @@ impl FileBrowser {
}
}
// dir_vec.sort_by(|a, b| a.1.cmp(&b.1));
dir_vec.sort_by(|a, b| {
let num_a = a.1.parse::<u32>().unwrap_or(u32::MAX);
let num_b = b.1.parse::<u32>().unwrap_or(u32::MAX);
num_a
.cmp(&num_b)
.then_with(|| a.1.to_lowercase().cmp(&b.1.to_lowercase()))
});
file_vec.sort_by(|a, b| {
let num_a = a.1.parse::<u32>().unwrap_or(u32::MAX);
let num_b = b.1.parse::<u32>().unwrap_or(u32::MAX);
num_a
.cmp(&num_b)
.then_with(|| a.1.to_lowercase().cmp(&b.1.to_lowercase()))
});
// Add metadata
dir_vec.extend(file_vec);
self.filetree = dir_vec;
// Add metadata
self.songs.clear();
for (t, song) in self.filetree.iter() {
if t == "file" {
let v = conn
.conn
.lsinfo(Song {
file: conn
.get_full_path(song)
.unwrap_or_else(|| "Not a song".to_string()),
file: (self.path.clone() + "/" + song)
.strip_prefix("./")
.unwrap_or("")
.to_string(),
..Default::default()
})
.unwrap_or_else(|_| {
@ -115,11 +115,13 @@ impl FileBrowser {
/// handles going back event
pub fn handle_go_back(&mut self, conn: &mut Connection) -> AppResult<()> {
if self.prev_path != "." {
let r = self.path.rfind('/').unwrap();
self.path = self.path.as_str()[..r].to_string();
self.update_directory(conn)?;
let r = self.path.rfind('/');
if let Some(r) = r {
self.path = self.path.as_str()[..r].to_string();
self.update_directory(conn)?;
}
} else {
self.path = self.prev_path.clone();
self.path.clone_from(&self.prev_path);
self.update_directory(conn)?;
}
@ -128,8 +130,6 @@ impl FileBrowser {
}
}
impl Default for FileBrowser {
fn default() -> Self {
Self::new()

View File

@ -1,10 +1,17 @@
use crate::app::AppResult;
use crate::utils::is_installed;
use mpd::song::Song;
use mpd::{Client, State};
use simple_dmenu::dmenu;
use std::process::Command;
use std::time::Duration;
/// Defines the current status of volume (Muted or UnMuted)
#[derive(Debug)]
pub enum VolumeStatus {
Muted(i8),
Unmuted,
}
#[derive(Debug)]
/// struct storing the mpd Client related stuff
pub struct Connection {
@ -13,11 +20,10 @@ pub struct Connection {
pub state: String,
pub elapsed: Duration,
pub total_duration: Duration,
pub volume: u8,
pub repeat: bool,
pub random: bool,
pub current_song: Song,
pub stats: mpd::Stats,
pub status: mpd::Status,
pub volume_status: VolumeStatus,
}
impl Connection {
@ -33,34 +39,29 @@ impl Connection {
..Default::default()
};
let songs_filenames: Vec<String> = conn
.listall()?
.into_iter()
.map(|x| x.file)
.collect();
let songs_filenames: Vec<String> = conn.listall()?.into_iter().map(|x| x.file).collect();
let status = conn.status().unwrap();
let (elapsed, total) = status.time.unwrap_or_default();
let volume: u8 = status.volume as u8;
let repeat = status.repeat;
let random = status.random;
let stats = conn.stats().unwrap_or_default();
let current_song = conn
.currentsong()
.unwrap_or_else(|_| Some(empty_song.clone()))
.unwrap_or(empty_song);
let volume_status = VolumeStatus::Unmuted;
Ok(Self {
conn,
songs_filenames,
state: "Stopped".to_string(),
elapsed,
total_duration: total,
volume,
repeat,
random,
current_song,
stats,
status,
volume_status,
})
}
@ -82,13 +83,18 @@ impl Connection {
/// Update status
pub fn update_status(&mut self) {
let status = self.conn.status().unwrap();
let stats = self.conn.stats().unwrap_or_default();
let empty_song = self.get_song_with_only_filename("No Song playing or in Queue");
let current_song = self
.conn
.currentsong()
.unwrap_or_else(|_| Some(empty_song.clone()))
.unwrap_or(empty_song);
let stats = self.conn.stats().unwrap_or_default();
// Status
self.status = status.clone();
// Playback State
self.state = match status.state {
@ -102,15 +108,6 @@ impl Connection {
self.elapsed = elapsed;
self.total_duration = total;
// Volume
self.volume = status.volume as u8;
// Repeat mode
self.repeat = status.repeat;
// Random mode
self.random = status.random;
// Current song
self.current_song = current_song;
@ -172,10 +169,10 @@ impl Connection {
}
/// Given a song name from a directory, it returns the full path of the song in the database
pub fn get_full_path(&self, short_path: &str) -> Option<String> {
pub fn get_full_path(&self, short_path: &str) -> Option<&str> {
for (i, f) in self.songs_filenames.iter().enumerate() {
if f.contains(short_path) {
return Some(self.songs_filenames.get(i).unwrap().to_string());
return Some(self.songs_filenames.get(i).unwrap());
}
}
None
@ -207,40 +204,32 @@ impl Connection {
/// Toggle Repeat mode
pub fn toggle_repeat(&mut self) {
let mode = self.conn.status().unwrap().repeat;
let mode = self.status.repeat;
self.conn.repeat(!mode).unwrap();
}
/// Toggle random mode
pub fn toggle_random(&mut self) {
let mode = self.conn.status().unwrap().random;
let mode = self.status.random;
self.conn.random(!mode).unwrap();
}
// Volume controls
/// Increase Volume
pub fn inc_volume(&mut self, v: i8) {
let cur = self.conn.status().unwrap().volume;
let cur = self.status.volume;
if cur + v <= 100 {
self.volume_status = VolumeStatus::Unmuted;
self.conn.volume(cur + v).unwrap();
}
}
/// Decrease volume
pub fn dec_volume(&mut self, v: i8) {
let cur = self.conn.status().unwrap().volume;
let cur = self.status.volume;
if cur - v >= 0 {
self.volume_status = VolumeStatus::Unmuted;
self.conn.volume(cur - v).unwrap();
}
}
}
/// Checks if given program is installed in your system
fn is_installed(ss: &str) -> bool {
let output = Command::new("which")
.arg(ss)
.output()
.expect("Failed to execute command");
output.status.success()
}

0
src/event/event.rs → src/event_handler/event.rs Executable file → Normal file
View File

71
src/event/handler.rs → src/event_handler/handler.rs Executable file → Normal file
View File

@ -1,11 +1,12 @@
use crate::{
app::{App, AppResult, SelectedTab},
connection::VolumeStatus,
ui::InputMode,
};
use crossterm::event::{KeyCode, KeyEvent, KeyModifiers};
use crossterm::event::{KeyCode, KeyEvent, KeyModifiers, MouseEvent, MouseEventKind};
use std::time::Duration;
use super::{pl_append_keys, pl_rename_keys, search_keys};
use super::{new_pl_keys, pl_append_keys, pl_rename_keys, search_keys};
pub fn handle_key_events(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
// searching, playlist renaming, playlist appending
@ -13,6 +14,8 @@ pub fn handle_key_events(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
search_keys::handle_search_keys(key_event, app)?;
} else if app.inputmode == InputMode::PlaylistRename {
pl_rename_keys::handle_pl_rename_keys(key_event, app)?;
} else if app.inputmode == InputMode::NewPlaylist {
new_pl_keys::handle_new_pl_keys(key_event, app)?;
} else if app.playlist_popup {
pl_append_keys::hande_pl_append_keys(key_event, app)?;
} else {
@ -33,10 +36,16 @@ pub fn handle_key_events(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
// Playback controls
// Toggle Pause
KeyCode::Char('p') => app.conn.toggle_pause(),
KeyCode::Char('p') => {
app.conn.toggle_pause();
app.conn.update_status();
}
// Pause
KeyCode::Char('s') => app.conn.pause(),
KeyCode::Char('s') => {
app.conn.pause();
app.conn.update_status();
}
// Toggle rpeat
KeyCode::Char('r') => {
@ -51,7 +60,10 @@ pub fn handle_key_events(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
}
// Dmenu prompt
KeyCode::Char('D') => app.conn.play_dmenu()?,
KeyCode::Char('D') => {
app.conn.play_dmenu()?;
app.conn.update_status();
}
// add to queue
KeyCode::Char('a') => app.playlist_popup = true,
@ -129,20 +141,26 @@ pub fn handle_key_events(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
app.conn.update_status();
}
// Toggle Mute
KeyCode::Char('m') => {
match app.conn.volume_status {
VolumeStatus::Muted(v) => {
app.conn.conn.volume(v)?;
app.conn.volume_status = VolumeStatus::Unmuted;
}
VolumeStatus::Unmuted => {
let current_volume = app.conn.status.volume;
app.conn.conn.volume(0)?;
app.conn.volume_status = VolumeStatus::Muted(current_volume);
}
}
app.conn.update_status();
}
// Update MPD database
KeyCode::Char('U') => {
app.conn.conn.rescan()?;
// Update the songs list
app.conn.songs_filenames = app
.conn
.conn
.listall()?
.into_iter()
.map(|x| x.file)
.collect();
app.browser.update_directory(&mut app.conn)?;
app.should_update_song_list = true;
}
// Search for songs
@ -279,8 +297,10 @@ pub fn handle_key_events(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
// go to bottom of list
KeyCode::Char('G') => app.pl_list.index = app.pl_list.list.len() - 1,
// Change playlist name
KeyCode::Char('e') => app.change_playlist_name()?,
// Playlist Rename
KeyCode::Char('R') => {
app.inputmode = InputMode::PlaylistRename;
}
// add to current playlist
KeyCode::Enter | KeyCode::Char('l') | KeyCode::Right | KeyCode::Char(' ') => {
@ -298,3 +318,18 @@ pub fn handle_key_events(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
}
Ok(())
}
pub fn handle_mouse_events(mouse_event: MouseEvent, app: &mut App) -> AppResult<()> {
match mouse_event.kind {
MouseEventKind::ScrollUp => app.handle_scroll_up(),
MouseEventKind::ScrollDown => app.handle_scroll_down(),
MouseEventKind::Down(button) => {
let (x, y) = (mouse_event.column, mouse_event.row);
if button == crossterm::event::MouseButton::Left {
app.handle_mouse_left_click(x, y)?;
}
}
_ => {}
}
Ok(())
}

1
src/event/mod.rs → src/event_handler/mod.rs Executable file → Normal file
View File

@ -3,3 +3,4 @@ pub mod handler;
pub mod search_keys;
pub mod pl_rename_keys;
pub mod pl_append_keys;
pub mod new_pl_keys;

View File

@ -0,0 +1,47 @@
use crate::{
app::{App, AppResult},
ui::InputMode,
};
use crossterm::event::{KeyCode, KeyEvent};
pub fn handle_new_pl_keys(key_event: KeyEvent, app: &mut App) -> AppResult<()> {
match key_event.code {
KeyCode::Esc => {
app.pl_new_pl_input.clear();
app.reset_cursor();
app.inputmode = InputMode::Normal;
}
KeyCode::Char(to_insert) => {
app.enter_char(to_insert);
}
KeyCode::Enter => {
let pl_name = &app.pl_new_pl_input;
for song in app.pl_new_pl_songs_buffer.iter() {
app.conn.conn.pl_push(pl_name, song)?;
}
app.pl_new_pl_input.clear();
app.pl_list.list = App::get_playlist(&mut app.conn.conn)?;
app.append_list = App::get_append_list(&mut app.conn.conn)?;
app.reset_cursor();
app.inputmode = InputMode::Normal;
}
KeyCode::Backspace => {
app.delete_char();
}
KeyCode::Left => {
app.move_cursor_left();
}
KeyCode::Right => {
app.move_cursor_right();
}
_ => {}
}
Ok(())
}

View File

@ -1,5 +1,6 @@
use crate::app::{App, AppResult, SelectedTab};
use crate::browser::FileExtension;
use crate::ui::InputMode;
use crate::utils::FileExtension;
use crossterm::event::{KeyCode, KeyEvent};
use std::path::Path;
@ -18,16 +19,25 @@ pub fn hande_pl_append_keys(key_event: KeyEvent, app: &mut App) -> AppResult<()>
match app.selected_tab {
SelectedTab::Queue => {
let short_path = &app.queue_list.get_item_at_current_index().file;
// Just exit out the menu if no item is selected in the Queue
if app.queue_list.list.is_empty() {
app.playlist_popup = false;
return Ok(());
}
if let Some(full_path) = app.conn.get_full_path(short_path) {
let song = app.conn.get_song_with_only_filename(&full_path);
if *pl_name == "Current Playlist" {
app.conn.conn.push(&song)?;
app.update_queue();
} else {
app.conn.add_to_playlist(pl_name, &song)?;
if let Ok(songs) = app.conn.conn.songs(app.queue_list.index as u32) {
let option_song = songs.first();
if let Some(song) = option_song {
if *pl_name == "Current Playlist" {
app.conn.conn.push(song)?;
app.update_queue();
} else if *pl_name == "New Playlist" {
app.pl_new_pl_songs_buffer.clear();
app.pl_new_pl_songs_buffer.push(song.clone());
app.inputmode = InputMode::NewPlaylist;
} else {
app.conn.add_to_playlist(pl_name, song)?;
}
}
}
}
@ -37,17 +47,23 @@ pub fn hande_pl_append_keys(key_event: KeyEvent, app: &mut App) -> AppResult<()>
if t == "file" {
let short_path = f;
if let Some(full_path) = app.conn.get_full_path(short_path) {
let song = app.conn.get_song_with_only_filename(&full_path);
let song = app.conn.get_song_with_only_filename(full_path);
if *pl_name == "Current Playlist" {
app.conn.conn.push(&song)?;
app.update_queue();
} else if *pl_name == "New Playlist" {
app.pl_new_pl_songs_buffer.clear();
app.pl_new_pl_songs_buffer.push(song.clone());
app.inputmode = InputMode::NewPlaylist;
} else {
app.conn.add_to_playlist(pl_name, &song)?;
}
}
} else if t == "directory" {
for (t, f) in app.conn.conn.listfiles(f)?.iter() {
let file = format!("{}/{}", app.browser.path, f);
app.pl_new_pl_songs_buffer.clear();
for (t, f) in app.conn.conn.listfiles(&file)?.iter() {
// dir_vec.push((t, f));
if t == "file"
&& Path::new(&f).has_extension(&[
@ -56,9 +72,12 @@ pub fn hande_pl_append_keys(key_event: KeyEvent, app: &mut App) -> AppResult<()>
])
{
let full_path = app.conn.get_full_path(f).unwrap_or_default();
let song = app.conn.get_song_with_only_filename(&full_path);
let song = app.conn.get_song_with_only_filename(full_path);
if *pl_name == "Current Playlist" {
app.conn.conn.push(&song)?;
} else if *pl_name == "New Playlist" {
app.pl_new_pl_songs_buffer.push(song.clone());
app.inputmode = InputMode::NewPlaylist;
} else {
app.conn.add_to_playlist(pl_name, &song)?;
}
@ -72,14 +91,14 @@ pub fn hande_pl_append_keys(key_event: KeyEvent, app: &mut App) -> AppResult<()>
if *pl_name == "Current Playlist" {
app.conn.load_playlist(playlist_name)?;
app.update_queue();
} else if *pl_name == "New Playlist" {
app.inputmode = InputMode::NewPlaylist;
} else {
let songs = app.conn.conn.playlist(playlist_name)?;
for song in songs {
// We ignore the Err() since there could be songs in playlists, which do not exist in the db anymore.
// So instead of panicking, we just ignore if the song does not exists
app.conn
.add_to_playlist(*pl_name, &song)
.unwrap_or_else(|_| {});
app.conn.add_to_playlist(pl_name, &song).unwrap_or(());
}
}
}

View File

View File

View File

@ -14,7 +14,10 @@ pub mod list;
pub mod browser;
/// Event Handler/ keymaps
pub mod event;
pub mod event_handler;
/// Application
pub mod app;
/// Utilities
pub mod utils;

View File

@ -1,9 +1,9 @@
use ratatui::prelude::*;
use rmptui::app::App;
use rmptui::app::AppResult;
use rmptui::event::event::Event;
use rmptui::event::event::EventHandler;
use rmptui::event::handler;
use rmptui::event_handler::event::Event;
use rmptui::event_handler::event::EventHandler;
use rmptui::event_handler::handler;
use rmptui::tui;
use std::env;
use std::io;
@ -25,12 +25,17 @@ fn main() -> AppResult<()> {
// initial directory read
app.browser.update_directory(&mut app.conn)?;
// initially set the queue's highlighted item to the current playing item
if let Ok(item) = app.conn.conn.currentsong() {
app.queue_list.index = item.unwrap_or_default().place.unwrap_or_default().pos as usize;
}
while app.running {
tui.draw(&mut app)?;
match tui.events.next()? {
Event::Tick => app.tick(),
Event::Tick => app.tick()?,
Event::Key(key_event) => handler::handle_key_events(key_event, &mut app)?,
Event::Mouse(_) => {}
Event::Mouse(mouse_event) => handler::handle_mouse_events(mouse_event, &mut app)?,
Event::Resize(_, _) => {}
}
}

View File

@ -5,7 +5,7 @@ use crossterm::terminal::{self, *};
use std::panic;
use crate::app::{App, AppResult};
use crate::event::event::EventHandler;
use crate::event_handler::event::EventHandler;
pub type CrosstermTerminal = ratatui::Terminal<ratatui::backend::CrosstermBackend<std::io::Stderr>>;

View File

@ -1,6 +1,9 @@
use std::time::Duration;
use crate::app::{App, SelectedTab};
use crate::{
app::{App, SelectedTab},
connection::VolumeStatus,
};
use ratatui::{
prelude::*,
widgets::{block::Title, *},
@ -11,6 +14,7 @@ pub enum InputMode {
Editing,
Normal,
PlaylistRename,
NewPlaylist,
}
/// Renders the user interface widgets
@ -37,6 +41,9 @@ pub fn render(app: &mut App, frame: &mut Frame) {
InputMode::PlaylistRename => {
draw_rename_playlist(frame, app, layout[1]);
}
InputMode::NewPlaylist => {
draw_new_playlist(frame, app, layout[1]);
}
}
if app.playlist_popup {
@ -76,7 +83,7 @@ fn draw_directory_browser(frame: &mut Frame, app: &mut App, size: Rect) {
let mut status: bool = false;
for sn in app.queue_list.list.iter() {
let file = sn.file.split("/").last().unwrap_or_default();
let file = sn.file.split('/').last().unwrap_or_default();
if file.eq(s) {
status = true;
}
@ -101,7 +108,6 @@ fn draw_directory_browser(frame: &mut Frame, app: &mut App, size: Rect) {
}
});
let mut state = TableState::new();
let header = ["Artist", "Track", "Title", "Album", "Time"]
.into_iter()
.map(Cell::from)
@ -125,10 +131,15 @@ fn draw_directory_browser(frame: &mut Frame, app: &mut App, size: Rect) {
Title::from(format!("Total Songs: {}", total_songs).green())
.alignment(Alignment::Center),
)
.title(
Title::from(format!("Volume: {}%", app.conn.volume).green())
.alignment(Alignment::Right),
)
.title(match app.conn.volume_status {
VolumeStatus::Unmuted => {
Title::from(format!("Volume: {}%", app.conn.status.volume).green())
.alignment(Alignment::Right)
}
VolumeStatus::Muted(_v) => {
Title::from("Muted".red()).alignment(Alignment::Right)
}
})
.borders(Borders::ALL),
)
.highlight_style(
@ -140,8 +151,8 @@ fn draw_directory_browser(frame: &mut Frame, app: &mut App, size: Rect) {
.header(header)
.flex(layout::Flex::Legacy);
state.select(Some(app.browser.selected));
frame.render_stateful_widget(table, size, &mut state);
app.browser_state.select(Some(app.browser.selected));
frame.render_stateful_widget(table, size, &mut app.browser_state);
}
/// draws playing queue
@ -196,7 +207,6 @@ fn draw_queue(frame: &mut Frame, app: &mut App, size: Rect) {
}
});
let mut state = TableState::new();
let header = ["Artist", "Track", "Title", "Album", "Time"]
.into_iter()
.map(Cell::from)
@ -219,10 +229,15 @@ fn draw_queue(frame: &mut Frame, app: &mut App, size: Rect) {
.title(Title::from(
format!("({} items)", app.queue_list.list.len()).bold(),
))
.title(
Title::from(format!("Volume: {}%", app.conn.volume).green())
.alignment(Alignment::Right),
)
.title(match app.conn.volume_status {
VolumeStatus::Unmuted => {
Title::from(format!("Volume: {}%", app.conn.status.volume).green())
.alignment(Alignment::Right)
}
VolumeStatus::Muted(_v) => {
Title::from("Muted".red()).alignment(Alignment::Right)
}
})
.borders(Borders::ALL),
)
.highlight_style(
@ -234,8 +249,8 @@ fn draw_queue(frame: &mut Frame, app: &mut App, size: Rect) {
.header(header)
.flex(layout::Flex::Legacy);
state.select(Some(app.queue_list.index));
frame.render_stateful_widget(table, size, &mut state);
app.queue_state.select(Some(app.queue_list.index));
frame.render_stateful_widget(table, size, &mut app.queue_state);
}
// Draw search bar
@ -273,24 +288,24 @@ fn draw_progress_bar(frame: &mut Frame, app: &mut App, size: Rect) {
// Get the current playing state
let mut state: String = String::new();
if !app.queue_list.list.is_empty() {
state = app.conn.state.clone();
state.clone_from(&app.conn.state);
state.push(':');
}
// Get the current modes
let mut modes_bottom: String = String::new();
// we do this to check if at least one mode is enabled so we can push "[]"
if app.conn.repeat | app.conn.random {
if app.conn.status.repeat | app.conn.status.random {
modes_bottom.push('r');
}
if !modes_bottom.is_empty() {
modes_bottom.clear();
modes_bottom.push('[');
if app.conn.repeat {
if app.conn.status.repeat {
modes_bottom.push('r');
}
if app.conn.random {
if app.conn.status.random {
modes_bottom.push('z');
}
modes_bottom.push(']');
@ -336,7 +351,6 @@ fn draw_playlist_viewer(frame: &mut Frame, app: &mut App, area: Rect) {
.split(area);
// Draw list of playlists
let mut state = ListState::default();
let title = Block::default().title(Title::from("Playlist".green().bold()));
let list = List::new(app.pl_list.list.clone())
.block(title.borders(Borders::ALL))
@ -348,8 +362,8 @@ fn draw_playlist_viewer(frame: &mut Frame, app: &mut App, area: Rect) {
.add_modifier(Modifier::REVERSED),
)
.repeat_highlight_symbol(true);
state.select(Some(app.pl_list.index));
frame.render_stateful_widget(list, layouts[0], &mut state);
app.playlists_state.select(Some(app.pl_list.index));
frame.render_stateful_widget(list, layouts[0], &mut app.playlists_state);
// Playlist viewer
@ -443,6 +457,26 @@ fn draw_rename_playlist(frame: &mut Frame, app: &mut App, area: Rect) {
frame.render_widget(input, area);
}
fn draw_new_playlist(frame: &mut Frame, app: &mut App, area: Rect) {
#[allow(clippy::cast_possible_truncation)]
frame.set_cursor(
// Draw the cursor at the current position in the input field.
// This position is can be controlled via the left and right arrow key
area.x + app.pl_new_pl_cursor_pos as u16 + 2,
// Move one line down, from the border to the input line
area.y + 1,
);
let input = Paragraph::new("/".to_string() + &app.pl_new_pl_input)
.style(Style::default())
.block(
Block::default()
.borders(Borders::ALL)
.title("Enter New Playlist's Name: ".bold().green()),
);
frame.render_widget(input, area);
}
fn centered_rect(percent_x: u16, percent_y: u16, r: Rect) -> Rect {
let popup_layout = Layout::vertical([
Constraint::Percentage((100 - percent_y) / 2),

32
src/utils.rs Normal file
View File

@ -0,0 +1,32 @@
use std::process::Command;
use std::ffi::OsStr;
use std::path::Path;
/// Checks if given program is installed in your system
pub fn is_installed(ss: &str) -> bool {
let output = Command::new("which")
.arg(ss)
.output()
.expect("Failed to execute command");
output.status.success()
}
/// Checks if a file has a given extension
// https://stackoverflow.com/questions/72392835/check-if-a-file-is-of-a-given-type
pub trait FileExtension {
fn has_extension<S: AsRef<str>>(&self, extensions: &[S]) -> bool;
}
impl<P: AsRef<Path>> FileExtension for P {
fn has_extension<S: AsRef<str>>(&self, extensions: &[S]) -> bool {
if let Some(extension) = self.as_ref().extension().and_then(OsStr::to_str) {
return extensions
.iter()
.any(|x| x.as_ref().eq_ignore_ascii_case(extension));
}
false
}
}