Compare commits
2 Commits
efe14200fe
...
1e79274187
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1e79274187 | ||
|
|
9cd1bf2898 |
@@ -1,17 +1,16 @@
|
||||
import gleam/io
|
||||
import gleam/json
|
||||
import gleam/result
|
||||
import gleam/string
|
||||
|
||||
import input/key.{type Key}
|
||||
import mpv/internal/control as internal_control
|
||||
import mpv/key.{type Key}
|
||||
import tcp/reason.{type Reason}
|
||||
import tcp/tcp.{type Socket}
|
||||
|
||||
pub type Control {
|
||||
TogglePlayPause
|
||||
|
||||
Search
|
||||
|
||||
Exit
|
||||
}
|
||||
|
||||
@@ -20,7 +19,6 @@ pub type ControlError {
|
||||
}
|
||||
|
||||
pub fn from_key(key: Key) -> Result(Control, Nil) {
|
||||
echo key
|
||||
case key {
|
||||
key.Char(char) -> char_control(char)
|
||||
_ -> Error(Nil)
|
||||
@@ -31,7 +29,6 @@ fn char_control(char: String) -> Result(Control, Nil) {
|
||||
case char {
|
||||
" " -> Ok(TogglePlayPause)
|
||||
"q" -> Ok(Exit)
|
||||
"/" -> Ok(Search)
|
||||
_ -> Error(Nil)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
import gleam/erlang/atom
|
||||
import gleam/list
|
||||
|
||||
import input/internal as internal_input
|
||||
import mpv/internal/key as internal_key
|
||||
|
||||
pub type Key {
|
||||
Char(String)
|
||||
@@ -52,12 +51,12 @@ pub fn from_list(l: List(String)) -> Key {
|
||||
pub fn start_raw_shell() {
|
||||
let no_shell = atom.create("noshell")
|
||||
let raw = atom.create("raw")
|
||||
internal_input.shell_start_interactive(#(no_shell, raw))
|
||||
internal_key.shell_start_interactive(#(no_shell, raw))
|
||||
}
|
||||
|
||||
pub fn read_input_until_key(l: List(String)) -> Key {
|
||||
case
|
||||
internal_input.read_input()
|
||||
internal_key.read_input()
|
||||
|> list.wrap
|
||||
|> list.append(l, _)
|
||||
|> from_list
|
||||
@@ -4,8 +4,8 @@ import gleam/otp/actor
|
||||
import gleam/result
|
||||
import gleam/string
|
||||
|
||||
import input/key
|
||||
import mpv/control.{type Control}
|
||||
import mpv/key
|
||||
import tcp/reason
|
||||
import tcp/tcp.{type Socket}
|
||||
|
||||
@@ -30,11 +30,6 @@ pub fn new(exit: Subject(Nil)) -> Result(Nil, String) {
|
||||
Ok(actor.Started(data:, ..)) -> {
|
||||
echo "waiting for input"
|
||||
key.start_raw_shell()
|
||||
let input = process.new_subject()
|
||||
process.self()
|
||||
process.receive
|
||||
|
||||
process.spawn(fn() { input_handler(input, data) })
|
||||
process.spawn(fn() { read_input(data) })
|
||||
Ok(Nil)
|
||||
}
|
||||
@@ -48,7 +43,6 @@ fn handle_message(
|
||||
control: Control,
|
||||
) -> actor.Next(State(socket, exit), Control) {
|
||||
case control {
|
||||
control.Search -> todo
|
||||
control.TogglePlayPause -> {
|
||||
echo "toggling play/pause"
|
||||
|
||||
@@ -71,32 +65,14 @@ fn handle_message(
|
||||
}
|
||||
}
|
||||
|
||||
// TODO create new input_handler_loop that recieves on a subject and
|
||||
// TODO read_input reads until a key is found, and then sends it to
|
||||
|
||||
// TODO a function that can recieve on a subject, and it can receive two types of messages:
|
||||
// 1. a Control message from read_input
|
||||
// 2. an injected controlMessage with pre-defined buffer
|
||||
// it then forwards the message to the actor subject
|
||||
|
||||
fn read_input(input_handler: Subject(Control)) -> Nil {
|
||||
fn read_input(subject: Subject(Control)) -> Nil {
|
||||
case
|
||||
key.read_input_until_key([])
|
||||
|> control.from_key
|
||||
{
|
||||
Error(_) -> Nil
|
||||
Ok(control) -> process.send(input_handler, control)
|
||||
Ok(control) -> process.send(subject, control)
|
||||
}
|
||||
|
||||
read_input(input_handler)
|
||||
}
|
||||
|
||||
fn input_handler(
|
||||
input: Subject(Control),
|
||||
actor_subject: Subject(Control),
|
||||
) -> Nil {
|
||||
case process.receive(input, 1000) {
|
||||
Error(_) -> Nil
|
||||
Ok(control) -> process.send(actor_subject, control)
|
||||
}
|
||||
read_input(subject)
|
||||
}
|
||||
|
||||
@@ -1,9 +1,9 @@
|
||||
import gleam/list
|
||||
import gleeunit
|
||||
|
||||
import input/key.{type Key, Char}
|
||||
import mpv/control.{type Control}
|
||||
import mpv/internal/control as control_internal
|
||||
import mpv/key.{type Key, Char}
|
||||
|
||||
pub fn main() -> Nil {
|
||||
gleeunit.main()
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
import gleam/list
|
||||
import gleeunit
|
||||
|
||||
import input/key.{type Key, Char, csi, esc}
|
||||
import mpv/key.{type Key, Char, csi, esc}
|
||||
|
||||
pub fn main() -> Nil {
|
||||
gleeunit.main()
|
||||
Reference in New Issue
Block a user