Fixed issue with output field handlers

Civi/DataProcessor/Factory.php

@@ -107,6 +107,7 @@ class Factory {
     $this->addDataSource('event', 'Civi\DataProcessor\Source\EventSource', E::ts('Event'));
     $this->addDataSource('participant', 'Civi\DataProcessor\Source\ParticipantSource', E::ts('Participant'));
     $this->addDataSource('mailing', 'Civi\DataProcessor\Source\MailingSource', E::ts('Mailing'));
+    $this->addDataSource('mailing_job', 'Civi\DataProcessor\Source\MailingJobSource', E::ts('Mailing Job'));
     $this->addOutput('api', 'Civi\DataProcessor\Output\Api', E::ts('API'));
     $this->addFilter('simple_sql_filter', 'Civi\DataProcessor\FilterHandler\SimpleSqlFilter', E::ts('Simple Filter'));
     $this->addjoinType('simple_join', 'Civi\DataProcessor\DataFlow\MultipleDataFlows\SimpleJoin', E::ts('Simple Join'));

Civi/DataProcessor/FieldOutputHandler/OptionFieldOutputHandler.php

@@ -26,7 +26,7 @@ class OptionFieldOutputHandler extends AbstractFieldOutputHandler {
   public function __construct(FieldSpecification $inputFieldSpec, SourceInterface $dataSource) {
     $this->dataSource = $dataSource;
     $this->inputFieldSpec = $inputFieldSpec;
-    $this->outputFieldSpecification = $inputFieldSpec;
+    $this->outputFieldSpecification = clone $inputFieldSpec;
     $this->outputFieldSpecification->alias = $this->getName();
   }
 

Civi/DataProcessor/FieldOutputHandler/RawFieldOutputHandler.php

@@ -25,7 +25,7 @@ class RawFieldOutputHandler extends AbstractFieldOutputHandler {
   public function __construct(FieldSpecification $inputFieldSpec, SourceInterface $dataSource) {
     $this->dataSource = $dataSource;
     $this->inputFieldSpec = $inputFieldSpec;
-    $this->outputFieldSpecification = $inputFieldSpec;
+    $this->outputFieldSpecification = clone $inputFieldSpec;
     $this->outputFieldSpecification->alias = $this->getName();
   }
 

Civi/DataProcessor/Source/MailingJobSource.php

+<?php
+/**
+ * @author Jaap Jansma <jaap.jansma@civicoop.org>
+ * @license AGPL-3.0
+ */
+
+namespace Civi\DataProcessor\Source;
+
+use Civi\DataProcessor\DataFlow\SqlTableDataFlow;
+use Civi\DataProcessor\DataSpecification\DataSpecification;
+use Civi\DataProcessor\DataSpecification\FieldSpecification;
+
+use CRM_Dataprocessor_ExtensionUtil as E;
+
+class MailingJobSource extends AbstractCivicrmEntitySource {
+
+  /**
+   * Returns the entity name
+   *
+   * @return String
+   */
+  protected function getEntity() {
+    return 'MailingJob';
+  }
+
+  /**
+   * Returns the table name of this entity
+   *
+   * @return String
+   */
+  protected function getTable() {
+    return 'civicrm_mailing_job';
+  }
+
+}
\ No newline at end of file