Renamed gem to active_elastic_job

The new name is easier to pronounce and easier to memorize.
KaranN · Jan 1, 2016 · d9c5500 · d9c5500
1 parent b0ace16
commit d9c5500
Show file tree

Hide file tree

Showing 22 changed files with 52 additions and 52 deletions.
diff --git a/Gemfile.lock b/Gemfile.lock
@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    rails_eb_job (0.1.0)
+    active_elastic_job (0.1.0)
       aws-sdk (~> 2)
 
 GEM
@@ -140,12 +140,12 @@ PLATFORMS
   ruby
 
 DEPENDENCIES
+  active_elastic_job!
   bundler
   dotenv
   fuubar
   pry-byebug
   rails (~> 4.2)
-  rails_eb_job!
   rspec (~> 3.4)
 
 BUNDLED WITH

diff --git a/README.md b/README.md
@@ -1 +1 @@
-# rails-eb-job
+# active-elastic-job
diff --git a/Vagrantfile b/Vagrantfile
@@ -13,6 +13,6 @@ Vagrant.configure(2) do |config|
   # Every Vagrant development environment requires a box. You can search for
   # boxes at https://atlas.hashicorp.com/search.
   config.vm.box = "ubuntu/trusty64"
-  config.vm.hostname = 'rails-eb-job-dev-box'
+  config.vm.hostname = 'active-elastic-job-dev-box'
   config.vm.provision :shell, path: 'bootstrap.sh', keep_color: true
 end
diff --git a/rails-eb-job.gemspec → active-elastic-job.gemspec b/rails-eb-job.gemspec → active-elastic-job.gemspec
@@ -2,18 +2,18 @@
 lib = File.expand_path('../lib', __FILE__)
 $LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
 
-require 'rails_eb_job/version'
+require 'active_elastic_job/version'
 
 Gem::Specification.new do |spec|
   spec.platform      = Gem::Platform::RUBY
-  spec.name          = 'rails_eb_job'
-  spec.version       = RailsEbJob::VERSION
+  spec.name          = 'active_elastic_job'
+  spec.version       = ActiveElasticJob::VERSION
   spec.authors       = ['Tawan Sierek']
   spec.email         = ['tawan@sierek.com']
   spec.description = spec.summary = %q()
   spec.license       = 'MIT'
 
-  spec.files         = Dir.glob('lib/**/*') + [ 'rails-eb-job.gemspec' ]
+  spec.files         = Dir.glob('lib/**/*') + [ 'active-elastic-job.gemspec' ]
   spec.executables   = []
   spec.test_files    = spec.files.grep(%r{^(test|spec|features)/})
   spec.require_paths = ['lib']

diff --git a/lib/active_elastic_job.rb b/lib/active_elastic_job.rb
@@ -0,0 +1,8 @@
+require 'aws-sdk-core'
+require 'active_elastic_job/version'
+require 'active_job/queue_adapters/active_elastic_job_adapter'
+require 'active_elastic_job/rack/sqs_processor'
+
+module ActiveElasticJob; end;
+
+require "active_elastic_job/railtie" if defined? Rails
diff --git a/lib/rails_eb_job/rack/sqs_processor.rb → lib/active_elastic_job/rack/sqs_processor.rb b/lib/rails_eb_job/rack/sqs_processor.rb → lib/active_elastic_job/rack/sqs_processor.rb
@@ -1,6 +1,6 @@
 require "action_dispatch"
 
-module RailsEbJob
+module ActiveElasticJob
   module Rack
     class SqsProcessor
       def initialize(app)

diff --git a/lib/active_elastic_job/railtie.rb b/lib/active_elastic_job/railtie.rb
@@ -0,0 +1,7 @@
+module ActiveElasticJob
+  class Railtie < Rails::Railtie
+    initializer "active_elastic_job.insert_middleware" do |app|
+      app.config.middleware.use "ActiveElasticJob::Rack::SqsProcessor"
+    end
+  end
+end
diff --git a/lib/rails_eb_job/version.rb → lib/active_elastic_job/version.rb b/lib/rails_eb_job/version.rb → lib/active_elastic_job/version.rb
@@ -1,3 +1,3 @@
-module RailsEbJob
+module ActiveElasticJob
   VERSION = '0.1.0'
 end
diff --git a/...ob/queue_adapters/rails_eb_job_adapter.rb → ...ue_adapters/active_elastic_job_adapter.rb b/...ob/queue_adapters/rails_eb_job_adapter.rb → ...ue_adapters/active_elastic_job_adapter.rb
@@ -1,11 +1,11 @@
 module ActiveJob
   module QueueAdapters
-    class RailsEbJobAdapter
+    class ActiveElasticJobAdapter
       class << self
         attr_writer :aws_sqs_client
 
         def enqueue(job)
-          queue_url = aws_sqs_client.get_queue_url(queue_name: job.queue_name.to_s).queue_url
+          queue_url = aws_sqs_client.create_queue(queue_name: job.queue_name.to_s).queue_url
           aws_sqs_client.send_message(
             queue_url: queue_url,
             message_body: JSON.dump(job.serialize)

diff --git a/lib/rails_eb_job.rb b/lib/rails_eb_job.rb
diff --git a/lib/rails_eb_job/railtie.rb b/lib/rails_eb_job/railtie.rb
diff --git a/spec/rails_eb_job/rack/sqs_processor_spec.rb → ...ve_elastic_job/rack/sqs_processor_spec.rb b/spec/rails_eb_job/rack/sqs_processor_spec.rb → ...ve_elastic_job/rack/sqs_processor_spec.rb
@@ -1,12 +1,12 @@
 require 'spec_helper'
 require 'rack/mock'
 
-describe RailsEbJob::Rack::SqsProcessor do
+describe ActiveElasticJob::Rack::SqsProcessor do
   let(:env) { Rack::MockRequest.env_for("http://example.com:8080/") }
   let(:app) { double("app") }
   let(:original_response) { double("original_response") }
 
-  subject(:sqs_processor) { RailsEbJob::Rack::SqsProcessor.new(app) }
+  subject(:sqs_processor) { ActiveElasticJob::Rack::SqsProcessor.new(app) }
 
   it "passes an ordinary request through" do
     expect(app).to receive(:call).with(env).and_return(original_response)

diff --git a/spec/active_elastic_job_spec.rb b/spec/active_elastic_job_spec.rb
@@ -0,0 +1,7 @@
+require 'spec_helper'
+
+describe ActiveElasticJob do
+  it 'has a version' do
+    expect(ActiveElasticJob::VERSION).to be_a(String)
+  end
+end
diff --git a/...eue_adapters/rails_eb_job_adapter_spec.rb → ...apters/active_elastic_job_adapter_spec.rb b/...eue_adapters/rails_eb_job_adapter_spec.rb → ...apters/active_elastic_job_adapter_spec.rb
@@ -1,7 +1,7 @@
 require 'spec_helper'
 
-describe ActiveJob::QueueAdapters::RailsEbJobAdapter do
-  subject(:adapter) { ActiveJob::QueueAdapters::RailsEbJobAdapter }
+describe ActiveJob::QueueAdapters::ActiveElasticJobAdapter do
+  subject(:adapter) { ActiveJob::QueueAdapters::ActiveElasticJobAdapter }
 
   let(:aws_sqs_client)  {
     double("aws_sqs_client")
@@ -17,16 +17,16 @@
   describe ".enqueue" do
     it "selects the correct queue" do
       expected_args = { queue_name: job.queue_name.to_s }
-      expect(aws_sqs_client).to receive(:get_queue_url).with(expected_args)
+      expect(aws_sqs_client).to receive(:create_queue).with(expected_args)
 
-      allow(aws_sqs_client).to receive(:get_queue_url) { queue_url_resp }
+      allow(aws_sqs_client).to receive(:create_queue) { queue_url_resp }
       allow(queue_url_resp).to receive(:queue_url) { queue_url }
       allow(aws_sqs_client).to receive(:send_message) { }
       adapter.enqueue job
     end
 
     it "sends the serialized job as a message to an AWS SQS queue" do
-      allow(aws_sqs_client).to receive(:get_queue_url) { queue_url_resp }
+      allow(aws_sqs_client).to receive(:create_queue) { queue_url_resp }
       allow(queue_url_resp).to receive(:queue_url) { queue_url }
       expected_args = {
         queue_url: queue_url,

diff --git a/spec/helpers.rb b/spec/helpers.rb
@@ -66,7 +66,7 @@ def create_random_string(random_string)
   private
 
   def build_gem
-    unless system("gem build rails-eb-job.gemspec")
+    unless system("gem build active-elastic-job.gemspec")
       raise "Could not build gem package!"
     end
     begin
@@ -85,14 +85,14 @@ def unpack_gem_into_vendor_dir
       raise "Could not unpack gem"
     end
     Dir.chdir(target_dir) do
-      unless system("rm -rf rails_eb_job-current") && system("mv #{gem_package_name} rails_eb_job-current")
+      unless system("rm -rf active_elastic_job-current") && system("mv #{gem_package_name} active_elastic_job-current")
         raise "Could not move gem"
       end
     end
   end
 
   def gem_package_name
-    "rails_eb_job-#{RailsEbJob::VERSION}"
+    "active_elastic_job-#{ActiveElasticJob::VERSION}"
   end
 
   def root_dir

diff --git a/spec/integration/aws_sqs_client_spec.rb b/spec/integration/aws_sqs_client_spec.rb
@@ -17,7 +17,7 @@ def perform(test_arg)
   end
 
   describe "message dispatching" do
-    let(:queue_name) { "RailsEbJob-integration-testing" }
+    let(:queue_name) { "ActiveElasticJob-integration-testing" }
     let(:queue_url) do
       response = aws_client.create_queue(queue_name: queue_name)
       response.queue_url

diff --git a/spec/integration/rails-app/Gemfile b/spec/integration/rails-app/Gemfile
@@ -31,7 +31,7 @@ gem 'sdoc', '~> 0.4.0', group: :doc
 # Use Capistrano for deployment
 # gem 'capistrano-rails', group: :development
 
-gem 'rails_eb_job', :path => 'vendor/gems/rails_eb_job-current'
+gem 'active_elastic_job', :path => 'vendor/gems/active_elastic_job-current'
 
 group :development, :test do
   # Call 'byebug' anywhere in the code to stop execution and get a debugger console

diff --git a/spec/integration/rails-app/Gemfile.lock b/spec/integration/rails-app/Gemfile.lock
@@ -1,7 +1,7 @@
 PATH
-  remote: vendor/gems/rails_eb_job-current
+  remote: vendor/gems/active_elastic_job-current
   specs:
-    rails_eb_job (0.1.0)
+    active_elastic_job (0.1.0)
       aws-sdk (~> 2)
 
 GEM
@@ -152,12 +152,12 @@ PLATFORMS
   ruby
 
 DEPENDENCIES
+  active_elastic_job!
   byebug
   coffee-rails (~> 4.1.0)
   jbuilder (~> 2.0)
   jquery-rails
   rails (= 4.2.5)
-  rails_eb_job!
   sass-rails (~> 5.0)
   sdoc (~> 0.4.0)
   spring

diff --git a/spec/integration/rails-app/app/jobs/test_job.rb b/spec/integration/rails-app/app/jobs/test_job.rb
@@ -1,5 +1,5 @@
 class TestJob < ActiveJob::Base
-  queue_as :rails_eb_job_integration_testing
+  queue_as :active_elastic_job_integration_testing
 
   WEB_ENV_HOST = ENV['WEB_ENV_HOST']
   WEB_ENV_PORT = ENV['WEB_ENV_PORT']

diff --git a/spec/integration/rails-app/config/application.rb b/spec/integration/rails-app/config/application.rb
@@ -23,6 +23,6 @@ class Application < Rails::Application
     # Do not swallow errors in after_commit/after_rollback callbacks.
     config.active_record.raise_in_transactional_callbacks = true
 
-    config.active_job.queue_adapter = :rails_eb_job
+    config.active_job.queue_adapter = :active_elastic_job
   end
 end
diff --git a/spec/rails_eb_job_spec.rb b/spec/rails_eb_job_spec.rb
diff --git a/spec/spec_helper.rb b/spec/spec_helper.rb
@@ -2,7 +2,7 @@
 Bundler.setup
 
 require 'pry-byebug'
-require 'rails_eb_job'
+require 'active_elastic_job'
 
 require 'dotenv'
 Dotenv.load