diff --git a/ajax/settings.php b/ajax/settings.php index 9dd32dd..f040dba 100644 --- a/ajax/settings.php +++ b/ajax/settings.php @@ -75,20 +75,40 @@ if(isset($_POST['appname']) && ($_POST['appname'] === 'user_sql') && isset($_POS 'data' => array('message' => $l -> t('The selected SQL table '.$_POST['sql_table'].' does not exist!')))); break; } + if(!empty($_POST['sql_group_table']) && !$helper->verifyTable($parameters, $_POST['sql_driver'], $_POST['sql_group_table'])) + { + $response->setData(array('status' => 'error', + 'data' => array('message' => $l -> t('The selected SQL table '.$_POST['sql_group_table'].' does not exist!')))); + break; + } // Retrieve all column settings $columns = array(); + $group_columns = array(); foreach($params as $param) { if(strpos($param, 'col_') === 0) { if(isset($_POST[$param]) && $_POST[$param] !== '') - $columns[] = $_POST[$param]; + { + if(strpos($param, 'col_group_') === 0) + { + $group_columns[] = $_POST[$param]; + } + else + { + $columns[] = $_POST[$param]; + } + } } } // Check if the columns exist $status = $helper->verifyColumns($parameters, $_POST['sql_driver'], $_POST['sql_table'], $columns); + if(!empty($_POST['sql_group_table']) && $status === true) + { + $status = $helper->verifyColumns($parameters, $_POST['sql_driver'], $_POST['sql_group_table'], $group_columns); + } if($status !== true) { $response->setData(array('status' => 'error', diff --git a/appinfo/app.php b/appinfo/app.php index 2617fb9..28ac922 100644 --- a/appinfo/app.php +++ b/appinfo/app.php @@ -22,10 +22,13 @@ */ require_once __DIR__ . '/../user_sql.php'; +require_once __DIR__ . '/../group_sql.php'; \OCP\App::registerAdmin('user_sql','settings'); $backend = new \OCA\user_sql\OC_USER_SQL; +$group_backend = new \OCA\user_sql\OC_GROUP_SQL; // register user backend \OC_User::useBackend($backend); +\OC::$server->getGroupManager()->addBackend($group_backend); diff --git a/appinfo/info.xml b/appinfo/info.xml index 2b557d1..d2b6911 100644 --- a/appinfo/info.xml +++ b/appinfo/info.xml @@ -15,5 +15,6 @@ auth + diff --git a/group_sql.php b/group_sql.php new file mode 100644 index 0000000..08c8d76 --- /dev/null +++ b/group_sql.php @@ -0,0 +1,95 @@ + helper = new \OCA\user_sql\lib\Helper(); + $domain = \OC::$server->getRequest()->getServerHost(); + $this -> settings = $this -> helper -> loadSettingsForDomain($domain); + $this -> helper -> connectToDb($this -> settings); + return false; + } + + public function getUserGroups($uid) { + if(empty($this -> settings['sql_group_table'])) + { + \OCP\Util::writeLog('OC_USER_SQL', "Group table not configured", \OCP\Util::DEBUG); + return []; + } + $rows = $this -> helper -> runQuery('getUserGroups', array('uid' => $uid), false, true); + if($rows === false) + { + \OCP\Util::writeLog('OC_USER_SQL', "Found no group", \OCP\Util::DEBUG); + return []; + } + $groups = array(); + foreach($rows as $row) + { + $groups[] = $row[$this -> settings['col_group_name']]; + } + return $groups; + } + + public function getGroups($search = '', $limit = null, $offset = null) { + if(empty($this -> settings['sql_group_table'])) + { + return []; + } + $search = "%".$search."%"; + $rows = $this -> helper -> runQuery('getGroups', array('search' => $search), false, true, array('limit' => $limit, 'offset' => $offset)); + if($rows === false) + { + return []; + } + $groups = array(); + foreach($rows as $row) + { + $groups[] = $row[$this -> settings['col_group_name']]; + } + return $groups; + } + + public function usersInGroup($gid, $search = '', $limit = null, $offset = null) { + if(empty($this -> settings['sql_group_table'])) + { + \OCP\Util::writeLog('OC_USER_SQL', "Group table not configured", \OCP\Util::DEBUG); + return []; + } + $rows = $this -> helper -> runQuery('getGroupUsers', array('gid' => $gid), false, true); + if($rows === false) + { + \OCP\Util::writeLog('OC_USER_SQL', "Found no users for group", \OCP\Util::DEBUG); + return []; + } + $users = array(); + foreach($rows as $row) + { + $users[] = $row[$this -> settings['col_group_username']]; + } + return $users; + } + + public function countUsersInGroup($gid, $search = '') { + if(empty($this -> settings['sql_group_table'])) + { + return 0; + } + $search = "%".$search."%"; + $count = $this -> helper -> runQuery('countUsersInGroup', array('gid' => $gid, 'search' => $search)); + if($count === false) + { + return 0; + } else { + return intval(reset($count)); + } + } +} +?> diff --git a/js/settings.js b/js/settings.js index b6c6f4a..a1f5869 100644 --- a/js/settings.js +++ b/js/settings.js @@ -17,7 +17,7 @@ user_sql.adminSettingsUI = function() $('#sqlDiv').tabs(); // Attach auto-completion to all column fields - $('#col_username, #col_password, #col_displayname, #col_active, #col_email, #col_gethome').autocomplete({ + $('#col_username, #col_password, #col_displayname, #col_active, #col_email, #col_gethome, #col_group_name, #col_group_username').autocomplete({ source: function(request, response) { var post = $('#sqlForm').serializeArray(); @@ -56,7 +56,7 @@ user_sql.adminSettingsUI = function() }); // Attach auto-completion to all table fields - $('#sql_table').autocomplete({ + $('#sql_table, #sql_group_table').autocomplete({ source: function(request, response) { var post = $('#sqlForm').serializeArray(); diff --git a/lib/helper.php b/lib/helper.php index 56931ed..bdd68dc 100644 --- a/lib/helper.php +++ b/lib/helper.php @@ -66,7 +66,10 @@ class Helper { 'set_mail_sync_mode', 'set_enable_gethome', 'set_gethome_mode', - 'set_gethome' + 'set_gethome', + 'sql_group_table', + 'col_group_username', + 'col_group_name' ); return $params; @@ -175,6 +178,22 @@ class Helper { case 'mysqlPassword': $query = "SELECT PASSWORD(:pw);"; break; + + case 'getUserGroups': + $query = "SELECT ".$this->settings['col_group_name']." FROM ".$this->settings['sql_group_table']." WHERE ".$this->settings['col_group_username']." = :uid"; + break; + + case 'getGroups': + $query = "SELECT distinct ".$this->settings['col_group_name']." FROM ".$this->settings['sql_group_table']." WHERE ".$this->settings['col_group_name']." LIKE :search"; + break; + + case 'getGroupUsers': + $query = "SELECT distinct ".$this->settings['col_group_username']." FROM ".$this->settings['sql_group_table']." WHERE ".$this->settings['col_group_name']." = :gid"; + break; + + case 'countUsersInGroup': + $query = "SELECT count(".$this->settings['col_group_username'].") FROM ".$this->settings['sql_group_table']." WHERE ".$this->settings['col_group_name']." = :gid AND ".$this->settings['col_group_username']." LIKE :search"; + break; } if(isset($limits['limit']) && $limits['limit'] !== null) @@ -267,7 +286,7 @@ class Helper { if(!in_array($col, $columns, true)) { $res = false; - $err .= $col.' '; + $err .= $table.'.'.$col.' '; } } if($res) @@ -301,13 +320,19 @@ class Helper { try { $conn = $cm -> getConnection($sql_driver, $parameters); $platform = $conn -> getDatabasePlatform(); - $query = $platform -> getListTablesSQL(); - $result = $conn -> executeQuery($query); + + $queries = array( + 'Tables_in_'.$parameters['dbname'] => $platform -> getListTablesSQL(), + 'TABLE_NAME' => $platform -> getListViewsSQL($parameters['dbname'])); $ret = array(); - while($row = $result -> fetch()) + foreach($queries as $field => $query) { - $name = $row['Tables_in_'.$parameters['dbname']]; - $ret[] = $name; + $result = $conn -> executeQuery($query); + while($row = $result -> fetch()) + { + $name = $row[$field]; + $ret[] = $name; + } } return $ret; } diff --git a/templates/settings.php b/templates/settings.php index e2b1ad5..7fbdba9 100644 --- a/templates/settings.php +++ b/templates/settings.php @@ -21,6 +21,7 @@ $cfgClass = $ocVersion >= 7 ? 'section' : 'personalblock';
  • t('Domain Settings')); ?>
  • t('getHome Settings')); ?>
  • t('Supervisor Settings')); ?>
  • +
  • t('Groups Settings')); ?>
  • @@ -165,6 +166,16 @@ $cfgClass = $ocVersion >= 7 ? 'section' : 'personalblock';

    t("Use supervisor username and target username separated by ';' to login as target user using supervisor's password (ex. superuser;user).")); ?>

    + +
    +

    + +

    + +

    + +
    + diff --git a/user_sql.php b/user_sql.php index aacfee1..2009a15 100644 --- a/user_sql.php +++ b/user_sql.php @@ -31,7 +31,13 @@ namespace OCA\user_sql; use \OCA\user_sql\lib\Helper; -class OC_USER_SQL extends \OC_User_Backend implements \OCP\IUserBackend, \OCP\UserInterface +if(!interface_exists('OCP\\User\\IProvidesEMailBackend')) +{ + // hack for nextcloud + eval("namespace OCP\User; interface IProvidesEMailBackend {}"); +} + +class OC_USER_SQL extends \OC_User_Backend implements \OCP\IUserBackend, \OCP\UserInterface, \OCP\User\IProvidesEMailBackend { protected $cache; protected $settings; @@ -116,6 +122,15 @@ class OC_USER_SQL extends \OC_User_Backend implements \OCP\IUserBackend, \OCP\Us return true; } + /** + * Only used by OwnCloud to get the email address + */ + public function getEMailAddress($uid) { + $this->doEmailSync($uid); + $email = $this->ocConfig->getUserValue($uid, 'settings', 'email', ''); + return $email; + } + /** * This maps the username to the specified domain name. * It can only append a default domain name. @@ -406,7 +421,7 @@ class OC_USER_SQL extends \OC_User_Backend implements \OCP\IUserBackend, \OCP\Us } else { - $search = "%".$this -> doUserDomainMapping("")."%"; + $search = "%".$this -> doUserDomainMapping("")."%"; } $rows = $this -> helper -> runQuery('getUsers', array('search' => $search), false, true, array('limit' => $limit, 'offset' => $offset));