simponic/chessh
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Process linking

Browse Source
This commit is contained in:
Logan Hunt 2023-01-13 18:02:37 -07:00
parent 9f56b735c6
commit 87e42b29f0
No known key found for this signature in database
GPG Key ID: 8AC6A4B840C0EC49
1 changed files with 33 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
lib/chessh/ssh/client/client.ex
View File

@ -19,7 +19,8 @@ defmodule Chessh.SSH.Client do
width: 0, width: 0,
height: 0, height: 0,
player_session: nil, player_session: nil,
screen_processes: [] screen_pid: nil,
screen_state_initials: []
end end
@impl true @impl true
@ -30,13 +31,29 @@ defmodule Chessh.SSH.Client do
@impl true @impl true
def handle_info( def handle_info(
{:set_screen_process, module, screen_state}, {:set_screen_process, module, screen_state_initial},
%State{width: width, height: height, screen_processes: screen_processes} = state %State{
width: width,
height: height,
screen_state_initials: screen_state_initials,
screen_pid: screen_pid
} = state
) do ) do
{:ok, new_screen_pid} = GenServer.start_link(module, [%{screen_state | client_pid: self()}]) if screen_pid do
Process.unlink(screen_pid)
end
{:ok, new_screen_pid} =
GenServer.start_link(module, [%{screen_state_initial | client_pid: self()}])
send(new_screen_pid, {:render, width, height}) send(new_screen_pid, {:render, width, height})
{:noreply, %{state | screen_processes: [new_screen_pid | screen_processes]}} {:noreply,
%State{
state
| screen_pid: new_screen_pid,
screen_state_initials: [{module, screen_state_initial} | screen_state_initials]
}}
end end
@impl true @impl true
@ -67,18 +84,22 @@ defmodule Chessh.SSH.Client do
def handle( def handle(
{:data, data}, {:data, data},
%State{width: width, height: height, screen_processes: [screen_pid | rest_processes]} = %State{
state width: width,
height: height,
screen_pid: screen_pid,
screen_state_initials: [_ | rest_initial]
} = state
) do ) do
case keymap(data) do case keymap(data) do
:quit -> :quit ->
{:stop, :normal, state} {:stop, :normal, state}
:previous_screen -> :previous_screen ->
Logger.debug(inspect(rest_processes)) [{prev_module, prev_state_initial} | _] = rest_initial
Process.exit(screen_pid, :kill) send(self(), {:set_screen_process, prev_module, prev_state_initial})
{:noreply, %State{state | screen_processes: rest_processes}} {:noreply, %State{state | screen_state_initials: rest_initial}}
action -> action ->
send(screen_pid, {:input, width, height, action}) send(screen_pid, {:input, width, height, action})
@ -108,7 +129,7 @@ defmodule Chessh.SSH.Client do
def handle( def handle(
{:resize, {width, height}}, {:resize, {width, height}},
%State{tui_pid: tui_pid, screen_processes: [screen_pid | _]} = state %State{tui_pid: tui_pid, screen_pid: screen_pid} = state
) do ) do
case get_terminal_dim_msg(width, height) do case get_terminal_dim_msg(width, height) do
{true, msg} -> send(tui_pid, {:send_data, msg}) {true, msg} -> send(tui_pid, {:send_data, msg})
@ -150,7 +171,7 @@ defmodule Chessh.SSH.Client do
tui_pid: tui_pid, tui_pid: tui_pid,
width: width, width: width,
height: height, height: height,
screen_processes: [screen_pid | _] screen_pid: screen_pid
}) do }) do
{out_of_range, msg} = get_terminal_dim_msg(width, height) {out_of_range, msg} = get_terminal_dim_msg(width, height)