SensorAsset.php in farmOS 2.x

Namespace

Drupal\farm_migrate\Plugin\migrate\source\d7

File

modules/core/migrate/src/Plugin/migrate/source/d7/SensorAsset.php

<?php

namespace Drupal\farm_migrate\Plugin\migrate\source\d7;

use Drupal\migrate\Row;

/**
 * Migration source for the d7 sensor asset.
 *
 * Extends the Asset source to include the sensor_type and sensor_settings
 * fields as source properties for the migration.
 *
 * @MigrateSource(
 *   id = "d7_sensor_asset",
 *   source_module = "farm_sensor"
 * )
 */
class SensorAsset extends FarmAsset {

  /**
   * {@inheritdoc}
   */
  public function query() {

    // Get the parent query.
    $query = parent::query();

    // Join in the farm_sensor table.
    $query
      ->join('farm_sensor', 'fs', 'fa.id = fs.id');

    // Limit by the sensor type.
    if (isset($this->configuration['sensor_type'])) {

      // Specify the sensor type.
      if (!empty($this->configuration['sensor_type'])) {
        $query
          ->condition('fs.type', (array) $this->configuration['sensor_type'], 'IN');
      }
      else {
        $query
          ->where("fs.type = '' OR fs.type IS NULL");
      }
    }

    // Add sensor fields aliased with correct name.
    $query
      ->addField('fs', 'type', 'sensor_type');
    $query
      ->addField('fs', 'settings', 'sensor_settings');
    return $query;
  }

  /**
   * {@inheritdoc}
   */
  public function prepareRow(Row $row) {

    // Get the sensor_settings field.
    $settings = $row
      ->getSourceProperty('sensor_settings');
    if (!empty($settings)) {

      // Unserialize the sensor_settings field.
      $settings_array = unserialize($settings);

      // Re-set the source property value.
      $row
        ->setSourceProperty('sensor_settings', $settings_array);
    }
    return parent::prepareRow($row);
  }

}

Classes

Name	Description
SensorAsset	Migration source for the d7 sensor asset.