Sha256: 3a3e76c1c56de380929e7f3f85c3c4902c1ef2c03bee021214e052ebf7d416fe
Contents?: true
Size: 1.77 KB
Versions: 6
Compression:
Stored size: 1.77 KB
Contents
module Sufia
module Arkivo
class SubscriptionError < RuntimeError
end
class CreateSubscriptionJob
attr_reader :user
def queue_name
:arkivo_subscription
end
def initialize(user_key)
@user = ::User.find_by_user_key(user_key)
validate_user!
end
def run
# post json to API
response = post_to_api
# parse results
subscription_path = response.headers['Location']
# create subscription
user.arkivo_subscription = subscription_path
user.save
end
private
def logger
ActiveFedora::Base.logger
end
def validate_user!
log_and_raise('User not found') if user.blank?
log_and_raise('User does not have an Arkivo token') if user.arkivo_token.blank?
log_and_raise('User has not yet connected with Zotero') if user.zotero_userid.blank?
log_and_raise('User already has a subscription') if user.arkivo_subscription.present?
end
def log_and_raise(message)
logger.error "*** Arkivo error: #{message}: #{user}"
raise SubscriptionError, message
end
def post_to_api
Faraday.new(url: Sufia::Arkivo.config[:url]).post do |request|
request.url Sufia::Arkivo.new_subscription_url
request.headers['Content-Type'] = 'application/json'
request.body = new_subscription_json
end
end
def new_subscription_json
{
url: Sufia::Zotero.publications_url(@user.zotero_userid),
plugins: [
{
name: "sufia",
options: { token: @user.arkivo_token }
}
]
}.to_json
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems