Class: Muxr::Application

Inherits:
Object
  • Object
show all
Defined in:
lib/muxr/application.rb

Overview

The Application is the muxr server. It owns the Session, panes, Renderer, and InputHandler, and listens on a Unix socket at ~/.muxr/sockets/<name>.sock for a Client to attach. Shells and other PTY processes survive client detach/reattach — only the listening socket and the one currently-attached client come and go.

The Renderer’s output sink is a small adapter that frames its bytes into OUTPUT messages on the attached client; when no client is attached the bytes are silently dropped (we also skip the render entirely in that case). PTY data still gets drained even with no client, so the in-memory Terminal grids stay up to date and are repainted in full on the next attach via Renderer#reset_frame!.

Defined Under Namespace

Classes: FramedOutput

Constant Summary collapse

SELECT_TIMEOUT = 
0.05
SOCKETS_DIR = 
File.join(Dir.home, ".muxr", "sockets").freeze
DEFAULT_WIDTH = 
80
DEFAULT_HEIGHT = 
24

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(argv = []) ⇒ Application

Returns a new instance of Application.



50
51
52
53
54
55
56
57
58
59
60
61
62
63
 
# File 'lib/muxr/application.rb', line 50

def initialize(argv = [])
  @argv = argv
  @session_name = parse_session_name(argv)
  @running = false
  @needs_render = true
  @message = nil
  @message_expires = nil
  @help_visible = false
  @next_pane_id = 0
  @current_client = nil
  @listening_socket = nil
  @socket_path = self.class.socket_path_for(@session_name)
  @paste_buffer = +""
end

Instance Attribute Details

#input ⇒ Object (readonly)

Returns the value of attribute input.



23
24
25
 
# File 'lib/muxr/application.rb', line 23

def input
  @input
end

#paste_buffer ⇒ Object (readonly)

Returns the value of attribute paste_buffer.



65
66
67
 
# File 'lib/muxr/application.rb', line 65

def paste_buffer
  @paste_buffer
end

#renderer ⇒ Object (readonly)

Returns the value of attribute renderer.



23
24
25
 
# File 'lib/muxr/application.rb', line 23

def renderer
  @renderer
end

#session ⇒ Object (readonly)

Returns the value of attribute session.



23
24
25
 
# File 'lib/muxr/application.rb', line 23

def session
  @session
end

#session_name ⇒ Object (readonly)

Returns the value of attribute session_name.



23
24
25
 
# File 'lib/muxr/application.rb', line 23

def session_name
  @session_name
end

Class Method Details

.alive_socket?(path) ⇒ Boolean

Returns:

  • (Boolean) 


42
43
44
45
46
47
48
 
# File 'lib/muxr/application.rb', line 42

def self.alive_socket?(path)
  return false unless File.exist?(path)
  UNIXSocket.new(path).close
  true
rescue SystemCallError
  false
end

.list_active ⇒ Object

Names of sessions whose server socket is currently accepting connections. Stale sockets (file exists, no listener) are skipped but left in place; cleanup happens on the next attach attempt.



32
33
34
35
36
37
38
39
40
 
# File 'lib/muxr/application.rb', line 32

def self.list_active
  return [] unless File.directory?(SOCKETS_DIR)
  Dir.children(SOCKETS_DIR).filter_map do |entry|
    next unless entry.end_with?(".sock")
    path = File.join(SOCKETS_DIR, entry)
    next unless alive_socket?(path)
    File.basename(entry, ".sock")
  end.sort
end

.socket_path_for(name) ⇒ Object 



25
26
27
 
# File 'lib/muxr/application.rb', line 25

def self.socket_path_for(name)
  File.join(SOCKETS_DIR, "#{name}.sock")
end

Instance Method Details

#cancel_quit ⇒ Object 



216
217
218
219
220
221
 
# File 'lib/muxr/application.rb', line 216

def cancel_quit
  @message = nil
  @message_expires = nil
  flash("cancelled")
  invalidate
end

#close_focused ⇒ Object 



130
131
132
133
134
135
136
137
138
139
 
# File 'lib/muxr/application.rb', line 130

def close_focused
  if @session.focus_drawer && @session.drawer&.visible?
    hide_drawer
    return
  end
  pane = focused_pane
  return unless pane
  @session.window.remove_pane(pane)
  invalidate
end

#confirm_quit ⇒ Object 



212
213
214
 
# File 'lib/muxr/application.rb', line 212

def confirm_quit
  shutdown_server
end

#cycle_layout ⇒ Object 



141
142
143
144
145
 
# File 'lib/muxr/application.rb', line 141

def cycle_layout
  @session.window.cycle_layout
  flash("layout: #{@session.window.layout}")
  invalidate
end

#deliver_output(bytes) ⇒ Object

Called by the FramedOutput adapter; ships one OUTPUT frame to the currently attached client. No-op when nobody is attached.



387
388
389
390
391
392
393
 
# File 'lib/muxr/application.rb', line 387

def deliver_output(bytes)
  sock = @current_client
  return unless sock
  Protocol.write(sock, Protocol::OUTPUT, bytes)
rescue Errno::EPIPE, Errno::ECONNRESET, IOError
  drop_client_silently
end

#detach ⇒ Object 



188
189
190
191
192
 
# File 'lib/muxr/application.rb', line 188

def detach
  flash("detached")
  disconnect_client(reason: "detached")
  # Server keeps running. Next `bin/muxr <name>` invocation will re-attach.
end

#dismiss_help ⇒ Object 



234
235
236
237
 
# File 'lib/muxr/application.rb', line 234

def dismiss_help
  @help_visible = false
  invalidate
end

#enter_scrollback ⇒ Object 



239
240
241
242
243
244
245
 
# File 'lib/muxr/application.rb', line 239

def enter_scrollback
  target = focused_target
  return unless target
  @input.enter_scrollback_mode
  @renderer.reset_frame!
  invalidate
end

#enter_selection ⇒ Object 



273
274
275
276
277
278
279
280
281
282
283
 
# File 'lib/muxr/application.rb', line 273

def enter_selection
  target = focused_target
  return unless target
  # Vim-style: drop the user at a movable cursor with NO selection yet.
  # They navigate with h/j/k/l, then press v (linear) or C-v (block) to
  # anchor.
  target.terminal.place_selection_cursor(0, 0)
  @input.enter_selection_mode
  @renderer.reset_frame!
  invalidate
end

#exit_scrollback ⇒ Object 



247
248
249
250
251
252
253
 
# File 'lib/muxr/application.rb', line 247

def exit_scrollback
  target = focused_target
  target&.terminal&.clear_selection
  target&.terminal&.scroll_to_bottom
  @renderer.reset_frame!
  invalidate
end

#exit_selection(yank:) ⇒ Object 



302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
 
# File 'lib/muxr/application.rb', line 302

def exit_selection(yank:)
  target = focused_target
  term = target&.terminal
  if yank
    # No anchor → no-op. User is still positioning; they can press v
    # first, then yank. Esc/q is the way to exit from navigation.
    return unless term&.selection_active?
    text = term.extract_selection_text
    unless text.empty?
      @paste_buffer = text
      spawn_pbcopy(text)
      flash("yanked #{text.bytesize} bytes")
    end
  end
  term&.clear_selection
  @input.enter_scrollback_mode
  @renderer.reset_frame!
  invalidate
end

#flash(msg) ⇒ Object 



351
352
353
354
355
 
# File 'lib/muxr/application.rb', line 351

def flash(msg)
  @message = msg
  @message_expires = Time.now + 2.5
  invalidate
end

#focus_last ⇒ Object 



111
112
113
114
115
116
117
118
119
 
# File 'lib/muxr/application.rb', line 111

def focus_last
  return if @session.window.panes.empty?
  if @session.focus_drawer && @session.drawer&.visible?
    @session.focus_drawer = false
  else
    @session.window.focus_last
  end
  invalidate
end

#focus_next ⇒ Object 



91
92
93
94
95
96
97
98
99
 
# File 'lib/muxr/application.rb', line 91

def focus_next
  return if @session.window.panes.empty?
  if @session.focus_drawer && @session.drawer&.visible?
    @session.focus_drawer = false
  else
    @session.window.focus_next
  end
  invalidate
end

#focus_pane_number(n) ⇒ Object 



121
122
123
124
125
126
127
128
 
# File 'lib/muxr/application.rb', line 121

def focus_pane_number(n)
  return if @session.window.panes.empty?
  idx = n - 1
  return unless idx >= 0 && idx < @session.window.panes.length
  @session.focus_drawer = false
  @session.window.focus_index(idx)
  invalidate
end

#focus_prev ⇒ Object 



101
102
103
104
105
106
107
108
109
 
# File 'lib/muxr/application.rb', line 101

def focus_prev
  return if @session.window.panes.empty?
  if @session.focus_drawer && @session.drawer&.visible?
    @session.focus_drawer = false
  else
    @session.window.focus_prev
  end
  invalidate
end

#hide_drawer ⇒ Object 



169
170
171
172
173
174
175
 
# File 'lib/muxr/application.rb', line 169

def hide_drawer
  return unless @session.drawer&.visible?
  @session.drawer.hide!
  @session.focus_drawer = false
  renderer.reset_frame!
  invalidate
end

#invalidate ⇒ Object 



357
358
359
 
# File 'lib/muxr/application.rb', line 357

def invalidate
  @needs_render = true
end

#list_sessions ⇒ Object 



375
376
377
378
379
380
381
382
383
 
# File 'lib/muxr/application.rb', line 375

def list_sessions
  names = Session.list
  if names.empty?
    flash("no saved sessions")
  else
    marker = ->(n) { n == @session_name ? "*#{n}" : n }
    flash("sessions: #{names.map(&marker).join(", ")}")
  end
end

#move_selection(action) ⇒ Object 



322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
 
# File 'lib/muxr/application.rb', line 322

def move_selection(action)
  target = focused_target
  return unless target
  term = target.terminal
  rows = term.rows
  cols = term.cols
  case action
  when :left       then term.move_selection_cursor_by(0, -1)
  when :right      then term.move_selection_cursor_by(0, 1)
  when :up         then term.move_selection_cursor_by(-1, 0)
  when :down       then term.move_selection_cursor_by(1, 0)
  when :half_up    then term.move_selection_cursor_by(-[rows / 2, 1].max, 0)
  when :half_down  then term.move_selection_cursor_by([rows / 2, 1].max, 0)
  when :full_up    then term.move_selection_cursor_by(-[rows - 1, 1].max, 0)
  when :full_down  then term.move_selection_cursor_by([rows - 1, 1].max, 0)
  when :line_start then term.selection_cursor_to_line_start
  when :line_end   then term.selection_cursor_to_line_end
  when :top        then term.selection_cursor_to_top
  when :bottom     then term.selection_cursor_to_bottom
  end
  invalidate
end

#new_pane ⇒ Object 



83
84
85
86
87
88
89
 
# File 'lib/muxr/application.rb', line 83

def new_pane
  cwd = focused_pane&.cwd
  @session.window.add_pane(make_pane(cwd: cwd))
  @session.focus_drawer = false
  @session.window.focused_index = @session.window.panes.length - 1
  invalidate
end

#paste_from_buffer ⇒ Object 



345
346
347
348
349
 
# File 'lib/muxr/application.rb', line 345

def paste_from_buffer
  return if @paste_buffer.nil? || @paste_buffer.empty?
  target = focused_target
  target&.write(@paste_buffer)
end

#promote_master ⇒ Object 



147
148
149
150
 
# File 'lib/muxr/application.rb', line 147

def promote_master
  @session.window.promote_to_master
  invalidate
end

#quit ⇒ Object

Both Ctrl-a q and :quit funnel through here. We don’t kill the server immediately — InputHandler enters a confirmation state and the user has to press ‘y’ to actually shut down (see :request_quit_confirmed).



197
198
199
 
# File 'lib/muxr/application.rb', line 197

def quit
  request_quit
end

#quit_immediate ⇒ Object 



201
202
203
 
# File 'lib/muxr/application.rb', line 201

def quit_immediate
  request_quit
end

#request_quit ⇒ Object 



205
206
207
208
209
210
 
# File 'lib/muxr/application.rb', line 205

def request_quit
  return if @input.state == :confirm_quit
  @input.enter_confirm_quit
  flash("kill session? (y/n)")
  invalidate
end

#reset_drawer ⇒ Object 



177
178
179
180
181
182
183
184
185
186
 
# File 'lib/muxr/application.rb', line 177

def reset_drawer
  if @session.drawer
    @session.drawer.close
    @session.drawer = nil
  end
  @session.focus_drawer = false
  renderer.reset_frame!
  flash("drawer reset")
  invalidate
end

#restore_session ⇒ Object 



366
367
368
369
370
371
372
373
 
# File 'lib/muxr/application.rb', line 366

def restore_session
  data = Session.load(@session_name)
  if data
    flash("session file: #{Session.save_path_for(@session_name)}")
  else
    flash("no saved session")
  end
end

#run ⇒ Object 



67
68
69
70
71
72
73
74
 
# File 'lib/muxr/application.rb', line 67

def run
  setup
  begin
    loop_forever
  ensure
    teardown
  end
end

#run_command(cmd_line) ⇒ Object 



223
224
225
226
 
# File 'lib/muxr/application.rb', line 223

def run_command(cmd_line)
  CommandDispatcher.new(self).dispatch(cmd_line)
  invalidate
end

#save_session ⇒ Object 



361
362
363
364
 
# File 'lib/muxr/application.rb', line 361

def save_session
  path = @session.save
  flash("saved: #{path}")
end

#scroll_focused(action) ⇒ Object 



255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
 
# File 'lib/muxr/application.rb', line 255

def scroll_focused(action)
  target = focused_target
  return unless target
  term = target.terminal
  rows = term.rows
  case action
  when :line_back     then term.scroll_back(1)
  when :line_forward  then term.scroll_forward(1)
  when :half_back     then term.scroll_back([rows / 2, 1].max)
  when :half_forward  then term.scroll_forward([rows / 2, 1].max)
  when :full_back     then term.scroll_back([rows - 1, 1].max)
  when :full_forward  then term.scroll_forward([rows - 1, 1].max)
  when :top           then term.scroll_to_top
  when :bottom        then term.scroll_to_bottom
  end
  invalidate
end

#send_to_focused(data) ⇒ Object

———- public action API (called from InputHandler / CommandDispatcher) ———-



78
79
80
81
 
# File 'lib/muxr/application.rb', line 78

def send_to_focused(data)
  target = focused_target
  target&.write(data)
end

#show_drawer ⇒ Object 



161
162
163
164
165
166
167
 
# File 'lib/muxr/application.rb', line 161

def show_drawer
  ensure_drawer
  @session.drawer.show!
  @session.focus_drawer = true
  renderer.reset_frame!
  invalidate
end

#show_help ⇒ Object 



228
229
230
231
232
 
# File 'lib/muxr/application.rb', line 228

def show_help
  @help_visible = true
  @input.enter_help_mode
  invalidate
end

#toggle_drawer ⇒ Object 



152
153
154
155
156
157
158
159
 
# File 'lib/muxr/application.rb', line 152

def toggle_drawer
  ensure_drawer
  @session.drawer.toggle!
  @session.focus_drawer = @session.drawer.visible?
  @session.focus_drawer = false unless @session.drawer.visible?
  renderer.reset_frame!
  invalidate
end

#toggle_selection(mode) ⇒ Object 



285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
 
# File 'lib/muxr/application.rb', line 285

def toggle_selection(mode)
  target = focused_target
  return unless target
  term = target.terminal
  if term.selection_active? && term.selection_mode == mode
    # Same mode pressed again — drop the anchor, return to navigation.
    term.clear_anchor!
  else
    # No anchor, or switching between linear/block — anchor at the
    # current cursor in the requested mode (vim keeps the visual range
    # when switching shapes, and we mirror that by not moving the
    # cursor).
    term.anchor_selection!(mode: mode)
  end
  invalidate
end