gwvpmini/gwvpmini_db.php

   1 <?php
   2
   3
   4 global $DB_CONNECTION;\r
   5 $DB_CONNECTION = false;\r
   6 \r
   7 \r
   8 global $db_url, $db_type;\r
   9 error_log("in include for database, $db_type, $db_name");
  10
  11
  12 function gwvpmini_DBExists()
  13 {
  14         global $WEB_ROOT_FS, $BASE_URL, $data_directory, $db_type, $db_name;
  15
  16         // oh this isnt working. poo.
  17         error_log("checking for $db_name, $db_type");
  18
  19         if($db_type == "sqlite") {
  20                 if(file_exists($db_name)) {
  21                         error_log("Exists");
  22                         return true;
  23                 }
  24                 else {
  25                         error_log("no exists");
  26                         return false;
  27                 }
  28         }
  29 }\r
  30
  31 function gwvpmini_getUser($username=null, $email=null, $id=null)\r
  32 {\r
  33         $conn = gwvpmini_ConnectDB();\r
  34 \r
  35         if($username != null) {\r
  36                 $res = $conn->query("select * from users where user_username='$username'");\r
  37         } else if($email != null) {\r
  38                 $res = $conn->query("select * from users where user_email='$email'");\r
  39         } else if($id != null) {\r
  40                 $res = $conn->query("select * from users where users_id='$id'");\r
  41         } else return false;\r
  42 \r
  43         $returns = false;\r
  44         foreach($res as $u_res) {\r
  45                 $returns["id"] = $u_res["user_id"];\r
  46                 $returns["fullname"] = $u_res["user_full_name"];\r
  47                 $returns["password"] = $u_res["user_password"];\r
  48                 $returns["username"] = $u_res["user_username"];\r
  49                 $returns["email"] = $u_res["user_email"];\r
  50                 $returns["desc"] = $u_res["user_desc"];\r
  51                 $returns["status"] = $u_res["user_status"];\r
  52         }\r
  53 \r
  54         return $returns;\r
  55 \r
  56 }\r
  57
  58 function gwvpmini_ConnectDB()\r
  59 {\r
  60         global $WEB_ROOT_FS, $BASE_URL, $data_directory, $db_type, $db_name, $DB_CONNECTION;\r
  61 \r
  62         // first check if $DB_CONNECTION IS live\r
  63         error_log("in connection $db_type, $db_name");\r
  64 \r
  65         if($DB_CONNECTION != false) return $DB_CONNECTION;\r
  66 \r
  67         if($db_type == "sqlite") {\r
  68                 $db_url = $db_name;\r
  69                 if(!file_exists($db_name)) {\r
  70                         error_log("$db_name does not exist - problem");
  71                         // TODO: NEED A SETUP AGENT!
  72                         gwvpmini_dbCreateSQLiteStructure($db_name);
  73                         gwvpmini_setConfigVal("repodir", "$data_directory/repos");\r
  74                 }\r
  75         }\r
  76 \r
  77         // and here we go with pdo.\r
  78         error_log("attmpting to open db, $db_type:$db_url");\r
  79         try {\r
  80                 $DB_CONNECTION = new PDO("$db_type:$db_url");\r
  81         } catch(PDOException $exep) {\r
  82                 error_log("execpt on db open");\r
  83                 return false;\r
  84         }\r
  85 \r
  86         return $DB_CONNECTION;\r
  87 }
  88
  89 function gwvpmini_AddUser($username, $password, $fullname, $email, $desc, $level, $status)
  90 {
  91         \r
  92
  93         \r
  94         $conn = gwvpmini_ConnectDB();\r
  95         \r
  96         $sql = "insert into 'users' values ( null, '$fullname', '".sha1($password)."', '$username', '$email', '$desc', '$level', '$status')";\r
  97         \r
  98         $res = $conn->query($sql);
  99         if(!$res) return -1;
 100
 101         $sql = "select user_id from users where user_username='$username'";\r
 102         $res = $conn->query($sql);\r
 103         if(!$res) return -1;\r
 104
 105         $retval = -1;
 106         foreach($res as $row) {
 107                 $retval = $row[0];
 108         }
 109
 110         return $retval;
 111 }\r
 112
 113
 114 function gwvpmini_dbCreateSQLiteStructure($dbloc)\r
 115 {\r
 116         $usersql = '\r
 117         CREATE TABLE "users" (\r
 118         "user_id" INTEGER PRIMARY KEY AUTOINCREMENT,\r
 119         "user_full_name" TEXT,\r
 120         "user_password" TEXT,\r
 121         "user_username" TEXT,\r
 122         "user_email" TEXT,\r
 123         "user_desc" TEXT,
 124         "user_level" TEXT,\r
 125         "user_status" TEXT,
 126         UNIQUE(user_username)\r
 127         )';\r
 128 \r
 129         $initialuser_admin = '
 130         insert into "users" values ( null, "Administrator", "'.sha1("password").'", "admin", "admin@localhost", "the admin", "1", "0");\r
 131         ';\r
 132
 133         $initialuser_user = '\r
 134         insert into "users" values ( null, "User", "'.sha1("password").'", "user", "user@localhost", "the user", "0", "0");\r
 135         ';\r
 136         \r
 137         $reposql = '\r
 138         CREATE TABLE "repos" (\r
 139         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,\r
 140         "repos_name" TEXT,\r
 141         "repos_description" TEXT,\r
 142         "repos_owner" INTEGER,
 143         "repos_readperms" TEXT,
 144         UNIQUE(repos_name)\r
 145         )';\r
 146 \r
 147         // this looks like null, <repoid>, <read|visible|write>, user:<uid>|group:<gid>|authed|anon\r
 148         // where authed = any authenticated user, anon = everyone (logged in, not logged in, etc)\r
 149         // read|visible|write = can clone from repo|can see repo exists and see description but not clone from it|can push to repo\r
 150         // TODO: is this sufficient? i have to think about it\r
 151 \r
 152         $configsql = '\r
 153         CREATE TABLE "config" (\r
 154         "config_name" TEXT,\r
 155         "config_value" TEXT\r
 156         )';\r
 157 \r
 158         try {\r
 159                 $DB_CONNECTION = new PDO("sqlite:$dbloc");\r
 160         } catch(PDOException $exep) {\r
 161                 error_log("execpt on db open");\r
 162                 return false;\r
 163         }\r
 164
 165         $DB_CONNECTION->query($usersql);\r
 166         $DB_CONNECTION->query($initialuser_admin);
 167         $DB_CONNECTION->query($initialuser_user);
 168         $DB_CONNECTION->query($reposql);\r
 169         $DB_CONNECTION->query($configsql);\r
 170 }
 171
 172 function gwvpmini_getConfigVal($confname)\r
 173 {\r
 174         /*\r
 175          *      $configsql = '\r
 176         CREATE TABLE "config" (\r
 177                         "config_name" TEXT,\r
 178                         "config_value" TEXT\r
 179         )';\r
 180 \r
 181         */\r
 182 \r
 183         $conn = gwvpmini_ConnectDB();\r
 184 \r
 185         $sql = "select config_value from config where config_name='$confname'";\r
 186 \r
 187         $res = $conn->query($sql);\r
 188 \r
 189         $return = null;\r
 190         foreach($res as $val) {\r
 191                 $return = $val["config_value"];\r
 192         }\r
 193 \r
 194         return $return;\r
 195 }\r
 196 \r
 197 function gwvpmini_eraseConfigVal($confname)\r
 198 {\r
 199         /*\r
 200          *      $configsql = '\r
 201         CREATE TABLE "config" (\r
 202                         "config_name" TEXT,\r
 203                         "config_value" TEXT\r
 204         )';\r
 205 \r
 206         */\r
 207 \r
 208         $conn = gwvpmini_ConnectDB();\r
 209 \r
 210         $sql = "delete from config where config_name='$confname'";\r
 211 \r
 212         return $conn->query($sql);\r
 213 }
 214
 215 function gwvpmini_GetRepoId($reponame)
 216 {
 217
 218         /*
 219          *      $reposql = '
 220         CREATE TABLE "repos" (
 221         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 222         "repos_name" TEXT,
 223         "repos_description" TEXT,
 224         "repos_owner" INTEGER
 225         )';
 226
 227          */
 228
 229         $conn = gwvpmini_ConnectDB();
 230
 231         $sql = "select repos_id from repos where repos_name='$reponame'";
 232
 233         $res = $conn->query($sql);
 234
 235         $retval = -1;
 236         if(!$res) return -1;
 237         foreach($res as $row) {
 238                 $reval = (int)$row[0];
 239         }
 240
 241         return $retval;
 242 }
 243 \r
 244 \r
 245 function gwvpmini_setConfigVal($confname, $confval)\r
 246 {\r
 247         /*\r
 248          *      $configsql = '\r
 249         CREATE TABLE "config" (\r
 250                         "config_name" TEXT,\r
 251                         "config_value" TEXT\r
 252         )';\r
 253 \r
 254         */\r
 255         gwvpmini_eraseConfigVal($confname);\r
 256 \r
 257         $conn = gwvpmini_ConnectDB();\r
 258 \r
 259         $sql = "insert into config values('$confname', '$confval')";\r
 260 \r
 261         return $conn->query($sql);\r
 262 }
 263
 264 function gwvpmini_AddRepo($name, $desc, $ownerid, $perms = "perms-public")
 265 {
 266
 267         error_log("addrepo in db for $name, $desc, $ownerid");
 268         $conn = gwvpmini_ConnectDB();\r
 269         \r
 270         $sql = "insert into repos values (null, '$name', '$desc', '$ownerid', '$perms')";\r
 271         \r
 272         $conn->query($sql);\r
 273 }
 274
 275 function gwvpmini_GetUserId($username)
 276 {
 277         $conn = gwvpmini_ConnectDB();\r
 278
 279         $sql = "select user_id from users where user_username='$username'";
 280
 281         error_log("userid sql $sql");\r
 282
 283         $res = $conn->query($sql);
 284
 285         $retval = false;
 286         foreach($res as $row) {
 287                 $retval = $row[0];
 288         }
 289
 290         return $retval;
 291 }
 292
 293 function gwvpmini_GetOwnedRepos($username)\r
 294 {
 295         /*
 296          *      CREATE TABLE "repos" (
 297         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 298         "repos_name" TEXT,
 299         "repos_description" TEXT,
 300         "repos_owner" INTEGER
 301         )';
 302
 303          */
 304         $conn = gwvpmini_ConnectDB();
 305
 306         $uid = gwvpmini_GetUserId($username);
 307         $sql = "select * from repos where repos_owner='$uid'";
 308         error_log("owned repos sql $sql");
 309         $res = $conn->query($sql);
 310
 311         $retval = false;
 312         foreach($res as $row) {
 313                 $id = $row["repos_id"];
 314                 $retval[$id]["name"] = $row["repos_name"];
 315                 $retval[$id]["desc"] = $row["repos_description"];
 316                 error_log(print_r($row, true));
 317         }
 318
 319         error_log(print_r($retval, true));\r
 320         return $retval;\r
 321 }
 322
 323 function gwvpmini_userLevel($id)
 324 {
 325         $conn = gwvpmini_ConnectDB();
 326
 327         $sql = "select user_level from users where user_id='$id'";
 328
 329         $res = $conn->query($sql);
 330
 331         $lev = -1;
 332         if(!$res) return -1;
 333         foreach($res as $row) {
 334                 $lev = (int)$row[0];
 335         }
 336
 337         return $lev;
 338 }
 339
 340 function gwvpmini_GetUsers($startat = 0, $num = 10)
 341 {
 342         $conn = gwvpmini_ConnectDB();
 343
 344         /*
 345          *      CREATE TABLE "users" (
 346         "user_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 347         "user_full_name" TEXT,
 348         "user_password" TEXT,
 349         "user_username" TEXT,
 350         "user_email" TEXT,
 351         "user_desc" TEXT,
 352         "user_level" TEXT,
 353         "user_status" TEXT
 354
 355          */\r
 356         \r
 357         $sql = "select * from users where user_id>'$startat' order by user_id asc limit $num";
 358
 359         $res = $conn->query($sql);
 360
 361         $retval = false;
 362         foreach($res as $row) {
 363                 $id = $row["user_id"];
 364                 $retval[$id]["fullname"] = $row["user_full_name"];
 365                 $retval[$id]["username"] = $row["user_username"];
 366                 $retval[$id]["email"] = $row["user_email"];
 367                 $retval[$id]["desc"] = $row["user_desc"];
 368                 $retval[$id]["level"] = $row["user_level"];
 369                 $retval[$id]["status"] = $row["user_status"];
 370         }
 371
 372         return $retval;
 373 }\r
 374
 375 function gwvpmini_GetRepos($startat=0, $num=200)\r
 376 {\r
 377         $conn = gwvpmini_ConnectDB();\r
 378         \r
 379         /*\r
 380          *      CREATE TABLE "repos" (
 381         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 382         "repos_name" TEXT,
 383         "repos_description" TEXT,
 384         "repos_owner" INTEGER
 385         )';
 386         \r
 387                         */\r
 388         \r
 389         $sql = "select * from repos where repos_id > '$startat' order by repos_id asc limit $num";\r
 390         \r
 391         $res = $conn->query($sql);\r
 392         \r
 393         $retval = false;\r
 394         foreach($res as $row) {\r
 395                 $id = $row["repos_id"];\r
 396                 $retval[$id]["name"] = $row["repos_name"];\r
 397                 $retval[$id]["desc"] = $row["repos_description"];\r
 398                 $retval[$id]["owner"] = $row["repos_owner"];\r
 399         }\r
 400         \r
 401         return $retval;\r
 402         \r
 403         \r
 404 }\r
 405
 406 function gwvpmini_GetNRepos()
 407 {
 408         $conn = gwvpmini_ConnectDB();
 409
 410         $sql = "select count(*) from repos";
 411
 412         $res = $conn->query($sql);
 413
 414         $retval = -1;
 415         foreach($res as $row) {
 416                 $retval = $row[0];
 417         }
 418
 419         return $retval;
 420 }
 421
 422 \r
 423 function gwvpmini_GetNUsers()\r
 424 {\r
 425         $conn = gwvpmini_ConnectDB();\r
 426 \r
 427         $sql = "select count(*) from users";\r
 428 \r
 429         $res = $conn->query($sql);\r
 430 \r
 431         $retval = -1;\r
 432         foreach($res as $row) {\r
 433                 $retval = $row[0];\r
 434         }\r
 435 \r
 436         return $retval;\r
 437 }\r
 438
 439
 440 ?>