egroupware/filemanager/inc/class.filemanager_collab_bo.inc.php

<?php
/**
 * Filemanager collab session Class
 *
 * @link http://www.egroupware.org
 * @package filemanager
 * @author Hadi Nategh <hn-AT-stylite.de>
 * @copyright (c) 2016 by Stylite AG
 * @license http://opensource.org/licenses/gpl-license.php GPL - GNU General Public License
 * @version $Id$
 */

use EGroupware\Api;

/**
 * Storage Object of the filemanager
 */
class filemanager_collab_bo
{

	/**
	 * session table name
	 */
	const SESSION_TABLE = 'egw_collab_session';

	/**
	 * member table name
	 */
	const MEMBER_TABLE = 'egw_collab_member';

	/**
	 * op table name
	 */
	const OP_TABLE = 'egw_collab_op';

	/**
	 * prefix value used for naming fields in DB
	 */
	const DB_FILEDS_PREFIX = 'collab_';

	/**
	 * Database object
	 * @var Api\Db
	 */
	protected $db;

	public function __construct()
	{
		$this->db = $GLOBALS['egw']->db;
	}

	/**
	 * Init session check for existing session or create one there's none
	 *
	 * @param string $es_id session id
	 *
	 * @return array returns an array contains of mapped session data
	 */
	protected function initSession ($es_id)
	{
		$session = $this->db->select(self::SESSION_TABLE,'*', array('collab_es_id' => $es_id));
		$full_name = $GLOBALS['egw_info']['user']['account_fullname'];
		$color = $GLOBALS['egw_info']['user']['prefs']['collab_user_color'];
		$user_id = $GLOBALS['egw_info']['user']['account_id'];


		if (!($result = self::db2id($session->fields)) && $es_id)
		{
			$result = self::db2id($this->SESSION_add2Db($es_id));
		}

		$this->MEMBER_add2Db($es_id, $user_id, $color);

		$member_id = $this->MEMBER_getLastMember();

		$this->OP_addMember($es_id, $member_id, $full_name, $user_id, $color);
	}

	/**
	 * Add session data with provided session id into DB
	 *
	 * @param string $es_id session id
	 *
	 * @return array returns an array contains of session data
	 */
	protected function SESSION_add2Db ($es_id)
	{
		if ($es_id)
		{
			$data = array (
				'collab_es_id' => $es_id,
				'collab_genesis_url' => '',
				'collab_genesis_hash' => '',
				'account_id' => $GLOBALS['egw_info']['user']['account_id']
			);

			$this->db->insert(self::SESSION_TABLE, $data,false,__LINE__, __FILE__,'filemanager');
		}
		return $data;
	}


	/**
	 * OP addMember function is backend equivalent to addMember from frontend
	 *
	 * @param string $es_id session id
	 * @param string $member_id
	 * @param string $full_name
	 * @param string $user_id
	 * @param string $color
	 * @param string $imageUrl
	 */
	protected function OP_addMember($es_id, $member_id, $full_name, $user_id, $color, $imageUrl)
	{
		$date = new DateTime();
		$op = array(
			'optype' => 'AddMember',
			'member' => (string) $member_id,
			'timestamp' => $date->getTimestamp(),
			'setProperties' => array(
				'fullName' => $full_name,
				'color' => $color,
				'imageUrl' => $imageUrl,
				'uid' => $user_id,
			)
		);
		$this->OP_add2Db($op, $es_id);
	}

	/**
	 * Function to get top head seq for a given session
	 *
	 * @param string $es_id
	 *
	 * @return string returns head seq or '' if none exists
	 * @throws Exception throws exception if no session is given
	 */
	protected function OP_getHeadSeq($es_id)
	{
		if (!$es_id) throw new Exception ('Session id must be given, none given!');

		$headSeq = $this->db->select(
				self::OP_TABLE,
				'collab_seq',
				array('collab_es_id' => $es_id),
				__LINE__,
				__FILE__,
				FALSE,
				'ORDER BY collab_seq DESC LIMIT 1',
				'filemanager'
		);

		return $headSeq->fields? $headSeq->fields['collab_seq']: '';
	}

	/**
	 * Insert op data into OP table in database
	 *
	 * @param array $op op data
	 * @param string $es_id session id
	 */
	protected function OP_add2Db ($op, $es_id)
	{
		$data = array (
			'collab_es_id' => $es_id,
			'collab_member' => $op['member'],
			'collab_optype' => $op['optype'],
			'collab_opspec' => json_encode($op)
		);
		$this->db->insert(self::OP_TABLE, $data,false,__LINE__, __FILE__,'filemanager');
	}

	/**
	 * Add member data into member table in database
	 *
	 * @param type $es_id session id
	 * @param type $user_id user id
	 * @param type $color user color code
	 */
	protected function MEMBER_add2Db ($es_id, $user_id, $color)
	{
		$data = array (
			'collab_es_id' => $es_id,
			'collab_uid' => $user_id,
			'collab_color' => $color
		);
		$this->db->insert(self::MEMBER_TABLE, $data,false,__LINE__, __FILE__,'filemanager');
	}

	/**
	 * Function to get member record of specific member id
	 *
	 * @param string $member_id member id
	 *
	 * @return array returns an array consist of member record
	 * @throws Exception throws exception if no member id is given
	 */
	protected function MEMBER_getMember ($member_id)
	{
		if (!$member_id) throw new Exception ('Member id must be given, none given!');
		$member = $this->db->select(
				self::MEMBER_TABLE,
				'*',
				array('collab_member_id' => $member_id),
				__LINE__,
				__FILE__
		);

		return $member->fields? self::db2id($member->fileds): [];
	}

	/**
	 * Utility function to map DB fields to ids
	 *
	 * @param array $data
	 * @return array|boolean returns an array contains of mapped DB data, otherwise false
	 */
	protected static function db2id($data)
	{
		if (!is_array($data)) return false;
		$keys = array_keys($data);
		array_walk($keys,function (&$key){$key = str_replace(self::DB_FILEDS_PREFIX, '', $key);});
		return array_combine ($keys, $data);
	}

	/**
	 * Return last member id from member table in db
	 *
	 * @return int returns the last member id or if it's not exist returns 0
	 */
	protected function MEMBER_getLastMember()
	{
		$last_row = $this->db->select(
				self::MEMBER_TABLE,
				'collab_member_id',
				'',
				__LINE__,
				__FILE__,
				false,
				"ORDER BY `collab_member_id` DESC LIMIT 1;"
		);

		return $last_row->fields? $last_row->fields['collab_member_id']: 0;
	}
}