add threading test

Author: ahanusa

entity_base.rb

@@ -0,0 +1,5 @@
+class EntityBase
+  def id=(value)
+    raise "id must be implemented"
+  end
+end

threading_test.rb

@@ -0,0 +1,45 @@
+require_relative "command_base"
+require_relative "execution_result"
+require_relative "service_base"
+require_relative "DataProxies/DatabaseProxies/customer_database_proxy"
+require_relative "DataProxies/RestfulServiceProxies/customer_restful_proxy"
+require_relative "Rules/field_length_rule"
+require_relative "Rules/field_required_rule"
+
+class CustomerService < ServiceBase
+  def initialize(data_proxy)
+    super(data_proxy)
+  end
+  def rules_for_insert(entity)
+    rules = []
+    rules << FieldRequiredRule.new(entity, :name)
+                              .if_valid_then_execute(lambda { |rule| puts "WOOT!" })
+                              .if_valid_then_validate(FieldLengthRule.new(entity, :name, 10)
+                                                                     .if_invalid_then_execute(lambda { |rule| puts "ARGH!!" }))
+    rules
+  end
+end
+
+#customer_data_proxy = CustomerRestfulProxy.new
+customer_data_proxy = CustomerDatabaseProxy.new
+
+service = CustomerService.new(customer_data_proxy)
+
+commands = []
+commands << service.insert_command({:id => 1, :name => ""})
+commands << service.insert_command({:id => 2, :name => "Foo Bar"})
+commands << service.insert_command({:id => 3, :name => ""})
+commands << service.insert_command({:id => 4, :name => "Mikasaessucasa"})
+commands << service.insert_command({:id => 5, :name => "John"})
+commands << service.insert_command({:id => 6, :name => ""})
+commands << service.insert_command({:id => 7, :name => ""})
+commands << service.insert_command({:id => 8, :name => "meh"})
+commands << service.insert_command({:id => 9, :name => ""})
+commands << service.insert_command({:id => 10, :name => "Aargssssssssss"})
+commands << service.insert_command({:id => 11, :name => ""})
+
+results = []
+threads = commands.map { |command| Thread.new(command) { |command| results << command.execute } }
+threads.each { |t| t.join }
+
+results.each { |result| puts result.inspect }

validation_result.rb

@@ -1,7 +1,8 @@
 class ValidationResult
-  attr_accessor :member, :error_messages
+  attr_accessor :entity, :error_messages
 
-  def initialize
-    @error_messages = []
+  def initialize(entity, error_messages = [])
+    @entity = entity
+    @error_messages = error_messages 
   end
 end