FeedsExJsonPathLines.inc in Feeds extensible parsers 7.2

Contains FeedsExJsonPathLines.

File

src/FeedsExJsonPathLines.inc

<?php

/**
 * @file
 * Contains FeedsExJsonPathLines.
 */

/**
 * Parses the JSON Lines format via JSONPath.
 */
class FeedsExJsonPathLines extends FeedsExJsonPath {

  /**
   * The file iterator.
   *
   * @var FeedsExLineIterator
   */
  protected $iterator;

  /**
   * {@inheritdoc}
   */
  protected function executeContext(FeedsSource $source, FeedsFetcherResult $fetcher_result) {
    return $this->iterator;
  }

  /**
   * {@inheritdoc}
   */
  protected function hasConfigurableContext() {
    return FALSE;
  }

  /**
   * {@inheritdoc}
   */
  protected function setUp(FeedsSource $source, FeedsFetcherResult $fetcher_result) {
    $this->iterator = new FeedsExLineIterator($fetcher_result
      ->getFilePath());
    $this->iterator
      ->setLineLimit($source->importer
      ->getLimit());
    $state = $source
      ->state(FEEDS_PARSE);
    if (!$state->total) {
      $state->total = $this->iterator
        ->getSize();
    }
    $state->start = $state->pointer ? $state->pointer : 0;
    $this->iterator
      ->setStartPosition($state->start);
  }

  /**
   * {@inheritdoc}
   */
  protected function cleanUp(FeedsSource $source, FeedsParserResult $result) {
    $state = $source
      ->state(FEEDS_PARSE);
    $state->pointer = $this->iterator
      ->ftell();
    unset($this->iterator);
  }

  /**
   * {@inheritdoc}
   */
  protected function executeSourceExpression($machine_name, $expression, $row) {

    // Row is a JSON string.
    if ($encoding = $this
      ->detectEncoding($row)) {
      $row = $this
        ->convertEncoding($row, $encoding);
    }
    $result = jsonPath(drupal_json_decode($row), $expression);
    if (is_scalar($result)) {
      return $result;
    }

    // Return a single value if there's only one value.
    return count($result) === 1 ? reset($result) : $result;
  }

}

Classes

Name	Description
FeedsExJsonPathLines	Parses the JSON Lines format via JSONPath.