"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
$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
\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;
+ foreach($res as $row) {
+ $retval[$i]["id"] = $row["msgs_id"];
+ $retval[$i]["type"] = $row["msgs_type"];
+ $retval[$i]["data"] = $row["msgs_data"];
+ $i++;\r
+ }
+
+ if($i == 0) return 0;
+ else 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
// error_log(print_r($row, true));
}
- // error_log(print_r($retval, true));\r
+ error_log(print_r($retval, true));\r
return $retval;\r
}