Skip to content

Commit

Permalink
Add argument to getSharesInFolder enable deep share lookup
Browse files Browse the repository at this point in the history
Signed-off-by: Louis Chemineau <louis@chmn.me>
  • Loading branch information
artonge committed Jun 23, 2022
1 parent f752fbb commit 55fa748
Show file tree
Hide file tree
Showing 7 changed files with 40 additions and 46 deletions.
11 changes: 8 additions & 3 deletions apps/federatedfilesharing/lib/FederatedShareProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -638,7 +638,7 @@ public function restore(IShare $share, string $recipient): IShare {
}


public function getSharesInFolder($userId, Folder $node, $reshares) {
public function getSharesInFolder($userId, Folder $node, $reshares, $shallow = true) {
$qb = $this->dbConnection->getQueryBuilder();
$qb->select('*')
->from('share', 's')
Expand All @@ -664,8 +664,13 @@ public function getSharesInFolder($userId, Folder $node, $reshares) {
);
}

$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->innerJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'));

if ($shallow) {
$qb->andWhere($qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId())));
} else {
$qb->andWhere($qb->expr()->like('f.path', $qb->createNamedParameter($this->dbConnection->escapeLikeParameter($node->getInternalPath()) . '/%')));
}

$qb->orderBy('id');

Expand Down
2 changes: 1 addition & 1 deletion apps/files_sharing/lib/Updater.php
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ private static function moveShareInOrOutOfShare($path): void {
$shares = array_merge($shares, $shareManager->getSharesBy($userFolder->getOwner()->getUID(), IShare::TYPE_ROOM, $src, false, -1));

if ($src instanceof Folder) {
$subShares = $shareManager->getSharesInFolderRecursive($userFolder->getOwner()->getUID(), $src, false);
$subShares = $shareManager->getSharesInFolder($userFolder->getOwner()->getUID(), $src, false, false);
foreach ($subShares as $subShare) {
$shares = array_merge($shares, array_values($subShare));
}
Expand Down
12 changes: 8 additions & 4 deletions apps/sharebymail/lib/ShareByMailProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,6 @@
* @package OCA\ShareByMail
*/
class ShareByMailProvider implements IShareProvider {

private IConfig $config;

/** @var IDBConnection */
Expand Down Expand Up @@ -1159,7 +1158,7 @@ protected function getRawShare($id) {
return $data;
}

public function getSharesInFolder($userId, Folder $node, $reshares) {
public function getSharesInFolder($userId, Folder $node, $reshares, $shallow = true) {
$qb = $this->dbConnection->getQueryBuilder();
$qb->select('*')
->from('share', 's')
Expand All @@ -1185,8 +1184,13 @@ public function getSharesInFolder($userId, Folder $node, $reshares) {
);
}

$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->innerJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'));

if ($shallow) {
$qb->andWhere($qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId())));
} else {
$qb->andWhere($qb->expr()->like('f.path', $qb->createNamedParameter($this->dbConnection->escapeLikeParameter($node->getInternalPath()) . '/%')));
}

$qb->orderBy('id');

Expand Down
23 changes: 16 additions & 7 deletions lib/private/Share20/DefaultShareProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -641,7 +641,7 @@ public function move(\OCP\Share\IShare $share, $recipient) {
return $share;
}

public function getSharesInFolder($userId, Folder $node, $reshares) {
public function getSharesInFolder($userId, Folder $node, $reshares, $shallow = true) {
$qb = $this->dbConn->getQueryBuilder();
$qb->select('s.*',
'f.fileid', 'f.path', 'f.permissions AS f_permissions', 'f.storage', 'f.path_hash',
Expand Down Expand Up @@ -682,12 +682,21 @@ public function getSharesInFolder($userId, Folder $node, $reshares) {
}, $childMountNodes);

$qb->innerJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'));
$qb->andWhere(
$qb->expr()->orX(
$qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId())),
$qb->expr()->in('f.fileid', $qb->createParameter('chunk'))
)
);
if ($shallow) {
$qb->andWhere(
$qb->expr()->orX(
$qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId())),
$qb->expr()->in('f.fileid', $qb->createParameter('chunk'))
)
);
} else {
$qb->andWhere(
$qb->expr()->orX(
$qb->expr()->like('f.path', $qb->createNamedParameter($this->dbConn->escapeLikeParameter($node->getInternalPath()) . '/%')),
$qb->expr()->in('f.fileid', $qb->createParameter('chunk'))
)
);
}

$qb->orderBy('id');

Expand Down
24 changes: 3 additions & 21 deletions lib/private/Share20/Manager.php
Original file line number Diff line number Diff line change
Expand Up @@ -1303,11 +1303,11 @@ public function moveShare(IShare $share, $recipientId) {
return $provider->move($share, $recipientId);
}

public function getSharesInFolder($userId, Folder $node, $reshares = false) {
public function getSharesInFolder($userId, Folder $node, $reshares = false, $shallow = true) {
$providers = $this->factory->getAllProviders();

return array_reduce($providers, function ($shares, IShareProvider $provider) use ($userId, $node, $reshares) {
$newShares = $provider->getSharesInFolder($userId, $node, $reshares);
return array_reduce($providers, function ($shares, IShareProvider $provider) use ($userId, $node, $reshares, $shallow) {
$newShares = $provider->getSharesInFolder($userId, $node, $reshares, $shallow);
foreach ($newShares as $fid => $data) {
if (!isset($shares[$fid])) {
$shares[$fid] = [];
Expand All @@ -1319,24 +1319,6 @@ public function getSharesInFolder($userId, Folder $node, $reshares = false) {
}, []);
}

public function getSharesInFolderRecursive(string $userId, Folder $node, $reshares = false) {
$shares = $this->getSharesInFolder($userId, $node, $reshares);

foreach ($node->getDirectoryListing() as $subnode) {
if (!$subnode instanceof Folder) {
continue;
}

$subShares = $this->getSharesInFolderRecursive($userId, $subnode, $reshares);

foreach ($subShares as $fileId => $subSharesForFile) {
$shares[$fileId] = array_merge($shares[$fileId] ?? [], $subSharesForFile);
}
}

return $shares;
}

/**
* @inheritdoc
*/
Expand Down
11 changes: 2 additions & 9 deletions lib/public/Share/IManager.php
Original file line number Diff line number Diff line change
Expand Up @@ -135,18 +135,11 @@ public function moveShare(IShare $share, $recipientId);
* @param string $userId
* @param Folder $node
* @param bool $reshares
* @param bool $shallow Whether the method should stop at the first level, or look into sub-folders.
* @return IShare[][] [$fileId => IShare[], ...]
* @since 11.0.0
*/
public function getSharesInFolder($userId, Folder $node, $reshares = false);

/**
* Recursively get all shares shared by (initiated) by the provided user in a folder.
*
* @return IShare[][] [$fileId => IShare[], ...]
* @since 11.0.0
*/
public function getSharesInFolderRecursive(string $userId, Folder $node, bool $reshares = false);
public function getSharesInFolder($userId, Folder $node, $reshares = false, $shallow = true);

/**
* Get shares shared by (initiated) by the provided user.
Expand Down
3 changes: 2 additions & 1 deletion lib/public/Share/IShareProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -123,10 +123,11 @@ public function move(\OCP\Share\IShare $share, $recipient);
* @param string $userId
* @param Folder $node
* @param bool $reshares Also get the shares where $user is the owner instead of just the shares where $user is the initiator
* @param bool $shallow Whether the method should stop at the first level, or look into sub-folders.
* @return \OCP\Share\IShare[][]
* @since 11.0.0
*/
public function getSharesInFolder($userId, Folder $node, $reshares);
public function getSharesInFolder($userId, Folder $node, $reshares, $shallow = true);

/**
* Get all shares by the given user
Expand Down

0 comments on commit 55fa748

Please sign in to comment.