ConfigToken\TreeCompiler\XrefResolver\Types\UrlXrefResolver::resolve()

Complexity

Conditions	12
Paths	35

Size

Total Lines	77
Code Lines	58

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	156

Importance

Changes	1
Bugs	0	Features	0

<?php
    public static function resolve(Xref $xref, $force = false)
    {
        if ($xref->isResolved() && (!$force)) {
            return;
        }
        static::matchType($xref);
        if (!$xref->hasLocation()) {
            throw new XrefResolverFetchException($xref);
        }
        $data = null;
        $httpCode = null;
        $contentType = null;
        $eventManager = EventManager::getInstance();
        if ($eventManager->hasListeners()) {
            $event = new Event(self::EVENT_ID_RESOLVE_URL);
            $event->data[self::EVENT_URL] = $xref->getLocation();
            $event->data[Event::RESULT] = false;
            $eventManager->dispatch($event);
            if (isset($event->data[Event::RESULT])) {
                if ($event->data[Event::RESULT] === true) {
                    $data = $event->data[self::EVENT_DATA];
                    $contentType = $event->data[self::EVENT_CONTENT_TYPE];
                    $httpCode = 200;
                } else if ($event->data[Event::RESULT] !== false) {
                    throw new XrefResolverFetchException(
                        $xref,
                        sprintf(
                            'Got error message from listener: %s',
                            $event->data[Event::RESULT]
                        )
                    );
                }
            }
        }
        if (!isset($data)) {
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
            curl_setopt($ch, CURLOPT_URL, $xref->getLocation());
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
            curl_setopt($ch, CURLOPT_TIMEOUT, 60);
            curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
            curl_setopt($ch, CURLOPT_HEADER, false);
            $data = curl_exec($ch);

            $contentType = curl_getinfo($ch, CURLINFO_CONTENT_TYPE);
            $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

            curl_close($ch);
        }

        if ($httpCode != 200) {
            throw new XrefResolverFetchException($xref, sprintf('Got response code %d', $httpCode));
        }
        if (TreeSerializerFactory::isRegisteredByContentType($contentType)) {
            $serializer = TreeSerializerFactory::getByContentType($contentType);
            $xref->setContentType($contentType);
        } else {
            $path = parse_url($xref->getLocation(), PHP_URL_PATH);
            $fileExtension = pathinfo($path, PATHINFO_EXTENSION);
            if (!TreeSerializerFactory::isRegisteredByFileExtension($fileExtension)) {
                throw new UnknownXrefTypeException(
                    sprintf(
                        'Unable to find resolver for Xref content type "%s" or file extension "%s" for location "%s".',
                        $contentType,
                        $fileExtension,
                        $xref->getLocation()
                    )
                );
            }
            $serializer = TreeSerializerFactory::getByFileExtension($fileExtension);
            $xref->setContentType($serializer::getContentType());
        }
        // TODO: catch exception, show xref location in error message
        $data = $serializer::deserialize($data);
        $xref->setData($data);
        $xref->setResolved(true);
    }
}