module Jason

# File lib/jason.rb, line 38
def self.init
  # Don't run in AR migration / generator etc.
  return if $PROGRAM_NAME == '-e' || ActiveRecord::Base.connection.migration_context.needs_migration?

  # Check if the schema has changed since last time app was started. If so, do some work to ensure cache contains the correct data
  got_lock = $redis_jason.set('jason:schema:lock', nx: true, ex: 3600) # Basic lock mechanism for multi-process environments
  return if !got_lock

  previous_schema = JSON.parse($redis_jason.get('jason:last_schema') || '{}')
  current_schema = Jason.schema.deep_stringify_keys.deep_transform_values { |v| v.is_a?(Symbol) ? v.to_s : v }
  current_schema.each do |model, config|
    if config != previous_schema[model]
      puts "Config changed for #{model}"
      puts "Old config was #{previous_schema[model]}"
      puts "New config is #{config}"
      puts "Rebuilding cache for #{model}"

      # This is necessary to ensure all Rails methods have been added to model before we attempt to cache.
      Rails.configuration.after_initialize do
         model.classify.constantize.cache_all
      end
      puts "Done"
    end
  end

  $redis_jason.set('jason:last_schema', current_schema.to_json)
ensure
  $redis_jason.del('jason:schema:lock')
end

# File lib/jason.rb, line 70
def self.setup(&block)
  yield self

  $redis_jason = self.redis || ::ConnectionPool::Wrapper.new(size: 5, timeout: 3) { ::Redis.new(url: ENV['REDIS_URL']) }

  if ![:action_cable, :pusher].include?(self.transport_service)
    raise "Unknown transport service '#{self.transport_service}' specified"
  end

  if self.transport_service == :pusher && self.pusher.blank?
    raise "Pusher specified as transport service but no Pusher client provided. Please configure with config.pusher = Pusher::Client.new(...)"
  end

  init
end