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_GetUserNameFromEmail($email)\r
 294 {\r
 295         $conn = gwvpmini_ConnectDB();\r
 296 \r
 297         $sql = "select user_username from users where user_email='$email'";\r
 298 \r
 299         error_log("username sql $sql");\r
 300 \r
 301         $res = $conn->query($sql);\r
 302 \r
 303         $retval = false;\r
 304         foreach($res as $row) {\r
 305                 $retval = $row[0];\r
 306         }\r
 307 \r
 308         return $retval;\r
 309 }
 310 function gwvpmini_GetOwnedRepos($username)\r
 311 {
 312         /*
 313          *      CREATE TABLE "repos" (
 314         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 315         "repos_name" TEXT,
 316         "repos_description" TEXT,
 317         "repos_owner" INTEGER
 318         )';
 319
 320          */
 321         $conn = gwvpmini_ConnectDB();
 322
 323         $uid = gwvpmini_GetUserId($username);
 324         $sql = "select * from repos where repos_owner='$uid'";
 325         error_log("owned repos sql $sql");
 326         $res = $conn->query($sql);
 327
 328         $retval = false;
 329         foreach($res as $row) {
 330                 $id = $row["repos_id"];
 331                 $retval[$id]["name"] = $row["repos_name"];
 332                 $retval[$id]["desc"] = $row["repos_description"];
 333                 error_log(print_r($row, true));
 334         }
 335
 336         error_log(print_r($retval, true));\r
 337         return $retval;\r
 338 }
 339
 340 function gwvpmini_userLevel($id)
 341 {
 342         $conn = gwvpmini_ConnectDB();
 343
 344         $sql = "select user_level from users where user_id='$id'";
 345
 346         $res = $conn->query($sql);
 347
 348         $lev = -1;
 349         if(!$res) return -1;
 350         foreach($res as $row) {
 351                 $lev = (int)$row[0];
 352         }
 353
 354         return $lev;
 355 }
 356
 357 function gwvpmini_GetUsers($startat = 0, $num = 10)
 358 {
 359         $conn = gwvpmini_ConnectDB();
 360
 361         /*
 362          *      CREATE TABLE "users" (
 363         "user_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 364         "user_full_name" TEXT,
 365         "user_password" TEXT,
 366         "user_username" TEXT,
 367         "user_email" TEXT,
 368         "user_desc" TEXT,
 369         "user_level" TEXT,
 370         "user_status" TEXT
 371
 372          */\r
 373         \r
 374         $sql = "select * from users where user_id>'$startat' order by user_id asc limit $num";
 375
 376         $res = $conn->query($sql);
 377
 378         $retval = false;
 379         foreach($res as $row) {
 380                 $id = $row["user_id"];
 381                 $retval[$id]["fullname"] = $row["user_full_name"];
 382                 $retval[$id]["username"] = $row["user_username"];
 383                 $retval[$id]["email"] = $row["user_email"];
 384                 $retval[$id]["desc"] = $row["user_desc"];
 385                 $retval[$id]["level"] = $row["user_level"];
 386                 $retval[$id]["status"] = $row["user_status"];
 387         }
 388
 389         return $retval;
 390 }\r
 391
 392 function gwvpmini_GetRepos($startat=0, $num=200)\r
 393 {\r
 394         $conn = gwvpmini_ConnectDB();\r
 395         \r
 396         /*\r
 397          *      CREATE TABLE "repos" (
 398         "repos_id" INTEGER PRIMARY KEY AUTOINCREMENT,
 399         "repos_name" TEXT,
 400         "repos_description" TEXT,
 401         "repos_owner" INTEGER
 402         )';
 403         \r
 404                         */\r
 405         \r
 406         $sql = "select * from repos where repos_id > '$startat' order by repos_id asc limit $num";\r
 407         \r
 408         $res = $conn->query($sql);\r
 409         \r
 410         $retval = false;\r
 411         foreach($res as $row) {\r
 412                 $id = $row["repos_id"];\r
 413                 $retval[$id]["name"] = $row["repos_name"];\r
 414                 $retval[$id]["desc"] = $row["repos_description"];\r
 415                 $retval[$id]["owner"] = $row["repos_owner"];\r
 416         }\r
 417         \r
 418         return $retval;\r
 419         \r
 420         \r
 421 }\r
 422
 423 function gwvpmini_GetNRepos()
 424 {
 425         $conn = gwvpmini_ConnectDB();
 426
 427         $sql = "select count(*) from repos";
 428
 429         $res = $conn->query($sql);
 430
 431         $retval = -1;
 432         foreach($res as $row) {
 433                 $retval = $row[0];
 434         }
 435
 436         return $retval;
 437 }
 438
 439 \r
 440 function gwvpmini_GetNUsers()\r
 441 {\r
 442         $conn = gwvpmini_ConnectDB();\r
 443 \r
 444         $sql = "select count(*) from users";\r
 445 \r
 446         $res = $conn->query($sql);\r
 447 \r
 448         $retval = -1;\r
 449         foreach($res as $row) {\r
 450                 $retval = $row[0];\r
 451         }\r
 452 \r
 453         return $retval;\r
 454 }\r
 455
 456
 457 ?>