You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
219 lines
5.7 KiB
PHP
219 lines
5.7 KiB
PHP
<?php
|
|
|
|
/**
|
|
* ownCloud - Documents App
|
|
*
|
|
* @author Victor Dubiniuk
|
|
* @copyright 2013 Victor Dubiniuk victor.dubiniuk@gmail.com
|
|
*
|
|
* This file is licensed under the Affero General Public License version 3 or
|
|
* later.
|
|
*/
|
|
|
|
namespace OCA\Documents\Db;
|
|
|
|
use OCP\Security\ISecureRandom;
|
|
|
|
use OCA\Documents\Filter;
|
|
|
|
/**
|
|
* Session management
|
|
*
|
|
* @method string getEsId()
|
|
* @method int getFileId()
|
|
* @method string getGenesisUrl()
|
|
* @method string getOwner()
|
|
* @method string getGenesisHash()
|
|
*
|
|
*/
|
|
class Session extends \OCA\Documents\Db {
|
|
|
|
/**
|
|
* DB table
|
|
*/
|
|
const DB_TABLE = '`*PREFIX*documents_session`';
|
|
protected $tableName = '`*PREFIX*documents_session`';
|
|
|
|
protected $insertStatement = 'INSERT INTO `*PREFIX*documents_session` (`es_id`, `genesis_url`, `genesis_hash`, `owner`, `file_id`)
|
|
VALUES (?, ?, ?, ?, ?)';
|
|
|
|
protected $loadStatement = 'SELECT * FROM `*PREFIX*documents_session` WHERE `es_id`= ?';
|
|
|
|
/**
|
|
* Start a editing session or return an existing one
|
|
* @param string $uid of the user starting a session
|
|
* @param \OCA\Documents\File $file - file object
|
|
* @return array
|
|
* @throws \Exception
|
|
*/
|
|
public static function start($uid, $file){
|
|
// Create a directory to store genesis
|
|
$genesis = new \OCA\Documents\Genesis($file);
|
|
|
|
list($ownerView, $path) = $file->getOwnerViewAndPath();
|
|
$mimetype = $ownerView->getMimeType($path);
|
|
if (!Filter::isSupportedMimetype($mimetype)){
|
|
throw new \Exception( $path . ' is ' . $mimetype . ' and is not supported by Documents app');
|
|
}
|
|
$oldSession = new Session();
|
|
$oldSession->loadBy('file_id', $file->getFileId());
|
|
|
|
//If there is no existing session we need to start a new one
|
|
if (!$oldSession->hasData()){
|
|
$newSession = new Session(array(
|
|
$genesis->getPath(),
|
|
$genesis->getHash(),
|
|
$file->getOwner(),
|
|
$file->getFileId()
|
|
));
|
|
|
|
if (!$newSession->insert()){
|
|
throw new \Exception('Failed to add session into database');
|
|
}
|
|
}
|
|
|
|
$sessionData = $oldSession
|
|
->loadBy('file_id', $file->getFileId())
|
|
->getData()
|
|
;
|
|
|
|
$memberColor = \OCA\Documents\Helper::getMemberColor($uid);
|
|
$member = new \OCA\Documents\Db\Member(array(
|
|
$sessionData['es_id'],
|
|
$uid,
|
|
$memberColor,
|
|
time(),
|
|
intval($file->isPublicShare()),
|
|
$file->getToken()
|
|
));
|
|
|
|
if (!$member->insert()){
|
|
throw new \Exception('Failed to add member into database');
|
|
}
|
|
$sessionData['member_id'] = (string) $member->getLastInsertId();
|
|
|
|
// Do we have OC_Avatar in out disposal?
|
|
if (\OC::$server->getConfig()->getSystemValue('enable_avatars', true) !== true){
|
|
$imageUrl = 'data:image/gif;base64,R0lGODlhAQABAIAAAAAAAAAAACH5BAAAAAAALAAAAAABAAEAAAICTAEAOw==';
|
|
} else {
|
|
$imageUrl = $uid;
|
|
}
|
|
|
|
$displayName = $file->isPublicShare()
|
|
? $uid . ' ' . \OCA\Documents\Db\Member::getGuestPostfix()
|
|
: \OC::$server->getUserSession()->getUser()->getDisplayName($uid)
|
|
;
|
|
$userId = $file->isPublicShare() ? $displayName : \OC::$server->getUserSession()->getUser()->getUID();
|
|
$op = new \OCA\Documents\Db\Op();
|
|
$op->addMember(
|
|
$sessionData['es_id'],
|
|
$sessionData['member_id'],
|
|
$displayName,
|
|
$userId,
|
|
$memberColor,
|
|
$imageUrl
|
|
);
|
|
|
|
$sessionData['title'] = basename($path);
|
|
$fileInfo = $ownerView->getFileInfo($path);
|
|
$sessionData['permissions'] = $fileInfo->getPermissions();
|
|
|
|
return $sessionData;
|
|
}
|
|
|
|
public static function cleanUp($esId){
|
|
$session = new Session();
|
|
$session->deleteBy('es_id', $esId);
|
|
|
|
$member = new \OCA\Documents\Db\Member();
|
|
$member->deleteBy('es_id', $esId);
|
|
|
|
$op= new \OCA\Documents\Db\Op();
|
|
$op->deleteBy('es_id', $esId);
|
|
}
|
|
|
|
|
|
public function syncOps($memberId, $currentHead, $clientHead, $clientOps){
|
|
$hasOps = count($clientOps)>0;
|
|
$op = new \OCA\Documents\Db\Op();
|
|
|
|
// TODO handle the case ($currentHead == "") && ($seqHead != "")
|
|
if ($clientHead == $currentHead) {
|
|
// matching heads
|
|
if ($hasOps) {
|
|
// incoming ops without conflict
|
|
// Add incoming ops, respond with a new head
|
|
$newHead = \OCA\Documents\Db\Op::addOpsArray($this->getEsId(), $memberId, $clientOps);
|
|
$result = array(
|
|
'result' => 'added',
|
|
'head_seq' => $newHead ? $newHead : $currentHead
|
|
);
|
|
} else {
|
|
// no incoming ops (just checking for new ops...)
|
|
$result = array(
|
|
'result' => 'new_ops',
|
|
'ops' => array(),
|
|
'head_seq' => $currentHead
|
|
);
|
|
}
|
|
} else { // HEADs do not match
|
|
$result = array(
|
|
'result' => $hasOps ? 'conflict' : 'new_ops',
|
|
'ops' => $op->getOpsAfterJson($this->getEsId(), $clientHead),
|
|
'head_seq' => $currentHead,
|
|
);
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
|
|
public function insert(){
|
|
$esId = $this->getUniqueSessionId();
|
|
array_unshift($this->data, $esId);
|
|
return parent::insert();
|
|
}
|
|
|
|
public function updateGenesisHash($esId, $genesisHash){
|
|
return $this->execute(
|
|
'UPDATE `*PREFIX*documents_session` SET `genesis_hash`=? WHERE `es_id`=?',
|
|
array(
|
|
$genesisHash, $esId
|
|
)
|
|
);
|
|
}
|
|
|
|
public function getInfo($esId){
|
|
$result = $this->execute('
|
|
SELECT `s`.*, COUNT(`m`.`member_id`) AS `users`
|
|
FROM ' . $this->tableName . ' AS `s`
|
|
LEFT JOIN `*PREFIX*documents_member` AS `m` ON `s`.`es_id`=`m`.`es_id`
|
|
AND `m`.`status`=' . Db\Member::MEMBER_STATUS_ACTIVE . '
|
|
AND `m`.`uid` != ?
|
|
WHERE `s`.`es_id` = ?
|
|
GROUP BY `m`.`es_id`
|
|
',
|
|
[
|
|
\OC::$server->getUserSession()->getUser()->getUID(),
|
|
$esId
|
|
]
|
|
);
|
|
|
|
$info = $result->fetch();
|
|
if (!is_array($info)){
|
|
$info = array();
|
|
}
|
|
return $info;
|
|
}
|
|
|
|
protected function getUniqueSessionId(){
|
|
$testSession = new Session();
|
|
do{
|
|
$id = \OC::$server->getSecureRandom()
|
|
->getMediumStrengthGenerator()
|
|
->generate(30, ISecureRandom::CHAR_LOWER . ISecureRandom::CHAR_DIGITS);
|
|
} while ($testSession->load($id)->hasData());
|
|
|
|
return $id;
|
|
}
|
|
}
|