lib/bloodbath/event.rb in bloodbath-1.0.0 vs lib/bloodbath/event.rb in bloodbath-1.1.0

@@ -1,34 +1,48 @@
 # frozen_string_literal: true
 require "net/http"
 require "pry"
 require "json"
 
+require_relative "utils/threading"
+
 module Bloodbath
   module Adapters
     class Rest
-      attr_reader :method, :endpoint, :body, :config
+      include Bloodbath::Utils::Threading
 
-      def initialize(method:, endpoint:, body: nil, config: Bloodbath.config)
+      attr_reader :method, :endpoint, :body, :options, :config
+
+      def initialize(method:, endpoint:, body: nil, options:, config: Bloodbath.config)
         @method = method
         @endpoint = endpoint
         @body = body
+        @options = options
         @config = config
       end
 
       def perform
         check_api_key
-        response
+
+        if options[:wait_for_response]
+          synchronous_call_with_response
+        else
+          asynchronously { synchronous_call_with_response }
+        end
       end
 
       private
 
       def check_api_key
         raise Bloodbath::Error, "Please set your API key through Bloodbath.api_key = 'my-api-key'" unless config.api_key
       end
 
-      def response
+      def asynchronously
+        threading { yield }
+      end
+
+      def synchronous_call_with_response
         http = Net::HTTP.new(uri.host, uri.port)
         http.use_ssl = true if uri.instance_of?(URI::HTTPS)
 
         request["Authorization"] = "Bearer #{config.api_key}"
         request["Content-Type"] = "application/json"
@@ -66,32 +80,52 @@
       end
     end
   end
 end
 
+# when we want to add specific Ruby library options we instanciate what we want
+# instead of going with Event.schedule we do Event.new(my_option: true).schedule
+# this is to manage the transition to go class first while adding the options
 module Bloodbath
   class Event
     class << self
-      def schedule(args)
-        adapter.new(method: :post, endpoint: "/events", body: args).perform
+      def method_missing(method_name, args = {}, &block)
+        return new.send(method_name, &block) if args == {}
+        new.send(method_name, args, &block)
       end
 
-      def list
-        adapter.new(method: :get, endpoint: "/events").perform
+      def respond_to_missing?(method_name, include_private = false)
+        super
       end
+    end
 
-      def find(id)
-        adapter.new(method: :get, endpoint: "/events/#{id}").perform
-      end
+    attr_reader :options
 
-      def cancel(id)
-        adapter.new(method: :delete, endpoint: "/events/#{id}").perform
-      end
+    def initialize(wait_for_response: true)
+      @options = {
+        wait_for_response: wait_for_response,
+      }
+    end
 
-      private
+    def schedule(args)
+      adapter.new(method: :post, endpoint: "/events", body: args, options: options).perform
+    end
 
-      def adapter
-        Bloodbath::Adapters::Rest
-      end
+    def list
+      adapter.new(method: :get, endpoint: "/events", options: options).perform
+    end
+
+    def find(id)
+      adapter.new(method: :get, endpoint: "/events/#{id}", options: options).perform
+    end
+
+    def cancel(id)
+      adapter.new(method: :delete, endpoint: "/events/#{id}", options: options).perform
+    end
+
+    private
+
+    def adapter
+      Bloodbath::Adapters::Rest
     end
   end
 end