Renaming project

.rubocop_todo.yml

@@ -1,12 +1,14 @@
 # This configuration was generated by
 # `rubocop --auto-gen-config`
-# on 2018-10-03 19:49:44 -0700 using RuboCop version 0.59.2.
+# on 2018-10-03 21:01:01 -0700 using RuboCop version 0.59.2.
 # The point is for the user to remove these configuration records
 # one by one as the offenses are removed from the code base.
 # Note that changes in the inspected code, or installation of new
 # versions of RuboCop, may require this file to be generated again.
 
-# Offense count: 1
-# Configuration parameters: CountComments, ExcludedMethods.
-Metrics/MethodLength:
-  Max: 12
+# Offense count: 2
+# Configuration parameters: CustomIncludeMethods.
+RSpec/EmptyExampleGroup:
+  Exclude:
+    - 'spec/lib/osbourne/queue_spec.rb'
+    - 'spec/lib/osbourne/topic_spec.rb'

Gemfile

@@ -2,7 +2,7 @@
 
 source "https://rubygems.org"
 
-# Declare your gem's dependencies in message_plumber.gemspec.
+# Declare your gem's dependencies in osbourne.gemspec.
 # Bundler will treat runtime dependencies like base dependencies, and
 # development dependencies will be added by default to the :development group.
 gemspec

README.md

@@ -1,4 +1,4 @@
-# MessagePlumber
+# Osbourne
 Short description and motivation.
 
 ## Usage
@@ -8,7 +8,7 @@ How to use my plugin.
 Add this line to your application's Gemfile:
 
 ```ruby
-gem 'message_plumber'
+gem 'osbourne'
 ```
 
 And then execute:
@@ -18,7 +18,7 @@ $ bundle
 
 Or install it yourself as:
 ```bash
-$ gem install message_plumber
+$ gem install osbourne
 ```
 
 ## Contributing

Rakefile

@@ -10,7 +10,7 @@ require "rdoc/task"
 
 RDoc::Task.new(:rdoc) do |rdoc|
   rdoc.rdoc_dir = "rdoc"
-  rdoc.title    = "MessagePlumber"
+  rdoc.title    = "Osbourne"
   rdoc.options << "--line-numbers"
   rdoc.rdoc_files.include("README.md")
   rdoc.rdoc_files.include("lib/**/*.rb")

lib/osbourne.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+require "osbourne/railtie"
+require "osbourne/services/sns"
+require "osbourne/services/sqs"
+require "osbourne/topic"
+require "osbourne/queue"
+
+module Osbourne
+  class << self
+    attr_accessor :cache
+    attr_writer :sns_client
+    def sns_client
+      @sns_client ||= Aws::SNS::Client.new(Osbourne.sns_config.aws_options)
+    end
+  end
+end

lib/message_plumber/config/file_loader.rb → lib/osbourne/config/file_loader.rb

@@ -4,7 +4,7 @@
 require "erb"
 require "fileutils"
 
-module MessagePlumber
+module Osbourne
   module Config
     module FileLoader
       def self.load(cfile, environment="development")
@@ -17,8 +17,8 @@ def self.load(cfile, environment="development")
         publisher_opts = opts.merge(opts.delete("publisher") || {})
         subscriber_opts = opts.merge(opts.delete("subscriber") || {})
 
-        MessagePlumber.subscriber_config = subscriber_opts
-        MessagePlumber.publisher_config = publisher_opts
+        Osbourne.subscriber_config = subscriber_opts
+        Osbourne.publisher_config = publisher_opts
         true
       end
     end

lib/osbourne/provisioning/subscriber.rb

@@ -0,0 +1,4 @@
+# frozen_string_literal: true
+
+require "osbourne/services/sns"
+require "osbourne/topic"

lib/osbourne/queue.rb

@@ -0,0 +1,28 @@
+# frozen_string_literal: true
+
+module Osbourne
+  class Queue
+    include Services::SQS
+    attr_reader :name
+    def initialize(name)
+      @name = name
+      arn
+    end
+
+    def arn
+      @arn ||= ensure_queue
+    end
+
+    def ensure_queue
+      Osbourne.cache.fetch("existing_queue_arn_for_#{name}") do
+        sns.create_queue(name: name).queue_arn
+      end
+    end
+
+    private
+
+    def subscriptions_cache_key
+      "existing_sqs_subscriptions_for_#{name}"
+    end
+  end
+end

lib/osbourne/railtie.rb

@@ -0,0 +1,26 @@
+# frozen_string_literal: true
+
+require "rails"
+# require 'osbourne/config/file_loader'
+
+module Osbourne
+  class Railtie < Rails::Railtie
+    config.osbourne = ActiveSupport::OrderedOptions.new
+
+    initializer "osbourne" do
+      env = ENV["RAILS_ENV"] || ENV["RACK_ENV"] || "development"
+
+      %w[config/osbourne.yml.erb config/osbourne.yml].find do |filename|
+        Osbourne::Config::FileLoader.load(filename, env)
+      end
+    end
+
+    initializer "osbourne.logger" do
+      ActiveSupport.on_load(:osbourne) { self.logger ||= Rails.logger }
+    end
+
+    initializer "osbourne.cache" do
+      ActiveSupport.on_load(:osbourne) { self.cache ||= Rails.cache }
+    end
+  end
+end

lib/message_plumber/services/sns.rb → lib/osbourne/services/sns.rb

@@ -2,15 +2,15 @@
 
 require "aws-sdk-sns"
 
-module MessagePlumber
+module Osbourne
   module Services
     module SNS
       def sns
-        @sns ||= MessagePlumber.sns_client
+        @sns ||= Osbourne.sns_client
       end
 
       def sns=(client)
-        MessagePlumber.sns_client = client
+        Osbourne.sns_client = client
       end
     end
   end

lib/osbourne/services/sqs.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+require "aws-sdk-sqs"
+
+module Osbourne
+  module Services
+    module SQS
+      def sqs
+        @sqs ||= Osbourne.sqs_client
+      end
+
+      def sqs=(client)
+        Osbourne.sqs_client = client
+      end
+    end
+  end
+end

lib/osbourne/topic.rb

@@ -0,0 +1,28 @@
+# frozen_string_literal: true
+
+module Osbourne
+  class Topic
+    include Services::SNS
+    attr_reader :name
+    def initialize(name)
+      @name = name
+      arn
+    end
+
+    def arn
+      @arn ||= ensure_topic
+    end
+
+    def ensure_topic
+      Osbourne.cache.fetch("existing_topic_arn_for_#{name}") do
+        sns.create_topic(name: name).topic_arn
+      end
+    end
+
+    private
+
+    def subscriptions_cache_key
+      "existing_sqs_subscriptions_for_#{name}"
+    end
+  end
+end

lib/message_plumber/version.rb → lib/osbourne/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
-module MessagePlumber
+module Osbourne
   VERSION = "0.1.0"
 end

lib/tasks/message_plumber_tasks.rake

@@ -1,6 +1,6 @@
 # frozen_string_literal: true
 
 # desc "Explaining what the task does"
-# task :message_plumber do
+# task :osbourne do
 #   # Task goes here
 # end

message_plumber.gemspec → osbourne.gemspec

@@ -3,17 +3,17 @@
 $LOAD_PATH.push File.expand_path("lib", __dir__)
 
 # Maintain your gem's version:
-require "message_plumber/version"
+require "osbourne/version"
 
 # Describe your gem and declare its dependencies:
 Gem::Specification.new do |s|
-  s.name        = "message_plumber"
-  s.version     = MessagePlumber::VERSION
+  s.name        = "osbourne"
+  s.version     = Osbourne::VERSION
   s.authors     = ["Steve Allen"]
   s.email       = ["[email protected]"]
   s.homepage    = "https://github.com/"
   s.summary     = "A simple implementation of the fan-out message pattern"
-  s.description = ": Description of MessagePlumber."
+  s.description = ": Description of Osbourne."
   s.license     = "MIT"
 
   s.files = Dir["{app,config,db,lib}/**/*", "MIT-LICENSE", "Rakefile", "README.md"]
@@ -26,12 +26,13 @@ Gem::Specification.new do |s|
   s.add_development_dependency "awesome_print"
   s.add_development_dependency "bundler", "~> 1.8"
   s.add_development_dependency "guard"
+  s.add_development_dependency "guard-bundler"
   s.add_development_dependency "guard-rspec"
   s.add_development_dependency "mock_redis"
   s.add_development_dependency "pry-byebug"
   s.add_development_dependency "rake", "~> 10.0"
   s.add_development_dependency "redis"
-  s.add_development_dependency "rspec", "~> 3.2"
+  s.add_development_dependency "rspec", "~> 3"
   s.add_development_dependency "rubocop"
   s.add_development_dependency "rubocop-rspec"
   s.add_development_dependency "simplecov"

spec/lib/osbourne/queue_spec.rb

@@ -0,0 +1,16 @@
+# frozen_string_literal: true
+
+require "spec_helper"
+
+RSpec.describe Osbourne::Queue, type: :model do
+  subject { described_class.new(queue_name) }
+
+  let(:sqs_client) { instance_double("Aws::SQS::Client") }
+  let(:queue_arn) { OpenStruct.new(queue_arn: "arn:aws:sqs:us-east-2:123456789012:queue") }
+  let(:queue_name) { "queue_name" }
+
+  before {
+    allow(sqs_client).to receive(:create_queue).and_return(queue_arn)
+    Osbourne.sqs_client = sqs_client
+  }
+end