feature: google cloud mvp.

Author: James Moriarty

.gitignore

@@ -1,3 +1,4 @@
+*.json
 /public/cache/
 /.bundle/
 /.yardoc

Gemfile

@@ -7,6 +7,7 @@ gem 'grape',      '~> 0.11'
 gem 'roar',       '~> 1'
 gem 'grape-roar', '~> 0.3'
 gem 'aws-sdk',    '~> 2'
+gem 'google-cloud-storage'
 gem 'mini_magick'
 gem 'puma'
 

Gemfile.lock

@@ -6,6 +6,8 @@ GEM
       i18n (~> 0.7)
       minitest (~> 5.1)
       tzinfo (~> 1.1)
+    addressable (2.5.0)
+      public_suffix (~> 2.0, >= 2.0.2)
     aws-sdk (2.5.5)
       aws-sdk-resources (= 2.5.5)
     aws-sdk-core (2.5.5)
@@ -26,9 +28,35 @@ GEM
     descendants_tracker (0.0.4)
       thread_safe (~> 0.3, >= 0.3.1)
     diff-lcs (1.2.5)
+    digest-crc (0.4.1)
     docile (1.1.5)
     enumerable-lazy (0.0.1)
     equalizer (0.0.11)
+    faraday (0.10.0)
+      multipart-post (>= 1.2, < 3)
+    google-api-client (0.9.20)
+      addressable (~> 2.3)
+      googleauth (~> 0.5)
+      httpclient (~> 2.7)
+      hurley (~> 0.1)
+      memoist (~> 0.11)
+      mime-types (>= 1.6)
+      representable (~> 2.3.0)
+      retriable (~> 2.0)
+    google-cloud-core (0.21.1)
+      googleauth (~> 0.5.1)
+    google-cloud-storage (0.21.0)
+      digest-crc (~> 0.4)
+      google-api-client (~> 0.9.11)
+      google-cloud-core (~> 0.21.0)
+    googleauth (0.5.1)
+      faraday (~> 0.9)
+      jwt (~> 1.4)
+      logging (~> 2.0)
+      memoist (~> 0.12)
+      multi_json (~> 1.11)
+      os (~> 0.9)
+      signet (~> 0.7)
     grape (0.17.0)
       activesupport
       builder
@@ -43,21 +71,35 @@ GEM
       grape
       roar (>= 1.0)
     hashie (3.4.4)
+    httpclient (2.8.2.4)
+    hurley (0.2)
     i18n (0.7.0)
     ice_nine (0.11.2)
     jmespath (1.3.1)
     json (1.8.3)
+    jwt (1.5.6)
+    little-plugger (1.1.4)
+    logging (2.1.0)
+      little-plugger (~> 1.1)
+      multi_json (~> 1.10)
+    memoist (0.15.0)
     method_source (0.8.2)
+    mime-types (3.1)
+      mime-types-data (~> 3.2015)
+    mime-types-data (3.2016.0521)
     mini_magick (4.5.1)
     minitest (5.9.0)
     multi_json (1.12.1)
     multi_xml (0.5.5)
+    multipart-post (2.0.0)
     mustermann19 (0.4.4)
       enumerable-lazy
+    os (0.9.6)
     pry (0.10.3)
       coderay (~> 1.1.0)
       method_source (~> 0.8.1)
       slop (~> 3.4)
+    public_suffix (2.0.4)
     puma (3.6.0)
     rack (1.6.4)
     rack-accept (0.4.5)
@@ -69,6 +111,7 @@ GEM
     rake (10.5.0)
     representable (2.3.0)
       uber (~> 0.0.7)
+    retriable (2.1.0)
     roar (1.0.4)
       representable (>= 2.0.1, < 2.4.0)
     rspec (3.4.0)
@@ -84,6 +127,11 @@ GEM
       diff-lcs (>= 1.2.0, < 2.0)
       rspec-support (~> 3.4.0)
     rspec-support (3.4.1)
+    signet (0.7.3)
+      addressable (~> 2.3)
+      faraday (~> 0.9)
+      jwt (~> 1.5)
+      multi_json (~> 1.10)
     simplecov (0.11.2)
       docile (~> 1.1.0)
       json (~> 1.8)
@@ -111,6 +159,7 @@ PLATFORMS
 DEPENDENCIES
   aws-sdk (~> 2)
   codeclimate-test-reporter
+  google-cloud-storage
   grape (~> 0.11)
   grape-roar (~> 0.3)
   mini_magick

config.ru

@@ -2,9 +2,16 @@ $LOAD_PATH.unshift File.expand_path('../lib', __FILE__)
 
 require "bundler/setup"
 require "poto"
-require "poto/file_repository/s3"
+# require "poto/file_repository/s3"
+#
+# repository = Poto::FileRepository::S3.new(bucket: ENV["AWS_S3_BUCKET"])
 
-repository = Poto::FileRepository::S3.new(bucket: ENV["AWS_S3_BUCKET"])
+require "poto/file_repository/google/cloud/storage"
+client     = Google::Cloud::Storage.new(
+  project: "poto-1266",
+  keyfile: "Poto-f69886a81372.json"
+)
+repository = Poto::FileRepository::Google::Cloud::Storage.new(bucket: "poto", client: client)
 
 map("/") do
   run Poto::App

docker-compose.yml

@@ -7,6 +7,10 @@ web:
 
 test:
   build: .
+  ports:
+    - '9292:9292'
+  environment:
+    PORT: 9292
   volumes:
     - '.:/app'
   command: bundle exec rspec

lib/poto/file_repository/google/cloud/storage.rb

@@ -0,0 +1,37 @@
+require "base64"
+require "google/cloud/storage"
+
+require "poto/file_repository/google/cloud/storage/file_collection_mapper"
+
+module Poto
+  module FileRepository
+    module Google
+      module Cloud
+        class Storage
+          attr_reader :bucket, :client
+
+          def initialize(bucket:, client:)
+            @client = client
+            @bucket = client.bucket(bucket)
+          end
+
+          def url(id)
+            bucket.file(decode(id)).signed_url
+          end
+
+          def all(prefix:, page:, per_page:)
+            files = bucket.files(prefix: prefix, token: page, max: per_page)
+
+            FileCollectionMapper.new(files, page).call
+          end
+
+          private
+
+          def decode(value)
+            URI.unescape(Base64.decode64(value))
+          end
+        end
+      end
+    end
+  end
+end

lib/poto/file_repository/google/cloud/storage/file_collection_mapper.rb

@@ -0,0 +1,41 @@
+require "base64"
+
+require "poto/file_repository/file_collection"
+require "poto/file_repository/google/cloud/storage/file_mapper"
+
+module Poto
+  module FileRepository
+    module Google
+      module Cloud
+        class Storage
+          class FileCollectionMapper
+            attr_reader :files, :page
+
+            def initialize(files, page)
+              @files = files
+              @page  = page
+            end
+
+            def call
+              FileCollection.new(_files, _page, next_page)
+            end
+
+            private
+
+            def _files
+              files.map { |object| FileMapper.new(object).call }
+            end
+
+            def _page
+              page
+            end
+
+            def next_page
+              files.token
+            end
+          end
+        end
+      end
+    end
+  end
+end

lib/poto/file_repository/google/cloud/storage/file_mapper.rb

@@ -0,0 +1,43 @@
+require "base64"
+
+require "poto/file_repository/file"
+
+module Poto
+  module FileRepository
+    module Google
+      module Cloud
+        class Storage
+          class FileMapper
+            attr_reader :file
+
+            def initialize(file)
+              @file = file
+            end
+
+            def call
+              File.new(id, name, size)
+            end
+
+            private
+
+            def name
+              file.name
+            end
+
+            def size
+              file.size
+            end
+
+            def id
+              encode file.name
+            end
+
+            def encode(value)
+              URI.escape Base64.encode64 name
+            end
+          end
+        end
+      end
+    end
+  end
+end