class Lingo::Attendee

# File lib/lingo/attendee.rb, line 86
def initialize(config, lingo)
  @lingo = lingo

  init_reportable

  # Make sure config exists

  lingo.dictionary_config

  @config, @subscriber = config, []

  init if self.class.method_defined?(:init)

  @can_control = self.class.method_defined?(:control)
  @can_process = self.class.method_defined?(:process)

  @skip_command, @timer = false, nil
end

# File lib/lingo/attendee.rb, line 104
def add_subscriber(subscriber)
  @subscriber.concat(subscriber)
end

# File lib/lingo/attendee.rb, line 108
def listen(obj)
  unless obj.is_a?(AgendaItem)
    @can_process ? stat_timer(:objects) { process(obj) } : forward(obj)
  else
    args = obj.to_a
    stat_timer(:commands) { control(*args) } if @can_control

    case obj.cmd
      when STR_CMD_TALK
        nil
      when STR_CMD_STATUS
        report_time
        report_status

        forward(*args)
      else
        forward(*args) unless skip_command!
    end
  end
end

# File lib/lingo/attendee.rb, line 129
def talk(obj)
  charge_timer { @subscriber.each { |attendee| attendee.listen(obj) } }
end

# File lib/lingo/attendee.rb, line 160
def charge_timer
  return yield unless @lingo.report_time

  res = nil
  @timer += Benchmark.realtime { res = yield }
  res
end

# File lib/lingo/attendee.rb, line 236
def dictionary(src, mod)
  Language::Dictionary.new({ 'source' => src, 'mode' => mod }, @lingo)
end

# File lib/lingo/attendee.rb, line 135
def find_word(f, d = @dic, g = @gra)
  w = d.find_word(f)
  g && (block_given? ? !yield(w) : w.unknown?) ? g.find_compound(f) : w
end

# File lib/lingo/attendee.rb, line 219
def forward(obj, param = nil)
  talk(param ? AgendaItem.new(obj, param) : obj)
end

# File lib/lingo/attendee.rb, line 232
def get_array(key, default = nil, m = nil)
  get_key(key, default).split(SEP_RE).tap { |ary| ary.map!(&m) if m }
end

# File lib/lingo/attendee.rb, line 227
def get_key(key, default = nodefault = Object.new)
  raise MissingConfigError.new(key) if nodefault && !has_key?(key)
  @config.fetch(key, default)
end

# File lib/lingo/attendee.rb, line 240
def grammar(src, mod)
  Language::Grammar.new({ 'source' => src, 'mode' => mod }, @lingo)
end

# File lib/lingo/attendee.rb, line 223
def has_key?(key)
  @config && @config.has_key?(key)
end

# File lib/lingo/attendee.rb, line 140
def report_on(cmd, *rep)
  rep.each { |r| r.report.each { |q| set(*q) } } if cmd == STR_CMD_STATUS
end

# File lib/lingo/attendee.rb, line 202
def report_status
  return unless @lingo.report_status

  msg = "Attendee <%s> was connected from '%s' to '%s' reporting..."

  warn msg % @config.values_at(*%w[name in out]), nil,
    report.sort.map! { |k, v| " #{k} = #{v}" }, nil
end

# File lib/lingo/attendee.rb, line 168
def report_time
  return unless @lingo.report_time

  msg = 'Perf: %-15s ' <<
        '=> %7d commands in %s (%s/cmd)' <<
        ',  %8d objects in %s (%s/obj)'

  arg = [@config['name']]

  %w[commands objects].each { |k|
    n, t = sta_for(k).map(&method(:get))
    arg << n

    arg.concat([1, n].map { |m|
      s = m.zero? ? 0.0 : t / m.to_f

      '%9.3f %-2s' %
        if s < 0.001
          [s * 1000.0 ** 2, 'µs']
        elsif s < 1.0
          [s * 1000.0,      'ms']
        elsif s < 60.0
          [s,               's']
        elsif s < 60.0 ** 2
          [s / 60.0,        'm']
        else
          [s / 60.0 ** 2,   'h']
        end
    })
  }

  warn msg % arg
end

# File lib/lingo/attendee.rb, line 244
def set_dic
  @dic = dictionary(get_array('source'), get_key('mode', 'all'))
end

# File lib/lingo/attendee.rb, line 248
def set_gra
  @gra = grammar(get_array('source'), get_key('mode', 'all'))
end

# File lib/lingo/attendee.rb, line 211
def skip_command
  @skip_command = true
end

# File lib/lingo/attendee.rb, line 215
def skip_command!
  @skip_command.tap { @skip_command &&= false }
end

# File lib/lingo/attendee.rb, line 144
def sta_for(key)
  %w[NUM TIM].map { |i| self.class.const_get("STA_#{i}_#{key.upcase}") }
end

# File lib/lingo/attendee.rb, line 148
def stat_timer(key)
  n, t = sta_for(key)
  inc(n)

  return yield unless @lingo.report_time

  @timer = Time.now.to_i
  res = yield
  add(t, Time.now.to_i - @timer)
  res
end

# File lib/lingo/attendee.rb, line 252
def warn(*msg)
  @lingo.warn(*msg)
end