WIP Empire Provider.

.ruby-version

@@ -1 +1 @@
-2.1.0
+2.1.2

.travis.yml

@@ -3,7 +3,7 @@ services:
   - mongodb
   - rabbitmq
 rvm:
-  - 2.1.0
+  - 2.1.2
 env:
   global:
     - secure: "lmVVP0lGUtwWzbWj5O9MBHOWs8aHeUKR0oSB7yG5lpQarBvjDbsV7HXdCXA6xLCWoUY/WI1pMGazcbyDMWLmFvo5XD+jomCKBJh2pPusomQ5f1iEWPH81fBCR1tlQc34m2KyfEKI19O5w9jSkccQNzmwzeDnIgF2eLZIlrUXSiM=" # GITHUB_DEPLOY_TOKEN

Gemfile

@@ -1,6 +1,6 @@
 source 'https://rubygems.org'
 
-ruby '2.1.0'
+ruby '2.1.2'
 
 gem 'rake'
 gem 'unicorn', '~> 4.6.2'

lib/shipr.rb

@@ -21,6 +21,7 @@ module Shipr
   module Provider
     autoload :Base,       'shipr/provider/base'
     autoload :IronWorker, 'shipr/provider/iron_worker'
+    autoload :Empire,     'shipr/provider/empire'
     autoload :Null,       'shipr/provider/null'
   end
 

lib/shipr/provider/empire.rb

@@ -0,0 +1,62 @@
+module Shipr::Provider
+  class Empire < Base
+    attr_reader :empire_client, :registry
+
+    def initialize(empire_client, registry)
+      @empire_client = empire_client
+      @registry = registry
+    end
+
+    def start(job)
+      image_id = registry.resolve_tag(job.repo.name, job.sha)
+      empire_client.create_deploy id: image_id, repo: job.repo.name
+    end
+
+    class EmpireClient
+      attr_reader :url
+
+      def initialize(url)
+        @url = url
+      end
+
+      def create_deploy(image)
+        connection.post '/v1/deploys', image: image
+      end
+
+      private
+
+      def connection
+        @connection ||= Faraday.new(url) do |builder|
+          builder.request :json
+          builder.response :json
+          builder.adapter Faraday.default_adapter
+        end
+      end
+    end
+
+    class RegistryClient
+      attr_reader :url, :auth
+
+      def initialize(url, auth)
+        @url = url || 'https://registry.hub.docker.com'
+        @auth = auth
+      end
+
+      def resolve_tag(repo, tag)
+        resp = connection.get "/v1/repositories/#{repo}/tags/#{tag}"
+        resp.body.gsub(/^"(.*)"/, '\\1')
+      end
+
+      private
+
+      def connection
+        @connection ||= Faraday.new(url) do |builder|
+          builder.request :json
+          builder.adapter Faraday.default_adapter
+        end.tap do |connection|
+          connection.basic_auth(*auth.split(':'))
+        end
+      end
+    end
+  end
+end

spec/shipr/provider/empire/empire_client_spec.rb

@@ -0,0 +1,15 @@
+
+require 'spec_helper'
+
+describe Shipr::Provider::Empire::EmpireClient do
+  let(:client) { described_class.new 'https://empire.remind.com' }
+
+  describe '#create_deploy' do
+    it 'post a url' do
+      stub_request(:post, 'https://empire.remind.com/v1/deploys').with(
+        body: '{"image":{"id":"1234","repo":"remind101/r101-api"}}'
+      )
+      client.create_deploy id: '1234', repo: 'remind101/r101-api'
+    end
+  end
+end

spec/shipr/provider/empire/registry_client_spec.rb

@@ -0,0 +1,16 @@
+require 'spec_helper'
+
+describe Shipr::Provider::Empire::RegistryClient do
+  let(:client) { described_class.new 'https://quay.io', 'foo:bar' }
+
+  describe '#resolve_tag' do
+    it 'resolves a tag to an image id' do
+      stub_request(:get, 'https://foo:bar@quay.io/v1/repositories/remind101/r101-api/tags/af2a2').to_return(
+        status: 200,
+        body: '"abcdefg"'
+      )
+      image_id = client.resolve_tag 'remind101/r101-api', 'af2a2'
+      expect(image_id).to eq 'abcdefg'
+    end
+  end
+end

spec/shipr/provider/empire_spec.rb

@@ -0,0 +1,18 @@
+require 'spec_helper'
+
+describe Shipr::Provider::Empire do
+  let(:empire_client) { double(Shipr::Provider::Empire::EmpireClient)}
+  let(:registry_client) { double(Shipr::Provider::Empire::RegistryClient) }
+  let(:service) { described_class.new empire_client, registry_client }
+
+  describe '#start' do
+    let(:repo) { Shipr::Repo.new name: 'remind101/r101-api' }
+    let(:job) { Shipr::Job.new repo: repo, sha: 1234 }
+
+    it 'creates a deploy task' do
+      expect(registry_client).to receive(:resolve_tag).with('remind101/r101-api', '1234').and_return('abcdefg')
+      expect(empire_client).to receive(:create_deploy).with(id: 'abcdefg', repo: 'remind101/r101-api')
+      service.start(job)
+    end
+  end
+end