Class: LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Condition

Inherits:

Node

• Object
• Treetop::Runtime::SyntaxNode
• Node
• LogStashCompilerLSCLGrammar::LogStash::Compiler::LSCL::AST::Condition

Includes:

Helpers

Defined in:

lib/logstash/compiler/lscl.rb

Constant Summary

Constants included from Helpers

Helpers::AND_METHOD, Helpers::OR_METHOD

Instance Method Summary

• #expr ⇒ Object
• #jconvert(sexpr) ⇒ Object

  Converts an sexpr of :and or :or to the java imperative IR.

• #join_conditions(all_elements) ⇒ Object
• #precedence(op) ⇒ Object
• #stack_to_expr(stack) ⇒ Object

Methods included from Helpers

#base_id, #base_protocol, #base_source_with_metadata, #base_source_with_metadata=, #compose, #compose_for, #jdsl, jdsl, #line_and_column, #source_meta

Methods inherited from Node

#section_type

Instance Method Details

#expr ⇒ Object

# File 'lib/logstash/compiler/lscl.rb', line 293

def expr
  first_element = elements.first
  rest_elements = elements.size > 1 ? elements[1].recursive_select(BooleanOperator, Expression, SelectorElement) : []

  all_elements = [first_element, *rest_elements]

  if all_elements.size == 1
    elem = all_elements.first
    if elem.is_a?(Selector)
      eventValue = elem.recursive_select(SelectorElement).first.expr
      jdsl.eTruthy(source_meta, eventValue)
    elsif elem.is_a?(RegexpExpression)
      elem.expr
    else
      join_conditions(all_elements)
    end
  else
    join_conditions(all_elements)
  end
end

#jconvert(sexpr) ⇒ Object

Converts an sexpr of :and or :or to the java imperative IR

# File 'lib/logstash/compiler/lscl.rb', line 327

def jconvert(sexpr)
  raise "jconvert cannot handle nils!" if sexpr.nil?

  if sexpr.java_kind_of?(Java::OrgLogstashConfigIrExpression::Expression)
    return sexpr
  end

  op, left, right = sexpr

  left_c = jconvert(left)
  right_c = jconvert(right)

  case op
  when :and
    return jdsl.eAnd(left, right);
  when :or
    return jdsl.eOr(left, right);
  else
    raise "Unknown op #{jop}"
  end
end

#join_conditions(all_elements) ⇒ Object

# File 'lib/logstash/compiler/lscl.rb', line 349

def join_conditions(all_elements)
  # Use Dijkstra's shunting yard algorithm
  out = []
  operators = []

  all_elements.each do |e|
    e_exp = e.expr

    if e.is_a?(BooleanOperator)
      if operators.last && precedence(operators.last) > precedence(e_exp)
        out << operators.pop
      end
      operators << e_exp
    else
      out << e_exp
    end
  end
  operators.reverse.each {|o| out << o}

  stack = []
  expr = []
  out.each do |e|
    if e.is_a?(Symbol)
      rval, lval = stack.pop, stack.pop
      stack << jconvert([e, lval, rval])
    elsif e.nil?
      raise "Nil expr encountered! This should not happen!"
    else
      stack << e
    end
  end

  stack_to_expr(stack)
end

#precedence(op) ⇒ Object

# File 'lib/logstash/compiler/lscl.rb', line 314

def precedence(op)
  #  Believe this is right for logstash?
  case op
  when AND_METHOD
    2
  when OR_METHOD
    1
  else
    raise ArgumentError, "Unexpected operator #{op}"
  end
end

#stack_to_expr(stack) ⇒ Object

# File 'lib/logstash/compiler/lscl.rb', line 384

def stack_to_expr(stack)
  raise "Got an empty stack! This should not happen!" if stack.empty?
  stack = stack.reverse # We need to work the stack in reverse order

  working_stack = []
  while elem = stack.pop
    if elem.is_a?(::Method)
      right, left = working_stack.pop, working_stack.pop
      working_stack << elem.call(left, right)
    else
      working_stack << elem
    end
  end

  raise "Invariant violated! Stack size > 1" if working_stack.size > 1

  working_stack.first
end