added MailingGroup

Civi/DataProcessor/Factory.php

@@ -108,6 +108,7 @@ class Factory {
     $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->addDataSource('mailing_group', 'Civi\DataProcessor\Source\MailingGroupSource', E::ts('Mailing Group'));
     $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/Source/AbstractCivicrmEntitySource.php

@@ -159,7 +159,7 @@ abstract class AbstractCivicrmEntitySource implements SourceInterface {
         continue;
       }
       $type = \CRM_Utils_Type::typeToString($field['type']);
-      $options = $bao::buildOptions($field['name']);
+      $options = $dao::buildOptions($field['name']);
       $alias = $this->getSourceName(). '_'.$field['name'];
       $fieldSpec = new FieldSpecification($field['name'], $type, $field['title'], $options, $alias);
       $dataSpecification->addFieldSpecification($fieldSpec->name, $fieldSpec);

Civi/DataProcessor/Source/MailingGroupSource.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 MailingGroupSource extends AbstractCivicrmEntitySource {
+
+  /**
+   * Returns the entity name
+   *
+   * @return String
+   */
+  protected function getEntity() {
+    return 'MailingGroup';
+  }
+
+  /**
+   * Returns the table name of this entity
+   *
+   * @return String
+   */
+  protected function getTable() {
+    return 'civicrm_mailing_group';
+  }
+
+}
\ No newline at end of file