add examples/board.rb

1 files changed, 115 insertions, 0 deletions

diff --git a/examples/board.rb b/examples/board.rb
new file mode 100644
index 0000000..b76679f
--- /dev/null
+++ b/examples/board.rb
@@ -0,0 +1,115 @@
+#! /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
+            if @file.eof?
+                p.reset!
+                send_p p, Edoors::ACT_PASS_THROUGH, 'stats'
+            else
+                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
+    #
+end
+#
+class Filter < Edoors::Door
+    #
+    def receive_p p
+        if p.action!=Edoors::ACT_ERROR
+            # apply the filter
+            h = {
+                :old => (p['person']['age']>=18),
+                :female => (p['person']['sex']=='f')
+            }
+            # puts "input : "+h.inspect
+            # store the result into one single attribute
+            p['filter_value']= h
+            # will follow the conditional link.
+            # see Room#_send and Room#_try_links
+            send_p p
+        end
+    end
+    #
+end
+#
+class Stats < Edoors::Board
+    #
+    def receive_p p
+        return if p.action==Edoors::ACT_ERROR
+        if p.action==Edoors::ACT_PASS_THROUGH
+            # use this signal to flush all stored data
+            flush!
+        else
+            # restore the Particle into myself
+            # send_p p, self.path
+            keep! p
+        end
+    end
+    #
+end
+#
+class OutputDoor < Edoors::Door
+    #
+    #
+    def receive_p p
+        return if p.action==Edoors::ACT_ERROR
+        f = p['filter_value']
+        puts "Team #{f[:old] ? 'mature' : 'tean'} #{f[:female] ? 'women' : 'men'} #{} (#{p.merged_length+1})"
+        d = p.get_data('person')
+        puts " #{d['name']} is #{d['age']} years old"
+        p.each_merged do |o|
+            d = o.get_data('person')
+            puts " #{d['name']} is #{d['age']} years old"
+        end
+        puts
+    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 'filter', dom0
+    # the statistics board
+    Stats.new 'stats', dom0
+    # different outptu doors
+    OutputDoor.new 'output', dom0
+    # default link directing everything from input into age_filter
+    dom0.add_link Edoors::Link.new('input', ['filter','stats?follow','output'], 'filter_value')
+    #
+    # schedule the spinning particles untill the system cools down
+    dom0.spin!
+    #
+end
+#
+# EOF