Initial commit

Author: fdeschenes

Gemfile

@@ -0,0 +1,3 @@
+source 'http://rubygems.org'
+gem 'rails', '>= 5.0'
+gemspec

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2019 Hypemarks Inc.
+
+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 @@
+# jsonapi-bulk

jsonapi-bulk.gemspec

@@ -0,0 +1,22 @@
+# -*- encoding: utf-8 -*-
+$:.push File.expand_path('../lib', __FILE__)
+require 'jsonapi/bulk/version'
+
+Gem::Specification.new do |spec|
+  spec.name = 'jsonapi-bulk'
+  spec.version = JSONAPI::Bulk::VERSION
+  spec.author = ['Francois Deschenes']
+  spec.email = ['fdeschenes@me.com']
+  spec.summary = ''
+  spec.description = ''
+  spec.homepage = 'https://github.com/hypemarks/jsonapi-bulk'
+  spec.license = 'MIT'
+
+  spec.files = Dir['LICENSE', 'README.md', 'lib/**/*']
+  spec.require_path = 'lib'
+
+  spec.add_dependency 'jsonapi-rb', '~> 0.5.0'
+  spec.add_dependency 'jsonapi-parser', '~> 0.1.0'
+  
+  spec.add_development_dependency 'rails', '~> 5.0'
+end

lib/jsonapi/bulk.rb

@@ -0,0 +1,6 @@
+require 'jsonapi/bulk/railtie'
+
+module JSONAPI
+  module Bulk
+  end
+end

lib/jsonapi/bulk/railtie.rb

@@ -0,0 +1,15 @@
+require 'rails/railtie'
+
+module JSONAPI
+  module Bulk
+    # @private
+    class Railtie < ::Rails::Railtie
+      initializer 'jsonapi-bulk.init' do |app|
+        ActiveSupport.on_load(:action_controller) do
+          require 'jsonapi/rails/controller/bulk_deserialization'
+          include ::JSONAPI::Rails::Controller::BulkDeserialization
+        end
+      end
+    end
+  end
+end

lib/jsonapi/bulk/version.rb

@@ -0,0 +1,5 @@
+module JSONAPI
+  module Bulk
+    VERSION = '0.1.0'
+  end
+end

lib/jsonapi/parser/bulk.rb

@@ -0,0 +1,22 @@
+require 'jsonapi/parser/document'
+
+module JSONAPI
+  module Parser
+    class Bulk
+      # Validate the structure of a bulk resource create/update payload.
+      #
+      # @param [Hash] document The input JSONAPI document.
+      # @raise [JSONAPI::Parser::InvalidDocument] if document is invalid.
+      def self.parse!(document)
+        Document.ensure!(document.is_a?(Hash),
+                         'A JSON object MUST be at the root of every JSONAPI ' \
+                         'request and response containing data.')
+        Document.ensure!(document.keys == ['data'].freeze &&
+                         document['data'].is_a?(Array),
+                         'The request MUST include an array of resource objects ' \
+                         'as primary data.')
+        document['data'].each { |data| Document.parse_primary_resource!(data) }
+      end
+    end
+  end
+end

lib/jsonapi/rails/controller/bulk_deserialization.rb

@@ -0,0 +1,50 @@
+require 'jsonapi/parser'
+require 'jsonapi/parser/bulk'
+require 'jsonapi/rails/deserializable_resource'
+require 'jsonapi/rails/controller/deserialization'
+
+module JSONAPI
+  module Rails
+    module Controller
+      module BulkDeserialization
+        extend ActiveSupport::Concern
+
+        class_methods do
+          def deserializable_resource(key, options = {}, &block)
+            options = options.dup
+            klass = options.delete(:class) ||
+                    Class.new(JSONAPI::Rails::DeserializableResource, &block)
+            bulk = options.delete(:bulk) || false
+
+            before_action(options) do |controller|
+              hash = controller.params.to_unsafe_hash.with_indifferent_access[:_jsonapi]
+              if hash.nil?
+                JSONAPI::Rails.logger.warn do
+                  "Unable to deserialize #{key} because no JSON API payload was" \
+                  " found. (#{controller.controller_name}##{params[:action]})"
+                end
+                next
+              end
+
+              ActiveSupport::Notifications
+                .instrument('parse.jsonapi-rails',
+                            key: key, payload: hash, class: klass) do
+                if bulk && controller.request.headers['Content-Type'] =~ /;\s?ext=bulk\b/
+                  JSONAPI::Parser::Bulk.parse!(hash)
+                  resources = hash[:data].map { |data| klass.new(data) }
+                  controller.request.env[JSONAPI::Rails::Controller::Deserialization::JSONAPI_POINTERS_KEY] = resources.first.reverse_mapping
+                  controller.params[key.to_sym] = resources.map(&:to_hash)
+                else
+                  JSONAPI::Parser::Resource.parse!(hash)
+                  resource = klass.new(hash[:data])
+                  controller.request.env[JSONAPI::Rails::Controller::Deserialization::JSONAPI_POINTERS_KEY] = resource.reverse_mapping
+                  controller.params[key.to_sym] = resource.to_hash
+                end
+              end
+            end
+          end
+        end
+      end
+    end
+  end
+end