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 function gwvpmini_GetRepoOwnerDetailsFromName($reponame)\r
 245 {\r
 246 \r
 247         /*\r
 248          *      $reposql = '\r
 249         CREATE TABLE "repos" (\r
 250                         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,\r
 251                         "repos_name" TEXT,\r
 252                         "repos_description" TEXT,\r
 253                         "repos_owner" INTEGER\r
 254         )';
 255
 256                 "user_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 257         "user_full_name" TEXT,
 258         "user_password" TEXT,
 259         "user_username" TEXT,
 260         "user_email" TEXT,
 261         "user_desc" TEXT,
 262         "user_level" TEXT,
 263         "user_status" TEXT,
 264         UNIQUE(user_username)\r
 265 \r
 266         */\r
 267 \r
 268         $conn = gwvpmini_ConnectDB();\r
 269 \r
 270         $sql = "select users.* from repos,users where repos_name='$reponame' and repos_owner=user_id";\r
 271 \r
 272         $res = $conn->query($sql);\r
 273 \r
 274         $retval = -1;\r
 275         if(!$res) return -1;\r
 276         foreach($res as $row) {
 277                 $retval = array();
 278                 error_log("STUFF2: ".print_r($row,true));\r
 279                 $retval["id"] = $row["user_id"];
 280                 $retval["fullname"] = $row["user_full_name"];
 281                 $retval["username"] = $row["user_username"];
 282                 $retval["email"] = $row["user_email"];
 283                 $retval["desc"] = $row["user_desc"];
 284                 $retval["level"] = $row["user_level"];
 285                 $retval["status"] = $row["user_status"];\r
 286         }\r
 287 \r
 288         return $retval;\r
 289 }\r
 290 \r
 291 function gwvpmini_setConfigVal($confname, $confval)\r
 292 {\r
 293         /*\r
 294          *      $configsql = '\r
 295         CREATE TABLE "config" (\r
 296                         "config_name" TEXT,\r
 297                         "config_value" TEXT\r
 298         )';\r
 299 \r
 300         */\r
 301         gwvpmini_eraseConfigVal($confname);\r
 302 \r
 303         $conn = gwvpmini_ConnectDB();\r
 304 \r
 305         $sql = "insert into config values('$confname', '$confval')";\r
 306 \r
 307         return $conn->query($sql);\r
 308 }
 309
 310 function gwvpmini_AddRepo($name, $desc, $ownerid, $perms = "perms-public")
 311 {
 312
 313         error_log("addrepo in db for $name, $desc, $ownerid");
 314         $conn = gwvpmini_ConnectDB();\r
 315         \r
 316         $sql = "insert into repos values (null, '$name', '$desc', '$ownerid', '$perms')";\r
 317         \r
 318         $conn->query($sql);\r
 319 }
 320
 321 function gwvpmini_GetUserId($username)
 322 {
 323         $conn = gwvpmini_ConnectDB();\r
 324
 325         $sql = "select user_id from users where user_username='$username'";
 326
 327         error_log("userid sql $sql");\r
 328
 329         $res = $conn->query($sql);
 330
 331         $retval = false;
 332         foreach($res as $row) {
 333                 $retval = $row[0];
 334         }
 335
 336         return $retval;
 337 }
 338
 339 function gwvpmini_GetUserNameFromEmail($email)\r
 340 {\r
 341         $conn = gwvpmini_ConnectDB();\r
 342 \r
 343         $sql = "select user_username from users where user_email='$email'";\r
 344 \r
 345         error_log("username sql $sql");\r
 346 \r
 347         $res = $conn->query($sql);\r
 348 \r
 349         $retval = false;\r
 350         foreach($res as $row) {\r
 351                 $retval = $row[0];\r
 352         }\r
 353 \r
 354         return $retval;\r
 355 }
 356 function gwvpmini_GetOwnedRepos($username)\r
 357 {
 358         /*
 359          *      CREATE TABLE "repos" (
 360         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 361         "repos_name" TEXT,
 362         "repos_description" TEXT,
 363         "repos_owner" INTEGER
 364         )';
 365
 366          */
 367         $conn = gwvpmini_ConnectDB();
 368
 369         $uid = gwvpmini_GetUserId($username);
 370         $sql = "select * from repos where repos_owner='$uid'";
 371         error_log("owned repos sql $sql");
 372         $res = $conn->query($sql);
 373
 374         $retval = false;
 375         foreach($res as $row) {
 376                 $id = $row["repos_id"];
 377                 $retval[$id]["name"] = $row["repos_name"];
 378                 $retval[$id]["desc"] = $row["repos_description"];
 379                 error_log(print_r($row, true));
 380         }
 381
 382         error_log(print_r($retval, true));\r
 383         return $retval;\r
 384 }
 385
 386 function gwvpmini_userLevel($id)
 387 {
 388         $conn = gwvpmini_ConnectDB();
 389
 390         $sql = "select user_level from users where user_id='$id'";
 391
 392         $res = $conn->query($sql);
 393
 394         $lev = -1;
 395         if(!$res) return -1;
 396         foreach($res as $row) {
 397                 $lev = (int)$row[0];
 398         }
 399
 400         return $lev;
 401 }
 402
 403 function gwvpmini_GetUsers($startat = 0, $num = 10)
 404 {
 405         $conn = gwvpmini_ConnectDB();
 406
 407         /*
 408          *      CREATE TABLE "users" (
 409         "user_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 410         "user_full_name" TEXT,
 411         "user_password" TEXT,
 412         "user_username" TEXT,
 413         "user_email" TEXT,
 414         "user_desc" TEXT,
 415         "user_level" TEXT,
 416         "user_status" TEXT
 417
 418          */\r
 419         \r
 420         $sql = "select * from users where user_id>'$startat' order by user_id asc limit $num";
 421
 422         $res = $conn->query($sql);
 423
 424         $retval = false;
 425         foreach($res as $row) {
 426                 $id = $row["user_id"];
 427                 $retval[$id]["fullname"] = $row["user_full_name"];
 428                 $retval[$id]["username"] = $row["user_username"];
 429                 $retval[$id]["email"] = $row["user_email"];
 430                 $retval[$id]["desc"] = $row["user_desc"];
 431                 $retval[$id]["level"] = $row["user_level"];
 432                 $retval[$id]["status"] = $row["user_status"];
 433         }
 434
 435         return $retval;
 436 }\r
 437
 438 function gwvpmini_GetRepos($startat=0, $num=200)\r
 439 {\r
 440         $conn = gwvpmini_ConnectDB();\r
 441         \r
 442         /*\r
 443          *      CREATE TABLE "repos" (
 444         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 445         "repos_name" TEXT,
 446         "repos_description" TEXT,
 447         "repos_owner" INTEGER
 448         )';
 449         \r
 450                         */\r
 451         \r
 452         $sql = "select * from repos where repos_id > '$startat' order by repos_id asc limit $num";\r
 453         \r
 454         $res = $conn->query($sql);\r
 455         \r
 456         $retval = false;\r
 457         foreach($res as $row) {\r
 458                 $id = $row["repos_id"];\r
 459                 $retval[$id]["name"] = $row["repos_name"];\r
 460                 $retval[$id]["desc"] = $row["repos_description"];\r
 461                 $retval[$id]["owner"] = $row["repos_owner"];\r
 462         }\r
 463         \r
 464         return $retval;\r
 465         \r
 466         \r
 467 }\r
 468
 469 function gwvpmini_GetNRepos()
 470 {
 471         $conn = gwvpmini_ConnectDB();
 472
 473         $sql = "select count(*) from repos";
 474
 475         $res = $conn->query($sql);
 476
 477         $retval = -1;
 478         foreach($res as $row) {
 479                 $retval = $row[0];
 480         }
 481
 482         return $retval;
 483 }
 484
 485 \r
 486 function gwvpmini_GetNUsers()\r
 487 {\r
 488         $conn = gwvpmini_ConnectDB();\r
 489 \r
 490         $sql = "select count(*) from users";\r
 491 \r
 492         $res = $conn->query($sql);\r
 493 \r
 494         $retval = -1;\r
 495         foreach($res as $row) {\r
 496                 $retval = $row[0];\r
 497         }\r
 498 \r
 499         return $retval;\r
 500 }\r
 501
 502
 503 ?>