-
Notifications
You must be signed in to change notification settings - Fork 0
/
pipeline_spec.rb
89 lines (67 loc) · 2.66 KB
/
pipeline_spec.rb
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
require "spec_helper"
require "dry/validation"
RSpec.describe "Pipeline examples" do
it "builds a simple pipeline of operations adding to an array with pre-conditions and post-conditions" do
# standard:disable Lint/ConstantDefinitionInBlock
class BuildArray < Plumbing::Pipeline
perform :add_first
perform :add_second
perform :add_third
pre_condition :must_be_an_array do |input|
input.is_a? Array
end
post_condition :must_have_three_elements do |output|
output.length == 3
end
private
def add_first(input) = input << "first"
def add_second(input) = input << "second"
def add_third(input) = input << "third"
end
# standard:enable Lint/ConstantDefinitionInBlock
expect(BuildArray.new.call([])).to eq ["first", "second", "third"]
expect { BuildArray.new.call(1) }.to raise_error(Plumbing::PreConditionError)
expect { BuildArray.new.call(["extra element"]) }.to raise_error(Plumbing::PostConditionError)
end
it "builds a simple pipeline of operations using an external class to implement one of the steps" do
# standard:disable Lint/ConstantDefinitionInBlock
class ExternalStep < Plumbing::Pipeline
perform :add_item_to_array
private
def add_item_to_array(input) = input << "external"
end
class BuildSequenceWithExternalStep < Plumbing::Pipeline
perform :add_first
perform :add_second, using: "ExternalStep"
perform :add_third
private
def add_first(input) = input << "first"
def add_third(input) = input << "third"
end
# standard:enable Lint/ConstantDefinitionInBlock
expect(BuildSequenceWithExternalStep.new.call([])).to eq ["first", "external", "third"]
end
it "uses a dry-validation contract to test the input parameters" do
# standard:disable Lint/ConstantDefinitionInBlock
class SayHello < Plumbing::Pipeline
validate_with "SayHello::Input"
perform :say_hello
private
def say_hello input
"Hello #{input[:name]} - I will now send a load of annoying marketing messages to #{input[:email]}"
end
class Input < Dry::Validation::Contract
params do
required(:name).filled(:string)
required(:email).filled(:string)
end
rule :email do
key.failure("must be a valid email") unless /\A[\w+\-.]+@[a-z\d\-]+(\.[a-z\d\-]+)*\.[a-z]+\z/i.match? value
end
end
end
# standard:enable Lint/ConstantDefinitionInBlock
SayHello.new.call(name: "Alice", email: "alice@example.com")
expect { SayHello.new.call(some: "other data") }.to raise_error(Plumbing::PreConditionError)
end
end