Check the possibility to intercept Readline's input and output

Author: 0x2c7

lib/ruby_jard/pry_proxy.rb

@@ -81,6 +81,10 @@ def pager
       RubyJard::Pager.new(self)
     end
 
+    def line_buffer
+      Readline.line_buffer
+    end
+
     private
 
     def pry_jard_prompt

lib/ruby_jard/repl_interceptor.rb

@@ -29,6 +29,11 @@ def start
 
     def stop
       @key_listen_thread&.exit if @key_listen_thread&.alive?
+      if interceptable?
+        sleep PTY_OUTPUT_TIMEOUT until @state.exited?
+      else
+        @state.exited!
+      end
     end
 
     def dispatch_command(command)
@@ -61,14 +66,18 @@ def redirected_output
       @output_writer
     end
 
-    def redirectable?
+    def interceptable?
+      return false if defined?(Reline) && Readline == Reline
+      return false if RubyJard::Reflection.instance.call_method(::Readline, :input=).source_location != nil
+      return false if RubyJard::Reflection.instance.call_method(::Readline, :output=).source_location != nil
+
       true
     end
 
     private
 
     def reopen_streams
-      unless redirectable?
+      unless interceptable?
         @input_reader = @console.input
         @input_writer = @console.input
         @output_reader = @console.output
@@ -86,7 +95,7 @@ def reopen_streams
     end
 
     def start_output_bridge
-      return unless redirectable?
+      return unless interceptable?
 
       @output_bridge_thread = Thread.new { output_bridge }
       @output_bridge_thread.abort_on_exception = true
@@ -95,7 +104,7 @@ def start_output_bridge
     end
 
     def start_key_listen_thread
-      return unless redirectable?
+      return unless interceptable?
 
       @main_thread = Thread.current
       @key_listen_thread = Thread.new { listen_key_press }
@@ -147,10 +156,9 @@ def listen_key_press
           end
         end
       end
-    rescue StandardError => e
+    rescue StandardError
       # This thread shoud never die, or the user may be freezed, and cannot type anything
       sleep 0.5
-      RubyJard.debug(e.inspect)
       retry
     end
 

lib/ruby_jard/repl_manager.rb

@@ -64,51 +64,49 @@ def repl(current_binding)
 
       @state.ready!
       @state.clear_pager!
-      @console.disable_echo!
-      @console.raw!
       @interceptor.start
 
-      pry_repl(current_binding)
+      set_console_raw!
+      unless @interceptor.interceptable?
+        @console.output.puts '*Warning*: Key bindings are disabled! '\
+          'There maybe a gem or a module touching Readline whose Jard depends on.'
+      end
+
+      pry_proxy.repl(current_binding)
     ensure
+      set_console_cooked!
       @state.exiting!
-      sleep PTY_OUTPUT_TIMEOUT until @state.exited?
-      @console.enable_echo!
-      @console.cooked!
       @interceptor.stop
     end
 
     private
 
-    def pry_repl(current_binding)
-      pry_instance.repl(current_binding)
-    end
-
-    def pry_instance
-      PryProxy.new(
+    def pry_proxy
+      @pry_proxy = PryProxy.new(
         original_input: @interceptor.original_input,
         original_output: @interceptor.original_output,
         redirected_input: @interceptor.redirected_input,
         redirected_output: @interceptor.redirected_output,
         state_hooks: {
           after_read: proc {
-            @console.cooked!
+            set_console_cooked!
             @state.processing!
             # Sleep 2 ticks, wait for pry to print out all existing output in the queue
             sleep PTY_OUTPUT_TIMEOUT * 2
           },
           after_handle_line: proc {
-            @console.raw!
+            set_console_raw!
             @state.ready!
           },
           before_pager: proc {
             @state.processing!
             @state.set_pager!
-            @console.cooked!
+            set_console_cooked!
           },
           after_pager: proc {
             @state.ready!
             @state.clear_pager!
-            @console.raw!
+            set_console_raw!
           }
         }
       )
@@ -119,7 +117,7 @@ def start_resizing
 
       @resizing = true
       @resizing_output_mark = @console.stdout_storage.length
-      @resizing_readline_buffer = Readline.line_buffer unless @state.processing?
+      @resizing_readline_buffer = @pry_proxy&.line_buffer unless @state.processing?
       @interceptor.dispatch_command('list')
     end
 
@@ -141,5 +139,19 @@ def finish_resizing
       @resizing_output_mark = nil
       @resizing = false
     end
+
+    def set_console_cooked!
+      return unless @interceptor.interceptable?
+
+      @console.enable_echo!
+      @console.cooked!
+    end
+
+    def set_console_raw!
+      return unless @interceptor.interceptable?
+
+      @console.disable_echo!
+      @console.raw!
+    end
   end
 end