Ruote::TestLogger

# File lib/ruote/log/test_logger.rb, line 39
def initialize (context)

  @context = context

  if @context.worker
    #
    # this is a worker context, DO log
    #
    @context.worker.subscribe(:all, self)
  #else
    #
    # this is not a worker context, DO NOT log, but be ready to
    # be queried
    #
  end

  @seen = []
  @log = []
  @waiting = []

  @count = -1
  @color = 33
  @noisy = false
end

# File lib/ruote/log/test_logger.rb, line 112
def self.pp (msg)

  @logger ||= TestLogger.new(nil)
  puts @logger.send(:pretty_print, msg)
end

# File lib/ruote/log/test_logger.rb, line 107
def color= (c)

  @color = c
end

# File lib/ruote/log/test_logger.rb, line 102
def dump

  @seen.collect { |msg| pretty_print(msg) }.join("\n")
end

# File lib/ruote/log/test_logger.rb, line 64
def notify (msg)

  puts(pretty_print(msg)) if @noisy

  @seen << msg
  @log << msg

  check_waiting
end

# File lib/ruote/log/test_logger.rb, line 87
def wait_for (interests)

  @waiting << [ Thread.current, interests ]

  check_waiting

  Thread.stop if @waiting.find { |w| w.first == Thread.current }

  # and when this thread gets woken up, go on and return __result__

  Thread.current['__result__']
end

# File lib/ruote/log/test_logger.rb, line 129
def check_msg (msg)

  wakeup = []

  @waiting.each do |thread, interests|

    wakeup << thread if matches(interests, msg)
  end

  @waiting.delete_if { |t, i| i.size < 1 }

  wakeup.each do |thread|

    thread['__result__'] = msg
    thread.wakeup
  end
end

# File lib/ruote/log/test_logger.rb, line 120
def check_waiting

  return if @waiting.size < 1

  while msg = @seen.shift
    check_msg(msg)
  end
end

# File lib/ruote/log/test_logger.rb, line 161
def matches (interests, msg)

  action = msg['action']

  interests.each do |interest|

    satisfied = if interest == :inactive

      (FINAL_ACTIONS.include?(action) && @context.worker.inactive?)

    elsif interest == :empty

      (action == 'terminated' && @context.storage.empty?('expressions'))

    elsif interest.is_a?(Symbol) # participant

      (action == 'dispatch' && msg['participant_name'] == interest.to_s)

    elsif interest.is_a?(Fixnum)

      interests.delete(interest)

      if (interest > 1)
        interests << (interest - 1)
        false
      else
        true
      end

    else # wfid

      (FINAL_ACTIONS.include?(action) && msg['wfid'] == interest)
    end

    interests.delete(interest) if satisfied
  end

  interests.size < 1
end