Class: EXEL::Job::Parser

Inherits:
Object
  • Object
show all
Defined in:
lib/exel/job.rb

Overview

Defines the EXEL DSL methods and is used to convert a block of Ruby code into an abstract syntax tree (AST)

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Parser

Returns a new instance of Parser.



48
49
50
 
# File 'lib/exel/job.rb', line 48

def initialize
  @ast = SequenceNode.new
end

Instance Attribute Details

#ast ⇒ Object (readonly)

Returns the value of attribute ast.



46
47
48
 
# File 'lib/exel/job.rb', line 46

def ast
  @ast
end

Class Method Details

.parse(dsl_proc_or_code) ⇒ Object 



52
53
54
55
56
57
58
59
60
 
# File 'lib/exel/job.rb', line 52

def self.parse(dsl_proc_or_code)
  parser = Parser.new
  if dsl_proc_or_code.is_a?(::Proc)
    parser.instance_eval(&dsl_proc_or_code)
  else
    parser.instance_eval(dsl_proc_or_code)
  end
  parser.ast
end

Instance Method Details

#async(options = {}, &block) ⇒ Object 



67
68
69
 
# File 'lib/exel/job.rb', line 67

def async(options = {}, &block)
  add_instruction_node(Processors::AsyncProcessor, parse(block), options)
end

#context ⇒ Object 



84
85
86
 
# File 'lib/exel/job.rb', line 84

def context
  DeferredContextValue.new
end

#listen(options) ⇒ Object 



79
80
81
82
 
# File 'lib/exel/job.rb', line 79

def listen(options)
  instruction = ListenInstruction.new(options.fetch(:for), options.fetch(:with))
  @ast.add_child(InstructionNode.new(instruction))
end

#process(options, &block) ⇒ Object 



62
63
64
65
 
# File 'lib/exel/job.rb', line 62

def process(options, &block)
  processor_class = options.delete(:with)
  add_instruction_node(processor_class, parse(block), options)
end

#run(options = {}, &block) ⇒ Object 



75
76
77
 
# File 'lib/exel/job.rb', line 75

def run(options = {}, &block)
  add_instruction_node(Processors::RunProcessor, parse(block), options)
end

#split(options = {}, &block) ⇒ Object 



71
72
73
 
# File 'lib/exel/job.rb', line 71

def split(options = {}, &block)
  add_instruction_node(Processors::SplitProcessor, parse(block), options)
end