initial

Author: dizer

.gitignore

@@ -0,0 +1,30 @@
+/.bundle
+
+/.yardoc
+/_yardoc/
+/coverage/
+/pkg/
+
+# Ignore all logfiles and tempfiles.
+/log/*
+/tmp/*
+!/log/.keep
+!/tmp/.keep
+mkmf.log
+
+nbproject
+.idea
+*~
+
+*.swp
+*.swap
+*.bundle
+*.so
+*.o
+*.a
+
+.vagrant
+.ruby-env
+.DS_Store
+Vagrantfile
+Gemfile.lock

.rspec

@@ -0,0 +1,2 @@
+--color
+--require spec_helper

Gemfile

@@ -0,0 +1,14 @@
+source 'https://rubygems.org'
+
+gem 'activesupport', '>= 5.0.0'
+
+group :development, :test do
+  gem 'rspec',       '~> 3.5.0'
+  gem 'spring'
+  gem 'factory_girl'
+end
+
+group :test do
+  gem 'webmock'
+  gem 'vcr'
+end

LICENSE.txt

@@ -0,0 +1,22 @@
+Copyright (c) 2016 dizer
+
+MIT License
+
+Permission is hereby granted, free of charge, to any person obtaining
+a copy of this software and associated documentation files (the
+"Software"), to deal in the Software without restriction, including
+without limitation the rights to use, copy, modify, merge, publish,
+distribute, sublicense, and/or sell copies of the Software, and to
+permit persons to whom the Software is furnished to do so, subject to
+the following conditions:
+
+The above copyright notice and this permission notice shall be
+included in all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1 @@
+# Eureka Bot gem

eureka-bot.gemspec

@@ -0,0 +1,23 @@
+# coding: utf-8
+lib = File.expand_path('../lib', __FILE__)
+$LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
+require 'eureka_bot/version'
+
+Gem::Specification.new do |spec|
+  spec.name          = "eureka-bot"
+  spec.version       = EurekaBot::VERSION
+  spec.authors       = ["dizer"]
+  spec.email         = ["[email protected]"]
+  spec.summary       = %q{Run your messenger bots}
+  spec.homepage      = ""
+  spec.license       = "MIT"
+
+  spec.files         = `git ls-files -z`.split("\x0")
+  spec.executables   = spec.files.grep(%r{^bin/}) { |f| File.basename(f) }
+  spec.test_files    = spec.files.grep(%r{^(test|spec|features)/})
+  spec.require_paths = ["lib"]
+
+  spec.add_development_dependency "bundler", "~> 1.7"
+  spec.add_development_dependency "rake", "> 10.0"
+  spec.add_development_dependency "rspec", "~> 3.5.0"
+end

lib/eureka-bot.rb

@@ -0,0 +1,11 @@
+$:.unshift File.dirname(__FILE__)
+
+require 'active_support'
+require 'active_support/core_ext'
+
+module EurekaBot
+  extend ActiveSupport::Autoload
+
+  autoload :Version
+  autoload :Controller
+end

lib/eureka_bot/controller.rb

@@ -0,0 +1,36 @@
+class EurekaBot::Controller
+  extend ActiveSupport::Autoload
+
+  autoload :Response
+  autoload :Resolver
+
+  attr_reader :params, :message, :logger, :response
+
+  def initialize(params: {}, message: nil, response: nil, logger: Logger.new(STDOUT))
+    @params   = params
+    @message  = message
+    @logger   = logger
+    @response = response || response_class.new(logger: logger)
+    @response.controller = self
+  end
+
+  def execute(action)
+    if respond_to?(action, include_all: false)
+      public_send(action)
+    else
+      raise UnknownAction.new("Action #{action} is not defined in #{self.class}")
+    end
+    self
+  end
+
+  def answer(params={})
+    response << params
+  end
+
+  def response_class
+    EurekaBot::Controller::Response
+  end
+
+  class UnknownAction < StandardError; end
+
+end

lib/eureka_bot/controller/resolver.rb

@@ -0,0 +1,30 @@
+class EurekaBot::Controller::Resolver
+
+  attr_reader :logger, :message, :response
+
+  def initialize(message:, response: nil, logger: Logger.new(STDOUT))
+    @logger   = logger
+    @message  = message
+    @response = response
+  end
+
+  def resolve
+    nil
+  end
+
+  def execute
+    resolved = resolve
+    raise ActionNotFound.new("Cant resolve path for #{message}") unless resolved
+    controller = resolved[:controller].new(
+        params:   {},
+        message:  message,
+        logger:   logger,
+        response: response
+    )
+    controller.execute(resolved[:action])
+  end
+
+  class ActionNotFound < StandardError;
+  end
+
+end

lib/eureka_bot/controller/response.rb

@@ -0,0 +1,27 @@
+class EurekaBot::Controller::Response
+  include ActiveSupport::Callbacks
+  define_callbacks :add
+
+  attr_reader :logger, :data
+  attr_accessor :controller
+
+  def initialize(logger: Logger.new(STDOUT))
+    @logger = logger
+    @data   = []
+  end
+
+  def add(params={})
+    run_callbacks :add do
+      @data << params
+    end
+  end
+
+  def <<(params={})
+    add(params)
+  end
+
+  def to_a
+    data
+  end
+
+end

lib/eureka_bot/version.rb

@@ -0,0 +1,3 @@
+module EurekaBot
+  VERSION = '1.0.0'
+end

log/.keep

@@ -0,0 +1,30 @@
+require 'spec_helper'
+
+RSpec.describe EurekaBot::Controller do
+
+  context 'response' do
+    let(:controller) { EurekaBot::Controller.new }
+
+    it 'is EurekaBot::Controller::Response subclass' do
+      expect(controller.response).to be_a_kind_of(EurekaBot::Controller::Response)
+    end
+
+    context '#answer' do
+      let(:controller) do
+        Class.new(EurekaBot::Controller) do
+          def some_action
+            answer(some_action: 'finished')
+          end
+        end.new
+      end
+
+      before do
+        controller.some_action
+      end
+
+      it do
+        expect(controller.response.to_a).to include(include(some_action: 'finished'))
+      end
+    end
+  end
+end

spec/eureka-bot/controller_spec.rb

@@ -0,0 +1,60 @@
+ENV['NEW_RELIC_ENV'] = 'test'
+
+require 'bundler'
+Bundler.require
+require './lib/eureka-bot'
+require 'webmock/rspec'
+require 'vcr'
+require 'factory_girl'
+
+$:.unshift File.dirname(__FILE__) + '/..'
+Dir['spec/support/**/*.rb'].each { |f| require f }
+
+RSpec.configure do |config|
+  config.include WebRequestHelper
+  config.include SettingsHelper
+  config.include FactoryGirl::Syntax::Methods
+
+  config.before(:suite) do
+    FactoryGirl.find_definitions
+    lint_time = Benchmark.realtime do
+      factories_for_lint = FactoryGirl.factories.select{|f| f.send(:class_name) != Hash}
+      FactoryGirl.lint(factories_for_lint)
+    end
+    # puts "=== FactoryGirl.lint complete in #{lint_time} seconds ==="
+  end
+
+  config.expect_with :rspec do |expectations|
+    expectations.include_chain_clauses_in_custom_matcher_descriptions = true
+  end
+
+  config.mock_with :rspec do |mocks|
+    mocks.verify_partial_doubles = true
+  end
+
+  config.disable_monkey_patching!
+  # config.warnings = true
+
+  config.profile_examples = 10
+  config.order            = :random
+
+  # tag to disable VCR and WebMock
+  # it 'Real web request', :novcr { ... }
+  config.around do |example|
+    if example.metadata[:novcr]
+      with_web_request do
+        example.run
+      end
+    else
+      example.run
+    end
+  end
+
+  Kernel.srand config.seed
+end
+
+VCR.configure do |c|
+  c.cassette_library_dir = 'spec/cassettes'
+  c.hook_into :webmock
+  c.configure_rspec_metadata!
+end

spec/spec_helper.rb

@@ -0,0 +1,5 @@
+module SettingsHelper
+  def settings
+    @settings ||= YAML.load_file('config/config.yml')['test']
+  end
+end

spec/support/settings_helper.rb

@@ -0,0 +1,11 @@
+module WebRequestHelper
+  def with_web_request(&block)
+    previous_allowed = WebMock.net_connect_allowed?
+    begin
+      WebMock.allow_net_connect!
+      VCR.turned_off(&block)
+    ensure
+      WebMock.disable_net_connect! unless previous_allowed
+    end
+  end
+end