Gig bulk create (#7)

* bulk skeleton

* bulk actions

* version bump

* stale code

Author: inderps

Gemfile.lock

@@ -1,7 +1,8 @@
 PATH
   remote: .
   specs:
-    cirro-ruby-client (1.0.1)
+    cirro-ruby-client (1.1.0)
+      faraday_middleware
       json_api_client
       jwt
 

cirro-ruby-client.gemspec

@@ -27,4 +27,5 @@ Gem::Specification.new do |spec|
 
   spec.add_runtime_dependency 'jwt'
   spec.add_runtime_dependency 'json_api_client'
+  spec.add_runtime_dependency 'faraday_middleware'
 end

lib/cirro_io/client.rb

@@ -7,6 +7,9 @@
 require 'cirro_io/client/gig_invitation'
 require 'cirro_io/client/app_user'
 require 'cirro_io/client/app_worker'
+require 'cirro_io/client/worker_invitation_filter'
+require 'cirro_io/client/gig_task'
+require 'cirro_io/client/gig'
 
 module CirroIO
   module Client

lib/cirro_io/client/app_user.rb

@@ -1,9 +1,6 @@
 module CirroIO
   module Client
     class AppUser < Base
-      def self.resource_name
-        'app-users'
-      end
     end
   end
 end

lib/cirro_io/client/app_worker.rb

@@ -3,10 +3,6 @@ module Client
     class AppWorker < Base
       has_one :app_user
       has_many :gig_invitations
-
-      def self.resource_name
-        'app-workers'
-      end
     end
   end
 end

lib/cirro_io/client/base.rb

@@ -9,6 +9,19 @@ def self.site=(url)
         super(url)
         connection.faraday.url_prefix = url
       end
+
+      def self.custom_post(endpoint, payload)
+        custom_connection.post(endpoint, payload.to_json)
+      end
+
+      def self.custom_connection
+        Faraday.new(url: "#{CirroIO::Client.configuration.site}/#{CirroIO::Client.configuration.api_version}") do |conn|
+          conn.request :json
+          conn.response :json
+          conn.use CirroIO::Client::JwtAuthentication
+          conn.use JsonApiClient::Middleware::Status, {}
+        end
+      end
     end
   end
 end

lib/cirro_io/client/gig.rb

@@ -0,0 +1,28 @@
+module CirroIO
+  module Client
+    class Gig < Base
+      has_one :worker_invitation_filter
+      has_many :gig_tasks
+
+      # rubocop:disable Metrics/AbcSize
+      def bulk_create_with(attrs)
+        payload = { data: { attributes: attributes } }
+
+        if attrs[:gig_tasks]
+          payload[:data][:relationships] ||= {}
+          payload[:data][:relationships][:gig_tasks] = attrs[:gig_tasks].map(&:attributes)
+        end
+
+        if attrs[:worker_invitation_filter]
+          payload[:data][:relationships] ||= {}
+          payload[:data][:relationships][:worker_invitation_filter] = attrs[:worker_invitation_filter].attributes
+        end
+
+        response = self.class.custom_post('bulk/gigs', payload)
+
+        self.class.parser.parse(self.class, response).first
+      end
+      # rubocop:enable Metrics/AbcSize
+    end
+  end
+end

lib/cirro_io/client/gig_invitation.rb

@@ -1,9 +1,6 @@
 module CirroIO
   module Client
     class GigInvitation < Base
-      def self.resource_name
-        'gig-invitations'
-      end
     end
   end
 end

lib/cirro_io/client/gig_task.rb

@@ -0,0 +1,6 @@
+module CirroIO
+  module Client
+    class GigTask < Base
+    end
+  end
+end

lib/cirro_io/client/response_debugging_middleware.rb

@@ -3,7 +3,7 @@ module CirroIO
   module Client
     class ResponseDebuggingMiddleware < Faraday::Response::Middleware
       def on_complete(env)
-        # binding.pry
+        binding.pry # rubocop:disable Lint/Debugger
       end
     end
   end