|
| 1 | +# frozen_string_literal: true |
| 2 | + |
| 3 | +module UserGroupMemberships |
| 4 | + class SyncEntitlements |
| 5 | + include Dry::Monads[:result, :do] |
| 6 | + |
| 7 | + attr_reader :membership |
| 8 | + |
| 9 | + delegate :user, :user_group, to: :membership |
| 10 | + |
| 11 | + # @param [User] user |
| 12 | + # @return [Dry::Monads::Result] |
| 13 | + def call(membership) |
| 14 | + @membership = membership |
| 15 | + |
| 16 | + destroy_excess_entitlements |
| 17 | + create_missing_entitlements |
| 18 | + |
| 19 | + return Success() |
| 20 | + end |
| 21 | + |
| 22 | + def create_missing_entitlements |
| 23 | + subjects = entitlements_to_create.map { _1[:subject_type].constantize.find _1[:subject_id] } |
| 24 | + subjects.each do |subject| |
| 25 | + Entitlements::Create.run( |
| 26 | + subject:, |
| 27 | + target: user, |
| 28 | + entitling_entity: membership, |
| 29 | + scoped_roles: { read_access: true } |
| 30 | + ) |
| 31 | + end |
| 32 | + end |
| 33 | + |
| 34 | + def destroy_excess_entitlements |
| 35 | + entitlements_to_destroy.map do |
| 36 | + Entitlement.by_entitling_entity(membership).where(**_1) |
| 37 | + end.reduce do |memo, query| |
| 38 | + memo.or(query) |
| 39 | + end&.destroy_all |
| 40 | + end |
| 41 | + |
| 42 | + def entitlements_to_create |
| 43 | + expected_entitlements - existing_entitlements |
| 44 | + end |
| 45 | + |
| 46 | + def entitlements_to_destroy |
| 47 | + existing_entitlements - expected_entitlements |
| 48 | + end |
| 49 | + |
| 50 | + def existing_entitlements |
| 51 | + @existing_entitlements ||= Entitlement.where( |
| 52 | + target: user, |
| 53 | + entitler: membership.to_upsertable_entitler |
| 54 | + ).map do |
| 55 | + { subject_type: _1.subject_type, subject_id: _1.subject_id } |
| 56 | + end |
| 57 | + end |
| 58 | + |
| 59 | + def expected_entitlements |
| 60 | + @expected_entitlements ||= user_group.entitleables.reload.map do |
| 61 | + { subject_type: _1.entitleable_type, subject_id: _1.entitleable_id } |
| 62 | + end |
| 63 | + end |
| 64 | + end |
| 65 | +end |
0 commit comments