Compare commits

2 Commits

Author SHA1 Message Date
Alexander Heldt
254765c232 json 2025-11-15 22:31:29 +01:00
Alexander Heldt
4c73244787 Map Key to Control 2025-11-15 17:47:59 +01:00
5 changed files with 12 additions and 91 deletions

View File

@@ -1,9 +1,7 @@
import gleam/json
import gleam/result
import gleam/string
import mpv/internal.{type Key, Char}
import mpv/internal/control as control_internal
import mpv/internal.{type Key}
import tcp/reason.{type Reason}
import tcp/tcp.{type Socket}
@@ -12,13 +10,9 @@ pub type Control {
Exit
}
pub type ControlError {
ControlError(details: String)
}
pub fn from_key(key: Key) -> Result(Control, Nil) {
case key {
Char(char) -> char_control(char)
internal.Char(char) -> char_control(char)
_ -> Error(Nil)
}
}
@@ -31,22 +25,15 @@ fn char_control(char: String) -> Result(Control, Nil) {
}
}
pub fn toggle_play_pause(socket: Socket) -> Result(Nil, ControlError) {
pub fn toggle_play_pause(socket: Socket) -> Result(Nil, Reason) {
let command =
json.object([#("command", json.array(["cycle", "pause"], of: json.string))])
case send_command(socket, command) {
Error(r) -> Error(ControlError(reason.to_string(r)))
Ok(_) -> Ok(Nil)
}
result.map(send_command(socket, command), fn(_) { Nil })
}
// https://mpv.io/manual/master/#command-interface-playback-time
pub type PlaybackTime {
PlaybackTime(data: Float)
}
pub fn get_playback_time(socket: Socket) -> Result(PlaybackTime, ControlError) {
pub fn get_playback_time(socket: Socket) -> Result(String, Reason) {
let command =
json.object([
#(
@@ -55,14 +42,7 @@ pub fn get_playback_time(socket: Socket) -> Result(PlaybackTime, ControlError) {
),
])
case send_command(socket, command) {
Error(r) -> Error(ControlError(reason.to_string(r)))
Ok(json_string) ->
case control_internal.parse_playback_time(json_string) {
Error(e) -> Error(ControlError(string.inspect(e)))
Ok(data) -> Ok(PlaybackTime(data))
}
}
send_command(socket, command)
}
fn send_command(socket: Socket, command: json.Json) -> Result(String, Reason) {

View File

@@ -1,25 +0,0 @@
import gleam/dynamic/decode
import gleam/float
import gleam/json
import gleam/string
pub fn parse_playback_time(
json_string: String,
) -> Result(Float, json.DecodeError) {
let decoder = {
let float_dececoder = fn(data_string) {
case float.parse(data_string) {
Error(_) -> decode.failure(0.0, "data")
Ok(float_value) -> decode.success(float_value)
}
}
use data <- decode.field(
"data",
decode.then(decode.string, float_dececoder),
)
decode.success(data)
}
json.parse(from: string.trim(json_string), using: decoder)
}

View File

@@ -1,5 +1,4 @@
import gleam/erlang/process.{type Subject}
import gleam/float
import gleam/otp/actor
import gleam/result
import gleam/string
@@ -45,17 +44,14 @@ fn handle_message(
case control {
control.TogglePlayPause -> {
echo "toggling play/pause"
let _ =
result.map_error(control.toggle_play_pause(state.socket), fn(err) {
echo "Could not toggle play/pause: " <> err.details
result.map_error(control.toggle_play_pause(state.socket), fn(r) {
echo "Could not toggle play/pause: " <> reason.to_string(r)
})
let _ =
result.map(control.get_playback_time(state.socket), fn(playback) {
echo "playback: " <> float.to_string(playback.data)
echo "playback: " <> playback
})
actor.continue(state)
}
control.Exit -> {

View File

@@ -4,6 +4,8 @@ pub type Reason {
/// from `send`
Closed
Overflow
/// Address already in use
Eaddrinuse
/// Cannot assign requested address
@@ -158,6 +160,7 @@ pub type Reason {
pub fn to_string(reason: Reason) -> String {
case reason {
Overflow -> "overflow"
Closed -> "Connection closed (closed)"
Eacces -> "Permission denied (eacces)"
Eaddrinuse -> "Address already in use (eaddrinuse)"

View File

@@ -1,33 +0,0 @@
import gleam/list
import gleeunit
import mpv/control.{type Control}
import mpv/internal.{type Key, Char}
import mpv/internal/control as control_internal
pub fn main() -> Nil {
gleeunit.main()
}
type TestCase {
TestCase(key: Key, expected: Result(Control, Nil))
}
pub fn control_from_key_test() {
let test_cases = [
TestCase(Char(" "), Ok(control.TogglePlayPause)),
TestCase(Char("q"), Ok(control.Exit)),
]
list.each(test_cases, fn(tc) {
assert tc.expected == control.from_key(tc.key)
})
}
pub fn parse_playback_time_test() {
let json_string =
"{\"data\":\"123.456789\",\"request_id\":0,\"error\":\"success\"}\n"
let assert Ok(data) = control_internal.parse_playback_time(json_string)
assert data == 123.456789
}