#! /usr/bin/env ruby
# -*- coding: UTF-8 -*-

require 'iotas'

HBN_PATH='hibernate.json'
#
class InputDoor < Iotas::Door
    #
    @count = 0
    #
    class << self
        attr_accessor :count
    end
    #
    def initialize n, p
        super n, p
        @lines = [ "#{name} says : hello", "world ( from #{path} )" ]
        @idx = 0
    end
    #
    def start!
        puts " -> start #{self.class.name} (#{@path})"
        # stimulate myself
        p = require_p Iotas::Particle
        # p.add_dst Iotas::ACT_GET, path
        send_p p, Iotas::ACT_GET
    end
    #
    def stop!
        puts " >- stop  #{self.class.name} (#{@path})"
    end
    #
    def hibernate!
        puts " !! hibernate  #{self.class.name} (#{@path})"
        # we want to remember where we are in the data flow
        {'idx'=>@idx}
    end
    #
    def resume! o
        puts " !! resume  #{self.class.name} (#{@path})"
        # restore idx
        @idx = o['idx']
    end
    #
    def receive_p p
        puts " @ #{self.class.name} (#{@path}) receive_p : #{p.action}"
        if p.action==Iotas::ACT_GET
            p.reset!
            p.set_data 'line', @lines[@idx]
            p.set_data 'f0', 'v0'
            p.set_data 'f1', 'v1'
            p.set_data 'f2', 'v2'
            send_p p    # will follow the link
            @idx+=1
            if @idx<@lines.length
                # there is more to read, restimulate myself
                p = require_p Iotas::Particle
                p.add_dst Iotas::ACT_GET, name
                send_p p
            end
        else
            # we can release it or let the Door do it
            release_p p
        end
        # I want to hibernate now!
        self.class.count+=1
        if self.class.count==3
            p = require_p Iotas::Particle
            p[Iotas::FIELD_HIBERNATE_PATH] = HBN_PATH
            p.add_dst Iotas::SYS_ACT_HIBERNATE
            send_sys_p p
        end
    end
    #
end
#
class ConcatBoard < Iotas::Board
    #
    def initialize n, p, m=false
        super n, p
        @manual = m
    end
    #
    def start!
        puts " -> start #{self.class.name} (#{@path})"
    end
    #
    def stop!
        puts " >- stop  #{self.class.name} (#{@path})"
    end
    #
    def receive_p p
        puts " @ #{self.class.name} receive_p : #{p.action}"
        if p.action==Iotas::ACT_ERROR
            #
        else
            if @manual
                # cleanup unnecessary p2 Particle
                p2 = p.merged_shift
                p.set_data 'line', (p.data('line')+' '+p2.data('line'))
                release_p p2
            else
                # Or let the system do it
                p.set_data 'line', (p.data('line')+' '+p.merged(0).data('line'))
            end
            send_p p
        end
    end
    #
end
#
class OutputDoor < Iotas::Door
    #
    def initialize n, p, c=false
        super n, p
        @clean = c
    end
    #
    def start!
        puts " -> start #{self.class.name} (#{@path})"
    end
    #
    def stop!
        puts " >- stop  #{self.class.name} (#{@path})"
    end
    #
    def receive_p p
        puts " #==> #{self.class.name} (#{@path}) receive_p : #{p.get_data('line')}"
        if @clean
            release_p p
        else
            # we do nothing Iotas::Door#process_p will detect it and release it
        end
    end
    #
end
#
spin = Iotas::Spin.new 'dom0', :debug_routing=>false, :debug_errors=>true
#
room0 = Iotas::Room.new 'room0', spin
room1 = Iotas::Room.new 'room1', spin
#
input0 = InputDoor.new 'input0', room0
output0 = OutputDoor.new 'output0', room0
#
input1 = InputDoor.new 'input1', room1
output1 = OutputDoor.new 'output1', room1, true
concat1 = ConcatBoard.new 'concat1', room1
#
room0.add_link Iotas::Link.new('input0', 'output0', nil, nil, nil)
#
p0 = spin.require_p Iotas::Particle
p0.set_data Iotas::LNK_SRC, 'input1'
p0.set_data Iotas::LNK_DSTS, 'concat1?follow,output1'
p0.set_data Iotas::LNK_FIELDS, 'f0,f2'
p0.set_data Iotas::LNK_CONDF, 'f0,f1,f2'
p0.set_data Iotas::LNK_CONDV, 'v0v1v2'
p0.add_dst Iotas::SYS_ACT_ADD_LINK, room1.path
room1.send_sys_p p0 # send_sys_p -> room0 -> spin -> room1 -> input1
#
spin.spin!
#
dom0 = Iotas::Spin.resume! HBN_PATH
dom0.spin!
File.unlink HBN_PATH if File.exists? HBN_PATH
#
# EOF