From a23c2a957a84971bd85f7cff3c38715c0acc1ece Mon Sep 17 00:00:00 2001
From: FusionPBX <markjcrane@gmail.com>
Date: Wed, 28 Sep 2016 16:42:42 -0600
Subject: [PATCH] Update orm.php

---
 resources/classes/orm.php | 886 ++++++++++++++++++++++----------------
 1 file changed, 520 insertions(+), 366 deletions(-)

diff --git a/resources/classes/orm.php b/resources/classes/orm.php
index a327b26221..5d42efdd78 100644
--- a/resources/classes/orm.php
+++ b/resources/classes/orm.php
@@ -48,6 +48,9 @@
 				//public $name;
 				//public $where;
 				//public $message;
+			//application 
+				public $app_name;
+				public $app_uuid;
 
 			public function factory($name) {
 				$this->name = $name;
@@ -246,12 +249,54 @@
 						$message["name"] = $this->name;
 						$message["message"] = "Forbidden";
 						$message["code"] = "403";
+						$message["line"] = __line__;
 						$this->message = $message;
 						$m++;
 					}
 			}
 
+			private function normalize_array($array, $name) {
+				//get the depth of the array
+					$depth = $this->array_depth($array);
+				//before normalizing the array
+					//echo "before: ".$depth."<br />\n";
+					//print_r($array);
+				//normalize the array
+					if ($depth == 1) {
+						$return_array[$name][] = $array;
+					} else if ($depth == 2) {
+						$return_array[$name] = $array;
+					//} else if ($depth == 3) {
+					//	$return_array[$name][] = $array;
+					} else {
+						$return_array = $array;
+					}
+					unset($array);
+				//after normalizing the array
+					//$depth = $this->array_depth($main_array);
+					//echo "after: ".$depth."<br />\n";
+					//print_r($main_array);
+				//return the array
+					return $return_array;
+			}
+
 			public function save($array) {
+
+				//return the array
+					if (!is_array($array)) { echo "not an array"; return false; }
+
+				//set the message id
+					$m = 0;
+
+				//set the app name
+					if (!isset($this->app_name)) {
+						$this->app_name = $this->name;
+					}
+
+				//normalize the array structure
+					$main_array = $this->normalize_array($array, $this->name);
+					unset($array);
+
 				//connect to the database if needed
 					if (!$this->db) {
 						$this->connect();
@@ -261,329 +306,97 @@
 					$this->debug["sql"] = true;
 
 				//start the atomic transaction
-					$this->db->beginTransaction();
+//					$this->db->beginTransaction();
 
-				//set the variables
-					$table_name = "v_".$this->name;
-					$parent_key_name = $this->singular($this->name)."_uuid";
+				//debug info
+					//echo "<pre>\n";
+					//print_r($main_array);
+					//echo "</pre>\n";
+					//exit;
 
-				//if the uuid is set then set parent key exists and value 
-					if (isset($this->uuid)) {
-						$parent_key_exists = true;
-						$parent_key_value = $this->uuid;
-					}
-					else {
-						//determine if the parent_key_exists
-						$parent_key_exists = false;
-						if (isset($array[$parent_key_name])) {
-							$this->uuid = $array[$parent_key_name];
-							$parent_key_value = $this->uuid;
-							$parent_key_exists = true;
-						}
-						else {
-							$parent_key_value = uuid();
-						}
-					}
+				//loop through the array
+					foreach ($main_array as $schema_name => $schema_array) {
+						$this->name = $schema_name;
 
-				//determine action update or delete and get the original data
-					if ($parent_key_exists) {
-						$sql = "SELECT * FROM ".$table_name." ";
-						$sql .= "WHERE ".$parent_key_name." = '".$this->uuid."' ";
-						$prep_statement = $this->db->prepare($sql);
-						if ($prep_statement) {
-							//get the data
-								$prep_statement->execute();
-								$parent_array = $prep_statement->fetch(PDO::FETCH_ASSOC);
-							//set the action
-								if (is_array($parent_array)) {
-									$action = "update";
+						foreach ($schema_array as $schema_key => $array) {
+
+							//set the variables
+								$table_name = "v_".$this->name;
+								$parent_key_name = $this->singular($this->name)."_uuid";
+
+							//if the uuid is set then set parent key exists and value 
+								//determine if the parent_key_exists
+								$parent_key_exists = false;
+								if (isset($array[$parent_key_name])) {
+									$this->uuid = $array[$parent_key_name];
+									$parent_key_value = $this->uuid;
+									$parent_key_exists = true;
+								}
+								else {
+									if (isset($this->uuid)) {
+										$parent_key_exists = true;
+										$parent_key_value = $this->uuid;
+									}
+									else {
+										$parent_key_value = uuid();
+									}
+								}
+
+							//get the parent field names
+								$parent_field_names = array();
+								foreach ($array as $key => $value) {
+									if (!is_array($value)) {
+										$parent_field_names[] = $key;
+									}
+								}
+
+							//determine action update or delete and get the original data
+								if ($parent_key_exists) {
+									$sql = "SELECT ".implode(", ", $parent_field_names)." FROM ".$table_name." ";
+									$sql .= "WHERE ".$parent_key_name." = '".$this->uuid."' ";
+									$prep_statement = $this->db->prepare($sql);
+									if ($prep_statement) {
+										//get the data
+											try {
+												$prep_statement->execute();
+												$parent_array = $prep_statement->fetch(PDO::FETCH_ASSOC);
+											}
+											catch(PDOException $e) {
+												echo 'Caught exception: ',  $e->getMessage(), "<br/><br/>\n";
+												echo $sql;
+												exit;
+											}
+										//set the action
+											if (is_array($parent_array)) {
+												$action = "update";
+											}
+											else {
+												$action = "add";
+											}
+									}
+									unset($prep_statement);
 								}
 								else {
 									$action = "add";
 								}
-						}
-						unset($prep_statement);
-					}
-					else {
-						$action = "add";
-					}
-					//echo "action: ".$action."\n";
+								//echo "action: ".$action."\n";
 
-				//add a record
-					$m = 0;
-					if ($action == "add") {
-						if (permission_exists($this->singular($this->name).'_add')) {
+							//add a record
+								if ($action == "add") {
 
-								$sql = "INSERT INTO v_".$this->name." ";
-								$sql .= "(";
-								if (!$parent_key_exists) {
-									$sql .= $parent_key_name.", ";
-								}
-								foreach ($array as $key => $value) {
-									if (!is_array($value)) {
-										$sql .= check_str($key).", ";
-									}
-								}
-								$sql .= ") ";
-								$sql .= "VALUES ";
-								$sql .= "(";
-								if (!$parent_key_exists) {
-									$sql .= "'".$parent_key_value."', ";
-								}
-								foreach ($array as $key => $value) {
-									if (!is_array($value)) {
-										if (strlen($value) == 0) {
-											$sql .= "null, ";
-										}
-										else {
-											$sql .= "'".check_str($value)."', ";
-										}
-									}
-								}
-								$sql .= ");";
-								$sql = str_replace(", )", ")", $sql);
-								$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
-								try {
-									$this->db->query(check_sql($sql));
-									$message["message"] = "OK";
-									$message["code"] = "200";
-									$message["uuid"] = $parent_key_value;
-									$message["details"][$m]["name"] = $this->name;
-									$message["details"][$m]["message"] = "OK";
-									$message["details"][$m]["code"] = "200";
-									$message["details"][$m]["uuid"] = $parent_key_value;
-									if ($this->debug["sql"]) {
-										$message["details"][$m]["sql"] = $sql;
-									}
-									$this->message = $message;
-									$m++;
-								}
-								catch(PDOException $e) {
-									$message["message"] = "Bad Request";
-									$message["code"] = "400";
-									$message["details"][$m]["name"] = $this->name;
-									$message["details"][$m]["message"] = $e->getMessage();
-									$message["details"][$m]["code"] = "400";
-									if ($this->debug["sql"]) {
-										$message["details"][$m]["sql"] = $sql;
-									}
-									$this->message = $message;
-									$m++;
-								}
-								unset($sql);
-						}
-						else {
-							$message["name"] = $this->name;
-							$message["message"] = "Forbidden";
-							$message["code"] = "403";
-							$this->message = $message;
-							$m++;
-						}
-					}
+									if (permission_exists($this->singular($this->name).'_add')) {
 
-				//edit a specific uuid
-					if ($action == "update") {
-						if (permission_exists($this->singular($this->name).'_edit')) {
-
-							//parent data
-								$sql = "UPDATE v_".$this->name." SET ";
-								foreach ($array as $key => $value) {
-									if (!is_array($value) && $key != $parent_key_name) {
-										if (strlen($value) == 0) {
-											$sql .= check_str($key)." = null, ";
-										}
-										else {
-											$sql .= check_str($key)." = '".check_str($value)."', ";
-										}
-									}
-								}
-								$sql .= "WHERE ".$parent_key_name." = '".$parent_key_value."' ";
-								$sql = str_replace(", WHERE", " WHERE", $sql);
-								$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
-								try {
-									$this->db->query(check_sql($sql));
-									$message["message"] = "OK";
-									$message["code"] = "200";
-									$message["uuid"] = $parent_key_value;
-									$message["details"][$m]["name"] = $this->name;
-									$message["details"][$m]["message"] = "OK";
-									$message["details"][$m]["code"] = "200";
-									$message["details"][$m]["uuid"] = $parent_key_value;
-									if ($this->debug["sql"]) {
-										$message["details"][$m]["sql"] = $sql;
-									}
-									$this->message = $message;
-									$m++;
-									unset($sql);
-								}
-								catch(PDOException $e) {
-									$message["message"] = "Bad Request";
-									$message["code"] = "400";
-									$message["details"][$m]["name"] = $this->name;
-									$message["details"][$m]["message"] = $e->getMessage();
-									$message["details"][$m]["code"] = "400";
-									if ($this->debug["sql"]) {
-										$message["details"][$m]["sql"] = $sql;
-									}
-									$this->message = $message;
-									$m++;
-								}
-						}
-						else {
-							$message["name"] = $this->name;
-							$message["message"] = "Forbidden";
-							$message["code"] = "403";
-							$this->message = $message;
-							$m++;
-						}
-					}
-
-				//unset the variables
-					unset($sql, $action);
-
-				//child data
-					foreach ($array as $key => $value) {
-						if (is_array($value)) {
-								$table_name = "v_".$key;
-								foreach ($value as $row) {
-									//prepare the variables
-										$child_name = $this->singular($key);
-										$child_key_name = $child_name."_uuid";
-
-									//determine if the parent key exists in the child array
-										$parent_key_exists = false;
-										if (!isset($array[$parent_key_name])) {
-											$parent_key_exists = true;
-										}
-
-									//determine if the uuid exists
-										$uuid_exists = false;
-										foreach ($row as $k => $v) {
-											if ($child_key_name == $k) {
-												if (strlen($v) > 0) {
-													$child_key_value = $v;
-													$uuid_exists = true;
-													break;
-												}
-											}
-											else {
-												$uuid_exists = false;
-											}
-										}
-
-									//determine sql update or delete and get the original data
-										if ($uuid_exists) {
-											$sql = "SELECT * FROM ".$table_name." ";
-											$sql .= "WHERE ".$child_key_name." = '".$child_key_value."' ";
-											$prep_statement = $this->db->prepare($sql);
-											if ($prep_statement) {
-												//get the data
-													$prep_statement->execute();
-													$child_array = $prep_statement->fetch(PDO::FETCH_ASSOC);
-												//set the action
-													if (is_array($child_array)) {
-														$action = "update";
-													}
-													else {
-														$action = "add";
-													}
-												//add to the parent array
-													if (is_array($child_array)) {
-														$parent_array[][$child_name] = $child_array;
-													}
-											}
-											unset($prep_statement);
-										}
-										else {
-											$action = "add";
-										}
-
-									//update the data
-										if ($action == "update") {
-											if (permission_exists($child_name.'_edit')) {
-												$sql = "UPDATE ".$table_name." SET ";
-												foreach ($row as $k => $v) {
-													//if (!is_array($v) && $k != $child_key_name) { //original
-													if (!is_array($v) && ($k != $parent_key_name || $k != $child_key_name)) {
-														if (strlen($v) == 0) {
-															$sql .= check_str($k)." = null, ";
-														}
-														else {
-															$sql .= check_str($k)." = '".check_str($v)."', ";
-														}
-													}
-												}
-												$sql .= "WHERE ".$parent_key_name." = '".$this->uuid."' ";
-												$sql .= "AND ".$child_key_name." = '".$child_key_value."' ";
-												$sql = str_replace(", WHERE", " WHERE", $sql);
-												$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
-												try {
-													$this->db->query(check_sql($sql));
-													$message["details"][$m]["name"] = $key;
-													$message["details"][$m]["message"] = "OK";
-													$message["details"][$m]["code"] = "200";
-													$message["details"][$m]["uuid"] = $child_key_value;
-													if ($this->debug["sql"]) {
-														$message["details"][$m]["sql"] = $sql;
-													}
-													$this->message = $message;
-													$m++;
-												}
-												catch(PDOException $e) {
-													if ($message["code"] = "200") {
-														$message["message"] = "Bad Request";
-														$message["code"] = "400";
-													}
-													$message["details"][$m]["name"] = $key;
-													$message["details"][$m]["message"] = $e->getMessage();
-													$message["details"][$m]["code"] = "400";
-													if ($this->debug["sql"]) {
-														$message["details"][$m]["sql"] = $sql;
-													}
-													$this->message = $message;
-													$m++;
-												}
-											}
-											else {
-												$message["name"] = $child_name;
-												$message["message"] = "Forbidden";
-												$message["code"] = "403";
-												$this->message = $message;
-												$m++;
-											}
-										} //action update
-
-								//add the data
-									if ($action == "add") {
-										if (permission_exists($child_name.'_add')) {
-											//determine if child or parent key exists
-											$child_key_name = $this->singular($child_name).'_uuid';
-											$parent_key_exists = false;
-											$child_key_exists = false;
-											foreach ($row as $k => $v) {
-												if ($k == $parent_key_name) {
-													$parent_key_exists = true; 
-												}
-												if ($k == $child_key_name) {
-													$child_key_exists = true;
-													$child_key_value = $v;
-												}
-											}
-											if (!$child_key_value) {
-												$child_key_value = uuid();
-											}
-											//build the insert
-											$sql = "INSERT INTO ".$table_name." ";
+											$sql = "INSERT INTO v_".$this->name." ";
 											$sql .= "(";
 											if (!$parent_key_exists) {
-												$sql .= $this->singular($parent_key_name).", ";
+												$sql .= $parent_key_name.", ";
 											}
-											if (!$child_key_exists) {
-												$sql .= $this->singular($child_key_name).", ";
-											}
-											foreach ($row as $k => $v) {
-												if (!is_array($v)) {
-													$sql .= check_str($k).", ";
+											//foreach ($parent_field_names as $field_name) {
+											//		$sql .= check_str($field_name).", ";
+											//}
+											foreach ($array as $key => $value) {
+												if (!is_array($value)) {
+													$sql .= check_str($key).", ";
 												}
 											}
 											$sql .= ") ";
@@ -592,16 +405,13 @@
 											if (!$parent_key_exists) {
 												$sql .= "'".$parent_key_value."', ";
 											}
-											if (!$child_key_exists) {
-												$sql .= "'".$child_key_value."', ";
-											}
-											foreach ($row as $k => $v) {
-												if (!is_array($v)) {
-													if (strlen($v) == 0) {
+											foreach ($array as $key => $value) {
+												if (!is_array($value)) {
+													if (strlen($value) == 0) {
 														$sql .= "null, ";
 													}
 													else {
-														$sql .= "'".check_str($v)."', ";
+														$sql .= "'".check_str($value)."', ";
 													}
 												}
 											}
@@ -610,10 +420,13 @@
 											$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
 											try {
 												$this->db->query(check_sql($sql));
-												$message["details"][$m]["name"] = $key;
+												$message["message"] = "OK";
+												$message["code"] = "200";
+												$message["uuid"] = $parent_key_value;
+												$message["details"][$m]["name"] = $this->name;
 												$message["details"][$m]["message"] = "OK";
 												$message["details"][$m]["code"] = "200";
-												$message["details"][$m]["uuid"] = $child_key_value;
+												$message["details"][$m]["uuid"] = $parent_key_value;
 												if ($this->debug["sql"]) {
 													$message["details"][$m]["sql"] = $sql;
 												}
@@ -621,11 +434,9 @@
 												$m++;
 											}
 											catch(PDOException $e) {
-												if ($message["code"] = "200") {
-													$message["message"] = "Bad Request";
-													$message["code"] = "400";
-												}
-												$message["details"][$m]["name"] = $key;
+												$message["message"] = "Bad Request";
+												$message["code"] = "400";
+												$message["details"][$m]["name"] = $this->name;
 												$message["details"][$m]["message"] = $e->getMessage();
 												$message["details"][$m]["code"] = "400";
 												if ($this->debug["sql"]) {
@@ -634,63 +445,391 @@
 												$this->message = $message;
 												$m++;
 											}
-										}
-										else {
-											$message["name"] = $child_name;
-											$message["message"] = "Forbidden";
-											$message["code"] = "403";
-											$this->message = $message;
-											$m++;
-										}
+											unset($sql);
+									}
+									else {
+										$message["name"] = $this->name;
+										$message["message"] = "Forbidden";
+										$message["code"] = "403";
+										$message["line"] = __line__;
+										$this->message[] = $message;
+										$m++;
+									}
+								}
 
-									} //action add
+							//edit a specific uuid
+								if ($action == "update") {
+									if (permission_exists($this->singular($this->name).'_edit')) {
 
-								//unset the variables
-									unset($sql, $action, $child_key_name, $child_key_value);
-							} // foreach value
-						} //is array
-					} //foreach array
+										//parent data
+											$sql = "UPDATE v_".$this->name." SET ";
+											foreach ($array as $key => $value) {
+												if (!is_array($value) && $key != $parent_key_name) {
+													if (strlen($value) == 0) {
+														$sql .= check_str($key)." = null, ";
+													}
+													else {
+														$sql .= check_str($key)." = '".check_str($value)."', ";
+													}
+												}
+											}
+											$sql .= "WHERE ".$parent_key_name." = '".$parent_key_value."' ";
+											$sql = str_replace(", WHERE", " WHERE", $sql);
+											$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+											try {
+												$this->db->query(check_sql($sql));
+												$message["message"] = "OK";
+												$message["code"] = "200";
+												$message["uuid"] = $parent_key_value;
+												$message["details"][$m]["name"] = $this->name;
+												$message["details"][$m]["message"] = "OK";
+												$message["details"][$m]["code"] = "200";
+												$message["details"][$m]["uuid"] = $parent_key_value;
+												if ($this->debug["sql"]) {
+													$message["details"][$m]["sql"] = $sql;
+												}
+												$this->message = $message;
+												$m++;
+												unset($sql);
+											}
+											catch(PDOException $e) {
+												$message["message"] = "Bad Request";
+												$message["code"] = "400";
+												$message["details"][$m]["name"] = $this->name;
+												$message["details"][$m]["message"] = $e->getMessage();
+												$message["details"][$m]["code"] = "400";
+												if ($this->debug["sql"]) {
+													$message["details"][$m]["sql"] = $sql;
+												}
+												$this->message = $message;
+												$m++;
+											}
+									}
+									else {
+										$message["name"] = $this->name;
+										$message["message"] = "Forbidden";
+										$message["code"] = "403";
+										$message["line"] = __line__;
+										$this->message = $message;
+										$m++;
+									}
+								}
+
+							//unset the variables
+								unset($sql, $action);
+
+							//child data
+								foreach ($array as $key => $value) {
+
+									if (is_array($value)) {
+											$table_name = "v_".$key;
+											foreach ($value as $row) {
+												//prepare the variables
+													$child_name = $this->singular($key);
+													$child_key_name = $child_name."_uuid";
+			
+												//determine if the parent key exists in the child array
+													$parent_key_exists = false;
+													if (!isset($array[$parent_key_name])) {
+														$parent_key_exists = true;
+													}
+
+												//determine if the uuid exists
+													$uuid_exists = false;
+													foreach ($row as $k => $v) {
+														if ($child_key_name == $k) {
+															if (strlen($v) > 0) {
+																$child_key_value = $v;
+																$uuid_exists = true;
+																break;
+															}
+														}
+														else {
+															$uuid_exists = false;
+														}
+													}
+
+												//get the child field names
+													$child_field_names = array();
+													foreach ($row as $k => $v) {
+														if (!is_array($v)) {
+															$child_field_names[] = $k;
+														}
+													}
+
+												//determine sql update or delete and get the original data
+													if ($uuid_exists) {
+														$sql = "SELECT ". implode(", ", $child_field_names)." FROM ".$table_name." ";
+														$sql .= "WHERE ".$child_key_name." = '".$child_key_value."' ";
+														$prep_statement = $this->db->prepare($sql);
+														if ($prep_statement) {
+															//get the data
+																$prep_statement->execute();
+																$child_array = $prep_statement->fetch(PDO::FETCH_ASSOC);
+															//set the action
+																if (is_array($child_array)) {
+																	$action = "update";
+																}
+																else {
+																	$action = "add";
+																}
+															//add to the parent array
+																if (is_array($child_array)) {
+																	$parent_array[$key][] = $child_array;
+																}
+														}
+														unset($prep_statement);
+													}
+													else {
+														$action = "add";
+													}
+
+												//update the data
+													if ($action == "update") {
+														if (permission_exists($child_name.'_edit')) {
+															$sql = "UPDATE ".$table_name." SET ";
+															foreach ($row as $k => $v) {
+																//if (!is_array($v) && $k != $child_key_name) { //original
+																if (!is_array($v) && ($k != $parent_key_name || $k != $child_key_name)) {
+																	if (strlen($v) == 0) {
+																		$sql .= check_str($k)." = null, ";
+																	}
+																	else {
+																		$sql .= check_str($k)." = '".check_str($v)."', ";
+																	}
+																}
+															}
+															$sql .= "WHERE ".$parent_key_name." = '".$this->uuid."' ";
+															$sql .= "AND ".$child_key_name." = '".$child_key_value."' ";
+															$sql = str_replace(", WHERE", " WHERE", $sql);
+															$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+															try {
+																$this->db->query(check_sql($sql));
+																$message["details"][$m]["name"] = $key;
+																$message["details"][$m]["message"] = "OK";
+																$message["details"][$m]["code"] = "200";
+																$message["details"][$m]["uuid"] = $child_key_value;
+																if ($this->debug["sql"]) {
+																	$message["details"][$m]["sql"] = $sql;
+																}
+																$this->message = $message;
+																$m++;
+															}
+															catch(PDOException $e) {
+																if ($message["code"] = "200") {
+																	$message["message"] = "Bad Request";
+																	$message["code"] = "400";
+																}
+																$message["details"][$m]["name"] = $key;
+																$message["details"][$m]["message"] = $e->getMessage();
+																$message["details"][$m]["code"] = "400";
+																if ($this->debug["sql"]) {
+																	$message["details"][$m]["sql"] = $sql;
+																}
+																$this->message = $message;
+																$m++;
+															}
+														}
+														else {
+															$message["name"] = $child_name;
+															$message["message"] = "Forbidden";
+															$message["code"] = "403";
+															$message["line"] = __line__;
+															$this->message = $message;
+															$m++;
+														}
+													} //action update
+
+											//add the data
+												if ($action == "add") {
+													if (permission_exists($child_name.'_add')) {
+														//determine if child or parent key exists
+														$child_key_name = $this->singular($child_name).'_uuid';
+														$parent_key_exists = false;
+														$child_key_exists = false;
+														foreach ($row as $k => $v) {
+															if ($k == $parent_key_name) {
+																$parent_key_exists = true; 
+															}
+															if ($k == $child_key_name) {
+																$child_key_exists = true;
+																$child_key_value = $v;
+															}
+														}
+														if (!$child_key_value) {
+															$child_key_value = uuid();
+														}
+														//build the insert
+														$sql = "INSERT INTO ".$table_name." ";
+														$sql .= "(";
+														if (!$parent_key_exists) {
+															$sql .= $this->singular($parent_key_name).", ";
+														}
+														if (!$child_key_exists) {
+															$sql .= $this->singular($child_key_name).", ";
+														}
+														foreach ($row as $k => $v) {
+															if (!is_array($v)) {
+																$sql .= check_str($k).", ";
+															}
+														}
+														$sql .= ") ";
+														$sql .= "VALUES ";
+														$sql .= "(";
+														if (!$parent_key_exists) {
+															$sql .= "'".$parent_key_value."', ";
+														}
+														if (!$child_key_exists) {
+															$sql .= "'".$child_key_value."', ";
+														}
+														foreach ($row as $k => $v) {
+															if (!is_array($v)) {
+																if (strlen($v) == 0) {
+																	$sql .= "null, ";
+																}
+																else {
+																	$sql .= "'".check_str($v)."', ";
+																}
+															}
+														}
+														$sql .= ");";
+														$sql = str_replace(", )", ")", $sql);
+														$this->db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+														try {
+															$this->db->query(check_sql($sql));
+															$message["details"][$m]["name"] = $key;
+															$message["details"][$m]["message"] = "OK";
+															$message["details"][$m]["code"] = "200";
+															$message["details"][$m]["uuid"] = $child_key_value;
+															if ($this->debug["sql"]) {
+																$message["details"][$m]["sql"] = $sql;
+															}
+															$this->message = $message;
+															$m++;
+														}
+														catch(PDOException $e) {
+															if ($message["code"] = "200") {
+																$message["message"] = "Bad Request";
+																$message["code"] = "400";
+															}
+															$message["details"][$m]["name"] = $key;
+															$message["details"][$m]["message"] = $e->getMessage();
+															$message["details"][$m]["code"] = "400";
+															if ($this->debug["sql"]) {
+																$message["details"][$m]["sql"] = $sql;
+															}
+															$this->message = $message;
+															$m++;
+														}
+													}
+													else {
+														$message["name"] = $child_name;
+														$message["message"] = "Forbidden";
+														$message["code"] = "403";
+														$message["line"] = __line__;
+														$this->message = $message;
+														$m++;
+													}
+												} //action add
+
+											//unset the variables
+												unset($sql, $action, $child_key_name, $child_key_value);
+										} // foreach value
+
+									} //is array
+								} //foreach array
+
+						} // foreach schema_array
+					}  // foreach main array
 
 				//return the before and after data
 					//log this in the future
-					//if (is_array($parent_array)) {
-					//	$message["old"] = $parent_array;
-					//}
-					//$message["new"] = $array;
-					//$this->message = $message;
+					if (is_array($parent_array)) {
+						//normalize the array structure
+						$parent_array = $this->normalize_array($parent_array, $this->name);
+						//$message["old"] = $parent_array;
+						//$message["old"]["array"] = $parent_array;
+						//$message["old"]["md5"] = md5(json_encode($parent_array));
+					}
+					//$message["new"] = $main_array;
+					//$message["new"]["md5"] = md5(json_encode($main_array));
+					$this->message = $message;
 
 				//commit the atomic transaction
-					$this->db->commit();
+//					$this->db->commit();
 
+				//get the domain uuid
+					$domain_uuid = $_SESSION['domain_uuid'];
+
+				//log the transaction results
+/*
+					$sql = "insert into v_database_transactions ";
+					$sql .= "(";
+					$sql .= "database_transaction_uuid, ";
+					$sql .= "domain_uuid, ";
+					$sql .= "user_uuid, ";
+					if (isset($this->app_uuid)) {
+						$sql .= "app_uuid, ";
+					}
+					$sql .= "app_name, ";
+					$sql .= "transaction_code, ";
+					$sql .= "transaction_address, ";
+					//$sql .= "transaction_type, ";
+					$sql .= "transaction_date, ";
+					$sql .= "transaction_before, ";
+					$sql .= "transaction_after, ";
+					$sql .= "transaction_result ";
+					$sql .= ")";
+					$sql .= "values ";
+					$sql .= "(";
+					$sql .= "'".uuid()."', ";
+					$sql .= "'".$domain_uuid."', ";
+					$sql .= "'".$_SESSION['user_uuid']."', ";
+					if (isset($this->app_uuid)) {
+						$sql .= "'".$this->app_uuid."', ";
+					}
+					
+					$sql .= "'".$this->app_name."', ";
+					$sql .= "'".$message["code"]."', ";
+					$sql .= "'".$_SERVER['REMOTE_ADDR']."', ";
+					//$sql .= "'$transaction_type', ";
+					$sql .= "now(), ";
+					$sql .= "'".json_encode($parent_array, JSON_PRETTY_PRINT)."', ";
+					$sql .= "'".json_encode($main_array, JSON_PRETTY_PRINT)."', ";
+					$sql .= "'".check_str(json_encode($this->message, JSON_PRETTY_PRINT))."' ";
+					$sql .= ")";
+					$this->db->exec(check_sql($sql));
+					unset($sql);
+*/
 			} //save method
 
 			//define singular function to convert a word in english to singular
-				private function singular($word) {
-					//"-es" is used for words that end in "-x", "-s", "-z", "-sh", "-ch" in which case you add
-					if (substr($word, -2) == "es") {
-						if (substr($word, -3, 1) == "x") {
-							return substr($word,0,-2);
-						}
-						if (substr($word, -3, 1) == "s") {
-							return substr($word,0,-2);
-						}
-						elseif (substr($word, -3, 1) == "z") {
-							return substr($word,0,-2);
-						}
-						elseif (substr($word, -4, 2) == "sh") {
-							return substr($word,0,-2);
-						}
-						elseif (substr($word, -4, 2) == "ch") {
-							return substr($word,0,-2);
-						}
-						else {
-							return rtrim($word, "s");
-						}
+			private function singular($word) {
+				//"-es" is used for words that end in "-x", "-s", "-z", "-sh", "-ch" in which case you add
+				if (substr($word, -2) == "es") {
+					if (substr($word, -3, 1) == "x") {
+						return substr($word,0,-2);
+					}
+					if (substr($word, -3, 1) == "s") {
+						return substr($word,0,-2);
+					}
+					elseif (substr($word, -3, 1) == "z") {
+						return substr($word,0,-2);
+					}
+					elseif (substr($word, -4, 2) == "sh") {
+						return substr($word,0,-2);
+					}
+					elseif (substr($word, -4, 2) == "ch") {
+						return substr($word,0,-2);
 					}
 					else {
 						return rtrim($word, "s");
 					}
 				}
+				else {
+					return rtrim($word, "s");
+				}
+			}
 
 			public function get_apps() {
 				//get the $apps array from the installed apps from the core and mod directories
@@ -703,6 +842,21 @@
 					$_SESSION['apps'] = $apps;
 			}
 
+			public function array_depth($array) {
+				if (is_array($array)) {
+					foreach ($array as $value) {
+						if (!isset($depth)) { $depth = 1; }
+						if (is_array($value)) {
+							$depth = $this->array_depth($value) + 1;
+						}
+					}
+				}
+				else {
+					$depth = 0;
+				}
+				return $depth;
+			}
+
 			public function domain_uuid_exists($name) {
 				//get the $apps array from the installed apps from the core and mod directories
 					if (!is_array($_SESSION['apps'])) {
@@ -724,7 +878,7 @@
 					return false;
 			}
 		}
-	}
+	}ƒ
 
 	//examples
 		/*