Sha256: 566acd7e3a0a5a878d4565bf6df2c25b91497746c40e057f628a19ba4f3deed4
Contents?: true
Size: 1.56 KB
Versions: 6
Compression:
Stored size: 1.56 KB
Contents
# Routine for getting account updates from the Accounts server
#
# Should be scheduled to run regularly
module OpenStax
module Accounts
class SyncAccounts
SYNC_ATTRIBUTES = ['username', 'first_name', 'last_name', 'full_name', 'title',
'faculty_status', 'salesforce_contact_id', 'uuid', 'role']
lev_routine transaction: :no_transaction
protected
def exec(options={})
return if OpenStax::Accounts.configuration.enable_stubbing?
response = OpenStax::Accounts::Api.get_application_account_updates
app_accounts = []
app_accounts_rep = OpenStax::Accounts::Api::V1::ApplicationAccountsRepresenter
.new(app_accounts)
app_accounts_rep.from_json(response.body)
return if app_accounts.empty?
updated_app_accounts = []
app_accounts.each do |app_account|
account = OpenStax::Accounts::Account.where(
openstax_uid: app_account.account.openstax_uid
).first || app_account.account
account.syncing = true
if account != app_account.account
SYNC_ATTRIBUTES.each do |attribute|
account.send("#{attribute}=", app_account.account.send(attribute))
end
end
next unless account.save
updated_app_accounts << {user_id: account.openstax_uid,
read_updates: app_account.unread_updates}
end
OpenStax::Accounts::Api.mark_account_updates_as_read(updated_app_accounts)
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems