1 files changed, 155 insertions, 0 deletions
diff --git a/www/crm/wp-content/plugins/civicrm/civicrm/ext/api4/Civi/Api4/Provider/ActionObjectProvider.php b/www/crm/wp-content/plugins/civicrm/civicrm/ext/api4/Civi/Api4/Provider/ActionObjectProvider.php
new file mode 100644
index 00000000..60596d92
--- /dev/null
+++ b/www/crm/wp-content/plugins/civicrm/civicrm/ext/api4/Civi/Api4/Provider/ActionObjectProvider.php
@@ -0,0 +1,155 @@
+<?php
+/*
+ +--------------------------------------------------------------------+
+ | CiviCRM version 4.7                                                |
+ +--------------------------------------------------------------------+
+ | Copyright CiviCRM LLC (c) 2004-2015                                |
+ +--------------------------------------------------------------------+
+ | This file is a part of CiviCRM.                                    |
+ |                                                                    |
+ | CiviCRM is free software; you can copy, modify, and distribute it  |
+ | under the terms of the GNU Affero General Public License           |
+ | Version 3, 19 November 2007 and the CiviCRM Licensing Exception.   |
+ |                                                                    |
+ | CiviCRM is distributed in the hope that it will be useful, but     |
+ | WITHOUT ANY WARRANTY; without even the implied warranty of         |
+ | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.               |
+ | See the GNU Affero General Public License for more details.        |
+ |                                                                    |
+ | You should have received a copy of the GNU Affero General Public   |
+ | License and the CiviCRM Licensing Exception along                  |
+ | with this program; if not, contact CiviCRM LLC                     |
+ | at info[AT]civicrm[DOT]org. If you have questions about the        |
+ | GNU Affero General Public License or the licensing of CiviCRM,     |
+ | see the CiviCRM license FAQ at http://civicrm.org/licensing        |
+ +--------------------------------------------------------------------+
+ */
+
+namespace Civi\Api4\Provider;
+
+use Civi\API\Event\ResolveEvent;
+use Civi\API\Provider\ProviderInterface;
+use Civi\Api4\Generic\AbstractAction;
+use Civi\API\Events;
+use Civi\Api4\Generic\Result;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+/**
+ * Accept $apiRequests based on \Civi\API\Action
+ */
+class ActionObjectProvider implements EventSubscriberInterface, ProviderInterface {
+
+  /**
+   * @return array
+   */
+  public static function getSubscribedEvents() {
+    // Using a high priority allows adhoc implementations
+    // to override standard implementations -- which is
+    // handy for testing/mocking.
+    return [
+      Events::RESOLVE => [
+        ['onApiResolve', Events::W_EARLY],
+      ],
+    ];
+  }
+  /**
+   * @param ResolveEvent $event
+   *   API resolution event.
+   */
+  public function onApiResolve(ResolveEvent $event) {
+    $apiRequest = $event->getApiRequest();
+    if ($apiRequest instanceof AbstractAction) {
+      $event->setApiRequest($apiRequest);
+      $event->setApiProvider($this);
+      $event->stopPropagation();
+    }
+  }
+
+  /**
+   * @inheritDoc
+   *
+   * @param AbstractAction $action
+   *
+   * @return array|mixed
+   */
+  public function invoke($action) {
+    $result = new Result();
+    $result->action = $action->getActionName();
+    $result->entity = $action->getEntityName();
+    $action->_run($result);
+    $this->handleChains($action, $result);
+    return $result;
+  }
+
+  /**
+   * Run each chained action once per row
+   *
+   * @param AbstractAction $action
+   * @param Result $result
+   */
+  protected function handleChains($action, $result) {
+    foreach ($action->getChain() as $name => $request) {
+      $request += [NULL, NULL, [], NULL];
+      $request[2]['checkPermissions'] = $action->getCheckPermissions();
+      foreach ($result as &$row) {
+        $row[$name] = $this->runChain($request, $row);
+      }
+    }
+  }
+
+  /**
+   * Run a chained action
+   *
+   * @param $request
+   * @param $row
+   * @return array|\Civi\Api4\Generic\Result|null
+   * @throws \API_Exception
+   */
+  protected function runChain($request, $row) {
+    list($entity, $action, $params, $index) = $request;
+    // Swap out variables in $entity, $action & $params
+    $this->resolveChainLinks($entity, $row);
+    $this->resolveChainLinks($action, $row);
+    $this->resolveChainLinks($params, $row);
+    return (array) civicrm_api4($entity, $action, $params, $index);
+  }
+
+  /**
+   * Swap out variable names
+   *
+   * @param mixed $val
+   * @param array $result
+   */
+  protected function resolveChainLinks(&$val, $result) {
+    if (is_array($val)) {
+      foreach ($val as &$v) {
+        $this->resolveChainLinks($v, $result);
+      }
+    }
+    elseif (is_string($val) && strlen($val) > 1 && substr($val, 0, 1) === '$') {
+      $val = \CRM_Utils_Array::pathGet($result, explode('.', substr($val, 1)));
+    }
+  }
+
+  /**
+   * @inheritDoc
+   * @param int $version
+   * @return array
+   */
+  public function getEntityNames($version) {
+    /** FIXME */
+    return [];
+  }
+
+  /**
+   * @inheritDoc
+   * @param int $version
+   * @param string $entity
+   * @return array
+   */
+  public function getActionNames($version, $entity) {
+    /** FIXME Civi\API\V4\Action\GetActions */
+    return [];
+  }
+
+}