mirror of
https://github.com/varvet/pundit.git
synced 2022-11-09 12:30:11 -05:00
122 lines
2.9 KiB
Ruby
122 lines
2.9 KiB
Ruby
require "pundit/version"
|
|
require "pundit/policy_finder"
|
|
require "active_support/concern"
|
|
require "active_support/core_ext/string/inflections"
|
|
require "active_support/core_ext/object/blank"
|
|
require "active_support/core_ext/module/introspection"
|
|
require "active_support/dependencies/autoload"
|
|
|
|
module Pundit
|
|
class NotAuthorizedError < StandardError
|
|
attr_reader :query, :record, :policy
|
|
|
|
def initialize(options = {})
|
|
@query = options[:query]
|
|
@record = options[:record]
|
|
@policy = options[:policy]
|
|
|
|
message = options.fetch(:message) { "not allowed to #{query} this #{record.inspect}" }
|
|
|
|
super(message)
|
|
end
|
|
end
|
|
class AuthorizationNotPerformedError < StandardError; end
|
|
class PolicyScopingNotPerformedError < AuthorizationNotPerformedError; end
|
|
class NotDefinedError < StandardError; end
|
|
|
|
extend ActiveSupport::Concern
|
|
|
|
class << self
|
|
def authorize(user, record, query)
|
|
policy = policy!(user, record)
|
|
|
|
unless policy.public_send(query)
|
|
raise NotAuthorizedError.new(query: query, record: record, policy: policy)
|
|
end
|
|
|
|
true
|
|
end
|
|
|
|
def policy_scope(user, scope)
|
|
policy_scope = PolicyFinder.new(scope).scope
|
|
policy_scope.new(user, scope).resolve if policy_scope
|
|
end
|
|
|
|
def policy_scope!(user, scope)
|
|
PolicyFinder.new(scope).scope!.new(user, scope).resolve
|
|
end
|
|
|
|
def policy(user, record)
|
|
policy = PolicyFinder.new(record).policy
|
|
policy.new(user, record) if policy
|
|
end
|
|
|
|
def policy!(user, record)
|
|
PolicyFinder.new(record).policy!.new(user, record)
|
|
end
|
|
end
|
|
|
|
included do
|
|
if respond_to?(:helper_method)
|
|
helper_method :policy_scope
|
|
helper_method :policy
|
|
helper_method :pundit_user
|
|
end
|
|
if respond_to?(:hide_action)
|
|
hide_action :policy
|
|
hide_action :policy_scope
|
|
hide_action :policies
|
|
hide_action :policy_scopes
|
|
hide_action :authorize
|
|
hide_action :verify_authorized
|
|
hide_action :verify_policy_scoped
|
|
hide_action :pundit_user
|
|
end
|
|
end
|
|
|
|
def verify_authorized
|
|
raise AuthorizationNotPerformedError unless @_pundit_policy_authorized
|
|
end
|
|
|
|
def verify_policy_scoped
|
|
raise PolicyScopingNotPerformedError unless @_pundit_policy_scoped
|
|
end
|
|
|
|
def authorize(record, query=nil)
|
|
query ||= params[:action].to_s + "?"
|
|
|
|
@_pundit_policy_authorized = true
|
|
|
|
policy = policy(record)
|
|
unless policy.public_send(query)
|
|
raise NotAuthorizedError.new(query: query, record: record, policy: policy)
|
|
end
|
|
|
|
true
|
|
end
|
|
|
|
def skip_authorization
|
|
@_pundit_policy_authorized = true
|
|
end
|
|
|
|
def policy_scope(scope)
|
|
@_pundit_policy_scoped = true
|
|
policy_scopes[scope] ||= Pundit.policy_scope!(pundit_user, scope)
|
|
end
|
|
|
|
def policy(record)
|
|
policies[record] ||= Pundit.policy!(pundit_user, record)
|
|
end
|
|
|
|
def policies
|
|
@_pundit_policies ||= {}
|
|
end
|
|
|
|
def policy_scopes
|
|
@_pundit_policy_scopes ||= {}
|
|
end
|
|
|
|
def pundit_user
|
|
current_user
|
|
end
|
|
end
|