DataStream.php in farmOS 2.x

Namespace

Drupal\data_stream\Plugin\migrate\destination

File

modules/core/data_stream/src/Plugin/migrate/destination/DataStream.php

<?php

namespace Drupal\data_stream\Plugin\migrate\destination;

use Drupal\migrate\Plugin\migrate\destination\EntityContentBase;
use Drupal\migrate\Row;

/**
 * A destination plugin for data streams that can use a "providing_asset" ID.
 *
 * Extend the entity content base plugin to create backwards references
 * to assets that provide data streams. This is necessary because there was
 * no concept of data streams in farmOS 1.x. When creating a data stream from a
 * sensor asset, we need to reference the asset at this time.
 *
 * @MigrateDestination(
 *   id = "data_stream",
 *   provider = "data_stream"
 * )
 */
class DataStream extends EntityContentBase {

  /**
   * {@inheritdoc}
   */
  protected static function getEntityTypeId($plugin_id) {
    return 'data_stream';
  }

  /**
   * {@inheritdoc}
   */
  protected function getEntity(Row $row, array $old_destination_id_values) {

    // The parent will create or update the entity.
    $entity = parent::getEntity($row, $old_destination_id_values);

    // Bail if the no entity was returned.
    if (empty($entity)) {
      return $entity;
    }

    // Save the entity now so that it has an ID.
    // This means that the EntityValidationRequired feature will not work
    // because we save it now, rather than waiting to see if it is validated.
    $entity
      ->save();

    // Check if a providing_asset ID was provided.
    if ($row
      ->hasDestinationProperty('providing_asset')) {
      $providing_asset = $row
        ->getDestinationProperty('providing_asset');

      /** @var \Drupal\asset\Entity\AssetInterface $asset */
      $asset = \Drupal::entityTypeManager()
        ->getStorage('asset')
        ->load($providing_asset);

      // Update the assets data_stream field if the asset was found
      // and the asset type has the field.
      if (!empty($asset) && $asset
        ->hasField('data_stream')) {
        $asset->data_stream[] = $entity
          ->id();
        $asset
          ->save();
      }
    }

    // Return the entity.
    return $entity;
  }

}

Classes

Name	Description
DataStream	A destination plugin for data streams that can use a "providing_asset" ID.