FLOWer interpreter on Ruby

Usage: flower.rb [<] flower.json
※flower.jsonはダウンロードしたzipを展開すると取り出せます。

本家FLOWerのジョブの3割ほどをカバーしています。
挙動については私の類推です。
条件分岐はドキュメントがないため実装できませんでした。。

複数のジョブから一度に値を受け取った時は先に生成されたジョブから受け取った値を先に使用するという挙動は再現出来ているはずです。

flower.rb

#!/usr/bin/ruby
require 'json'

#FLOWer Job parent
class FLOWerJob
	def initialize(jobs,inputports,constant,outputports)
		@jobs=jobs # fixme
		@queue=Hash.new{|h,k|h[k]=[]}
		@inputports=inputports
		@constant=constant
		@outputports=outputports
		@input={}
		@constant.each{|k,v|
			@input[k]=v
		}
	end
	def send_value(port,value)
		@queue[port]<< value
	end
	def accept_value
		@queue.each{|k,v|
			if @input[k]==nil && v.size>0
				@input[k]=v.shift
			end
		}
	end
	def query
		return if @inputports.any?{|e|@input[e]==nil}
		query2
		@inputports.each{|e|
			@input[e]=nil if !@constant.has_key?(e)
		}
	end
end

#FLOWer Jobs
#core
class FLOWerJob_core_Through <FLOWerJob
	def query2
		value=@input['input']
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_core_Add <FLOWerJob
	def query2
		value=@input['input1']+@input['input2']
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_core_Times <FLOWerJob
	def query2
		value=@input['input1']*@input['input2']
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_core_And <FLOWerJob
	def query2
		value=@input['input1']&@input['input2']
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_core_Or <FLOWerJob
	def query2
		value=@input['input1']|@input['input2']
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_core_Transistor <FLOWerJob
	def query2
		value=@input['emitter']
		@outputports['collector'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
#number
class FLOWerJob_number_C0 <FLOWerJob
	def query2
		value=0
		@outputports['0'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C1 <FLOWerJob
	def query2
		value=1
		@outputports['1'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C2 <FLOWerJob
	def query2
		value=2
		@outputports['2'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C3 <FLOWerJob
	def query2
		value=3
		@outputports['3'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C4 <FLOWerJob
	def query2
		value=4
		@outputports['4'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C5 <FLOWerJob
	def query2
		value=5
		@outputports['5'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C6 <FLOWerJob
	def query2
		value=6
		@outputports['6'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C7 <FLOWerJob
	def query2
		value=7
		@outputports['7'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C8 <FLOWerJob
	def query2
		value=8
		@outputports['8'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_number_C9 <FLOWerJob
	def query2
		value=9
		@outputports['9'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
#math
class FLOWerJob_math_Abs <FLOWerJob
	def query2
		value=@input['input'].abs
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_math_Max <FLOWerJob
	def query2
		value=[@input['a'],@input['b']].max
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_math_Max <FLOWerJob
	def query2
		value=[@input['a'],@input['b']].min
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
#system
class FLOWerJob_system_Speed <FLOWerJob
	def query2
		value=@input['speed']
		# do nothing here
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_system_Print <FLOWerJob
	def query2
		value=@input['input']
		print value.to_s+', '
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
class FLOWerJob_system_Scan <FLOWerJob
	def query2
		#value=@input['input']
		print 'input> '
		value=gets.to_i
		@outputports['output'].each{|job,port|
			@jobs[job].send_value(port,value)
		}
	end
end
#snapsvg
#snapelement
#map
#string
#array

#flower.json runner
class FLOWer
	def initialize(json_str)
		json=JSON.parse(json_str)
		@jobs={}
		json['diagram']['jobs'].each{|e|
			id=e['id']
			constant={}
			inputports=[]
			e['inputports'].each{|f|
				inputports<<f['name']
				if f['constant']
					constant[f['name']]=f['constant']['value']
				end
			}
			if e['ref']
				ref=e['ref']
			else
				ref='core.Through'
				inputports=['input']
				@entry=id
			end
			outputports={}
			e['outputports'].map{|f|
				outputports[f['name']]=f['connections'].map{|e|e.split('.')}
			}
			#If NameError is thrown here, that means the job is not implemented yet.
			@jobs[id]=Object.const_get('FLOWerJob_'+ref.gsub('.','_')).new(@jobs,inputports,constant,outputports)
		}
	end
	def run
		@jobs[@entry].send_value('input',0)
		@jobs[@entry].accept_value
		loop{
			@jobs.each{|k,v|
				v.query
			}
			@jobs.each{|k,v|
				v.accept_value
			}
		}
	end
end
FLOWer.new($<.read).run