AttributeReleasePolicyService::applyAttributeReleasePolicies()

Complexity

Conditions	10
Paths	10

Size

Total Lines

73

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function applyAttributeReleasePolicies(ConsentList $consentList, AttributeSetInterface $attributeSet)
    {
        $entityIds = $consentList->map(function (Consent $consent) {
            return $consent->getServiceProvider()->getEntity()->getEntityId()->getEntityId();
        });

        $mappedAttributes = [];
        foreach ($attributeSet as $attribute) {
            $mace = $attribute->getAttributeDefinition()->getUrnMace();
            $oid  = $attribute->getAttributeDefinition()->getUrnOid();

            if ($mace !== null) {
                $mappedAttributes[$mace] = $attribute->getValue();
            }

            if ($oid !== null) {
                $mappedAttributes[$oid] = $attribute->getValue();
            }
        }

        $data = [
            'entityIds'  => $entityIds,
            'attributes' => !empty($mappedAttributes) ? $mappedAttributes : new stdClass(),
            'showSources' => true,
        ];
        // Arp is applied for all entities
        $response = $this->jsonApiClient->post($data, '/arp');

        $data = [
            'entityIds'  => $entityIds,
        ];

        // Arp information is retrieved for all entities with arp enabled.
        $arpResponse = $this->jsonApiClient->post($data, '/read-arp');

        $specifiedConsents = $consentList->map(
            function (Consent $consent) use ($response, $arpResponse) {
                $entityId = $consent->getServiceProvider()->getEntity()->getEntityId()->getEntityId();

                if (!isset($response[$entityId])) {
                    throw new InvalidResponseException(
                        sprintf(
                            'EntityID "%s" was not found in the ARP response (entityIDs: %s)',
                            $entityId,
                            join(', ', array_keys($response))
                        )
                    );
                }

                $attributes = [];
                foreach ($response[$entityId] as $attributeName => $attributeValue) {
                    try {
                        $attributeDefinition = $this->attributeDictionary->getAttributeDefinitionByUrn($attributeName);
                    } catch (UnknownUrnException $exception) {
                        $attributeDefinition = new AttributeDefinition($attributeName, $attributeName, $attributeName);
                    }

                    $attribute = new Attribute($attributeDefinition, $attributeValue);
                    if (!in_array($attribute, $attributes)) {
                        $attributes[] = $attribute;
                    }
                }
                $arp = Arp::createWith([], null);
                if (isset($arpResponse[$entityId])) {
                    $arp = Arp::createWith($arpResponse[$entityId], $this->attributeDictionary);
                }

                return SpecifiedConsent::specifies($consent, AttributeSetWithFallbacks::create($attributes), $arp);
            }
        );

        return SpecifiedConsentList::createWith($specifiedConsents);
    }
}