123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065 |
- <?php
- namespace OCA\FederatedFileSharing;
- use OC\Share20\Exception\InvalidShare;
- use OC\Share20\Share;
- use OCP\Constants;
- use OCP\DB\QueryBuilder\IQueryBuilder;
- use OCP\Federation\ICloudFederationProviderManager;
- use OCP\Federation\ICloudIdManager;
- use OCP\Files\Folder;
- use OCP\Files\IRootFolder;
- use OCP\Files\Node;
- use OCP\Files\NotFoundException;
- use OCP\IConfig;
- use OCP\IDBConnection;
- use OCP\IL10N;
- use OCP\IUserManager;
- use OCP\Share\Exceptions\GenericShareException;
- use OCP\Share\Exceptions\ShareNotFound;
- use OCP\Share\IShare;
- use OCP\Share\IShareProvider;
- use Psr\Log\LoggerInterface;
- class FederatedShareProvider implements IShareProvider {
- public const SHARE_TYPE_REMOTE = 6;
-
- private $externalShareTable = 'share_external';
-
- private $supportedShareType = [IShare::TYPE_REMOTE_GROUP, IShare::TYPE_REMOTE, IShare::TYPE_CIRCLE];
-
- public function __construct(
- private IDBConnection $dbConnection,
- private AddressHandler $addressHandler,
- private Notifications $notifications,
- private TokenHandler $tokenHandler,
- private IL10N $l,
- private IRootFolder $rootFolder,
- private IConfig $config,
- private IUserManager $userManager,
- private ICloudIdManager $cloudIdManager,
- private \OCP\GlobalScale\IConfig $gsConfig,
- private ICloudFederationProviderManager $cloudFederationProviderManager,
- private LoggerInterface $logger,
- ) {
- }
-
- public function identifier() {
- return 'ocFederatedSharing';
- }
-
- public function create(IShare $share) {
- $shareWith = $share->getSharedWith();
- $itemSource = $share->getNodeId();
- $itemType = $share->getNodeType();
- $permissions = $share->getPermissions();
- $sharedBy = $share->getSharedBy();
- $shareType = $share->getShareType();
- $expirationDate = $share->getExpirationDate();
- if ($shareType === IShare::TYPE_REMOTE_GROUP &&
- !$this->isOutgoingServer2serverGroupShareEnabled()
- ) {
- $message = 'It is not allowed to send federated group shares from this server.';
- $message_t = $this->l->t('It is not allowed to send federated group shares from this server.');
- $this->logger->debug($message, ['app' => 'Federated File Sharing']);
- throw new \Exception($message_t);
- }
-
- $alreadyShared = $this->getSharedWith($shareWith, IShare::TYPE_REMOTE, $share->getNode(), 1, 0);
- $alreadySharedGroup = $this->getSharedWith($shareWith, IShare::TYPE_REMOTE_GROUP, $share->getNode(), 1, 0);
- if (!empty($alreadyShared) || !empty($alreadySharedGroup)) {
- $message = 'Sharing %1$s failed, because this item is already shared with %2$s';
- $message_t = $this->l->t('Sharing %1$s failed, because this item is already shared with the account %2$s', [$share->getNode()->getName(), $shareWith]);
- $this->logger->debug(sprintf($message, $share->getNode()->getName(), $shareWith), ['app' => 'Federated File Sharing']);
- throw new \Exception($message_t);
- }
-
- $cloudId = $this->cloudIdManager->resolveCloudId($shareWith);
- $currentServer = $this->addressHandler->generateRemoteURL();
- $currentUser = $sharedBy;
- if ($this->addressHandler->compareAddresses($cloudId->getUser(), $cloudId->getRemote(), $currentUser, $currentServer)) {
- $message = 'Not allowed to create a federated share to the same account.';
- $message_t = $this->l->t('Not allowed to create a federated share to the same account');
- $this->logger->debug($message, ['app' => 'Federated File Sharing']);
- throw new \Exception($message_t);
- }
-
- if (($share->getPermissions() & Constants::PERMISSION_READ) === 0) {
- $message = 'Federated shares require read permissions';
- $message_t = $this->l->t('Federated shares require read permissions');
- $this->logger->debug($message, ['app' => 'Federated File Sharing']);
- throw new \Exception($message_t);
- }
- $share->setSharedWith($cloudId->getId());
- try {
- $remoteShare = $this->getShareFromExternalShareTable($share);
- } catch (ShareNotFound $e) {
- $remoteShare = null;
- }
- if ($remoteShare) {
- try {
- $ownerCloudId = $this->cloudIdManager->getCloudId($remoteShare['owner'], $remoteShare['remote']);
- $shareId = $this->addShareToDB($itemSource, $itemType, $shareWith, $sharedBy, $ownerCloudId->getId(), $permissions, 'tmp_token_' . time(), $shareType, $expirationDate);
- $share->setId($shareId);
- [$token, $remoteId] = $this->askOwnerToReShare($shareWith, $share, $shareId);
-
- $send = is_string($token) && $token !== '';
- } catch (\Exception $e) {
-
-
- $this->removeShareFromTable($share);
- $shareId = $this->createFederatedShare($share);
- }
- if ($send) {
- $this->updateSuccessfulReshare($shareId, $token);
- $this->storeRemoteId($shareId, $remoteId);
- } else {
- $this->removeShareFromTable($share);
- $message_t = $this->l->t('File is already shared with %s', [$shareWith]);
- throw new \Exception($message_t);
- }
- } else {
- $shareId = $this->createFederatedShare($share);
- }
- $data = $this->getRawShare($shareId);
- return $this->createShareObject($data);
- }
-
- protected function createFederatedShare(IShare $share) {
- $token = $this->tokenHandler->generateToken();
- $shareId = $this->addShareToDB(
- $share->getNodeId(),
- $share->getNodeType(),
- $share->getSharedWith(),
- $share->getSharedBy(),
- $share->getShareOwner(),
- $share->getPermissions(),
- $token,
- $share->getShareType(),
- $share->getExpirationDate()
- );
- $failure = false;
- try {
- $sharedByFederatedId = $share->getSharedBy();
- if ($this->userManager->userExists($sharedByFederatedId)) {
- $cloudId = $this->cloudIdManager->getCloudId($sharedByFederatedId, $this->addressHandler->generateRemoteURL());
- $sharedByFederatedId = $cloudId->getId();
- }
- $ownerCloudId = $this->cloudIdManager->getCloudId($share->getShareOwner(), $this->addressHandler->generateRemoteURL());
- $send = $this->notifications->sendRemoteShare(
- $token,
- $share->getSharedWith(),
- $share->getNode()->getName(),
- $shareId,
- $share->getShareOwner(),
- $ownerCloudId->getId(),
- $share->getSharedBy(),
- $sharedByFederatedId,
- $share->getShareType()
- );
- if ($send === false) {
- $failure = true;
- }
- } catch (\Exception $e) {
- $this->logger->error('Failed to notify remote server of federated share, removing share.', [
- 'app' => 'federatedfilesharing',
- 'exception' => $e,
- ]);
- $failure = true;
- }
- if ($failure) {
- $this->removeShareFromTableById($shareId);
- $message_t = $this->l->t('Sharing %1$s failed, could not find %2$s, maybe the server is currently unreachable or uses a self-signed certificate.',
- [$share->getNode()->getName(), $share->getSharedWith()]);
- throw new \Exception($message_t);
- }
- return $shareId;
- }
-
- protected function askOwnerToReShare($shareWith, IShare $share, $shareId) {
- $remoteShare = $this->getShareFromExternalShareTable($share);
- $token = $remoteShare['share_token'];
- $remoteId = $remoteShare['remote_id'];
- $remote = $remoteShare['remote'];
- [$token, $remoteId] = $this->notifications->requestReShare(
- $token,
- $remoteId,
- $shareId,
- $remote,
- $shareWith,
- $share->getPermissions(),
- $share->getNode()->getName()
- );
- return [$token, $remoteId];
- }
-
- protected function getShareFromExternalShareTable(IShare $share) {
- $query = $this->dbConnection->getQueryBuilder();
- $query->select('*')->from($this->externalShareTable)
- ->where($query->expr()->eq('user', $query->createNamedParameter($share->getShareOwner())))
- ->andWhere($query->expr()->eq('mountpoint', $query->createNamedParameter($share->getTarget())));
- $qResult = $query->execute();
- $result = $qResult->fetchAll();
- $qResult->closeCursor();
- if (isset($result[0]) && (int)$result[0]['remote_id'] > 0) {
- return $result[0];
- }
- throw new ShareNotFound('share not found in share_external table');
- }
-
- private function addShareToDB($itemSource, $itemType, $shareWith, $sharedBy, $uidOwner, $permissions, $token, $shareType, $expirationDate) {
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->insert('share')
- ->setValue('share_type', $qb->createNamedParameter($shareType))
- ->setValue('item_type', $qb->createNamedParameter($itemType))
- ->setValue('item_source', $qb->createNamedParameter($itemSource))
- ->setValue('file_source', $qb->createNamedParameter($itemSource))
- ->setValue('share_with', $qb->createNamedParameter($shareWith))
- ->setValue('uid_owner', $qb->createNamedParameter($uidOwner))
- ->setValue('uid_initiator', $qb->createNamedParameter($sharedBy))
- ->setValue('permissions', $qb->createNamedParameter($permissions))
- ->setValue('expiration', $qb->createNamedParameter($expirationDate, IQueryBuilder::PARAM_DATE))
- ->setValue('token', $qb->createNamedParameter($token))
- ->setValue('stime', $qb->createNamedParameter(time()));
-
- $qb->setValue('file_target', $qb->createNamedParameter(''));
- $qb->execute();
- return $qb->getLastInsertId();
- }
-
- public function update(IShare $share) {
-
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->update('share')
- ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
- ->set('permissions', $qb->createNamedParameter($share->getPermissions()))
- ->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
- ->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
- ->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
- ->execute();
-
- if ($share->getShareOwner() !== $share->getSharedBy()) {
- $this->sendPermissionUpdate($share);
- }
- return $share;
- }
-
- protected function sendPermissionUpdate(IShare $share) {
- $remoteId = $this->getRemoteId($share);
-
- if ($this->userManager->userExists($share->getShareOwner())) {
- [, $remote] = $this->addressHandler->splitUserRemote($share->getSharedBy());
- } else {
- [, $remote] = $this->addressHandler->splitUserRemote($share->getShareOwner());
- }
- $this->notifications->sendPermissionChange($remote, $remoteId, $share->getToken(), $share->getPermissions());
- }
-
- protected function updateSuccessfulReShare($shareId, $token) {
- $query = $this->dbConnection->getQueryBuilder();
- $query->update('share')
- ->where($query->expr()->eq('id', $query->createNamedParameter($shareId)))
- ->set('token', $query->createNamedParameter($token))
- ->execute();
- }
-
- public function storeRemoteId(int $shareId, string $remoteId): void {
- $query = $this->dbConnection->getQueryBuilder();
- $query->insert('federated_reshares')
- ->values(
- [
- 'share_id' => $query->createNamedParameter($shareId),
- 'remote_id' => $query->createNamedParameter($remoteId),
- ]
- );
- $query->execute();
- }
-
- public function getRemoteId(IShare $share): string {
- $query = $this->dbConnection->getQueryBuilder();
- $query->select('remote_id')->from('federated_reshares')
- ->where($query->expr()->eq('share_id', $query->createNamedParameter((int)$share->getId())));
- $result = $query->execute();
- $data = $result->fetch();
- $result->closeCursor();
- if (!is_array($data) || !isset($data['remote_id'])) {
- throw new ShareNotFound();
- }
- return (string)$data['remote_id'];
- }
-
- public function move(IShare $share, $recipient) {
-
- return $share;
- }
-
- public function getChildren(IShare $parent) {
- $children = [];
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('*')
- ->from('share')
- ->where($qb->expr()->eq('parent', $qb->createNamedParameter($parent->getId())))
- ->andWhere($qb->expr()->in('share_type', $qb->createNamedParameter($this->supportedShareType, IQueryBuilder::PARAM_INT_ARRAY)))
- ->orderBy('id');
- $cursor = $qb->execute();
- while ($data = $cursor->fetch()) {
- $children[] = $this->createShareObject($data);
- }
- $cursor->closeCursor();
- return $children;
- }
-
- public function delete(IShare $share) {
- [, $remote] = $this->addressHandler->splitUserRemote($share->getSharedWith());
-
- if ($this->userManager->userExists($share->getShareOwner())) {
- $this->notifications->sendRemoteUnShare($remote, $share->getId(), $share->getToken());
- $this->revokeShare($share, true);
- } else {
- $remoteId = $this->getRemoteId($share);
- $this->notifications->sendRemoteUnShare($remote, $remoteId, $share->getToken());
- $this->revokeShare($share, false);
- }
-
-
- $this->removeShareFromTable($share);
- }
-
- protected function revokeShare($share, $isOwner) {
- if ($this->userManager->userExists($share->getShareOwner()) && $this->userManager->userExists($share->getSharedBy())) {
-
- return;
- }
-
- if ($share->getShareOwner() !== $share->getSharedBy()) {
- if ($isOwner) {
- [, $remote] = $this->addressHandler->splitUserRemote($share->getSharedBy());
- } else {
- [, $remote] = $this->addressHandler->splitUserRemote($share->getShareOwner());
- }
- $remoteId = $this->getRemoteId($share);
- $this->notifications->sendRevokeShare($remote, $remoteId, $share->getToken());
- }
- }
-
- public function removeShareFromTable(IShare $share) {
- $this->removeShareFromTableById($share->getId());
- }
-
- private function removeShareFromTableById($shareId) {
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->delete('share')
- ->where($qb->expr()->eq('id', $qb->createNamedParameter($shareId)))
- ->andWhere($qb->expr()->neq('share_type', $qb->createNamedParameter(IShare::TYPE_CIRCLE)));
- $qb->execute();
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->delete('federated_reshares')
- ->where($qb->expr()->eq('share_id', $qb->createNamedParameter($shareId)));
- $qb->execute();
- }
-
- public function deleteFromSelf(IShare $share, $recipient) {
-
-
-
-
- }
- public function restore(IShare $share, string $recipient): IShare {
- throw new GenericShareException('not implemented');
- }
- public function getSharesInFolder($userId, Folder $node, $reshares, $shallow = true) {
- if (!$shallow) {
- throw new \Exception("non-shallow getSharesInFolder is no longer supported");
- }
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('*')
- ->from('share', 's')
- ->andWhere($qb->expr()->orX(
- $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
- $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
- ))
- ->andWhere(
- $qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_REMOTE))
- );
-
- if ($reshares === false) {
- $qb->andWhere($qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId)));
- } else {
- $qb->andWhere(
- $qb->expr()->orX(
- $qb->expr()->eq('uid_owner', $qb->createNamedParameter($userId)),
- $qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId))
- )
- );
- }
- $qb->innerJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'));
- $qb->andWhere($qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId())));
- $qb->orderBy('id');
- $cursor = $qb->execute();
- $shares = [];
- while ($data = $cursor->fetch()) {
- $shares[$data['fileid']][] = $this->createShareObject($data);
- }
- $cursor->closeCursor();
- return $shares;
- }
-
- public function getSharesBy($userId, $shareType, $node, $reshares, $limit, $offset) {
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('*')
- ->from('share');
- $qb->andWhere($qb->expr()->eq('share_type', $qb->createNamedParameter($shareType)));
-
- if ($reshares === false) {
-
- $or1 = $qb->expr()->andX(
- $qb->expr()->eq('uid_owner', $qb->createNamedParameter($userId)),
- $qb->expr()->isNull('uid_initiator')
- );
- $qb->andWhere(
- $qb->expr()->orX(
- $qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId)),
- $or1
- )
- );
- } else {
- $qb->andWhere(
- $qb->expr()->orX(
- $qb->expr()->eq('uid_owner', $qb->createNamedParameter($userId)),
- $qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId))
- )
- );
- }
- if ($node !== null) {
- $qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
- }
- if ($limit !== -1) {
- $qb->setMaxResults($limit);
- }
- $qb->setFirstResult($offset);
- $qb->orderBy('id');
- $cursor = $qb->execute();
- $shares = [];
- while ($data = $cursor->fetch()) {
- $shares[] = $this->createShareObject($data);
- }
- $cursor->closeCursor();
- return $shares;
- }
-
- public function getShareById($id, $recipientId = null) {
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('*')
- ->from('share')
- ->where($qb->expr()->eq('id', $qb->createNamedParameter($id)))
- ->andWhere($qb->expr()->in('share_type', $qb->createNamedParameter($this->supportedShareType, IQueryBuilder::PARAM_INT_ARRAY)));
- $cursor = $qb->execute();
- $data = $cursor->fetch();
- $cursor->closeCursor();
- if ($data === false) {
- throw new ShareNotFound('Can not find share with ID: ' . $id);
- }
- try {
- $share = $this->createShareObject($data);
- } catch (InvalidShare $e) {
- throw new ShareNotFound();
- }
- return $share;
- }
-
- public function getSharesByPath(Node $path) {
- $qb = $this->dbConnection->getQueryBuilder();
-
- $cursor = $qb->select('*')
- ->from('share')
- ->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($path->getId())))
- ->andWhere($qb->expr()->in('share_type', $qb->createNamedParameter($this->supportedShareType, IQueryBuilder::PARAM_INT_ARRAY)))
- ->execute();
- $shares = [];
- while ($data = $cursor->fetch()) {
- $shares[] = $this->createShareObject($data);
- }
- $cursor->closeCursor();
- return $shares;
- }
-
- public function getSharedWith($userId, $shareType, $node, $limit, $offset) {
-
- $shares = [];
-
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('*')
- ->from('share');
-
- $qb->orderBy('id');
-
- if ($limit !== -1) {
- $qb->setMaxResults($limit);
- }
- $qb->setFirstResult($offset);
- $qb->where($qb->expr()->in('share_type', $qb->createNamedParameter($this->supportedShareType, IQueryBuilder::PARAM_INT_ARRAY)));
- $qb->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($userId)));
-
- if ($node !== null) {
- $qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
- }
- $cursor = $qb->execute();
- while ($data = $cursor->fetch()) {
- $shares[] = $this->createShareObject($data);
- }
- $cursor->closeCursor();
- return $shares;
- }
-
- public function getShareByToken($token) {
- $qb = $this->dbConnection->getQueryBuilder();
- $cursor = $qb->select('*')
- ->from('share')
- ->where($qb->expr()->in('share_type', $qb->createNamedParameter($this->supportedShareType, IQueryBuilder::PARAM_INT_ARRAY)))
- ->andWhere($qb->expr()->eq('token', $qb->createNamedParameter($token)))
- ->execute();
- $data = $cursor->fetch();
- if ($data === false) {
- throw new ShareNotFound('Share not found', $this->l->t('Could not find share'));
- }
- try {
- $share = $this->createShareObject($data);
- } catch (InvalidShare $e) {
- throw new ShareNotFound('Share not found', $this->l->t('Could not find share'));
- }
- return $share;
- }
-
- private function getRawShare($id) {
-
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('*')
- ->from('share')
- ->where($qb->expr()->eq('id', $qb->createNamedParameter($id)));
- $cursor = $qb->execute();
- $data = $cursor->fetch();
- $cursor->closeCursor();
- if ($data === false) {
- throw new ShareNotFound;
- }
- return $data;
- }
-
- private function createShareObject($data) {
- $share = new Share($this->rootFolder, $this->userManager);
- $share->setId((int)$data['id'])
- ->setShareType((int)$data['share_type'])
- ->setPermissions((int)$data['permissions'])
- ->setTarget($data['file_target'])
- ->setMailSend((bool)$data['mail_send'])
- ->setToken($data['token']);
- $shareTime = new \DateTime();
- $shareTime->setTimestamp((int)$data['stime']);
- $share->setShareTime($shareTime);
- $share->setSharedWith($data['share_with']);
- if ($data['uid_initiator'] !== null) {
- $share->setShareOwner($data['uid_owner']);
- $share->setSharedBy($data['uid_initiator']);
- } else {
-
- $share->setSharedBy($data['uid_owner']);
- $path = $this->getNode($share->getSharedBy(), (int)$data['file_source']);
- $owner = $path->getOwner();
- $share->setShareOwner($owner->getUID());
- }
- $share->setNodeId((int)$data['file_source']);
- $share->setNodeType($data['item_type']);
- $share->setProviderId($this->identifier());
- if ($data['expiration'] !== null) {
- $expiration = \DateTime::createFromFormat('Y-m-d H:i:s', $data['expiration']);
- $share->setExpirationDate($expiration);
- }
- return $share;
- }
-
- private function getNode($userId, $id) {
- try {
- $userFolder = $this->rootFolder->getUserFolder($userId);
- } catch (NotFoundException $e) {
- throw new InvalidShare();
- }
- $node = $userFolder->getFirstNodeById($id);
- if (!$node) {
- throw new InvalidShare();
- }
- return $node;
- }
-
- public function userDeleted($uid, $shareType) {
-
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->delete('share')
- ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_REMOTE)))
- ->andWhere($qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid)))
- ->execute();
- }
-
- public function groupDeleted($gid) {
-
- }
-
- public function userDeletedFromGroup($uid, $gid) {
-
- }
-
- public function isOutgoingServer2serverShareEnabled() {
- if ($this->gsConfig->onlyInternalFederation()) {
- return false;
- }
- $result = $this->config->getAppValue('files_sharing', 'outgoing_server2server_share_enabled', 'yes');
- return ($result === 'yes');
- }
-
- public function isIncomingServer2serverShareEnabled() {
- if ($this->gsConfig->onlyInternalFederation()) {
- return false;
- }
- $result = $this->config->getAppValue('files_sharing', 'incoming_server2server_share_enabled', 'yes');
- return ($result === 'yes');
- }
-
- public function isOutgoingServer2serverGroupShareEnabled() {
- if ($this->gsConfig->onlyInternalFederation()) {
- return false;
- }
- $result = $this->config->getAppValue('files_sharing', 'outgoing_server2server_group_share_enabled', 'no');
- return ($result === 'yes');
- }
-
- public function isIncomingServer2serverGroupShareEnabled() {
- if ($this->gsConfig->onlyInternalFederation()) {
- return false;
- }
- $result = $this->config->getAppValue('files_sharing', 'incoming_server2server_group_share_enabled', 'no');
- return ($result === 'yes');
- }
-
- public function isFederatedGroupSharingSupported() {
- return $this->cloudFederationProviderManager->isReady();
- }
-
- public function isLookupServerQueriesEnabled() {
-
- if ($this->gsConfig->isGlobalScaleEnabled()) {
- return true;
- }
- $result = $this->config->getAppValue('files_sharing', 'lookupServerEnabled', 'yes');
- return ($result === 'yes');
- }
-
- public function isLookupServerUploadEnabled() {
-
- if ($this->gsConfig->isGlobalScaleEnabled()) {
- return false;
- }
- $result = $this->config->getAppValue('files_sharing', 'lookupServerUploadEnabled', 'yes');
- return ($result === 'yes');
- }
-
- public function getAccessList($nodes, $currentAccess) {
- $ids = [];
- foreach ($nodes as $node) {
- $ids[] = $node->getId();
- }
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('share_with', 'token', 'file_source')
- ->from('share')
- ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(IShare::TYPE_REMOTE)))
- ->andWhere($qb->expr()->in('file_source', $qb->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY)))
- ->andWhere($qb->expr()->orX(
- $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
- $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
- ));
- $cursor = $qb->execute();
- if ($currentAccess === false) {
- $remote = $cursor->fetch() !== false;
- $cursor->closeCursor();
- return ['remote' => $remote];
- }
- $remote = [];
- while ($row = $cursor->fetch()) {
- $remote[$row['share_with']] = [
- 'node_id' => $row['file_source'],
- 'token' => $row['token'],
- ];
- }
- $cursor->closeCursor();
- return ['remote' => $remote];
- }
- public function getAllShares(): iterable {
- $qb = $this->dbConnection->getQueryBuilder();
- $qb->select('*')
- ->from('share')
- ->where(
- $qb->expr()->orX(
- $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share\IShare::TYPE_REMOTE)),
- $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share\IShare::TYPE_REMOTE_GROUP))
- )
- );
- $cursor = $qb->execute();
- while ($data = $cursor->fetch()) {
- try {
- $share = $this->createShareObject($data);
- } catch (InvalidShare $e) {
- continue;
- } catch (ShareNotFound $e) {
- continue;
- }
- yield $share;
- }
- $cursor->closeCursor();
- }
- }
|