4 Commits

Author SHA1 Message Date
Alexander Heldt
693eaf44bd working-but-not-columnwise 2025-11-29 21:43:59 +01:00
Alexander Heldt
6ef3e9734d wip-working-ish 2025-11-29 20:46:35 +01:00
Alexander Heldt
e524a865fe Move render_layout to layout module 2025-11-29 19:03:37 +01:00
Alexander Heldt
5e8ba9a4b0 Don't prefix internal modules 2025-11-29 18:59:28 +01:00
14 changed files with 357 additions and 712 deletions

View File

@@ -8,14 +8,15 @@ import musicplayer/musicplayer
import musicplayer/ui/ui import musicplayer/ui/ui
pub fn main() -> Nil { pub fn main() -> Nil {
let assert Ok(_) = logging.initialize() let assert Ok(logger) = logging.new("/tmp/musicplayer.log")
let input_keys_name: Name(Key) = process.new_name("input_keys") let input_keys_name: Name(Key) = process.new_name("input_keys")
input.new(input_keys_name) input.new(input_keys_name)
let assert Ok(ui) = ui.new() let assert Ok(ui) = ui.new(logger)
let assert Ok(mpv) = mpv.new() let assert Ok(mpv) = mpv.new()
let assert Ok(musicplayer_pid) = musicplayer.new(ui, mpv, input_keys_name) let assert Ok(musicplayer_pid) =
musicplayer.new(logger, ui, mpv, input_keys_name)
let monitor = process.monitor(musicplayer_pid) let monitor = process.monitor(musicplayer_pid)
process.new_selector() process.new_selector()

View File

@@ -1,58 +1,30 @@
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(input: String, capturing: Bool) Search
SetView(view_idx: layout.ViewIdx) Raw(String)
Return
Backspace
Exit Exit
} }
pub fn from_key(key: Key, mode: Mode) -> Result(Control, Nil) { pub fn from_key(key: Key) -> 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.Char(char) -> { key.Return -> Ok(Return)
case char { key.Backspace -> Ok(Backspace)
// Views are zero indexed key.Char(char) -> Ok(char_control(char))
"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)
} }
} }
pub fn searching_from_key(key: Key, input: String) -> Result(Control, Nil) { fn char_control(char: String) -> Control {
case key { case char {
key.Char(char) -> Ok(Search(input <> char, True)) " " -> TogglePlayPause
key.Backspace -> Ok(Search(string.drop_end(input, 1), True)) "/" -> Search
key.Return -> Ok(Search(input, False)) "q" -> Exit
_ -> Raw(char)
// NOOP
_ -> Error(Nil)
} }
} }

View File

@@ -1,5 +1,7 @@
import gleam/erlang/process.{type Subject}
pub type Control { pub type Control {
Write(String) Write(String)
Exit Exit(reply_to: Subject(Nil))
} }

View File

@@ -1,30 +1,58 @@
import gleam/erlang/process.{type Subject}
import gleam/otp/actor
import gleam/result import gleam/result
import gleam/string import gleam/string
import gleam/time/calendar import gleam/time/calendar
import gleam/time/timestamp import gleam/time/timestamp
import simplifile import simplifile
const filepath = "/tmp/musicplayer.log" import musicplayer/logging/control.{type Control}
pub fn initialize() -> Result(Nil, String) { type State {
case simplifile.is_file(filepath) { State(filepath: String)
Ok(True) -> Ok(Nil) }
_ -> simplifile.create_file(filepath)
} pub fn new(filepath: String) -> Result(Subject(Control), String) {
|> result.map_error(fn(e) { use _ <- result.try(
"Could not access or create log file: " <> string.inspect(e) case simplifile.is_file(filepath) {
Ok(True) -> Ok(Nil)
_ -> simplifile.create_file(filepath)
}
|> result.map_error(fn(e) {
"Could not access or create log file: " <> string.inspect(e)
}),
)
actor.new(State(filepath:))
|> actor.on_message(handle_message)
|> actor.start
|> result.map_error(fn(start_error) {
"Could not start logger: " <> string.inspect(start_error)
}) })
|> result.map(fn(started) { started.data })
} }
pub fn log(content: String) -> Nil { fn handle_message(state: State, control: Control) -> actor.Next(State, Control) {
let log_line = case control {
timestamp.system_time() control.Write(content) -> {
|> timestamp.to_rfc3339(calendar.utc_offset) let log_line =
<> ": " timestamp.system_time()
<> content |> timestamp.to_rfc3339(calendar.utc_offset)
<> "\n" <> ": "
<> content
<> "\n"
// Ignore any logging errors // Ignore any logging errors
let _ = simplifile.append(filepath, log_line) let _ = simplifile.append(state.filepath, log_line)
Nil actor.continue(state)
}
control.Exit(reply_to) -> {
process.send(reply_to, Nil)
actor.stop()
}
}
}
pub fn log(logger: Subject(Control), content: String) -> Nil {
process.send(logger, control.Write(content))
} }

View File

@@ -1,112 +1,151 @@
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 Mode} import musicplayer/control.{type Control}
import musicplayer/input/key.{type Key} import musicplayer/input/key.{type Key}
import musicplayer/logging/control as logging_control
import musicplayer/logging/logging import musicplayer/logging/logging
import musicplayer/mpv/control as mpv_control import musicplayer/mpv/control as mpv_control
import musicplayer/time/time 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,
logger: Subject(logging_control.Control),
ui: Subject(ui_control.Control), ui: Subject(ui_control.Control),
mpv: Subject(mpv_control.Control), mpv: Subject(mpv_control.Control),
) )
} }
pub fn new( pub fn new(
logger: Subject(logging_control.Control),
ui: Subject(ui_control.Control), ui: Subject(ui_control.Control),
mpv: Subject(mpv_control.Control), mpv: Subject(mpv_control.Control),
input_keys_name: Name(Key), input_keys_name: Name(Key),
) -> 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(control.Idle, ui, mpv)) actor.new(State(Idle, input, logger, ui, mpv))
|> actor.on_message(handle_message) |> actor.on_message(handle_message)
|> actor.start |> actor.start
{ {
Error(start_error) -> Error(start_error) ->
Error("Could not start actor: " <> string.inspect(start_error)) Error("Could not start actor: " <> string.inspect(start_error))
Ok(actor.Started(pid:, data: musicplayer)) -> { Ok(actor.Started(pid:, data: musicplayer)) -> {
logging.log("musicplayer - started") logging.log(logger, "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)
forward_key(musicplayer, input_keys) handle_key(musicplayer, input_keys)
}) })
process.spawn(fn() { update_playback_time_loop(mpv, ui, 250) }) process.spawn(fn() { update_playback_time_loop(mpv, ui, 1000) })
Ok(pid) Ok(pid)
} }
} }
} }
fn handle_message(state: State, key: Key) -> actor.Next(State, Key) { fn handle_message(state: State, control: Control) -> actor.Next(State, Control) {
case control.from_key(key, state.mode) { case control {
Error(_) -> actor.continue(state) control.Search -> {
Ok(c) -> logging.log(state.logger, "musicplayer - initiating search")
case c {
control.SetView(view_idx) -> {
logging.log(
"musicplayer - setting current view to: "
<> string.inspect(view_idx),
)
update_current_view(state.ui, view_idx) update_search(state.ui, "searching: ")
actor.continue(state)
}
control.Search(input, capturing) -> {
case capturing {
True -> {
logging.log("musicplayer - searching: " <> input)
update_search(state.ui, "searching: " <> input) actor.continue(
State(
..state,
mode: Searching,
input: Input(..state.input, capturing: True),
),
)
}
actor.continue(State(..state, mode: control.Searching(input))) control.Raw(content) -> {
} logging.log(state.logger, "musicplayer - recieved raw input: " <> content)
False -> {
logging.log(
"musicplayer - recieved return. `input`: "
<> "'"
<> input
<> "'",
)
update_search(state.ui, "") let content = case state.mode {
Idle -> state.input.content
actor.continue(State(..state, mode: control.Idle)) Searching -> {
} 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(state.logger, "musicplayer - recieved backspace")
let content = case state.mode {
Idle -> state.input.content
Searching -> string.drop_end(state.input.content, 1)
}
actor.continue(State(..state, input: Input(..state.input, content:)))
}
control.Return -> {
logging.log(
state.logger,
"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(state.logger, "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(state.logger, "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(state.logger, "musicplayer - stopped")
// Close logger (NOOP)
process.call(state.logger, 1000, fn(reply_to) {
logging_control.Exit(reply_to)
})
actor.stop()
}
} }
} }
@@ -155,21 +194,14 @@ 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))
} }
fn update_current_view( /// `handle_key` listens to a subject onto which `input` will send messages with `Key`s
ui: Subject(ui_control.Control), fn handle_key(musicplayer: Subject(Control), input_keys: Subject(Key)) -> Nil {
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
|> process.send(musicplayer, _) |> control.from_key
|> result.map(process.send(musicplayer, _))
forward_key(musicplayer, input_keys) handle_key(musicplayer, input_keys)
} }

View File

@@ -1,11 +1,10 @@
import gleam/erlang/process.{type Subject} import gleam/erlang/process.{type Subject}
import musicplayer/ui/layout.{type Section, type ViewIdx} import musicplayer/ui/layout.{type Section}
pub type Control { pub type Control {
UpdateDimensions(columns: Int, rows: Int) UpdateDimensions(width: Int, height: 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

@@ -3,23 +3,13 @@ import gleam/io
// https://en.wikipedia.org/wiki/ANSI_escape_code#Control_Sequence_Introducer_commands // https://en.wikipedia.org/wiki/ANSI_escape_code#Control_Sequence_Introducer_commands
pub const move_to_home = "\u{001B}[H"
pub const disable_auto_wrap = "\u{001B}[?7l"
pub const enable_auto_wrap = "\u{001B}[?7h"
pub fn update(frame: String) -> Nil {
io.print(disable_auto_wrap <> move_to_home <> frame <> enable_auto_wrap)
}
pub fn clear_screen() -> Nil { pub fn clear_screen() -> Nil {
io.print("\u{001B}[2J\u{001B}[H") io.print("\u{001B}[2J\u{001B}[H")
} }
pub fn chars_at(chars: String, x: Int, y: Int) -> String { pub fn print_at(text: String, x: Int, y: Int) -> Nil {
let seq = "\u{001B}[" <> int.to_string(y) <> ";" <> int.to_string(x) <> "H" let seq = "\u{001B}[" <> int.to_string(y) <> ";" <> int.to_string(x) <> "H"
seq <> chars io.print(seq <> text)
} }
pub fn hide_cursor() -> Nil { pub fn hide_cursor() -> Nil {

View File

@@ -1,101 +1,63 @@
import gleam/dict import gleam/dict
import gleam/erlang/process.{type Subject}
import gleam/float
import gleam/int import gleam/int
import gleam/list import gleam/list
import gleam/pair
import gleam/set
import gleam/string import gleam/string
import musicplayer/logging/control as logging_control
import musicplayer/logging/logging
import musicplayer/ui/internal import musicplayer/ui/internal
import musicplayer/ui/plot.{type Buffer}
pub const root_section = "reserved_root_section" pub type Layout {
Layout(width: Int, height: Int, nodes: dict.Dict(Section, Node))
}
pub type Section { pub type Section {
Section(String) Root
Header Header
Search Search
PlaybackTime PlaybackTime
} }
pub type Dimension { /// A Nodes width and height is in percentage (of the available width/height of its parent Node)
Percent(width: Int, height: Int)
// TODO add Flex that flows
}
pub type Style {
Style(dimensions: Dimension)
}
pub type Node { pub type Node {
Row(content: String, style: Style, children: List(Section)) Node(
Cell(content: String, style: Style) content: String,
} width_percent: Int,
height_percent: Int,
pub type ViewIdx = children: List(Section),
Int
pub type View =
dict.Dict(Section, Node)
// Layout consists of a list Views, and only one View is rendered at a time
pub type Layout {
Layout(
columns: Int,
rows: Int,
current_view: ViewIdx,
views: dict.Dict(ViewIdx, View),
) )
} }
pub fn new( pub fn new() -> Layout {
columns: Int, let nodes =
rows: Int, dict.from_list([
views: List(List(#(Section, Node))), #(
) -> Layout { Root,
let views = Node(content: "", width_percent: 100, height_percent: 100, children: [
list.index_map(views, fn(view_nodes, i) { #(i, view_nodes) }) // Header,
|> list.fold(dict.new(), fn(view_acc, iv) { // Search,
let #(i, view_nodes) = iv PlaybackTime,
]),
),
// #(
// Header,
// Node(content: "Music Player", width: 50, height: 10, children: []),
// ),
// #(Search, Node(content: "", width: 50, height: 10, children: [])),
#(
PlaybackTime,
Node(
content: "00:00",
width_percent: 50,
height_percent: 100,
children: [],
),
),
])
dict.insert(view_acc, i, view_loop(i, view_nodes)) Layout(0, 0, nodes: nodes)
})
Layout(columns:, rows:, current_view: 0, views:)
}
fn view_loop(i: ViewIdx, view_nodes: List(#(Section, Node))) -> View {
let children =
view_nodes
|> list.flat_map(fn(node) {
case pair.second(node) {
Row(children: c, ..) -> c
Cell(..) -> []
}
})
|> set.from_list
// All sections that are not children of other nodes will be added as
// children to the root
let orphans =
view_nodes
|> list.map(pair.first)
|> list.filter(fn(node) { !set.contains(children, node) })
dict.from_list(view_nodes)
|> dict.insert(
view_index_section(i),
Row(
content: "",
style: Style(dimensions: Percent(width: 100, height: 100)),
children: orphans,
),
)
}
/// 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(
@@ -103,146 +65,128 @@ pub fn update_section(
section: Section, section: Section,
content: String, content: String,
) -> Layout { ) -> Layout {
case dict.get(layout.views, layout.current_view) { case dict.get(layout.nodes, section) {
Error(_) -> layout Error(_) -> layout
Ok(view) -> Ok(node) ->
case dict.get(view, section) { Layout(
Error(_) -> layout ..layout,
Ok(node) -> { nodes: dict.insert(
let updated_node = case node { layout.nodes,
Cell(..) -> Cell(..node, content: content) section,
Row(..) -> Row(..node, content: content) Node(..node, content: content),
} ),
let updated_view = dict.insert(view, section, updated_node)
Layout(
..layout,
views: dict.insert(layout.views, layout.current_view, updated_view),
)
}
}
}
}
pub fn update_dimensions(layout: Layout, columns: Int, rows: Int) -> Layout {
Layout(..layout, columns:, rows:)
}
pub fn update_current_view(layout: Layout, view_idx: ViewIdx) -> Layout {
Layout(..layout, current_view: view_idx)
}
pub fn render(layout: Layout) -> Nil {
let context =
RenderContext(
parent_width: layout.columns,
parent_height: layout.rows,
parent_top_left_x: 1,
parent_top_left_y: 1,
position_index: 0,
)
case dict.get(layout.views, layout.current_view) {
Error(_) -> Nil
Ok(view) -> {
let buffer: Buffer = dict.new()
render_loop(
view,
context,
view_index_section(layout.current_view),
buffer,
) )
|> plot.flush_buffer(layout.columns, layout.rows)
|> internal.update
}
} }
} }
pub type RenderContext { pub fn update_dimensions(layout: Layout, width: Int, height: Int) -> Layout {
RenderContext( Layout(..layout, width:, height:)
parent_width: Int, }
parent_height: Int,
parent_top_left_x: Int, pub fn render(logger: Subject(logging_control.Control), layout: Layout) -> Nil {
parent_top_left_y: Int, internal.clear_screen()
position_index: Int, [layout.width, layout.height]
|> list.map(int.to_string)
|> string.join(" ")
|> string.append("layout - render: ", _)
|> logging.log(logger, _)
let container_width = int.to_float(layout.width)
let container_height = int.to_float(layout.height)
let container_top_left_x = 1
let container_top_left_y = 1
render_loop(
layout,
container_width,
container_height,
container_top_left_x,
container_top_left_y,
Root,
logger,
) )
} }
pub fn render_loop( pub fn render_loop(
view: View, layout: Layout,
context: RenderContext, container_width: Float,
container_height: Float,
container_top_left_x: Int,
container_top_left_y: Int,
from: Section, from: Section,
buffer: Buffer, logger: Subject(logging_control.Control),
) -> Buffer { ) -> Nil {
case dict.get(view, from) { let margin = 2.0
Error(_) -> buffer
case dict.get(layout.nodes, from) {
Error(_) -> Nil
Ok(node) -> { Ok(node) -> {
// Margin between container and the node being rendered list.each(node.children, fn(child) {
let margin = 2 let cw =
container_width
*. { int.to_float(node.width_percent) /. 100.0 }
-. margin
|> float.floor
let #(node_width, node_height) = case node.style.dimensions { let ch =
Percent(width:, height:) -> { container_height
let width = { context.parent_width * width } / 100 *. { int.to_float(node.height_percent) /. 100.0 }
let height = { context.parent_height * height } / 100 -. margin
|> float.floor
#(width, height) let cx = container_top_left_x + 1
} let cy = container_top_left_y + 1
}
// Check if this node should be placed to the left or below the parent render_loop(layout, cw, ch, cx, cy, child, logger)
let #(node_top_left_x, node_top_left_y) = case node { })
Row(..) -> #(
context.parent_top_left_x,
context.parent_top_left_y + { context.position_index * node_height },
)
Cell(..) -> #(
context.parent_top_left_x + { context.position_index * node_width },
context.parent_top_left_y,
)
}
let parent = logging.log(logger, "section: " <> string.inspect(from))
plot.box( logging.log(
buffer, logger,
node_top_left_x, "container width: " <> float.to_string(container_width),
node_top_left_y, )
node_width, logging.log(
node_height, logger,
) "container height: " <> float.to_string(container_height),
|> plot.text(node.content, node_top_left_x, node_top_left_y) )
case node { let width =
Cell(..) -> parent container_width
Row(children:, ..) -> { *. { int.to_float(node.width_percent) /. int.to_float(100) }
list.index_map(children, fn(child, i) { #(i, child) }) |> float.floor
|> list.fold(parent, fn(acc_buffer, ic) { |> float.truncate
let #(i, child) = ic
let #(child_width, child_height) = case node.style.dimensions { let height =
Percent(width:, height:) -> { container_height
let width = { { context.parent_width * width } / 100 } - margin *. { int.to_float(node.height_percent) /. int.to_float(100) }
let height = |> float.floor
{ { context.parent_height * height } / 100 } - margin |> float.truncate
#(width, height) logging.log(logger, "width: " <> int.to_string(width))
} logging.log(logger, "height: " <> int.to_string(height))
}
let context = let cx = container_top_left_x
RenderContext( let cy = container_top_left_y
parent_width: child_width, logging.log(logger, "cx: " <> int.to_string(cx))
parent_height: child_height, logging.log(logger, "cy: " <> int.to_string(cy))
parent_top_left_x: context.parent_top_left_x + 1,
parent_top_left_y: context.parent_top_left_y + 1,
position_index: i,
)
render_loop(view, context, child, acc_buffer) draw_box(cx, cy, width, height)
}) // Box heading
} internal.print_at(node.content, cx, cy)
}
} }
} }
} }
fn draw_box(x: Int, y: Int, width: Int, height: Int) -> Nil {
let box_chars = #("", "", "", "", "", "")
let #(tl, tr, bl, br, h, v) = box_chars
internal.print_at(tl <> string.repeat(h, width - 2) <> tr, x, y)
list.range(1, height - 2)
|> list.each(fn(row) {
internal.print_at(v, x, y + row)
internal.print_at(v, x + width - 1, y + row)
})
internal.print_at(bl <> string.repeat(h, width - 2) <> br, x, y + height - 1)
}

View File

@@ -1,58 +0,0 @@
import musicplayer/ui/internal
import musicplayer/ui/layout.{Percent, Section, Style}
import musicplayer/ui/layout_examples/wait_for_input.{wait_for_input}
pub fn main() {
let assert Ok(columns) = internal.io_get_columns()
let assert Ok(rows) = internal.io_get_rows()
two_rows_with_cells(columns, rows)
|> layout.render
wait_for_input()
}
/// Two rows:
/// First row has two cells
/// Second row has no cells
fn two_rows_with_cells(columns: Int, rows: Int) -> layout.Layout {
let views = [
[
#(
Section("Row1"),
layout.Row(
content: "row 1",
style: Style(dimensions: Percent(width: 100, height: 50)),
children: [
Section("A"),
Section("B"),
],
),
),
#(
Section("A"),
layout.Cell(
content: "cell 1",
style: Style(dimensions: Percent(width: 50, height: 50)),
),
),
#(
Section("B"),
layout.Cell(
content: "cell 2",
style: Style(dimensions: Percent(width: 50, height: 50)),
),
),
#(
Section("Row2"),
layout.Row(
content: "row 2",
style: Style(dimensions: Percent(width: 50, height: 50)),
children: [],
),
),
],
]
layout.new(columns, rows, views)
}

View File

@@ -1,15 +0,0 @@
import gleam/erlang/process.{type Name}
import musicplayer/input/input
import musicplayer/input/key.{type Key}
pub fn wait_for_input() {
let input_keys_name: Name(Key) = process.new_name("input_keys")
let assert Ok(_) = process.register(process.self(), input_keys_name)
input.new(input_keys_name)
process.new_selector()
|> process.select(process.named_subject(input_keys_name))
|> process.selector_receive_forever
}

View File

@@ -1,72 +0,0 @@
import gleam/dict.{type Dict}
import gleam/list
import gleam/string
pub type Buffer =
Dict(#(Int, Int), String)
pub fn flush_buffer(buffer: Buffer, columns: Int, rows: Int) -> String {
list.range(1, rows)
|> list.map(fn(y) {
list.range(1, columns)
|> list.map(fn(x) {
case dict.get(buffer, #(x, y)) {
Ok(char) -> char
Error(_) -> " "
}
})
|> string.join("")
})
|> string.join("\r\n")
}
pub fn text(buffer: Buffer, text: String, x: Int, y: Int) -> Buffer {
text
|> string.to_graphemes
|> list.index_fold(buffer, fn(acc, char, i) {
dict.insert(acc, #(x + i, y), char)
})
}
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 #(tl, tr, bl, br, hor, ver) = box_chars
case width < 2 || height < 2 {
True -> buffer
False -> {
buffer
|> dict.insert(#(x, y), tl)
|> dict.insert(#(x + width - 1, y), tr)
|> dict.insert(#(x, y + height - 1), bl)
|> dict.insert(#(x + width - 1, y + height - 1), br)
|> horizontal_line(x + 1, y, width - 2, hor)
|> horizontal_line(x + 1, y + height - 1, width - 2, hor)
|> vertical_line(x, y + 1, height - 2, ver)
|> vertical_line(x + width - 1, y + 1, height - 2, ver)
}
}
}
fn horizontal_line(
buffer: Buffer,
x: Int,
y: Int,
len: Int,
char: String,
) -> Buffer {
list.range(0, len - 1)
|> list.fold(buffer, fn(acc, i) { dict.insert(acc, #(x + i, y), char) })
}
fn vertical_line(
buffer: Buffer,
x: Int,
y: Int,
len: Int,
char: String,
) -> Buffer {
list.range(0, len - 1)
|> list.fold(buffer, fn(acc, i) { dict.insert(acc, #(x, y + i), char) })
}

View File

@@ -4,85 +4,30 @@ import gleam/list
import gleam/otp/actor import gleam/otp/actor
import gleam/string import gleam/string
import musicplayer/logging/control as logging_control
import musicplayer/logging/logging import musicplayer/logging/logging
import musicplayer/ui/control.{type Control} import musicplayer/ui/control.{type Control}
import musicplayer/ui/internal import musicplayer/ui/internal
import musicplayer/ui/layout.{type Layout} import musicplayer/ui/layout.{type Layout}
pub type State(redraw, content) { pub type State(redraw, content) {
State(redraw: Subject(Layout), layout: Layout) State(
logger: Subject(logging_control.Control),
redraw: Subject(Layout),
layout: Layout,
)
} }
pub fn new() -> Result(Subject(Control), String) { pub fn new(
logger: Subject(logging_control.Control),
) -> Result(Subject(Control), String) {
let redraw_name = process.new_name("redraw") let redraw_name = process.new_name("redraw")
let redraw: Subject(Layout) = process.named_subject(redraw_name) let redraw: Subject(Layout) = process.named_subject(redraw_name)
let layout = let layout = layout.new()
[
[
#(
layout.Header,
layout.Row(
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(
width: 100,
height: 33,
)),
children: [],
),
),
#(
layout.Search,
layout.Row(
content: "",
style: layout.Style(dimensions: layout.Percent(
width: 100,
height: 33,
)),
children: [],
),
),
#(
layout.PlaybackTime,
layout.Row(
content: "00:00",
style: layout.Style(dimensions: layout.Percent(
width: 100,
height: 33,
)),
children: [],
),
),
],
]
|> layout.new(0, 0, _)
case case
actor.new(State(redraw, layout)) actor.new(State(logger, redraw, layout))
|> actor.on_message(handle_message) |> actor.on_message(handle_message)
|> actor.start |> actor.start
{ {
@@ -91,7 +36,7 @@ pub fn new() -> Result(Subject(Control), String) {
Ok(actor.Started(data: ui, ..)) -> { Ok(actor.Started(data: ui, ..)) -> {
process.spawn(fn() { process.spawn(fn() {
let update_dimensions_interval_ms = 300 let update_dimensions_interval_ms = 300
update_dimensions_on_interval(ui, update_dimensions_interval_ms) update_dimensions_on_interval(logger, ui, update_dimensions_interval_ms)
}) })
process.spawn(fn() { process.spawn(fn() {
@@ -100,7 +45,7 @@ pub fn new() -> Result(Subject(Control), String) {
internal.clear_screen() internal.clear_screen()
internal.hide_cursor() internal.hide_cursor()
redraw_loop(redraw) redraw_loop(logger, redraw)
}) })
Ok(ui) Ok(ui)
@@ -113,19 +58,19 @@ fn handle_message(
control: Control, control: Control,
) -> actor.Next(State(redraw, layout), Control) { ) -> actor.Next(State(redraw, layout), Control) {
case control { case control {
control.UpdateDimensions(columns, rows) -> { control.UpdateDimensions(width, height) -> {
let current_dimensions = #(state.layout.columns, state.layout.rows) let current_dimensions = #(state.layout.width, state.layout.height)
case #(columns, rows) == current_dimensions { case #(width, height) == current_dimensions {
True -> actor.continue(state) True -> actor.continue(state)
False -> { False -> {
[columns, rows] [width, height]
|> list.map(int.to_string) |> list.map(int.to_string)
|> string.join(" ") |> string.join(" ")
|> string.append("ui - updating dimensions: ", _) |> string.append("ui - updating dimensions: ", _)
|> logging.log |> logging.log(state.logger, _)
let layout = layout.update_dimensions(state.layout, columns, rows) let layout = layout.update_dimensions(state.layout, width, height)
process.send(state.redraw, layout) process.send(state.redraw, layout)
actor.continue(State(..state, layout:)) actor.continue(State(..state, layout:))
@@ -144,30 +89,31 @@ 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:))
}
} }
} }
fn redraw_loop(redraw: Subject(Layout)) -> Nil { fn redraw_loop(
logger: Subject(logging_control.Control),
redraw: Subject(Layout),
) -> Nil {
process.receive_forever(redraw) process.receive_forever(redraw)
|> layout.render |> layout.render(logger, _)
redraw_loop(redraw) redraw_loop(logger, redraw)
} }
fn update_dimensions_on_interval(ui: Subject(Control), interval_ms: Int) { fn update_dimensions_on_interval(
logger: Subject(logging_control.Control),
ui: Subject(Control),
interval_ms: Int,
) {
case internal.io_get_columns(), internal.io_get_rows() { case internal.io_get_columns(), internal.io_get_rows() {
Ok(width), Ok(height) -> { Ok(width), Ok(height) -> {
process.send(ui, control.UpdateDimensions(width, height)) process.send(ui, control.UpdateDimensions(width, height))
} }
_, _ -> logging.log("ui - failed to update dimensions") _, _ -> logging.log(logger, "ui - failed to update dimensions")
} }
process.sleep(interval_ms) process.sleep(interval_ms)
update_dimensions_on_interval(ui, interval_ms) update_dimensions_on_interval(logger, ui, interval_ms)
} }

View File

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

View File

@@ -1,116 +0,0 @@
import gleam/dict
import gleam/io
import gleam/string
import gleeunit
import gleeunit/should
import musicplayer/ui/layout.{Percent, RenderContext, Section, Style}
import musicplayer/ui/plot
pub fn main() -> Nil {
gleeunit.main()
}
pub fn percent_layout_test() {
let views = [
[
#(
Section("Row1"),
layout.Row(
content: "row 1",
style: Style(dimensions: Percent(width: 100, height: 50)),
children: [
Section("A"),
Section("B"),
],
),
),
#(
Section("A"),
layout.Cell(
content: "cell 1",
style: Style(dimensions: Percent(width: 50, height: 100)),
),
),
#(
Section("B"),
layout.Cell(
content: "cell 2",
style: Style(dimensions: Percent(width: 50, height: 100)),
),
),
#(
Section("Row2"),
layout.Row(
content: "row 1",
style: Style(dimensions: Percent(width: 100, height: 50)),
children: [],
),
),
],
]
let columns = 80
let rows = 20
let layout = layout.new(columns, rows, views)
let expected =
"
┌──────────────────────────────────────────────────────────────────────────────┐
│row 1────────────────────────────────────────────────────────────────────────┐│
││cell 1───────────────────────────────┐cell 2───────────────────────────────┐││
│││ ││ │││
│││ ││ │││
│││ ││ │││
│││ ││ │││
│││ ││ │││
││└────────────────────────────────────┘└────────────────────────────────────┘││
│└────────────────────────────────────────────────────────────────────────────┘│
│row 1────────────────────────────────────────────────────────────────────────┐│
││ ││
││ ││
││ ││
││ ││
││ ││
││ ││
││ ││
│└────────────────────────────────────────────────────────────────────────────┘│
└──────────────────────────────────────────────────────────────────────────────┘
"
|> string.replace(each: "\n", with: "\r\n")
|> string.trim
let context =
RenderContext(
parent_width: layout.columns,
parent_height: layout.rows,
parent_top_left_x: 1,
parent_top_left_y: 1,
position_index: 0,
)
let assert Ok(view) = dict.get(layout.views, layout.current_view)
let flushed =
layout.render_loop(
view,
context,
Section(string.append("view_", string.inspect(layout.current_view))),
dict.new(),
)
|> plot.flush_buffer(layout.columns, layout.rows)
case flushed == expected {
True -> Nil
False -> {
io.println("Test failed")
io.println("Expected:")
io.println(string.trim(expected))
io.println("Got:")
io.println(flushed)
should.equal(flushed, expected)
}
}
}