mirror of
https://github.com/EGroupware/egroupware.git
synced 2024-11-28 10:53:39 +01:00
144 lines
3.3 KiB
PHP
144 lines
3.3 KiB
PHP
<?php
|
|
/**
|
|
* EGroupware - Filemanager Collab
|
|
*
|
|
* @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;
|
|
|
|
class filemanager_collab extends filemanager_collab_bo {
|
|
|
|
/**
|
|
* Methods callable via menuaction
|
|
*
|
|
* @var array
|
|
*/
|
|
var $public_functions = array(
|
|
'poll' => true
|
|
);
|
|
|
|
/**
|
|
* Constructor
|
|
*
|
|
*/
|
|
function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Join session, initialises edit session for opened file by user
|
|
*
|
|
* @param type $es_id session id
|
|
* @return array returns an array consists of session data
|
|
*/
|
|
function join_session ($es_id)
|
|
{
|
|
$response = $this->initSession($es_id);
|
|
$response += array (
|
|
'id' => $GLOBALS['egw_info']['user']['account_id'],
|
|
'full_name' => $GLOBALS['egw_info']['user']['account_fullname'],
|
|
'success' => true
|
|
);
|
|
|
|
return $response;
|
|
}
|
|
|
|
/**
|
|
* Polling mechanisim to sysncronise data
|
|
*
|
|
* @throws Exception
|
|
*/
|
|
function poll ()
|
|
{
|
|
// Get POST request payload
|
|
$payload = file_get_contents('php://input');
|
|
$params = $payload? json_decode ($payload, true): null;
|
|
$response = array();
|
|
if (is_array($params))
|
|
{
|
|
switch ($params['command'])
|
|
{
|
|
case 'join_session':
|
|
$response = $this->join_session($params['args']['es_id'],$params['args']['user_id']);
|
|
break;
|
|
case 'sync_ops':
|
|
try
|
|
{
|
|
$memberid = $params['args']['member_id']? $params['args']['member_id']: '';
|
|
$es_id = $params['args']['es_id'];
|
|
$seq_head = (string) isset($params['args']['seq_head'])? $params['args']['seq_head']: null;
|
|
if(!is_null($seq_head))
|
|
{
|
|
$client_ops = $params['args']['client_ops']? $params['args']['client_ops']: [];
|
|
$current_seq_head = $this->OP_getHeadSeq($es_id);
|
|
if ($seq_head == $current_seq_head) {
|
|
|
|
if (count($client_ops)>0)
|
|
{
|
|
$newHead = $this->get_newHead($es_id, $memberid, $client_ops);
|
|
$response = array(
|
|
'result' => 'added',
|
|
'head_seq' => $newHead ? $newHead : $current_seq_head
|
|
);
|
|
}
|
|
else
|
|
{
|
|
$response = array(
|
|
'result' => 'new_ops',
|
|
'ops' => array(),
|
|
'head_seq' => $current_seq_head
|
|
);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$response = array(
|
|
'result' => count($client_ops)>0 ? 'conflict' : 'new_ops',
|
|
'ops' => $this->OP_getOPSECS($es_id, $seq_head),
|
|
'head_seq' => $current_seq_head,
|
|
);
|
|
}
|
|
|
|
}
|
|
else
|
|
{
|
|
throw new Exception('Invalid seq head!');
|
|
}
|
|
} catch (Exception $ex) {
|
|
error_log($ex->getMessage());
|
|
}
|
|
|
|
break;
|
|
default:
|
|
//
|
|
}
|
|
}
|
|
header('content-type: application/json; charset=utf-8');
|
|
echo json_encode($response);
|
|
exit();
|
|
}
|
|
|
|
/**
|
|
* Function to get a new head sequence
|
|
*
|
|
* @param string $es_id session id
|
|
* @param string $member_id member id
|
|
* @param array $client_ops opspec from client side
|
|
*
|
|
* @return string return a seq head number
|
|
*/
|
|
function get_newHead ($es_id, $member_id, $client_ops)
|
|
{
|
|
$this->OP_addOPS($es_id, $member_id, $client_ops);
|
|
|
|
return $this->OP_getHeadSeq($es_id);
|
|
}
|
|
|
|
} |