3 Commits

Author SHA1 Message Date
Alexander Heldt
0c4c085dd0 Add ability to switch View 2025-12-25 19:50:05 +01:00
Alexander Heldt
a3c5c203f1 wip set view 2025-12-25 17:51:32 +01:00
Alexander Heldt
0ef94d7c89 Key handling is state aware
By forwarding all `Key`s to the agent and allow it to decide what should
be done, instead of converting the `Key` to a `Control` and then decide
what should be done
2025-12-25 17:49:34 +01:00
7 changed files with 172 additions and 129 deletions

View File

@@ -1,30 +1,58 @@
import gleam/string
import musicplayer/ui/layout
import musicplayer/input/key.{type Key} import musicplayer/input/key.{type Key}
pub type Mode {
Idle
Searching(input: String)
}
pub type Control { pub type Control {
TogglePlayPause TogglePlayPause
Search Search(input: String, capturing: Bool)
Raw(String) SetView(view_idx: layout.ViewIdx)
Return
Backspace
Exit Exit
} }
pub fn from_key(key: Key) -> Result(Control, Nil) { pub fn from_key(key: Key, mode: Mode) -> Result(Control, Nil) {
case mode {
Idle -> idle_from_key(key)
Searching(input) -> searching_from_key(key, input)
}
}
pub fn idle_from_key(key: Key) -> Result(Control, Nil) {
case key { case key {
key.Return -> Ok(Return) key.Char(char) -> {
key.Backspace -> Ok(Backspace) case char {
key.Char(char) -> Ok(char_control(char)) // Views are zero indexed
"1" -> Ok(SetView(0))
"2" -> Ok(SetView(1))
" " -> Ok(TogglePlayPause)
"/" -> Ok(Search(input: "", capturing: True))
"q" -> Ok(Exit)
// NOOP
_ -> Error(Nil)
}
}
// NOOP
_ -> Error(Nil) _ -> Error(Nil)
} }
} }
fn char_control(char: String) -> Control { pub fn searching_from_key(key: Key, input: String) -> Result(Control, Nil) {
case char { case key {
" " -> TogglePlayPause key.Char(char) -> Ok(Search(input <> char, True))
"/" -> Search key.Backspace -> Ok(Search(string.drop_end(input, 1), True))
"q" -> Exit key.Return -> Ok(Search(input, False))
_ -> Raw(char)
// NOOP
_ -> Error(Nil)
} }
} }

View File

@@ -1,9 +1,8 @@
import gleam/erlang/process.{type Name, type Pid, type Subject} import gleam/erlang/process.{type Name, type Pid, type Subject}
import gleam/otp/actor import gleam/otp/actor
import gleam/result
import gleam/string import gleam/string
import musicplayer/control.{type Control} import musicplayer/control.{type Mode}
import musicplayer/input/key.{type Key} import musicplayer/input/key.{type Key}
import musicplayer/logging/logging import musicplayer/logging/logging
import musicplayer/mpv/control as mpv_control import musicplayer/mpv/control as mpv_control
@@ -11,19 +10,9 @@ import musicplayer/time/time
import musicplayer/ui/control as ui_control import musicplayer/ui/control as ui_control
import musicplayer/ui/layout import musicplayer/ui/layout
type Mode {
Idle
Searching
}
type Input {
Input(capturing: Bool, content: String)
}
type State { type State {
State( State(
mode: Mode, mode: Mode,
input: Input,
ui: Subject(ui_control.Control), ui: Subject(ui_control.Control),
mpv: Subject(mpv_control.Control), mpv: Subject(mpv_control.Control),
) )
@@ -36,10 +25,8 @@ pub fn new(
) -> Result(Pid, String) { ) -> Result(Pid, String) {
let input_keys = process.named_subject(input_keys_name) let input_keys = process.named_subject(input_keys_name)
let input = Input(False, "")
case case
actor.new(State(Idle, input, ui, mpv)) actor.new(State(control.Idle, ui, mpv))
|> actor.on_message(handle_message) |> actor.on_message(handle_message)
|> actor.start |> actor.start
{ {
@@ -49,7 +36,7 @@ pub fn new(
logging.log("musicplayer - started") logging.log("musicplayer - started")
process.spawn(fn() { process.spawn(fn() {
let assert Ok(_) = process.register(process.self(), input_keys_name) let assert Ok(_) = process.register(process.self(), input_keys_name)
handle_key(musicplayer, input_keys) forward_key(musicplayer, input_keys)
}) })
process.spawn(fn() { update_playback_time_loop(mpv, ui, 250) }) process.spawn(fn() { update_playback_time_loop(mpv, ui, 250) })
@@ -59,88 +46,67 @@ pub fn new(
} }
} }
fn handle_message(state: State, control: Control) -> actor.Next(State, Control) { fn handle_message(state: State, key: Key) -> actor.Next(State, Key) {
case control { case control.from_key(key, state.mode) {
control.Search -> { Error(_) -> actor.continue(state)
logging.log("musicplayer - initiating search") Ok(c) ->
case c {
control.SetView(view_idx) -> {
logging.log(
"musicplayer - setting current view to: "
<> string.inspect(view_idx),
)
update_search(state.ui, "searching: ") update_current_view(state.ui, view_idx)
actor.continue(state)
}
control.Search(input, capturing) -> {
case capturing {
True -> {
logging.log("musicplayer - searching: " <> input)
actor.continue( update_search(state.ui, "searching: " <> input)
State(
..state,
mode: Searching,
input: Input(..state.input, capturing: True),
),
)
}
control.Raw(content) -> { actor.continue(State(..state, mode: control.Searching(input)))
logging.log("musicplayer - recieved raw input: " <> content) }
False -> {
logging.log(
"musicplayer - recieved return. `input`: "
<> "'"
<> input
<> "'",
)
let content = case state.mode { update_search(state.ui, "")
Idle -> state.input.content
Searching -> { actor.continue(State(..state, mode: control.Idle))
let updated = state.input.content <> content }
update_search(state.ui, "searching: " <> updated) }
updated }
control.TogglePlayPause -> {
logging.log("musicplayer - toggling play/pause")
process.send(state.mpv, mpv_control.TogglePlayPause)
update_playback_time(state.mpv, state.ui)
actor.continue(state)
}
control.Exit -> {
logging.log("musicplayer - initiating musicplayer shutdown")
// Close `mpv` socket
process.call(state.mpv, 1000, fn(reply_to) {
mpv_control.Exit(reply_to)
})
// Reset terminal state (show cursor etc.)
process.call(state.ui, 1000, fn(reply_to) {
ui_control.Exit(reply_to)
})
logging.log("musicplayer - stopped")
actor.stop()
} }
} }
actor.continue(State(..state, input: Input(..state.input, content:)))
}
control.Backspace -> {
logging.log("musicplayer - recieved backspace")
let content = case state.mode {
Idle -> state.input.content
Searching -> {
let updated = string.drop_end(state.input.content, 1)
update_search(state.ui, "searching: " <> updated)
updated
}
}
actor.continue(State(..state, input: Input(..state.input, content:)))
}
control.Return -> {
logging.log(
"musicplayer - recieved return. `input.capture`: "
<> "'"
<> state.input.content
<> "'",
)
// Note: state.input.content is now the final input, use it
// before it is reset
case state.mode {
Idle -> Nil
Searching -> update_search(state.ui, "")
}
actor.continue(
State(..state, mode: Idle, input: Input(capturing: False, content: "")),
)
}
control.TogglePlayPause -> {
logging.log("musicplayer - toggling play/pause")
process.send(state.mpv, mpv_control.TogglePlayPause)
update_playback_time(state.mpv, state.ui)
actor.continue(state)
}
control.Exit -> {
logging.log("musicplayer - initiating musicplayer shutdown")
// Close `mpv` socket
process.call(state.mpv, 1000, fn(reply_to) { mpv_control.Exit(reply_to) })
// Reset terminal state (show cursor etc.)
process.call(state.ui, 1000, fn(reply_to) { ui_control.Exit(reply_to) })
logging.log("musicplayer - stopped")
actor.stop()
}
} }
} }
@@ -189,14 +155,21 @@ fn update_search(ui: Subject(ui_control.Control), content: String) -> Nil {
process.send(ui, ui_control.UpdateState(layout.Search, content)) process.send(ui, ui_control.UpdateState(layout.Search, content))
} }
/// `handle_key` listens to a subject onto which `input` will send messages with `Key`s fn update_current_view(
fn handle_key(musicplayer: Subject(Control), input_keys: Subject(Key)) -> Nil { ui: Subject(ui_control.Control),
view_idx: layout.ViewIdx,
) {
process.send(ui, ui_control.SetView(view_idx))
}
/// `forward_key` listens to a subject onto which `input` will send messages with `Key`s
/// that is then forwarded to the `musicplayer` agent to handle
fn forward_key(musicplayer: Subject(Key), input_keys: Subject(Key)) -> Nil {
let _ = let _ =
process.new_selector() process.new_selector()
|> process.select(input_keys) |> process.select(input_keys)
|> process.selector_receive_forever |> process.selector_receive_forever
|> control.from_key |> process.send(musicplayer, _)
|> result.map(process.send(musicplayer, _))
handle_key(musicplayer, input_keys) forward_key(musicplayer, input_keys)
} }

View File

@@ -1,10 +1,11 @@
import gleam/erlang/process.{type Subject} import gleam/erlang/process.{type Subject}
import musicplayer/ui/layout.{type Section} import musicplayer/ui/layout.{type Section, type ViewIdx}
pub type Control { pub type Control {
UpdateDimensions(columns: Int, rows: Int) UpdateDimensions(columns: Int, rows: Int)
UpdateState(section: Section, content: String) UpdateState(section: Section, content: String)
SetView(view_idx: ViewIdx)
Exit(reply_to: Subject(Nil)) Exit(reply_to: Subject(Nil))
} }

View File

@@ -5,7 +5,6 @@ import gleam/pair
import gleam/set import gleam/set
import gleam/string import gleam/string
import musicplayer/logging/logging
import musicplayer/ui/internal import musicplayer/ui/internal
import musicplayer/ui/plot.{type Buffer} import musicplayer/ui/plot.{type Buffer}
@@ -85,7 +84,7 @@ fn view_loop(i: ViewIdx, view_nodes: List(#(Section, Node))) -> View {
dict.from_list(view_nodes) dict.from_list(view_nodes)
|> dict.insert( |> dict.insert(
Section(string.append("view_", string.inspect(i))), view_index_section(i),
Row( Row(
content: "", content: "",
style: Style(dimensions: Percent(width: 100, height: 100)), style: Style(dimensions: Percent(width: 100, height: 100)),
@@ -94,6 +93,11 @@ fn view_loop(i: ViewIdx, view_nodes: List(#(Section, Node))) -> View {
) )
} }
/// Takes a ViewIndex and create a Section key from it
fn view_index_section(view_idx: ViewIdx) -> Section {
Section(string.append("view_", int.to_string(view_idx)))
}
pub fn update_section( pub fn update_section(
layout: Layout, layout: Layout,
section: Section, section: Section,
@@ -125,13 +129,11 @@ pub fn update_dimensions(layout: Layout, columns: Int, rows: Int) -> Layout {
Layout(..layout, columns:, rows:) Layout(..layout, columns:, rows:)
} }
pub fn render(layout: Layout) -> Nil { pub fn update_current_view(layout: Layout, view_idx: ViewIdx) -> Layout {
[layout.columns, layout.rows] Layout(..layout, current_view: view_idx)
|> list.map(int.to_string) }
|> string.join(" ")
|> string.append("layout - render: ", _)
|> logging.log
pub fn render(layout: Layout) -> Nil {
let context = let context =
RenderContext( RenderContext(
parent_width: layout.columns, parent_width: layout.columns,
@@ -149,7 +151,7 @@ pub fn render(layout: Layout) -> Nil {
render_loop( render_loop(
view, view,
context, context,
Section(string.append("view_", string.inspect(layout.current_view))), view_index_section(layout.current_view),
buffer, buffer,
) )
|> plot.flush_buffer(layout.columns, layout.rows) |> plot.flush_buffer(layout.columns, layout.rows)

View File

@@ -29,6 +29,7 @@ pub fn text(buffer: Buffer, text: String, x: Int, y: Int) -> Buffer {
} }
pub fn box(buffer: Buffer, x: Int, y: Int, width: Int, height: Int) -> Buffer { pub fn box(buffer: Buffer, x: Int, y: Int, width: Int, height: Int) -> Buffer {
// TODO move box style to `layout.Style`
let box_chars = #("", "", "", "", "", "") let box_chars = #("", "", "", "", "", "")
let #(tl, tr, bl, br, hor, ver) = box_chars let #(tl, tr, bl, br, hor, ver) = box_chars

View File

@@ -23,7 +23,31 @@ pub fn new() -> Result(Subject(Control), String) {
#( #(
layout.Header, layout.Header,
layout.Row( layout.Row(
content: "Foo (1) | Bar (2) | Baz (3)", content: "Foo <1> | Bar (2)",
style: layout.Style(dimensions: layout.Percent(
width: 100,
height: 50,
)),
children: [],
),
),
#(
layout.PlaybackTime,
layout.Row(
content: "00:00",
style: layout.Style(dimensions: layout.Percent(
width: 100,
height: 50,
)),
children: [],
),
),
],
[
#(
layout.Header,
layout.Row(
content: "Foo (1) | Bar <2>",
style: layout.Style(dimensions: layout.Percent( style: layout.Style(dimensions: layout.Percent(
width: 100, width: 100,
height: 33, height: 33,
@@ -120,6 +144,12 @@ fn handle_message(
process.send(reply_to, Nil) process.send(reply_to, Nil)
actor.stop() actor.stop()
} }
control.SetView(view_idx) -> {
let layout = layout.update_current_view(state.layout, view_idx)
actor.send(state.redraw, layout)
actor.continue(State(..state, layout:))
}
} }
} }

View File

@@ -1,7 +1,7 @@
import gleam/list import gleam/list
import gleeunit import gleeunit
import musicplayer/control.{type Control} import musicplayer/control.{type Control, type Mode}
import musicplayer/input/key.{type Key, Char} import musicplayer/input/key.{type Key, Char}
pub fn main() -> Nil { pub fn main() -> Nil {
@@ -9,16 +9,24 @@ pub fn main() -> Nil {
} }
type TestCase { type TestCase {
TestCase(key: Key, expected: Result(Control, Nil)) TestCase(key: Key, mode: Mode, expected: Result(Control, Nil))
} }
pub fn control_from_key_test() { pub fn control_from_key_test() {
let test_cases = [ let idle_tests = [
TestCase(Char(" "), Ok(control.TogglePlayPause)), TestCase(Char(" "), control.Idle, Ok(control.TogglePlayPause)),
TestCase(Char("q"), Ok(control.Exit)), TestCase(Char("/"), control.Idle, Ok(control.Search("", True))),
TestCase(Char("q"), control.Idle, Ok(control.Exit)),
] ]
list.each(test_cases, fn(tc) { let search_tests = [
assert tc.expected == control.from_key(tc.key) TestCase(Char("a"), control.Searching(""), Ok(control.Search("a", True))),
TestCase(Char("b"), control.Searching("a"), Ok(control.Search("ab", True))),
]
let test_cases = [idle_tests, search_tests]
list.each(list.flatten(test_cases), fn(tc) {
assert tc.expected == control.from_key(tc.key, tc.mode)
}) })
} }