[sql-web.git] / lib / security.lib.php

<?php

require_once('mitsql.lib.php');

class Login {
	private $id, $u, $p;
    private $info;
    function Login($u, $p=null) {
		if (empty($u)) return;
   		$this->u = $u;
		$this->p = $p;
		if (is_numeric($u)) {
			$this->id = $u;
			$opt = sprintf(" UserId = '%s'", mysql_escape_string($u));
		} else {
			$opt = sprintf(" Username = '%s'", mysql_escape_string($u));
			$opt .= (is_null($p)?'':sprintf(" AND Password='%s'", mysql_escape_string(base64_encode($p))));
		}
        $sql = sprintf("SELECT UserId, Username, Name, Email, UL, bEnabled
                        FROM User
                        WHERE %s", $opt);
        $r = fetchRows(DBSelect($sql),'UserId');
		$this->info = count($r)?array_shift($r):$r;
	}
    function exists() {
        return count($this->info);
    }
	function isValid() {
		return $this->getUL()>0;
	}
    function isEnabled() {
        return $this->exists() && $this->info['bEnabled']==1;
    }
    function canLogin() {
        return $this->isEnabled() && $this->isValid();
    }
    function canSignup() {
        return !$this->isEnabled() && $this->isValid();
    }
    function getUserId() {
        return $this->exists()?$this->info['UserId']:'';
    }
    function getUsername() {
        return $this->exists()?$this->info['Username']:'';
    }
    function getName() {
        return $this->exists()?$this->info['Name']:'';
    }
    function getEmail() {
        return $this->exists()?$this->info['Email']:'';
    }
    function getUL() {
        return $this->exists()?$this->info['UL']:'';
    }
    function expire() {
        $this->info = null;
    }
    function refresh() {
		if (!empty($this->id)) {
			$this->Login($this->id);
		} else {
			$this->Login($this->u,$this->p);
		}
    }
    function update($name=null,$email=null) {
        if (!$this->exists()) return;
        $arr = array();
		if ($name == $this->getName()) $name = null;
		if ($email == $this->getEmail()) $email = null;
        is_null($name) || $arr['Name'] = $name;
        is_null($email) || $arr['Email'] = $email;
		$upd = buildSQLSet($arr);
        $sql = sprintf("UPDATE User %s WHERE UserId = '%s'",
                        $upd, mysql_escape_string($this->getUserId()));
		if (!empty($upd) && $upd != 'SET')
			DBUpdate($sql);
		if (isset($arr['Name']))
			$this->info['Name'] = $arr['Name'];
		if (isset($arr['Email']))
			$this->info['Email'] = $arr['Email'];
	}
}

class User {
	private $userId;
	private $info;
	private $dblist;
    function User($userId) {
		$this->userId = $userId;
        $sql = sprintf("SELECT User.UserId, Username, Password, Name, Email, UL, bEnabled, nBytesSoft, nBytesHard, nBytes, nDatabases, nDatabasesHard, IF(nBytes>nBytesHard,1,0) AS bOverQuota
                        FROM User
						INNER JOIN UserQuota ON User.UserId = UserQuota.UserId
						INNER JOIN UserStat ON User.UserId = UserStat.UserId
                        WHERE User.UserId = '%s'",
                        mysql_escape_string($userId));
        $r = fetchRows(DBSelect($sql),'UserId');
        $this->info = count($r)?array_shift($r):$r;
		$this->dblist = $this->getDBList();
//		$this->pass = base64_decode($this->info['Password']);
    }
	function refresh() {
		unset($this->dblist);
		$this->User($this->userId);
		/*
        $sql = sprintf("SELECT UserId, Username, Password, Name, Email, UL, bEnabled
                        FROM User
                        WHERE UserId = '%s'",
                        mysql_escape_string($this->userId));
        $r = fetchRows(DBSelect($sql),'UserId');
        $this->info = count($r)?array_shift($r):$r;
		unset($this->dblist);
		$this->getDBList();
		*/
	}
    function exists() {
        return count($this->info);
    }
    function getUserId() {
        return $this->exists()?$this->info['UserId']:'';
    }
    function getUsername() {
        return $this->exists()?$this->info['Username']:'';
    }
    function isOverQuota() {
        return $this->exists()?($this->info['bOverQuota']>0?true:false):'';
    }
    function getBytes() {
        if($this->exists()) {
			$arr['nBytes'] = $this->info['nBytes'];
			$arr['nBytesSoft'] = $this->info['nBytesSoft'];
			$arr['nBytesHard'] = $this->info['nBytesHard'];
			return $arr;
		}
    }
	function setPassword($pwd) {
		$arr['Password'] = base64_encode($pwd);
        $sql = sprintf("UPDATE User %s WHERE UserId = '%s'",
                        buildSQLSet($arr), mysql_escape_string($this->getUserId()));
        DBUpdate($sql);
		$sql = sprintf('SET PASSWORD FOR \'%s\'@\'%%\'=PASSWORD(\'%s\')',
						mysql_escape_string($this->getUsername()),
						mysql_escape_string($pwd));
		DBSet($sql);
	}
	function signup($pwd) {
		$this->pass = $pwd;
		$arr['Password'] = base64_encode($pwd);
		$arr['bEnabled'] = 1;
		$arr['dSignup'] = 'NOW()';
        $sql = sprintf("UPDATE User %s WHERE UserId = '%s'",
                        buildSQLSet($arr), mysql_escape_string($this->getUserId()));
        DBUpdate($sql);

		$this->setUsage();
		$this->setAccess();
	}
	function setUsage($yes=true) {
		$verb = $yes?'GRANT':'REVOKE';
		$prep = $yes?'TO':'FROM';
		$suffix = $yes?sprintf("IDENTIFIED BY '%s'",mysql_escape_string($this->pass)):'';
		$sql = sprintf("%s USAGE ON * . * %s '%s'@'%s' %s",
						mysql_escape_string($verb),
						mysql_escape_string($prep),
						mysql_escape_string($this->getUsername()),
						'%',
						$suffix);
		DBGrant($sql);
	}
	function setAccess($db=null,$yes=true) {
		$verb = $yes?'GRANT':'REVOKE';
		$prep = $yes?'TO':'FROM';
		if (is_null($db)) {
			$dbs = $this->getDBList();
		} else {
			$dbs[] = array('Name'=>$db);
		}
		foreach($dbs as $db) {
			$name = $db['Name'];
			$sql = sprintf("%s ALL PRIVILEGES ON `%s` . * %s '%s'@'%s'",
							mysql_escape_string($verb),
							mysql_escape_string($name),
							mysql_escape_string($prep),
							mysql_escape_string($this->getUsername()),
							'%');
			DBGrant($sql);
		}
	}
	function getDBList() {
		if (isset($this->dblist)) {
			return $this->dblist;
		} else {
			//			LEFT JOIN DBQuota ON DBQuota.DatabaseId = DBOwner.DatabaseId
			$sql = sprintf("SELECT *
						FROM DBOwner
						INNER JOIN DB ON DB.DatabaseId = DBOwner.DatabaseId
						INNER JOIN DBQuota ON DBQuota.DatabaseId = DBOwner.DatabaseId
						WHERE DBOwner.UserId = '%s' AND DB.bEnabled=1",
						mysql_escape_string($this->getUserId()));
//			$r = fetchRows(DBSelect($sql),'DatabaseId');
			$r = fetchRows(DBSelect($sql),'Name');
			ksort($r);
			return $r;
		}
	}
	function addDB($name) {
		if (in_array($name, array_keys($this->getDBList()))) return false;
		if (!addDB($name, $this->getUserId())) return false;
		$this->setAccess($name);
		return true;
	}
	function delDB($name) {
		if (!in_array($name, array_keys($this->getDBList()))) return false;
		if (!delDB($name)) return false;//, $this->getUserId())) return false;
		$this->setAccess($name,false);
		return true;
	}
}


function isLoggedIn($aLogin=null) {
    if (is_null($aLogin)) {
        global $Login;
        $aLogin = $Login;
    }
    return !empty($aLogin) && ($aLogin instanceof Login) && $aLogin->canLogin();
}

function isAdmin($aLogin=null) {
    if (is_null($aLogin)) {
        global $Login;
        $aLogin = $Login;
    }
    return !empty($aLogin) && ($aLogin instanceof Login) && $aLogin->getUL()>=100;
}

function isImpersonating() {
	return isSess('_UserId') && isSess('UserId');
}

function isOffline() {
	return (defined('OFFLINE') && OFFLINE);
}

function isOnline() {
	return !isOffline();
}

function impersonate($userId=null) {
	$wasImpersonating = isImpersonating();
	if ($wasImpersonating) {
		if (is_null($userId) || empty($userId)) {
			sess('UserId',sess('_UserId'));
			sess('_UserId','');
		} elseif ($userId>0) {
			sess('UserId',$userId);
		} else {
			return false;
		}
	} elseif (isLoggedIn()) {
		sess('_UserId',sess('UserId'));
		sess('UserId',$userId);
		return true;
	} else {
		return false;
	}
}

function isSSL() {
	return isset($_SERVER['SERVER_PORT'])?($_SERVER['SERVER_PORT'] == 443):false;
}

function getSSLCert() {
    if (DEVEL && file_exists('.forceauth')) {
        $fu = explode('|',file_get_contents('.forceauth'));
        $name = trim($fu[0]);
        $email = trim($fu[1]);
    } else {
        $name = isset($_SERVER['SSL_CLIENT_S_DN_CN'])?$_SERVER['SSL_CLIENT_S_DN_CN']:null;
        $email = isset($_SERVER['SSL_CLIENT_S_DN_Email'])?$_SERVER['SSL_CLIENT_S_DN_Email']:null;
    }
    if (!is_null($email)) {
        $user = explode('@',$email);
		$user = $user[0];
        return array('Username'=>$user, 'Name'=>$name, 'Email'=>$email);
	} else {
		return null;
	}
}

## 302 REDIRECTS

function redirect($target=null,$secure=null) {
    $base = (is_null($target)||substr($target,0,1)=='?')?$_SERVER['REDIRECT_URL']:(dirname($_SERVER['REDIRECT_URL']).'/');
    redirectFull(is_null($target)?$base:($base.$target),$secure);
}
function redirectStart() {
	redirectFull(BASE_URL,null);
}
function redirectFull($target,$secure) {
	redirect2((((isSSL()&&is_null($secure))||$secure==true)?'https://':'http://').$_SERVER['SERVER_NAME'].$target);
}
function redirect2($target) {
	header('Location: '.$target);
	exit;
}
function flipSSL() {
	return (isSSL()?'http://':'https://').$_SERVER['SERVER_NAME'].$_SERVER['REDIRECT_URL'];
}

## USER SCRIPTS

function addUser($sslCredentials) {
    global $_NEW_USER, $_NEW_USERQUOTA, $_NEW_USERSTAT;

    $arr = array_merge($sslCredentials, $_NEW_USER);
    $sql = sprintf("INSERT INTO User %s",
                    buildSQLInsert($arr));
    $UserId = DBInsert($sql);

	$arr = $_NEW_USERQUOTA;
	$arr['UserId'] = $UserId;
    $sql = sprintf("INSERT INTO UserQuota %s",
                    buildSQLInsert($arr));
	DBInsert($sql);

	$arr = $_NEW_USERSTAT;
	$arr['UserId'] = $UserId;
    $sql = sprintf("INSERT INTO UserStat %s",
                    buildSQLInsert($arr));
	DBInsert($sql);

	return $UserId;
}

function addDB($dbname,$userid) {
	global $_NEW_DB, $_NEW_DBQUOTA, $_NEW_DBOWNER;

	DBCreate(sprintf('CREATE DATABASE `%s`', mysql_escape_string($dbname)));

	$newdb['Name'] = $dbname;
	$arr = array_merge($newdb, $_NEW_DB);
	$arr['bEnabled'] = 1;
	$sql = sprintf("INSERT IGNORE INTO DB %s",
                    buildSQLInsert($arr));
	$DBId = DBInsert($sql);
	if (empty($DBId)) {
		$sql = sprintf("SELECT DatabaseId FROM DB WHERE Name = '%s'",
						mysql_escape_string($dbname));
		$r = fetchRows(DBSelect($sql), 'DatabaseId');
		if (count($r)) {
			$r = array_shift($r);
			$DBId = $r['DatabaseId'];
		} else {
			return false;
		}
		$sql = sprintf("UPDATE DB %s WHERE DB.DatabaseId = '%s'",
						buildSQLSet($arr),
						$DBId);
		DBUpdate($sql);
		return $DBId;
	} else {
		$arr = $_NEW_DBQUOTA;
		$arr['DatabaseId'] = $DBId;
		$sql = sprintf("INSERT IGNORE INTO DBQuota %s",
						buildSQLInsert($arr));
		DBInsert($sql);

		$arr = $_NEW_DBOWNER;
		$arr['DatabaseId'] = $DBId;
		$arr['UserId'] = $userid;
		$sql = sprintf("INSERT IGNORE INTO DBOwner %s",
						buildSQLInsert($arr));
		DBInsert($sql);

		return $DBId;
	}
}

function delDB($dbname) {
	global $_NEW_DB, $_NEW_DBQUOTA, $_NEW_DBOWNER;

	DBCreate(sprintf('DROP DATABASE `%s`', mysql_escape_string($dbname)));

	$arr['bEnabled'] = 0;
	$sql = sprintf("UPDATE DB %s WHERE DB.Name = '%s'",
					buildSQLSet($arr),
					$dbname);
	DBUpdate($sql);

	return true;
}

?>
Commit	Line	Data
997305cf JP	1	<?php
	2
	3	require_once('mitsql.lib.php');
	4
	5	class Login {
e346f2b3 JP	6	private $id, $u, $p;
e346f2b3 JP	7	private $info;
997305cf	8	function Login($u, $p=null) {
377015e0	9	if (empty($u)) return;
e47be57b	10	$this->u = $u;
dc478ec8	11	$this->p = $p;
e47be57b JP	12	if (is_numeric($u)) {
	13	$this->id = $u;
	14	$opt = sprintf(" UserId = '%s'", mysql_escape_string($u));
	15	} else {
	16	$opt = sprintf(" Username = '%s'", mysql_escape_string($u));
	17	$opt .= (is_null($p)?'':sprintf(" AND Password='%s'", mysql_escape_string(base64_encode($p))));
	18	}
997305cf JP	19	$sql = sprintf("SELECT UserId, Username, Name, Email, UL, bEnabled
997305cf JP	20	FROM User
377015e0	21	WHERE %s", $opt);
997305cf	22	$r = fetchRows(DBSelect($sql),'UserId');
e47be57b JP	23	$this->info = count($r)?array_shift($r):$r;
e47be57b JP	24	}
997305cf	25	function exists() {
dc478ec8	26	return count($this->info);
997305cf	27	}
dc478ec8 JP	28	function isValid() {
	29	return $this->getUL()>0;
	30	}
997305cf JP	31	function isEnabled() {
	32	return $this->exists() && $this->info['bEnabled']==1;
	33	}
dc478ec8 JP	34	function canLogin() {
	35	return $this->isEnabled() && $this->isValid();
	36	}
	37	function canSignup() {
	38	return !$this->isEnabled() && $this->isValid();
	39	}
997305cf	40	function getUserId() {
dc478ec8	41	return $this->exists()?$this->info['UserId']:'';
997305cf JP	42	}
997305cf JP	43	function getUsername() {
dc478ec8	44	return $this->exists()?$this->info['Username']:'';
997305cf JP	45	}
997305cf JP	46	function getName() {
dc478ec8	47	return $this->exists()?$this->info['Name']:'';
997305cf JP	48	}
997305cf JP	49	function getEmail() {
dc478ec8	50	return $this->exists()?$this->info['Email']:'';
997305cf JP	51	}
997305cf JP	52	function getUL() {
dc478ec8	53	return $this->exists()?$this->info['UL']:'';
997305cf JP	54	}
	55	function expire() {
	56	$this->info = null;
	57	}
	58	function refresh() {
e47be57b JP	59	if (!empty($this->id)) {
	60	$this->Login($this->id);
	61	} else {
	62	$this->Login($this->u,$this->p);
	63	}
997305cf JP	64	}
	65	function update($name=null,$email=null) {
	66	if (!$this->exists()) return;
	67	$arr = array();
dc478ec8 JP	68	if ($name == $this->getName()) $name = null;
dc478ec8 JP	69	if ($email == $this->getEmail()) $email = null;
997305cf JP	70	is_null($name) \|\| $arr['Name'] = $name;
997305cf JP	71	is_null($email) \|\| $arr['Email'] = $email;
e47be57b	72	$upd = buildSQLSet($arr);
997305cf	73	$sql = sprintf("UPDATE User %s WHERE UserId = '%s'",
3ebfe9a3	74	$upd, mysql_escape_string($this->getUserId()));
e47be57b JP	75	if (!empty($upd) && $upd != 'SET')
e47be57b JP	76	DBUpdate($sql);
dc478ec8	77	if (isset($arr['Name']))
377015e0	78	$this->info['Name'] = $arr['Name'];
dc478ec8	79	if (isset($arr['Email']))
377015e0	80	$this->info['Email'] = $arr['Email'];
dc478ec8 JP	81	}
	82	}
	83
	84	class User {
e346f2b3 JP	85	private $userId;
	86	private $info;
	87	private $dblist;
dc478ec8 JP	88	function User($userId) {
dc478ec8 JP	89	$this->userId = $userId;
9c70b481	90	$sql = sprintf("SELECT User.UserId, Username, Password, Name, Email, UL, bEnabled, nBytesSoft, nBytesHard, nBytes, nDatabases, nDatabasesHard, IF(nBytes>nBytesHard,1,0) AS bOverQuota
dc478ec8	91	FROM User
e47be57b JP	92	INNER JOIN UserQuota ON User.UserId = UserQuota.UserId
e47be57b JP	93	INNER JOIN UserStat ON User.UserId = UserStat.UserId
88b7d384	94	WHERE User.UserId = '%s'",
dc478ec8 JP	95	mysql_escape_string($userId));
	96	$r = fetchRows(DBSelect($sql),'UserId');
	97	$this->info = count($r)?array_shift($r):$r;
377015e0 JP	98	$this->dblist = $this->getDBList();
377015e0 JP	99	// $this->pass = base64_decode($this->info['Password']);
997305cf	100	}
88b7d384 JP	101	function refresh() {
	102	unset($this->dblist);
	103	$this->User($this->userId);
	104	/*
	105	$sql = sprintf("SELECT UserId, Username, Password, Name, Email, UL, bEnabled
	106	FROM User
	107	WHERE UserId = '%s'",
	108	mysql_escape_string($this->userId));
	109	$r = fetchRows(DBSelect($sql),'UserId');
	110	$this->info = count($r)?array_shift($r):$r;
	111	unset($this->dblist);
	112	$this->getDBList();
	113	*/
	114	}
dc478ec8 JP	115	function exists() {
	116	return count($this->info);
	117	}
	118	function getUserId() {
	119	return $this->exists()?$this->info['UserId']:'';
	120	}
	121	function getUsername() {
	122	return $this->exists()?$this->info['Username']:'';
88b7d384	123	}
9c70b481 JP	124	function isOverQuota() {
	125	return $this->exists()?($this->info['bOverQuota']>0?true:false):'';
	126	}
88b7d384 JP	127	function getBytes() {
	128	if($this->exists()) {
	129	$arr['nBytes'] = $this->info['nBytes'];
	130	$arr['nBytesSoft'] = $this->info['nBytesSoft'];
	131	$arr['nBytesHard'] = $this->info['nBytesHard'];
	132	return $arr;
	133	}
dc478ec8 JP	134	}
	135	function setPassword($pwd) {
	136	$arr['Password'] = base64_encode($pwd);
	137	$sql = sprintf("UPDATE User %s WHERE UserId = '%s'",
	138	buildSQLSet($arr), mysql_escape_string($this->getUserId()));
	139	DBUpdate($sql);
377015e0 JP	140	$sql = sprintf('SET PASSWORD FOR \'%s\'@\'%%\'=PASSWORD(\'%s\')',
	141	mysql_escape_string($this->getUsername()),
	142	mysql_escape_string($pwd));
	143	DBSet($sql);
dc478ec8 JP	144	}
	145	function signup($pwd) {
	146	$this->pass = $pwd;
	147	$arr['Password'] = base64_encode($pwd);
	148	$arr['bEnabled'] = 1;
	149	$arr['dSignup'] = 'NOW()';
	150	$sql = sprintf("UPDATE User %s WHERE UserId = '%s'",
	151	buildSQLSet($arr), mysql_escape_string($this->getUserId()));
	152	DBUpdate($sql);
	153
	154	$this->setUsage();
	155	$this->setAccess();
	156	}
	157	function setUsage($yes=true) {
	158	$verb = $yes?'GRANT':'REVOKE';
	159	$prep = $yes?'TO':'FROM';
3ebfe9a3	160	$suffix = $yes?sprintf("IDENTIFIED BY '%s'",mysql_escape_string($this->pass)):'';
dc478ec8 JP	161	$sql = sprintf("%s USAGE ON * . * %s '%s'@'%s' %s",
	162	mysql_escape_string($verb),
	163	mysql_escape_string($prep),
	164	mysql_escape_string($this->getUsername()),
	165	'%',
3ebfe9a3	166	$suffix);
dc478ec8 JP	167	DBGrant($sql);
	168	}
	169	function setAccess($db=null,$yes=true) {
	170	$verb = $yes?'GRANT':'REVOKE';
	171	$prep = $yes?'TO':'FROM';
	172	if (is_null($db)) {
88b7d384	173	$dbs = $this->getDBList();
dc478ec8 JP	174	} else {
	175	$dbs[] = array('Name'=>$db);
	176	}
	177	foreach($dbs as $db) {
	178	$name = $db['Name'];
	179	$sql = sprintf("%s ALL PRIVILEGES ON `%s` . * %s '%s'@'%s'",
	180	mysql_escape_string($verb),
	181	mysql_escape_string($name),
	182	mysql_escape_string($prep),
377015e0	183	mysql_escape_string($this->getUsername()),
dc478ec8 JP	184	'%');
	185	DBGrant($sql);
	186	}
	187	}
	188	function getDBList() {
88b7d384 JP	189	if (isset($this->dblist)) {
	190	return $this->dblist;
	191	} else {
	192	// LEFT JOIN DBQuota ON DBQuota.DatabaseId = DBOwner.DatabaseId
	193	$sql = sprintf("SELECT *
dc478ec8	194	FROM DBOwner
e47be57b JP	195	INNER JOIN DB ON DB.DatabaseId = DBOwner.DatabaseId
e47be57b JP	196	INNER JOIN DBQuota ON DBQuota.DatabaseId = DBOwner.DatabaseId
88b7d384	197	WHERE DBOwner.UserId = '%s' AND DB.bEnabled=1",
dc478ec8	198	mysql_escape_string($this->getUserId()));
88b7d384 JP	199	// $r = fetchRows(DBSelect($sql),'DatabaseId');
88b7d384 JP	200	$r = fetchRows(DBSelect($sql),'Name');
9c70b481	201	ksort($r);
88b7d384 JP	202	return $r;
88b7d384 JP	203	}
dc478ec8	204	}
377015e0	205	function addDB($name) {
4a77eeb5	206	if (in_array($name, array_keys($this->getDBList()))) return false;
377015e0 JP	207	if (!addDB($name, $this->getUserId())) return false;
	208	$this->setAccess($name);
	209	return true;
	210	}
e47be57b JP	211	function delDB($name) {
	212	if (!in_array($name, array_keys($this->getDBList()))) return false;
	213	if (!delDB($name)) return false;//, $this->getUserId())) return false;
	214	$this->setAccess($name,false);
	215	return true;
	216	}
997305cf JP	217	}
	218
	219
	220	function isLoggedIn($aLogin=null) {
	221	if (is_null($aLogin)) {
	222	global $Login;
	223	$aLogin = $Login;
	224	}
e346f2b3	225	return !empty($aLogin) && ($aLogin instanceof Login) && $aLogin->canLogin();
997305cf JP	226	}
997305cf JP	227
e47be57b JP	228	function isAdmin($aLogin=null) {
	229	if (is_null($aLogin)) {
	230	global $Login;
	231	$aLogin = $Login;
	232	}
e346f2b3	233	return !empty($aLogin) && ($aLogin instanceof Login) && $aLogin->getUL()>=100;
e47be57b JP	234	}
e47be57b JP	235
88b7d384 JP	236	function isImpersonating() {
	237	return isSess('_UserId') && isSess('UserId');
	238	}
	239
8ed5cf01 JP	240	function isOffline() {
	241	return (defined('OFFLINE') && OFFLINE);
	242	}
	243
	244	function isOnline() {
	245	return !isOffline();
	246	}
	247
88b7d384 JP	248	function impersonate($userId=null) {
	249	$wasImpersonating = isImpersonating();
	250	if ($wasImpersonating) {
224df904	251	if (is_null($userId) \|\| empty($userId)) {
88b7d384	252	sess('UserId',sess('_UserId'));
224df904	253	sess('_UserId','');
88b7d384 JP	254	} elseif ($userId>0) {
	255	sess('UserId',$userId);
	256	} else {
	257	return false;
	258	}
	259	} elseif (isLoggedIn()) {
	260	sess('_UserId',sess('UserId'));
	261	sess('UserId',$userId);
	262	return true;
	263	} else {
	264	return false;
	265	}
	266	}
	267
997305cf	268	function isSSL() {
aaaa7a8f	269	return isset($_SERVER['SERVER_PORT'])?($_SERVER['SERVER_PORT'] == 443):false;
997305cf JP	270	}
	271
	272	function getSSLCert() {
	273	if (DEVEL && file_exists('.forceauth')) {
	274	$fu = explode('\|',file_get_contents('.forceauth'));
dc478ec8 JP	275	$name = trim($fu[0]);
dc478ec8 JP	276	$email = trim($fu[1]);
997305cf JP	277	} else {
	278	$name = isset($_SERVER['SSL_CLIENT_S_DN_CN'])?$_SERVER['SSL_CLIENT_S_DN_CN']:null;
	279	$email = isset($_SERVER['SSL_CLIENT_S_DN_Email'])?$_SERVER['SSL_CLIENT_S_DN_Email']:null;
	280	}
	281	if (!is_null($email)) {
	282	$user = explode('@',$email);
	283	$user = $user[0];
	284	return array('Username'=>$user, 'Name'=>$name, 'Email'=>$email);
	285	} else {
	286	return null;
	287	}
	288	}
	289
	290	## 302 REDIRECTS
	291
1389493c	292	function redirect($target=null,$secure=null) {
997305cf	293	$base = (is_null($target)\|\|substr($target,0,1)=='?')?$_SERVER['REDIRECT_URL']:(dirname($_SERVER['REDIRECT_URL']).'/');
dc478ec8	294	redirectFull(is_null($target)?$base:($base.$target),$secure);
997305cf	295	}
224df904 JP	296	function redirectStart() {
	297	redirectFull(BASE_URL,null);
	298	}
dc478ec8	299	function redirectFull($target,$secure) {
1389493c	300	redirect2((((isSSL()&&is_null($secure))\|\|$secure==true)?'https://':'http://').$_SERVER['SERVER_NAME'].$target);
997305cf JP	301	}
	302	function redirect2($target) {
	303	header('Location: '.$target);
	304	exit;
	305	}
dc478ec8 JP	306	function flipSSL() {
	307	return (isSSL()?'http://':'https://').$_SERVER['SERVER_NAME'].$_SERVER['REDIRECT_URL'];
	308	}
997305cf JP	309
	310	## USER SCRIPTS
	311
	312	function addUser($sslCredentials) {
dc478ec8 JP	313	global $_NEW_USER, $_NEW_USERQUOTA, $_NEW_USERSTAT;
dc478ec8 JP	314
997305cf JP	315	$arr = array_merge($sslCredentials, $_NEW_USER);
	316	$sql = sprintf("INSERT INTO User %s",
	317	buildSQLInsert($arr));
dc478ec8 JP	318	$UserId = DBInsert($sql);
	319
	320	$arr = $_NEW_USERQUOTA;
	321	$arr['UserId'] = $UserId;
	322	$sql = sprintf("INSERT INTO UserQuota %s",
	323	buildSQLInsert($arr));
	324	DBInsert($sql);
	325
	326	$arr = $_NEW_USERSTAT;
	327	$arr['UserId'] = $UserId;
1389493c	328	$sql = sprintf("INSERT INTO UserStat %s",
dc478ec8 JP	329	buildSQLInsert($arr));
	330	DBInsert($sql);
	331
	332	return $UserId;
997305cf JP	333	}
997305cf JP	334
377015e0	335	function addDB($dbname,$userid) {
e47be57b	336	global $_NEW_DB, $_NEW_DBQUOTA, $_NEW_DBOWNER;
377015e0 JP	337
377015e0 JP	338	DBCreate(sprintf('CREATE DATABASE `%s`', mysql_escape_string($dbname)));
377015e0 JP	339
377015e0 JP	340	$newdb['Name'] = $dbname;
e47be57b	341	$arr = array_merge($newdb, $_NEW_DB);
377015e0	342	$arr['bEnabled'] = 1;
e47be57b	343	$sql = sprintf("INSERT IGNORE INTO DB %s",
377015e0	344	buildSQLInsert($arr));
e47be57b JP	345	$DBId = DBInsert($sql);
	346	if (empty($DBId)) {
	347	$sql = sprintf("SELECT DatabaseId FROM DB WHERE Name = '%s'",
	348	mysql_escape_string($dbname));
	349	$r = fetchRows(DBSelect($sql), 'DatabaseId');
	350	if (count($r)) {
	351	$r = array_shift($r);
	352	$DBId = $r['DatabaseId'];
	353	} else {
	354	return false;
	355	}
	356	$sql = sprintf("UPDATE DB %s WHERE DB.DatabaseId = '%s'",
	357	buildSQLSet($arr),
	358	$DBId);
	359	DBUpdate($sql);
	360	return $DBId;
	361	} else {
	362	$arr = $_NEW_DBQUOTA;
	363	$arr['DatabaseId'] = $DBId;
	364	$sql = sprintf("INSERT IGNORE INTO DBQuota %s",
	365	buildSQLInsert($arr));
	366	DBInsert($sql);
377015e0	367
e47be57b JP	368	$arr = $_NEW_DBOWNER;
	369	$arr['DatabaseId'] = $DBId;
	370	$arr['UserId'] = $userid;
	371	$sql = sprintf("INSERT IGNORE INTO DBOwner %s",
	372	buildSQLInsert($arr));
	373	DBInsert($sql);
377015e0	374
e47be57b JP	375	return $DBId;
	376	}
	377	}
	378
	379	function delDB($dbname) {
	380	global $_NEW_DB, $_NEW_DBQUOTA, $_NEW_DBOWNER;
	381
	382	DBCreate(sprintf('DROP DATABASE `%s`', mysql_escape_string($dbname)));
	383
	384	$arr['bEnabled'] = 0;
	385	$sql = sprintf("UPDATE DB %s WHERE DB.Name = '%s'",
	386	buildSQLSet($arr),
	387	$dbname);
	388	DBUpdate($sql);
377015e0	389
e47be57b	390	return true;
377015e0 JP	391	}
377015e0 JP	392
88b7d384	393	?>