940 lines
24 KiB
PHP
Executable File
940 lines
24 KiB
PHP
Executable File
<?php
|
|
|
|
// Pandora FMS - http://pandorafms.com
|
|
// ==================================================
|
|
// Copyright (c) 2005-2009 Artica Soluciones Tecnologicas
|
|
// Please see http://pandorafms.org for full contribution list
|
|
|
|
// This program is free software; you can redistribute it and/or
|
|
// modify it under the terms of the GNU Lesser General Public License
|
|
// as published by the Free Software Foundation; version 2
|
|
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
|
|
/**
|
|
* @package Include
|
|
* @subpackage Users
|
|
*/
|
|
|
|
require_once($config['homedir'] . "/include/functions_groups.php");
|
|
|
|
function users_is_strict_acl($id_user = null) {
|
|
global $config;
|
|
|
|
if (empty($id_user)) {
|
|
$id_user = $config['id_user'];
|
|
}
|
|
|
|
$strict_acl = (bool)db_get_value('strict_acl', 'tusuario',
|
|
'id_user', $id_user);
|
|
|
|
return $strict_acl;
|
|
}
|
|
|
|
/**
|
|
* Get a list of all users in an array [username] => (info)
|
|
*
|
|
* @param string Field to order by (id_usuario, nombre_real or fecha_registro)
|
|
* @param string Which info to get (defaults to nombre_real)
|
|
*
|
|
* @return array An array of users
|
|
*/
|
|
function users_get_info ($order = "fullname", $info = "fullname") {
|
|
$users = get_users ($order);
|
|
|
|
$ret = array ();
|
|
foreach ($users as $user_id => $user_info) {
|
|
$ret[$user_id] = $user_info[$info];
|
|
}
|
|
|
|
return $ret;
|
|
}
|
|
|
|
/**
|
|
* Enable/Disable a user
|
|
*
|
|
* @param int user id
|
|
* @param int new disabled value (0 when enable, 1 when disable)
|
|
*
|
|
* @return int sucess return
|
|
*/
|
|
function users_disable ($user_id, $new_disabled_value) {
|
|
return db_process_sql_update('tusuario',
|
|
array('disabled' => $new_disabled_value), array('id_user' => $user_id));
|
|
}
|
|
|
|
/**
|
|
* Get all the Model groups a user has reading privileges.
|
|
*
|
|
* @param string User id
|
|
* @param string The privilege to evaluate
|
|
*
|
|
* @return array A list of the groups the user has certain privileges.
|
|
*/
|
|
function users_get_all_model_groups () {
|
|
$groups = db_get_all_rows_in_table ('tmodule_group');
|
|
if ($groups === false) {
|
|
$groups = array();
|
|
}
|
|
|
|
$returnGroups = array();
|
|
foreach ($groups as $group)
|
|
$returnGroups[$group['id_mg']] = $group['name'];
|
|
|
|
$returnGroups[0] = "Not assigned"; //Module group external to DB but it exist
|
|
|
|
|
|
return $returnGroups;
|
|
}
|
|
|
|
/**
|
|
* Get all the groups a user has reading privileges with the special format to use it on select.
|
|
*
|
|
* @param string User id
|
|
* @param string The privilege to evaluate, and it is false then no check ACL.
|
|
* @param boolean $returnAllGroup Flag the return group, by default true.
|
|
* @param boolean $returnAllColumns Flag to return all columns of groups.
|
|
* @param array $id_groups The id of node that must do not show the children and own.
|
|
* @param string $keys_field The field of the group used in the array keys. By default ID
|
|
*
|
|
* @return array A list of the groups the user has certain privileges.
|
|
*/
|
|
function users_get_groups_for_select($id_user, $privilege = "AR", $returnAllGroup = true, $returnAllColumns = false, $id_groups = null, $keys_field = 'id_grupo') {
|
|
if ($id_groups === false) {
|
|
$id_groups = null;
|
|
}
|
|
|
|
$user_groups = users_get_groups ($id_user, $privilege, $returnAllGroup, $returnAllColumns, null);
|
|
|
|
if ($id_groups !== null) {
|
|
$childrens = groups_get_childrens($id_groups);
|
|
foreach ($childrens as $child) {
|
|
unset($user_groups[$child['id_grupo']]);
|
|
}
|
|
unset($user_groups[$id_groups]);
|
|
}
|
|
|
|
if (empty($user_groups)) {
|
|
$user_groups_tree = array();
|
|
}
|
|
else {
|
|
// First group it's needed to retrieve its parent group
|
|
$first_group = array_slice($user_groups, 0, 1);
|
|
$first_group = reset($first_group);
|
|
$parent_group = $first_group['parent'];
|
|
|
|
$user_groups_tree = groups_get_groups_tree_recursive($user_groups, $parent_group);
|
|
}
|
|
$fields = array();
|
|
|
|
foreach ($user_groups_tree as $group) {
|
|
$groupName = ui_print_truncate_text($group['nombre'], GENERIC_SIZE_TEXT, false, true, false);
|
|
|
|
$fields[$group[$keys_field]] = str_repeat(" ", $group['deep']) . $groupName;
|
|
}
|
|
|
|
return $fields;
|
|
}
|
|
|
|
/**
|
|
* Get all the groups a user has reading privileges.
|
|
*
|
|
* @param string User id
|
|
* @param string The privilege to evaluate, and it is false then no check ACL.
|
|
* @param boolean $returnAllGroup Flag the return group, by default true.
|
|
* @param boolean $returnAllColumns Flag to return all columns of groups.
|
|
* @param array $id_groups The list of group to scan to bottom child. By default null.
|
|
* @param string $keys_field The field of the group used in the array keys. By default ID
|
|
*
|
|
* @return array A list of the groups the user has certain privileges.
|
|
*/
|
|
function users_get_groups ($id_user = false, $privilege = "AR", $returnAllGroup = true, $returnAllColumns = false,
|
|
$id_groups = null, $keys_field = 'id_grupo', $cache = true) {
|
|
static $group_cache = array();
|
|
|
|
if (empty ($id_user)) {
|
|
global $config;
|
|
|
|
$id_user = null;
|
|
if (isset($config['id_user'])) {
|
|
$id_user = $config['id_user'];
|
|
}
|
|
}
|
|
|
|
// Check the group cache first.
|
|
if (array_key_exists($id_user, $group_cache) && $cache) {
|
|
$groups = $group_cache[$id_user];
|
|
} else {
|
|
// Admin.
|
|
if (is_user_admin($id_user)) {
|
|
$groups = db_get_all_rows_sql ("SELECT * FROM tgrupo ORDER BY nombre");
|
|
}
|
|
// Per-group permissions.
|
|
else {
|
|
$query = sprintf("SELECT tgrupo.*, tperfil.*, tusuario_perfil.tags FROM tgrupo, tusuario_perfil, tperfil
|
|
WHERE (tgrupo.id_grupo = tusuario_perfil.id_grupo OR tusuario_perfil.id_grupo = 0)
|
|
AND tusuario_perfil.id_perfil = tperfil.id_perfil
|
|
AND tusuario_perfil.id_usuario = '%s' ORDER BY nombre", $id_user);
|
|
$groups = db_get_all_rows_sql ($query);
|
|
|
|
// Get children groups.
|
|
$parent_ids = array();
|
|
$parents = $groups;
|
|
$seen = array();
|
|
while (!empty($parents)) {
|
|
$children = array();
|
|
foreach ($parents as $parent) {
|
|
// Do not process the same parent twice.
|
|
if (array_key_exists($parent['id_grupo'], $seen)) {
|
|
continue;
|
|
}
|
|
$seen[$parent['id_grupo']] = 1;
|
|
|
|
// Does this group propagate ACLs?
|
|
if ($parent['propagate'] == '0') {
|
|
continue;
|
|
}
|
|
|
|
// Save a list of parents in the tree to search for user profiles, including the current parent!
|
|
$parent_ids[$parent['id_grupo']] = isset($parent_ids[$parent['parent']]) ? array_merge(array($parent['id_grupo']), $parent_ids[$parent['parent']]) : array($parent['id_grupo']);
|
|
|
|
// Get children groups from the DB.
|
|
$query = sprintf("SELECT tgrupo.*, tperfil.*, tusuario_perfil.tags FROM tgrupo, tusuario_perfil, tperfil
|
|
WHERE tgrupo.parent = %d
|
|
AND tusuario_perfil.id_grupo IN (%s)
|
|
AND tusuario_perfil.id_perfil = tperfil.id_perfil
|
|
AND tusuario_perfil.id_usuario = '%s'", $parent['id_grupo'], join(',', $parent_ids[$parent['id_grupo']]), $id_user);
|
|
$local_children = db_get_all_rows_sql ($query);
|
|
if (!empty($local_children)) {
|
|
$children = array_merge($children, $local_children);
|
|
}
|
|
}
|
|
|
|
if (!empty($children)) {
|
|
$groups = array_merge($groups, $children);
|
|
}
|
|
|
|
// Move down in the hierarchy.
|
|
$parents = $children;
|
|
}
|
|
}
|
|
|
|
// Update the group cache.
|
|
$group_cache[$id_user] = $groups;
|
|
}
|
|
|
|
$user_groups = array ();
|
|
if (!$groups) {
|
|
return $user_groups;
|
|
}
|
|
|
|
if ($returnAllGroup) { //All group
|
|
$groupall = array('id_grupo' => 0, 'nombre' => __('All'),
|
|
'icon' => 'world', 'parent' => 0, 'disabled' => 0,
|
|
'custom_id' => null, 'description' => '', 'propagate' => 0);
|
|
|
|
// Add the All group to the beginning to be always the first
|
|
array_unshift($groups, $groupall);
|
|
}
|
|
|
|
$acl_column = get_acl_column($privilege);
|
|
foreach ($groups as $group) {
|
|
|
|
# Check the specific permission column. acl_column is undefined for admins.
|
|
if (defined($group[$acl_column]) && $group[$acl_column] != '1') {
|
|
continue;
|
|
}
|
|
|
|
if ($returnAllColumns) {
|
|
$user_groups[$group[$keys_field]] = $group;
|
|
}
|
|
else {
|
|
$user_groups[$group[$keys_field]] = $group['nombre'];
|
|
}
|
|
}
|
|
|
|
return $user_groups;
|
|
}
|
|
|
|
/**
|
|
* Get all the groups a user has reading privileges. Version for tree groups.
|
|
*
|
|
* @param string User id
|
|
* @param string The privilege to evaluate
|
|
* @param boolean $returnAllGroup Flag the return group, by default true.
|
|
* @param boolean $returnAllColumns Flag to return all columns of groups.
|
|
*
|
|
* @return array A treefield list of the groups the user has certain privileges.
|
|
*/
|
|
function users_get_groups_tree($id_user = false, $privilege = "AR", $returnAllGroup = true) {
|
|
$user_groups = users_get_groups ($id_user, $privilege, $returnAllGroup, true);
|
|
|
|
$user_groups_tree = groups_get_groups_tree_recursive($user_groups);
|
|
|
|
return $user_groups_tree;
|
|
}
|
|
|
|
/**
|
|
* Get the first group of an user.
|
|
*
|
|
* Useful function when you need a default group for a user.
|
|
*
|
|
* @param string User id
|
|
* @param string The privilege to evaluate
|
|
* @param bool $all_group Flag to return all group, by default true;
|
|
*
|
|
* @return array The first group where the user has certain privileges.
|
|
*/
|
|
function users_get_first_group ($id_user = false, $privilege = "AR", $all_group = true) {
|
|
$groups = array_keys (users_get_groups ($id_user, $privilege));
|
|
|
|
$return = array_shift($groups);
|
|
|
|
if ((!$all_group) && ($return == 0)) {
|
|
$return = array_shift($groups);
|
|
}
|
|
|
|
return $return;
|
|
}
|
|
|
|
/**
|
|
* Return access to a specific agent by a specific user
|
|
*
|
|
* @param int Agent id.
|
|
* @param string Access mode to be checked. Default AR (Agent reading)
|
|
* @param string User id. Current user by default
|
|
*
|
|
* @return bool Access to that agent (false not, true yes)
|
|
*/
|
|
function users_access_to_agent ($id_agent, $mode = "AR", $id_user = false) {
|
|
if (empty ($id_agent))
|
|
return false;
|
|
|
|
if ($id_user == false) {
|
|
global $config;
|
|
$id_user = $config['id_user'];
|
|
}
|
|
|
|
$id_group = (int) db_get_value ('id_grupo', 'tagente', 'id_agente', (int) $id_agent);
|
|
|
|
return (bool) check_acl ($id_user, $id_group, $mode);
|
|
}
|
|
|
|
/**
|
|
* Return user by id (user name)
|
|
*
|
|
* @param string User id.
|
|
*
|
|
* @return mixed User row or false if something goes wrong
|
|
*/
|
|
function users_get_user_by_id ($id_user) {
|
|
$result_user = db_get_row('tusuario', 'id_user', $id_user);
|
|
|
|
return $result_user;
|
|
}
|
|
|
|
define("MAX_TIMES", 10);
|
|
|
|
////////////////////////////////////////////////////////////////////////
|
|
//////////////////////WEBCHAT FUNCTIONS/////////////////////////////////
|
|
////////////////////////////////////////////////////////////////////////
|
|
function users_get_last_messages($last_time = false) {
|
|
$file_global_counter_chat = $config["attachment_store"] . '/pandora_chat.global_counter.txt';
|
|
|
|
//First lock the file
|
|
$fp_global_counter = @fopen($file_global_counter_chat, "a+");
|
|
if ($fp_global_counter === false) {
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
//Try to look MAX_TIMES times
|
|
$tries = 0;
|
|
while (!flock($fp_global_counter, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
fscanf($fp_global_counter, "%d", $global_counter_file);
|
|
if (empty($global_counter_file)) {
|
|
$global_counter_file = 0;
|
|
}
|
|
|
|
$timestamp = time();
|
|
if ($last_time === false)
|
|
$last_time = 24 * 60 * 60;
|
|
$from = $timestamp - $last_time;
|
|
|
|
$log_chat_file = $config["attachment_store"] . '/pandora_chat.log.json.txt';
|
|
|
|
$return = array('correct' => false, 'log' => array());
|
|
|
|
if (!file_exists($log_chat_file)) {
|
|
touch($log_chat_file);
|
|
}
|
|
|
|
$text_encode = @file_get_contents($log_chat_file);
|
|
$log = json_decode($text_encode, true);
|
|
|
|
if ($log !== false) {
|
|
if ($log === null)
|
|
$log = array();
|
|
|
|
$log_last_time = array();
|
|
foreach ($log as $message) {
|
|
if ($message['timestamp'] >= $from) {
|
|
$log_last_time[] = $message;
|
|
}
|
|
}
|
|
|
|
$return['correct'] = true;
|
|
$return['log'] = $log_last_time;
|
|
$return['global_counter'] = $global_counter_file;
|
|
}
|
|
|
|
echo json_encode($return);
|
|
|
|
fclose($fp_global_counter);
|
|
|
|
return;
|
|
}
|
|
|
|
function users_save_login() {
|
|
global $config;
|
|
|
|
$file_global_user_list = $config["attachment_store"] . '/pandora_chat.user_list.json.txt';
|
|
|
|
$user = db_get_row_filter('tusuario',
|
|
array('id_user' => $config['id_user']));
|
|
|
|
$message = sprintf(__('User %s login at %s'), $user['fullname'],
|
|
date($config['date_format']));
|
|
users_save_text_message($message, 'notification');
|
|
|
|
//First lock the file
|
|
$fp_user_list = @fopen($file_global_user_list, "a+");
|
|
if ($fp_user_list === false) {
|
|
return;
|
|
}
|
|
//Try to look MAX_TIMES times
|
|
$tries = 0;
|
|
while (!flock($fp_user_list, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
return;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
@fscanf($fp_user_list, "%[^\n]", $user_list_json);
|
|
|
|
$user_list = json_decode($user_list_json, true);
|
|
if (empty($user_list))
|
|
$user_list = array();
|
|
|
|
if (isset($user_list[$config['id_user']])) {
|
|
$user_list[$config['id_user']]['count']++;
|
|
}
|
|
else {
|
|
$user_list[$config['id_user']] = array('name' => $user['fullname'],
|
|
'count' => 1);
|
|
}
|
|
|
|
//Clean the file
|
|
ftruncate($fp_user_list, 0);
|
|
|
|
$status = fwrite($fp_user_list, json_encode($user_list));
|
|
|
|
if ($status === false) {
|
|
fclose($fp_user_list);
|
|
|
|
return;
|
|
}
|
|
|
|
fclose($fp_user_list);
|
|
}
|
|
|
|
function users_save_logout($user = false, $delete = false) {
|
|
global $config;
|
|
|
|
$return = array('correct' => false, 'users' => array());
|
|
|
|
$file_global_user_list = $config["attachment_store"] . '/pandora_chat.user_list.json.txt';
|
|
|
|
if (empty($user)) {
|
|
$user = db_get_row_filter('tusuario',
|
|
array('id_user' => $config['id_user']));
|
|
}
|
|
|
|
if ($delete) {
|
|
$no_json_output = true;
|
|
$message = sprintf(__('User %s was deleted in the DB at %s'),
|
|
$user['fullname'], date($config['date_format']));
|
|
}
|
|
else {
|
|
$no_json_output = false;
|
|
$message = sprintf(__('User %s logout at %s'), $user['fullname'],
|
|
date($config['date_format']));
|
|
}
|
|
|
|
users_save_text_message($message, 'notification', $no_json_output);
|
|
|
|
//First lock the file
|
|
$fp_user_list = @fopen($file_global_user_list, "a+");
|
|
if ($fp_user_list === false) {
|
|
return;
|
|
}
|
|
//Try to look MAX_TIMES times
|
|
$tries = 0;
|
|
while (!flock($fp_user_list, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
return;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
@fscanf($fp_user_list, "%[^\n]", $user_list_json);
|
|
|
|
$user_list = json_decode($user_list_json, true);
|
|
if (empty($user_list))
|
|
$user_list = array();
|
|
|
|
if ($delete) {
|
|
unset($user_list[$user['id_user']]);
|
|
}
|
|
else {
|
|
if (isset($user_list[$config['id_user']])) {
|
|
$user_list[$config['id_user']]['count']--;
|
|
}
|
|
|
|
if ($user_list[$config['id_user']]['count'] <= 0) {
|
|
unset($user_list[$user['id_user']]);
|
|
}
|
|
}
|
|
|
|
//Clean the file
|
|
ftruncate($fp_user_list, 0);
|
|
|
|
$status = fwrite($fp_user_list, json_encode($user_list));
|
|
|
|
if ($status === false) {
|
|
fclose($fp_user_list);
|
|
|
|
return;
|
|
}
|
|
|
|
fclose($fp_user_list);
|
|
}
|
|
|
|
function users_save_text_message($message = false, $type = 'message', $no_json_output = false) {
|
|
global $config;
|
|
|
|
$file_global_counter_chat = $config["attachment_store"] . '/pandora_chat.global_counter.txt';
|
|
$log_chat_file = $config["attachment_store"] . '/pandora_chat.log.json.txt';
|
|
|
|
$return = array('correct' => false);
|
|
|
|
$id_user = $config['id_user'];
|
|
$user = db_get_row_filter('tusuario',
|
|
array('id_user' => $id_user));
|
|
|
|
$message_data = array();
|
|
$message_data['type'] = $type;
|
|
$message_data['id_user'] = $id_user;
|
|
$message_data['user_name'] = $user['fullname'];
|
|
$message_data['text'] = io_safe_input_html($message);
|
|
//The $message_data['timestamp'] set when adquire the files to save.
|
|
|
|
|
|
|
|
//First lock the file
|
|
$fp_global_counter = @fopen($file_global_counter_chat, "a+");
|
|
if ($fp_global_counter === false) {
|
|
if (!$no_json_output)
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
//Try to look MAX_TIMES times
|
|
$tries = 0;
|
|
while (!flock($fp_global_counter, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
if (!$no_json_output)
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
@fscanf($fp_global_counter, "%d", $global_counter_file);
|
|
if (empty($global_counter_file)) {
|
|
$global_counter_file = 0;
|
|
}
|
|
|
|
//Clean the file
|
|
ftruncate($fp_global_counter, 0);
|
|
|
|
$message_data['timestamp'] = time();
|
|
$message_data['human_time'] = date($config['date_format'], $message_data['timestamp']);
|
|
|
|
$global_counter = $global_counter_file + 1;
|
|
|
|
$status = fwrite($fp_global_counter, $global_counter);
|
|
|
|
if ($status === false) {
|
|
fclose($fp_global_counter);
|
|
|
|
if (!$no_json_output)
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
else {
|
|
$text_encode = @file_get_contents($log_chat_file);
|
|
$log = json_decode($text_encode, true);
|
|
$log[$global_counter] = $message_data;
|
|
$status = file_put_contents($log_chat_file, json_encode($log));
|
|
|
|
fclose($fp_global_counter);
|
|
|
|
$return['correct'] = true;
|
|
if (!$no_json_output)
|
|
echo json_encode($return);
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
function users_long_polling_check_messages($global_counter) {
|
|
global $config;
|
|
|
|
$file_global_counter_chat = $config["attachment_store"] . '/pandora_chat.global_counter.txt';
|
|
$log_chat_file = $config["attachment_store"] . '/pandora_chat.log.json.txt';
|
|
|
|
$changes = false;
|
|
|
|
$tries_general = 0;
|
|
|
|
$error = false;
|
|
|
|
while (!$changes) {
|
|
//First lock the file
|
|
$fp_global_counter = @fopen($file_global_counter_chat, "a+");
|
|
if ($fp_global_counter) {
|
|
//Try to look MAX_TIMES times
|
|
$tries = 0;
|
|
$lock = true;
|
|
while (!flock($fp_global_counter, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
$lock = false;
|
|
$error = true;
|
|
break;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
|
|
if ($lock) {
|
|
@fscanf($fp_global_counter, "%d", $global_counter_file);
|
|
if (empty($global_counter_file)) {
|
|
$global_counter_file = 0;
|
|
}
|
|
|
|
if ($global_counter_file > $global_counter) {
|
|
//TODO Optimize slice the array.
|
|
|
|
$text_encode = @file_get_contents($log_chat_file);
|
|
$log = json_decode($text_encode, true);
|
|
|
|
$return_log = array();
|
|
foreach ($log as $key => $message) {
|
|
if ($key <= $global_counter) continue;
|
|
|
|
$return_log[] = $message;
|
|
}
|
|
|
|
$return = array(
|
|
'correct' => true,
|
|
'global_counter' => $global_counter_file,
|
|
'log' => $return_log);
|
|
|
|
echo json_encode($return);
|
|
|
|
fclose($fp_global_counter);
|
|
|
|
return;
|
|
}
|
|
}
|
|
fclose($fp_global_counter);
|
|
}
|
|
|
|
sleep(3);
|
|
$tries_general = $tries_general + 3;
|
|
|
|
if ($tries_general > MAX_TIMES) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
//Because maybe the exit of loop for exaust.
|
|
echo json_encode(array('correct' => false, 'error' => $error));
|
|
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* Get the last global counter for chat.
|
|
*
|
|
* @param string $mode There are two modes 'json', 'return' and 'session'. And json is by default.
|
|
*/
|
|
function users_get_last_global_counter($mode = 'json') {
|
|
global $config;
|
|
|
|
$file_global_counter_chat = $config["attachment_store"] . '/pandora_chat.global_counter.txt';
|
|
|
|
$global_counter_file = 0;
|
|
|
|
$fp_global_counter = @fopen($file_global_counter_chat, "a+");
|
|
if ($fp_global_counter) {
|
|
$tries = 0;
|
|
$lock = true;
|
|
while (!flock($fp_global_counter, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
$lock = false;
|
|
break;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
|
|
if ($lock) {
|
|
@fscanf($fp_global_counter, "%d", $global_counter_file);
|
|
if (empty($global_counter_file)) {
|
|
$global_counter_file = 0;
|
|
}
|
|
|
|
fclose($fp_global_counter);
|
|
}
|
|
}
|
|
|
|
switch ($mode) {
|
|
case 'json':
|
|
echo json_encode(array('correct' => true, 'global_counter' => $global_counter_file));
|
|
break;
|
|
case 'return':
|
|
return $global_counter_file;
|
|
break;
|
|
case 'session':
|
|
$_SESSION['global_counter_chat'] = $global_counter_file;
|
|
break;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Get the last global counter for chat.
|
|
*
|
|
* @param string $mode There are two modes 'json', 'return' and 'session'. And json is by default.
|
|
*/
|
|
function users_get_last_type_message() {
|
|
global $config;
|
|
|
|
$return = 'false';
|
|
|
|
$file_global_counter_chat = $config["attachment_store"] . '/pandora_chat.global_counter.txt';
|
|
$log_chat_file = $config["attachment_store"] . '/pandora_chat.log.json.txt';
|
|
|
|
$global_counter_file = 0;
|
|
|
|
$fp_global_counter = @fopen($file_global_counter_chat, "a+");
|
|
if ($fp_global_counter) {
|
|
$tries = 0;
|
|
$lock = true;
|
|
while (!flock($fp_global_counter, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
$lock = false;
|
|
break;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
|
|
if ($lock) {
|
|
$text_encode = @file_get_contents($log_chat_file);
|
|
$log = json_decode($text_encode, true);
|
|
|
|
// Prevent from error when chat file log doesn't exists
|
|
if (empty($log))
|
|
$return = false;
|
|
else {
|
|
$last = end($log);
|
|
$return = $last['type'];
|
|
}
|
|
|
|
fclose($fp_global_counter);
|
|
}
|
|
}
|
|
|
|
return $return;
|
|
}
|
|
|
|
function users_is_admin($id_user = false) {
|
|
global $config;
|
|
|
|
if ($id_user === false) {
|
|
$id_user = $config['id_user'];
|
|
}
|
|
|
|
$is_admin = (bool)db_get_value('is_admin',
|
|
'tusuario', 'id_user', $id_user);
|
|
|
|
return $is_admin;
|
|
}
|
|
|
|
function users_is_last_system_message() {
|
|
$type = users_get_last_type_message();
|
|
|
|
if ($type != 'message')
|
|
return true;
|
|
else
|
|
return false;
|
|
}
|
|
|
|
function users_check_users() {
|
|
global $config;
|
|
|
|
$return = array('correct' => false, 'users' => '');
|
|
|
|
$file_global_user_list = $config["attachment_store"] . '/pandora_chat.user_list.json.txt';
|
|
|
|
//First lock the file
|
|
$fp_user_list = @fopen($file_global_user_list, "a+");
|
|
if ($fp_user_list === false) {
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
//Try to look MAX_TIMES times
|
|
$tries = 0;
|
|
while (!flock($fp_user_list, LOCK_EX)) {
|
|
$tries++;
|
|
if ($tries > MAX_TIMES) {
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
|
|
sleep(1);
|
|
}
|
|
@fscanf($fp_user_list, "%[^\n]", $user_list_json);
|
|
|
|
$user_list = json_decode($user_list_json, true);
|
|
if (empty($user_list))
|
|
$user_list = array();
|
|
|
|
fclose($fp_user_list);
|
|
|
|
$user_name_list = array();
|
|
foreach ($user_list as $user) {
|
|
$user_name_list[] = $user['name'];
|
|
}
|
|
|
|
$return['correct'] = true;
|
|
$return['users'] = implode('<br />', $user_name_list);
|
|
echo json_encode($return);
|
|
|
|
return;
|
|
}
|
|
|
|
// Check if a user can manage a group when group is all
|
|
// This function dont check acls of the group, only if the
|
|
// user is admin or pandora manager and the group is all
|
|
function users_can_manage_group_all($access = "PM") {
|
|
global $config;
|
|
|
|
$is_admin = db_get_value('is_admin', 'tusuario', 'id_user', $config['id_user']);
|
|
|
|
if (check_acl ($config['id_user'], 0, $access, true) || $is_admin) {
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Get the users that belongs to the same groups of the current user
|
|
*
|
|
* @param string User id
|
|
* @param string The privilege to evaluate, and it is false then no check ACL.
|
|
* @param boolean $returnAllGroup Flag the return group, by default true.
|
|
*
|
|
* @return mixed Array with id_user as index and value
|
|
*/
|
|
function users_get_user_users($id_user = false, $privilege = "AR",
|
|
$returnAllGroup = true, $fields = null) {
|
|
|
|
global $config;
|
|
|
|
$user_groups = users_get_groups($id_user, $privilege, $returnAllGroup);
|
|
|
|
$user_users = array();
|
|
$array_user_group = array();
|
|
|
|
foreach ($user_groups as $id_user_group => $name_user_group) {
|
|
$array_user_group[] = $id_user_group;
|
|
}
|
|
|
|
$group_users = groups_get_users($array_user_group, false, $returnAllGroup);
|
|
|
|
foreach ($group_users as $gu) {
|
|
if (empty($fields)) {
|
|
$user_users[$gu['id_user']] = $gu['id_user'];
|
|
}
|
|
else {
|
|
$fields = (array)$fields;
|
|
foreach ($fields as $field) {
|
|
$user_users[$gu['id_user']][$field] = $gu[$field];
|
|
}
|
|
}
|
|
}
|
|
|
|
return $user_users;
|
|
}
|
|
|
|
function users_get_strict_mode_groups($id_user, $return_group_all) {
|
|
|
|
global $config;
|
|
|
|
$sql = "SELECT * FROM tusuario_perfil WHERE id_usuario = '".$id_user."' AND tags = ''";
|
|
$user_groups = db_get_all_rows_sql ($sql);
|
|
|
|
if ($user_groups == false) {
|
|
$user_groups = array();
|
|
}
|
|
|
|
$return_user_groups = array();
|
|
if ($return_group_all) {
|
|
$return_user_groups[0] = __('All');
|
|
}
|
|
foreach ($user_groups as $group) {
|
|
$return_user_groups[$group['id_grupo']] = groups_get_name ($group['id_grupo']);
|
|
}
|
|
|
|
return $return_user_groups;
|
|
}
|
|
|
|
?>
|