Rename Interpreter class as Worker
This commit is contained in:
parent
cdc3128727
commit
4c0a7f0fc7
@ -14,7 +14,6 @@ require 'producer/core/condition'
|
|||||||
require 'producer/core/condition/dsl'
|
require 'producer/core/condition/dsl'
|
||||||
require 'producer/core/env'
|
require 'producer/core/env'
|
||||||
require 'producer/core/errors'
|
require 'producer/core/errors'
|
||||||
require 'producer/core/interpreter'
|
|
||||||
require 'producer/core/recipe'
|
require 'producer/core/recipe'
|
||||||
require 'producer/core/recipe/dsl'
|
require 'producer/core/recipe/dsl'
|
||||||
require 'producer/core/remote'
|
require 'producer/core/remote'
|
||||||
@ -23,3 +22,4 @@ require 'producer/core/remote/fs'
|
|||||||
require 'producer/core/task'
|
require 'producer/core/task'
|
||||||
require 'producer/core/task/dsl'
|
require 'producer/core/task/dsl'
|
||||||
require 'producer/core/version'
|
require 'producer/core/version'
|
||||||
|
require 'producer/core/worker'
|
||||||
|
@ -28,7 +28,7 @@ module Producer
|
|||||||
@stdout = stdout
|
@stdout = stdout
|
||||||
end
|
end
|
||||||
|
|
||||||
def run(worker: Interpreter.new)
|
def run(worker: Worker.new)
|
||||||
load_recipe
|
load_recipe
|
||||||
worker.process recipe.tasks
|
worker.process recipe.tasks
|
||||||
end
|
end
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
module Producer
|
module Producer
|
||||||
module Core
|
module Core
|
||||||
class Interpreter
|
class Worker
|
||||||
def process(tasks)
|
def process(tasks)
|
||||||
tasks.each { |t| process_task t }
|
tasks.each { |t| process_task t }
|
||||||
end
|
end
|
@ -1,13 +1,13 @@
|
|||||||
require 'spec_helper'
|
require 'spec_helper'
|
||||||
|
|
||||||
module Producer::Core
|
module Producer::Core
|
||||||
describe Interpreter do
|
describe Worker do
|
||||||
subject(:interpreter) { Interpreter.new }
|
subject(:worker) { described_class.new }
|
||||||
|
|
||||||
describe '#process' do
|
describe '#process' do
|
||||||
it 'processes each task' do
|
it 'processes each task' do
|
||||||
expect(interpreter).to receive(:process_task).with(:some_task)
|
expect(worker).to receive(:process_task).with(:some_task)
|
||||||
interpreter.process [:some_task]
|
worker.process [:some_task]
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
@ -18,7 +18,7 @@ module Producer::Core
|
|||||||
context 'when task condition is met' do
|
context 'when task condition is met' do
|
||||||
it 'applies the actions' do
|
it 'applies the actions' do
|
||||||
expect(action).to receive :apply
|
expect(action).to receive :apply
|
||||||
interpreter.process_task task
|
worker.process_task task
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
@ -27,7 +27,7 @@ module Producer::Core
|
|||||||
|
|
||||||
it 'does not apply the actions' do
|
it 'does not apply the actions' do
|
||||||
expect(action).not_to receive :apply
|
expect(action).not_to receive :apply
|
||||||
interpreter.process_task task
|
worker.process_task task
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
Loading…
x
Reference in New Issue
Block a user