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."
\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."
\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 "\n";
+ //print_r($main_array);
+ //echo "
\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(), "
\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
/*