1 files changed, 40 insertions, 0 deletions
diff --git a/www/crm/wp-content/plugins/civicrm/civicrm/ext/api4/Civi/Api4/Event/Subscriber/ActivityPreCreationSubscriber.php b/www/crm/wp-content/plugins/civicrm/civicrm/ext/api4/Civi/Api4/Event/Subscriber/ActivityPreCreationSubscriber.php
new file mode 100644
index 00000000..1938ce0b
--- /dev/null
+++ b/www/crm/wp-content/plugins/civicrm/civicrm/ext/api4/Civi/Api4/Event/Subscriber/ActivityPreCreationSubscriber.php
@@ -0,0 +1,40 @@
+<?php
+
+namespace Civi\Api4\Event\Subscriber;
+
+use Civi\Api4\Generic\DAOCreateAction;
+use Civi\Api4\OptionValue;
+
+class ActivityPreCreationSubscriber extends PreCreationSubscriber {
+  /**
+   * @param DAOCreateAction $request
+   * @throws \API_Exception
+   * @throws \Exception
+   */
+  protected function modify(DAOCreateAction $request) {
+    $activityType = $request->getValue('activity_type');
+    if ($activityType) {
+      $result = OptionValue::get()
+        ->setCheckPermissions(FALSE)
+        ->addWhere('name', '=', $activityType)
+        ->addWhere('option_group.name', '=', 'activity_type')
+        ->execute();
+
+      if ($result->count() !== 1) {
+        throw new \Exception('Activity type must match a *single* type');
+      }
+
+      $request->addValue('activity_type_id', $result->first()['value']);
+    }
+  }
+
+  /**
+   * @param DAOCreateAction $request
+   *
+   * @return bool
+   */
+  protected function applies(DAOCreateAction $request) {
+    return $request->getEntityName() === 'Activity';
+  }
+
+}