WIP actions hooks

code/web/cron/updateCommunityEngagementMilestonesProgress.php

@@ -0,0 +1,4 @@
+<?php
+require_once __DIR__ . '/../bootstrap.php';
+
+#DO CODE HERE

code/web/sys/DB/DataObject.php

@@ -1,5 +1,5 @@
 <?php
-
+require_once ROOT_DIR . '/sys/action-hooks.php';
 /**
  * Class DataObject
  *
@@ -310,6 +310,8 @@ public function insert($context = '') {
 		$serializedFields = $this->getSerializedFieldNames();
 		$compressedFields = $this->getCompressedColumnNames();
 
+		do_action('before_object_insert', get_object_vars($this));
+
 		$properties = get_object_vars($this);
 		$propertyNames = '';
 		$propertyValues = '';
@@ -408,6 +410,9 @@ public function insert($context = '') {
 			}
 		}
 
+		#Call hook for post insert here
+		do_action('after_object_insert', $this);
+
 		return $response;
 	}
 

code/web/sys/action-hooks.php

@@ -0,0 +1,80 @@
+<?php
+
+$hook_actions = array();
+
+ /**
+ * Attach (or remove) multiple callbacks to an action and trigger those callbacks when that action is called.
+ *
+ * @param string $hook name
+ * @param string $action name
+ * @param mixed $callback the method or function to call - FALSE to remove all callbacks for action
+ */
+
+function add_action($hook_name, $action_name, $callback = NULL){
+    global $hook_actions;
+
+    if($callback)
+    {
+        $hook_actions[$hook_name][$action_name] = $callback;
+    }
+    else
+    {
+        unset($hook_actions[$hook_name][$action_name]);
+    }
+}
+
+/**
+ * Executes all callback functions attached to a given action.
+ *
+ * @param string $action The name of the action to execute.
+ * @param mixed $value (optional) The value to pass to each callback function. Defaults to NULL.
+ * @return void
+ */
+
+function do_action($hook_name, $value = NULL){
+    global $hook_actions;
+
+    if(isset($hook_actions[$hook_name])) // Fire a callback
+    {
+        foreach($hook_actions[$hook_name] as $function)
+        {
+            call_user_func($function, $value);
+        }
+    }
+}
+
+add_action('before_object_insert', 'before_checkout_insert', function($value){
+
+    $tableName = 'user_checkout';
+
+    # Bail if not the table we want
+    if($value['__table'] != $tableName) return;
+
+    # Bail if the newly created checkout already exists
+    $checkOuts = new CheckOut();
+    $checkOuts->query("SELECT sourceId from {$tableName} WHERE sourceId = {$value['sourceId']}");
+    if ($checkOuts->getNumResults() > 0) {
+        return;
+    }
+
+    # Add entry to ce_milestone_goal_actions
+
+});
+
+// Example of action hook
+// add_action('after_object_insert', 'after_checkout_insert', function($value){
+
+//     $tableName = 'user_checkout';
+
+//     # Bail if not the table we want
+//     if($value->__table != $tableName) return;
+
+//     # Bail if the newly created checkout already exists
+//     $checkOuts = new CheckOut();
+//     $checkOuts->query("SELECT sourceId from {$tableName} WHERE sourceId = {$value->sourceId}");
+//     if ($checkOuts->getNumResults() > 0) {
+//         return;
+//     }
+
+
+// });