Organizr/api/functions/api-functions.php

<?php /** @noinspection SqlResolve */
/** @noinspection SqlResolve */
/** @noinspection SqlResolve */
/** @noinspection SqlResolve */
/** @noinspection SyntaxError */
function apiLogin()
{
	$array = array(
		'data' => array(
			array(
				'name' => 'username',
				'value' => (isset($_POST['username'])) ? $_POST['username'] : false
			),
			array(
				'name' => 'password',
				'value' => (isset($_POST['password'])) ? $_POST['password'] : false
			),
			array(
				'name' => 'remember',
				'value' => (isset($_POST['remember'])) ? true : false
			),
			array(
				'name' => 'oAuth',
				'value' => (isset($_POST['oAuth'])) ? $_POST['oAuth'] : false
			),
			array(
				'name' => 'oAuthType',
				'value' => (isset($_POST['oAuthType'])) ? $_POST['oAuthType'] : false
			),
			array(
				'name' => 'tfaCode',
				'value' => (isset($_POST['tfaCode'])) ? $_POST['tfaCode'] : false
			),
			array(
				'name' => 'loginAttempts',
				'value' => (isset($_POST['loginAttempts'])) ? $_POST['loginAttempts'] : false
			),
			array(
				'name' => 'output',
				'value' => true
			),
		)
	);
	foreach ($array['data'] as $items) {
		foreach ($items as $key => $value) {
			if ($key == 'name') {
				$newKey = $value;
			}
			if ($key == 'value') {
				$newValue = $value;
			}
			if (isset($newKey) && isset($newValue)) {
				$$newKey = $newValue;
			}
		}
	}
	return login($array);
}

function login($array)
{
	// Grab username and Password from login form
	$username = $password = $oAuth = $oAuthType = '';
	foreach ($array['data'] as $items) {
		foreach ($items as $key => $value) {
			if ($key == 'name') {
				$newKey = $value;
			}
			if ($key == 'value') {
				$newValue = $value;
			}
			if (isset($newKey) && isset($newValue)) {
				$$newKey = $newValue;
			}
		}
	}
	$username = (strpos($GLOBALS['authBackend'], 'emby') !== false) ? $username : strtolower($username);
	$days = (isset($remember)) ? $GLOBALS['rememberMeDays'] : 1;
	$oAuth = (isset($oAuth)) ? $oAuth : false;
	$output = (isset($output)) ? $output : false;
	$loginAttempts = (isset($loginAttempts)) ? $loginAttempts : false;
	if ($loginAttempts > $GLOBALS['loginAttempts'] || isset($_COOKIE['lockout'])) {
		coookieSeconds('set', 'lockout', $GLOBALS['loginLockout'], $GLOBALS['loginLockout']);
		return 'lockout';
	}
	try {
		$database = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
		]);
		$authSuccess = false;
		$authProxy = false;
		if ($GLOBALS['authProxyEnabled'] && $GLOBALS['authProxyHeaderName'] !== '' && $GLOBALS['authProxyWhitelist'] !== '') {
			if (isset(getallheaders()[$GLOBALS['authProxyHeaderName']])) {
				$usernameHeader = isset(getallheaders()[$GLOBALS['authProxyHeaderName']]) ? getallheaders()[$GLOBALS['authProxyHeaderName']] : $username;
				writeLog('success', 'Auth Proxy Function - Starting Verification for IP: ' . userIP() . ' for request on: ' . $_SERVER['REMOTE_ADDR'] . ' against IP/Subnet: ' . $GLOBALS['authProxyWhitelist'], $usernameHeader);
				$whitelistRange = analyzeIP($GLOBALS['authProxyWhitelist']);
				$from = $whitelistRange['from'];
				$to = $whitelistRange['to'];
				$authProxy = authProxyRangeCheck($from, $to);
				$username = ($authProxy) ? $usernameHeader : $username;
				if ($authProxy) {
					writeLog('success', 'Auth Proxy Function - IP: ' . userIP() . ' has been verified', $usernameHeader);
				} else {
					writeLog('error', 'Auth Proxy Function - IP: ' . userIP() . ' has failed verification', $usernameHeader);
				}
			}
		}
		$function = 'plugin_auth_' . $GLOBALS['authBackend'];
		if (!$oAuth) {
			$result = $database->fetch('SELECT * FROM users WHERE username = ? COLLATE NOCASE OR email = ? COLLATE NOCASE', $username, $username);
			$result['password'] = $result['password'] ?? '';
			switch ($GLOBALS['authType']) {
				case 'external':
					if (function_exists($function)) {
						$authSuccess = $function($username, $password);
					}
					break;
				/** @noinspection PhpMissingBreakStatementInspection */
				case 'both':
					if (function_exists($function)) {
						$authSuccess = $function($username, $password);
					}
				// no break
				default: // Internal
					if (!$authSuccess) {
						// perform the internal authentication step
						if (password_verify($password, $result['password'])) {
							$authSuccess = true;
						}
					}
			}
			$authSuccess = ($authProxy) ? true : $authSuccess;
		} else {
			// Has oAuth Token!
			switch ($oAuthType) {
				case 'plex':
					if ($GLOBALS['plexoAuth']) {
						$tokenInfo = checkPlexToken($oAuth);
						if ($tokenInfo) {
							$authSuccess = array(
								'username' => $tokenInfo['user']['username'],
								'email' => $tokenInfo['user']['email'],
								'image' => $tokenInfo['user']['thumb'],
								'token' => $tokenInfo['user']['authToken']
							);
							coookie('set', 'oAuth', 'true', $GLOBALS['rememberMeDays']);
							$authSuccess = ((!empty($GLOBALS['plexAdmin']) && strtolower($GLOBALS['plexAdmin']) == strtolower($tokenInfo['user']['username'])) || (!empty($GLOBALS['plexAdmin']) && strtolower($GLOBALS['plexAdmin']) == strtolower($tokenInfo['user']['email'])) || checkPlexUser($tokenInfo['user']['username'])) ? $authSuccess : false;
						}
					}
					break;
				default:
					return ($output) ? 'No oAuthType defined' : 'error';
					break;
			}
			$result = ($authSuccess) ? $database->fetch('SELECT * FROM users WHERE username = ? COLLATE NOCASE OR email = ? COLLATE NOCASE', $authSuccess['username'], $authSuccess['email']) : '';
		}
		if ($authSuccess) {
			// Make sure user exists in database
			$userExists = false;
			$passwordMatches = ($oAuth || $authProxy) ? true : false;
			$token = (is_array($authSuccess) && isset($authSuccess['token']) ? $authSuccess['token'] : '');
			if ($result['username']) {
				$userExists = true;
				$username = $result['username'];
				if ($passwordMatches == false) {
					$passwordMatches = (password_verify($password, $result['password'])) ? true : false;
				}
			}
			if ($userExists) {
				//does org password need to be updated
				if (!$passwordMatches) {
					$database->query('
                    	UPDATE users SET', [
						'password' => password_hash($password, PASSWORD_BCRYPT)
					], '
                    	WHERE id=?', $result['id']);
					writeLog('success', 'Login Function - User Password updated from backend', $username);
				}
				if ($token !== '') {
					if ($token !== $result['plex_token']) {
						$database->query('
	                        UPDATE users SET', [
							'plex_token' => $token
						], '
	                        WHERE id=?', $result['id']);
						writeLog('success', 'Login Function - User Plex Token updated from backend', $username);
					}
				}
				// 2FA might go here
				if ($result['auth_service'] !== 'internal' && strpos($result['auth_service'], '::') !== false) {
					$tfaProceed = true;
					// Add check for local or not
					if ($GLOBALS['ignoreTFALocal'] !== false) {
						$tfaProceed = (isLocal()) ? false : true;
					}
					if ($tfaProceed) {
						$TFA = explode('::', $result['auth_service']);
						// Is code with login info?
						if ($tfaCode == '') {
							return '2FA';
						} else {
							if (!verify2FA($TFA[1], $tfaCode, $TFA[0])) {
								writeLoginLog($username, 'error');
								writeLog('error', 'Login Function - Wrong 2FA', $username);
								return '2FA-incorrect';
							}
						}
					}
				}
				// End 2FA
				// authentication passed - 1) mark active and update token
				$createToken = createToken($result['username'], $result['email'], $result['image'], $result['group'], $result['group_id'], $GLOBALS['organizrHash'], $days);
				if ($createToken) {
					writeLoginLog($username, 'success');
					writeLog('success', 'Login Function - A User has logged in', $username);
					$ssoUser = ((empty($result['email'])) ? $result['username'] : (strpos($result['email'], 'placeholder') !== false)) ? $result['username'] : $result['email'];
					ssoCheck($ssoUser, $password, $token); //need to work on this
					return ($output) ? array('name' => $GLOBALS['cookieName'], 'token' => (string)$createToken) : true;
				} else {
					return 'Token Creation Error';
				}
			} else {
				// Create User
				//ssoCheck($username, $password, $token);
				return authRegister((is_array($authSuccess) && isset($authSuccess['username']) ? $authSuccess['username'] : $username), $password, defaultUserGroup(), (is_array($authSuccess) && isset($authSuccess['email']) ? $authSuccess['email'] : ''), $token);
			}
		} else {
			// authentication failed
			writeLoginLog($username, 'error');
			writeLog('error', 'Login Function - Wrong Password', $username);
			if ($loginAttempts >= $GLOBALS['loginAttempts']) {
				coookieSeconds('set', 'lockout', $GLOBALS['loginLockout'], $GLOBALS['loginLockout']);
				return 'lockout';
			} else {
				return 'mismatch';
			}
		}
	} catch (Dibi\Exception $e) {
		return $e;
	}
}

function createDB($path, $filename)
{
	try {
		if (!file_exists($path)) {
			mkdir($path, 0777, true);
		}
		$createDB = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $path . $filename,
		]);
		// Create Users
		$createDB->query('CREATE TABLE `users` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
    		`username`	TEXT UNIQUE,
    		`password`	TEXT,
    		`email`	TEXT,
    		`plex_token`	TEXT,
            `group`	TEXT,
            `group_id`	INTEGER,
            `locked`	INTEGER,
    		`image`	TEXT,
            `register_date` DATE,
    		`auth_service`	TEXT DEFAULT \'internal\'
    	);');
		// Create Tokens
		$createDB->query('CREATE TABLE `chatroom` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
    		`username`	TEXT,
    		`gravatar`	TEXT,
    		`uid`	TEXT,
            `date` DATE,
            `ip` TEXT,
            `message` TEXT
    	);');
		$createDB->query('CREATE TABLE `tokens` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
    		`token`	TEXT UNIQUE,
    		`user_id`	INTEGER,
    		`browser`	TEXT,
    		`ip`	TEXT,
            `created` DATE,
            `expires` DATE
    	);');
		$createDB->query('CREATE TABLE `groups` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
    		`group`	TEXT UNIQUE,
            `group_id`	INTEGER,
    		`image`	TEXT,
            `default` INTEGER
    	);');
		$createDB->query('CREATE TABLE `categories` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
            `order`	INTEGER,
    		`category`	TEXT UNIQUE,
            `category_id`	INTEGER,
    		`image`	TEXT,
            `default` INTEGER
    	);');
		// Create Tabs
		$createDB->query('CREATE TABLE `tabs` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
    		`order`	INTEGER,
    		`category_id`	INTEGER,
    		`name`	TEXT,
            `url`	TEXT,
    		`url_local`	TEXT,
    		`default`	INTEGER,
    		`enabled`	INTEGER,
    		`group_id`	INTEGER,
    		`image`	TEXT,
    		`type`	INTEGER,
    		`splash`	INTEGER,
    		`ping`		INTEGER,
    		`ping_url`	TEXT,
    		`timeout`	INTEGER,
    		`timeout_ms`	INTEGER,
    		`preload`	INTEGER
    	);');
		// Create Options
		$createDB->query('CREATE TABLE `options` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
    		`name`	TEXT UNIQUE,
    		`value`	TEXT
    	);');
		// Create Invites
		$createDB->query('CREATE TABLE `invites` (
    		`id`	INTEGER PRIMARY KEY AUTOINCREMENT UNIQUE,
    		`code`	TEXT UNIQUE,
    		`date`	TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    		`email`	TEXT,
    		`username`	TEXT,
    		`dateused`	TIMESTAMP,
    		`usedby`	TEXT,
    		`ip`	TEXT,
    		`valid`	TEXT,
            `type` TEXT
    	);');
		return true;
	} catch (Dibi\Exception $e) {
		return false;
	}
}

// Upgrade Database
function updateDB($oldVerNum = false)
{
	$tempLock = $GLOBALS['dbLocation'] . 'DBLOCK.txt';
	if (!file_exists($tempLock)) {
		touch($tempLock);
		// Create Temp DB First
		$migrationDB = 'tempMigration.db';
		$pathDigest = pathinfo($GLOBALS['dbLocation'] . $GLOBALS['dbName']);
		if (file_exists($GLOBALS['dbLocation'] . $migrationDB)) {
			unlink($GLOBALS['dbLocation'] . $migrationDB);
		}
		$backupDB = $pathDigest['dirname'] . '/' . $pathDigest['filename'] . '[' . date('Y-m-d_H-i-s') . ']' . ($oldVerNum ? '[' . $oldVerNum . ']' : '') . '.bak.db';
		copy($GLOBALS['dbLocation'] . $GLOBALS['dbName'], $backupDB);
		$success = createDB($GLOBALS['dbLocation'], $migrationDB);
		if ($success) {
			try {
				$connectOldDB = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $backupDB,
				]);
				$connectNewDB = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $migrationDB,
				]);
				$tables = $connectOldDB->fetchAll('SELECT name FROM sqlite_master WHERE type="table"');
				foreach ($tables as $table) {
					$data = $connectOldDB->fetchAll('SELECT * FROM ' . $table['name']);
					writeLog('success', 'Update Function -  Grabbed Table data for Table: ' . $table['name'], 'Database');
					foreach ($data as $row) {
						$connectNewDB->query('INSERT into ' . $table['name'], $row);
					}
					writeLog('success', 'Update Function -  Wrote Table data for Table: ' . $table['name'], 'Database');
				}
				writeLog('success', 'Update Function -  All Table data converted - Starting Movement', 'Database');
				$connectOldDB->disconnect();
				$connectNewDB->disconnect();
				// Remove Current Database
				if (file_exists($GLOBALS['dbLocation'] . $migrationDB)) {
					$oldFileSize = filesize($GLOBALS['dbLocation'] . $GLOBALS['dbName']);
					$newFileSize = filesize($GLOBALS['dbLocation'] . $migrationDB);
					if ($newFileSize > 0) {
						writeLog('success', 'Update Function -  Table Size of new DB ok..', 'Database');
						@unlink($GLOBALS['dbLocation'] . $GLOBALS['dbName']);
						copy($GLOBALS['dbLocation'] . $migrationDB, $GLOBALS['dbLocation'] . $GLOBALS['dbName']);
						@unlink($GLOBALS['dbLocation'] . $migrationDB);
						writeLog('success', 'Update Function -  Migrated Old Info to new Database', 'Database');
						@unlink($tempLock);
						return true;
					}
				}
				@unlink($tempLock);
				return false;
			} catch (Dibi\Exception $e) {
				writeLog('error', 'Update Function -  Error [' . $e . ']', 'Database');
				@unlink($tempLock);
				return false;
			}
		}
		@unlink($tempLock);
		return false;
	}
	return false;
}

function createFirstAdmin($path, $filename, $username, $password, $email)
{
	try {
		$createDB = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $path . $filename,
		]);
		$userInfo = [
			'username' => $username,
			'password' => password_hash($password, PASSWORD_BCRYPT),
			'email' => $email,
			'group' => 'Admin',
			'group_id' => 0,
			'image' => gravatar($email),
			'register_date' => $GLOBALS['currentTime'],
		];
		$groupInfo0 = [
			'group' => 'Admin',
			'group_id' => 0,
			'default' => false,
			'image' => 'plugins/images/groups/admin.png',
		];
		$groupInfo1 = [
			'group' => 'Co-Admin',
			'group_id' => 1,
			'default' => false,
			'image' => 'plugins/images/groups/coadmin.png',
		];
		$groupInfo2 = [
			'group' => 'Super User',
			'group_id' => 2,
			'default' => false,
			'image' => 'plugins/images/groups/superuser.png',
		];
		$groupInfo3 = [
			'group' => 'Power User',
			'group_id' => 3,
			'default' => false,
			'image' => 'plugins/images/groups/poweruser.png',
		];
		$groupInfo4 = [
			'group' => 'User',
			'group_id' => 4,
			'default' => true,
			'image' => 'plugins/images/groups/user.png',
		];
		$groupInfoGuest = [
			'group' => 'Guest',
			'group_id' => 999,
			'default' => false,
			'image' => 'plugins/images/groups/guest.png',
		];
		$settingsInfo = [
			'order' => 1,
			'category_id' => 0,
			'name' => 'Settings',
			'url' => 'api/?v1/settings/page',
			'default' => false,
			'enabled' => true,
			'group_id' => 1,
			'image' => 'fontawesome::cog',
			'type' => 0
		];
		$homepageInfo = [
			'order' => 2,
			'category_id' => 0,
			'name' => 'Homepage',
			'url' => 'api/?v1/homepage/page',
			'default' => false,
			'enabled' => false,
			'group_id' => 4,
			'image' => 'fontawesome::home',
			'type' => 0
		];
		$unsortedInfo = [
			'order' => 1,
			'category' => 'Unsorted',
			'category_id' => 0,
			'image' => 'plugins/images/categories/unsorted.png',
			'default' => true
		];
		$createDB->query('INSERT INTO [users]', $userInfo);
		$createDB->query('INSERT INTO [groups]', $groupInfo0);
		$createDB->query('INSERT INTO [groups]', $groupInfo1);
		$createDB->query('INSERT INTO [groups]', $groupInfo2);
		$createDB->query('INSERT INTO [groups]', $groupInfo3);
		$createDB->query('INSERT INTO [groups]', $groupInfo4);
		$createDB->query('INSERT INTO [groups]', $groupInfoGuest);
		$createDB->query('INSERT INTO [tabs]', $settingsInfo);
		$createDB->query('INSERT INTO [tabs]', $homepageInfo);
		$createDB->query('INSERT INTO [categories]', $unsortedInfo);
		return true;
	} catch (Dibi\Exception $e) {
		writeLog('error', 'Wizard Function -  Error [' . $e . ']', 'Wizard');
		return false;
	}
}

function defaultUserGroup()
{
	try {
		$connect = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
		]);
		$all = $connect->fetch('SELECT * FROM groups WHERE `default` = 1');
		return $all;
	} catch (Dibi\Exception $e) {
		return false;
	}
}

function defaultTabCategory()
{
	try {
		$connect = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
		]);
		$all = $connect->fetch('SELECT * FROM categories WHERE `default` = 1');
		return $all;
	} catch (Dibi\Exception $e) {
		return false;
	}
}

function getGuest()
{
	if (isset($GLOBALS['dbLocation'])) {
		try {
			$connect = new Dibi\Connection([
				'driver' => 'sqlite3',
				'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
			]);
			$all = $connect->fetch('SELECT * FROM groups WHERE `group_id` = 999');
			return $all;
		} catch (Dibi\Exception $e) {
			return false;
		}
	} else {
		return array(
			'group' => 'Guest',
			'group_id' => 999,
			'image' => 'plugins/images/groups/guest.png'
		);
	}
}

function adminEditGroup($array)
{
	switch ($array['data']['action']) {
		case 'changeDefaultGroup':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('UPDATE groups SET `default` = 0');
				$connect->query('
                	UPDATE groups SET', [
					'default' => 1
				], '
                	WHERE id=?', $array['data']['id']);
				writeLog('success', 'Group Management Function -  Changed Default Group from [' . $array['data']['oldGroupName'] . '] to [' . $array['data']['newGroupName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'deleteUserGroup':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('DELETE FROM groups WHERE id = ?', $array['data']['id']);
				writeLog('success', 'Group Management Function -  Deleted Group [' . $array['data']['groupName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'addUserGroup':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$newGroup = [
					'group' => $array['data']['newGroupName'],
					'group_id' => $array['data']['newGroupID'],
					'default' => false,
					'image' => $array['data']['newGroupImage'],
				];
				$connect->query('INSERT INTO [groups]', $newGroup);
				writeLog('success', 'Group Management Function -  Added Group [' . $array['data']['newGroupName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'editUserGroup':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                	UPDATE groups SET', [
					'group' => $array['data']['groupName'],
					'image' => $array['data']['groupImage'],
				], '
                	WHERE id=?', $array['data']['id']);
				writeLog('success', 'Group Management Function -  Edited Group Info for [' . $array['data']['oldGroupName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		default:
			return false;
			break;
	}
}

function adminEditUser($array)
{
	switch ($array['data']['action']) {
		case 'changeGroup':
			if ($array['data']['newGroupID'] == 0) {
				return false;
			}
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                	UPDATE users SET', [
					'group' => $array['data']['newGroupName'],
					'group_id' => $array['data']['newGroupID'],
				], '
                	WHERE id=?', $array['data']['id']);
				writeLog('success', 'User Management Function - User: ' . $array['data']['username'] . '\'s group was changed from [' . $array['data']['oldGroup'] . '] to [' . $array['data']['newGroupName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				writeLog('error', 'User Management Function - Error - User: ' . $array['data']['username'] . '\'s group was changed from [' . $array['data']['oldGroup'] . '] to [' . $array['data']['newGroupName'] . ']', $GLOBALS['organizrUser']['username']);
				return false;
			}
			break;
		case 'editUser':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				if (!usernameTakenExcept($array['data']['username'], $array['data']['email'], $array['data']['id'])) {
					$connect->query('
                        UPDATE users SET', [
						'username' => $array['data']['username'],
						'email' => $array['data']['email'],
						'image' => gravatar($array['data']['email']),
					], '
                        WHERE id=?', $array['data']['id']);
					if (!empty($array['data']['password'])) {
						$connect->query('
                            UPDATE users SET', [
							'password' => password_hash($array['data']['password'], PASSWORD_BCRYPT)
						], '
                            WHERE id=?', $array['data']['id']);
					}
					writeLog('success', 'User Management Function - User: ' . $array['data']['username'] . '\'s info was changed', $GLOBALS['organizrUser']['username']);
					return true;
				} else {
					return false;
				}
			} catch (Dibi\Exception $e) {
				writeLog('error', 'User Management Function - Error - User: ' . $array['data']['username'] . '\'s group was changed from [' . $array['data']['oldGroup'] . '] to [' . $array['data']['newGroupName'] . ']', $GLOBALS['organizrUser']['username']);
				return false;
			}
			break;
		case 'addNewUser':
			$defaults = defaultUserGroup();
			if (createUser($array['data']['username'], $array['data']['password'], $defaults, $array['data']['email'])) {
				writeLog('success', 'Create User Function - Account created for [' . $array['data']['username'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} else {
				writeLog('error', 'Registration Function - An error occurred', $GLOBALS['organizrUser']['username']);
				return 'username taken';
			}
			break;
		case 'deleteUser':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('DELETE FROM users WHERE id = ?', $array['data']['id']);
				writeLog('success', 'User Management Function -  Deleted User [' . $array['data']['username'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		default:
			return false;
			break;
	}
}

function editTabs($array)
{
	switch ($array['data']['action']) {
		case 'changeGroup':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                	UPDATE tabs SET', [
					'group_id' => $array['data']['newGroupID'],
				], '
                	WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function - Tab: ' . $array['data']['tab'] . '\'s group was changed to [' . $array['data']['newGroupName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changeCategory':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                        UPDATE tabs SET', [
					'category_id' => $array['data']['newCategoryID'],
				], '
                        WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function - Tab: ' . $array['data']['tab'] . '\'s category was changed to [' . $array['data']['newCategoryName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changeType':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                        UPDATE tabs SET', [
					'type' => $array['data']['newTypeID'],
				], '
                        WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function - Tab: ' . $array['data']['tab'] . '\'s type was changed to [' . $array['data']['newTypeName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changeEnabled':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                        UPDATE tabs SET', [
					'enabled' => $array['data']['tabEnabled'],
				], '
                        WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function - Tab: ' . $array['data']['tab'] . '\'s enable status was changed to [' . $array['data']['tabEnabledWord'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changeSplash':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                        UPDATE tabs SET', [
					'splash' => $array['data']['tabSplash'],
				], '
                        WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function - Tab: ' . $array['data']['tab'] . '\'s splash status was changed to [' . $array['data']['tabSplashWord'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changePing':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                        UPDATE tabs SET', [
					'ping' => $array['data']['tabPing'],
				], '
                        WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function - Tab: ' . $array['data']['tab'] . '\'s ping status was changed to [' . $array['data']['tabPingWord'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changePreload':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                        UPDATE tabs SET', [
					'preload' => $array['data']['tabPreload'],
				], '
                        WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function - Tab: ' . $array['data']['tab'] . '\'s preload status was changed to [' . $array['data']['tabPreloadWord'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changeDefault':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('UPDATE tabs SET `default` = 0');
				$connect->query('
                    UPDATE tabs SET', [
					'default' => 1
				], '
                    WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function -  Changed Default Tab to [' . $array['data']['tab'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'deleteTab':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('DELETE FROM tabs WHERE id = ?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function -  Deleted Tab [' . $array['data']['tab'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'editTab':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                    UPDATE tabs SET', [
					'name' => $array['data']['tabName'],
					'url' => $array['data']['tabURL'],
					'url_local' => $array['data']['tabLocalURL'],
					'ping_url' => $array['data']['pingURL'],
					'image' => $array['data']['tabImage'],
					'timeout' => $array['data']['tabActionType'],
					'timeout_ms' => $array['data']['tabActionTime'],
				], '
                    WHERE id=?', $array['data']['id']);
				writeLog('success', 'Tab Editor Function -  Edited Tab Info for [' . $array['data']['tabName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
		case 'changeOrder':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				foreach ($array['data']['tabs']['tab'] as $key => $value) {
					if ($value['order'] != $value['originalOrder']) {
						$connect->query('
                            UPDATE tabs SET', [
							'order' => $value['order'],
						], '
                            WHERE id=?', $value['id']);
						writeLog('success', 'Tab Editor Function - ' . $value['name'] . ' Order Changed From ' . $value['order'] . ' to ' . $value['originalOrder'], $GLOBALS['organizrUser']['username']);
					}
				}
				writeLog('success', 'Tab Editor Function - Tab Order Changed', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'addNewTab':
			try {
				$default = defaultTabCategory()['category_id'];
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$newTab = [
					'order' => $array['data']['tabOrder'],
					'category_id' => $default,
					'name' => $array['data']['tabName'],
					'url' => $array['data']['tabURL'],
					'url_local' => $array['data']['tabLocalURL'],
					'ping_url' => $array['data']['pingURL'],
					'default' => $array['data']['tabDefault'],
					'enabled' => 1,
					'group_id' => $array['data']['tabGroupID'],
					'image' => $array['data']['tabImage'],
					'type' => $array['data']['tabType'],
					'timeout' => $array['data']['tabActionType'],
					'timeout_ms' => $array['data']['tabActionTime'],
				];
				$connect->query('INSERT INTO [tabs]', $newTab);
				writeLog('success', 'Tab Editor Function - Created Tab for: ' . $array['data']['tabName'], $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		default:
			return false;
			break;
	}
}

function editCategories($array)
{
	switch ($array['data']['action']) {
		case 'changeDefault':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('UPDATE categories SET `default` = 0');
				$connect->query('
                	UPDATE categories SET', [
					'default' => 1
				], '
                	WHERE id=?', $array['data']['id']);
				writeLog('success', 'Category Editor Function -  Changed Default Category from [' . $array['data']['oldCategoryName'] . '] to [' . $array['data']['newCategoryName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'deleteCategory':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('DELETE FROM categories WHERE id = ?', $array['data']['id']);
				writeLog('success', 'Category Editor Function -  Deleted Category [' . $array['data']['category'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'addNewCategory':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$newCategory = [
					'category' => $array['data']['categoryName'],
					'order' => $array['data']['categoryOrder'],
					'category_id' => $array['data']['categoryID'],
					'default' => false,
					'image' => $array['data']['categoryImage'],
				];
				$connect->query('INSERT INTO [categories]', $newCategory);
				writeLog('success', 'Category Editor Function -  Added Category [' . $array['data']['categoryName'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return $e;
			}
			break;
		case 'editCategory':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				$connect->query('
                	UPDATE categories SET', [
					'category' => $array['data']['name'],
					'image' => $array['data']['image'],
				], '
                	WHERE id=?', $array['data']['id']);
				writeLog('success', 'Category Editor Function -  Edited Category Info for [' . $array['data']['name'] . ']', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		case 'changeOrder':
			try {
				$connect = new Dibi\Connection([
					'driver' => 'sqlite3',
					'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
				]);
				foreach ($array['data']['categories']['category'] as $key => $value) {
					if ($value['order'] != $value['originalOrder']) {
						$connect->query('
                            UPDATE categories SET', [
							'order' => $value['order'],
						], '
                            WHERE id=?', $value['id']);
						writeLog('success', 'Category Editor Function - ' . $value['name'] . ' Order Changed From ' . $value['order'] . ' to ' . $value['originalOrder'], $GLOBALS['organizrUser']['username']);
					}
				}
				writeLog('success', 'Category Editor Function - Category Order Changed', $GLOBALS['organizrUser']['username']);
				return true;
			} catch (Dibi\Exception $e) {
				return false;
			}
			break;
		default:
			return false;
			break;
	}
}

function allUsers()
{
	try {
		$connect = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
		]);
		$users = $connect->fetchAll('SELECT * FROM users');
		$groups = $connect->fetchAll('SELECT * FROM groups ORDER BY group_id ASC');
		foreach ($users as $k => $v) {
			// clear password from array
			unset($users[$k]['password']);
		}
		$all['users'] = $users;
		$all['groups'] = $groups;
		return $all;
	} catch (Dibi\Exception $e) {
		return false;
	}
}

function usernameTaken($username, $email)
{
	try {
		$connect = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
		]);
		$all = $connect->fetch('SELECT * FROM users WHERE username = ? COLLATE NOCASE OR email = ? COLLATE NOCASE', $username, $email);
		return ($all) ? true : false;
	} catch (Dibi\Exception $e) {
		return false;
	}
}

function usernameTakenExcept($username, $email, $id)
{
	try {
		$connect = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
		]);
		$all = $connect->fetch('SELECT * FROM users WHERE id IS NOT ? AND username = ? COLLATE NOCASE OR id IS NOT ? AND email = ? COLLATE NOCASE', $id, $username, $id, $email);
		return ($all) ? true : false;
	} catch (Dibi\Exception $e) {
		return false;
	}
}

function createUser($username, $password, $defaults, $email = null)
{
	$email = ($email) ? $email : random_ascii_string(10) . '@placeholder.eml';
	try {
		if (!usernameTaken($username, $email)) {
			$createDB = new Dibi\Connection([
				'driver' => 'sqlite3',
				'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
			]);
			$userInfo = [
				'username' => $username,
				'password' => password_hash($password, PASSWORD_BCRYPT),
				'email' => $email,
				'group' => $defaults['group'],
				'group_id' => $defaults['group_id'],
				'image' => gravatar($email),
				'register_date' => $GLOBALS['currentTime'],
			];
			$createDB->query('INSERT INTO [users]', $userInfo);
			return true;
		} else {
			return false;
		}
	} catch (Dibi\Exception $e) {
		return false;
	}
}

function importUsers($array)
{
	$imported = 0;
	$defaults = defaultUserGroup();
	foreach ($array as $user) {
		$password = random_ascii_string(30);
		if ($user['username'] !== '' && $user['email'] !== '' && $password !== '' && $defaults !== '') {
			$newUser = createUser($user['username'], $password, $defaults, $user['email']);
			if (!$newUser) {
				writeLog('error', 'Import Function - Error', $user['username']);
			} else {
				$imported++;
			}
		}
	}
	return $imported;
}

function importUsersType($array)
{
	$type = $array['data']['type'];
	if ($type !== '') {
		switch ($type) {
			case 'plex':
				return importUsers(allPlexUsers(true));
				break;
			default:
				return false;
		}
	}
	return false;
}

function allTabs()
{
	if (file_exists('config' . DIRECTORY_SEPARATOR . 'config.php')) {
		try {
			$connect = new Dibi\Connection([
				'driver' => 'sqlite3',
				'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
			]);
			$all['tabs'] = $connect->fetchAll('SELECT * FROM tabs ORDER BY `order` ASC');
			$all['categories'] = $connect->fetchAll('SELECT * FROM categories ORDER BY `order` ASC');
			$all['groups'] = $connect->fetchAll('SELECT * FROM groups ORDER BY `group_id` ASC');
			return $all;
		} catch (Dibi\Exception $e) {
			return false;
		}
	}
	return false;
}

function allGroups()
{
	if (file_exists('config' . DIRECTORY_SEPARATOR . 'config.php')) {
		try {
			$connect = new Dibi\Connection([
				'driver' => 'sqlite3',
				'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
			]);
			$all = $connect->fetchAll('SELECT * FROM groups ORDER BY `group_id` ASC');
			return $all;
		} catch (Dibi\Exception $e) {
			return false;
		}
	}
	return false;
}

function loadTabs($type = null)
{
	if (file_exists('config' . DIRECTORY_SEPARATOR . 'config.php') && $type) {
		try {
			$connect = new Dibi\Connection([
				'driver' => 'sqlite3',
				'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
			]);
			$sort = ($GLOBALS['unsortedTabs'] == 'top') ? 'DESC' : 'ASC';
			$tabs = $connect->fetchAll('SELECT * FROM tabs WHERE `group_id` >= ? AND `enabled` = 1 ORDER BY `order` ' . $sort, $GLOBALS['organizrUser']['groupID']);
			$categories = $connect->fetchAll('SELECT * FROM categories ORDER BY `order` ASC');
			$all['tabs'] = $tabs;
			foreach ($tabs as $k => $v) {
				$v['access_url'] = (!empty($v['url_local']) && ($v['url_local'] !== null) && ($v['url_local'] !== 'null') && isLocal() && $v['type'] !== 0) ? $v['url_local'] : $v['url'];
			}
			$count = array_map(function ($element) {
				return $element['category_id'];
			}, $tabs);
			$count = (array_count_values($count));
			foreach ($categories as $k => $v) {
				$v['count'] = isset($count[$v['category_id']]) ? $count[$v['category_id']] : 0;
			}
			$all['categories'] = $categories;
			switch ($type) {
				case 'categories':
					return $all['categories'];
				case 'tabs':
					return $all['tabs'];
				default:
					return $all;
			}
		} catch (Dibi\Exception $e) {
			return false;
		}
	}
	return false;
}

function getActiveTokens()
{
	try {
		$connect = new Dibi\Connection([
			'driver' => 'sqlite3',
			'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
		]);
		$all = $connect->fetchAll('SELECT * FROM `tokens` WHERE `user_id` = ? AND `expires` > ?', $GLOBALS['organizrUser']['userID'], $GLOBALS['currentTime']);
		return $all;
	} catch (Dibi\Exception $e) {
		return false;
	}
}

function revokeToken($array)
{
	if ($array['data']['token']) {
		try {
			$connect = new Dibi\Connection([
				'driver' => 'sqlite3',
				'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
			]);
			$connect->query('DELETE FROM tokens WHERE user_id = ? AND token = ?', $GLOBALS['organizrUser']['userID'], $array['data']['token']);
			return true;
		} catch (Dibi\Exception $e) {
			return false;
		}
	}
}

function getSchema()
{
	if (file_exists('config' . DIRECTORY_SEPARATOR . 'config.php')) {
		try {
			$connect = new Dibi\Connection([
				'driver' => 'sqlite3',
				'database' => $GLOBALS['dbLocation'] . $GLOBALS['dbName'],
			]);
			$result = $connect->fetchAll(' SELECT name, sql FROM sqlite_master WHERE type=\'table\' ORDER BY name');
			return $result;
		} catch (Dibi\Exception $e) {
			return false;
		}
	} else {
		return 'DB not set yet...';
	}
}

function youtubeSearch($query)
{
	if (!$query) {
		return 'no query provided!';
	}
	$keys = array('AIzaSyBsdt8nLJRMTwOq5PY5A5GLZ2q7scgn01w', 'AIzaSyD-8SHutB60GCcSM8q_Fle38rJUV7ujd8k', 'AIzaSyBzOpVBT6VII-b-8gWD0MOEosGg4hyhCsQ', 'AIzaSyBKnRe1P8fpfBHgooJpmT0WOsrdUtZ4cpk');
	$randomKeyIndex = array_rand($keys);
	$key = $keys[$randomKeyIndex];
	$apikey = ($GLOBALS['youtubeAPI'] !== '') ? $GLOBALS['youtubeAPI'] : $key;
	$results = false;
	$url = "https://www.googleapis.com/youtube/v3/search?part=snippet&q=$query+official+trailer&part=snippet&maxResults=1&type=video&videoDuration=short&key=$apikey";
	$response = Requests::get($url);
	if ($response->success) {
		$results = json_decode($response->body, true);
	}
	return ($results) ? $results : false;
}

function scrapePage($array)
{
	try {
		$url = $array['data']['url'] ?? false;
		$type = $array['data']['type'] ?? false;
		if (!$url) return array(
			'result' => 'Error',
			'data' => 'No URL'
		);
		$url = qualifyURL($url);
		$data = array(
			'full_url' => $url,
			'drill_url' => qualifyURL($url, true)
		);
		$options = array('verify' => false);
		$response = Requests::get($url, array(), $options);
		$data['response_code'] = $response->status_code;
		if ($response->success) {
			$data['result'] = 'Success';
			switch ($type) {
				case 'html':
					$data['data'] = html_entity_decode($response->body);
					break;
				case 'json':
					$data['data'] = json_decode($response->body);
					break;
				default:
					$data['data'] = $response->body;
			}
			return $data;
		}
	} catch (Requests_Exception $e) {
		return array(
			'result' => 'Error',
			'data' => $e->getMessage()
		);
	};
	return array('result' => 'Error');
}

function searchCityForCoordinates($array)
{
	try {
		$query = $array['data']['query'] ?? false;
		$url = qualifyURL('https://api.mapbox.com/geocoding/v5/mapbox.places/' . urlencode($query) . '.json?access_token=pk.eyJ1IjoiY2F1c2VmeCIsImEiOiJjazhyeGxqeXgwMWd2M2ZydWQ4YmdjdGlzIn0.R50iYuMewh1CnUZ7sFPdHA&limit=5&fuzzyMatch=true');
		$options = array('verify' => false);
		$response = Requests::get($url, array(), $options);
		if ($response->success) {
			return json_decode($response->body);
		}
	} catch (Requests_Exception $e) {
		return array(
			'result' => 'Error',
			'data' => $e->getMessage()
		);
	};
	return array('result' => 'Error');
}