This commit is contained in:
Alexander Heldt
2025-11-16 15:47:00 +01:00
parent c3df22ecd8
commit 3fb92d4654
3 changed files with 36 additions and 52 deletions

View File

@@ -1,9 +1,8 @@
import gleam/dynamic/decode
import gleam/float
import gleam/json
import gleam/result
import gleam/string
import mpv/internal/control as internal_control
import mpv/key.{type Key, Char}
import tcp/reason.{type Reason}
import tcp/tcp.{type Socket}
@@ -58,32 +57,12 @@ 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) -> parse_playback_time(json_string)
}
}
fn parse_playback_time(
json_string: String,
) -> Result(PlaybackTime, ControlError) {
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)
Ok(json_string) ->
case internal_control.parse_playback_time(json_string) {
Error(e) -> Error(ControlError(string.inspect(e)))
Ok(data) -> Ok(PlaybackTime(data))
}
}
use data <- decode.field(
"data",
decode.then(decode.string, float_dececoder),
)
decode.success(PlaybackTime(data))
}
result.map_error(
json.parse(from: string.trim(json_string), using: decoder),
fn(r) { ControlError(string.inspect(r)) },
)
}
fn send_command(socket: Socket, command: json.Json) -> Result(String, Reason) {