require "pusherable/version"
require "active_support"
require "active_record"

module Pusherable
  extend ::ActiveSupport::Concern

  module ClassMethods
    def pusherable?
      false
    end

    def pusherable(pusherable_channel="test_channel")
      raise "Please `gem install pusher` and configure it to run in your app!" if Pusher.app_id.blank? || Pusher.key.blank? || Pusher.secret.blank?

      class_attribute :pusherable_channel

      self.pusherable_channel = pusherable_channel

      class_eval do
        if defined?(Mongoid) && defined?(Mongoid::Document) && include?(Mongoid::Document)
          after_create :pusherable_trigger_create
          after_update :pusherable_trigger_update
          before_destroy :pusherable_trigger_destroy
        else
          after_commit :pusherable_trigger_create, on: :create
          after_commit :pusherable_trigger_update, on: :update
          after_commit :pusherable_trigger_destroy, on: :destroy
        end

        def self.pusherable?
          true
        end

        singleton_class.send(:alias_method, :generated_pusherable_channel, :pusherable_channel)

        def self.pusherable_channel(obj=nil)
          if generated_pusherable_channel.respond_to? :call
            if generated_pusherable_channel.arity > 0
              generated_pusherable_channel.call(obj)
            else
              generated_pusherable_channel.call
            end
          else
            generated_pusherable_channel
          end
        end

        def pusherable_channel
          self.class.pusherable_channel(self)
        end

        private

        def pusherable_class_name
          self.class.name.underscore
        end

        def pusherable_trigger_create
          Pusher.trigger(pusherable_channel, "#{pusherable_class_name}.create", to_json)
        end

        def pusherable_trigger_update
          Pusher.trigger(pusherable_channel, "#{pusherable_class_name}.update", to_json)
        end

        def pusherable_trigger_destroy
          Pusher.trigger(pusherable_channel, "#{pusherable_class_name}.destroy", to_json)
        end
      end
    end
  end
end

if defined?(ActiveRecord) && defined?(ActiveRecord::Base)
  ActiveRecord::Base.send :include, Pusherable
end

if defined?(Mongoid) && defined?(Mongoid::Document)
  Mongoid::Document.send :include, Pusherable
end