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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
#! /usr/bin/env ruby
# -*- coding: UTF-8 -*-
#
# from the project top directory :
#
# run this script which builds the example system and spin it untill it's empty:
# $ ruby -Ilib examples/links.rb
#
# or load the system from a JSON specification ( created with dom0.hibernate! )
# $ ruby -Ilib -r ./examples/links.rb bin/edoors.rb examples/links.json
#
#
require 'edoors'
#
class FileReader < Edoors::Door
#
def initialize n, p, path=nil
super n, p
@filepath = path
end
#
def hibernate!
{'filepath'=>@filepath}
end
#
def resume! o
@filepath = o['filepath']
end
#
def start!
@file = File.open(@filepath,'r')
# stimulate myself on system boot up
send_p require_p(Edoors::Particle), Edoors::ACT_GET
end
#
def receive_p p
if p.action==Edoors::ACT_GET
# stop everything if EOF reached
return if @file.eof?
p.set_data 'person', JSON.load(@file.readline)
# will follow the non conditional link.
# see Room#_send and Room#_try_links
send_p p
# stimulate myself
send_p require_p(Edoors::Particle), Edoors::ACT_GET
end
end
#
end
#
class Filter < Edoors::Door
#
def receive_p p
if p.action!=Edoors::ACT_ERROR
# apply the filter
p['old'] = (p['person']['age']>=18)
p['sex'] = p['person']['sex']
# will follow the conditional link.
# see Room#_send and Room#_try_links
send_p p
end
end
#
end
#
class OutputDoor < Edoors::Door
#
def initialize n, p, t=nil
super n, p
@title = t
end
#
def hibernate!
{'title'=>@title}
end
#
def resume! o
@title = o['title']
end
#
def receive_p p
if p.action!=Edoors::ACT_ERROR
p = p.get_data('person')
puts "#{p['name']} is a #{p['age']} year(s) old #{@title}"
end
end
#
end
#
if $0 == __FILE__
# basic setup, see hello_world.rb
dom0 = Edoors::Spin.new 'dom0'
#
FileReader.new 'input', dom0, './examples/data.json'
# the filter to be applied to each particle
Filter.new 'age_filter', dom0
# different output doors
OutputDoor.new 'output_f', dom0, 'woman'
OutputDoor.new 'output_m', dom0, 'man'
OutputDoor.new 'output_child', dom0, 'child'
OutputDoor.new 'output_parent', dom0, 'parent'
# default link directing everything from input into age_filter
dom0.add_link Edoors::Link.new('input', 'age_filter')
# different links directing to different outputs depending on 'sex' key
dom0.add_link Edoors::Link.new('age_filter', 'output_f', nil, {'sex'=>'f'})
dom0.add_link Edoors::Link.new('age_filter', 'output_m', nil, {'sex'=>'m'})
# different links directing to different outputs depending on 'old' key
dom0.add_link Edoors::Link.new('age_filter', 'output_child', nil, {'old'=>false})
dom0.add_link Edoors::Link.new('age_filter', 'output_parent', nil, {'old'=>true})
#
# schedule the spinning particles untill the system cools down
dom0.spin!
#
# you can save the system state after it's run,
# but to be able to use it to bootstrap, the hibernation attribute must be set to false
# otherwise start! method is not called
dom0.hibernate! 'links.json'
#
end
#
# EOF
|
