initial commit -> ServiceBase, CommandBase, DataProxy

Author: ahanusa

DataProxies/DatabaseProxies/active_record_data_proxy.rb

@@ -0,0 +1,23 @@
+require_relative "../../data_proxy"
+
+class ActiveRecordDataProxy < DataProxy
+  def get_all
+    raise "get_all must be implemented"
+  end
+
+  def get_by_id(id)
+    raise "get_by_id must be implemented"
+  end
+
+  def insert(state)
+    raise "insert must be implemented"
+  end
+
+  def update(state)
+    raise "update must be implemented"
+  end
+
+  def delete(id)
+    raise "delete must be implemented"
+  end
+end

DataProxies/DatabaseProxies/customer_database_proxy.rb

@@ -0,0 +1,33 @@
+require_relative "active_record_data_proxy"
+
+class CustomerDatabaseProxy < ActiveRecordDataProxy
+  def get_all
+    puts "GETTING all entities from database"
+    [{:name => "Aaron" }, {:name => "Jack"}, {:name => "Terry"}]
+  end
+
+  def get_by_id(id)
+    puts "GETTING entity from database #{id}"
+    {:name => "Aaron" }
+  end
+
+  def insert(entity)
+    puts "INSERTING entity into database"
+    puts entity
+    puts "INSERTED entity"
+    entity
+  end
+
+  def update(entity)
+    puts "UPDATING entity in database"
+    puts entity
+    puts "UPDATING entity"
+    entity
+  end
+
+  def delete(id)
+    puts "DELETING entity in database"
+    puts id
+    puts "DELETING entity"
+  end
+end

DataProxies/RestfulServiceProxies/customer_restful_proxy.rb

@@ -0,0 +1,33 @@
+require_relative 'restful_service_proxy'
+
+class CustomerRestfulProxy < RestfulServiceProxy
+  def get_all
+    puts "GETTING all entities via GET http://api/customers"
+    [{:name => "Aaron" }, {:name => "Jack"}, {:name => "Terry"}]
+  end
+
+  def get_by_id(id)
+    puts "GETTING entity via GET http://api/customers/#{id}"
+    {:name => "Aaron" }
+  end
+
+  def insert(entity)
+    puts "INSERTING entity via POST http://api/customers"
+    puts entity
+    puts "INSERTED entity"
+    entity
+  end
+
+  def update(entity)
+    puts "UPDATING entity via PUT http://api/customers/#{entity[:id]}" 
+    puts entity
+    puts "UPDATING entity"
+    entity
+  end
+
+  def delete(id)
+    puts "DELETING entity via DELETE http://api/customers/#{id}" 
+    puts id
+    puts "DELETING entity"
+  end
+end

DataProxies/RestfulServiceProxies/restful_service_proxy.rb

@@ -0,0 +1,23 @@
+require_relative "../../data_proxy"
+
+class RestfulServiceProxy < DataProxy
+  def get_all
+    raise "get_all must be implemented"
+  end
+
+  def get_by_id(id)
+    raise "get_by_id must be implemented"
+  end
+
+  def insert(state)
+    raise "insert must be implemented"
+  end
+
+  def update(state)
+    raise "update must be implemented"
+  end
+
+  def delete(id)
+    raise "delete must be implemented"
+  end
+end

command_base.rb

@@ -0,0 +1,31 @@
+require_relative "execution_result"
+
+class CommandBase
+
+  def initialize(execute_method, business_rules_method)
+    @execute_method = execute_method
+    @business_rules_method = business_rules_method
+  end
+
+  def can_execute?
+    !get_validation_errors.any?
+  end
+
+  def execute
+    errors = get_validation_errors
+    if errors.any?
+      return ExecutionResult.new(false, nil, errors)
+    end
+
+    execution_result = @execute_method.call
+    return ExecutionResult.new(true, execution_result, nil)
+  end
+
+  protected
+
+  def get_validation_errors
+    #raise "must implement get_validation_errors"
+    errors = @business_rules_method.call
+  end
+
+end

data_proxy.rb

@@ -0,0 +1,21 @@
+class DataProxy
+  def get_all
+    raise "get_all must be implemented"
+  end
+
+  def get_by_id(id)
+    raise "get_by_id must be implemented"
+  end
+
+  def insert(state)
+    raise "insert must be implemented"
+  end
+
+  def update(state)
+    raise "update must be implemented"
+  end
+
+  def delete(id)
+    raise "delete must be implemented"
+  end
+end

execution_result.rb

@@ -0,0 +1,9 @@
+class ExecutionResult
+  attr_reader :success, :value, :errors
+
+  def initialize(success, value, errors)
+    @success = success
+    @value = value
+    @errors = errors
+  end
+end

service_base.rb

@@ -0,0 +1,85 @@
+require_relative "command_base"
+
+class ServiceBase
+
+  def initialize(data_proxy)
+    @data_proxy = data_proxy  
+  end
+
+  def get_by_id_command(id)
+    CommandBase.new(get_by_id(id), rules_for_get_by_id(id))
+  end
+
+  def get_all_command
+   CommandBase.new(get_all, rules_for_get_all)
+  end
+
+  def insert_command(entity)
+    CommandBase.new(insert(entity), rules_for_insert(entity))
+  end
+
+  def update_command(entity)
+    CommandBase.new(update(entity), rules_for_update(entity))
+  end
+
+  def delete_command(id)
+    CommandBase.new(delete(id), rules_for_delete(id))
+  end
+
+  protected
+
+  def get_by_id(id)
+    return Proc.new do
+      @data_proxy.get_by_id(id)
+    end
+  end
+
+  def rules_for_get_by_id(id)
+    return Proc.new { [] }
+  end
+
+  def get_all
+    return Proc.new do
+      @data_proxy.get_all
+    end
+  end
+
+  def rules_for_get_all
+    return Proc.new { [] }
+  end
+
+  def insert(entity)
+    return Proc.new do 
+      @data_proxy.insert(entity)
+    end
+  end
+
+  def rules_for_insert(entity)
+    return Proc.new { [] } 
+  end
+
+  def update(entity)
+    return Proc.new do 
+      @data_proxy.update(entity)
+    end
+  end
+
+  def rules_for_update(entity)
+    #return Proc.new do
+      ## return entity_must_contain_id_field_rule
+    #end
+    return Proc.new { [] } 
+  end
+
+  def delete(id) 
+    return Proc.new do 
+      @data_proxy.delete(id)
+    end
+  end
+
+  def rules_for_delete(id)
+    return Proc.new { [] } 
+  end
+end
+
+

tests.rb

@@ -0,0 +1,30 @@
+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"
+
+class CustomerService < ServiceBase
+  def initialize(data_proxy)
+    super(data_proxy)
+  end
+end
+
+customer_data_proxy = CustomerRestfulProxy.new
+#customer_data_proxy = CustomerDatabaseProxy.new
+
+service = CustomerService.new(customer_data_proxy)
+result = service.insert_command({:name => "Aaron"}).execute
+puts result.inspect
+
+result = service.get_by_id_command(1).execute
+puts result.inspect
+
+result = service.get_all_command.execute
+puts result.inspect
+
+result = service.update_command({:id => 1, :name => "Aaron"}).execute
+puts result.inspect
+
+result = service.delete_command(1).execute
+puts result.inspect

validation_result.rb

@@ -0,0 +1,7 @@
+class ValidationResult
+  attr_accessor :member, :error_messages
+
+  def initialize
+    @error_messages = []
+  end
+end