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
|
#! /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
#
require 'edoors'
#
class FileReader < Edoors::Door
#
def initialize n, p, path
super n, p
@file = File.open(path,'r')
end
#
def start!
# 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
start!
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
super n, p
@title = t
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!
#
end
#
# EOF
|
