Class: Watobo::Gui::InterceptorUI

Inherits:

FXTopWindow

Object
FXTopWindow
Watobo::Gui::InterceptorUI

Includes:: Responder, Icons

Defined in:: lib/watobo/gui/interceptor_gui.rb

Constant Summary

Constants included from Icons

Constants included from Interceptor

Interceptor::INTERCEPT_BOTH, Interceptor::INTERCEPT_DEFAULT_PORT, Interceptor::INTERCEPT_NONE, Interceptor::INTERCEPT_REQUEST, Interceptor::INTERCEPT_RESPONSE, Interceptor::MODE_REGULAR, Interceptor::MODE_TRANSPARENT, Interceptor::REWRITE_BOTH, Interceptor::REWRITE_NONE, Interceptor::REWRITE_REQUEST, Interceptor::REWRITE_RESPONSE

Instance Method Summary collapse

#addRequest(request, thread) ⇒ Object
#addResponse(response, thread) ⇒ Object
#execute ⇒ Object
#initialize(owner, opts) ⇒ InterceptorUI constructor

A new instance of InterceptorUI.
#modifyRequest(request, thread) ⇒ Object

this method is obsolet! Use addRequest() instead.
#modifyResponse(request, thread) ⇒ Object

this method is obsolet! Use addResponse() instead.
#releaseAll ⇒ Object

Constructor Details

#initialize(owner, opts) ⇒ `InterceptorUI`

Returns a new instance of InterceptorUI.

# File 'lib/watobo/gui/interceptor_gui.rb', line 487

def initialize(owner, opts)
  # Invoke base class initialize function first

  super( owner, 'Interceptor', nil, nil, DECOR_ALL|DECOR_TITLE|DECOR_BORDER|DECOR_RESIZE, 0, 0, 600, 400, 0, 0, 0, 0, 0, 0)
  self.connect(SEL_CLOSE, method(:onClose))
  self.icon = ICON_INTERCEPTOR
  #@interceptor = interceptor

  @request_list = []
  @response_list = []

  @request_queue = []
  @response_queue = []

  @request_lock = Mutex.new
  @response_lock = Mutex.new

  # initial frame setup
  mr_splitter = FXSplitter.new(self, LAYOUT_FILL_X|LAYOUT_FILL_Y|SPLITTER_VERTICAL|SPLITTER_REVERSED|SPLITTER_TRACKING)

  top_frame = FXVerticalFrame.new(mr_splitter, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y||LAYOUT_FIX_HEIGHT|LAYOUT_BOTTOM,:height => 500)
  top_splitter = FXSplitter.new(top_frame, LAYOUT_FILL_X|SPLITTER_HORIZONTAL|LAYOUT_FILL_Y|SPLITTER_TRACKING)

  #log_frame = FXVerticalFrame.new(mr_splitter, :opts => LAYOUT_FILL_X|LAYOUT_SIDE_BOTTOM,:height => 100)

  filter_frame = FXVerticalFrame.new(top_splitter, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y||LAYOUT_FIX_HEIGHT|LAYOUT_BOTTOM)
   gbframe = FXGroupBox.new(filter_frame, "Intercept", LAYOUT_SIDE_RIGHT|FRAME_GROOVE|LAYOUT_FILL_X, 0, 0, 0, 0)
  frame = FXVerticalFrame.new(gbframe, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y, :padding => 0)
#  FXLabel.new(filter_frame, "Intercept:" )
  @intercept_request = FXCheckButton.new(frame, "Requests", nil, 0,
  ICON_BEFORE_TEXT|LAYOUT_SIDE_TOP)
  @intercept_request.connect(SEL_COMMAND, method(:onInterceptChanged))

  @intercept_response = FXCheckButton.new(frame, "Response", nil, 0,
  ICON_BEFORE_TEXT|LAYOUT_SIDE_TOP)
  @intercept_response.connect(SEL_COMMAND, method(:onInterceptChanged))
  @filter_options_btn = FXButton.new(frame, "Options", nil, nil, 0, FRAME_RAISED|FRAME_THICK|LAYOUT_LEFT)
  @filter_options_btn.connect(SEL_COMMAND, method(:onBtnFilterOptions))
  
  gbframe = FXGroupBox.new(filter_frame, "Rewrite", LAYOUT_SIDE_RIGHT|FRAME_GROOVE|LAYOUT_FILL_X, 0, 0, 0, 0)
  frame = FXVerticalFrame.new(gbframe, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y, :padding => 0)
  #FXLabel.new(filter_frame, "Rewrite:" )
  @rewrite_request = FXCheckButton.new(frame, "Requests", nil, 0,
  ICON_BEFORE_TEXT|LAYOUT_SIDE_TOP)
  @rewrite_request.connect(SEL_COMMAND, method(:onInterceptChanged))

  @rewrite_response = FXCheckButton.new(frame, "Response", nil, 0,
  ICON_BEFORE_TEXT|LAYOUT_SIDE_TOP)
  @rewrite_response.connect(SEL_COMMAND, method(:onInterceptChanged))

 @rewrite_options_btn = FXButton.new(frame, "Options", nil, nil, 0, FRAME_RAISED|FRAME_THICK|LAYOUT_LEFT)
  @rewrite_options_btn.connect(SEL_COMMAND){ open_rewrite_options_dialog }
 
  #@intercept_request.checkState = false
  #@intercept_response.checkState = false
  if Watobo::Interceptor.active?

    @intercept_request.checkState = Watobo::Interceptor.intercept_requests?
    @intercept_response.checkState = Watobo::Interceptor.intercept_requests?
  end

  view_frame = FXVerticalFrame.new(top_splitter, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y||LAYOUT_FIX_HEIGHT|LAYOUT_BOTTOM)

  @tabBook = FXTabBook.new(view_frame, nil, 0, LAYOUT_FILL_X|LAYOUT_FILL_Y|LAYOUT_RIGHT)

  button_frame = FXHorizontalFrame.new(view_frame, LAYOUT_FILL_X)
  @tabBook.connect(SEL_COMMAND) { |sender, sel, item|
    case item
    when 0
      enable_buttons if @request_list.length > 0
    when 1
      enable_buttons if @response_list.length > 0
    end

  }
  @request_tab = FXTabItem.new(@tabBook, "Request (0)", nil)
  request_frame_outer = FXVerticalFrame.new(@tabBook, LAYOUT_FILL_X|LAYOUT_FILL_Y|FRAME_RAISED)
  # request_frame = FXVerticalFrame.new(request_frame_outer, LAYOUT_FILL_X|LAYOUT_FILL_Y)

  @requestbox = Watobo::Gui::InterceptEditor.new(request_frame_outer, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y)
  

  @response_tab = FXTabItem.new(@tabBook, "Response (0)", nil)
  response_frame_outer = FXVerticalFrame.new(@tabBook, LAYOUT_FILL_X|LAYOUT_FILL_Y|FRAME_RAISED)
  #response_frame = FXVerticalFrame.new(response_frame_outer, LAYOUT_FILL_X|LAYOUT_FILL_Y, :padding=>0)
  # @responsebox = Watobo::Gui::RequestEditor.new(response_frame, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y )
  @responsebox = Watobo::Gui::InterceptEditor.new(response_frame_outer, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y)
  # @responsebox.editable = true

  @accept_button = FXButton.new(button_frame, "Accept", nil, nil, 0, FRAME_RAISED|FRAME_THICK|LAYOUT_LEFT)
  @accept_button.connect(SEL_COMMAND, method(:onAcceptChanges))

  @discard_button = FXButton.new(button_frame, "Discard", nil, nil, 0, FRAME_RAISED|FRAME_THICK|LAYOUT_LEFT)
  @discard_button.connect(SEL_COMMAND, method(:onDiscard))

  @drop_button = FXButton.new(button_frame, "Drop", nil, nil, 0, FRAME_RAISED|FRAME_THICK|LAYOUT_LEFT)
  @drop_button.connect(SEL_COMMAND, method(:onDrop))

  #  log_text_frame = FXVerticalFrame.new(log_frame, LAYOUT_FILL_X|LAYOUT_FILL_Y|FRAME_SUNKEN|FRAME_THICK, :padding=>0)
  #  @log_viewer = FXText.new(log_text_frame, :opts => LAYOUT_FILL_X|LAYOUT_FILL_Y)

  disable_buttons()

  # start an update timer
  @update_timer = FXApp.instance.addTimeout( 50, :repeat => true) {
    @request_lock.synchronize do
      unless @request_queue.empty?
        @request_list.concat @request_queue
        @request_queue.clear
        @request_tab.text = "Request (#{@request_list.length})"
      end

      if @request_list.length > 0 and @requestbox.empty?
        @requestbox.setText @request_list.first[:request]
      end

    end
    @response_lock.synchronize do
      unless @response_queue.empty?
        @response_list.concat @response_queue
        @response_queue.clear
        @response_tab.text = "Response (#{@response_list.length})"
      end

      if @response_list.length > 0 and @responsebox.empty?
        @responsebox.setText @response_list.first[:response]
      end

    end
    update_buttons
  }

end

Instance Method Details

#addRequest(request, thread) ⇒ `Object`

# File 'lib/watobo/gui/interceptor_gui.rb', line 450

def addRequest(request, thread)
  puts "* [Interceptor] addRequest"

  new_request = {
    :request => request,
    :thread => thread
  }

  @request_lock.synchronize do
  #   enable_buttons()
    @request_queue << new_request

  end

# enable_buttons()

end

#addResponse(response, thread) ⇒ `Object`

# File 'lib/watobo/gui/interceptor_gui.rb', line 468

def addResponse(response, thread)
  response.extend Watobo::Mixin::Parser::Web10
  response.extend Watobo::Mixin::Shaper::Web10

  response.fixupContentLength()

  #  puts response

  new_response = {
    :response => response,
    :thread => thread
  }

  @response_lock.synchronize do
    @response_queue.push new_response

  end
end

#execute ⇒ `Object`

# File 'lib/watobo/gui/interceptor_gui.rb', line 434

def execute
  create
  show(PLACEMENT_SCREEN)
# getApp().runModalFor(self)
end

#modifyRequest(request, thread) ⇒ `Object`

this method is obsolet! Use addRequest() instead



441
442
443

# File 'lib/watobo/gui/interceptor_gui.rb', line 441

def modifyRequest(request, thread)
  addRequest(request, thread)
end

#modifyResponse(request, thread) ⇒ `Object`

this method is obsolet! Use addResponse() instead



446
447
448

# File 'lib/watobo/gui/interceptor_gui.rb', line 446

def modifyResponse(request, thread)
  addResponse(request, thread)
end

#releaseAll ⇒ `Object`

# File 'lib/watobo/gui/interceptor_gui.rb', line 621

def releaseAll()
  #  puts "* closing interceptor"
  #  puts "* disable all interceptions"
  #@project.intercept_request = false
  #@project.intercept_response = false
  #  puts "* release all interceptions ..."
  @request_list.each do |ir|
    ir[:thread].run
  end
  @response_list.each do |ir|
    ir[:thread].run
  end

end

Class: Watobo::Gui::InterceptorUI

Constant Summary

Constants included from Icons

Constants included from Interceptor

Instance Method Summary collapse

Constructor Details

#initialize(owner, opts) ⇒ InterceptorUI

Instance Method Details

#addRequest(request, thread) ⇒ Object

#addResponse(response, thread) ⇒ Object

#execute ⇒ Object

#modifyRequest(request, thread) ⇒ Object

#modifyResponse(request, thread) ⇒ Object

#releaseAll ⇒ Object

#initialize(owner, opts) ⇒ `InterceptorUI`

#addRequest(request, thread) ⇒ `Object`

#addResponse(response, thread) ⇒ `Object`

#execute ⇒ `Object`

#modifyRequest(request, thread) ⇒ `Object`

#modifyResponse(request, thread) ⇒ `Object`

#releaseAll ⇒ `Object`