added a message via db commit path

[gwvp-mini.git] / gwvpmini / gwvpmini_db.php

diff --git a/gwvpmini/gwvpmini_db.php b/gwvpmini/gwvpmini_db.php
index 88c7ee2..fc6babc 100644 (file)
--- a/gwvpmini/gwvpmini_db.php
+++ b/gwvpmini/gwvpmini_db.php
@@ -546,7 +546,16 @@ function gwvpmini_dbCreateSQLiteStructure($dbloc)
        "repos_status" TEXT,
        "repos_origin" TEXT,
        UNIQUE(repos_name)\r
-       )';\r
+       )';
+       
+       $msgsql = '
+       CREATE TABLE "messages" (
+       "msgs_id" INTEGER PRIMARY KEY AUTOINCREMENT,
+       "msgs_type" TEXT,
+       "msgs_data" TEXT,
+       "msgs_to_id" TEXT
+       )';
+       \r
 \r
        // this looks like null, <repoid>, <read|visible|write>, user:<uid>|group:<gid>|authed|anon\r
        // where authed = any authenticated user, anon = everyone (logged in, not logged in, etc)\r
@@ -591,7 +600,8 @@ function gwvpmini_dbCreateSQLiteStructure($dbloc)
        $DB_CONNECTION->query($initialuser_user);
        $DB_CONNECTION->query($reposql);\r
        $DB_CONNECTION->query($configsql);
-       $DB_CONNECTION->query($activitysql);\r
+       $DB_CONNECTION->query($activitysql);
+       $DB_CONNECTION->query($msgsql);\r
 }
 
 function gwvpmini_getConfigVal($confname)\r
@@ -695,6 +705,59 @@ function gwvpmini_GetRepoDescFromName($reponame)
 \r
        return $retval;\r
 }
+
+function gwvpmini_SendMessageByDb($type, $data, $forid)
+{
+       $conn = gwvpmini_ConnectDB();
+       
+       $sql = "insert into messages values (null, '$type', '$data', '$forid')";
+       
+       return $conn->query($sql);
+}
+
+function gwvpmini_GetMessagesForId($uid)
+{
+       /*
+        *      $msgsql = '
+       CREATE TABLE "messages" (
+       "msgs_id" INTEGER PRIMARY KEY AUTOINCREMENT,
+       "msgs_type" TEXT,
+       "msgs_data" TEXT,
+       "msgs_to_id" TEXT,
+       )';
+
+        */
+       $conn = gwvpmini_ConnectDB();\r
+       \r
+       $sql = "select * from messages where msgs_to_id='$uid'";\r
+       // error_log("desc for name sql: $sql");\r
+       \r
+       $res = $conn->query($sql);
+       
+       error_log("request message for uid, $uid with sql $sql");\r
+       
+       $i = 0;\r
+       if(!$res) return 0;\r
+       foreach($res as $row) {
+               $retval[$i]["id"] = $row["msgs_id"];
+               $retval[$i]["type"] = $row["msgs_type"];
+               $retval[$i]["data"] = $row["msgs_data"];
+               $i++;\r
+       }
+       
+       \r
+       return $retval;\r
+       
+}
+
+function gwvpmini_DeleteMessagesById($mid)
+{
+       $conn = gwvpmini_ConnectDB();\r
+       \r
+       $sql = "delete from messages where msgs_id='$mid'";
+       
+       return $conn->query($sql);
+}
 \r
 function gwvpmini_GetRepoOwnerDetailsFromName($reponame)\r
 {\r
@@ -848,7 +911,7 @@ function gwvpmini_GetOwnedRepos($username)
                // error_log(print_r($row, true));
        }
        
-       // error_log(print_r($retval, true));\r
+       error_log(print_r($retval, true));\r
        return $retval;\r
 }