32 lines
656 B
Ruby
32 lines
656 B
Ruby
# frozen_string_literal: true
|
|
|
|
module Subscriptions
|
|
class BaseSubscription < GraphQL::Schema::Subscription
|
|
object_class Types::BaseObject
|
|
field_class Types::BaseField
|
|
|
|
def initialize(object:, context:, field:)
|
|
super
|
|
|
|
# Reset user so that we don't use a stale user for authorization
|
|
current_user.reset if current_user
|
|
end
|
|
|
|
def authorized?(*)
|
|
raise NotImplementedError
|
|
end
|
|
|
|
private
|
|
|
|
def unauthorized!
|
|
unsubscribe if context.query.subscription_update?
|
|
|
|
raise GraphQL::ExecutionError, 'Unauthorized subscription'
|
|
end
|
|
|
|
def current_user
|
|
context[:current_user]
|
|
end
|
|
end
|
|
end
|