JSKOS\RDF\Parser

Complexity

Total Complexity

9

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	parseJSKOS()	0	19	3
B	parse()	0	39	6

<?php declare(strict_types = 1);

namespace JSKOS\RDF;

use JSKOS\PrettyJsonSerializable;
use JSKOS\Set;
use ML\JsonLD\JsonLD;
use ML\JsonLD\NQuads;
use ML\IRI\IRI;
use ML\JsonLD\LanguageTaggedString;
use EasyRdf_Graph;

/**
 * EasyRdf parser to support JSON-LD to RDF conversion.
 *
 * Bridges PHP packages EasyRDF and json-ld.
 */
class Parser extends \EasyRdf_Parser
{
    protected $context;

    /**
     * Parse JSKOS Resources to RDF.
     */
    public function parseJSKOS(PrettyJsonSerializable $jskos): EasyRdf_Graph
    {
        if (!$this->context) {
            $this->context = json_decode(file_get_contents(__DIR__.'/jskos-context.json'));
        }
        
        if ($jskos instanceof Set) {
            $json = '{"@graph":'.json_encode($jskos->jsonLDSerialize('', true)).'}';
        } else {
            $json = json_encode($jskos->jsonLDSerialize('', true));
        }

        $rdf = JsonLD::toRdf($json, ['expandContext' => $this->context]);
        # TODO: catch (\ML\JsonLD\Exception\JsonLdException $e)

        $graph = new EasyRdf_Graph();
        $this->parse($graph, $rdf);

        return $graph;
    }

    /**
     * Parse Quads as returned by JsonLD.
     */
    public function parse($graph, $data, $format = 'jsonld', $baseUri = null)
    {
        parent::checkParseParams($graph, $data, $format, $baseUri);

        foreach ($data as $quad) {
            $subject = (string)$quad->getSubject();

            if ('_:' === substr($subject, 0, 2)) {
                $subject = $this->remapBnode($subject);
            }

            $predicate = (string)$quad->getProperty();

            if ($quad->getObject() instanceof IRI) {
                $object = [
                    'type' => 'uri',
                    'value' => (string)$quad->getObject()
                ];

                if ('_:' === substr($object['value'], 0, 2)) {
                    $object = [
                        'type' => 'bnode',
                        'value' => $this->remapBnode($object['value'])
                    ];
                }
            } else {
                $object = [
                    'type' => 'literal',
                    'value' => $quad->getObject()->getValue()
                ];

                if ($quad->getObject() instanceof LanguageTaggedString) {
                    $object['lang'] = $quad->getObject()->getLanguage();
                } else {
                    $object['datatype'] = $quad->getObject()->getType();
                }
            }

            $this->addTriple($subject, $predicate, $object);
        }
    }
}