JSKOS\RDF\Parser

Complexity

Total Complexity

9

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Importance

Changes

0

2 Methods

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

<?php declare(strict_types = 1);

namespace JSKOS\RDF;

use JSKOS\PrettyJsonSerializable;
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'));
        }
        
        $data = $jskos->jsonLDSerialize('');        
        if (!count($data['type'] ?? [])) { # TODO: put into JSKOS core package?
            $class = get_class($jskos);
            $data['type'] = [ $class::TYPES[0] ];
        }

        $rdf = JsonLD::toRdf(json_encode($data), ['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 = array(
			  'type' => 'uri',
			  'value' => (string) $quad->getObject()
			);

			if ('_:' === substr($object['value'], 0, 2)) {
			  $object = array(
				'type' => 'bnode',
				'value' => $this->remapBnode($object['value'])
			  );
			}
		  }
		  else {
			$object = array(
			  '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);
		}
    }
}