Completed
Push — master ( 6a06df...c46422 )
by Lukas
16:58
created
lib/private/Share20/DefaultShareProvider.php 1 patch
Indentation   +1103 added lines, -1103 removed lines patch added patch discarded remove patch
@@ -46,1140 +46,1140 @@
 block discarded – undo
46 46
  */
47 47
 class DefaultShareProvider implements IShareProvider {
48 48
 
49
-	// Special share type for user modified group shares
50
-	const SHARE_TYPE_USERGROUP = 2;
51
-
52
-	/** @var IDBConnection */
53
-	private $dbConn;
54
-
55
-	/** @var IUserManager */
56
-	private $userManager;
57
-
58
-	/** @var IGroupManager */
59
-	private $groupManager;
60
-
61
-	/** @var IRootFolder */
62
-	private $rootFolder;
63
-
64
-	/**
65
-	 * DefaultShareProvider constructor.
66
-	 *
67
-	 * @param IDBConnection $connection
68
-	 * @param IUserManager $userManager
69
-	 * @param IGroupManager $groupManager
70
-	 * @param IRootFolder $rootFolder
71
-	 */
72
-	public function __construct(
73
-			IDBConnection $connection,
74
-			IUserManager $userManager,
75
-			IGroupManager $groupManager,
76
-			IRootFolder $rootFolder) {
77
-		$this->dbConn = $connection;
78
-		$this->userManager = $userManager;
79
-		$this->groupManager = $groupManager;
80
-		$this->rootFolder = $rootFolder;
81
-	}
82
-
83
-	/**
84
-	 * Return the identifier of this provider.
85
-	 *
86
-	 * @return string Containing only [a-zA-Z0-9]
87
-	 */
88
-	public function identifier() {
89
-		return 'ocinternal';
90
-	}
91
-
92
-	/**
93
-	 * Share a path
94
-	 *
95
-	 * @param \OCP\Share\IShare $share
96
-	 * @return \OCP\Share\IShare The share object
97
-	 * @throws ShareNotFound
98
-	 * @throws \Exception
99
-	 */
100
-	public function create(\OCP\Share\IShare $share) {
101
-		$qb = $this->dbConn->getQueryBuilder();
102
-
103
-		$qb->insert('share');
104
-		$qb->setValue('share_type', $qb->createNamedParameter($share->getShareType()));
105
-
106
-		if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
107
-			//Set the UID of the user we share with
108
-			$qb->setValue('share_with', $qb->createNamedParameter($share->getSharedWith()));
109
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
110
-			//Set the GID of the group we share with
111
-			$qb->setValue('share_with', $qb->createNamedParameter($share->getSharedWith()));
112
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_LINK) {
113
-			//Set the token of the share
114
-			$qb->setValue('token', $qb->createNamedParameter($share->getToken()));
115
-
116
-			//If a password is set store it
117
-			if ($share->getPassword() !== null) {
118
-				$qb->setValue('password', $qb->createNamedParameter($share->getPassword()));
119
-			}
120
-
121
-			//If an expiration date is set store it
122
-			if ($share->getExpirationDate() !== null) {
123
-				$qb->setValue('expiration', $qb->createNamedParameter($share->getExpirationDate(), 'datetime'));
124
-			}
125
-
126
-			if (method_exists($share, 'getParent')) {
127
-				$qb->setValue('parent', $qb->createNamedParameter($share->getParent()));
128
-			}
129
-		} else {
130
-			throw new \Exception('invalid share type!');
131
-		}
132
-
133
-		// Set what is shares
134
-		$qb->setValue('item_type', $qb->createParameter('itemType'));
135
-		if ($share->getNode() instanceof \OCP\Files\File) {
136
-			$qb->setParameter('itemType', 'file');
137
-		} else {
138
-			$qb->setParameter('itemType', 'folder');
139
-		}
140
-
141
-		// Set the file id
142
-		$qb->setValue('item_source', $qb->createNamedParameter($share->getNode()->getId()));
143
-		$qb->setValue('file_source', $qb->createNamedParameter($share->getNode()->getId()));
144
-
145
-		// set the permissions
146
-		$qb->setValue('permissions', $qb->createNamedParameter($share->getPermissions()));
147
-
148
-		// Set who created this share
149
-		$qb->setValue('uid_initiator', $qb->createNamedParameter($share->getSharedBy()));
150
-
151
-		// Set who is the owner of this file/folder (and this the owner of the share)
152
-		$qb->setValue('uid_owner', $qb->createNamedParameter($share->getShareOwner()));
153
-
154
-		// Set the file target
155
-		$qb->setValue('file_target', $qb->createNamedParameter($share->getTarget()));
156
-
157
-		// Set the time this share was created
158
-		$qb->setValue('stime', $qb->createNamedParameter(time()));
159
-
160
-		// insert the data and fetch the id of the share
161
-		$this->dbConn->beginTransaction();
162
-		$qb->execute();
163
-		$id = $this->dbConn->lastInsertId('*PREFIX*share');
164
-
165
-		// Now fetch the inserted share and create a complete share object
166
-		$qb = $this->dbConn->getQueryBuilder();
167
-		$qb->select('*')
168
-			->from('share')
169
-			->where($qb->expr()->eq('id', $qb->createNamedParameter($id)));
170
-
171
-		$cursor = $qb->execute();
172
-		$data = $cursor->fetch();
173
-		$this->dbConn->commit();
174
-		$cursor->closeCursor();
175
-
176
-		if ($data === false) {
177
-			throw new ShareNotFound();
178
-		}
179
-
180
-		$share = $this->createShare($data);
181
-		return $share;
182
-	}
183
-
184
-	/**
185
-	 * Update a share
186
-	 *
187
-	 * @param \OCP\Share\IShare $share
188
-	 * @return \OCP\Share\IShare The share object
189
-	 */
190
-	public function update(\OCP\Share\IShare $share) {
191
-		if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
192
-			/*
49
+    // Special share type for user modified group shares
50
+    const SHARE_TYPE_USERGROUP = 2;
51
+
52
+    /** @var IDBConnection */
53
+    private $dbConn;
54
+
55
+    /** @var IUserManager */
56
+    private $userManager;
57
+
58
+    /** @var IGroupManager */
59
+    private $groupManager;
60
+
61
+    /** @var IRootFolder */
62
+    private $rootFolder;
63
+
64
+    /**
65
+     * DefaultShareProvider constructor.
66
+     *
67
+     * @param IDBConnection $connection
68
+     * @param IUserManager $userManager
69
+     * @param IGroupManager $groupManager
70
+     * @param IRootFolder $rootFolder
71
+     */
72
+    public function __construct(
73
+            IDBConnection $connection,
74
+            IUserManager $userManager,
75
+            IGroupManager $groupManager,
76
+            IRootFolder $rootFolder) {
77
+        $this->dbConn = $connection;
78
+        $this->userManager = $userManager;
79
+        $this->groupManager = $groupManager;
80
+        $this->rootFolder = $rootFolder;
81
+    }
82
+
83
+    /**
84
+     * Return the identifier of this provider.
85
+     *
86
+     * @return string Containing only [a-zA-Z0-9]
87
+     */
88
+    public function identifier() {
89
+        return 'ocinternal';
90
+    }
91
+
92
+    /**
93
+     * Share a path
94
+     *
95
+     * @param \OCP\Share\IShare $share
96
+     * @return \OCP\Share\IShare The share object
97
+     * @throws ShareNotFound
98
+     * @throws \Exception
99
+     */
100
+    public function create(\OCP\Share\IShare $share) {
101
+        $qb = $this->dbConn->getQueryBuilder();
102
+
103
+        $qb->insert('share');
104
+        $qb->setValue('share_type', $qb->createNamedParameter($share->getShareType()));
105
+
106
+        if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
107
+            //Set the UID of the user we share with
108
+            $qb->setValue('share_with', $qb->createNamedParameter($share->getSharedWith()));
109
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
110
+            //Set the GID of the group we share with
111
+            $qb->setValue('share_with', $qb->createNamedParameter($share->getSharedWith()));
112
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_LINK) {
113
+            //Set the token of the share
114
+            $qb->setValue('token', $qb->createNamedParameter($share->getToken()));
115
+
116
+            //If a password is set store it
117
+            if ($share->getPassword() !== null) {
118
+                $qb->setValue('password', $qb->createNamedParameter($share->getPassword()));
119
+            }
120
+
121
+            //If an expiration date is set store it
122
+            if ($share->getExpirationDate() !== null) {
123
+                $qb->setValue('expiration', $qb->createNamedParameter($share->getExpirationDate(), 'datetime'));
124
+            }
125
+
126
+            if (method_exists($share, 'getParent')) {
127
+                $qb->setValue('parent', $qb->createNamedParameter($share->getParent()));
128
+            }
129
+        } else {
130
+            throw new \Exception('invalid share type!');
131
+        }
132
+
133
+        // Set what is shares
134
+        $qb->setValue('item_type', $qb->createParameter('itemType'));
135
+        if ($share->getNode() instanceof \OCP\Files\File) {
136
+            $qb->setParameter('itemType', 'file');
137
+        } else {
138
+            $qb->setParameter('itemType', 'folder');
139
+        }
140
+
141
+        // Set the file id
142
+        $qb->setValue('item_source', $qb->createNamedParameter($share->getNode()->getId()));
143
+        $qb->setValue('file_source', $qb->createNamedParameter($share->getNode()->getId()));
144
+
145
+        // set the permissions
146
+        $qb->setValue('permissions', $qb->createNamedParameter($share->getPermissions()));
147
+
148
+        // Set who created this share
149
+        $qb->setValue('uid_initiator', $qb->createNamedParameter($share->getSharedBy()));
150
+
151
+        // Set who is the owner of this file/folder (and this the owner of the share)
152
+        $qb->setValue('uid_owner', $qb->createNamedParameter($share->getShareOwner()));
153
+
154
+        // Set the file target
155
+        $qb->setValue('file_target', $qb->createNamedParameter($share->getTarget()));
156
+
157
+        // Set the time this share was created
158
+        $qb->setValue('stime', $qb->createNamedParameter(time()));
159
+
160
+        // insert the data and fetch the id of the share
161
+        $this->dbConn->beginTransaction();
162
+        $qb->execute();
163
+        $id = $this->dbConn->lastInsertId('*PREFIX*share');
164
+
165
+        // Now fetch the inserted share and create a complete share object
166
+        $qb = $this->dbConn->getQueryBuilder();
167
+        $qb->select('*')
168
+            ->from('share')
169
+            ->where($qb->expr()->eq('id', $qb->createNamedParameter($id)));
170
+
171
+        $cursor = $qb->execute();
172
+        $data = $cursor->fetch();
173
+        $this->dbConn->commit();
174
+        $cursor->closeCursor();
175
+
176
+        if ($data === false) {
177
+            throw new ShareNotFound();
178
+        }
179
+
180
+        $share = $this->createShare($data);
181
+        return $share;
182
+    }
183
+
184
+    /**
185
+     * Update a share
186
+     *
187
+     * @param \OCP\Share\IShare $share
188
+     * @return \OCP\Share\IShare The share object
189
+     */
190
+    public function update(\OCP\Share\IShare $share) {
191
+        if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
192
+            /*
193 193
 			 * We allow updating the recipient on user shares.
194 194
 			 */
195
-			$qb = $this->dbConn->getQueryBuilder();
196
-			$qb->update('share')
197
-				->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
198
-				->set('share_with', $qb->createNamedParameter($share->getSharedWith()))
199
-				->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
200
-				->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
201
-				->set('permissions', $qb->createNamedParameter($share->getPermissions()))
202
-				->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
203
-				->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
204
-				->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
205
-				->execute();
206
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
207
-			$qb = $this->dbConn->getQueryBuilder();
208
-			$qb->update('share')
209
-				->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
210
-				->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
211
-				->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
212
-				->set('permissions', $qb->createNamedParameter($share->getPermissions()))
213
-				->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
214
-				->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
215
-				->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
216
-				->execute();
217
-
218
-			/*
195
+            $qb = $this->dbConn->getQueryBuilder();
196
+            $qb->update('share')
197
+                ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
198
+                ->set('share_with', $qb->createNamedParameter($share->getSharedWith()))
199
+                ->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
200
+                ->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
201
+                ->set('permissions', $qb->createNamedParameter($share->getPermissions()))
202
+                ->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
203
+                ->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
204
+                ->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
205
+                ->execute();
206
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
207
+            $qb = $this->dbConn->getQueryBuilder();
208
+            $qb->update('share')
209
+                ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
210
+                ->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
211
+                ->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
212
+                ->set('permissions', $qb->createNamedParameter($share->getPermissions()))
213
+                ->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
214
+                ->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
215
+                ->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
216
+                ->execute();
217
+
218
+            /*
219 219
 			 * Update all user defined group shares
220 220
 			 */
221
-			$qb = $this->dbConn->getQueryBuilder();
222
-			$qb->update('share')
223
-				->where($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
224
-				->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
225
-				->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
226
-				->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
227
-				->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
228
-				->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
229
-				->execute();
230
-
231
-			/*
221
+            $qb = $this->dbConn->getQueryBuilder();
222
+            $qb->update('share')
223
+                ->where($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
224
+                ->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
225
+                ->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
226
+                ->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
227
+                ->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
228
+                ->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
229
+                ->execute();
230
+
231
+            /*
232 232
 			 * Now update the permissions for all children that have not set it to 0
233 233
 			 */
234
-			$qb = $this->dbConn->getQueryBuilder();
235
-			$qb->update('share')
236
-				->where($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
237
-				->andWhere($qb->expr()->neq('permissions', $qb->createNamedParameter(0)))
238
-				->set('permissions', $qb->createNamedParameter($share->getPermissions()))
239
-				->execute();
240
-
241
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_LINK) {
242
-			$qb = $this->dbConn->getQueryBuilder();
243
-			$qb->update('share')
244
-				->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
245
-				->set('password', $qb->createNamedParameter($share->getPassword()))
246
-				->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
247
-				->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
248
-				->set('permissions', $qb->createNamedParameter($share->getPermissions()))
249
-				->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
250
-				->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
251
-				->set('token', $qb->createNamedParameter($share->getToken()))
252
-				->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
253
-				->execute();
254
-		}
255
-
256
-		return $share;
257
-	}
258
-
259
-	/**
260
-	 * Get all children of this share
261
-	 * FIXME: remove once https://github.com/owncloud/core/pull/21660 is in
262
-	 *
263
-	 * @param \OCP\Share\IShare $parent
264
-	 * @return \OCP\Share\IShare[]
265
-	 */
266
-	public function getChildren(\OCP\Share\IShare $parent) {
267
-		$children = [];
268
-
269
-		$qb = $this->dbConn->getQueryBuilder();
270
-		$qb->select('*')
271
-			->from('share')
272
-			->where($qb->expr()->eq('parent', $qb->createNamedParameter($parent->getId())))
273
-			->andWhere(
274
-				$qb->expr()->in(
275
-					'share_type',
276
-					$qb->createNamedParameter([
277
-						\OCP\Share::SHARE_TYPE_USER,
278
-						\OCP\Share::SHARE_TYPE_GROUP,
279
-						\OCP\Share::SHARE_TYPE_LINK,
280
-					], IQueryBuilder::PARAM_INT_ARRAY)
281
-				)
282
-			)
283
-			->andWhere($qb->expr()->orX(
284
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
285
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
286
-			))
287
-			->orderBy('id');
288
-
289
-		$cursor = $qb->execute();
290
-		while($data = $cursor->fetch()) {
291
-			$children[] = $this->createShare($data);
292
-		}
293
-		$cursor->closeCursor();
294
-
295
-		return $children;
296
-	}
297
-
298
-	/**
299
-	 * Delete a share
300
-	 *
301
-	 * @param \OCP\Share\IShare $share
302
-	 */
303
-	public function delete(\OCP\Share\IShare $share) {
304
-		$qb = $this->dbConn->getQueryBuilder();
305
-		$qb->delete('share')
306
-			->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())));
307
-
308
-		/*
234
+            $qb = $this->dbConn->getQueryBuilder();
235
+            $qb->update('share')
236
+                ->where($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
237
+                ->andWhere($qb->expr()->neq('permissions', $qb->createNamedParameter(0)))
238
+                ->set('permissions', $qb->createNamedParameter($share->getPermissions()))
239
+                ->execute();
240
+
241
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_LINK) {
242
+            $qb = $this->dbConn->getQueryBuilder();
243
+            $qb->update('share')
244
+                ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
245
+                ->set('password', $qb->createNamedParameter($share->getPassword()))
246
+                ->set('uid_owner', $qb->createNamedParameter($share->getShareOwner()))
247
+                ->set('uid_initiator', $qb->createNamedParameter($share->getSharedBy()))
248
+                ->set('permissions', $qb->createNamedParameter($share->getPermissions()))
249
+                ->set('item_source', $qb->createNamedParameter($share->getNode()->getId()))
250
+                ->set('file_source', $qb->createNamedParameter($share->getNode()->getId()))
251
+                ->set('token', $qb->createNamedParameter($share->getToken()))
252
+                ->set('expiration', $qb->createNamedParameter($share->getExpirationDate(), IQueryBuilder::PARAM_DATE))
253
+                ->execute();
254
+        }
255
+
256
+        return $share;
257
+    }
258
+
259
+    /**
260
+     * Get all children of this share
261
+     * FIXME: remove once https://github.com/owncloud/core/pull/21660 is in
262
+     *
263
+     * @param \OCP\Share\IShare $parent
264
+     * @return \OCP\Share\IShare[]
265
+     */
266
+    public function getChildren(\OCP\Share\IShare $parent) {
267
+        $children = [];
268
+
269
+        $qb = $this->dbConn->getQueryBuilder();
270
+        $qb->select('*')
271
+            ->from('share')
272
+            ->where($qb->expr()->eq('parent', $qb->createNamedParameter($parent->getId())))
273
+            ->andWhere(
274
+                $qb->expr()->in(
275
+                    'share_type',
276
+                    $qb->createNamedParameter([
277
+                        \OCP\Share::SHARE_TYPE_USER,
278
+                        \OCP\Share::SHARE_TYPE_GROUP,
279
+                        \OCP\Share::SHARE_TYPE_LINK,
280
+                    ], IQueryBuilder::PARAM_INT_ARRAY)
281
+                )
282
+            )
283
+            ->andWhere($qb->expr()->orX(
284
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
285
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
286
+            ))
287
+            ->orderBy('id');
288
+
289
+        $cursor = $qb->execute();
290
+        while($data = $cursor->fetch()) {
291
+            $children[] = $this->createShare($data);
292
+        }
293
+        $cursor->closeCursor();
294
+
295
+        return $children;
296
+    }
297
+
298
+    /**
299
+     * Delete a share
300
+     *
301
+     * @param \OCP\Share\IShare $share
302
+     */
303
+    public function delete(\OCP\Share\IShare $share) {
304
+        $qb = $this->dbConn->getQueryBuilder();
305
+        $qb->delete('share')
306
+            ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())));
307
+
308
+        /*
309 309
 		 * If the share is a group share delete all possible
310 310
 		 * user defined groups shares.
311 311
 		 */
312
-		if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
313
-			$qb->orWhere($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())));
314
-		}
315
-
316
-		$qb->execute();
317
-	}
318
-
319
-	/**
320
-	 * Unshare a share from the recipient. If this is a group share
321
-	 * this means we need a special entry in the share db.
322
-	 *
323
-	 * @param \OCP\Share\IShare $share
324
-	 * @param string $recipient UserId of recipient
325
-	 * @throws BackendError
326
-	 * @throws ProviderException
327
-	 */
328
-	public function deleteFromSelf(\OCP\Share\IShare $share, $recipient) {
329
-		if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
330
-
331
-			$group = $this->groupManager->get($share->getSharedWith());
332
-			$user = $this->userManager->get($recipient);
333
-
334
-			if (is_null($group)) {
335
-				throw new ProviderException('Group "' . $share->getSharedWith() . '" does not exist');
336
-			}
337
-
338
-			if (!$group->inGroup($user)) {
339
-				throw new ProviderException('Recipient not in receiving group');
340
-			}
341
-
342
-			// Try to fetch user specific share
343
-			$qb = $this->dbConn->getQueryBuilder();
344
-			$stmt = $qb->select('*')
345
-				->from('share')
346
-				->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
347
-				->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($recipient)))
348
-				->andWhere($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
349
-				->andWhere($qb->expr()->orX(
350
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
351
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
352
-				))
353
-				->execute();
354
-
355
-			$data = $stmt->fetch();
356
-
357
-			/*
312
+        if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
313
+            $qb->orWhere($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())));
314
+        }
315
+
316
+        $qb->execute();
317
+    }
318
+
319
+    /**
320
+     * Unshare a share from the recipient. If this is a group share
321
+     * this means we need a special entry in the share db.
322
+     *
323
+     * @param \OCP\Share\IShare $share
324
+     * @param string $recipient UserId of recipient
325
+     * @throws BackendError
326
+     * @throws ProviderException
327
+     */
328
+    public function deleteFromSelf(\OCP\Share\IShare $share, $recipient) {
329
+        if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
330
+
331
+            $group = $this->groupManager->get($share->getSharedWith());
332
+            $user = $this->userManager->get($recipient);
333
+
334
+            if (is_null($group)) {
335
+                throw new ProviderException('Group "' . $share->getSharedWith() . '" does not exist');
336
+            }
337
+
338
+            if (!$group->inGroup($user)) {
339
+                throw new ProviderException('Recipient not in receiving group');
340
+            }
341
+
342
+            // Try to fetch user specific share
343
+            $qb = $this->dbConn->getQueryBuilder();
344
+            $stmt = $qb->select('*')
345
+                ->from('share')
346
+                ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
347
+                ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($recipient)))
348
+                ->andWhere($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
349
+                ->andWhere($qb->expr()->orX(
350
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
351
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
352
+                ))
353
+                ->execute();
354
+
355
+            $data = $stmt->fetch();
356
+
357
+            /*
358 358
 			 * Check if there already is a user specific group share.
359 359
 			 * If there is update it (if required).
360 360
 			 */
361
-			if ($data === false) {
362
-				$qb = $this->dbConn->getQueryBuilder();
363
-
364
-				$type = $share->getNodeType();
365
-
366
-				//Insert new share
367
-				$qb->insert('share')
368
-					->values([
369
-						'share_type' => $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP),
370
-						'share_with' => $qb->createNamedParameter($recipient),
371
-						'uid_owner' => $qb->createNamedParameter($share->getShareOwner()),
372
-						'uid_initiator' => $qb->createNamedParameter($share->getSharedBy()),
373
-						'parent' => $qb->createNamedParameter($share->getId()),
374
-						'item_type' => $qb->createNamedParameter($type),
375
-						'item_source' => $qb->createNamedParameter($share->getNodeId()),
376
-						'file_source' => $qb->createNamedParameter($share->getNodeId()),
377
-						'file_target' => $qb->createNamedParameter($share->getTarget()),
378
-						'permissions' => $qb->createNamedParameter(0),
379
-						'stime' => $qb->createNamedParameter($share->getShareTime()->getTimestamp()),
380
-					])->execute();
381
-
382
-			} else if ($data['permissions'] !== 0) {
383
-
384
-				// Update existing usergroup share
385
-				$qb = $this->dbConn->getQueryBuilder();
386
-				$qb->update('share')
387
-					->set('permissions', $qb->createNamedParameter(0))
388
-					->where($qb->expr()->eq('id', $qb->createNamedParameter($data['id'])))
389
-					->execute();
390
-			}
391
-
392
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
393
-
394
-			if ($share->getSharedWith() !== $recipient) {
395
-				throw new ProviderException('Recipient does not match');
396
-			}
397
-
398
-			// We can just delete user and link shares
399
-			$this->delete($share);
400
-		} else {
401
-			throw new ProviderException('Invalid shareType');
402
-		}
403
-	}
404
-
405
-	/**
406
-	 * @inheritdoc
407
-	 */
408
-	public function move(\OCP\Share\IShare $share, $recipient) {
409
-		if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
410
-			// Just update the target
411
-			$qb = $this->dbConn->getQueryBuilder();
412
-			$qb->update('share')
413
-				->set('file_target', $qb->createNamedParameter($share->getTarget()))
414
-				->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
415
-				->execute();
416
-
417
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
418
-
419
-			// Check if there is a usergroup share
420
-			$qb = $this->dbConn->getQueryBuilder();
421
-			$stmt = $qb->select('id')
422
-				->from('share')
423
-				->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
424
-				->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($recipient)))
425
-				->andWhere($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
426
-				->andWhere($qb->expr()->orX(
427
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
428
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
429
-				))
430
-				->setMaxResults(1)
431
-				->execute();
432
-
433
-			$data = $stmt->fetch();
434
-			$stmt->closeCursor();
435
-
436
-			if ($data === false) {
437
-				// No usergroup share yet. Create one.
438
-				$qb = $this->dbConn->getQueryBuilder();
439
-				$qb->insert('share')
440
-					->values([
441
-						'share_type' => $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP),
442
-						'share_with' => $qb->createNamedParameter($recipient),
443
-						'uid_owner' => $qb->createNamedParameter($share->getShareOwner()),
444
-						'uid_initiator' => $qb->createNamedParameter($share->getSharedBy()),
445
-						'parent' => $qb->createNamedParameter($share->getId()),
446
-						'item_type' => $qb->createNamedParameter($share->getNode() instanceof File ? 'file' : 'folder'),
447
-						'item_source' => $qb->createNamedParameter($share->getNode()->getId()),
448
-						'file_source' => $qb->createNamedParameter($share->getNode()->getId()),
449
-						'file_target' => $qb->createNamedParameter($share->getTarget()),
450
-						'permissions' => $qb->createNamedParameter($share->getPermissions()),
451
-						'stime' => $qb->createNamedParameter($share->getShareTime()->getTimestamp()),
452
-					])->execute();
453
-			} else {
454
-				// Already a usergroup share. Update it.
455
-				$qb = $this->dbConn->getQueryBuilder();
456
-				$qb->update('share')
457
-					->set('file_target', $qb->createNamedParameter($share->getTarget()))
458
-					->where($qb->expr()->eq('id', $qb->createNamedParameter($data['id'])))
459
-					->execute();
460
-			}
461
-		}
462
-
463
-		return $share;
464
-	}
465
-
466
-	public function getSharesInFolder($userId, Folder $node, $reshares) {
467
-		$qb = $this->dbConn->getQueryBuilder();
468
-		$qb->select('*')
469
-			->from('share', 's')
470
-			->andWhere($qb->expr()->orX(
471
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
472
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
473
-			));
474
-
475
-		$qb->andWhere($qb->expr()->orX(
476
-			$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)),
477
-			$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)),
478
-			$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK))
479
-		));
480
-
481
-		/**
482
-		 * Reshares for this user are shares where they are the owner.
483
-		 */
484
-		if ($reshares === false) {
485
-			$qb->andWhere($qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId)));
486
-		} else {
487
-			$qb->andWhere(
488
-				$qb->expr()->orX(
489
-					$qb->expr()->eq('uid_owner', $qb->createNamedParameter($userId)),
490
-					$qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId))
491
-				)
492
-			);
493
-		}
494
-
495
-		$qb->innerJoin('s', 'filecache' ,'f', $qb->expr()->eq('s.file_source', 'f.fileid'));
496
-		$qb->andWhere($qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId())));
497
-
498
-		$qb->orderBy('id');
499
-
500
-		$cursor = $qb->execute();
501
-		$shares = [];
502
-		while ($data = $cursor->fetch()) {
503
-			$shares[$data['fileid']][] = $this->createShare($data);
504
-		}
505
-		$cursor->closeCursor();
506
-
507
-		return $shares;
508
-	}
509
-
510
-	/**
511
-	 * @inheritdoc
512
-	 */
513
-	public function getSharesBy($userId, $shareType, $node, $reshares, $limit, $offset) {
514
-		$qb = $this->dbConn->getQueryBuilder();
515
-		$qb->select('*')
516
-			->from('share')
517
-			->andWhere($qb->expr()->orX(
518
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
519
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
520
-			));
521
-
522
-		$qb->andWhere($qb->expr()->eq('share_type', $qb->createNamedParameter($shareType)));
523
-
524
-		/**
525
-		 * Reshares for this user are shares where they are the owner.
526
-		 */
527
-		if ($reshares === false) {
528
-			$qb->andWhere($qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId)));
529
-		} else {
530
-			$qb->andWhere(
531
-				$qb->expr()->orX(
532
-					$qb->expr()->eq('uid_owner', $qb->createNamedParameter($userId)),
533
-					$qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId))
534
-				)
535
-			);
536
-		}
537
-
538
-		if ($node !== null) {
539
-			$qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
540
-		}
541
-
542
-		if ($limit !== -1) {
543
-			$qb->setMaxResults($limit);
544
-		}
545
-
546
-		$qb->setFirstResult($offset);
547
-		$qb->orderBy('id');
548
-
549
-		$cursor = $qb->execute();
550
-		$shares = [];
551
-		while($data = $cursor->fetch()) {
552
-			$shares[] = $this->createShare($data);
553
-		}
554
-		$cursor->closeCursor();
555
-
556
-		return $shares;
557
-	}
558
-
559
-	/**
560
-	 * @inheritdoc
561
-	 */
562
-	public function getShareById($id, $recipientId = null) {
563
-		$qb = $this->dbConn->getQueryBuilder();
564
-
565
-		$qb->select('*')
566
-			->from('share')
567
-			->where($qb->expr()->eq('id', $qb->createNamedParameter($id)))
568
-			->andWhere(
569
-				$qb->expr()->in(
570
-					'share_type',
571
-					$qb->createNamedParameter([
572
-						\OCP\Share::SHARE_TYPE_USER,
573
-						\OCP\Share::SHARE_TYPE_GROUP,
574
-						\OCP\Share::SHARE_TYPE_LINK,
575
-					], IQueryBuilder::PARAM_INT_ARRAY)
576
-				)
577
-			)
578
-			->andWhere($qb->expr()->orX(
579
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
580
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
581
-			));
582
-
583
-		$cursor = $qb->execute();
584
-		$data = $cursor->fetch();
585
-		$cursor->closeCursor();
586
-
587
-		if ($data === false) {
588
-			throw new ShareNotFound();
589
-		}
590
-
591
-		try {
592
-			$share = $this->createShare($data);
593
-		} catch (InvalidShare $e) {
594
-			throw new ShareNotFound();
595
-		}
596
-
597
-		// If the recipient is set for a group share resolve to that user
598
-		if ($recipientId !== null && $share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
599
-			$share = $this->resolveGroupShares([$share], $recipientId)[0];
600
-		}
601
-
602
-		return $share;
603
-	}
604
-
605
-	/**
606
-	 * Get shares for a given path
607
-	 *
608
-	 * @param \OCP\Files\Node $path
609
-	 * @return \OCP\Share\IShare[]
610
-	 */
611
-	public function getSharesByPath(Node $path) {
612
-		$qb = $this->dbConn->getQueryBuilder();
613
-
614
-		$cursor = $qb->select('*')
615
-			->from('share')
616
-			->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($path->getId())))
617
-			->andWhere(
618
-				$qb->expr()->orX(
619
-					$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)),
620
-					$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP))
621
-				)
622
-			)
623
-			->andWhere($qb->expr()->orX(
624
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
625
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
626
-			))
627
-			->execute();
628
-
629
-		$shares = [];
630
-		while($data = $cursor->fetch()) {
631
-			$shares[] = $this->createShare($data);
632
-		}
633
-		$cursor->closeCursor();
634
-
635
-		return $shares;
636
-	}
637
-
638
-	/**
639
-	 * Returns whether the given database result can be interpreted as
640
-	 * a share with accessible file (not trashed, not deleted)
641
-	 */
642
-	private function isAccessibleResult($data) {
643
-		// exclude shares leading to deleted file entries
644
-		if ($data['fileid'] === null) {
645
-			return false;
646
-		}
647
-
648
-		// exclude shares leading to trashbin on home storages
649
-		$pathSections = explode('/', $data['path'], 2);
650
-		// FIXME: would not detect rare md5'd home storage case properly
651
-		if ($pathSections[0] !== 'files'
652
-		    	&& in_array(explode(':', $data['storage_string_id'], 2)[0], array('home', 'object'))) {
653
-			return false;
654
-		}
655
-		return true;
656
-	}
657
-
658
-	/**
659
-	 * @inheritdoc
660
-	 */
661
-	public function getSharedWith($userId, $shareType, $node, $limit, $offset) {
662
-		/** @var Share[] $shares */
663
-		$shares = [];
664
-
665
-		if ($shareType === \OCP\Share::SHARE_TYPE_USER) {
666
-			//Get shares directly with this user
667
-			$qb = $this->dbConn->getQueryBuilder();
668
-			$qb->select('s.*',
669
-				'f.fileid', 'f.path', 'f.permissions AS f_permissions', 'f.storage', 'f.path_hash',
670
-				'f.parent AS f_parent', 'f.name', 'f.mimetype', 'f.mimepart', 'f.size', 'f.mtime', 'f.storage_mtime',
671
-				'f.encrypted', 'f.unencrypted_size', 'f.etag', 'f.checksum'
672
-			)
673
-				->selectAlias('st.id', 'storage_string_id')
674
-				->from('share', 's')
675
-				->leftJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'))
676
-				->leftJoin('f', 'storages', 'st', $qb->expr()->eq('f.storage', 'st.numeric_id'));
677
-
678
-			// Order by id
679
-			$qb->orderBy('s.id');
680
-
681
-			// Set limit and offset
682
-			if ($limit !== -1) {
683
-				$qb->setMaxResults($limit);
684
-			}
685
-			$qb->setFirstResult($offset);
686
-
687
-			$qb->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)))
688
-				->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($userId)))
689
-				->andWhere($qb->expr()->orX(
690
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
691
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
692
-				));
693
-
694
-			// Filter by node if provided
695
-			if ($node !== null) {
696
-				$qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
697
-			}
698
-
699
-			$cursor = $qb->execute();
700
-
701
-			while($data = $cursor->fetch()) {
702
-				if ($this->isAccessibleResult($data)) {
703
-					$shares[] = $this->createShare($data);
704
-				}
705
-			}
706
-			$cursor->closeCursor();
707
-
708
-		} else if ($shareType === \OCP\Share::SHARE_TYPE_GROUP) {
709
-			$user = $this->userManager->get($userId);
710
-			$allGroups = $this->groupManager->getUserGroups($user);
711
-
712
-			/** @var Share[] $shares2 */
713
-			$shares2 = [];
714
-
715
-			$start = 0;
716
-			while(true) {
717
-				$groups = array_slice($allGroups, $start, 100);
718
-				$start += 100;
719
-
720
-				if ($groups === []) {
721
-					break;
722
-				}
723
-
724
-				$qb = $this->dbConn->getQueryBuilder();
725
-				$qb->select('s.*',
726
-					'f.fileid', 'f.path', 'f.permissions AS f_permissions', 'f.storage', 'f.path_hash',
727
-					'f.parent AS f_parent', 'f.name', 'f.mimetype', 'f.mimepart', 'f.size', 'f.mtime', 'f.storage_mtime',
728
-					'f.encrypted', 'f.unencrypted_size', 'f.etag', 'f.checksum'
729
-				)
730
-					->selectAlias('st.id', 'storage_string_id')
731
-					->from('share', 's')
732
-					->leftJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'))
733
-					->leftJoin('f', 'storages', 'st', $qb->expr()->eq('f.storage', 'st.numeric_id'))
734
-					->orderBy('s.id')
735
-					->setFirstResult(0);
736
-
737
-				if ($limit !== -1) {
738
-					$qb->setMaxResults($limit - count($shares));
739
-				}
740
-
741
-				// Filter by node if provided
742
-				if ($node !== null) {
743
-					$qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
744
-				}
745
-
746
-
747
-				$groups = array_filter($groups, function($group) { return $group instanceof IGroup; });
748
-				$groups = array_map(function(IGroup $group) { return $group->getGID(); }, $groups);
749
-
750
-				$qb->andWhere($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
751
-					->andWhere($qb->expr()->in('share_with', $qb->createNamedParameter(
752
-						$groups,
753
-						IQueryBuilder::PARAM_STR_ARRAY
754
-					)))
755
-					->andWhere($qb->expr()->orX(
756
-						$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
757
-						$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
758
-					));
759
-
760
-				$cursor = $qb->execute();
761
-				while($data = $cursor->fetch()) {
762
-					if ($offset > 0) {
763
-						$offset--;
764
-						continue;
765
-					}
766
-
767
-					if ($this->isAccessibleResult($data)) {
768
-						$shares2[] = $this->createShare($data);
769
-					}
770
-				}
771
-				$cursor->closeCursor();
772
-			}
773
-
774
-			/*
361
+            if ($data === false) {
362
+                $qb = $this->dbConn->getQueryBuilder();
363
+
364
+                $type = $share->getNodeType();
365
+
366
+                //Insert new share
367
+                $qb->insert('share')
368
+                    ->values([
369
+                        'share_type' => $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP),
370
+                        'share_with' => $qb->createNamedParameter($recipient),
371
+                        'uid_owner' => $qb->createNamedParameter($share->getShareOwner()),
372
+                        'uid_initiator' => $qb->createNamedParameter($share->getSharedBy()),
373
+                        'parent' => $qb->createNamedParameter($share->getId()),
374
+                        'item_type' => $qb->createNamedParameter($type),
375
+                        'item_source' => $qb->createNamedParameter($share->getNodeId()),
376
+                        'file_source' => $qb->createNamedParameter($share->getNodeId()),
377
+                        'file_target' => $qb->createNamedParameter($share->getTarget()),
378
+                        'permissions' => $qb->createNamedParameter(0),
379
+                        'stime' => $qb->createNamedParameter($share->getShareTime()->getTimestamp()),
380
+                    ])->execute();
381
+
382
+            } else if ($data['permissions'] !== 0) {
383
+
384
+                // Update existing usergroup share
385
+                $qb = $this->dbConn->getQueryBuilder();
386
+                $qb->update('share')
387
+                    ->set('permissions', $qb->createNamedParameter(0))
388
+                    ->where($qb->expr()->eq('id', $qb->createNamedParameter($data['id'])))
389
+                    ->execute();
390
+            }
391
+
392
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
393
+
394
+            if ($share->getSharedWith() !== $recipient) {
395
+                throw new ProviderException('Recipient does not match');
396
+            }
397
+
398
+            // We can just delete user and link shares
399
+            $this->delete($share);
400
+        } else {
401
+            throw new ProviderException('Invalid shareType');
402
+        }
403
+    }
404
+
405
+    /**
406
+     * @inheritdoc
407
+     */
408
+    public function move(\OCP\Share\IShare $share, $recipient) {
409
+        if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
410
+            // Just update the target
411
+            $qb = $this->dbConn->getQueryBuilder();
412
+            $qb->update('share')
413
+                ->set('file_target', $qb->createNamedParameter($share->getTarget()))
414
+                ->where($qb->expr()->eq('id', $qb->createNamedParameter($share->getId())))
415
+                ->execute();
416
+
417
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
418
+
419
+            // Check if there is a usergroup share
420
+            $qb = $this->dbConn->getQueryBuilder();
421
+            $stmt = $qb->select('id')
422
+                ->from('share')
423
+                ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
424
+                ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($recipient)))
425
+                ->andWhere($qb->expr()->eq('parent', $qb->createNamedParameter($share->getId())))
426
+                ->andWhere($qb->expr()->orX(
427
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
428
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
429
+                ))
430
+                ->setMaxResults(1)
431
+                ->execute();
432
+
433
+            $data = $stmt->fetch();
434
+            $stmt->closeCursor();
435
+
436
+            if ($data === false) {
437
+                // No usergroup share yet. Create one.
438
+                $qb = $this->dbConn->getQueryBuilder();
439
+                $qb->insert('share')
440
+                    ->values([
441
+                        'share_type' => $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP),
442
+                        'share_with' => $qb->createNamedParameter($recipient),
443
+                        'uid_owner' => $qb->createNamedParameter($share->getShareOwner()),
444
+                        'uid_initiator' => $qb->createNamedParameter($share->getSharedBy()),
445
+                        'parent' => $qb->createNamedParameter($share->getId()),
446
+                        'item_type' => $qb->createNamedParameter($share->getNode() instanceof File ? 'file' : 'folder'),
447
+                        'item_source' => $qb->createNamedParameter($share->getNode()->getId()),
448
+                        'file_source' => $qb->createNamedParameter($share->getNode()->getId()),
449
+                        'file_target' => $qb->createNamedParameter($share->getTarget()),
450
+                        'permissions' => $qb->createNamedParameter($share->getPermissions()),
451
+                        'stime' => $qb->createNamedParameter($share->getShareTime()->getTimestamp()),
452
+                    ])->execute();
453
+            } else {
454
+                // Already a usergroup share. Update it.
455
+                $qb = $this->dbConn->getQueryBuilder();
456
+                $qb->update('share')
457
+                    ->set('file_target', $qb->createNamedParameter($share->getTarget()))
458
+                    ->where($qb->expr()->eq('id', $qb->createNamedParameter($data['id'])))
459
+                    ->execute();
460
+            }
461
+        }
462
+
463
+        return $share;
464
+    }
465
+
466
+    public function getSharesInFolder($userId, Folder $node, $reshares) {
467
+        $qb = $this->dbConn->getQueryBuilder();
468
+        $qb->select('*')
469
+            ->from('share', 's')
470
+            ->andWhere($qb->expr()->orX(
471
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
472
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
473
+            ));
474
+
475
+        $qb->andWhere($qb->expr()->orX(
476
+            $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)),
477
+            $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)),
478
+            $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK))
479
+        ));
480
+
481
+        /**
482
+         * Reshares for this user are shares where they are the owner.
483
+         */
484
+        if ($reshares === false) {
485
+            $qb->andWhere($qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId)));
486
+        } else {
487
+            $qb->andWhere(
488
+                $qb->expr()->orX(
489
+                    $qb->expr()->eq('uid_owner', $qb->createNamedParameter($userId)),
490
+                    $qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId))
491
+                )
492
+            );
493
+        }
494
+
495
+        $qb->innerJoin('s', 'filecache' ,'f', $qb->expr()->eq('s.file_source', 'f.fileid'));
496
+        $qb->andWhere($qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId())));
497
+
498
+        $qb->orderBy('id');
499
+
500
+        $cursor = $qb->execute();
501
+        $shares = [];
502
+        while ($data = $cursor->fetch()) {
503
+            $shares[$data['fileid']][] = $this->createShare($data);
504
+        }
505
+        $cursor->closeCursor();
506
+
507
+        return $shares;
508
+    }
509
+
510
+    /**
511
+     * @inheritdoc
512
+     */
513
+    public function getSharesBy($userId, $shareType, $node, $reshares, $limit, $offset) {
514
+        $qb = $this->dbConn->getQueryBuilder();
515
+        $qb->select('*')
516
+            ->from('share')
517
+            ->andWhere($qb->expr()->orX(
518
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
519
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
520
+            ));
521
+
522
+        $qb->andWhere($qb->expr()->eq('share_type', $qb->createNamedParameter($shareType)));
523
+
524
+        /**
525
+         * Reshares for this user are shares where they are the owner.
526
+         */
527
+        if ($reshares === false) {
528
+            $qb->andWhere($qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId)));
529
+        } else {
530
+            $qb->andWhere(
531
+                $qb->expr()->orX(
532
+                    $qb->expr()->eq('uid_owner', $qb->createNamedParameter($userId)),
533
+                    $qb->expr()->eq('uid_initiator', $qb->createNamedParameter($userId))
534
+                )
535
+            );
536
+        }
537
+
538
+        if ($node !== null) {
539
+            $qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
540
+        }
541
+
542
+        if ($limit !== -1) {
543
+            $qb->setMaxResults($limit);
544
+        }
545
+
546
+        $qb->setFirstResult($offset);
547
+        $qb->orderBy('id');
548
+
549
+        $cursor = $qb->execute();
550
+        $shares = [];
551
+        while($data = $cursor->fetch()) {
552
+            $shares[] = $this->createShare($data);
553
+        }
554
+        $cursor->closeCursor();
555
+
556
+        return $shares;
557
+    }
558
+
559
+    /**
560
+     * @inheritdoc
561
+     */
562
+    public function getShareById($id, $recipientId = null) {
563
+        $qb = $this->dbConn->getQueryBuilder();
564
+
565
+        $qb->select('*')
566
+            ->from('share')
567
+            ->where($qb->expr()->eq('id', $qb->createNamedParameter($id)))
568
+            ->andWhere(
569
+                $qb->expr()->in(
570
+                    'share_type',
571
+                    $qb->createNamedParameter([
572
+                        \OCP\Share::SHARE_TYPE_USER,
573
+                        \OCP\Share::SHARE_TYPE_GROUP,
574
+                        \OCP\Share::SHARE_TYPE_LINK,
575
+                    ], IQueryBuilder::PARAM_INT_ARRAY)
576
+                )
577
+            )
578
+            ->andWhere($qb->expr()->orX(
579
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
580
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
581
+            ));
582
+
583
+        $cursor = $qb->execute();
584
+        $data = $cursor->fetch();
585
+        $cursor->closeCursor();
586
+
587
+        if ($data === false) {
588
+            throw new ShareNotFound();
589
+        }
590
+
591
+        try {
592
+            $share = $this->createShare($data);
593
+        } catch (InvalidShare $e) {
594
+            throw new ShareNotFound();
595
+        }
596
+
597
+        // If the recipient is set for a group share resolve to that user
598
+        if ($recipientId !== null && $share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
599
+            $share = $this->resolveGroupShares([$share], $recipientId)[0];
600
+        }
601
+
602
+        return $share;
603
+    }
604
+
605
+    /**
606
+     * Get shares for a given path
607
+     *
608
+     * @param \OCP\Files\Node $path
609
+     * @return \OCP\Share\IShare[]
610
+     */
611
+    public function getSharesByPath(Node $path) {
612
+        $qb = $this->dbConn->getQueryBuilder();
613
+
614
+        $cursor = $qb->select('*')
615
+            ->from('share')
616
+            ->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($path->getId())))
617
+            ->andWhere(
618
+                $qb->expr()->orX(
619
+                    $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)),
620
+                    $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP))
621
+                )
622
+            )
623
+            ->andWhere($qb->expr()->orX(
624
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
625
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
626
+            ))
627
+            ->execute();
628
+
629
+        $shares = [];
630
+        while($data = $cursor->fetch()) {
631
+            $shares[] = $this->createShare($data);
632
+        }
633
+        $cursor->closeCursor();
634
+
635
+        return $shares;
636
+    }
637
+
638
+    /**
639
+     * Returns whether the given database result can be interpreted as
640
+     * a share with accessible file (not trashed, not deleted)
641
+     */
642
+    private function isAccessibleResult($data) {
643
+        // exclude shares leading to deleted file entries
644
+        if ($data['fileid'] === null) {
645
+            return false;
646
+        }
647
+
648
+        // exclude shares leading to trashbin on home storages
649
+        $pathSections = explode('/', $data['path'], 2);
650
+        // FIXME: would not detect rare md5'd home storage case properly
651
+        if ($pathSections[0] !== 'files'
652
+                && in_array(explode(':', $data['storage_string_id'], 2)[0], array('home', 'object'))) {
653
+            return false;
654
+        }
655
+        return true;
656
+    }
657
+
658
+    /**
659
+     * @inheritdoc
660
+     */
661
+    public function getSharedWith($userId, $shareType, $node, $limit, $offset) {
662
+        /** @var Share[] $shares */
663
+        $shares = [];
664
+
665
+        if ($shareType === \OCP\Share::SHARE_TYPE_USER) {
666
+            //Get shares directly with this user
667
+            $qb = $this->dbConn->getQueryBuilder();
668
+            $qb->select('s.*',
669
+                'f.fileid', 'f.path', 'f.permissions AS f_permissions', 'f.storage', 'f.path_hash',
670
+                'f.parent AS f_parent', 'f.name', 'f.mimetype', 'f.mimepart', 'f.size', 'f.mtime', 'f.storage_mtime',
671
+                'f.encrypted', 'f.unencrypted_size', 'f.etag', 'f.checksum'
672
+            )
673
+                ->selectAlias('st.id', 'storage_string_id')
674
+                ->from('share', 's')
675
+                ->leftJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'))
676
+                ->leftJoin('f', 'storages', 'st', $qb->expr()->eq('f.storage', 'st.numeric_id'));
677
+
678
+            // Order by id
679
+            $qb->orderBy('s.id');
680
+
681
+            // Set limit and offset
682
+            if ($limit !== -1) {
683
+                $qb->setMaxResults($limit);
684
+            }
685
+            $qb->setFirstResult($offset);
686
+
687
+            $qb->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)))
688
+                ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($userId)))
689
+                ->andWhere($qb->expr()->orX(
690
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
691
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
692
+                ));
693
+
694
+            // Filter by node if provided
695
+            if ($node !== null) {
696
+                $qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
697
+            }
698
+
699
+            $cursor = $qb->execute();
700
+
701
+            while($data = $cursor->fetch()) {
702
+                if ($this->isAccessibleResult($data)) {
703
+                    $shares[] = $this->createShare($data);
704
+                }
705
+            }
706
+            $cursor->closeCursor();
707
+
708
+        } else if ($shareType === \OCP\Share::SHARE_TYPE_GROUP) {
709
+            $user = $this->userManager->get($userId);
710
+            $allGroups = $this->groupManager->getUserGroups($user);
711
+
712
+            /** @var Share[] $shares2 */
713
+            $shares2 = [];
714
+
715
+            $start = 0;
716
+            while(true) {
717
+                $groups = array_slice($allGroups, $start, 100);
718
+                $start += 100;
719
+
720
+                if ($groups === []) {
721
+                    break;
722
+                }
723
+
724
+                $qb = $this->dbConn->getQueryBuilder();
725
+                $qb->select('s.*',
726
+                    'f.fileid', 'f.path', 'f.permissions AS f_permissions', 'f.storage', 'f.path_hash',
727
+                    'f.parent AS f_parent', 'f.name', 'f.mimetype', 'f.mimepart', 'f.size', 'f.mtime', 'f.storage_mtime',
728
+                    'f.encrypted', 'f.unencrypted_size', 'f.etag', 'f.checksum'
729
+                )
730
+                    ->selectAlias('st.id', 'storage_string_id')
731
+                    ->from('share', 's')
732
+                    ->leftJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid'))
733
+                    ->leftJoin('f', 'storages', 'st', $qb->expr()->eq('f.storage', 'st.numeric_id'))
734
+                    ->orderBy('s.id')
735
+                    ->setFirstResult(0);
736
+
737
+                if ($limit !== -1) {
738
+                    $qb->setMaxResults($limit - count($shares));
739
+                }
740
+
741
+                // Filter by node if provided
742
+                if ($node !== null) {
743
+                    $qb->andWhere($qb->expr()->eq('file_source', $qb->createNamedParameter($node->getId())));
744
+                }
745
+
746
+
747
+                $groups = array_filter($groups, function($group) { return $group instanceof IGroup; });
748
+                $groups = array_map(function(IGroup $group) { return $group->getGID(); }, $groups);
749
+
750
+                $qb->andWhere($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
751
+                    ->andWhere($qb->expr()->in('share_with', $qb->createNamedParameter(
752
+                        $groups,
753
+                        IQueryBuilder::PARAM_STR_ARRAY
754
+                    )))
755
+                    ->andWhere($qb->expr()->orX(
756
+                        $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
757
+                        $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
758
+                    ));
759
+
760
+                $cursor = $qb->execute();
761
+                while($data = $cursor->fetch()) {
762
+                    if ($offset > 0) {
763
+                        $offset--;
764
+                        continue;
765
+                    }
766
+
767
+                    if ($this->isAccessibleResult($data)) {
768
+                        $shares2[] = $this->createShare($data);
769
+                    }
770
+                }
771
+                $cursor->closeCursor();
772
+            }
773
+
774
+            /*
775 775
  			 * Resolve all group shares to user specific shares
776 776
  			 */
777
-			$shares = $this->resolveGroupShares($shares2, $userId);
778
-		} else {
779
-			throw new BackendError('Invalid backend');
780
-		}
781
-
782
-
783
-		return $shares;
784
-	}
785
-
786
-	/**
787
-	 * Get a share by token
788
-	 *
789
-	 * @param string $token
790
-	 * @return \OCP\Share\IShare
791
-	 * @throws ShareNotFound
792
-	 */
793
-	public function getShareByToken($token) {
794
-		$qb = $this->dbConn->getQueryBuilder();
795
-
796
-		$cursor = $qb->select('*')
797
-			->from('share')
798
-			->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK)))
799
-			->andWhere($qb->expr()->eq('token', $qb->createNamedParameter($token)))
800
-			->andWhere($qb->expr()->orX(
801
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
802
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
803
-			))
804
-			->execute();
805
-
806
-		$data = $cursor->fetch();
807
-
808
-		if ($data === false) {
809
-			throw new ShareNotFound();
810
-		}
811
-
812
-		try {
813
-			$share = $this->createShare($data);
814
-		} catch (InvalidShare $e) {
815
-			throw new ShareNotFound();
816
-		}
817
-
818
-		return $share;
819
-	}
820
-
821
-	/**
822
-	 * Create a share object from an database row
823
-	 *
824
-	 * @param mixed[] $data
825
-	 * @return \OCP\Share\IShare
826
-	 * @throws InvalidShare
827
-	 */
828
-	private function createShare($data) {
829
-		$share = new Share($this->rootFolder, $this->userManager);
830
-		$share->setId((int)$data['id'])
831
-			->setShareType((int)$data['share_type'])
832
-			->setPermissions((int)$data['permissions'])
833
-			->setTarget($data['file_target'])
834
-			->setMailSend((bool)$data['mail_send']);
835
-
836
-		$shareTime = new \DateTime();
837
-		$shareTime->setTimestamp((int)$data['stime']);
838
-		$share->setShareTime($shareTime);
839
-
840
-		if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
841
-			$share->setSharedWith($data['share_with']);
842
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
843
-			$share->setSharedWith($data['share_with']);
844
-		} else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_LINK) {
845
-			$share->setPassword($data['password']);
846
-			$share->setToken($data['token']);
847
-		}
848
-
849
-		$share->setSharedBy($data['uid_initiator']);
850
-		$share->setShareOwner($data['uid_owner']);
851
-
852
-		$share->setNodeId((int)$data['file_source']);
853
-		$share->setNodeType($data['item_type']);
854
-
855
-		if ($data['expiration'] !== null) {
856
-			$expiration = \DateTime::createFromFormat('Y-m-d H:i:s', $data['expiration']);
857
-			$share->setExpirationDate($expiration);
858
-		}
859
-
860
-		if (isset($data['f_permissions'])) {
861
-			$entryData = $data;
862
-			$entryData['permissions'] = $entryData['f_permissions'];
863
-			$entryData['parent'] = $entryData['f_parent'];;
864
-			$share->setNodeCacheEntry(Cache::cacheEntryFromData($entryData,
865
-				\OC::$server->getMimeTypeLoader()));
866
-		}
867
-
868
-		$share->setProviderId($this->identifier());
869
-
870
-		return $share;
871
-	}
872
-
873
-	/**
874
-	 * @param Share[] $shares
875
-	 * @param $userId
876
-	 * @return Share[] The updates shares if no update is found for a share return the original
877
-	 */
878
-	private function resolveGroupShares($shares, $userId) {
879
-		$result = [];
880
-
881
-		$start = 0;
882
-		while(true) {
883
-			/** @var Share[] $shareSlice */
884
-			$shareSlice = array_slice($shares, $start, 100);
885
-			$start += 100;
886
-
887
-			if ($shareSlice === []) {
888
-				break;
889
-			}
890
-
891
-			/** @var int[] $ids */
892
-			$ids = [];
893
-			/** @var Share[] $shareMap */
894
-			$shareMap = [];
895
-
896
-			foreach ($shareSlice as $share) {
897
-				$ids[] = (int)$share->getId();
898
-				$shareMap[$share->getId()] = $share;
899
-			}
900
-
901
-			$qb = $this->dbConn->getQueryBuilder();
902
-
903
-			$query = $qb->select('*')
904
-				->from('share')
905
-				->where($qb->expr()->in('parent', $qb->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY)))
906
-				->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($userId)))
907
-				->andWhere($qb->expr()->orX(
908
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
909
-					$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
910
-				));
911
-
912
-			$stmt = $query->execute();
913
-
914
-			while($data = $stmt->fetch()) {
915
-				$shareMap[$data['parent']]->setPermissions((int)$data['permissions']);
916
-				$shareMap[$data['parent']]->setTarget($data['file_target']);
917
-			}
918
-
919
-			$stmt->closeCursor();
920
-
921
-			foreach ($shareMap as $share) {
922
-				$result[] = $share;
923
-			}
924
-		}
925
-
926
-		return $result;
927
-	}
928
-
929
-	/**
930
-	 * A user is deleted from the system
931
-	 * So clean up the relevant shares.
932
-	 *
933
-	 * @param string $uid
934
-	 * @param int $shareType
935
-	 */
936
-	public function userDeleted($uid, $shareType) {
937
-		$qb = $this->dbConn->getQueryBuilder();
938
-
939
-		$qb->delete('share');
940
-
941
-		if ($shareType === \OCP\Share::SHARE_TYPE_USER) {
942
-			/*
777
+            $shares = $this->resolveGroupShares($shares2, $userId);
778
+        } else {
779
+            throw new BackendError('Invalid backend');
780
+        }
781
+
782
+
783
+        return $shares;
784
+    }
785
+
786
+    /**
787
+     * Get a share by token
788
+     *
789
+     * @param string $token
790
+     * @return \OCP\Share\IShare
791
+     * @throws ShareNotFound
792
+     */
793
+    public function getShareByToken($token) {
794
+        $qb = $this->dbConn->getQueryBuilder();
795
+
796
+        $cursor = $qb->select('*')
797
+            ->from('share')
798
+            ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK)))
799
+            ->andWhere($qb->expr()->eq('token', $qb->createNamedParameter($token)))
800
+            ->andWhere($qb->expr()->orX(
801
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
802
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
803
+            ))
804
+            ->execute();
805
+
806
+        $data = $cursor->fetch();
807
+
808
+        if ($data === false) {
809
+            throw new ShareNotFound();
810
+        }
811
+
812
+        try {
813
+            $share = $this->createShare($data);
814
+        } catch (InvalidShare $e) {
815
+            throw new ShareNotFound();
816
+        }
817
+
818
+        return $share;
819
+    }
820
+
821
+    /**
822
+     * Create a share object from an database row
823
+     *
824
+     * @param mixed[] $data
825
+     * @return \OCP\Share\IShare
826
+     * @throws InvalidShare
827
+     */
828
+    private function createShare($data) {
829
+        $share = new Share($this->rootFolder, $this->userManager);
830
+        $share->setId((int)$data['id'])
831
+            ->setShareType((int)$data['share_type'])
832
+            ->setPermissions((int)$data['permissions'])
833
+            ->setTarget($data['file_target'])
834
+            ->setMailSend((bool)$data['mail_send']);
835
+
836
+        $shareTime = new \DateTime();
837
+        $shareTime->setTimestamp((int)$data['stime']);
838
+        $share->setShareTime($shareTime);
839
+
840
+        if ($share->getShareType() === \OCP\Share::SHARE_TYPE_USER) {
841
+            $share->setSharedWith($data['share_with']);
842
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_GROUP) {
843
+            $share->setSharedWith($data['share_with']);
844
+        } else if ($share->getShareType() === \OCP\Share::SHARE_TYPE_LINK) {
845
+            $share->setPassword($data['password']);
846
+            $share->setToken($data['token']);
847
+        }
848
+
849
+        $share->setSharedBy($data['uid_initiator']);
850
+        $share->setShareOwner($data['uid_owner']);
851
+
852
+        $share->setNodeId((int)$data['file_source']);
853
+        $share->setNodeType($data['item_type']);
854
+
855
+        if ($data['expiration'] !== null) {
856
+            $expiration = \DateTime::createFromFormat('Y-m-d H:i:s', $data['expiration']);
857
+            $share->setExpirationDate($expiration);
858
+        }
859
+
860
+        if (isset($data['f_permissions'])) {
861
+            $entryData = $data;
862
+            $entryData['permissions'] = $entryData['f_permissions'];
863
+            $entryData['parent'] = $entryData['f_parent'];;
864
+            $share->setNodeCacheEntry(Cache::cacheEntryFromData($entryData,
865
+                \OC::$server->getMimeTypeLoader()));
866
+        }
867
+
868
+        $share->setProviderId($this->identifier());
869
+
870
+        return $share;
871
+    }
872
+
873
+    /**
874
+     * @param Share[] $shares
875
+     * @param $userId
876
+     * @return Share[] The updates shares if no update is found for a share return the original
877
+     */
878
+    private function resolveGroupShares($shares, $userId) {
879
+        $result = [];
880
+
881
+        $start = 0;
882
+        while(true) {
883
+            /** @var Share[] $shareSlice */
884
+            $shareSlice = array_slice($shares, $start, 100);
885
+            $start += 100;
886
+
887
+            if ($shareSlice === []) {
888
+                break;
889
+            }
890
+
891
+            /** @var int[] $ids */
892
+            $ids = [];
893
+            /** @var Share[] $shareMap */
894
+            $shareMap = [];
895
+
896
+            foreach ($shareSlice as $share) {
897
+                $ids[] = (int)$share->getId();
898
+                $shareMap[$share->getId()] = $share;
899
+            }
900
+
901
+            $qb = $this->dbConn->getQueryBuilder();
902
+
903
+            $query = $qb->select('*')
904
+                ->from('share')
905
+                ->where($qb->expr()->in('parent', $qb->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY)))
906
+                ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($userId)))
907
+                ->andWhere($qb->expr()->orX(
908
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
909
+                    $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
910
+                ));
911
+
912
+            $stmt = $query->execute();
913
+
914
+            while($data = $stmt->fetch()) {
915
+                $shareMap[$data['parent']]->setPermissions((int)$data['permissions']);
916
+                $shareMap[$data['parent']]->setTarget($data['file_target']);
917
+            }
918
+
919
+            $stmt->closeCursor();
920
+
921
+            foreach ($shareMap as $share) {
922
+                $result[] = $share;
923
+            }
924
+        }
925
+
926
+        return $result;
927
+    }
928
+
929
+    /**
930
+     * A user is deleted from the system
931
+     * So clean up the relevant shares.
932
+     *
933
+     * @param string $uid
934
+     * @param int $shareType
935
+     */
936
+    public function userDeleted($uid, $shareType) {
937
+        $qb = $this->dbConn->getQueryBuilder();
938
+
939
+        $qb->delete('share');
940
+
941
+        if ($shareType === \OCP\Share::SHARE_TYPE_USER) {
942
+            /*
943 943
 			 * Delete all user shares that are owned by this user
944 944
 			 * or that are received by this user
945 945
 			 */
946 946
 
947
-			$qb->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)));
947
+            $qb->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)));
948 948
 
949
-			$qb->andWhere(
950
-				$qb->expr()->orX(
951
-					$qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid)),
952
-					$qb->expr()->eq('share_with', $qb->createNamedParameter($uid))
953
-				)
954
-			);
955
-		} else if ($shareType === \OCP\Share::SHARE_TYPE_GROUP) {
956
-			/*
949
+            $qb->andWhere(
950
+                $qb->expr()->orX(
951
+                    $qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid)),
952
+                    $qb->expr()->eq('share_with', $qb->createNamedParameter($uid))
953
+                )
954
+            );
955
+        } else if ($shareType === \OCP\Share::SHARE_TYPE_GROUP) {
956
+            /*
957 957
 			 * Delete all group shares that are owned by this user
958 958
 			 * Or special user group shares that are received by this user
959 959
 			 */
960
-			$qb->where(
961
-				$qb->expr()->andX(
962
-					$qb->expr()->orX(
963
-						$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)),
964
-						$qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP))
965
-					),
966
-					$qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid))
967
-				)
968
-			);
969
-
970
-			$qb->orWhere(
971
-				$qb->expr()->andX(
972
-					$qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)),
973
-					$qb->expr()->eq('share_with', $qb->createNamedParameter($uid))
974
-				)
975
-			);
976
-		} else if ($shareType === \OCP\Share::SHARE_TYPE_LINK) {
977
-			/*
960
+            $qb->where(
961
+                $qb->expr()->andX(
962
+                    $qb->expr()->orX(
963
+                        $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)),
964
+                        $qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP))
965
+                    ),
966
+                    $qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid))
967
+                )
968
+            );
969
+
970
+            $qb->orWhere(
971
+                $qb->expr()->andX(
972
+                    $qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)),
973
+                    $qb->expr()->eq('share_with', $qb->createNamedParameter($uid))
974
+                )
975
+            );
976
+        } else if ($shareType === \OCP\Share::SHARE_TYPE_LINK) {
977
+            /*
978 978
 			 * Delete all link shares owned by this user.
979 979
 			 * And all link shares initiated by this user (until #22327 is in)
980 980
 			 */
981
-			$qb->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK)));
982
-
983
-			$qb->andWhere(
984
-				$qb->expr()->orX(
985
-					$qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid)),
986
-					$qb->expr()->eq('uid_initiator', $qb->createNamedParameter($uid))
987
-				)
988
-			);
989
-		}
990
-
991
-		$qb->execute();
992
-	}
993
-
994
-	/**
995
-	 * Delete all shares received by this group. As well as any custom group
996
-	 * shares for group members.
997
-	 *
998
-	 * @param string $gid
999
-	 */
1000
-	public function groupDeleted($gid) {
1001
-		/*
981
+            $qb->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK)));
982
+
983
+            $qb->andWhere(
984
+                $qb->expr()->orX(
985
+                    $qb->expr()->eq('uid_owner', $qb->createNamedParameter($uid)),
986
+                    $qb->expr()->eq('uid_initiator', $qb->createNamedParameter($uid))
987
+                )
988
+            );
989
+        }
990
+
991
+        $qb->execute();
992
+    }
993
+
994
+    /**
995
+     * Delete all shares received by this group. As well as any custom group
996
+     * shares for group members.
997
+     *
998
+     * @param string $gid
999
+     */
1000
+    public function groupDeleted($gid) {
1001
+        /*
1002 1002
 		 * First delete all custom group shares for group members
1003 1003
 		 */
1004
-		$qb = $this->dbConn->getQueryBuilder();
1005
-		$qb->select('id')
1006
-			->from('share')
1007
-			->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
1008
-			->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($gid)));
1009
-
1010
-		$cursor = $qb->execute();
1011
-		$ids = [];
1012
-		while($row = $cursor->fetch()) {
1013
-			$ids[] = (int)$row['id'];
1014
-		}
1015
-		$cursor->closeCursor();
1016
-
1017
-		if (!empty($ids)) {
1018
-			$chunks = array_chunk($ids, 100);
1019
-			foreach ($chunks as $chunk) {
1020
-				$qb->delete('share')
1021
-					->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
1022
-					->andWhere($qb->expr()->in('parent', $qb->createNamedParameter($chunk, IQueryBuilder::PARAM_INT_ARRAY)));
1023
-				$qb->execute();
1024
-			}
1025
-		}
1026
-
1027
-		/*
1004
+        $qb = $this->dbConn->getQueryBuilder();
1005
+        $qb->select('id')
1006
+            ->from('share')
1007
+            ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
1008
+            ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($gid)));
1009
+
1010
+        $cursor = $qb->execute();
1011
+        $ids = [];
1012
+        while($row = $cursor->fetch()) {
1013
+            $ids[] = (int)$row['id'];
1014
+        }
1015
+        $cursor->closeCursor();
1016
+
1017
+        if (!empty($ids)) {
1018
+            $chunks = array_chunk($ids, 100);
1019
+            foreach ($chunks as $chunk) {
1020
+                $qb->delete('share')
1021
+                    ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
1022
+                    ->andWhere($qb->expr()->in('parent', $qb->createNamedParameter($chunk, IQueryBuilder::PARAM_INT_ARRAY)));
1023
+                $qb->execute();
1024
+            }
1025
+        }
1026
+
1027
+        /*
1028 1028
 		 * Now delete all the group shares
1029 1029
 		 */
1030
-		$qb = $this->dbConn->getQueryBuilder();
1031
-		$qb->delete('share')
1032
-			->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
1033
-			->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($gid)));
1034
-		$qb->execute();
1035
-	}
1036
-
1037
-	/**
1038
-	 * Delete custom group shares to this group for this user
1039
-	 *
1040
-	 * @param string $uid
1041
-	 * @param string $gid
1042
-	 */
1043
-	public function userDeletedFromGroup($uid, $gid) {
1044
-		/*
1030
+        $qb = $this->dbConn->getQueryBuilder();
1031
+        $qb->delete('share')
1032
+            ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
1033
+            ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($gid)));
1034
+        $qb->execute();
1035
+    }
1036
+
1037
+    /**
1038
+     * Delete custom group shares to this group for this user
1039
+     *
1040
+     * @param string $uid
1041
+     * @param string $gid
1042
+     */
1043
+    public function userDeletedFromGroup($uid, $gid) {
1044
+        /*
1045 1045
 		 * Get all group shares
1046 1046
 		 */
1047
-		$qb = $this->dbConn->getQueryBuilder();
1048
-		$qb->select('id')
1049
-			->from('share')
1050
-			->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
1051
-			->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($gid)));
1052
-
1053
-		$cursor = $qb->execute();
1054
-		$ids = [];
1055
-		while($row = $cursor->fetch()) {
1056
-			$ids[] = (int)$row['id'];
1057
-		}
1058
-		$cursor->closeCursor();
1059
-
1060
-		if (!empty($ids)) {
1061
-			$chunks = array_chunk($ids, 100);
1062
-			foreach ($chunks as $chunk) {
1063
-				/*
1047
+        $qb = $this->dbConn->getQueryBuilder();
1048
+        $qb->select('id')
1049
+            ->from('share')
1050
+            ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)))
1051
+            ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($gid)));
1052
+
1053
+        $cursor = $qb->execute();
1054
+        $ids = [];
1055
+        while($row = $cursor->fetch()) {
1056
+            $ids[] = (int)$row['id'];
1057
+        }
1058
+        $cursor->closeCursor();
1059
+
1060
+        if (!empty($ids)) {
1061
+            $chunks = array_chunk($ids, 100);
1062
+            foreach ($chunks as $chunk) {
1063
+                /*
1064 1064
 				 * Delete all special shares wit this users for the found group shares
1065 1065
 				 */
1066
-				$qb->delete('share')
1067
-					->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
1068
-					->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($uid)))
1069
-					->andWhere($qb->expr()->in('parent', $qb->createNamedParameter($chunk, IQueryBuilder::PARAM_INT_ARRAY)));
1070
-				$qb->execute();
1071
-			}
1072
-		}
1073
-	}
1074
-
1075
-	/**
1076
-	 * @inheritdoc
1077
-	 */
1078
-	public function getAccessList($nodes, $currentAccess) {
1079
-		$ids = [];
1080
-		foreach ($nodes as $node) {
1081
-			$ids[] = $node->getId();
1082
-		}
1083
-
1084
-		$qb = $this->dbConn->getQueryBuilder();
1085
-
1086
-		$or = $qb->expr()->orX(
1087
-			$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)),
1088
-			$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)),
1089
-			$qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK))
1090
-		);
1091
-
1092
-		if ($currentAccess) {
1093
-			$or->add($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)));
1094
-		}
1095
-
1096
-		$qb->select('id', 'parent', 'share_type', 'share_with', 'file_source', 'file_target', 'permissions')
1097
-			->from('share')
1098
-			->where(
1099
-				$or
1100
-			)
1101
-			->andWhere($qb->expr()->in('file_source', $qb->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY)))
1102
-			->andWhere($qb->expr()->orX(
1103
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
1104
-				$qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
1105
-			));
1106
-		$cursor = $qb->execute();
1107
-
1108
-		$users = [];
1109
-		$link = false;
1110
-		while($row = $cursor->fetch()) {
1111
-			$type = (int)$row['share_type'];
1112
-			if ($type === \OCP\Share::SHARE_TYPE_USER) {
1113
-				$uid = $row['share_with'];
1114
-				$users[$uid] = isset($users[$uid]) ? $users[$uid] : [];
1115
-				$users[$uid][$row['id']] = $row;
1116
-			} else if ($type === \OCP\Share::SHARE_TYPE_GROUP) {
1117
-				$gid = $row['share_with'];
1118
-				$group = $this->groupManager->get($gid);
1119
-
1120
-				if ($gid === null) {
1121
-					continue;
1122
-				}
1123
-
1124
-				$userList = $group->getUsers();
1125
-				foreach ($userList as $user) {
1126
-					$uid = $user->getUID();
1127
-					$users[$uid] = isset($users[$uid]) ? $users[$uid] : [];
1128
-					$users[$uid][$row['id']] = $row;
1129
-				}
1130
-			} else if ($type === \OCP\Share::SHARE_TYPE_LINK) {
1131
-				$link = true;
1132
-			} else if ($type === self::SHARE_TYPE_USERGROUP && $currentAccess === true) {
1133
-				$uid = $row['share_with'];
1134
-				$users[$uid] = isset($users[$uid]) ? $users[$uid] : [];
1135
-				$users[$uid][$row['id']] = $row;
1136
-			}
1137
-		}
1138
-		$cursor->closeCursor();
1139
-
1140
-		if ($currentAccess === true) {
1141
-			$users = array_map([$this, 'filterSharesOfUser'], $users);
1142
-			$users = array_filter($users);
1143
-		} else {
1144
-			$users = array_keys($users);
1145
-		}
1146
-
1147
-		return ['users' => $users, 'public' => $link];
1148
-	}
1149
-
1150
-	/**
1151
-	 * For each user the path with the fewest slashes is returned
1152
-	 * @param array $shares
1153
-	 * @return array
1154
-	 */
1155
-	protected function filterSharesOfUser(array $shares) {
1156
-		// Group shares when the user has a share exception
1157
-		foreach ($shares as $id => $share) {
1158
-			$type = (int) $share['share_type'];
1159
-			$permissions = (int) $share['permissions'];
1160
-
1161
-			if ($type === self::SHARE_TYPE_USERGROUP) {
1162
-				unset($shares[$share['parent']]);
1163
-
1164
-				if ($permissions === 0) {
1165
-					unset($shares[$id]);
1166
-				}
1167
-			}
1168
-		}
1169
-
1170
-		$best = [];
1171
-		$bestDepth = 0;
1172
-		foreach ($shares as $id => $share) {
1173
-			$depth = substr_count($share['file_target'], '/');
1174
-			if (empty($best) || $depth < $bestDepth) {
1175
-				$bestDepth = $depth;
1176
-				$best = [
1177
-					'node_id' => $share['file_source'],
1178
-					'node_path' => $share['file_target'],
1179
-				];
1180
-			}
1181
-		}
1182
-
1183
-		return $best;
1184
-	}
1066
+                $qb->delete('share')
1067
+                    ->where($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)))
1068
+                    ->andWhere($qb->expr()->eq('share_with', $qb->createNamedParameter($uid)))
1069
+                    ->andWhere($qb->expr()->in('parent', $qb->createNamedParameter($chunk, IQueryBuilder::PARAM_INT_ARRAY)));
1070
+                $qb->execute();
1071
+            }
1072
+        }
1073
+    }
1074
+
1075
+    /**
1076
+     * @inheritdoc
1077
+     */
1078
+    public function getAccessList($nodes, $currentAccess) {
1079
+        $ids = [];
1080
+        foreach ($nodes as $node) {
1081
+            $ids[] = $node->getId();
1082
+        }
1083
+
1084
+        $qb = $this->dbConn->getQueryBuilder();
1085
+
1086
+        $or = $qb->expr()->orX(
1087
+            $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_USER)),
1088
+            $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_GROUP)),
1089
+            $qb->expr()->eq('share_type', $qb->createNamedParameter(\OCP\Share::SHARE_TYPE_LINK))
1090
+        );
1091
+
1092
+        if ($currentAccess) {
1093
+            $or->add($qb->expr()->eq('share_type', $qb->createNamedParameter(self::SHARE_TYPE_USERGROUP)));
1094
+        }
1095
+
1096
+        $qb->select('id', 'parent', 'share_type', 'share_with', 'file_source', 'file_target', 'permissions')
1097
+            ->from('share')
1098
+            ->where(
1099
+                $or
1100
+            )
1101
+            ->andWhere($qb->expr()->in('file_source', $qb->createNamedParameter($ids, IQueryBuilder::PARAM_INT_ARRAY)))
1102
+            ->andWhere($qb->expr()->orX(
1103
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('file')),
1104
+                $qb->expr()->eq('item_type', $qb->createNamedParameter('folder'))
1105
+            ));
1106
+        $cursor = $qb->execute();
1107
+
1108
+        $users = [];
1109
+        $link = false;
1110
+        while($row = $cursor->fetch()) {
1111
+            $type = (int)$row['share_type'];
1112
+            if ($type === \OCP\Share::SHARE_TYPE_USER) {
1113
+                $uid = $row['share_with'];
1114
+                $users[$uid] = isset($users[$uid]) ? $users[$uid] : [];
1115
+                $users[$uid][$row['id']] = $row;
1116
+            } else if ($type === \OCP\Share::SHARE_TYPE_GROUP) {
1117
+                $gid = $row['share_with'];
1118
+                $group = $this->groupManager->get($gid);
1119
+
1120
+                if ($gid === null) {
1121
+                    continue;
1122
+                }
1123
+
1124
+                $userList = $group->getUsers();
1125
+                foreach ($userList as $user) {
1126
+                    $uid = $user->getUID();
1127
+                    $users[$uid] = isset($users[$uid]) ? $users[$uid] : [];
1128
+                    $users[$uid][$row['id']] = $row;
1129
+                }
1130
+            } else if ($type === \OCP\Share::SHARE_TYPE_LINK) {
1131
+                $link = true;
1132
+            } else if ($type === self::SHARE_TYPE_USERGROUP && $currentAccess === true) {
1133
+                $uid = $row['share_with'];
1134
+                $users[$uid] = isset($users[$uid]) ? $users[$uid] : [];
1135
+                $users[$uid][$row['id']] = $row;
1136
+            }
1137
+        }
1138
+        $cursor->closeCursor();
1139
+
1140
+        if ($currentAccess === true) {
1141
+            $users = array_map([$this, 'filterSharesOfUser'], $users);
1142
+            $users = array_filter($users);
1143
+        } else {
1144
+            $users = array_keys($users);
1145
+        }
1146
+
1147
+        return ['users' => $users, 'public' => $link];
1148
+    }
1149
+
1150
+    /**
1151
+     * For each user the path with the fewest slashes is returned
1152
+     * @param array $shares
1153
+     * @return array
1154
+     */
1155
+    protected function filterSharesOfUser(array $shares) {
1156
+        // Group shares when the user has a share exception
1157
+        foreach ($shares as $id => $share) {
1158
+            $type = (int) $share['share_type'];
1159
+            $permissions = (int) $share['permissions'];
1160
+
1161
+            if ($type === self::SHARE_TYPE_USERGROUP) {
1162
+                unset($shares[$share['parent']]);
1163
+
1164
+                if ($permissions === 0) {
1165
+                    unset($shares[$id]);
1166
+                }
1167
+            }
1168
+        }
1169
+
1170
+        $best = [];
1171
+        $bestDepth = 0;
1172
+        foreach ($shares as $id => $share) {
1173
+            $depth = substr_count($share['file_target'], '/');
1174
+            if (empty($best) || $depth < $bestDepth) {
1175
+                $bestDepth = $depth;
1176
+                $best = [
1177
+                    'node_id' => $share['file_source'],
1178
+                    'node_path' => $share['file_target'],
1179
+                ];
1180
+            }
1181
+        }
1182
+
1183
+        return $best;
1184
+    }
1185 1185
 }
Please login to merge, or discard this patch.
lib/private/Group/Manager.php 1 patch
Indentation   +318 added lines, -318 removed lines patch added patch discarded remove patch
@@ -58,323 +58,323 @@
 block discarded – undo
58 58
  * @package OC\Group
59 59
  */
60 60
 class Manager extends PublicEmitter implements IGroupManager {
61
-	/**
62
-	 * @var GroupInterface[] $backends
63
-	 */
64
-	private $backends = array();
65
-
66
-	/**
67
-	 * @var \OC\User\Manager $userManager
68
-	 */
69
-	private $userManager;
70
-
71
-	/**
72
-	 * @var \OC\Group\Group[]
73
-	 */
74
-	private $cachedGroups = array();
75
-
76
-	/**
77
-	 * @var \OC\Group\Group[][]
78
-	 */
79
-	private $cachedUserGroups = array();
80
-
81
-	/** @var \OC\SubAdmin */
82
-	private $subAdmin = null;
83
-
84
-	/** @var ILogger */
85
-	private $logger;
86
-
87
-	/**
88
-	 * @param \OC\User\Manager $userManager
89
-	 * @param ILogger $logger
90
-	 */
91
-	public function __construct(\OC\User\Manager $userManager, ILogger $logger) {
92
-		$this->userManager = $userManager;
93
-		$this->logger = $logger;
94
-		$cachedGroups = & $this->cachedGroups;
95
-		$cachedUserGroups = & $this->cachedUserGroups;
96
-		$this->listen('\OC\Group', 'postDelete', function ($group) use (&$cachedGroups, &$cachedUserGroups) {
97
-			/**
98
-			 * @var \OC\Group\Group $group
99
-			 */
100
-			unset($cachedGroups[$group->getGID()]);
101
-			$cachedUserGroups = array();
102
-		});
103
-		$this->listen('\OC\Group', 'postAddUser', function ($group) use (&$cachedUserGroups) {
104
-			/**
105
-			 * @var \OC\Group\Group $group
106
-			 */
107
-			$cachedUserGroups = array();
108
-		});
109
-		$this->listen('\OC\Group', 'postRemoveUser', function ($group) use (&$cachedUserGroups) {
110
-			/**
111
-			 * @var \OC\Group\Group $group
112
-			 */
113
-			$cachedUserGroups = array();
114
-		});
115
-	}
116
-
117
-	/**
118
-	 * Checks whether a given backend is used
119
-	 *
120
-	 * @param string $backendClass Full classname including complete namespace
121
-	 * @return bool
122
-	 */
123
-	public function isBackendUsed($backendClass) {
124
-		$backendClass = strtolower(ltrim($backendClass, '\\'));
125
-
126
-		foreach ($this->backends as $backend) {
127
-			if (strtolower(get_class($backend)) === $backendClass) {
128
-				return true;
129
-			}
130
-		}
131
-
132
-		return false;
133
-	}
134
-
135
-	/**
136
-	 * @param \OCP\GroupInterface $backend
137
-	 */
138
-	public function addBackend($backend) {
139
-		$this->backends[] = $backend;
140
-		$this->clearCaches();
141
-	}
142
-
143
-	public function clearBackends() {
144
-		$this->backends = array();
145
-		$this->clearCaches();
146
-	}
61
+    /**
62
+     * @var GroupInterface[] $backends
63
+     */
64
+    private $backends = array();
65
+
66
+    /**
67
+     * @var \OC\User\Manager $userManager
68
+     */
69
+    private $userManager;
70
+
71
+    /**
72
+     * @var \OC\Group\Group[]
73
+     */
74
+    private $cachedGroups = array();
75
+
76
+    /**
77
+     * @var \OC\Group\Group[][]
78
+     */
79
+    private $cachedUserGroups = array();
80
+
81
+    /** @var \OC\SubAdmin */
82
+    private $subAdmin = null;
83
+
84
+    /** @var ILogger */
85
+    private $logger;
86
+
87
+    /**
88
+     * @param \OC\User\Manager $userManager
89
+     * @param ILogger $logger
90
+     */
91
+    public function __construct(\OC\User\Manager $userManager, ILogger $logger) {
92
+        $this->userManager = $userManager;
93
+        $this->logger = $logger;
94
+        $cachedGroups = & $this->cachedGroups;
95
+        $cachedUserGroups = & $this->cachedUserGroups;
96
+        $this->listen('\OC\Group', 'postDelete', function ($group) use (&$cachedGroups, &$cachedUserGroups) {
97
+            /**
98
+             * @var \OC\Group\Group $group
99
+             */
100
+            unset($cachedGroups[$group->getGID()]);
101
+            $cachedUserGroups = array();
102
+        });
103
+        $this->listen('\OC\Group', 'postAddUser', function ($group) use (&$cachedUserGroups) {
104
+            /**
105
+             * @var \OC\Group\Group $group
106
+             */
107
+            $cachedUserGroups = array();
108
+        });
109
+        $this->listen('\OC\Group', 'postRemoveUser', function ($group) use (&$cachedUserGroups) {
110
+            /**
111
+             * @var \OC\Group\Group $group
112
+             */
113
+            $cachedUserGroups = array();
114
+        });
115
+    }
116
+
117
+    /**
118
+     * Checks whether a given backend is used
119
+     *
120
+     * @param string $backendClass Full classname including complete namespace
121
+     * @return bool
122
+     */
123
+    public function isBackendUsed($backendClass) {
124
+        $backendClass = strtolower(ltrim($backendClass, '\\'));
125
+
126
+        foreach ($this->backends as $backend) {
127
+            if (strtolower(get_class($backend)) === $backendClass) {
128
+                return true;
129
+            }
130
+        }
131
+
132
+        return false;
133
+    }
134
+
135
+    /**
136
+     * @param \OCP\GroupInterface $backend
137
+     */
138
+    public function addBackend($backend) {
139
+        $this->backends[] = $backend;
140
+        $this->clearCaches();
141
+    }
142
+
143
+    public function clearBackends() {
144
+        $this->backends = array();
145
+        $this->clearCaches();
146
+    }
147 147
 	
148
-	protected function clearCaches() {
149
-		$this->cachedGroups = array();
150
-		$this->cachedUserGroups = array();
151
-	}
152
-
153
-	/**
154
-	 * @param string $gid
155
-	 * @return \OC\Group\Group
156
-	 */
157
-	public function get($gid) {
158
-		if (isset($this->cachedGroups[$gid])) {
159
-			return $this->cachedGroups[$gid];
160
-		}
161
-		return $this->getGroupObject($gid);
162
-	}
163
-
164
-	/**
165
-	 * @param string $gid
166
-	 * @param string $displayName
167
-	 * @return \OCP\IGroup
168
-	 */
169
-	protected function getGroupObject($gid, $displayName = null) {
170
-		$backends = array();
171
-		foreach ($this->backends as $backend) {
172
-			if ($backend->implementsActions(\OC\Group\Backend::GROUP_DETAILS)) {
173
-				$groupData = $backend->getGroupDetails($gid);
174
-				if (is_array($groupData)) {
175
-					// take the display name from the first backend that has a non-null one
176
-					if (is_null($displayName) && isset($groupData['displayName'])) {
177
-						$displayName = $groupData['displayName'];
178
-					}
179
-					$backends[] = $backend;
180
-				}
181
-			} else if ($backend->groupExists($gid)) {
182
-				$backends[] = $backend;
183
-			}
184
-		}
185
-		if (count($backends) === 0) {
186
-			return null;
187
-		}
188
-		$this->cachedGroups[$gid] = new Group($gid, $backends, $this->userManager, $this, $displayName);
189
-		return $this->cachedGroups[$gid];
190
-	}
191
-
192
-	/**
193
-	 * @param string $gid
194
-	 * @return bool
195
-	 */
196
-	public function groupExists($gid) {
197
-		return $this->get($gid) instanceof IGroup;
198
-	}
199
-
200
-	/**
201
-	 * @param string $gid
202
-	 * @return \OC\Group\Group
203
-	 */
204
-	public function createGroup($gid) {
205
-		if ($gid === '' || $gid === null) {
206
-			return false;
207
-		} else if ($group = $this->get($gid)) {
208
-			return $group;
209
-		} else {
210
-			$this->emit('\OC\Group', 'preCreate', array($gid));
211
-			foreach ($this->backends as $backend) {
212
-				if ($backend->implementsActions(\OC\Group\Backend::CREATE_GROUP)) {
213
-					$backend->createGroup($gid);
214
-					$group = $this->getGroupObject($gid);
215
-					$this->emit('\OC\Group', 'postCreate', array($group));
216
-					return $group;
217
-				}
218
-			}
219
-			return null;
220
-		}
221
-	}
222
-
223
-	/**
224
-	 * @param string $search
225
-	 * @param int $limit
226
-	 * @param int $offset
227
-	 * @return \OC\Group\Group[]
228
-	 */
229
-	public function search($search, $limit = null, $offset = null) {
230
-		$groups = array();
231
-		foreach ($this->backends as $backend) {
232
-			$groupIds = $backend->getGroups($search, $limit, $offset);
233
-			foreach ($groupIds as $groupId) {
234
-				$aGroup = $this->get($groupId);
235
-				if ($aGroup instanceof IGroup) {
236
-					$groups[$groupId] = $aGroup;
237
-				} else {
238
-					$this->logger->debug('Group "' . $groupId . '" was returned by search but not found through direct access', ['app' => 'core']);
239
-				}
240
-			}
241
-			if (!is_null($limit) and $limit <= 0) {
242
-				return array_values($groups);
243
-			}
244
-		}
245
-		return array_values($groups);
246
-	}
247
-
248
-	/**
249
-	 * @param \OC\User\User|null $user
250
-	 * @return \OC\Group\Group[]
251
-	 */
252
-	public function getUserGroups($user) {
253
-		if (!$user instanceof IUser) {
254
-			return [];
255
-		}
256
-		return $this->getUserIdGroups($user->getUID());
257
-	}
258
-
259
-	/**
260
-	 * @param string $uid the user id
261
-	 * @return \OC\Group\Group[]
262
-	 */
263
-	public function getUserIdGroups($uid) {
264
-		if (isset($this->cachedUserGroups[$uid])) {
265
-			return $this->cachedUserGroups[$uid];
266
-		}
267
-		$groups = array();
268
-		foreach ($this->backends as $backend) {
269
-			$groupIds = $backend->getUserGroups($uid);
270
-			if (is_array($groupIds)) {
271
-				foreach ($groupIds as $groupId) {
272
-					$aGroup = $this->get($groupId);
273
-					if ($aGroup instanceof IGroup) {
274
-						$groups[$groupId] = $aGroup;
275
-					} else {
276
-						$this->logger->debug('User "' . $uid . '" belongs to deleted group: "' . $groupId . '"', ['app' => 'core']);
277
-					}
278
-				}
279
-			}
280
-		}
281
-		$this->cachedUserGroups[$uid] = $groups;
282
-		return $this->cachedUserGroups[$uid];
283
-	}
284
-
285
-	/**
286
-	 * Checks if a userId is in the admin group
287
-	 * @param string $userId
288
-	 * @return bool if admin
289
-	 */
290
-	public function isAdmin($userId) {
291
-		return $this->isInGroup($userId, 'admin');
292
-	}
293
-
294
-	/**
295
-	 * Checks if a userId is in a group
296
-	 * @param string $userId
297
-	 * @param string $group
298
-	 * @return bool if in group
299
-	 */
300
-	public function isInGroup($userId, $group) {
301
-		return array_key_exists($group, $this->getUserIdGroups($userId));
302
-	}
303
-
304
-	/**
305
-	 * get a list of group ids for a user
306
-	 * @param \OC\User\User $user
307
-	 * @return array with group ids
308
-	 */
309
-	public function getUserGroupIds($user) {
310
-		return array_map(function($value) {
311
-			return (string) $value;
312
-		}, array_keys($this->getUserGroups($user)));
313
-	}
314
-
315
-	/**
316
-	 * get a list of all display names in a group
317
-	 * @param string $gid
318
-	 * @param string $search
319
-	 * @param int $limit
320
-	 * @param int $offset
321
-	 * @return array an array of display names (value) and user ids (key)
322
-	 */
323
-	public function displayNamesInGroup($gid, $search = '', $limit = -1, $offset = 0) {
324
-		$group = $this->get($gid);
325
-		if(is_null($group)) {
326
-			return array();
327
-		}
328
-
329
-		$search = trim($search);
330
-		$groupUsers = array();
331
-
332
-		if(!empty($search)) {
333
-			// only user backends have the capability to do a complex search for users
334
-			$searchOffset = 0;
335
-			$searchLimit = $limit * 100;
336
-			if($limit === -1) {
337
-				$searchLimit = 500;
338
-			}
339
-
340
-			do {
341
-				$filteredUsers = $this->userManager->searchDisplayName($search, $searchLimit, $searchOffset);
342
-				foreach($filteredUsers as $filteredUser) {
343
-					if($group->inGroup($filteredUser)) {
344
-						$groupUsers[]= $filteredUser;
345
-					}
346
-				}
347
-				$searchOffset += $searchLimit;
348
-			} while(count($groupUsers) < $searchLimit+$offset && count($filteredUsers) >= $searchLimit);
349
-
350
-			if($limit === -1) {
351
-				$groupUsers = array_slice($groupUsers, $offset);
352
-			} else {
353
-				$groupUsers = array_slice($groupUsers, $offset, $limit);
354
-			}
355
-		} else {
356
-			$groupUsers = $group->searchUsers('', $limit, $offset);
357
-		}
358
-
359
-		$matchingUsers = array();
360
-		foreach($groupUsers as $groupUser) {
361
-			$matchingUsers[$groupUser->getUID()] = $groupUser->getDisplayName();
362
-		}
363
-		return $matchingUsers;
364
-	}
365
-
366
-	/**
367
-	 * @return \OC\SubAdmin
368
-	 */
369
-	public function getSubAdmin() {
370
-		if (!$this->subAdmin) {
371
-			$this->subAdmin = new \OC\SubAdmin(
372
-				$this->userManager,
373
-				$this,
374
-				\OC::$server->getDatabaseConnection()
375
-			);
376
-		}
377
-
378
-		return $this->subAdmin;
379
-	}
148
+    protected function clearCaches() {
149
+        $this->cachedGroups = array();
150
+        $this->cachedUserGroups = array();
151
+    }
152
+
153
+    /**
154
+     * @param string $gid
155
+     * @return \OC\Group\Group
156
+     */
157
+    public function get($gid) {
158
+        if (isset($this->cachedGroups[$gid])) {
159
+            return $this->cachedGroups[$gid];
160
+        }
161
+        return $this->getGroupObject($gid);
162
+    }
163
+
164
+    /**
165
+     * @param string $gid
166
+     * @param string $displayName
167
+     * @return \OCP\IGroup
168
+     */
169
+    protected function getGroupObject($gid, $displayName = null) {
170
+        $backends = array();
171
+        foreach ($this->backends as $backend) {
172
+            if ($backend->implementsActions(\OC\Group\Backend::GROUP_DETAILS)) {
173
+                $groupData = $backend->getGroupDetails($gid);
174
+                if (is_array($groupData)) {
175
+                    // take the display name from the first backend that has a non-null one
176
+                    if (is_null($displayName) && isset($groupData['displayName'])) {
177
+                        $displayName = $groupData['displayName'];
178
+                    }
179
+                    $backends[] = $backend;
180
+                }
181
+            } else if ($backend->groupExists($gid)) {
182
+                $backends[] = $backend;
183
+            }
184
+        }
185
+        if (count($backends) === 0) {
186
+            return null;
187
+        }
188
+        $this->cachedGroups[$gid] = new Group($gid, $backends, $this->userManager, $this, $displayName);
189
+        return $this->cachedGroups[$gid];
190
+    }
191
+
192
+    /**
193
+     * @param string $gid
194
+     * @return bool
195
+     */
196
+    public function groupExists($gid) {
197
+        return $this->get($gid) instanceof IGroup;
198
+    }
199
+
200
+    /**
201
+     * @param string $gid
202
+     * @return \OC\Group\Group
203
+     */
204
+    public function createGroup($gid) {
205
+        if ($gid === '' || $gid === null) {
206
+            return false;
207
+        } else if ($group = $this->get($gid)) {
208
+            return $group;
209
+        } else {
210
+            $this->emit('\OC\Group', 'preCreate', array($gid));
211
+            foreach ($this->backends as $backend) {
212
+                if ($backend->implementsActions(\OC\Group\Backend::CREATE_GROUP)) {
213
+                    $backend->createGroup($gid);
214
+                    $group = $this->getGroupObject($gid);
215
+                    $this->emit('\OC\Group', 'postCreate', array($group));
216
+                    return $group;
217
+                }
218
+            }
219
+            return null;
220
+        }
221
+    }
222
+
223
+    /**
224
+     * @param string $search
225
+     * @param int $limit
226
+     * @param int $offset
227
+     * @return \OC\Group\Group[]
228
+     */
229
+    public function search($search, $limit = null, $offset = null) {
230
+        $groups = array();
231
+        foreach ($this->backends as $backend) {
232
+            $groupIds = $backend->getGroups($search, $limit, $offset);
233
+            foreach ($groupIds as $groupId) {
234
+                $aGroup = $this->get($groupId);
235
+                if ($aGroup instanceof IGroup) {
236
+                    $groups[$groupId] = $aGroup;
237
+                } else {
238
+                    $this->logger->debug('Group "' . $groupId . '" was returned by search but not found through direct access', ['app' => 'core']);
239
+                }
240
+            }
241
+            if (!is_null($limit) and $limit <= 0) {
242
+                return array_values($groups);
243
+            }
244
+        }
245
+        return array_values($groups);
246
+    }
247
+
248
+    /**
249
+     * @param \OC\User\User|null $user
250
+     * @return \OC\Group\Group[]
251
+     */
252
+    public function getUserGroups($user) {
253
+        if (!$user instanceof IUser) {
254
+            return [];
255
+        }
256
+        return $this->getUserIdGroups($user->getUID());
257
+    }
258
+
259
+    /**
260
+     * @param string $uid the user id
261
+     * @return \OC\Group\Group[]
262
+     */
263
+    public function getUserIdGroups($uid) {
264
+        if (isset($this->cachedUserGroups[$uid])) {
265
+            return $this->cachedUserGroups[$uid];
266
+        }
267
+        $groups = array();
268
+        foreach ($this->backends as $backend) {
269
+            $groupIds = $backend->getUserGroups($uid);
270
+            if (is_array($groupIds)) {
271
+                foreach ($groupIds as $groupId) {
272
+                    $aGroup = $this->get($groupId);
273
+                    if ($aGroup instanceof IGroup) {
274
+                        $groups[$groupId] = $aGroup;
275
+                    } else {
276
+                        $this->logger->debug('User "' . $uid . '" belongs to deleted group: "' . $groupId . '"', ['app' => 'core']);
277
+                    }
278
+                }
279
+            }
280
+        }
281
+        $this->cachedUserGroups[$uid] = $groups;
282
+        return $this->cachedUserGroups[$uid];
283
+    }
284
+
285
+    /**
286
+     * Checks if a userId is in the admin group
287
+     * @param string $userId
288
+     * @return bool if admin
289
+     */
290
+    public function isAdmin($userId) {
291
+        return $this->isInGroup($userId, 'admin');
292
+    }
293
+
294
+    /**
295
+     * Checks if a userId is in a group
296
+     * @param string $userId
297
+     * @param string $group
298
+     * @return bool if in group
299
+     */
300
+    public function isInGroup($userId, $group) {
301
+        return array_key_exists($group, $this->getUserIdGroups($userId));
302
+    }
303
+
304
+    /**
305
+     * get a list of group ids for a user
306
+     * @param \OC\User\User $user
307
+     * @return array with group ids
308
+     */
309
+    public function getUserGroupIds($user) {
310
+        return array_map(function($value) {
311
+            return (string) $value;
312
+        }, array_keys($this->getUserGroups($user)));
313
+    }
314
+
315
+    /**
316
+     * get a list of all display names in a group
317
+     * @param string $gid
318
+     * @param string $search
319
+     * @param int $limit
320
+     * @param int $offset
321
+     * @return array an array of display names (value) and user ids (key)
322
+     */
323
+    public function displayNamesInGroup($gid, $search = '', $limit = -1, $offset = 0) {
324
+        $group = $this->get($gid);
325
+        if(is_null($group)) {
326
+            return array();
327
+        }
328
+
329
+        $search = trim($search);
330
+        $groupUsers = array();
331
+
332
+        if(!empty($search)) {
333
+            // only user backends have the capability to do a complex search for users
334
+            $searchOffset = 0;
335
+            $searchLimit = $limit * 100;
336
+            if($limit === -1) {
337
+                $searchLimit = 500;
338
+            }
339
+
340
+            do {
341
+                $filteredUsers = $this->userManager->searchDisplayName($search, $searchLimit, $searchOffset);
342
+                foreach($filteredUsers as $filteredUser) {
343
+                    if($group->inGroup($filteredUser)) {
344
+                        $groupUsers[]= $filteredUser;
345
+                    }
346
+                }
347
+                $searchOffset += $searchLimit;
348
+            } while(count($groupUsers) < $searchLimit+$offset && count($filteredUsers) >= $searchLimit);
349
+
350
+            if($limit === -1) {
351
+                $groupUsers = array_slice($groupUsers, $offset);
352
+            } else {
353
+                $groupUsers = array_slice($groupUsers, $offset, $limit);
354
+            }
355
+        } else {
356
+            $groupUsers = $group->searchUsers('', $limit, $offset);
357
+        }
358
+
359
+        $matchingUsers = array();
360
+        foreach($groupUsers as $groupUser) {
361
+            $matchingUsers[$groupUser->getUID()] = $groupUser->getDisplayName();
362
+        }
363
+        return $matchingUsers;
364
+    }
365
+
366
+    /**
367
+     * @return \OC\SubAdmin
368
+     */
369
+    public function getSubAdmin() {
370
+        if (!$this->subAdmin) {
371
+            $this->subAdmin = new \OC\SubAdmin(
372
+                $this->userManager,
373
+                $this,
374
+                \OC::$server->getDatabaseConnection()
375
+            );
376
+        }
377
+
378
+        return $this->subAdmin;
379
+    }
380 380
 }
Please login to merge, or discard this patch.