Sha256: b7a43e17c25fbe50946481bc6c5ad610fe3d6b4a7bcd62fd2c4fd3be8982ccf3
Contents?: true
Size: 1.68 KB
Versions: 6
Compression:
Stored size: 1.68 KB
Contents
# Routine for getting group updates from the Accounts server
#
# Should be scheduled to run regularly
module OpenStax
module Accounts
class SyncGroups
SYNC_ATTRIBUTES = ['name', 'is_public', 'group_members',
'group_owners', 'member_group_nestings',
'cached_supertree_group_ids', 'cached_subtree_group_ids']
lev_routine transaction: :no_transaction
protected
def exec(options={})
begin
OpenStax::Accounts.syncing = true
return if OpenStax::Accounts.configuration.enable_stubbing?
response = OpenStax::Accounts.get_application_group_updates
app_groups = []
app_groups_rep = OpenStax::Accounts::Api::V1::ApplicationGroupsRepresenter
.new(app_groups)
app_groups_rep.from_json(response.body)
return if app_groups.empty?
updated_app_groups = []
app_groups.each do |app_group|
group = OpenStax::Accounts::Group.where(
:openstax_uid => app_group.group.openstax_uid).first || app_group.group
if group != app_group.group
SYNC_ATTRIBUTES.each do |attribute|
group.send("#{attribute}=", app_group.group.send(attribute))
end
end
next unless group.save
updated_app_groups << {group_id: group.openstax_uid,
read_updates: app_group.unread_updates}
end
OpenStax::Accounts.mark_group_updates_as_read(updated_app_groups)
ensure
OpenStax::Accounts.syncing = false
end
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems