Passed
Push — master ( c00d6f...a085a8 )
by Morris
09:54 queued 11s
created
apps/dav/lib/CardDAV/Xml/Groups.php 2 patches
Indentation   +14 added lines, -14 removed lines patch added patch discarded remove patch
@@ -26,21 +26,21 @@
 block discarded – undo
26 26
 use Sabre\Xml\Writer;
27 27
 
28 28
 class Groups implements XmlSerializable {
29
-	const NS_OWNCLOUD = 'http://owncloud.org/ns';
29
+    const NS_OWNCLOUD = 'http://owncloud.org/ns';
30 30
 
31
-	/** @var string[] of TYPE:CHECKSUM */
32
-	private $groups;
31
+    /** @var string[] of TYPE:CHECKSUM */
32
+    private $groups;
33 33
 
34
-	/**
35
-	 * @param string $groups
36
-	 */
37
-	public function __construct($groups) {
38
-		$this->groups = $groups;
39
-	}
34
+    /**
35
+     * @param string $groups
36
+     */
37
+    public function __construct($groups) {
38
+        $this->groups = $groups;
39
+    }
40 40
 
41
-	function xmlSerialize(Writer $writer) {
42
-		foreach ($this->groups as $group) {
43
-			$writer->writeElement('{' . self::NS_OWNCLOUD . '}group', $group);
44
-		}
45
-	}
41
+    function xmlSerialize(Writer $writer) {
42
+        foreach ($this->groups as $group) {
43
+            $writer->writeElement('{' . self::NS_OWNCLOUD . '}group', $group);
44
+        }
45
+    }
46 46
 }
Please login to merge, or discard this patch.
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -40,7 +40,7 @@
 block discarded – undo
40 40
 
41 41
 	function xmlSerialize(Writer $writer) {
42 42
 		foreach ($this->groups as $group) {
43
-			$writer->writeElement('{' . self::NS_OWNCLOUD . '}group', $group);
43
+			$writer->writeElement('{'.self::NS_OWNCLOUD.'}group', $group);
44 44
 		}
45 45
 	}
46 46
 }
Please login to merge, or discard this patch.
apps/dav/lib/CardDAV/AddressBookRoot.php 1 patch
Indentation   +33 added lines, -33 removed lines patch added patch discarded remove patch
@@ -25,46 +25,46 @@
 block discarded – undo
25 25
 
26 26
 class AddressBookRoot extends \Sabre\CardDAV\AddressBookRoot {
27 27
 
28
-	/** @var IL10N */
29
-	protected $l10n;
28
+    /** @var IL10N */
29
+    protected $l10n;
30 30
 
31
-	/**
32
-	 * @param \Sabre\DAVACL\PrincipalBackend\BackendInterface $principalBackend
33
-	 * @param \Sabre\CardDAV\Backend\BackendInterface $carddavBackend
34
-	 * @param string $principalPrefix
35
-	 */
36
-	public function __construct(\Sabre\DAVACL\PrincipalBackend\BackendInterface $principalBackend, \Sabre\CardDAV\Backend\BackendInterface $carddavBackend, $principalPrefix = 'principals') {
37
-		parent::__construct($principalBackend, $carddavBackend, $principalPrefix);
38
-		$this->l10n = \OC::$server->getL10N('dav');
39
-	}
31
+    /**
32
+     * @param \Sabre\DAVACL\PrincipalBackend\BackendInterface $principalBackend
33
+     * @param \Sabre\CardDAV\Backend\BackendInterface $carddavBackend
34
+     * @param string $principalPrefix
35
+     */
36
+    public function __construct(\Sabre\DAVACL\PrincipalBackend\BackendInterface $principalBackend, \Sabre\CardDAV\Backend\BackendInterface $carddavBackend, $principalPrefix = 'principals') {
37
+        parent::__construct($principalBackend, $carddavBackend, $principalPrefix);
38
+        $this->l10n = \OC::$server->getL10N('dav');
39
+    }
40 40
 
41
-	/**
42
-	 * This method returns a node for a principal.
43
-	 *
44
-	 * The passed array contains principal information, and is guaranteed to
45
-	 * at least contain a uri item. Other properties may or may not be
46
-	 * supplied by the authentication backend.
47
-	 *
48
-	 * @param array $principal
49
-	 * @return \Sabre\DAV\INode
50
-	 */
51
-	function getChildForPrincipal(array $principal) {
41
+    /**
42
+     * This method returns a node for a principal.
43
+     *
44
+     * The passed array contains principal information, and is guaranteed to
45
+     * at least contain a uri item. Other properties may or may not be
46
+     * supplied by the authentication backend.
47
+     *
48
+     * @param array $principal
49
+     * @return \Sabre\DAV\INode
50
+     */
51
+    function getChildForPrincipal(array $principal) {
52 52
 
53
-		return new UserAddressBooks($this->carddavBackend, $principal['uri'], $this->l10n);
53
+        return new UserAddressBooks($this->carddavBackend, $principal['uri'], $this->l10n);
54 54
 
55
-	}
55
+    }
56 56
 
57
-	function getName() {
57
+    function getName() {
58 58
 
59
-		if ($this->principalPrefix === 'principals') {
60
-			return parent::getName();
61
-		}
62
-		// Grabbing all the components of the principal path.
63
-		$parts = explode('/', $this->principalPrefix);
59
+        if ($this->principalPrefix === 'principals') {
60
+            return parent::getName();
61
+        }
62
+        // Grabbing all the components of the principal path.
63
+        $parts = explode('/', $this->principalPrefix);
64 64
 
65
-		// We are only interested in the second part.
66
-		return $parts[1];
65
+        // We are only interested in the second part.
66
+        return $parts[1];
67 67
 
68
-	}
68
+    }
69 69
 
70 70
 }
Please login to merge, or discard this patch.
apps/dav/lib/CardDAV/CardDavBackend.php 3 patches
Braces   +3 added lines, -1 removed lines patch added patch discarded remove patch
@@ -745,7 +745,9 @@
 block discarded – undo
745 745
 		$stmt->execute([ $addressBookId ]);
746 746
 		$currentToken = $stmt->fetchColumn(0);
747 747
 
748
-		if (is_null($currentToken)) return null;
748
+		if (is_null($currentToken)) {
749
+		    return null;
750
+		}
749 751
 
750 752
 		$result = [
751 753
 			'syncToken' => $currentToken,
Please login to merge, or discard this patch.
Indentation   +1118 added lines, -1118 removed lines patch added patch discarded remove patch
@@ -53,1122 +53,1122 @@
 block discarded – undo
53 53
 
54 54
 class CardDavBackend implements BackendInterface, SyncSupport {
55 55
 
56
-	const PERSONAL_ADDRESSBOOK_URI = 'contacts';
57
-	const PERSONAL_ADDRESSBOOK_NAME = 'Contacts';
58
-
59
-	/** @var Principal */
60
-	private $principalBackend;
61
-
62
-	/** @var string */
63
-	private $dbCardsTable = 'cards';
64
-
65
-	/** @var string */
66
-	private $dbCardsPropertiesTable = 'cards_properties';
67
-
68
-	/** @var IDBConnection */
69
-	private $db;
70
-
71
-	/** @var Backend */
72
-	private $sharingBackend;
73
-
74
-	/** @var array properties to index */
75
-	public static $indexProperties = array(
76
-			'BDAY', 'UID', 'N', 'FN', 'TITLE', 'ROLE', 'NOTE', 'NICKNAME',
77
-			'ORG', 'CATEGORIES', 'EMAIL', 'TEL', 'IMPP', 'ADR', 'URL', 'GEO', 'CLOUD');
78
-
79
-	/**
80
-	 * @var string[] Map of uid => display name
81
-	 */
82
-	protected $userDisplayNames;
83
-
84
-	/** @var IUserManager */
85
-	private $userManager;
86
-
87
-	/** @var EventDispatcherInterface */
88
-	private $dispatcher;
89
-
90
-	/**
91
-	 * CardDavBackend constructor.
92
-	 *
93
-	 * @param IDBConnection $db
94
-	 * @param Principal $principalBackend
95
-	 * @param IUserManager $userManager
96
-	 * @param IGroupManager $groupManager
97
-	 * @param EventDispatcherInterface $dispatcher
98
-	 */
99
-	public function __construct(IDBConnection $db,
100
-								Principal $principalBackend,
101
-								IUserManager $userManager,
102
-								IGroupManager $groupManager,
103
-								EventDispatcherInterface $dispatcher) {
104
-		$this->db = $db;
105
-		$this->principalBackend = $principalBackend;
106
-		$this->userManager = $userManager;
107
-		$this->dispatcher = $dispatcher;
108
-		$this->sharingBackend = new Backend($this->db, $this->userManager, $groupManager, $principalBackend, 'addressbook');
109
-	}
110
-
111
-	/**
112
-	 * Return the number of address books for a principal
113
-	 *
114
-	 * @param $principalUri
115
-	 * @return int
116
-	 */
117
-	public function getAddressBooksForUserCount($principalUri) {
118
-		$principalUri = $this->convertPrincipal($principalUri, true);
119
-		$query = $this->db->getQueryBuilder();
120
-		$query->select($query->func()->count('*'))
121
-			->from('addressbooks')
122
-			->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
123
-
124
-		return (int)$query->execute()->fetchColumn();
125
-	}
126
-
127
-	/**
128
-	 * Returns the list of address books for a specific user.
129
-	 *
130
-	 * Every addressbook should have the following properties:
131
-	 *   id - an arbitrary unique id
132
-	 *   uri - the 'basename' part of the url
133
-	 *   principaluri - Same as the passed parameter
134
-	 *
135
-	 * Any additional clark-notation property may be passed besides this. Some
136
-	 * common ones are :
137
-	 *   {DAV:}displayname
138
-	 *   {urn:ietf:params:xml:ns:carddav}addressbook-description
139
-	 *   {http://calendarserver.org/ns/}getctag
140
-	 *
141
-	 * @param string $principalUri
142
-	 * @return array
143
-	 */
144
-	function getAddressBooksForUser($principalUri) {
145
-		$principalUriOriginal = $principalUri;
146
-		$principalUri = $this->convertPrincipal($principalUri, true);
147
-		$query = $this->db->getQueryBuilder();
148
-		$query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
149
-			->from('addressbooks')
150
-			->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
151
-
152
-		$addressBooks = [];
153
-
154
-		$result = $query->execute();
155
-		while($row = $result->fetch()) {
156
-			$addressBooks[$row['id']] = [
157
-				'id'  => $row['id'],
158
-				'uri' => $row['uri'],
159
-				'principaluri' => $this->convertPrincipal($row['principaluri'], false),
160
-				'{DAV:}displayname' => $row['displayname'],
161
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
162
-				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
163
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
164
-			];
165
-
166
-			$this->addOwnerPrincipal($addressBooks[$row['id']]);
167
-		}
168
-		$result->closeCursor();
169
-
170
-		// query for shared addressbooks
171
-		$principals = $this->principalBackend->getGroupMembership($principalUriOriginal, true);
172
-		$principals = array_merge($principals, $this->principalBackend->getCircleMembership($principalUriOriginal));
173
-
174
-		$principals = array_map(function($principal) {
175
-			return urldecode($principal);
176
-		}, $principals);
177
-		$principals[]= $principalUri;
178
-
179
-		$query = $this->db->getQueryBuilder();
180
-		$result = $query->select(['a.id', 'a.uri', 'a.displayname', 'a.principaluri', 'a.description', 'a.synctoken', 's.access'])
181
-			->from('dav_shares', 's')
182
-			->join('s', 'addressbooks', 'a', $query->expr()->eq('s.resourceid', 'a.id'))
183
-			->where($query->expr()->in('s.principaluri', $query->createParameter('principaluri')))
184
-			->andWhere($query->expr()->eq('s.type', $query->createParameter('type')))
185
-			->setParameter('type', 'addressbook')
186
-			->setParameter('principaluri', $principals, IQueryBuilder::PARAM_STR_ARRAY)
187
-			->execute();
188
-
189
-		$readOnlyPropertyName = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}read-only';
190
-		while($row = $result->fetch()) {
191
-			if ($row['principaluri'] === $principalUri) {
192
-				continue;
193
-			}
194
-
195
-			$readOnly = (int) $row['access'] === Backend::ACCESS_READ;
196
-			if (isset($addressBooks[$row['id']])) {
197
-				if ($readOnly) {
198
-					// New share can not have more permissions then the old one.
199
-					continue;
200
-				}
201
-				if (isset($addressBooks[$row['id']][$readOnlyPropertyName]) &&
202
-					$addressBooks[$row['id']][$readOnlyPropertyName] === 0) {
203
-					// Old share is already read-write, no more permissions can be gained
204
-					continue;
205
-				}
206
-			}
207
-
208
-			list(, $name) = \Sabre\Uri\split($row['principaluri']);
209
-			$uri = $row['uri'] . '_shared_by_' . $name;
210
-			$displayName = $row['displayname'] . ' (' . $this->getUserDisplayName($name) . ')';
211
-
212
-			$addressBooks[$row['id']] = [
213
-				'id'  => $row['id'],
214
-				'uri' => $uri,
215
-				'principaluri' => $principalUriOriginal,
216
-				'{DAV:}displayname' => $displayName,
217
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
218
-				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
219
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
220
-				'{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal' => $row['principaluri'],
221
-				$readOnlyPropertyName => $readOnly,
222
-			];
223
-
224
-			$this->addOwnerPrincipal($addressBooks[$row['id']]);
225
-		}
226
-		$result->closeCursor();
227
-
228
-		return array_values($addressBooks);
229
-	}
230
-
231
-	public function getUsersOwnAddressBooks($principalUri) {
232
-		$principalUri = $this->convertPrincipal($principalUri, true);
233
-		$query = $this->db->getQueryBuilder();
234
-		$query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
235
-			  ->from('addressbooks')
236
-			  ->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
237
-
238
-		$addressBooks = [];
239
-
240
-		$result = $query->execute();
241
-		while($row = $result->fetch()) {
242
-			$addressBooks[$row['id']] = [
243
-				'id'  => $row['id'],
244
-				'uri' => $row['uri'],
245
-				'principaluri' => $this->convertPrincipal($row['principaluri'], false),
246
-				'{DAV:}displayname' => $row['displayname'],
247
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
248
-				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
249
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
250
-			];
251
-
252
-			$this->addOwnerPrincipal($addressBooks[$row['id']]);
253
-		}
254
-		$result->closeCursor();
255
-
256
-		return array_values($addressBooks);
257
-	}
258
-
259
-	private function getUserDisplayName($uid) {
260
-		if (!isset($this->userDisplayNames[$uid])) {
261
-			$user = $this->userManager->get($uid);
262
-
263
-			if ($user instanceof IUser) {
264
-				$this->userDisplayNames[$uid] = $user->getDisplayName();
265
-			} else {
266
-				$this->userDisplayNames[$uid] = $uid;
267
-			}
268
-		}
269
-
270
-		return $this->userDisplayNames[$uid];
271
-	}
272
-
273
-	/**
274
-	 * @param int $addressBookId
275
-	 */
276
-	public function getAddressBookById($addressBookId) {
277
-		$query = $this->db->getQueryBuilder();
278
-		$result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
279
-			->from('addressbooks')
280
-			->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
281
-			->execute();
282
-
283
-		$row = $result->fetch();
284
-		$result->closeCursor();
285
-		if ($row === false) {
286
-			return null;
287
-		}
288
-
289
-		$addressBook = [
290
-			'id'  => $row['id'],
291
-			'uri' => $row['uri'],
292
-			'principaluri' => $row['principaluri'],
293
-			'{DAV:}displayname' => $row['displayname'],
294
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
295
-			'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
296
-			'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
297
-		];
298
-
299
-		$this->addOwnerPrincipal($addressBook);
300
-
301
-		return $addressBook;
302
-	}
303
-
304
-	/**
305
-	 * @param $addressBookUri
306
-	 * @return array|null
307
-	 */
308
-	public function getAddressBooksByUri($principal, $addressBookUri) {
309
-		$query = $this->db->getQueryBuilder();
310
-		$result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
311
-			->from('addressbooks')
312
-			->where($query->expr()->eq('uri', $query->createNamedParameter($addressBookUri)))
313
-			->andWhere($query->expr()->eq('principaluri', $query->createNamedParameter($principal)))
314
-			->setMaxResults(1)
315
-			->execute();
316
-
317
-		$row = $result->fetch();
318
-		$result->closeCursor();
319
-		if ($row === false) {
320
-			return null;
321
-		}
322
-
323
-		$addressBook = [
324
-			'id'  => $row['id'],
325
-			'uri' => $row['uri'],
326
-			'principaluri' => $row['principaluri'],
327
-			'{DAV:}displayname' => $row['displayname'],
328
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
329
-			'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
330
-			'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
331
-		];
332
-
333
-		$this->addOwnerPrincipal($addressBook);
334
-
335
-		return $addressBook;
336
-	}
337
-
338
-	/**
339
-	 * Updates properties for an address book.
340
-	 *
341
-	 * The list of mutations is stored in a Sabre\DAV\PropPatch object.
342
-	 * To do the actual updates, you must tell this object which properties
343
-	 * you're going to process with the handle() method.
344
-	 *
345
-	 * Calling the handle method is like telling the PropPatch object "I
346
-	 * promise I can handle updating this property".
347
-	 *
348
-	 * Read the PropPatch documentation for more info and examples.
349
-	 *
350
-	 * @param string $addressBookId
351
-	 * @param \Sabre\DAV\PropPatch $propPatch
352
-	 * @return void
353
-	 */
354
-	function updateAddressBook($addressBookId, \Sabre\DAV\PropPatch $propPatch) {
355
-		$supportedProperties = [
356
-			'{DAV:}displayname',
357
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description',
358
-		];
359
-
360
-		/**
361
-		 * @suppress SqlInjectionChecker
362
-		 */
363
-		$propPatch->handle($supportedProperties, function($mutations) use ($addressBookId) {
364
-
365
-			$updates = [];
366
-			foreach($mutations as $property=>$newValue) {
367
-
368
-				switch($property) {
369
-					case '{DAV:}displayname' :
370
-						$updates['displayname'] = $newValue;
371
-						break;
372
-					case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
373
-						$updates['description'] = $newValue;
374
-						break;
375
-				}
376
-			}
377
-			$query = $this->db->getQueryBuilder();
378
-			$query->update('addressbooks');
379
-
380
-			foreach($updates as $key=>$value) {
381
-				$query->set($key, $query->createNamedParameter($value));
382
-			}
383
-			$query->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
384
-			->execute();
385
-
386
-			$this->addChange($addressBookId, "", 2);
387
-
388
-			return true;
389
-
390
-		});
391
-	}
392
-
393
-	/**
394
-	 * Creates a new address book
395
-	 *
396
-	 * @param string $principalUri
397
-	 * @param string $url Just the 'basename' of the url.
398
-	 * @param array $properties
399
-	 * @return int
400
-	 * @throws BadRequest
401
-	 */
402
-	function createAddressBook($principalUri, $url, array $properties) {
403
-		$values = [
404
-			'displayname' => null,
405
-			'description' => null,
406
-			'principaluri' => $principalUri,
407
-			'uri' => $url,
408
-			'synctoken' => 1
409
-		];
410
-
411
-		foreach($properties as $property=>$newValue) {
412
-
413
-			switch($property) {
414
-				case '{DAV:}displayname' :
415
-					$values['displayname'] = $newValue;
416
-					break;
417
-				case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
418
-					$values['description'] = $newValue;
419
-					break;
420
-				default :
421
-					throw new BadRequest('Unknown property: ' . $property);
422
-			}
423
-
424
-		}
425
-
426
-		// Fallback to make sure the displayname is set. Some clients may refuse
427
-		// to work with addressbooks not having a displayname.
428
-		if(is_null($values['displayname'])) {
429
-			$values['displayname'] = $url;
430
-		}
431
-
432
-		$query = $this->db->getQueryBuilder();
433
-		$query->insert('addressbooks')
434
-			->values([
435
-				'uri' => $query->createParameter('uri'),
436
-				'displayname' => $query->createParameter('displayname'),
437
-				'description' => $query->createParameter('description'),
438
-				'principaluri' => $query->createParameter('principaluri'),
439
-				'synctoken' => $query->createParameter('synctoken'),
440
-			])
441
-			->setParameters($values)
442
-			->execute();
443
-
444
-		return $query->getLastInsertId();
445
-	}
446
-
447
-	/**
448
-	 * Deletes an entire addressbook and all its contents
449
-	 *
450
-	 * @param mixed $addressBookId
451
-	 * @return void
452
-	 */
453
-	function deleteAddressBook($addressBookId) {
454
-		$query = $this->db->getQueryBuilder();
455
-		$query->delete('cards')
456
-			->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
457
-			->setParameter('addressbookid', $addressBookId)
458
-			->execute();
459
-
460
-		$query->delete('addressbookchanges')
461
-			->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
462
-			->setParameter('addressbookid', $addressBookId)
463
-			->execute();
464
-
465
-		$query->delete('addressbooks')
466
-			->where($query->expr()->eq('id', $query->createParameter('id')))
467
-			->setParameter('id', $addressBookId)
468
-			->execute();
469
-
470
-		$this->sharingBackend->deleteAllShares($addressBookId);
471
-
472
-		$query->delete($this->dbCardsPropertiesTable)
473
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
474
-			->execute();
475
-
476
-	}
477
-
478
-	/**
479
-	 * Returns all cards for a specific addressbook id.
480
-	 *
481
-	 * This method should return the following properties for each card:
482
-	 *   * carddata - raw vcard data
483
-	 *   * uri - Some unique url
484
-	 *   * lastmodified - A unix timestamp
485
-	 *
486
-	 * It's recommended to also return the following properties:
487
-	 *   * etag - A unique etag. This must change every time the card changes.
488
-	 *   * size - The size of the card in bytes.
489
-	 *
490
-	 * If these last two properties are provided, less time will be spent
491
-	 * calculating them. If they are specified, you can also ommit carddata.
492
-	 * This may speed up certain requests, especially with large cards.
493
-	 *
494
-	 * @param mixed $addressBookId
495
-	 * @return array
496
-	 */
497
-	function getCards($addressBookId) {
498
-		$query = $this->db->getQueryBuilder();
499
-		$query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
500
-			->from('cards')
501
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
502
-
503
-		$cards = [];
504
-
505
-		$result = $query->execute();
506
-		while($row = $result->fetch()) {
507
-			$row['etag'] = '"' . $row['etag'] . '"';
508
-			$row['carddata'] = $this->readBlob($row['carddata']);
509
-			$cards[] = $row;
510
-		}
511
-		$result->closeCursor();
512
-
513
-		return $cards;
514
-	}
515
-
516
-	/**
517
-	 * Returns a specific card.
518
-	 *
519
-	 * The same set of properties must be returned as with getCards. The only
520
-	 * exception is that 'carddata' is absolutely required.
521
-	 *
522
-	 * If the card does not exist, you must return false.
523
-	 *
524
-	 * @param mixed $addressBookId
525
-	 * @param string $cardUri
526
-	 * @return array
527
-	 */
528
-	function getCard($addressBookId, $cardUri) {
529
-		$query = $this->db->getQueryBuilder();
530
-		$query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
531
-			->from('cards')
532
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
533
-			->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
534
-			->setMaxResults(1);
535
-
536
-		$result = $query->execute();
537
-		$row = $result->fetch();
538
-		if (!$row) {
539
-			return false;
540
-		}
541
-		$row['etag'] = '"' . $row['etag'] . '"';
542
-		$row['carddata'] = $this->readBlob($row['carddata']);
543
-
544
-		return $row;
545
-	}
546
-
547
-	/**
548
-	 * Returns a list of cards.
549
-	 *
550
-	 * This method should work identical to getCard, but instead return all the
551
-	 * cards in the list as an array.
552
-	 *
553
-	 * If the backend supports this, it may allow for some speed-ups.
554
-	 *
555
-	 * @param mixed $addressBookId
556
-	 * @param string[] $uris
557
-	 * @return array
558
-	 */
559
-	function getMultipleCards($addressBookId, array $uris) {
560
-		if (empty($uris)) {
561
-			return [];
562
-		}
563
-
564
-		$chunks = array_chunk($uris, 100);
565
-		$cards = [];
566
-
567
-		$query = $this->db->getQueryBuilder();
568
-		$query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
569
-			->from('cards')
570
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
571
-			->andWhere($query->expr()->in('uri', $query->createParameter('uri')));
572
-
573
-		foreach ($chunks as $uris) {
574
-			$query->setParameter('uri', $uris, IQueryBuilder::PARAM_STR_ARRAY);
575
-			$result = $query->execute();
576
-
577
-			while ($row = $result->fetch()) {
578
-				$row['etag'] = '"' . $row['etag'] . '"';
579
-				$row['carddata'] = $this->readBlob($row['carddata']);
580
-				$cards[] = $row;
581
-			}
582
-			$result->closeCursor();
583
-		}
584
-		return $cards;
585
-	}
586
-
587
-	/**
588
-	 * Creates a new card.
589
-	 *
590
-	 * The addressbook id will be passed as the first argument. This is the
591
-	 * same id as it is returned from the getAddressBooksForUser method.
592
-	 *
593
-	 * The cardUri is a base uri, and doesn't include the full path. The
594
-	 * cardData argument is the vcard body, and is passed as a string.
595
-	 *
596
-	 * It is possible to return an ETag from this method. This ETag is for the
597
-	 * newly created resource, and must be enclosed with double quotes (that
598
-	 * is, the string itself must contain the double quotes).
599
-	 *
600
-	 * You should only return the ETag if you store the carddata as-is. If a
601
-	 * subsequent GET request on the same card does not have the same body,
602
-	 * byte-by-byte and you did return an ETag here, clients tend to get
603
-	 * confused.
604
-	 *
605
-	 * If you don't return an ETag, you can just return null.
606
-	 *
607
-	 * @param mixed $addressBookId
608
-	 * @param string $cardUri
609
-	 * @param string $cardData
610
-	 * @return string
611
-	 */
612
-	function createCard($addressBookId, $cardUri, $cardData) {
613
-		$etag = md5($cardData);
614
-		$uid = $this->getUID($cardData);
615
-
616
-		$q = $this->db->getQueryBuilder();
617
-		$q->select('uid')
618
-			->from('cards')
619
-			->where($q->expr()->eq('addressbookid', $q->createNamedParameter($addressBookId)))
620
-			->andWhere($q->expr()->eq('uid', $q->createNamedParameter($uid)))
621
-			->setMaxResults(1);
622
-		$result = $q->execute();
623
-		$count = (bool) $result->fetchColumn();
624
-		$result->closeCursor();
625
-		if ($count) {
626
-			throw new \Sabre\DAV\Exception\BadRequest('VCard object with uid already exists in this addressbook collection.');
627
-		}
628
-
629
-		$query = $this->db->getQueryBuilder();
630
-		$query->insert('cards')
631
-			->values([
632
-				'carddata' => $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB),
633
-				'uri' => $query->createNamedParameter($cardUri),
634
-				'lastmodified' => $query->createNamedParameter(time()),
635
-				'addressbookid' => $query->createNamedParameter($addressBookId),
636
-				'size' => $query->createNamedParameter(strlen($cardData)),
637
-				'etag' => $query->createNamedParameter($etag),
638
-				'uid' => $query->createNamedParameter($uid),
639
-			])
640
-			->execute();
641
-
642
-		$this->addChange($addressBookId, $cardUri, 1);
643
-		$this->updateProperties($addressBookId, $cardUri, $cardData);
644
-
645
-		$this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::createCard',
646
-			new GenericEvent(null, [
647
-				'addressBookId' => $addressBookId,
648
-				'cardUri' => $cardUri,
649
-				'cardData' => $cardData]));
650
-
651
-		return '"' . $etag . '"';
652
-	}
653
-
654
-	/**
655
-	 * Updates a card.
656
-	 *
657
-	 * The addressbook id will be passed as the first argument. This is the
658
-	 * same id as it is returned from the getAddressBooksForUser method.
659
-	 *
660
-	 * The cardUri is a base uri, and doesn't include the full path. The
661
-	 * cardData argument is the vcard body, and is passed as a string.
662
-	 *
663
-	 * It is possible to return an ETag from this method. This ETag should
664
-	 * match that of the updated resource, and must be enclosed with double
665
-	 * quotes (that is: the string itself must contain the actual quotes).
666
-	 *
667
-	 * You should only return the ETag if you store the carddata as-is. If a
668
-	 * subsequent GET request on the same card does not have the same body,
669
-	 * byte-by-byte and you did return an ETag here, clients tend to get
670
-	 * confused.
671
-	 *
672
-	 * If you don't return an ETag, you can just return null.
673
-	 *
674
-	 * @param mixed $addressBookId
675
-	 * @param string $cardUri
676
-	 * @param string $cardData
677
-	 * @return string
678
-	 */
679
-	function updateCard($addressBookId, $cardUri, $cardData) {
680
-
681
-		$uid = $this->getUID($cardData);
682
-		$etag = md5($cardData);
683
-		$query = $this->db->getQueryBuilder();
684
-		$query->update('cards')
685
-			->set('carddata', $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB))
686
-			->set('lastmodified', $query->createNamedParameter(time()))
687
-			->set('size', $query->createNamedParameter(strlen($cardData)))
688
-			->set('etag', $query->createNamedParameter($etag))
689
-			->set('uid', $query->createNamedParameter($uid))
690
-			->where($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
691
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
692
-			->execute();
693
-
694
-		$this->addChange($addressBookId, $cardUri, 2);
695
-		$this->updateProperties($addressBookId, $cardUri, $cardData);
696
-
697
-		$this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::updateCard',
698
-			new GenericEvent(null, [
699
-				'addressBookId' => $addressBookId,
700
-				'cardUri' => $cardUri,
701
-				'cardData' => $cardData]));
702
-
703
-		return '"' . $etag . '"';
704
-	}
705
-
706
-	/**
707
-	 * Deletes a card
708
-	 *
709
-	 * @param mixed $addressBookId
710
-	 * @param string $cardUri
711
-	 * @return bool
712
-	 */
713
-	function deleteCard($addressBookId, $cardUri) {
714
-		try {
715
-			$cardId = $this->getCardId($addressBookId, $cardUri);
716
-		} catch (\InvalidArgumentException $e) {
717
-			$cardId = null;
718
-		}
719
-		$query = $this->db->getQueryBuilder();
720
-		$ret = $query->delete('cards')
721
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
722
-			->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
723
-			->execute();
724
-
725
-		$this->addChange($addressBookId, $cardUri, 3);
726
-
727
-		$this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::deleteCard',
728
-			new GenericEvent(null, [
729
-				'addressBookId' => $addressBookId,
730
-				'cardUri' => $cardUri]));
731
-
732
-		if ($ret === 1) {
733
-			if ($cardId !== null) {
734
-				$this->purgeProperties($addressBookId, $cardId);
735
-			}
736
-			return true;
737
-		}
738
-
739
-		return false;
740
-	}
741
-
742
-	/**
743
-	 * The getChanges method returns all the changes that have happened, since
744
-	 * the specified syncToken in the specified address book.
745
-	 *
746
-	 * This function should return an array, such as the following:
747
-	 *
748
-	 * [
749
-	 *   'syncToken' => 'The current synctoken',
750
-	 *   'added'   => [
751
-	 *      'new.txt',
752
-	 *   ],
753
-	 *   'modified'   => [
754
-	 *      'modified.txt',
755
-	 *   ],
756
-	 *   'deleted' => [
757
-	 *      'foo.php.bak',
758
-	 *      'old.txt'
759
-	 *   ]
760
-	 * ];
761
-	 *
762
-	 * The returned syncToken property should reflect the *current* syncToken
763
-	 * of the calendar, as reported in the {http://sabredav.org/ns}sync-token
764
-	 * property. This is needed here too, to ensure the operation is atomic.
765
-	 *
766
-	 * If the $syncToken argument is specified as null, this is an initial
767
-	 * sync, and all members should be reported.
768
-	 *
769
-	 * The modified property is an array of nodenames that have changed since
770
-	 * the last token.
771
-	 *
772
-	 * The deleted property is an array with nodenames, that have been deleted
773
-	 * from collection.
774
-	 *
775
-	 * The $syncLevel argument is basically the 'depth' of the report. If it's
776
-	 * 1, you only have to report changes that happened only directly in
777
-	 * immediate descendants. If it's 2, it should also include changes from
778
-	 * the nodes below the child collections. (grandchildren)
779
-	 *
780
-	 * The $limit argument allows a client to specify how many results should
781
-	 * be returned at most. If the limit is not specified, it should be treated
782
-	 * as infinite.
783
-	 *
784
-	 * If the limit (infinite or not) is higher than you're willing to return,
785
-	 * you should throw a Sabre\DAV\Exception\TooMuchMatches() exception.
786
-	 *
787
-	 * If the syncToken is expired (due to data cleanup) or unknown, you must
788
-	 * return null.
789
-	 *
790
-	 * The limit is 'suggestive'. You are free to ignore it.
791
-	 *
792
-	 * @param string $addressBookId
793
-	 * @param string $syncToken
794
-	 * @param int $syncLevel
795
-	 * @param int $limit
796
-	 * @return array
797
-	 */
798
-	function getChangesForAddressBook($addressBookId, $syncToken, $syncLevel, $limit = null) {
799
-		// Current synctoken
800
-		$stmt = $this->db->prepare('SELECT `synctoken` FROM `*PREFIX*addressbooks` WHERE `id` = ?');
801
-		$stmt->execute([ $addressBookId ]);
802
-		$currentToken = $stmt->fetchColumn(0);
803
-
804
-		if (is_null($currentToken)) return null;
805
-
806
-		$result = [
807
-			'syncToken' => $currentToken,
808
-			'added'     => [],
809
-			'modified'  => [],
810
-			'deleted'   => [],
811
-		];
812
-
813
-		if ($syncToken) {
814
-
815
-			$query = "SELECT `uri`, `operation` FROM `*PREFIX*addressbookchanges` WHERE `synctoken` >= ? AND `synctoken` < ? AND `addressbookid` = ? ORDER BY `synctoken`";
816
-			if ($limit>0) {
817
-				$query .= " LIMIT " . (int)$limit;
818
-			}
819
-
820
-			// Fetching all changes
821
-			$stmt = $this->db->prepare($query);
822
-			$stmt->execute([$syncToken, $currentToken, $addressBookId]);
823
-
824
-			$changes = [];
825
-
826
-			// This loop ensures that any duplicates are overwritten, only the
827
-			// last change on a node is relevant.
828
-			while($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
829
-
830
-				$changes[$row['uri']] = $row['operation'];
831
-
832
-			}
833
-
834
-			foreach($changes as $uri => $operation) {
835
-
836
-				switch($operation) {
837
-					case 1:
838
-						$result['added'][] = $uri;
839
-						break;
840
-					case 2:
841
-						$result['modified'][] = $uri;
842
-						break;
843
-					case 3:
844
-						$result['deleted'][] = $uri;
845
-						break;
846
-				}
847
-
848
-			}
849
-		} else {
850
-			// No synctoken supplied, this is the initial sync.
851
-			$query = "SELECT `uri` FROM `*PREFIX*cards` WHERE `addressbookid` = ?";
852
-			$stmt = $this->db->prepare($query);
853
-			$stmt->execute([$addressBookId]);
854
-
855
-			$result['added'] = $stmt->fetchAll(\PDO::FETCH_COLUMN);
856
-		}
857
-		return $result;
858
-	}
859
-
860
-	/**
861
-	 * Adds a change record to the addressbookchanges table.
862
-	 *
863
-	 * @param mixed $addressBookId
864
-	 * @param string $objectUri
865
-	 * @param int $operation 1 = add, 2 = modify, 3 = delete
866
-	 * @return void
867
-	 */
868
-	protected function addChange($addressBookId, $objectUri, $operation) {
869
-		$sql = 'INSERT INTO `*PREFIX*addressbookchanges`(`uri`, `synctoken`, `addressbookid`, `operation`) SELECT ?, `synctoken`, ?, ? FROM `*PREFIX*addressbooks` WHERE `id` = ?';
870
-		$stmt = $this->db->prepare($sql);
871
-		$stmt->execute([
872
-			$objectUri,
873
-			$addressBookId,
874
-			$operation,
875
-			$addressBookId
876
-		]);
877
-		$stmt = $this->db->prepare('UPDATE `*PREFIX*addressbooks` SET `synctoken` = `synctoken` + 1 WHERE `id` = ?');
878
-		$stmt->execute([
879
-			$addressBookId
880
-		]);
881
-	}
882
-
883
-	private function readBlob($cardData) {
884
-		if (is_resource($cardData)) {
885
-			return stream_get_contents($cardData);
886
-		}
887
-
888
-		return $cardData;
889
-	}
890
-
891
-	/**
892
-	 * @param IShareable $shareable
893
-	 * @param string[] $add
894
-	 * @param string[] $remove
895
-	 */
896
-	public function updateShares(IShareable $shareable, $add, $remove) {
897
-		$this->sharingBackend->updateShares($shareable, $add, $remove);
898
-	}
899
-
900
-	/**
901
-	 * search contact
902
-	 *
903
-	 * @param int $addressBookId
904
-	 * @param string $pattern which should match within the $searchProperties
905
-	 * @param array $searchProperties defines the properties within the query pattern should match
906
-	 * @param array $options = array() to define the search behavior
907
-	 * 	- 'escape_like_param' - If set to false wildcards _ and % are not escaped, otherwise they are
908
-	 * @return array an array of contacts which are arrays of key-value-pairs
909
-	 */
910
-	public function search($addressBookId, $pattern, $searchProperties, $options = array()) {
911
-		$query = $this->db->getQueryBuilder();
912
-		$query2 = $this->db->getQueryBuilder();
913
-
914
-		$query2->selectDistinct('cp.cardid')->from($this->dbCardsPropertiesTable, 'cp');
915
-		$query2->andWhere($query2->expr()->eq('cp.addressbookid', $query->createNamedParameter($addressBookId)));
916
-		$or = $query2->expr()->orX();
917
-		foreach ($searchProperties as $property) {
918
-			$or->add($query2->expr()->eq('cp.name', $query->createNamedParameter($property)));
919
-		}
920
-		$query2->andWhere($or);
921
-
922
-		// No need for like when the pattern is empty
923
-		if ('' !== $pattern) {
924
-			if(\array_key_exists('escape_like_param', $options) && $options['escape_like_param'] === false) {
925
-				$query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter($pattern)));
926
-			} else {
927
-				$query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter('%' . $this->db->escapeLikeParameter($pattern) . '%')));
928
-			}
929
-		}
930
-
931
-		$query->select('c.carddata', 'c.uri')->from($this->dbCardsTable, 'c')
932
-			->where($query->expr()->in('c.id', $query->createFunction($query2->getSQL())));
933
-
934
-		$result = $query->execute();
935
-		$cards = $result->fetchAll();
936
-
937
-		$result->closeCursor();
938
-
939
-		return array_map(function($array) {
940
-			$array['carddata'] = $this->readBlob($array['carddata']);
941
-			return $array;
942
-		}, $cards);
943
-	}
944
-
945
-	/**
946
-	 * @param int $bookId
947
-	 * @param string $name
948
-	 * @return array
949
-	 */
950
-	public function collectCardProperties($bookId, $name) {
951
-		$query = $this->db->getQueryBuilder();
952
-		$result = $query->selectDistinct('value')
953
-			->from($this->dbCardsPropertiesTable)
954
-			->where($query->expr()->eq('name', $query->createNamedParameter($name)))
955
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($bookId)))
956
-			->execute();
957
-
958
-		$all = $result->fetchAll(PDO::FETCH_COLUMN);
959
-		$result->closeCursor();
960
-
961
-		return $all;
962
-	}
963
-
964
-	/**
965
-	 * get URI from a given contact
966
-	 *
967
-	 * @param int $id
968
-	 * @return string
969
-	 */
970
-	public function getCardUri($id) {
971
-		$query = $this->db->getQueryBuilder();
972
-		$query->select('uri')->from($this->dbCardsTable)
973
-				->where($query->expr()->eq('id', $query->createParameter('id')))
974
-				->setParameter('id', $id);
975
-
976
-		$result = $query->execute();
977
-		$uri = $result->fetch();
978
-		$result->closeCursor();
979
-
980
-		if (!isset($uri['uri'])) {
981
-			throw new \InvalidArgumentException('Card does not exists: ' . $id);
982
-		}
983
-
984
-		return $uri['uri'];
985
-	}
986
-
987
-	/**
988
-	 * return contact with the given URI
989
-	 *
990
-	 * @param int $addressBookId
991
-	 * @param string $uri
992
-	 * @returns array
993
-	 */
994
-	public function getContact($addressBookId, $uri) {
995
-		$result = [];
996
-		$query = $this->db->getQueryBuilder();
997
-		$query->select('*')->from($this->dbCardsTable)
998
-				->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
999
-				->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1000
-		$queryResult = $query->execute();
1001
-		$contact = $queryResult->fetch();
1002
-		$queryResult->closeCursor();
1003
-
1004
-		if (is_array($contact)) {
1005
-			$result = $contact;
1006
-		}
1007
-
1008
-		return $result;
1009
-	}
1010
-
1011
-	/**
1012
-	 * Returns the list of people whom this address book is shared with.
1013
-	 *
1014
-	 * Every element in this array should have the following properties:
1015
-	 *   * href - Often a mailto: address
1016
-	 *   * commonName - Optional, for example a first + last name
1017
-	 *   * status - See the Sabre\CalDAV\SharingPlugin::STATUS_ constants.
1018
-	 *   * readOnly - boolean
1019
-	 *   * summary - Optional, a description for the share
1020
-	 *
1021
-	 * @return array
1022
-	 */
1023
-	public function getShares($addressBookId) {
1024
-		return $this->sharingBackend->getShares($addressBookId);
1025
-	}
1026
-
1027
-	/**
1028
-	 * update properties table
1029
-	 *
1030
-	 * @param int $addressBookId
1031
-	 * @param string $cardUri
1032
-	 * @param string $vCardSerialized
1033
-	 */
1034
-	protected function updateProperties($addressBookId, $cardUri, $vCardSerialized) {
1035
-		$cardId = $this->getCardId($addressBookId, $cardUri);
1036
-		$vCard = $this->readCard($vCardSerialized);
1037
-
1038
-		$this->purgeProperties($addressBookId, $cardId);
1039
-
1040
-		$query = $this->db->getQueryBuilder();
1041
-		$query->insert($this->dbCardsPropertiesTable)
1042
-			->values(
1043
-				[
1044
-					'addressbookid' => $query->createNamedParameter($addressBookId),
1045
-					'cardid' => $query->createNamedParameter($cardId),
1046
-					'name' => $query->createParameter('name'),
1047
-					'value' => $query->createParameter('value'),
1048
-					'preferred' => $query->createParameter('preferred')
1049
-				]
1050
-			);
1051
-
1052
-		foreach ($vCard->children() as $property) {
1053
-			if(!in_array($property->name, self::$indexProperties)) {
1054
-				continue;
1055
-			}
1056
-			$preferred = 0;
1057
-			foreach($property->parameters as $parameter) {
1058
-				if ($parameter->name === 'TYPE' && strtoupper($parameter->getValue()) === 'PREF') {
1059
-					$preferred = 1;
1060
-					break;
1061
-				}
1062
-			}
1063
-			$query->setParameter('name', $property->name);
1064
-			$query->setParameter('value', substr($property->getValue(), 0, 254));
1065
-			$query->setParameter('preferred', $preferred);
1066
-			$query->execute();
1067
-		}
1068
-	}
1069
-
1070
-	/**
1071
-	 * read vCard data into a vCard object
1072
-	 *
1073
-	 * @param string $cardData
1074
-	 * @return VCard
1075
-	 */
1076
-	protected function readCard($cardData) {
1077
-		return  Reader::read($cardData);
1078
-	}
1079
-
1080
-	/**
1081
-	 * delete all properties from a given card
1082
-	 *
1083
-	 * @param int $addressBookId
1084
-	 * @param int $cardId
1085
-	 */
1086
-	protected function purgeProperties($addressBookId, $cardId) {
1087
-		$query = $this->db->getQueryBuilder();
1088
-		$query->delete($this->dbCardsPropertiesTable)
1089
-			->where($query->expr()->eq('cardid', $query->createNamedParameter($cardId)))
1090
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1091
-		$query->execute();
1092
-	}
1093
-
1094
-	/**
1095
-	 * get ID from a given contact
1096
-	 *
1097
-	 * @param int $addressBookId
1098
-	 * @param string $uri
1099
-	 * @return int
1100
-	 */
1101
-	protected function getCardId($addressBookId, $uri) {
1102
-		$query = $this->db->getQueryBuilder();
1103
-		$query->select('id')->from($this->dbCardsTable)
1104
-			->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
1105
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1106
-
1107
-		$result = $query->execute();
1108
-		$cardIds = $result->fetch();
1109
-		$result->closeCursor();
1110
-
1111
-		if (!isset($cardIds['id'])) {
1112
-			throw new \InvalidArgumentException('Card does not exists: ' . $uri);
1113
-		}
1114
-
1115
-		return (int)$cardIds['id'];
1116
-	}
1117
-
1118
-	/**
1119
-	 * For shared address books the sharee is set in the ACL of the address book
1120
-	 * @param $addressBookId
1121
-	 * @param $acl
1122
-	 * @return array
1123
-	 */
1124
-	public function applyShareAcl($addressBookId, $acl) {
1125
-		return $this->sharingBackend->applyShareAcl($addressBookId, $acl);
1126
-	}
1127
-
1128
-	private function convertPrincipal($principalUri, $toV2) {
1129
-		if ($this->principalBackend->getPrincipalPrefix() === 'principals') {
1130
-			list(, $name) = \Sabre\Uri\split($principalUri);
1131
-			if ($toV2 === true) {
1132
-				return "principals/users/$name";
1133
-			}
1134
-			return "principals/$name";
1135
-		}
1136
-		return $principalUri;
1137
-	}
1138
-
1139
-	private function addOwnerPrincipal(&$addressbookInfo) {
1140
-		$ownerPrincipalKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal';
1141
-		$displaynameKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_NEXTCLOUD . '}owner-displayname';
1142
-		if (isset($addressbookInfo[$ownerPrincipalKey])) {
1143
-			$uri = $addressbookInfo[$ownerPrincipalKey];
1144
-		} else {
1145
-			$uri = $addressbookInfo['principaluri'];
1146
-		}
1147
-
1148
-		$principalInformation = $this->principalBackend->getPrincipalByPath($uri);
1149
-		if (isset($principalInformation['{DAV:}displayname'])) {
1150
-			$addressbookInfo[$displaynameKey] = $principalInformation['{DAV:}displayname'];
1151
-		}
1152
-	}
1153
-
1154
-	/**
1155
-	 * Extract UID from vcard
1156
-	 *
1157
-	 * @param string $cardData the vcard raw data
1158
-	 * @return string the uid
1159
-	 * @throws BadRequest if no UID is available
1160
-	 */
1161
-	private function getUID($cardData) {
1162
-		if ($cardData != '') {
1163
-			$vCard = Reader::read($cardData);
1164
-			if ($vCard->UID) {
1165
-				$uid = $vCard->UID->getValue();
1166
-				return $uid;
1167
-			}
1168
-			// should already be handled, but just in case
1169
-			throw new BadRequest('vCards on CardDAV servers MUST have a UID property');
1170
-		}
1171
-		// should already be handled, but just in case
1172
-		throw new BadRequest('vCard can not be empty');
1173
-	}
56
+    const PERSONAL_ADDRESSBOOK_URI = 'contacts';
57
+    const PERSONAL_ADDRESSBOOK_NAME = 'Contacts';
58
+
59
+    /** @var Principal */
60
+    private $principalBackend;
61
+
62
+    /** @var string */
63
+    private $dbCardsTable = 'cards';
64
+
65
+    /** @var string */
66
+    private $dbCardsPropertiesTable = 'cards_properties';
67
+
68
+    /** @var IDBConnection */
69
+    private $db;
70
+
71
+    /** @var Backend */
72
+    private $sharingBackend;
73
+
74
+    /** @var array properties to index */
75
+    public static $indexProperties = array(
76
+            'BDAY', 'UID', 'N', 'FN', 'TITLE', 'ROLE', 'NOTE', 'NICKNAME',
77
+            'ORG', 'CATEGORIES', 'EMAIL', 'TEL', 'IMPP', 'ADR', 'URL', 'GEO', 'CLOUD');
78
+
79
+    /**
80
+     * @var string[] Map of uid => display name
81
+     */
82
+    protected $userDisplayNames;
83
+
84
+    /** @var IUserManager */
85
+    private $userManager;
86
+
87
+    /** @var EventDispatcherInterface */
88
+    private $dispatcher;
89
+
90
+    /**
91
+     * CardDavBackend constructor.
92
+     *
93
+     * @param IDBConnection $db
94
+     * @param Principal $principalBackend
95
+     * @param IUserManager $userManager
96
+     * @param IGroupManager $groupManager
97
+     * @param EventDispatcherInterface $dispatcher
98
+     */
99
+    public function __construct(IDBConnection $db,
100
+                                Principal $principalBackend,
101
+                                IUserManager $userManager,
102
+                                IGroupManager $groupManager,
103
+                                EventDispatcherInterface $dispatcher) {
104
+        $this->db = $db;
105
+        $this->principalBackend = $principalBackend;
106
+        $this->userManager = $userManager;
107
+        $this->dispatcher = $dispatcher;
108
+        $this->sharingBackend = new Backend($this->db, $this->userManager, $groupManager, $principalBackend, 'addressbook');
109
+    }
110
+
111
+    /**
112
+     * Return the number of address books for a principal
113
+     *
114
+     * @param $principalUri
115
+     * @return int
116
+     */
117
+    public function getAddressBooksForUserCount($principalUri) {
118
+        $principalUri = $this->convertPrincipal($principalUri, true);
119
+        $query = $this->db->getQueryBuilder();
120
+        $query->select($query->func()->count('*'))
121
+            ->from('addressbooks')
122
+            ->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
123
+
124
+        return (int)$query->execute()->fetchColumn();
125
+    }
126
+
127
+    /**
128
+     * Returns the list of address books for a specific user.
129
+     *
130
+     * Every addressbook should have the following properties:
131
+     *   id - an arbitrary unique id
132
+     *   uri - the 'basename' part of the url
133
+     *   principaluri - Same as the passed parameter
134
+     *
135
+     * Any additional clark-notation property may be passed besides this. Some
136
+     * common ones are :
137
+     *   {DAV:}displayname
138
+     *   {urn:ietf:params:xml:ns:carddav}addressbook-description
139
+     *   {http://calendarserver.org/ns/}getctag
140
+     *
141
+     * @param string $principalUri
142
+     * @return array
143
+     */
144
+    function getAddressBooksForUser($principalUri) {
145
+        $principalUriOriginal = $principalUri;
146
+        $principalUri = $this->convertPrincipal($principalUri, true);
147
+        $query = $this->db->getQueryBuilder();
148
+        $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
149
+            ->from('addressbooks')
150
+            ->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
151
+
152
+        $addressBooks = [];
153
+
154
+        $result = $query->execute();
155
+        while($row = $result->fetch()) {
156
+            $addressBooks[$row['id']] = [
157
+                'id'  => $row['id'],
158
+                'uri' => $row['uri'],
159
+                'principaluri' => $this->convertPrincipal($row['principaluri'], false),
160
+                '{DAV:}displayname' => $row['displayname'],
161
+                '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
162
+                '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
163
+                '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
164
+            ];
165
+
166
+            $this->addOwnerPrincipal($addressBooks[$row['id']]);
167
+        }
168
+        $result->closeCursor();
169
+
170
+        // query for shared addressbooks
171
+        $principals = $this->principalBackend->getGroupMembership($principalUriOriginal, true);
172
+        $principals = array_merge($principals, $this->principalBackend->getCircleMembership($principalUriOriginal));
173
+
174
+        $principals = array_map(function($principal) {
175
+            return urldecode($principal);
176
+        }, $principals);
177
+        $principals[]= $principalUri;
178
+
179
+        $query = $this->db->getQueryBuilder();
180
+        $result = $query->select(['a.id', 'a.uri', 'a.displayname', 'a.principaluri', 'a.description', 'a.synctoken', 's.access'])
181
+            ->from('dav_shares', 's')
182
+            ->join('s', 'addressbooks', 'a', $query->expr()->eq('s.resourceid', 'a.id'))
183
+            ->where($query->expr()->in('s.principaluri', $query->createParameter('principaluri')))
184
+            ->andWhere($query->expr()->eq('s.type', $query->createParameter('type')))
185
+            ->setParameter('type', 'addressbook')
186
+            ->setParameter('principaluri', $principals, IQueryBuilder::PARAM_STR_ARRAY)
187
+            ->execute();
188
+
189
+        $readOnlyPropertyName = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}read-only';
190
+        while($row = $result->fetch()) {
191
+            if ($row['principaluri'] === $principalUri) {
192
+                continue;
193
+            }
194
+
195
+            $readOnly = (int) $row['access'] === Backend::ACCESS_READ;
196
+            if (isset($addressBooks[$row['id']])) {
197
+                if ($readOnly) {
198
+                    // New share can not have more permissions then the old one.
199
+                    continue;
200
+                }
201
+                if (isset($addressBooks[$row['id']][$readOnlyPropertyName]) &&
202
+                    $addressBooks[$row['id']][$readOnlyPropertyName] === 0) {
203
+                    // Old share is already read-write, no more permissions can be gained
204
+                    continue;
205
+                }
206
+            }
207
+
208
+            list(, $name) = \Sabre\Uri\split($row['principaluri']);
209
+            $uri = $row['uri'] . '_shared_by_' . $name;
210
+            $displayName = $row['displayname'] . ' (' . $this->getUserDisplayName($name) . ')';
211
+
212
+            $addressBooks[$row['id']] = [
213
+                'id'  => $row['id'],
214
+                'uri' => $uri,
215
+                'principaluri' => $principalUriOriginal,
216
+                '{DAV:}displayname' => $displayName,
217
+                '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
218
+                '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
219
+                '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
220
+                '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal' => $row['principaluri'],
221
+                $readOnlyPropertyName => $readOnly,
222
+            ];
223
+
224
+            $this->addOwnerPrincipal($addressBooks[$row['id']]);
225
+        }
226
+        $result->closeCursor();
227
+
228
+        return array_values($addressBooks);
229
+    }
230
+
231
+    public function getUsersOwnAddressBooks($principalUri) {
232
+        $principalUri = $this->convertPrincipal($principalUri, true);
233
+        $query = $this->db->getQueryBuilder();
234
+        $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
235
+                ->from('addressbooks')
236
+                ->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
237
+
238
+        $addressBooks = [];
239
+
240
+        $result = $query->execute();
241
+        while($row = $result->fetch()) {
242
+            $addressBooks[$row['id']] = [
243
+                'id'  => $row['id'],
244
+                'uri' => $row['uri'],
245
+                'principaluri' => $this->convertPrincipal($row['principaluri'], false),
246
+                '{DAV:}displayname' => $row['displayname'],
247
+                '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
248
+                '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
249
+                '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
250
+            ];
251
+
252
+            $this->addOwnerPrincipal($addressBooks[$row['id']]);
253
+        }
254
+        $result->closeCursor();
255
+
256
+        return array_values($addressBooks);
257
+    }
258
+
259
+    private function getUserDisplayName($uid) {
260
+        if (!isset($this->userDisplayNames[$uid])) {
261
+            $user = $this->userManager->get($uid);
262
+
263
+            if ($user instanceof IUser) {
264
+                $this->userDisplayNames[$uid] = $user->getDisplayName();
265
+            } else {
266
+                $this->userDisplayNames[$uid] = $uid;
267
+            }
268
+        }
269
+
270
+        return $this->userDisplayNames[$uid];
271
+    }
272
+
273
+    /**
274
+     * @param int $addressBookId
275
+     */
276
+    public function getAddressBookById($addressBookId) {
277
+        $query = $this->db->getQueryBuilder();
278
+        $result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
279
+            ->from('addressbooks')
280
+            ->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
281
+            ->execute();
282
+
283
+        $row = $result->fetch();
284
+        $result->closeCursor();
285
+        if ($row === false) {
286
+            return null;
287
+        }
288
+
289
+        $addressBook = [
290
+            'id'  => $row['id'],
291
+            'uri' => $row['uri'],
292
+            'principaluri' => $row['principaluri'],
293
+            '{DAV:}displayname' => $row['displayname'],
294
+            '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
295
+            '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
296
+            '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
297
+        ];
298
+
299
+        $this->addOwnerPrincipal($addressBook);
300
+
301
+        return $addressBook;
302
+    }
303
+
304
+    /**
305
+     * @param $addressBookUri
306
+     * @return array|null
307
+     */
308
+    public function getAddressBooksByUri($principal, $addressBookUri) {
309
+        $query = $this->db->getQueryBuilder();
310
+        $result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
311
+            ->from('addressbooks')
312
+            ->where($query->expr()->eq('uri', $query->createNamedParameter($addressBookUri)))
313
+            ->andWhere($query->expr()->eq('principaluri', $query->createNamedParameter($principal)))
314
+            ->setMaxResults(1)
315
+            ->execute();
316
+
317
+        $row = $result->fetch();
318
+        $result->closeCursor();
319
+        if ($row === false) {
320
+            return null;
321
+        }
322
+
323
+        $addressBook = [
324
+            'id'  => $row['id'],
325
+            'uri' => $row['uri'],
326
+            'principaluri' => $row['principaluri'],
327
+            '{DAV:}displayname' => $row['displayname'],
328
+            '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
329
+            '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
330
+            '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
331
+        ];
332
+
333
+        $this->addOwnerPrincipal($addressBook);
334
+
335
+        return $addressBook;
336
+    }
337
+
338
+    /**
339
+     * Updates properties for an address book.
340
+     *
341
+     * The list of mutations is stored in a Sabre\DAV\PropPatch object.
342
+     * To do the actual updates, you must tell this object which properties
343
+     * you're going to process with the handle() method.
344
+     *
345
+     * Calling the handle method is like telling the PropPatch object "I
346
+     * promise I can handle updating this property".
347
+     *
348
+     * Read the PropPatch documentation for more info and examples.
349
+     *
350
+     * @param string $addressBookId
351
+     * @param \Sabre\DAV\PropPatch $propPatch
352
+     * @return void
353
+     */
354
+    function updateAddressBook($addressBookId, \Sabre\DAV\PropPatch $propPatch) {
355
+        $supportedProperties = [
356
+            '{DAV:}displayname',
357
+            '{' . Plugin::NS_CARDDAV . '}addressbook-description',
358
+        ];
359
+
360
+        /**
361
+         * @suppress SqlInjectionChecker
362
+         */
363
+        $propPatch->handle($supportedProperties, function($mutations) use ($addressBookId) {
364
+
365
+            $updates = [];
366
+            foreach($mutations as $property=>$newValue) {
367
+
368
+                switch($property) {
369
+                    case '{DAV:}displayname' :
370
+                        $updates['displayname'] = $newValue;
371
+                        break;
372
+                    case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
373
+                        $updates['description'] = $newValue;
374
+                        break;
375
+                }
376
+            }
377
+            $query = $this->db->getQueryBuilder();
378
+            $query->update('addressbooks');
379
+
380
+            foreach($updates as $key=>$value) {
381
+                $query->set($key, $query->createNamedParameter($value));
382
+            }
383
+            $query->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
384
+            ->execute();
385
+
386
+            $this->addChange($addressBookId, "", 2);
387
+
388
+            return true;
389
+
390
+        });
391
+    }
392
+
393
+    /**
394
+     * Creates a new address book
395
+     *
396
+     * @param string $principalUri
397
+     * @param string $url Just the 'basename' of the url.
398
+     * @param array $properties
399
+     * @return int
400
+     * @throws BadRequest
401
+     */
402
+    function createAddressBook($principalUri, $url, array $properties) {
403
+        $values = [
404
+            'displayname' => null,
405
+            'description' => null,
406
+            'principaluri' => $principalUri,
407
+            'uri' => $url,
408
+            'synctoken' => 1
409
+        ];
410
+
411
+        foreach($properties as $property=>$newValue) {
412
+
413
+            switch($property) {
414
+                case '{DAV:}displayname' :
415
+                    $values['displayname'] = $newValue;
416
+                    break;
417
+                case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
418
+                    $values['description'] = $newValue;
419
+                    break;
420
+                default :
421
+                    throw new BadRequest('Unknown property: ' . $property);
422
+            }
423
+
424
+        }
425
+
426
+        // Fallback to make sure the displayname is set. Some clients may refuse
427
+        // to work with addressbooks not having a displayname.
428
+        if(is_null($values['displayname'])) {
429
+            $values['displayname'] = $url;
430
+        }
431
+
432
+        $query = $this->db->getQueryBuilder();
433
+        $query->insert('addressbooks')
434
+            ->values([
435
+                'uri' => $query->createParameter('uri'),
436
+                'displayname' => $query->createParameter('displayname'),
437
+                'description' => $query->createParameter('description'),
438
+                'principaluri' => $query->createParameter('principaluri'),
439
+                'synctoken' => $query->createParameter('synctoken'),
440
+            ])
441
+            ->setParameters($values)
442
+            ->execute();
443
+
444
+        return $query->getLastInsertId();
445
+    }
446
+
447
+    /**
448
+     * Deletes an entire addressbook and all its contents
449
+     *
450
+     * @param mixed $addressBookId
451
+     * @return void
452
+     */
453
+    function deleteAddressBook($addressBookId) {
454
+        $query = $this->db->getQueryBuilder();
455
+        $query->delete('cards')
456
+            ->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
457
+            ->setParameter('addressbookid', $addressBookId)
458
+            ->execute();
459
+
460
+        $query->delete('addressbookchanges')
461
+            ->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
462
+            ->setParameter('addressbookid', $addressBookId)
463
+            ->execute();
464
+
465
+        $query->delete('addressbooks')
466
+            ->where($query->expr()->eq('id', $query->createParameter('id')))
467
+            ->setParameter('id', $addressBookId)
468
+            ->execute();
469
+
470
+        $this->sharingBackend->deleteAllShares($addressBookId);
471
+
472
+        $query->delete($this->dbCardsPropertiesTable)
473
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
474
+            ->execute();
475
+
476
+    }
477
+
478
+    /**
479
+     * Returns all cards for a specific addressbook id.
480
+     *
481
+     * This method should return the following properties for each card:
482
+     *   * carddata - raw vcard data
483
+     *   * uri - Some unique url
484
+     *   * lastmodified - A unix timestamp
485
+     *
486
+     * It's recommended to also return the following properties:
487
+     *   * etag - A unique etag. This must change every time the card changes.
488
+     *   * size - The size of the card in bytes.
489
+     *
490
+     * If these last two properties are provided, less time will be spent
491
+     * calculating them. If they are specified, you can also ommit carddata.
492
+     * This may speed up certain requests, especially with large cards.
493
+     *
494
+     * @param mixed $addressBookId
495
+     * @return array
496
+     */
497
+    function getCards($addressBookId) {
498
+        $query = $this->db->getQueryBuilder();
499
+        $query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
500
+            ->from('cards')
501
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
502
+
503
+        $cards = [];
504
+
505
+        $result = $query->execute();
506
+        while($row = $result->fetch()) {
507
+            $row['etag'] = '"' . $row['etag'] . '"';
508
+            $row['carddata'] = $this->readBlob($row['carddata']);
509
+            $cards[] = $row;
510
+        }
511
+        $result->closeCursor();
512
+
513
+        return $cards;
514
+    }
515
+
516
+    /**
517
+     * Returns a specific card.
518
+     *
519
+     * The same set of properties must be returned as with getCards. The only
520
+     * exception is that 'carddata' is absolutely required.
521
+     *
522
+     * If the card does not exist, you must return false.
523
+     *
524
+     * @param mixed $addressBookId
525
+     * @param string $cardUri
526
+     * @return array
527
+     */
528
+    function getCard($addressBookId, $cardUri) {
529
+        $query = $this->db->getQueryBuilder();
530
+        $query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
531
+            ->from('cards')
532
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
533
+            ->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
534
+            ->setMaxResults(1);
535
+
536
+        $result = $query->execute();
537
+        $row = $result->fetch();
538
+        if (!$row) {
539
+            return false;
540
+        }
541
+        $row['etag'] = '"' . $row['etag'] . '"';
542
+        $row['carddata'] = $this->readBlob($row['carddata']);
543
+
544
+        return $row;
545
+    }
546
+
547
+    /**
548
+     * Returns a list of cards.
549
+     *
550
+     * This method should work identical to getCard, but instead return all the
551
+     * cards in the list as an array.
552
+     *
553
+     * If the backend supports this, it may allow for some speed-ups.
554
+     *
555
+     * @param mixed $addressBookId
556
+     * @param string[] $uris
557
+     * @return array
558
+     */
559
+    function getMultipleCards($addressBookId, array $uris) {
560
+        if (empty($uris)) {
561
+            return [];
562
+        }
563
+
564
+        $chunks = array_chunk($uris, 100);
565
+        $cards = [];
566
+
567
+        $query = $this->db->getQueryBuilder();
568
+        $query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
569
+            ->from('cards')
570
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
571
+            ->andWhere($query->expr()->in('uri', $query->createParameter('uri')));
572
+
573
+        foreach ($chunks as $uris) {
574
+            $query->setParameter('uri', $uris, IQueryBuilder::PARAM_STR_ARRAY);
575
+            $result = $query->execute();
576
+
577
+            while ($row = $result->fetch()) {
578
+                $row['etag'] = '"' . $row['etag'] . '"';
579
+                $row['carddata'] = $this->readBlob($row['carddata']);
580
+                $cards[] = $row;
581
+            }
582
+            $result->closeCursor();
583
+        }
584
+        return $cards;
585
+    }
586
+
587
+    /**
588
+     * Creates a new card.
589
+     *
590
+     * The addressbook id will be passed as the first argument. This is the
591
+     * same id as it is returned from the getAddressBooksForUser method.
592
+     *
593
+     * The cardUri is a base uri, and doesn't include the full path. The
594
+     * cardData argument is the vcard body, and is passed as a string.
595
+     *
596
+     * It is possible to return an ETag from this method. This ETag is for the
597
+     * newly created resource, and must be enclosed with double quotes (that
598
+     * is, the string itself must contain the double quotes).
599
+     *
600
+     * You should only return the ETag if you store the carddata as-is. If a
601
+     * subsequent GET request on the same card does not have the same body,
602
+     * byte-by-byte and you did return an ETag here, clients tend to get
603
+     * confused.
604
+     *
605
+     * If you don't return an ETag, you can just return null.
606
+     *
607
+     * @param mixed $addressBookId
608
+     * @param string $cardUri
609
+     * @param string $cardData
610
+     * @return string
611
+     */
612
+    function createCard($addressBookId, $cardUri, $cardData) {
613
+        $etag = md5($cardData);
614
+        $uid = $this->getUID($cardData);
615
+
616
+        $q = $this->db->getQueryBuilder();
617
+        $q->select('uid')
618
+            ->from('cards')
619
+            ->where($q->expr()->eq('addressbookid', $q->createNamedParameter($addressBookId)))
620
+            ->andWhere($q->expr()->eq('uid', $q->createNamedParameter($uid)))
621
+            ->setMaxResults(1);
622
+        $result = $q->execute();
623
+        $count = (bool) $result->fetchColumn();
624
+        $result->closeCursor();
625
+        if ($count) {
626
+            throw new \Sabre\DAV\Exception\BadRequest('VCard object with uid already exists in this addressbook collection.');
627
+        }
628
+
629
+        $query = $this->db->getQueryBuilder();
630
+        $query->insert('cards')
631
+            ->values([
632
+                'carddata' => $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB),
633
+                'uri' => $query->createNamedParameter($cardUri),
634
+                'lastmodified' => $query->createNamedParameter(time()),
635
+                'addressbookid' => $query->createNamedParameter($addressBookId),
636
+                'size' => $query->createNamedParameter(strlen($cardData)),
637
+                'etag' => $query->createNamedParameter($etag),
638
+                'uid' => $query->createNamedParameter($uid),
639
+            ])
640
+            ->execute();
641
+
642
+        $this->addChange($addressBookId, $cardUri, 1);
643
+        $this->updateProperties($addressBookId, $cardUri, $cardData);
644
+
645
+        $this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::createCard',
646
+            new GenericEvent(null, [
647
+                'addressBookId' => $addressBookId,
648
+                'cardUri' => $cardUri,
649
+                'cardData' => $cardData]));
650
+
651
+        return '"' . $etag . '"';
652
+    }
653
+
654
+    /**
655
+     * Updates a card.
656
+     *
657
+     * The addressbook id will be passed as the first argument. This is the
658
+     * same id as it is returned from the getAddressBooksForUser method.
659
+     *
660
+     * The cardUri is a base uri, and doesn't include the full path. The
661
+     * cardData argument is the vcard body, and is passed as a string.
662
+     *
663
+     * It is possible to return an ETag from this method. This ETag should
664
+     * match that of the updated resource, and must be enclosed with double
665
+     * quotes (that is: the string itself must contain the actual quotes).
666
+     *
667
+     * You should only return the ETag if you store the carddata as-is. If a
668
+     * subsequent GET request on the same card does not have the same body,
669
+     * byte-by-byte and you did return an ETag here, clients tend to get
670
+     * confused.
671
+     *
672
+     * If you don't return an ETag, you can just return null.
673
+     *
674
+     * @param mixed $addressBookId
675
+     * @param string $cardUri
676
+     * @param string $cardData
677
+     * @return string
678
+     */
679
+    function updateCard($addressBookId, $cardUri, $cardData) {
680
+
681
+        $uid = $this->getUID($cardData);
682
+        $etag = md5($cardData);
683
+        $query = $this->db->getQueryBuilder();
684
+        $query->update('cards')
685
+            ->set('carddata', $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB))
686
+            ->set('lastmodified', $query->createNamedParameter(time()))
687
+            ->set('size', $query->createNamedParameter(strlen($cardData)))
688
+            ->set('etag', $query->createNamedParameter($etag))
689
+            ->set('uid', $query->createNamedParameter($uid))
690
+            ->where($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
691
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
692
+            ->execute();
693
+
694
+        $this->addChange($addressBookId, $cardUri, 2);
695
+        $this->updateProperties($addressBookId, $cardUri, $cardData);
696
+
697
+        $this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::updateCard',
698
+            new GenericEvent(null, [
699
+                'addressBookId' => $addressBookId,
700
+                'cardUri' => $cardUri,
701
+                'cardData' => $cardData]));
702
+
703
+        return '"' . $etag . '"';
704
+    }
705
+
706
+    /**
707
+     * Deletes a card
708
+     *
709
+     * @param mixed $addressBookId
710
+     * @param string $cardUri
711
+     * @return bool
712
+     */
713
+    function deleteCard($addressBookId, $cardUri) {
714
+        try {
715
+            $cardId = $this->getCardId($addressBookId, $cardUri);
716
+        } catch (\InvalidArgumentException $e) {
717
+            $cardId = null;
718
+        }
719
+        $query = $this->db->getQueryBuilder();
720
+        $ret = $query->delete('cards')
721
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
722
+            ->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
723
+            ->execute();
724
+
725
+        $this->addChange($addressBookId, $cardUri, 3);
726
+
727
+        $this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::deleteCard',
728
+            new GenericEvent(null, [
729
+                'addressBookId' => $addressBookId,
730
+                'cardUri' => $cardUri]));
731
+
732
+        if ($ret === 1) {
733
+            if ($cardId !== null) {
734
+                $this->purgeProperties($addressBookId, $cardId);
735
+            }
736
+            return true;
737
+        }
738
+
739
+        return false;
740
+    }
741
+
742
+    /**
743
+     * The getChanges method returns all the changes that have happened, since
744
+     * the specified syncToken in the specified address book.
745
+     *
746
+     * This function should return an array, such as the following:
747
+     *
748
+     * [
749
+     *   'syncToken' => 'The current synctoken',
750
+     *   'added'   => [
751
+     *      'new.txt',
752
+     *   ],
753
+     *   'modified'   => [
754
+     *      'modified.txt',
755
+     *   ],
756
+     *   'deleted' => [
757
+     *      'foo.php.bak',
758
+     *      'old.txt'
759
+     *   ]
760
+     * ];
761
+     *
762
+     * The returned syncToken property should reflect the *current* syncToken
763
+     * of the calendar, as reported in the {http://sabredav.org/ns}sync-token
764
+     * property. This is needed here too, to ensure the operation is atomic.
765
+     *
766
+     * If the $syncToken argument is specified as null, this is an initial
767
+     * sync, and all members should be reported.
768
+     *
769
+     * The modified property is an array of nodenames that have changed since
770
+     * the last token.
771
+     *
772
+     * The deleted property is an array with nodenames, that have been deleted
773
+     * from collection.
774
+     *
775
+     * The $syncLevel argument is basically the 'depth' of the report. If it's
776
+     * 1, you only have to report changes that happened only directly in
777
+     * immediate descendants. If it's 2, it should also include changes from
778
+     * the nodes below the child collections. (grandchildren)
779
+     *
780
+     * The $limit argument allows a client to specify how many results should
781
+     * be returned at most. If the limit is not specified, it should be treated
782
+     * as infinite.
783
+     *
784
+     * If the limit (infinite or not) is higher than you're willing to return,
785
+     * you should throw a Sabre\DAV\Exception\TooMuchMatches() exception.
786
+     *
787
+     * If the syncToken is expired (due to data cleanup) or unknown, you must
788
+     * return null.
789
+     *
790
+     * The limit is 'suggestive'. You are free to ignore it.
791
+     *
792
+     * @param string $addressBookId
793
+     * @param string $syncToken
794
+     * @param int $syncLevel
795
+     * @param int $limit
796
+     * @return array
797
+     */
798
+    function getChangesForAddressBook($addressBookId, $syncToken, $syncLevel, $limit = null) {
799
+        // Current synctoken
800
+        $stmt = $this->db->prepare('SELECT `synctoken` FROM `*PREFIX*addressbooks` WHERE `id` = ?');
801
+        $stmt->execute([ $addressBookId ]);
802
+        $currentToken = $stmt->fetchColumn(0);
803
+
804
+        if (is_null($currentToken)) return null;
805
+
806
+        $result = [
807
+            'syncToken' => $currentToken,
808
+            'added'     => [],
809
+            'modified'  => [],
810
+            'deleted'   => [],
811
+        ];
812
+
813
+        if ($syncToken) {
814
+
815
+            $query = "SELECT `uri`, `operation` FROM `*PREFIX*addressbookchanges` WHERE `synctoken` >= ? AND `synctoken` < ? AND `addressbookid` = ? ORDER BY `synctoken`";
816
+            if ($limit>0) {
817
+                $query .= " LIMIT " . (int)$limit;
818
+            }
819
+
820
+            // Fetching all changes
821
+            $stmt = $this->db->prepare($query);
822
+            $stmt->execute([$syncToken, $currentToken, $addressBookId]);
823
+
824
+            $changes = [];
825
+
826
+            // This loop ensures that any duplicates are overwritten, only the
827
+            // last change on a node is relevant.
828
+            while($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
829
+
830
+                $changes[$row['uri']] = $row['operation'];
831
+
832
+            }
833
+
834
+            foreach($changes as $uri => $operation) {
835
+
836
+                switch($operation) {
837
+                    case 1:
838
+                        $result['added'][] = $uri;
839
+                        break;
840
+                    case 2:
841
+                        $result['modified'][] = $uri;
842
+                        break;
843
+                    case 3:
844
+                        $result['deleted'][] = $uri;
845
+                        break;
846
+                }
847
+
848
+            }
849
+        } else {
850
+            // No synctoken supplied, this is the initial sync.
851
+            $query = "SELECT `uri` FROM `*PREFIX*cards` WHERE `addressbookid` = ?";
852
+            $stmt = $this->db->prepare($query);
853
+            $stmt->execute([$addressBookId]);
854
+
855
+            $result['added'] = $stmt->fetchAll(\PDO::FETCH_COLUMN);
856
+        }
857
+        return $result;
858
+    }
859
+
860
+    /**
861
+     * Adds a change record to the addressbookchanges table.
862
+     *
863
+     * @param mixed $addressBookId
864
+     * @param string $objectUri
865
+     * @param int $operation 1 = add, 2 = modify, 3 = delete
866
+     * @return void
867
+     */
868
+    protected function addChange($addressBookId, $objectUri, $operation) {
869
+        $sql = 'INSERT INTO `*PREFIX*addressbookchanges`(`uri`, `synctoken`, `addressbookid`, `operation`) SELECT ?, `synctoken`, ?, ? FROM `*PREFIX*addressbooks` WHERE `id` = ?';
870
+        $stmt = $this->db->prepare($sql);
871
+        $stmt->execute([
872
+            $objectUri,
873
+            $addressBookId,
874
+            $operation,
875
+            $addressBookId
876
+        ]);
877
+        $stmt = $this->db->prepare('UPDATE `*PREFIX*addressbooks` SET `synctoken` = `synctoken` + 1 WHERE `id` = ?');
878
+        $stmt->execute([
879
+            $addressBookId
880
+        ]);
881
+    }
882
+
883
+    private function readBlob($cardData) {
884
+        if (is_resource($cardData)) {
885
+            return stream_get_contents($cardData);
886
+        }
887
+
888
+        return $cardData;
889
+    }
890
+
891
+    /**
892
+     * @param IShareable $shareable
893
+     * @param string[] $add
894
+     * @param string[] $remove
895
+     */
896
+    public function updateShares(IShareable $shareable, $add, $remove) {
897
+        $this->sharingBackend->updateShares($shareable, $add, $remove);
898
+    }
899
+
900
+    /**
901
+     * search contact
902
+     *
903
+     * @param int $addressBookId
904
+     * @param string $pattern which should match within the $searchProperties
905
+     * @param array $searchProperties defines the properties within the query pattern should match
906
+     * @param array $options = array() to define the search behavior
907
+     * 	- 'escape_like_param' - If set to false wildcards _ and % are not escaped, otherwise they are
908
+     * @return array an array of contacts which are arrays of key-value-pairs
909
+     */
910
+    public function search($addressBookId, $pattern, $searchProperties, $options = array()) {
911
+        $query = $this->db->getQueryBuilder();
912
+        $query2 = $this->db->getQueryBuilder();
913
+
914
+        $query2->selectDistinct('cp.cardid')->from($this->dbCardsPropertiesTable, 'cp');
915
+        $query2->andWhere($query2->expr()->eq('cp.addressbookid', $query->createNamedParameter($addressBookId)));
916
+        $or = $query2->expr()->orX();
917
+        foreach ($searchProperties as $property) {
918
+            $or->add($query2->expr()->eq('cp.name', $query->createNamedParameter($property)));
919
+        }
920
+        $query2->andWhere($or);
921
+
922
+        // No need for like when the pattern is empty
923
+        if ('' !== $pattern) {
924
+            if(\array_key_exists('escape_like_param', $options) && $options['escape_like_param'] === false) {
925
+                $query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter($pattern)));
926
+            } else {
927
+                $query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter('%' . $this->db->escapeLikeParameter($pattern) . '%')));
928
+            }
929
+        }
930
+
931
+        $query->select('c.carddata', 'c.uri')->from($this->dbCardsTable, 'c')
932
+            ->where($query->expr()->in('c.id', $query->createFunction($query2->getSQL())));
933
+
934
+        $result = $query->execute();
935
+        $cards = $result->fetchAll();
936
+
937
+        $result->closeCursor();
938
+
939
+        return array_map(function($array) {
940
+            $array['carddata'] = $this->readBlob($array['carddata']);
941
+            return $array;
942
+        }, $cards);
943
+    }
944
+
945
+    /**
946
+     * @param int $bookId
947
+     * @param string $name
948
+     * @return array
949
+     */
950
+    public function collectCardProperties($bookId, $name) {
951
+        $query = $this->db->getQueryBuilder();
952
+        $result = $query->selectDistinct('value')
953
+            ->from($this->dbCardsPropertiesTable)
954
+            ->where($query->expr()->eq('name', $query->createNamedParameter($name)))
955
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($bookId)))
956
+            ->execute();
957
+
958
+        $all = $result->fetchAll(PDO::FETCH_COLUMN);
959
+        $result->closeCursor();
960
+
961
+        return $all;
962
+    }
963
+
964
+    /**
965
+     * get URI from a given contact
966
+     *
967
+     * @param int $id
968
+     * @return string
969
+     */
970
+    public function getCardUri($id) {
971
+        $query = $this->db->getQueryBuilder();
972
+        $query->select('uri')->from($this->dbCardsTable)
973
+                ->where($query->expr()->eq('id', $query->createParameter('id')))
974
+                ->setParameter('id', $id);
975
+
976
+        $result = $query->execute();
977
+        $uri = $result->fetch();
978
+        $result->closeCursor();
979
+
980
+        if (!isset($uri['uri'])) {
981
+            throw new \InvalidArgumentException('Card does not exists: ' . $id);
982
+        }
983
+
984
+        return $uri['uri'];
985
+    }
986
+
987
+    /**
988
+     * return contact with the given URI
989
+     *
990
+     * @param int $addressBookId
991
+     * @param string $uri
992
+     * @returns array
993
+     */
994
+    public function getContact($addressBookId, $uri) {
995
+        $result = [];
996
+        $query = $this->db->getQueryBuilder();
997
+        $query->select('*')->from($this->dbCardsTable)
998
+                ->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
999
+                ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1000
+        $queryResult = $query->execute();
1001
+        $contact = $queryResult->fetch();
1002
+        $queryResult->closeCursor();
1003
+
1004
+        if (is_array($contact)) {
1005
+            $result = $contact;
1006
+        }
1007
+
1008
+        return $result;
1009
+    }
1010
+
1011
+    /**
1012
+     * Returns the list of people whom this address book is shared with.
1013
+     *
1014
+     * Every element in this array should have the following properties:
1015
+     *   * href - Often a mailto: address
1016
+     *   * commonName - Optional, for example a first + last name
1017
+     *   * status - See the Sabre\CalDAV\SharingPlugin::STATUS_ constants.
1018
+     *   * readOnly - boolean
1019
+     *   * summary - Optional, a description for the share
1020
+     *
1021
+     * @return array
1022
+     */
1023
+    public function getShares($addressBookId) {
1024
+        return $this->sharingBackend->getShares($addressBookId);
1025
+    }
1026
+
1027
+    /**
1028
+     * update properties table
1029
+     *
1030
+     * @param int $addressBookId
1031
+     * @param string $cardUri
1032
+     * @param string $vCardSerialized
1033
+     */
1034
+    protected function updateProperties($addressBookId, $cardUri, $vCardSerialized) {
1035
+        $cardId = $this->getCardId($addressBookId, $cardUri);
1036
+        $vCard = $this->readCard($vCardSerialized);
1037
+
1038
+        $this->purgeProperties($addressBookId, $cardId);
1039
+
1040
+        $query = $this->db->getQueryBuilder();
1041
+        $query->insert($this->dbCardsPropertiesTable)
1042
+            ->values(
1043
+                [
1044
+                    'addressbookid' => $query->createNamedParameter($addressBookId),
1045
+                    'cardid' => $query->createNamedParameter($cardId),
1046
+                    'name' => $query->createParameter('name'),
1047
+                    'value' => $query->createParameter('value'),
1048
+                    'preferred' => $query->createParameter('preferred')
1049
+                ]
1050
+            );
1051
+
1052
+        foreach ($vCard->children() as $property) {
1053
+            if(!in_array($property->name, self::$indexProperties)) {
1054
+                continue;
1055
+            }
1056
+            $preferred = 0;
1057
+            foreach($property->parameters as $parameter) {
1058
+                if ($parameter->name === 'TYPE' && strtoupper($parameter->getValue()) === 'PREF') {
1059
+                    $preferred = 1;
1060
+                    break;
1061
+                }
1062
+            }
1063
+            $query->setParameter('name', $property->name);
1064
+            $query->setParameter('value', substr($property->getValue(), 0, 254));
1065
+            $query->setParameter('preferred', $preferred);
1066
+            $query->execute();
1067
+        }
1068
+    }
1069
+
1070
+    /**
1071
+     * read vCard data into a vCard object
1072
+     *
1073
+     * @param string $cardData
1074
+     * @return VCard
1075
+     */
1076
+    protected function readCard($cardData) {
1077
+        return  Reader::read($cardData);
1078
+    }
1079
+
1080
+    /**
1081
+     * delete all properties from a given card
1082
+     *
1083
+     * @param int $addressBookId
1084
+     * @param int $cardId
1085
+     */
1086
+    protected function purgeProperties($addressBookId, $cardId) {
1087
+        $query = $this->db->getQueryBuilder();
1088
+        $query->delete($this->dbCardsPropertiesTable)
1089
+            ->where($query->expr()->eq('cardid', $query->createNamedParameter($cardId)))
1090
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1091
+        $query->execute();
1092
+    }
1093
+
1094
+    /**
1095
+     * get ID from a given contact
1096
+     *
1097
+     * @param int $addressBookId
1098
+     * @param string $uri
1099
+     * @return int
1100
+     */
1101
+    protected function getCardId($addressBookId, $uri) {
1102
+        $query = $this->db->getQueryBuilder();
1103
+        $query->select('id')->from($this->dbCardsTable)
1104
+            ->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
1105
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1106
+
1107
+        $result = $query->execute();
1108
+        $cardIds = $result->fetch();
1109
+        $result->closeCursor();
1110
+
1111
+        if (!isset($cardIds['id'])) {
1112
+            throw new \InvalidArgumentException('Card does not exists: ' . $uri);
1113
+        }
1114
+
1115
+        return (int)$cardIds['id'];
1116
+    }
1117
+
1118
+    /**
1119
+     * For shared address books the sharee is set in the ACL of the address book
1120
+     * @param $addressBookId
1121
+     * @param $acl
1122
+     * @return array
1123
+     */
1124
+    public function applyShareAcl($addressBookId, $acl) {
1125
+        return $this->sharingBackend->applyShareAcl($addressBookId, $acl);
1126
+    }
1127
+
1128
+    private function convertPrincipal($principalUri, $toV2) {
1129
+        if ($this->principalBackend->getPrincipalPrefix() === 'principals') {
1130
+            list(, $name) = \Sabre\Uri\split($principalUri);
1131
+            if ($toV2 === true) {
1132
+                return "principals/users/$name";
1133
+            }
1134
+            return "principals/$name";
1135
+        }
1136
+        return $principalUri;
1137
+    }
1138
+
1139
+    private function addOwnerPrincipal(&$addressbookInfo) {
1140
+        $ownerPrincipalKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal';
1141
+        $displaynameKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_NEXTCLOUD . '}owner-displayname';
1142
+        if (isset($addressbookInfo[$ownerPrincipalKey])) {
1143
+            $uri = $addressbookInfo[$ownerPrincipalKey];
1144
+        } else {
1145
+            $uri = $addressbookInfo['principaluri'];
1146
+        }
1147
+
1148
+        $principalInformation = $this->principalBackend->getPrincipalByPath($uri);
1149
+        if (isset($principalInformation['{DAV:}displayname'])) {
1150
+            $addressbookInfo[$displaynameKey] = $principalInformation['{DAV:}displayname'];
1151
+        }
1152
+    }
1153
+
1154
+    /**
1155
+     * Extract UID from vcard
1156
+     *
1157
+     * @param string $cardData the vcard raw data
1158
+     * @return string the uid
1159
+     * @throws BadRequest if no UID is available
1160
+     */
1161
+    private function getUID($cardData) {
1162
+        if ($cardData != '') {
1163
+            $vCard = Reader::read($cardData);
1164
+            if ($vCard->UID) {
1165
+                $uid = $vCard->UID->getValue();
1166
+                return $uid;
1167
+            }
1168
+            // should already be handled, but just in case
1169
+            throw new BadRequest('vCards on CardDAV servers MUST have a UID property');
1170
+        }
1171
+        // should already be handled, but just in case
1172
+        throw new BadRequest('vCard can not be empty');
1173
+    }
1174 1174
 }
Please login to merge, or discard this patch.
Spacing   +50 added lines, -50 removed lines patch added patch discarded remove patch
@@ -121,7 +121,7 @@  discard block
 block discarded – undo
121 121
 			->from('addressbooks')
122 122
 			->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
123 123
 
124
-		return (int)$query->execute()->fetchColumn();
124
+		return (int) $query->execute()->fetchColumn();
125 125
 	}
126 126
 
127 127
 	/**
@@ -152,15 +152,15 @@  discard block
 block discarded – undo
152 152
 		$addressBooks = [];
153 153
 
154 154
 		$result = $query->execute();
155
-		while($row = $result->fetch()) {
155
+		while ($row = $result->fetch()) {
156 156
 			$addressBooks[$row['id']] = [
157 157
 				'id'  => $row['id'],
158 158
 				'uri' => $row['uri'],
159 159
 				'principaluri' => $this->convertPrincipal($row['principaluri'], false),
160 160
 				'{DAV:}displayname' => $row['displayname'],
161
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
161
+				'{'.Plugin::NS_CARDDAV.'}addressbook-description' => $row['description'],
162 162
 				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
163
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
163
+				'{http://sabredav.org/ns}sync-token' => $row['synctoken'] ? $row['synctoken'] : '0',
164 164
 			];
165 165
 
166 166
 			$this->addOwnerPrincipal($addressBooks[$row['id']]);
@@ -174,7 +174,7 @@  discard block
 block discarded – undo
174 174
 		$principals = array_map(function($principal) {
175 175
 			return urldecode($principal);
176 176
 		}, $principals);
177
-		$principals[]= $principalUri;
177
+		$principals[] = $principalUri;
178 178
 
179 179
 		$query = $this->db->getQueryBuilder();
180 180
 		$result = $query->select(['a.id', 'a.uri', 'a.displayname', 'a.principaluri', 'a.description', 'a.synctoken', 's.access'])
@@ -186,8 +186,8 @@  discard block
 block discarded – undo
186 186
 			->setParameter('principaluri', $principals, IQueryBuilder::PARAM_STR_ARRAY)
187 187
 			->execute();
188 188
 
189
-		$readOnlyPropertyName = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}read-only';
190
-		while($row = $result->fetch()) {
189
+		$readOnlyPropertyName = '{'.\OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD.'}read-only';
190
+		while ($row = $result->fetch()) {
191 191
 			if ($row['principaluri'] === $principalUri) {
192 192
 				continue;
193 193
 			}
@@ -206,18 +206,18 @@  discard block
 block discarded – undo
206 206
 			}
207 207
 
208 208
 			list(, $name) = \Sabre\Uri\split($row['principaluri']);
209
-			$uri = $row['uri'] . '_shared_by_' . $name;
210
-			$displayName = $row['displayname'] . ' (' . $this->getUserDisplayName($name) . ')';
209
+			$uri = $row['uri'].'_shared_by_'.$name;
210
+			$displayName = $row['displayname'].' ('.$this->getUserDisplayName($name).')';
211 211
 
212 212
 			$addressBooks[$row['id']] = [
213 213
 				'id'  => $row['id'],
214 214
 				'uri' => $uri,
215 215
 				'principaluri' => $principalUriOriginal,
216 216
 				'{DAV:}displayname' => $displayName,
217
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
217
+				'{'.Plugin::NS_CARDDAV.'}addressbook-description' => $row['description'],
218 218
 				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
219
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
220
-				'{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal' => $row['principaluri'],
219
+				'{http://sabredav.org/ns}sync-token' => $row['synctoken'] ? $row['synctoken'] : '0',
220
+				'{'.\OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD.'}owner-principal' => $row['principaluri'],
221 221
 				$readOnlyPropertyName => $readOnly,
222 222
 			];
223 223
 
@@ -238,15 +238,15 @@  discard block
 block discarded – undo
238 238
 		$addressBooks = [];
239 239
 
240 240
 		$result = $query->execute();
241
-		while($row = $result->fetch()) {
241
+		while ($row = $result->fetch()) {
242 242
 			$addressBooks[$row['id']] = [
243 243
 				'id'  => $row['id'],
244 244
 				'uri' => $row['uri'],
245 245
 				'principaluri' => $this->convertPrincipal($row['principaluri'], false),
246 246
 				'{DAV:}displayname' => $row['displayname'],
247
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
247
+				'{'.Plugin::NS_CARDDAV.'}addressbook-description' => $row['description'],
248 248
 				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
249
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
249
+				'{http://sabredav.org/ns}sync-token' => $row['synctoken'] ? $row['synctoken'] : '0',
250 250
 			];
251 251
 
252 252
 			$this->addOwnerPrincipal($addressBooks[$row['id']]);
@@ -291,9 +291,9 @@  discard block
 block discarded – undo
291 291
 			'uri' => $row['uri'],
292 292
 			'principaluri' => $row['principaluri'],
293 293
 			'{DAV:}displayname' => $row['displayname'],
294
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
294
+			'{'.Plugin::NS_CARDDAV.'}addressbook-description' => $row['description'],
295 295
 			'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
296
-			'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
296
+			'{http://sabredav.org/ns}sync-token' => $row['synctoken'] ? $row['synctoken'] : '0',
297 297
 		];
298 298
 
299 299
 		$this->addOwnerPrincipal($addressBook);
@@ -325,9 +325,9 @@  discard block
 block discarded – undo
325 325
 			'uri' => $row['uri'],
326 326
 			'principaluri' => $row['principaluri'],
327 327
 			'{DAV:}displayname' => $row['displayname'],
328
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
328
+			'{'.Plugin::NS_CARDDAV.'}addressbook-description' => $row['description'],
329 329
 			'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
330
-			'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
330
+			'{http://sabredav.org/ns}sync-token' => $row['synctoken'] ? $row['synctoken'] : '0',
331 331
 		];
332 332
 
333 333
 		$this->addOwnerPrincipal($addressBook);
@@ -354,7 +354,7 @@  discard block
 block discarded – undo
354 354
 	function updateAddressBook($addressBookId, \Sabre\DAV\PropPatch $propPatch) {
355 355
 		$supportedProperties = [
356 356
 			'{DAV:}displayname',
357
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description',
357
+			'{'.Plugin::NS_CARDDAV.'}addressbook-description',
358 358
 		];
359 359
 
360 360
 		/**
@@ -363,13 +363,13 @@  discard block
 block discarded – undo
363 363
 		$propPatch->handle($supportedProperties, function($mutations) use ($addressBookId) {
364 364
 
365 365
 			$updates = [];
366
-			foreach($mutations as $property=>$newValue) {
366
+			foreach ($mutations as $property=>$newValue) {
367 367
 
368
-				switch($property) {
368
+				switch ($property) {
369 369
 					case '{DAV:}displayname' :
370 370
 						$updates['displayname'] = $newValue;
371 371
 						break;
372
-					case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
372
+					case '{'.Plugin::NS_CARDDAV.'}addressbook-description' :
373 373
 						$updates['description'] = $newValue;
374 374
 						break;
375 375
 				}
@@ -377,7 +377,7 @@  discard block
 block discarded – undo
377 377
 			$query = $this->db->getQueryBuilder();
378 378
 			$query->update('addressbooks');
379 379
 
380
-			foreach($updates as $key=>$value) {
380
+			foreach ($updates as $key=>$value) {
381 381
 				$query->set($key, $query->createNamedParameter($value));
382 382
 			}
383 383
 			$query->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
@@ -408,24 +408,24 @@  discard block
 block discarded – undo
408 408
 			'synctoken' => 1
409 409
 		];
410 410
 
411
-		foreach($properties as $property=>$newValue) {
411
+		foreach ($properties as $property=>$newValue) {
412 412
 
413
-			switch($property) {
413
+			switch ($property) {
414 414
 				case '{DAV:}displayname' :
415 415
 					$values['displayname'] = $newValue;
416 416
 					break;
417
-				case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
417
+				case '{'.Plugin::NS_CARDDAV.'}addressbook-description' :
418 418
 					$values['description'] = $newValue;
419 419
 					break;
420 420
 				default :
421
-					throw new BadRequest('Unknown property: ' . $property);
421
+					throw new BadRequest('Unknown property: '.$property);
422 422
 			}
423 423
 
424 424
 		}
425 425
 
426 426
 		// Fallback to make sure the displayname is set. Some clients may refuse
427 427
 		// to work with addressbooks not having a displayname.
428
-		if(is_null($values['displayname'])) {
428
+		if (is_null($values['displayname'])) {
429 429
 			$values['displayname'] = $url;
430 430
 		}
431 431
 
@@ -503,8 +503,8 @@  discard block
 block discarded – undo
503 503
 		$cards = [];
504 504
 
505 505
 		$result = $query->execute();
506
-		while($row = $result->fetch()) {
507
-			$row['etag'] = '"' . $row['etag'] . '"';
506
+		while ($row = $result->fetch()) {
507
+			$row['etag'] = '"'.$row['etag'].'"';
508 508
 			$row['carddata'] = $this->readBlob($row['carddata']);
509 509
 			$cards[] = $row;
510 510
 		}
@@ -538,7 +538,7 @@  discard block
 block discarded – undo
538 538
 		if (!$row) {
539 539
 			return false;
540 540
 		}
541
-		$row['etag'] = '"' . $row['etag'] . '"';
541
+		$row['etag'] = '"'.$row['etag'].'"';
542 542
 		$row['carddata'] = $this->readBlob($row['carddata']);
543 543
 
544 544
 		return $row;
@@ -575,7 +575,7 @@  discard block
 block discarded – undo
575 575
 			$result = $query->execute();
576 576
 
577 577
 			while ($row = $result->fetch()) {
578
-				$row['etag'] = '"' . $row['etag'] . '"';
578
+				$row['etag'] = '"'.$row['etag'].'"';
579 579
 				$row['carddata'] = $this->readBlob($row['carddata']);
580 580
 				$cards[] = $row;
581 581
 			}
@@ -648,7 +648,7 @@  discard block
 block discarded – undo
648 648
 				'cardUri' => $cardUri,
649 649
 				'cardData' => $cardData]));
650 650
 
651
-		return '"' . $etag . '"';
651
+		return '"'.$etag.'"';
652 652
 	}
653 653
 
654 654
 	/**
@@ -700,7 +700,7 @@  discard block
 block discarded – undo
700 700
 				'cardUri' => $cardUri,
701 701
 				'cardData' => $cardData]));
702 702
 
703
-		return '"' . $etag . '"';
703
+		return '"'.$etag.'"';
704 704
 	}
705 705
 
706 706
 	/**
@@ -798,7 +798,7 @@  discard block
 block discarded – undo
798 798
 	function getChangesForAddressBook($addressBookId, $syncToken, $syncLevel, $limit = null) {
799 799
 		// Current synctoken
800 800
 		$stmt = $this->db->prepare('SELECT `synctoken` FROM `*PREFIX*addressbooks` WHERE `id` = ?');
801
-		$stmt->execute([ $addressBookId ]);
801
+		$stmt->execute([$addressBookId]);
802 802
 		$currentToken = $stmt->fetchColumn(0);
803 803
 
804 804
 		if (is_null($currentToken)) return null;
@@ -813,8 +813,8 @@  discard block
 block discarded – undo
813 813
 		if ($syncToken) {
814 814
 
815 815
 			$query = "SELECT `uri`, `operation` FROM `*PREFIX*addressbookchanges` WHERE `synctoken` >= ? AND `synctoken` < ? AND `addressbookid` = ? ORDER BY `synctoken`";
816
-			if ($limit>0) {
817
-				$query .= " LIMIT " . (int)$limit;
816
+			if ($limit > 0) {
817
+				$query .= " LIMIT ".(int) $limit;
818 818
 			}
819 819
 
820 820
 			// Fetching all changes
@@ -825,15 +825,15 @@  discard block
 block discarded – undo
825 825
 
826 826
 			// This loop ensures that any duplicates are overwritten, only the
827 827
 			// last change on a node is relevant.
828
-			while($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
828
+			while ($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
829 829
 
830 830
 				$changes[$row['uri']] = $row['operation'];
831 831
 
832 832
 			}
833 833
 
834
-			foreach($changes as $uri => $operation) {
834
+			foreach ($changes as $uri => $operation) {
835 835
 
836
-				switch($operation) {
836
+				switch ($operation) {
837 837
 					case 1:
838 838
 						$result['added'][] = $uri;
839 839
 						break;
@@ -921,10 +921,10 @@  discard block
 block discarded – undo
921 921
 
922 922
 		// No need for like when the pattern is empty
923 923
 		if ('' !== $pattern) {
924
-			if(\array_key_exists('escape_like_param', $options) && $options['escape_like_param'] === false) {
924
+			if (\array_key_exists('escape_like_param', $options) && $options['escape_like_param'] === false) {
925 925
 				$query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter($pattern)));
926 926
 			} else {
927
-				$query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter('%' . $this->db->escapeLikeParameter($pattern) . '%')));
927
+				$query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter('%'.$this->db->escapeLikeParameter($pattern).'%')));
928 928
 			}
929 929
 		}
930 930
 
@@ -978,7 +978,7 @@  discard block
 block discarded – undo
978 978
 		$result->closeCursor();
979 979
 
980 980
 		if (!isset($uri['uri'])) {
981
-			throw new \InvalidArgumentException('Card does not exists: ' . $id);
981
+			throw new \InvalidArgumentException('Card does not exists: '.$id);
982 982
 		}
983 983
 
984 984
 		return $uri['uri'];
@@ -1050,11 +1050,11 @@  discard block
 block discarded – undo
1050 1050
 			);
1051 1051
 
1052 1052
 		foreach ($vCard->children() as $property) {
1053
-			if(!in_array($property->name, self::$indexProperties)) {
1053
+			if (!in_array($property->name, self::$indexProperties)) {
1054 1054
 				continue;
1055 1055
 			}
1056 1056
 			$preferred = 0;
1057
-			foreach($property->parameters as $parameter) {
1057
+			foreach ($property->parameters as $parameter) {
1058 1058
 				if ($parameter->name === 'TYPE' && strtoupper($parameter->getValue()) === 'PREF') {
1059 1059
 					$preferred = 1;
1060 1060
 					break;
@@ -1109,10 +1109,10 @@  discard block
 block discarded – undo
1109 1109
 		$result->closeCursor();
1110 1110
 
1111 1111
 		if (!isset($cardIds['id'])) {
1112
-			throw new \InvalidArgumentException('Card does not exists: ' . $uri);
1112
+			throw new \InvalidArgumentException('Card does not exists: '.$uri);
1113 1113
 		}
1114 1114
 
1115
-		return (int)$cardIds['id'];
1115
+		return (int) $cardIds['id'];
1116 1116
 	}
1117 1117
 
1118 1118
 	/**
@@ -1137,8 +1137,8 @@  discard block
 block discarded – undo
1137 1137
 	}
1138 1138
 
1139 1139
 	private function addOwnerPrincipal(&$addressbookInfo) {
1140
-		$ownerPrincipalKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal';
1141
-		$displaynameKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_NEXTCLOUD . '}owner-displayname';
1140
+		$ownerPrincipalKey = '{'.\OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD.'}owner-principal';
1141
+		$displaynameKey = '{'.\OCA\DAV\DAV\Sharing\Plugin::NS_NEXTCLOUD.'}owner-displayname';
1142 1142
 		if (isset($addressbookInfo[$ownerPrincipalKey])) {
1143 1143
 			$uri = $addressbookInfo[$ownerPrincipalKey];
1144 1144
 		} else {
Please login to merge, or discard this patch.
apps/dav/lib/SystemTag/SystemTagNode.php 2 patches
Indentation   +132 added lines, -132 removed lines patch added patch discarded remove patch
@@ -39,136 +39,136 @@
 block discarded – undo
39 39
  */
40 40
 class SystemTagNode implements \Sabre\DAV\INode {
41 41
 
42
-	/**
43
-	 * @var ISystemTag
44
-	 */
45
-	protected $tag;
46
-
47
-	/**
48
-	 * @var ISystemTagManager
49
-	 */
50
-	protected $tagManager;
51
-
52
-	/**
53
-	 * User
54
-	 *
55
-	 * @var IUser
56
-	 */
57
-	protected $user;
58
-
59
-	/**
60
-	 * Whether to allow permissions for admins
61
-	 *
62
-	 * @var bool
63
-	 */
64
-	protected $isAdmin;
65
-
66
-	/**
67
-	 * Sets up the node, expects a full path name
68
-	 *
69
-	 * @param ISystemTag $tag system tag
70
-	 * @param IUser $user user
71
-	 * @param bool $isAdmin whether to allow operations for admins
72
-	 * @param ISystemTagManager $tagManager tag manager
73
-	 */
74
-	public function __construct(ISystemTag $tag, IUser $user, $isAdmin, ISystemTagManager $tagManager) {
75
-		$this->tag = $tag;
76
-		$this->user = $user;
77
-		$this->isAdmin = $isAdmin;
78
-		$this->tagManager = $tagManager;
79
-	}
80
-
81
-	/**
82
-	 *  Returns the id of the tag
83
-	 *
84
-	 * @return string
85
-	 */
86
-	public function getName() {
87
-		return $this->tag->getId();
88
-	}
89
-
90
-	/**
91
-	 * Returns the system tag represented by this node
92
-	 *
93
-	 * @return ISystemTag system tag
94
-	 */
95
-	public function getSystemTag() {
96
-		return $this->tag;
97
-	}
98
-
99
-	/**
100
-	 * Renames the node
101
-	 *
102
-	 * @param string $name The new name
103
-	 *
104
-	 * @throws MethodNotAllowed not allowed to rename node
105
-	 */
106
-	public function setName($name) {
107
-		throw new MethodNotAllowed();
108
-	}
109
-
110
-	/**
111
-	 * Update tag
112
-	 *
113
-	 * @param string $name new tag name
114
-	 * @param bool $userVisible user visible
115
-	 * @param bool $userAssignable user assignable
116
-	 * @throws NotFound whenever the given tag id does not exist
117
-	 * @throws Forbidden whenever there is no permission to update said tag
118
-	 * @throws Conflict whenever a tag already exists with the given attributes
119
-	 */
120
-	public function update($name, $userVisible, $userAssignable) {
121
-		try {
122
-			if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
123
-				throw new NotFound('Tag with id ' . $this->tag->getId() . ' does not exist');
124
-			}
125
-			if (!$this->tagManager->canUserAssignTag($this->tag, $this->user)) {
126
-				throw new Forbidden('No permission to update tag ' . $this->tag->getId());
127
-			}
128
-
129
-			// only admin is able to change permissions, regular users can only rename
130
-			if (!$this->isAdmin) {
131
-				// only renaming is allowed for regular users
132
-				if ($userVisible !== $this->tag->isUserVisible()
133
-					|| $userAssignable !== $this->tag->isUserAssignable()
134
-				) {
135
-					throw new Forbidden('No permission to update permissions for tag ' . $this->tag->getId());
136
-				}
137
-			}
138
-
139
-			$this->tagManager->updateTag($this->tag->getId(), $name, $userVisible, $userAssignable);
140
-		} catch (TagNotFoundException $e) {
141
-			throw new NotFound('Tag with id ' . $this->tag->getId() . ' does not exist');
142
-		} catch (TagAlreadyExistsException $e) {
143
-			throw new Conflict(
144
-				'Tag with the properties "' . $name . '", ' .
145
-				$userVisible . ', ' . $userAssignable . ' already exists'
146
-			);
147
-		}
148
-	}
149
-
150
-	/**
151
-	 * Returns null, not supported
152
-	 *
153
-	 */
154
-	public function getLastModified() {
155
-		return null;
156
-	}
157
-
158
-	public function delete() {
159
-		try {
160
-			if (!$this->isAdmin) {
161
-				throw new Forbidden('No permission to delete tag ' . $this->tag->getId());
162
-			}
163
-
164
-			if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
165
-				throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found');
166
-			}
167
-
168
-			$this->tagManager->deleteTags($this->tag->getId());
169
-		} catch (TagNotFoundException $e) {
170
-			// can happen if concurrent deletion occurred
171
-			throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found', 0, $e);
172
-		}
173
-	}
42
+    /**
43
+     * @var ISystemTag
44
+     */
45
+    protected $tag;
46
+
47
+    /**
48
+     * @var ISystemTagManager
49
+     */
50
+    protected $tagManager;
51
+
52
+    /**
53
+     * User
54
+     *
55
+     * @var IUser
56
+     */
57
+    protected $user;
58
+
59
+    /**
60
+     * Whether to allow permissions for admins
61
+     *
62
+     * @var bool
63
+     */
64
+    protected $isAdmin;
65
+
66
+    /**
67
+     * Sets up the node, expects a full path name
68
+     *
69
+     * @param ISystemTag $tag system tag
70
+     * @param IUser $user user
71
+     * @param bool $isAdmin whether to allow operations for admins
72
+     * @param ISystemTagManager $tagManager tag manager
73
+     */
74
+    public function __construct(ISystemTag $tag, IUser $user, $isAdmin, ISystemTagManager $tagManager) {
75
+        $this->tag = $tag;
76
+        $this->user = $user;
77
+        $this->isAdmin = $isAdmin;
78
+        $this->tagManager = $tagManager;
79
+    }
80
+
81
+    /**
82
+     *  Returns the id of the tag
83
+     *
84
+     * @return string
85
+     */
86
+    public function getName() {
87
+        return $this->tag->getId();
88
+    }
89
+
90
+    /**
91
+     * Returns the system tag represented by this node
92
+     *
93
+     * @return ISystemTag system tag
94
+     */
95
+    public function getSystemTag() {
96
+        return $this->tag;
97
+    }
98
+
99
+    /**
100
+     * Renames the node
101
+     *
102
+     * @param string $name The new name
103
+     *
104
+     * @throws MethodNotAllowed not allowed to rename node
105
+     */
106
+    public function setName($name) {
107
+        throw new MethodNotAllowed();
108
+    }
109
+
110
+    /**
111
+     * Update tag
112
+     *
113
+     * @param string $name new tag name
114
+     * @param bool $userVisible user visible
115
+     * @param bool $userAssignable user assignable
116
+     * @throws NotFound whenever the given tag id does not exist
117
+     * @throws Forbidden whenever there is no permission to update said tag
118
+     * @throws Conflict whenever a tag already exists with the given attributes
119
+     */
120
+    public function update($name, $userVisible, $userAssignable) {
121
+        try {
122
+            if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
123
+                throw new NotFound('Tag with id ' . $this->tag->getId() . ' does not exist');
124
+            }
125
+            if (!$this->tagManager->canUserAssignTag($this->tag, $this->user)) {
126
+                throw new Forbidden('No permission to update tag ' . $this->tag->getId());
127
+            }
128
+
129
+            // only admin is able to change permissions, regular users can only rename
130
+            if (!$this->isAdmin) {
131
+                // only renaming is allowed for regular users
132
+                if ($userVisible !== $this->tag->isUserVisible()
133
+                    || $userAssignable !== $this->tag->isUserAssignable()
134
+                ) {
135
+                    throw new Forbidden('No permission to update permissions for tag ' . $this->tag->getId());
136
+                }
137
+            }
138
+
139
+            $this->tagManager->updateTag($this->tag->getId(), $name, $userVisible, $userAssignable);
140
+        } catch (TagNotFoundException $e) {
141
+            throw new NotFound('Tag with id ' . $this->tag->getId() . ' does not exist');
142
+        } catch (TagAlreadyExistsException $e) {
143
+            throw new Conflict(
144
+                'Tag with the properties "' . $name . '", ' .
145
+                $userVisible . ', ' . $userAssignable . ' already exists'
146
+            );
147
+        }
148
+    }
149
+
150
+    /**
151
+     * Returns null, not supported
152
+     *
153
+     */
154
+    public function getLastModified() {
155
+        return null;
156
+    }
157
+
158
+    public function delete() {
159
+        try {
160
+            if (!$this->isAdmin) {
161
+                throw new Forbidden('No permission to delete tag ' . $this->tag->getId());
162
+            }
163
+
164
+            if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
165
+                throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found');
166
+            }
167
+
168
+            $this->tagManager->deleteTags($this->tag->getId());
169
+        } catch (TagNotFoundException $e) {
170
+            // can happen if concurrent deletion occurred
171
+            throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found', 0, $e);
172
+        }
173
+    }
174 174
 }
Please login to merge, or discard this patch.
Spacing   +9 added lines, -9 removed lines patch added patch discarded remove patch
@@ -120,10 +120,10 @@  discard block
 block discarded – undo
120 120
 	public function update($name, $userVisible, $userAssignable) {
121 121
 		try {
122 122
 			if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
123
-				throw new NotFound('Tag with id ' . $this->tag->getId() . ' does not exist');
123
+				throw new NotFound('Tag with id '.$this->tag->getId().' does not exist');
124 124
 			}
125 125
 			if (!$this->tagManager->canUserAssignTag($this->tag, $this->user)) {
126
-				throw new Forbidden('No permission to update tag ' . $this->tag->getId());
126
+				throw new Forbidden('No permission to update tag '.$this->tag->getId());
127 127
 			}
128 128
 
129 129
 			// only admin is able to change permissions, regular users can only rename
@@ -132,17 +132,17 @@  discard block
 block discarded – undo
132 132
 				if ($userVisible !== $this->tag->isUserVisible()
133 133
 					|| $userAssignable !== $this->tag->isUserAssignable()
134 134
 				) {
135
-					throw new Forbidden('No permission to update permissions for tag ' . $this->tag->getId());
135
+					throw new Forbidden('No permission to update permissions for tag '.$this->tag->getId());
136 136
 				}
137 137
 			}
138 138
 
139 139
 			$this->tagManager->updateTag($this->tag->getId(), $name, $userVisible, $userAssignable);
140 140
 		} catch (TagNotFoundException $e) {
141
-			throw new NotFound('Tag with id ' . $this->tag->getId() . ' does not exist');
141
+			throw new NotFound('Tag with id '.$this->tag->getId().' does not exist');
142 142
 		} catch (TagAlreadyExistsException $e) {
143 143
 			throw new Conflict(
144
-				'Tag with the properties "' . $name . '", ' .
145
-				$userVisible . ', ' . $userAssignable . ' already exists'
144
+				'Tag with the properties "'.$name.'", '.
145
+				$userVisible.', '.$userAssignable.' already exists'
146 146
 			);
147 147
 		}
148 148
 	}
@@ -158,17 +158,17 @@  discard block
 block discarded – undo
158 158
 	public function delete() {
159 159
 		try {
160 160
 			if (!$this->isAdmin) {
161
-				throw new Forbidden('No permission to delete tag ' . $this->tag->getId());
161
+				throw new Forbidden('No permission to delete tag '.$this->tag->getId());
162 162
 			}
163 163
 
164 164
 			if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
165
-				throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found');
165
+				throw new NotFound('Tag with id '.$this->tag->getId().' not found');
166 166
 			}
167 167
 
168 168
 			$this->tagManager->deleteTags($this->tag->getId());
169 169
 		} catch (TagNotFoundException $e) {
170 170
 			// can happen if concurrent deletion occurred
171
-			throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found', 0, $e);
171
+			throw new NotFound('Tag with id '.$this->tag->getId().' not found', 0, $e);
172 172
 		}
173 173
 	}
174 174
 }
Please login to merge, or discard this patch.
apps/dav/lib/SystemTag/SystemTagsByIdCollection.php 2 patches
Indentation   +140 added lines, -140 removed lines patch added patch discarded remove patch
@@ -37,144 +37,144 @@
 block discarded – undo
37 37
 
38 38
 class SystemTagsByIdCollection implements ICollection {
39 39
 
40
-	/**
41
-	 * @var ISystemTagManager
42
-	 */
43
-	private $tagManager;
44
-
45
-	/**
46
-	 * @var IGroupManager
47
-	 */
48
-	private $groupManager;
49
-
50
-	/**
51
-	 * @var IUserSession
52
-	 */
53
-	private $userSession;
54
-
55
-	/**
56
-	 * SystemTagsByIdCollection constructor.
57
-	 *
58
-	 * @param ISystemTagManager $tagManager
59
-	 * @param IUserSession $userSession
60
-	 * @param IGroupManager $groupManager
61
-	 */
62
-	public function __construct(
63
-		ISystemTagManager $tagManager,
64
-		IUserSession $userSession,
65
-		IGroupManager $groupManager
66
-	) {
67
-		$this->tagManager = $tagManager;
68
-		$this->userSession = $userSession;
69
-		$this->groupManager = $groupManager;
70
-	}
71
-
72
-	/**
73
-	 * Returns whether the currently logged in user is an administrator
74
-	 *
75
-	 * @return bool true if the user is an admin
76
-	 */
77
-	private function isAdmin() {
78
-		$user = $this->userSession->getUser();
79
-		if ($user !== null) {
80
-			return $this->groupManager->isAdmin($user->getUID());
81
-		}
82
-		return false;
83
-	}
84
-
85
-	/**
86
-	 * @param string $name
87
-	 * @param resource|string $data Initial payload
88
-	 * @throws Forbidden
89
-	 */
90
-	function createFile($name, $data = null) {
91
-		throw new Forbidden('Cannot create tags by id');
92
-	}
93
-
94
-	/**
95
-	 * @param string $name
96
-	 */
97
-	function createDirectory($name) {
98
-		throw new Forbidden('Permission denied to create collections');
99
-	}
100
-
101
-	/**
102
-	 * @param string $name
103
-	 */
104
-	function getChild($name) {
105
-		try {
106
-			$tag = $this->tagManager->getTagsByIds([$name]);
107
-			$tag = current($tag);
108
-			if (!$this->tagManager->canUserSeeTag($tag, $this->userSession->getUser())) {
109
-				throw new NotFound('Tag with id ' . $name . ' not found');
110
-			}
111
-			return $this->makeNode($tag);
112
-		} catch (\InvalidArgumentException $e) {
113
-			throw new BadRequest('Invalid tag id', 0, $e);
114
-		} catch (TagNotFoundException $e) {
115
-			throw new NotFound('Tag with id ' . $name . ' not found', 0, $e);
116
-		}
117
-	}
118
-
119
-	function getChildren() {
120
-		$visibilityFilter = true;
121
-		if ($this->isAdmin()) {
122
-			$visibilityFilter = null;
123
-		}
124
-
125
-		$tags = $this->tagManager->getAllTags($visibilityFilter);
126
-		return array_map(function($tag) {
127
-			return $this->makeNode($tag);
128
-		}, $tags);
129
-	}
130
-
131
-	/**
132
-	 * @param string $name
133
-	 */
134
-	function childExists($name) {
135
-		try {
136
-			$tag = $this->tagManager->getTagsByIds([$name]);
137
-			$tag = current($tag);
138
-			if (!$this->tagManager->canUserSeeTag($tag, $this->userSession->getUser())) {
139
-				return false;
140
-			}
141
-			return true;
142
-		} catch (\InvalidArgumentException $e) {
143
-			throw new BadRequest('Invalid tag id', 0, $e);
144
-		} catch (TagNotFoundException $e) {
145
-			return false;
146
-		}
147
-	}
148
-
149
-	function delete() {
150
-		throw new Forbidden('Permission denied to delete this collection');
151
-	}
152
-
153
-	function getName() {
154
-		return 'systemtags';
155
-	}
156
-
157
-	function setName($name) {
158
-		throw new Forbidden('Permission denied to rename this collection');
159
-	}
160
-
161
-	/**
162
-	 * Returns the last modification time, as a unix timestamp
163
-	 *
164
-	 * @return int
165
-	 */
166
-	function getLastModified() {
167
-		return null;
168
-	}
169
-
170
-	/**
171
-	 * Create a sabre node for the given system tag
172
-	 *
173
-	 * @param ISystemTag $tag
174
-	 *
175
-	 * @return SystemTagNode
176
-	 */
177
-	private function makeNode(ISystemTag $tag) {
178
-		return new SystemTagNode($tag, $this->userSession->getUser(), $this->isAdmin(), $this->tagManager);
179
-	}
40
+    /**
41
+     * @var ISystemTagManager
42
+     */
43
+    private $tagManager;
44
+
45
+    /**
46
+     * @var IGroupManager
47
+     */
48
+    private $groupManager;
49
+
50
+    /**
51
+     * @var IUserSession
52
+     */
53
+    private $userSession;
54
+
55
+    /**
56
+     * SystemTagsByIdCollection constructor.
57
+     *
58
+     * @param ISystemTagManager $tagManager
59
+     * @param IUserSession $userSession
60
+     * @param IGroupManager $groupManager
61
+     */
62
+    public function __construct(
63
+        ISystemTagManager $tagManager,
64
+        IUserSession $userSession,
65
+        IGroupManager $groupManager
66
+    ) {
67
+        $this->tagManager = $tagManager;
68
+        $this->userSession = $userSession;
69
+        $this->groupManager = $groupManager;
70
+    }
71
+
72
+    /**
73
+     * Returns whether the currently logged in user is an administrator
74
+     *
75
+     * @return bool true if the user is an admin
76
+     */
77
+    private function isAdmin() {
78
+        $user = $this->userSession->getUser();
79
+        if ($user !== null) {
80
+            return $this->groupManager->isAdmin($user->getUID());
81
+        }
82
+        return false;
83
+    }
84
+
85
+    /**
86
+     * @param string $name
87
+     * @param resource|string $data Initial payload
88
+     * @throws Forbidden
89
+     */
90
+    function createFile($name, $data = null) {
91
+        throw new Forbidden('Cannot create tags by id');
92
+    }
93
+
94
+    /**
95
+     * @param string $name
96
+     */
97
+    function createDirectory($name) {
98
+        throw new Forbidden('Permission denied to create collections');
99
+    }
100
+
101
+    /**
102
+     * @param string $name
103
+     */
104
+    function getChild($name) {
105
+        try {
106
+            $tag = $this->tagManager->getTagsByIds([$name]);
107
+            $tag = current($tag);
108
+            if (!$this->tagManager->canUserSeeTag($tag, $this->userSession->getUser())) {
109
+                throw new NotFound('Tag with id ' . $name . ' not found');
110
+            }
111
+            return $this->makeNode($tag);
112
+        } catch (\InvalidArgumentException $e) {
113
+            throw new BadRequest('Invalid tag id', 0, $e);
114
+        } catch (TagNotFoundException $e) {
115
+            throw new NotFound('Tag with id ' . $name . ' not found', 0, $e);
116
+        }
117
+    }
118
+
119
+    function getChildren() {
120
+        $visibilityFilter = true;
121
+        if ($this->isAdmin()) {
122
+            $visibilityFilter = null;
123
+        }
124
+
125
+        $tags = $this->tagManager->getAllTags($visibilityFilter);
126
+        return array_map(function($tag) {
127
+            return $this->makeNode($tag);
128
+        }, $tags);
129
+    }
130
+
131
+    /**
132
+     * @param string $name
133
+     */
134
+    function childExists($name) {
135
+        try {
136
+            $tag = $this->tagManager->getTagsByIds([$name]);
137
+            $tag = current($tag);
138
+            if (!$this->tagManager->canUserSeeTag($tag, $this->userSession->getUser())) {
139
+                return false;
140
+            }
141
+            return true;
142
+        } catch (\InvalidArgumentException $e) {
143
+            throw new BadRequest('Invalid tag id', 0, $e);
144
+        } catch (TagNotFoundException $e) {
145
+            return false;
146
+        }
147
+    }
148
+
149
+    function delete() {
150
+        throw new Forbidden('Permission denied to delete this collection');
151
+    }
152
+
153
+    function getName() {
154
+        return 'systemtags';
155
+    }
156
+
157
+    function setName($name) {
158
+        throw new Forbidden('Permission denied to rename this collection');
159
+    }
160
+
161
+    /**
162
+     * Returns the last modification time, as a unix timestamp
163
+     *
164
+     * @return int
165
+     */
166
+    function getLastModified() {
167
+        return null;
168
+    }
169
+
170
+    /**
171
+     * Create a sabre node for the given system tag
172
+     *
173
+     * @param ISystemTag $tag
174
+     *
175
+     * @return SystemTagNode
176
+     */
177
+    private function makeNode(ISystemTag $tag) {
178
+        return new SystemTagNode($tag, $this->userSession->getUser(), $this->isAdmin(), $this->tagManager);
179
+    }
180 180
 }
Please login to merge, or discard this patch.
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -106,13 +106,13 @@
 block discarded – undo
106 106
 			$tag = $this->tagManager->getTagsByIds([$name]);
107 107
 			$tag = current($tag);
108 108
 			if (!$this->tagManager->canUserSeeTag($tag, $this->userSession->getUser())) {
109
-				throw new NotFound('Tag with id ' . $name . ' not found');
109
+				throw new NotFound('Tag with id '.$name.' not found');
110 110
 			}
111 111
 			return $this->makeNode($tag);
112 112
 		} catch (\InvalidArgumentException $e) {
113 113
 			throw new BadRequest('Invalid tag id', 0, $e);
114 114
 		} catch (TagNotFoundException $e) {
115
-			throw new NotFound('Tag with id ' . $name . ' not found', 0, $e);
115
+			throw new NotFound('Tag with id '.$name.' not found', 0, $e);
116 116
 		}
117 117
 	}
118 118
 
Please login to merge, or discard this patch.
apps/dav/lib/SystemTag/SystemTagsObjectTypeCollection.php 2 patches
Indentation   +132 added lines, -132 removed lines patch added patch discarded remove patch
@@ -39,136 +39,136 @@
 block discarded – undo
39 39
  */
40 40
 class SystemTagsObjectTypeCollection implements ICollection {
41 41
 
42
-	/**
43
-	 * @var string
44
-	 */
45
-	private $objectType;
46
-
47
-	/**
48
-	 * @var ISystemTagManager
49
-	 */
50
-	private $tagManager;
51
-
52
-	/**
53
-	 * @var ISystemTagObjectMapper
54
-	 */
55
-	private $tagMapper;
56
-
57
-	/**
58
-	 * @var IGroupManager
59
-	 */
60
-	private $groupManager;
61
-
62
-	/**
63
-	 * @var IUserSession
64
-	 */
65
-	private $userSession;
66
-
67
-	/**
68
-	 * @var \Closure
69
-	 **/
70
-	protected $childExistsFunction;
71
-
72
-	/**
73
-	 * Constructor
74
-	 *
75
-	 * @param string $objectType object type
76
-	 * @param ISystemTagManager $tagManager
77
-	 * @param ISystemTagObjectMapper $tagMapper
78
-	 * @param IUserSession $userSession
79
-	 * @param IGroupManager $groupManager
80
-	 * @param \Closure $childExistsFunction
81
-	 */
82
-	public function __construct(
83
-		$objectType, 
84
-		ISystemTagManager $tagManager,
85
-		ISystemTagObjectMapper $tagMapper,
86
-		IUserSession $userSession,
87
-		IGroupManager $groupManager,
88
-		\Closure $childExistsFunction
89
-	) {
90
-		$this->tagManager = $tagManager;
91
-		$this->tagMapper = $tagMapper;
92
-		$this->objectType = $objectType;
93
-		$this->userSession = $userSession;
94
-		$this->groupManager = $groupManager;
95
-		$this->childExistsFunction = $childExistsFunction;
96
-	}
97
-
98
-	/**
99
-	 * @param string $name
100
-	 * @param resource|string $data Initial payload
101
-	 * @return null|string
102
-	 * @throws Forbidden
103
-	 */
104
-	function createFile($name, $data = null) {
105
-		throw new Forbidden('Permission denied to create nodes');
106
-	}
107
-
108
-	/**
109
-	 * @param string $name
110
-	 * @throws Forbidden
111
-	 */
112
-	function createDirectory($name) {
113
-		throw new Forbidden('Permission denied to create collections');
114
-	}
115
-
116
-	/**
117
-	 * @param string $objectId
118
-	 * @return SystemTagsObjectMappingCollection
119
-	 * @throws NotFound
120
-	 */
121
-	function getChild($objectId) {
122
-		// make sure the object exists and is reachable
123
-		if(!$this->childExists($objectId)) {
124
-			throw new NotFound('Entity does not exist or is not available');
125
-		}
126
-		return new SystemTagsObjectMappingCollection(
127
-			$objectId,
128
-			$this->objectType,
129
-			$this->userSession->getUser(),
130
-			$this->tagManager,
131
-			$this->tagMapper
132
-		);
133
-	}
134
-
135
-	function getChildren() {
136
-		// do not list object ids
137
-		throw new MethodNotAllowed();
138
-	}
139
-
140
-	/**
141
-	 * Checks if a child-node with the specified name exists
142
-	 *
143
-	 * @param string $name
144
-	 * @return bool
145
-	 */
146
-	function childExists($name) {
147
-		return call_user_func($this->childExistsFunction, $name);
148
-	}
149
-
150
-	function delete() {
151
-		throw new Forbidden('Permission denied to delete this collection');
152
-	}
153
-
154
-	function getName() {
155
-		return $this->objectType;
156
-	}
157
-
158
-	/**
159
-	 * @param string $name
160
-	 * @throws Forbidden
161
-	 */
162
-	function setName($name) {
163
-		throw new Forbidden('Permission denied to rename this collection');
164
-	}
165
-
166
-	/**
167
-	 * Returns the last modification time, as a unix timestamp
168
-	 *
169
-	 * @return int
170
-	 */
171
-	function getLastModified() {
172
-		return null;
173
-	}
42
+    /**
43
+     * @var string
44
+     */
45
+    private $objectType;
46
+
47
+    /**
48
+     * @var ISystemTagManager
49
+     */
50
+    private $tagManager;
51
+
52
+    /**
53
+     * @var ISystemTagObjectMapper
54
+     */
55
+    private $tagMapper;
56
+
57
+    /**
58
+     * @var IGroupManager
59
+     */
60
+    private $groupManager;
61
+
62
+    /**
63
+     * @var IUserSession
64
+     */
65
+    private $userSession;
66
+
67
+    /**
68
+     * @var \Closure
69
+     **/
70
+    protected $childExistsFunction;
71
+
72
+    /**
73
+     * Constructor
74
+     *
75
+     * @param string $objectType object type
76
+     * @param ISystemTagManager $tagManager
77
+     * @param ISystemTagObjectMapper $tagMapper
78
+     * @param IUserSession $userSession
79
+     * @param IGroupManager $groupManager
80
+     * @param \Closure $childExistsFunction
81
+     */
82
+    public function __construct(
83
+        $objectType, 
84
+        ISystemTagManager $tagManager,
85
+        ISystemTagObjectMapper $tagMapper,
86
+        IUserSession $userSession,
87
+        IGroupManager $groupManager,
88
+        \Closure $childExistsFunction
89
+    ) {
90
+        $this->tagManager = $tagManager;
91
+        $this->tagMapper = $tagMapper;
92
+        $this->objectType = $objectType;
93
+        $this->userSession = $userSession;
94
+        $this->groupManager = $groupManager;
95
+        $this->childExistsFunction = $childExistsFunction;
96
+    }
97
+
98
+    /**
99
+     * @param string $name
100
+     * @param resource|string $data Initial payload
101
+     * @return null|string
102
+     * @throws Forbidden
103
+     */
104
+    function createFile($name, $data = null) {
105
+        throw new Forbidden('Permission denied to create nodes');
106
+    }
107
+
108
+    /**
109
+     * @param string $name
110
+     * @throws Forbidden
111
+     */
112
+    function createDirectory($name) {
113
+        throw new Forbidden('Permission denied to create collections');
114
+    }
115
+
116
+    /**
117
+     * @param string $objectId
118
+     * @return SystemTagsObjectMappingCollection
119
+     * @throws NotFound
120
+     */
121
+    function getChild($objectId) {
122
+        // make sure the object exists and is reachable
123
+        if(!$this->childExists($objectId)) {
124
+            throw new NotFound('Entity does not exist or is not available');
125
+        }
126
+        return new SystemTagsObjectMappingCollection(
127
+            $objectId,
128
+            $this->objectType,
129
+            $this->userSession->getUser(),
130
+            $this->tagManager,
131
+            $this->tagMapper
132
+        );
133
+    }
134
+
135
+    function getChildren() {
136
+        // do not list object ids
137
+        throw new MethodNotAllowed();
138
+    }
139
+
140
+    /**
141
+     * Checks if a child-node with the specified name exists
142
+     *
143
+     * @param string $name
144
+     * @return bool
145
+     */
146
+    function childExists($name) {
147
+        return call_user_func($this->childExistsFunction, $name);
148
+    }
149
+
150
+    function delete() {
151
+        throw new Forbidden('Permission denied to delete this collection');
152
+    }
153
+
154
+    function getName() {
155
+        return $this->objectType;
156
+    }
157
+
158
+    /**
159
+     * @param string $name
160
+     * @throws Forbidden
161
+     */
162
+    function setName($name) {
163
+        throw new Forbidden('Permission denied to rename this collection');
164
+    }
165
+
166
+    /**
167
+     * Returns the last modification time, as a unix timestamp
168
+     *
169
+     * @return int
170
+     */
171
+    function getLastModified() {
172
+        return null;
173
+    }
174 174
 }
Please login to merge, or discard this patch.
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -120,7 +120,7 @@
 block discarded – undo
120 120
 	 */
121 121
 	function getChild($objectId) {
122 122
 		// make sure the object exists and is reachable
123
-		if(!$this->childExists($objectId)) {
123
+		if (!$this->childExists($objectId)) {
124 124
 			throw new NotFound('Entity does not exist or is not available');
125 125
 		}
126 126
 		return new SystemTagsObjectMappingCollection(
Please login to merge, or discard this patch.
apps/dav/lib/SystemTag/SystemTagMappingNode.php 2 patches
Indentation   +130 added lines, -130 removed lines patch added patch discarded remove patch
@@ -37,134 +37,134 @@
 block discarded – undo
37 37
  * Mapping node for system tag to object id
38 38
  */
39 39
 class SystemTagMappingNode implements \Sabre\DAV\INode {
40
-	/**
41
-	 * @var ISystemTag
42
-	 */
43
-	protected $tag;
44
-
45
-	/**
46
-	 * @var string
47
-	 */
48
-	private $objectId;
49
-
50
-	/**
51
-	 * @var string
52
-	 */
53
-	private $objectType;
54
-
55
-	/**
56
-	 * User
57
-	 *
58
-	 * @var IUser
59
-	 */
60
-	protected $user;
61
-
62
-	/**
63
-	 * @var ISystemTagManager
64
-	 */
65
-	protected $tagManager;
66
-
67
-	/**
68
-	 * @var ISystemTagObjectMapper
69
-	 */
70
-	private $tagMapper;
71
-
72
-	/**
73
-	 * Sets up the node, expects a full path name
74
-	 *
75
-	 * @param ISystemTag $tag system tag
76
-	 * @param string $objectId
77
-	 * @param string $objectType
78
-	 * @param IUser $user user
79
-	 * @param ISystemTagManager $tagManager
80
-	 * @param ISystemTagObjectMapper $tagMapper
81
-	 */
82
-	public function __construct(
83
-		ISystemTag $tag,
84
-		$objectId,
85
-		$objectType,
86
-		IUser $user,
87
-		ISystemTagManager $tagManager,
88
-		ISystemTagObjectMapper $tagMapper
89
-	) {
90
-		$this->tag = $tag;
91
-		$this->objectId = $objectId;
92
-		$this->objectType = $objectType;
93
-		$this->user = $user;
94
-		$this->tagManager = $tagManager;
95
-		$this->tagMapper = $tagMapper;
96
-	}
97
-
98
-	/**
99
-	 * Returns the object id of the relationship
100
-	 *
101
-	 * @return string object id
102
-	 */
103
-	public function getObjectId() {
104
-		return $this->objectId;
105
-	}
106
-
107
-	/**
108
-	 * Returns the object type of the relationship
109
-	 *
110
-	 * @return string object type
111
-	 */
112
-	public function getObjectType() {
113
-		return $this->objectType;
114
-	}
115
-
116
-	/**
117
-	 * Returns the system tag represented by this node
118
-	 *
119
-	 * @return ISystemTag system tag
120
-	 */
121
-	public function getSystemTag() {
122
-		return $this->tag;
123
-	}
124
-
125
-	/**
126
-	 *  Returns the id of the tag
127
-	 *
128
-	 * @return string
129
-	 */
130
-	public function getName() {
131
-		return $this->tag->getId();
132
-	}
133
-
134
-	/**
135
-	 * Renames the node
136
-	 *
137
-	 * @param string $name The new name
138
-	 *
139
-	 * @throws MethodNotAllowed not allowed to rename node
140
-	 */
141
-	public function setName($name) {
142
-		throw new MethodNotAllowed();
143
-	}
144
-
145
-	/**
146
-	 * Returns null, not supported
147
-	 *
148
-	 */
149
-	public function getLastModified() {
150
-		return null;
151
-	}
152
-
153
-	/**
154
-	 * Delete tag to object association
155
-	 */
156
-	public function delete() {
157
-		try {
158
-			if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
159
-				throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found');
160
-			}
161
-			if (!$this->tagManager->canUserAssignTag($this->tag, $this->user)) {
162
-				throw new Forbidden('No permission to unassign tag ' . $this->tag->getId());
163
-			}
164
-			$this->tagMapper->unassignTags($this->objectId, $this->objectType, $this->tag->getId());
165
-		} catch (TagNotFoundException $e) {
166
-			// can happen if concurrent deletion occurred
167
-			throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found', 0, $e);
168
-		}
169
-	}
40
+    /**
41
+     * @var ISystemTag
42
+     */
43
+    protected $tag;
44
+
45
+    /**
46
+     * @var string
47
+     */
48
+    private $objectId;
49
+
50
+    /**
51
+     * @var string
52
+     */
53
+    private $objectType;
54
+
55
+    /**
56
+     * User
57
+     *
58
+     * @var IUser
59
+     */
60
+    protected $user;
61
+
62
+    /**
63
+     * @var ISystemTagManager
64
+     */
65
+    protected $tagManager;
66
+
67
+    /**
68
+     * @var ISystemTagObjectMapper
69
+     */
70
+    private $tagMapper;
71
+
72
+    /**
73
+     * Sets up the node, expects a full path name
74
+     *
75
+     * @param ISystemTag $tag system tag
76
+     * @param string $objectId
77
+     * @param string $objectType
78
+     * @param IUser $user user
79
+     * @param ISystemTagManager $tagManager
80
+     * @param ISystemTagObjectMapper $tagMapper
81
+     */
82
+    public function __construct(
83
+        ISystemTag $tag,
84
+        $objectId,
85
+        $objectType,
86
+        IUser $user,
87
+        ISystemTagManager $tagManager,
88
+        ISystemTagObjectMapper $tagMapper
89
+    ) {
90
+        $this->tag = $tag;
91
+        $this->objectId = $objectId;
92
+        $this->objectType = $objectType;
93
+        $this->user = $user;
94
+        $this->tagManager = $tagManager;
95
+        $this->tagMapper = $tagMapper;
96
+    }
97
+
98
+    /**
99
+     * Returns the object id of the relationship
100
+     *
101
+     * @return string object id
102
+     */
103
+    public function getObjectId() {
104
+        return $this->objectId;
105
+    }
106
+
107
+    /**
108
+     * Returns the object type of the relationship
109
+     *
110
+     * @return string object type
111
+     */
112
+    public function getObjectType() {
113
+        return $this->objectType;
114
+    }
115
+
116
+    /**
117
+     * Returns the system tag represented by this node
118
+     *
119
+     * @return ISystemTag system tag
120
+     */
121
+    public function getSystemTag() {
122
+        return $this->tag;
123
+    }
124
+
125
+    /**
126
+     *  Returns the id of the tag
127
+     *
128
+     * @return string
129
+     */
130
+    public function getName() {
131
+        return $this->tag->getId();
132
+    }
133
+
134
+    /**
135
+     * Renames the node
136
+     *
137
+     * @param string $name The new name
138
+     *
139
+     * @throws MethodNotAllowed not allowed to rename node
140
+     */
141
+    public function setName($name) {
142
+        throw new MethodNotAllowed();
143
+    }
144
+
145
+    /**
146
+     * Returns null, not supported
147
+     *
148
+     */
149
+    public function getLastModified() {
150
+        return null;
151
+    }
152
+
153
+    /**
154
+     * Delete tag to object association
155
+     */
156
+    public function delete() {
157
+        try {
158
+            if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
159
+                throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found');
160
+            }
161
+            if (!$this->tagManager->canUserAssignTag($this->tag, $this->user)) {
162
+                throw new Forbidden('No permission to unassign tag ' . $this->tag->getId());
163
+            }
164
+            $this->tagMapper->unassignTags($this->objectId, $this->objectType, $this->tag->getId());
165
+        } catch (TagNotFoundException $e) {
166
+            // can happen if concurrent deletion occurred
167
+            throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found', 0, $e);
168
+        }
169
+    }
170 170
 }
Please login to merge, or discard this patch.
Spacing   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -156,15 +156,15 @@
 block discarded – undo
156 156
 	public function delete() {
157 157
 		try {
158 158
 			if (!$this->tagManager->canUserSeeTag($this->tag, $this->user)) {
159
-				throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found');
159
+				throw new NotFound('Tag with id '.$this->tag->getId().' not found');
160 160
 			}
161 161
 			if (!$this->tagManager->canUserAssignTag($this->tag, $this->user)) {
162
-				throw new Forbidden('No permission to unassign tag ' . $this->tag->getId());
162
+				throw new Forbidden('No permission to unassign tag '.$this->tag->getId());
163 163
 			}
164 164
 			$this->tagMapper->unassignTags($this->objectId, $this->objectType, $this->tag->getId());
165 165
 		} catch (TagNotFoundException $e) {
166 166
 			// can happen if concurrent deletion occurred
167
-			throw new NotFound('Tag with id ' . $this->tag->getId() . ' not found', 0, $e);
167
+			throw new NotFound('Tag with id '.$this->tag->getId().' not found', 0, $e);
168 168
 		}
169 169
 	}
170 170
 }
Please login to merge, or discard this patch.
apps/dav/lib/SystemTag/SystemTagPlugin.php 2 patches
Spacing   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -135,7 +135,7 @@  discard block
 block discarded – undo
135 135
 			if ($node instanceof SystemTagsObjectMappingCollection) {
136 136
 				// also add to collection
137 137
 				$node->createFile($tag->getId());
138
-				$url = $request->getBaseUrl() . 'systemtags/';
138
+				$url = $request->getBaseUrl().'systemtags/';
139 139
 			} else {
140 140
 				$url = $request->getUrl();
141 141
 			}
@@ -144,7 +144,7 @@  discard block
 block discarded – undo
144 144
 				$url .= '/';
145 145
 			}
146 146
 
147
-			$response->setHeader('Content-Location', $url . $tag->getId());
147
+			$response->setHeader('Content-Location', $url.$tag->getId());
148 148
 
149 149
 			// created
150 150
 			$response->setStatus(201);
@@ -179,11 +179,11 @@  discard block
 block discarded – undo
179 179
 		$userAssignable = true;
180 180
 
181 181
 		if (isset($data['userVisible'])) {
182
-			$userVisible = (bool)$data['userVisible'];
182
+			$userVisible = (bool) $data['userVisible'];
183 183
 		}
184 184
 
185 185
 		if (isset($data['userAssignable'])) {
186
-			$userAssignable = (bool)$data['userAssignable'];
186
+			$userAssignable = (bool) $data['userAssignable'];
187 187
 		}
188 188
 
189 189
 		$groups = [];
@@ -194,8 +194,8 @@  discard block
 block discarded – undo
194 194
 			}
195 195
 		}
196 196
 
197
-		if($userVisible === false || $userAssignable === false || !empty($groups)) {
198
-			if(!$this->userSession->isLoggedIn() || !$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
197
+		if ($userVisible === false || $userAssignable === false || !empty($groups)) {
198
+			if (!$this->userSession->isLoggedIn() || !$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
199 199
 				throw new BadRequest('Not sufficient permissions');
200 200
 			}
201 201
 		}
Please login to merge, or discard this patch.
Indentation   +276 added lines, -276 removed lines patch added patch discarded remove patch
@@ -46,280 +46,280 @@
 block discarded – undo
46 46
  */
47 47
 class SystemTagPlugin extends \Sabre\DAV\ServerPlugin {
48 48
 
49
-	// namespace
50
-	const NS_OWNCLOUD = 'http://owncloud.org/ns';
51
-	const ID_PROPERTYNAME = '{http://owncloud.org/ns}id';
52
-	const DISPLAYNAME_PROPERTYNAME = '{http://owncloud.org/ns}display-name';
53
-	const USERVISIBLE_PROPERTYNAME = '{http://owncloud.org/ns}user-visible';
54
-	const USERASSIGNABLE_PROPERTYNAME = '{http://owncloud.org/ns}user-assignable';
55
-	const GROUPS_PROPERTYNAME = '{http://owncloud.org/ns}groups';
56
-	const CANASSIGN_PROPERTYNAME = '{http://owncloud.org/ns}can-assign';
57
-
58
-	/**
59
-	 * @var \Sabre\DAV\Server $server
60
-	 */
61
-	private $server;
62
-
63
-	/**
64
-	 * @var ISystemTagManager
65
-	 */
66
-	protected $tagManager;
67
-
68
-	/**
69
-	 * @var IUserSession
70
-	 */
71
-	protected $userSession;
72
-
73
-	/**
74
-	 * @var IGroupManager
75
-	 */
76
-	protected $groupManager;
77
-
78
-	/**
79
-	 * @param ISystemTagManager $tagManager tag manager
80
-	 * @param IGroupManager $groupManager
81
-	 * @param IUserSession $userSession
82
-	 */
83
-	public function __construct(ISystemTagManager $tagManager,
84
-								IGroupManager $groupManager,
85
-								IUserSession $userSession) {
86
-		$this->tagManager = $tagManager;
87
-		$this->userSession = $userSession;
88
-		$this->groupManager = $groupManager;
89
-	}
90
-
91
-	/**
92
-	 * This initializes the plugin.
93
-	 *
94
-	 * This function is called by \Sabre\DAV\Server, after
95
-	 * addPlugin is called.
96
-	 *
97
-	 * This method should set up the required event subscriptions.
98
-	 *
99
-	 * @param \Sabre\DAV\Server $server
100
-	 * @return void
101
-	 */
102
-	public function initialize(\Sabre\DAV\Server $server) {
103
-
104
-		$server->xml->namespaceMap[self::NS_OWNCLOUD] = 'oc';
105
-
106
-		$server->protectedProperties[] = self::ID_PROPERTYNAME;
107
-
108
-		$server->on('propFind', array($this, 'handleGetProperties'));
109
-		$server->on('propPatch', array($this, 'handleUpdateProperties'));
110
-		$server->on('method:POST', [$this, 'httpPost']);
111
-
112
-		$this->server = $server;
113
-	}
114
-
115
-	/**
116
-	 * POST operation on system tag collections
117
-	 *
118
-	 * @param RequestInterface $request request object
119
-	 * @param ResponseInterface $response response object
120
-	 * @return null|false
121
-	 */
122
-	public function httpPost(RequestInterface $request, ResponseInterface $response) {
123
-		$path = $request->getPath();
124
-
125
-		// Making sure the node exists
126
-		$node = $this->server->tree->getNodeForPath($path);
127
-		if ($node instanceof SystemTagsByIdCollection || $node instanceof SystemTagsObjectMappingCollection) {
128
-			$data = $request->getBodyAsString();
129
-
130
-			$tag = $this->createTag($data, $request->getHeader('Content-Type'));
131
-
132
-			if ($node instanceof SystemTagsObjectMappingCollection) {
133
-				// also add to collection
134
-				$node->createFile($tag->getId());
135
-				$url = $request->getBaseUrl() . 'systemtags/';
136
-			} else {
137
-				$url = $request->getUrl();
138
-			}
139
-
140
-			if ($url[strlen($url) - 1] !== '/') {
141
-				$url .= '/';
142
-			}
143
-
144
-			$response->setHeader('Content-Location', $url . $tag->getId());
145
-
146
-			// created
147
-			$response->setStatus(201);
148
-			return false;
149
-		}
150
-	}
151
-
152
-	/**
153
-	 * Creates a new tag
154
-	 *
155
-	 * @param string $data JSON encoded string containing the properties of the tag to create
156
-	 * @param string $contentType content type of the data
157
-	 * @return ISystemTag newly created system tag
158
-	 *
159
-	 * @throws BadRequest if a field was missing
160
-	 * @throws Conflict if a tag with the same properties already exists
161
-	 * @throws UnsupportedMediaType if the content type is not supported
162
-	 */
163
-	private function createTag($data, $contentType = 'application/json') {
164
-		if (explode(';', $contentType)[0] === 'application/json') {
165
-			$data = json_decode($data, true);
166
-		} else {
167
-			throw new UnsupportedMediaType();
168
-		}
169
-
170
-		if (!isset($data['name'])) {
171
-			throw new BadRequest('Missing "name" attribute');
172
-		}
173
-
174
-		$tagName = $data['name'];
175
-		$userVisible = true;
176
-		$userAssignable = true;
177
-
178
-		if (isset($data['userVisible'])) {
179
-			$userVisible = (bool)$data['userVisible'];
180
-		}
181
-
182
-		if (isset($data['userAssignable'])) {
183
-			$userAssignable = (bool)$data['userAssignable'];
184
-		}
185
-
186
-		$groups = [];
187
-		if (isset($data['groups'])) {
188
-			$groups = $data['groups'];
189
-			if (is_string($groups)) {
190
-				$groups = explode('|', $groups);
191
-			}
192
-		}
193
-
194
-		if($userVisible === false || $userAssignable === false || !empty($groups)) {
195
-			if(!$this->userSession->isLoggedIn() || !$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
196
-				throw new BadRequest('Not sufficient permissions');
197
-			}
198
-		}
199
-
200
-		try {
201
-			$tag = $this->tagManager->createTag($tagName, $userVisible, $userAssignable);
202
-			if (!empty($groups)) {
203
-				$this->tagManager->setTagGroups($tag, $groups);
204
-			}
205
-			return $tag;
206
-		} catch (TagAlreadyExistsException $e) {
207
-			throw new Conflict('Tag already exists', 0, $e);
208
-		}
209
-	}
210
-
211
-
212
-	/**
213
-	 * Retrieves system tag properties
214
-	 *
215
-	 * @param PropFind $propFind
216
-	 * @param \Sabre\DAV\INode $node
217
-	 */
218
-	public function handleGetProperties(
219
-		PropFind $propFind,
220
-		\Sabre\DAV\INode $node
221
-	) {
222
-		if (!($node instanceof SystemTagNode) && !($node instanceof SystemTagMappingNode)) {
223
-			return;
224
-		}
225
-
226
-		$propFind->handle(self::ID_PROPERTYNAME, function() use ($node) {
227
-			return $node->getSystemTag()->getId();
228
-		});
229
-
230
-		$propFind->handle(self::DISPLAYNAME_PROPERTYNAME, function() use ($node) {
231
-			return $node->getSystemTag()->getName();
232
-		});
233
-
234
-		$propFind->handle(self::USERVISIBLE_PROPERTYNAME, function() use ($node) {
235
-			return $node->getSystemTag()->isUserVisible() ? 'true' : 'false';
236
-		});
237
-
238
-		$propFind->handle(self::USERASSIGNABLE_PROPERTYNAME, function() use ($node) {
239
-			// this is the tag's inherent property "is user assignable"
240
-			return $node->getSystemTag()->isUserAssignable() ? 'true' : 'false';
241
-		});
242
-
243
-		$propFind->handle(self::CANASSIGN_PROPERTYNAME, function() use ($node) {
244
-			// this is the effective permission for the current user
245
-			return $this->tagManager->canUserAssignTag($node->getSystemTag(), $this->userSession->getUser()) ? 'true' : 'false';
246
-		});
247
-
248
-		$propFind->handle(self::GROUPS_PROPERTYNAME, function() use ($node) {
249
-			if (!$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
250
-				// property only available for admins
251
-				throw new Forbidden();
252
-			}
253
-			$groups = [];
254
-			// no need to retrieve groups for namespaces that don't qualify
255
-			if ($node->getSystemTag()->isUserVisible() && !$node->getSystemTag()->isUserAssignable()) {
256
-				$groups = $this->tagManager->getTagGroups($node->getSystemTag());
257
-			}
258
-			return implode('|', $groups);
259
-		});
260
-	}
261
-
262
-	/**
263
-	 * Updates tag attributes
264
-	 *
265
-	 * @param string $path
266
-	 * @param PropPatch $propPatch
267
-	 *
268
-	 * @return void
269
-	 */
270
-	public function handleUpdateProperties($path, PropPatch $propPatch) {
271
-		$node = $this->server->tree->getNodeForPath($path);
272
-		if (!($node instanceof SystemTagNode)) {
273
-			return;
274
-		}
275
-
276
-		$propPatch->handle([
277
-			self::DISPLAYNAME_PROPERTYNAME,
278
-			self::USERVISIBLE_PROPERTYNAME,
279
-			self::USERASSIGNABLE_PROPERTYNAME,
280
-			self::GROUPS_PROPERTYNAME,
281
-		], function($props) use ($node) {
282
-			$tag = $node->getSystemTag();
283
-			$name = $tag->getName();
284
-			$userVisible = $tag->isUserVisible();
285
-			$userAssignable = $tag->isUserAssignable();
286
-
287
-			$updateTag = false;
288
-
289
-			if (isset($props[self::DISPLAYNAME_PROPERTYNAME])) {
290
-				$name = $props[self::DISPLAYNAME_PROPERTYNAME];
291
-				$updateTag = true;
292
-			}
293
-
294
-			if (isset($props[self::USERVISIBLE_PROPERTYNAME])) {
295
-				$propValue = $props[self::USERVISIBLE_PROPERTYNAME];
296
-				$userVisible = ($propValue !== 'false' && $propValue !== '0');
297
-				$updateTag = true;
298
-			}
299
-
300
-			if (isset($props[self::USERASSIGNABLE_PROPERTYNAME])) {
301
-				$propValue = $props[self::USERASSIGNABLE_PROPERTYNAME];
302
-				$userAssignable = ($propValue !== 'false' && $propValue !== '0');
303
-				$updateTag = true;
304
-			}
305
-
306
-			if (isset($props[self::GROUPS_PROPERTYNAME])) {
307
-				if (!$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
308
-					// property only available for admins
309
-					throw new Forbidden();
310
-				}
311
-
312
-				$propValue = $props[self::GROUPS_PROPERTYNAME];
313
-				$groupIds = explode('|', $propValue);
314
-				$this->tagManager->setTagGroups($tag, $groupIds);
315
-			}
316
-
317
-			if ($updateTag) {
318
-				$node->update($name, $userVisible, $userAssignable);
319
-			}
320
-
321
-			return true;
322
-		});
323
-
324
-	}
49
+    // namespace
50
+    const NS_OWNCLOUD = 'http://owncloud.org/ns';
51
+    const ID_PROPERTYNAME = '{http://owncloud.org/ns}id';
52
+    const DISPLAYNAME_PROPERTYNAME = '{http://owncloud.org/ns}display-name';
53
+    const USERVISIBLE_PROPERTYNAME = '{http://owncloud.org/ns}user-visible';
54
+    const USERASSIGNABLE_PROPERTYNAME = '{http://owncloud.org/ns}user-assignable';
55
+    const GROUPS_PROPERTYNAME = '{http://owncloud.org/ns}groups';
56
+    const CANASSIGN_PROPERTYNAME = '{http://owncloud.org/ns}can-assign';
57
+
58
+    /**
59
+     * @var \Sabre\DAV\Server $server
60
+     */
61
+    private $server;
62
+
63
+    /**
64
+     * @var ISystemTagManager
65
+     */
66
+    protected $tagManager;
67
+
68
+    /**
69
+     * @var IUserSession
70
+     */
71
+    protected $userSession;
72
+
73
+    /**
74
+     * @var IGroupManager
75
+     */
76
+    protected $groupManager;
77
+
78
+    /**
79
+     * @param ISystemTagManager $tagManager tag manager
80
+     * @param IGroupManager $groupManager
81
+     * @param IUserSession $userSession
82
+     */
83
+    public function __construct(ISystemTagManager $tagManager,
84
+                                IGroupManager $groupManager,
85
+                                IUserSession $userSession) {
86
+        $this->tagManager = $tagManager;
87
+        $this->userSession = $userSession;
88
+        $this->groupManager = $groupManager;
89
+    }
90
+
91
+    /**
92
+     * This initializes the plugin.
93
+     *
94
+     * This function is called by \Sabre\DAV\Server, after
95
+     * addPlugin is called.
96
+     *
97
+     * This method should set up the required event subscriptions.
98
+     *
99
+     * @param \Sabre\DAV\Server $server
100
+     * @return void
101
+     */
102
+    public function initialize(\Sabre\DAV\Server $server) {
103
+
104
+        $server->xml->namespaceMap[self::NS_OWNCLOUD] = 'oc';
105
+
106
+        $server->protectedProperties[] = self::ID_PROPERTYNAME;
107
+
108
+        $server->on('propFind', array($this, 'handleGetProperties'));
109
+        $server->on('propPatch', array($this, 'handleUpdateProperties'));
110
+        $server->on('method:POST', [$this, 'httpPost']);
111
+
112
+        $this->server = $server;
113
+    }
114
+
115
+    /**
116
+     * POST operation on system tag collections
117
+     *
118
+     * @param RequestInterface $request request object
119
+     * @param ResponseInterface $response response object
120
+     * @return null|false
121
+     */
122
+    public function httpPost(RequestInterface $request, ResponseInterface $response) {
123
+        $path = $request->getPath();
124
+
125
+        // Making sure the node exists
126
+        $node = $this->server->tree->getNodeForPath($path);
127
+        if ($node instanceof SystemTagsByIdCollection || $node instanceof SystemTagsObjectMappingCollection) {
128
+            $data = $request->getBodyAsString();
129
+
130
+            $tag = $this->createTag($data, $request->getHeader('Content-Type'));
131
+
132
+            if ($node instanceof SystemTagsObjectMappingCollection) {
133
+                // also add to collection
134
+                $node->createFile($tag->getId());
135
+                $url = $request->getBaseUrl() . 'systemtags/';
136
+            } else {
137
+                $url = $request->getUrl();
138
+            }
139
+
140
+            if ($url[strlen($url) - 1] !== '/') {
141
+                $url .= '/';
142
+            }
143
+
144
+            $response->setHeader('Content-Location', $url . $tag->getId());
145
+
146
+            // created
147
+            $response->setStatus(201);
148
+            return false;
149
+        }
150
+    }
151
+
152
+    /**
153
+     * Creates a new tag
154
+     *
155
+     * @param string $data JSON encoded string containing the properties of the tag to create
156
+     * @param string $contentType content type of the data
157
+     * @return ISystemTag newly created system tag
158
+     *
159
+     * @throws BadRequest if a field was missing
160
+     * @throws Conflict if a tag with the same properties already exists
161
+     * @throws UnsupportedMediaType if the content type is not supported
162
+     */
163
+    private function createTag($data, $contentType = 'application/json') {
164
+        if (explode(';', $contentType)[0] === 'application/json') {
165
+            $data = json_decode($data, true);
166
+        } else {
167
+            throw new UnsupportedMediaType();
168
+        }
169
+
170
+        if (!isset($data['name'])) {
171
+            throw new BadRequest('Missing "name" attribute');
172
+        }
173
+
174
+        $tagName = $data['name'];
175
+        $userVisible = true;
176
+        $userAssignable = true;
177
+
178
+        if (isset($data['userVisible'])) {
179
+            $userVisible = (bool)$data['userVisible'];
180
+        }
181
+
182
+        if (isset($data['userAssignable'])) {
183
+            $userAssignable = (bool)$data['userAssignable'];
184
+        }
185
+
186
+        $groups = [];
187
+        if (isset($data['groups'])) {
188
+            $groups = $data['groups'];
189
+            if (is_string($groups)) {
190
+                $groups = explode('|', $groups);
191
+            }
192
+        }
193
+
194
+        if($userVisible === false || $userAssignable === false || !empty($groups)) {
195
+            if(!$this->userSession->isLoggedIn() || !$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
196
+                throw new BadRequest('Not sufficient permissions');
197
+            }
198
+        }
199
+
200
+        try {
201
+            $tag = $this->tagManager->createTag($tagName, $userVisible, $userAssignable);
202
+            if (!empty($groups)) {
203
+                $this->tagManager->setTagGroups($tag, $groups);
204
+            }
205
+            return $tag;
206
+        } catch (TagAlreadyExistsException $e) {
207
+            throw new Conflict('Tag already exists', 0, $e);
208
+        }
209
+    }
210
+
211
+
212
+    /**
213
+     * Retrieves system tag properties
214
+     *
215
+     * @param PropFind $propFind
216
+     * @param \Sabre\DAV\INode $node
217
+     */
218
+    public function handleGetProperties(
219
+        PropFind $propFind,
220
+        \Sabre\DAV\INode $node
221
+    ) {
222
+        if (!($node instanceof SystemTagNode) && !($node instanceof SystemTagMappingNode)) {
223
+            return;
224
+        }
225
+
226
+        $propFind->handle(self::ID_PROPERTYNAME, function() use ($node) {
227
+            return $node->getSystemTag()->getId();
228
+        });
229
+
230
+        $propFind->handle(self::DISPLAYNAME_PROPERTYNAME, function() use ($node) {
231
+            return $node->getSystemTag()->getName();
232
+        });
233
+
234
+        $propFind->handle(self::USERVISIBLE_PROPERTYNAME, function() use ($node) {
235
+            return $node->getSystemTag()->isUserVisible() ? 'true' : 'false';
236
+        });
237
+
238
+        $propFind->handle(self::USERASSIGNABLE_PROPERTYNAME, function() use ($node) {
239
+            // this is the tag's inherent property "is user assignable"
240
+            return $node->getSystemTag()->isUserAssignable() ? 'true' : 'false';
241
+        });
242
+
243
+        $propFind->handle(self::CANASSIGN_PROPERTYNAME, function() use ($node) {
244
+            // this is the effective permission for the current user
245
+            return $this->tagManager->canUserAssignTag($node->getSystemTag(), $this->userSession->getUser()) ? 'true' : 'false';
246
+        });
247
+
248
+        $propFind->handle(self::GROUPS_PROPERTYNAME, function() use ($node) {
249
+            if (!$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
250
+                // property only available for admins
251
+                throw new Forbidden();
252
+            }
253
+            $groups = [];
254
+            // no need to retrieve groups for namespaces that don't qualify
255
+            if ($node->getSystemTag()->isUserVisible() && !$node->getSystemTag()->isUserAssignable()) {
256
+                $groups = $this->tagManager->getTagGroups($node->getSystemTag());
257
+            }
258
+            return implode('|', $groups);
259
+        });
260
+    }
261
+
262
+    /**
263
+     * Updates tag attributes
264
+     *
265
+     * @param string $path
266
+     * @param PropPatch $propPatch
267
+     *
268
+     * @return void
269
+     */
270
+    public function handleUpdateProperties($path, PropPatch $propPatch) {
271
+        $node = $this->server->tree->getNodeForPath($path);
272
+        if (!($node instanceof SystemTagNode)) {
273
+            return;
274
+        }
275
+
276
+        $propPatch->handle([
277
+            self::DISPLAYNAME_PROPERTYNAME,
278
+            self::USERVISIBLE_PROPERTYNAME,
279
+            self::USERASSIGNABLE_PROPERTYNAME,
280
+            self::GROUPS_PROPERTYNAME,
281
+        ], function($props) use ($node) {
282
+            $tag = $node->getSystemTag();
283
+            $name = $tag->getName();
284
+            $userVisible = $tag->isUserVisible();
285
+            $userAssignable = $tag->isUserAssignable();
286
+
287
+            $updateTag = false;
288
+
289
+            if (isset($props[self::DISPLAYNAME_PROPERTYNAME])) {
290
+                $name = $props[self::DISPLAYNAME_PROPERTYNAME];
291
+                $updateTag = true;
292
+            }
293
+
294
+            if (isset($props[self::USERVISIBLE_PROPERTYNAME])) {
295
+                $propValue = $props[self::USERVISIBLE_PROPERTYNAME];
296
+                $userVisible = ($propValue !== 'false' && $propValue !== '0');
297
+                $updateTag = true;
298
+            }
299
+
300
+            if (isset($props[self::USERASSIGNABLE_PROPERTYNAME])) {
301
+                $propValue = $props[self::USERASSIGNABLE_PROPERTYNAME];
302
+                $userAssignable = ($propValue !== 'false' && $propValue !== '0');
303
+                $updateTag = true;
304
+            }
305
+
306
+            if (isset($props[self::GROUPS_PROPERTYNAME])) {
307
+                if (!$this->groupManager->isAdmin($this->userSession->getUser()->getUID())) {
308
+                    // property only available for admins
309
+                    throw new Forbidden();
310
+                }
311
+
312
+                $propValue = $props[self::GROUPS_PROPERTYNAME];
313
+                $groupIds = explode('|', $propValue);
314
+                $this->tagManager->setTagGroups($tag, $groupIds);
315
+            }
316
+
317
+            if ($updateTag) {
318
+                $node->update($name, $userVisible, $userAssignable);
319
+            }
320
+
321
+            return true;
322
+        });
323
+
324
+    }
325 325
 }
Please login to merge, or discard this patch.
apps/dav/lib/SystemTag/SystemTagsObjectMappingCollection.php 2 patches
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch
@@ -95,15 +95,15 @@  discard block
 block discarded – undo
95 95
 			$tags = $this->tagManager->getTagsByIds([$tagId]);
96 96
 			$tag = current($tags);
97 97
 			if (!$this->tagManager->canUserSeeTag($tag, $this->user)) {
98
-				throw new PreconditionFailed('Tag with id ' . $tagId . ' does not exist, cannot assign');
98
+				throw new PreconditionFailed('Tag with id '.$tagId.' does not exist, cannot assign');
99 99
 			}
100 100
 			if (!$this->tagManager->canUserAssignTag($tag, $this->user)) {
101
-				throw new Forbidden('No permission to assign tag ' . $tagId);
101
+				throw new Forbidden('No permission to assign tag '.$tagId);
102 102
 			}
103 103
 
104 104
 			$this->tagMapper->assignTags($this->objectId, $this->objectType, $tagId);
105 105
 		} catch (TagNotFoundException $e) {
106
-			throw new PreconditionFailed('Tag with id ' . $tagId . ' does not exist, cannot assign');
106
+			throw new PreconditionFailed('Tag with id '.$tagId.' does not exist, cannot assign');
107 107
 		}
108 108
 	}
109 109
 
@@ -120,11 +120,11 @@  discard block
 block discarded – undo
120 120
 					return $this->makeNode($tag);
121 121
 				}
122 122
 			}
123
-			throw new NotFound('Tag with id ' . $tagId . ' not present for object ' . $this->objectId);
123
+			throw new NotFound('Tag with id '.$tagId.' not present for object '.$this->objectId);
124 124
 		} catch (\InvalidArgumentException $e) {
125 125
 			throw new BadRequest('Invalid tag id', 0, $e);
126 126
 		} catch (TagNotFoundException $e) {
127
-			throw new NotFound('Tag with id ' . $tagId . ' not found', 0, $e);
127
+			throw new NotFound('Tag with id '.$tagId.' not found', 0, $e);
128 128
 		}
129 129
 	}
130 130
 
Please login to merge, or discard this patch.
Indentation   +165 added lines, -165 removed lines patch added patch discarded remove patch
@@ -39,169 +39,169 @@
 block discarded – undo
39 39
  */
40 40
 class SystemTagsObjectMappingCollection implements ICollection {
41 41
 
42
-	/**
43
-	 * @var string
44
-	 */
45
-	private $objectId;
46
-
47
-	/**
48
-	 * @var string
49
-	 */
50
-	private $objectType;
51
-
52
-	/**
53
-	 * @var ISystemTagManager
54
-	 */
55
-	private $tagManager;
56
-
57
-	/**
58
-	 * @var ISystemTagObjectMapper
59
-	 */
60
-	private $tagMapper;
61
-
62
-	/**
63
-	 * User
64
-	 *
65
-	 * @var IUser
66
-	 */
67
-	private $user;
68
-
69
-
70
-	/**
71
-	 * Constructor
72
-	 *
73
-	 * @param string $objectId object id
74
-	 * @param string $objectType object type
75
-	 * @param IUser $user user
76
-	 * @param ISystemTagManager $tagManager tag manager
77
-	 * @param ISystemTagObjectMapper $tagMapper tag mapper
78
-	 */
79
-	public function __construct(
80
-		$objectId,
81
-		$objectType,
82
-		IUser $user,
83
-		ISystemTagManager $tagManager,
84
-		ISystemTagObjectMapper $tagMapper
85
-	) {
86
-		$this->tagManager = $tagManager;
87
-		$this->tagMapper = $tagMapper;
88
-		$this->objectId = $objectId;
89
-		$this->objectType = $objectType;
90
-		$this->user = $user;
91
-	}
92
-
93
-	function createFile($tagId, $data = null) {
94
-		try {
95
-			$tags = $this->tagManager->getTagsByIds([$tagId]);
96
-			$tag = current($tags);
97
-			if (!$this->tagManager->canUserSeeTag($tag, $this->user)) {
98
-				throw new PreconditionFailed('Tag with id ' . $tagId . ' does not exist, cannot assign');
99
-			}
100
-			if (!$this->tagManager->canUserAssignTag($tag, $this->user)) {
101
-				throw new Forbidden('No permission to assign tag ' . $tagId);
102
-			}
103
-
104
-			$this->tagMapper->assignTags($this->objectId, $this->objectType, $tagId);
105
-		} catch (TagNotFoundException $e) {
106
-			throw new PreconditionFailed('Tag with id ' . $tagId . ' does not exist, cannot assign');
107
-		}
108
-	}
109
-
110
-	function createDirectory($name) {
111
-		throw new Forbidden('Permission denied to create collections');
112
-	}
113
-
114
-	function getChild($tagId) {
115
-		try {
116
-			if ($this->tagMapper->haveTag([$this->objectId], $this->objectType, $tagId, true)) {
117
-				$tag = $this->tagManager->getTagsByIds([$tagId]);
118
-				$tag = current($tag);
119
-				if ($this->tagManager->canUserSeeTag($tag, $this->user)) {
120
-					return $this->makeNode($tag);
121
-				}
122
-			}
123
-			throw new NotFound('Tag with id ' . $tagId . ' not present for object ' . $this->objectId);
124
-		} catch (\InvalidArgumentException $e) {
125
-			throw new BadRequest('Invalid tag id', 0, $e);
126
-		} catch (TagNotFoundException $e) {
127
-			throw new NotFound('Tag with id ' . $tagId . ' not found', 0, $e);
128
-		}
129
-	}
130
-
131
-	function getChildren() {
132
-		$tagIds = current($this->tagMapper->getTagIdsForObjects([$this->objectId], $this->objectType));
133
-		if (empty($tagIds)) {
134
-			return [];
135
-		}
136
-		$tags = $this->tagManager->getTagsByIds($tagIds);
137
-
138
-		// filter out non-visible tags
139
-		$tags = array_filter($tags, function($tag) {
140
-			return $this->tagManager->canUserSeeTag($tag, $this->user);
141
-		});
142
-
143
-		return array_values(array_map(function($tag) {
144
-			return $this->makeNode($tag);
145
-		}, $tags));
146
-	}
147
-
148
-	function childExists($tagId) {
149
-		try {
150
-			$result = $this->tagMapper->haveTag([$this->objectId], $this->objectType, $tagId, true);
151
-
152
-			if ($result) {
153
-				$tags = $this->tagManager->getTagsByIds([$tagId]);
154
-				$tag = current($tags);
155
-				if (!$this->tagManager->canUserSeeTag($tag, $this->user)) {
156
-					return false;
157
-				}
158
-			}
159
-
160
-			return $result;
161
-		} catch (\InvalidArgumentException $e) {
162
-			throw new BadRequest('Invalid tag id', 0, $e);
163
-		} catch (TagNotFoundException $e) {
164
-			return false;
165
-		}
166
-	}
167
-
168
-	function delete() {
169
-		throw new Forbidden('Permission denied to delete this collection');
170
-	}
171
-
172
-	function getName() {
173
-		return $this->objectId;
174
-	}
175
-
176
-	function setName($name) {
177
-		throw new Forbidden('Permission denied to rename this collection');
178
-	}
179
-
180
-	/**
181
-	 * Returns the last modification time, as a unix timestamp
182
-	 *
183
-	 * @return int
184
-	 */
185
-	function getLastModified() {
186
-		return null;
187
-	}
188
-
189
-	/**
190
-	 * Create a sabre node for the mapping of the 
191
-	 * given system tag to the collection's object
192
-	 *
193
-	 * @param ISystemTag $tag
194
-	 *
195
-	 * @return SystemTagMappingNode
196
-	 */
197
-	private function makeNode(ISystemTag $tag) {
198
-		return new SystemTagMappingNode(
199
-			$tag,
200
-			$this->objectId,
201
-			$this->objectType,
202
-			$this->user,
203
-			$this->tagManager,
204
-			$this->tagMapper
205
-		);
206
-	}
42
+    /**
43
+     * @var string
44
+     */
45
+    private $objectId;
46
+
47
+    /**
48
+     * @var string
49
+     */
50
+    private $objectType;
51
+
52
+    /**
53
+     * @var ISystemTagManager
54
+     */
55
+    private $tagManager;
56
+
57
+    /**
58
+     * @var ISystemTagObjectMapper
59
+     */
60
+    private $tagMapper;
61
+
62
+    /**
63
+     * User
64
+     *
65
+     * @var IUser
66
+     */
67
+    private $user;
68
+
69
+
70
+    /**
71
+     * Constructor
72
+     *
73
+     * @param string $objectId object id
74
+     * @param string $objectType object type
75
+     * @param IUser $user user
76
+     * @param ISystemTagManager $tagManager tag manager
77
+     * @param ISystemTagObjectMapper $tagMapper tag mapper
78
+     */
79
+    public function __construct(
80
+        $objectId,
81
+        $objectType,
82
+        IUser $user,
83
+        ISystemTagManager $tagManager,
84
+        ISystemTagObjectMapper $tagMapper
85
+    ) {
86
+        $this->tagManager = $tagManager;
87
+        $this->tagMapper = $tagMapper;
88
+        $this->objectId = $objectId;
89
+        $this->objectType = $objectType;
90
+        $this->user = $user;
91
+    }
92
+
93
+    function createFile($tagId, $data = null) {
94
+        try {
95
+            $tags = $this->tagManager->getTagsByIds([$tagId]);
96
+            $tag = current($tags);
97
+            if (!$this->tagManager->canUserSeeTag($tag, $this->user)) {
98
+                throw new PreconditionFailed('Tag with id ' . $tagId . ' does not exist, cannot assign');
99
+            }
100
+            if (!$this->tagManager->canUserAssignTag($tag, $this->user)) {
101
+                throw new Forbidden('No permission to assign tag ' . $tagId);
102
+            }
103
+
104
+            $this->tagMapper->assignTags($this->objectId, $this->objectType, $tagId);
105
+        } catch (TagNotFoundException $e) {
106
+            throw new PreconditionFailed('Tag with id ' . $tagId . ' does not exist, cannot assign');
107
+        }
108
+    }
109
+
110
+    function createDirectory($name) {
111
+        throw new Forbidden('Permission denied to create collections');
112
+    }
113
+
114
+    function getChild($tagId) {
115
+        try {
116
+            if ($this->tagMapper->haveTag([$this->objectId], $this->objectType, $tagId, true)) {
117
+                $tag = $this->tagManager->getTagsByIds([$tagId]);
118
+                $tag = current($tag);
119
+                if ($this->tagManager->canUserSeeTag($tag, $this->user)) {
120
+                    return $this->makeNode($tag);
121
+                }
122
+            }
123
+            throw new NotFound('Tag with id ' . $tagId . ' not present for object ' . $this->objectId);
124
+        } catch (\InvalidArgumentException $e) {
125
+            throw new BadRequest('Invalid tag id', 0, $e);
126
+        } catch (TagNotFoundException $e) {
127
+            throw new NotFound('Tag with id ' . $tagId . ' not found', 0, $e);
128
+        }
129
+    }
130
+
131
+    function getChildren() {
132
+        $tagIds = current($this->tagMapper->getTagIdsForObjects([$this->objectId], $this->objectType));
133
+        if (empty($tagIds)) {
134
+            return [];
135
+        }
136
+        $tags = $this->tagManager->getTagsByIds($tagIds);
137
+
138
+        // filter out non-visible tags
139
+        $tags = array_filter($tags, function($tag) {
140
+            return $this->tagManager->canUserSeeTag($tag, $this->user);
141
+        });
142
+
143
+        return array_values(array_map(function($tag) {
144
+            return $this->makeNode($tag);
145
+        }, $tags));
146
+    }
147
+
148
+    function childExists($tagId) {
149
+        try {
150
+            $result = $this->tagMapper->haveTag([$this->objectId], $this->objectType, $tagId, true);
151
+
152
+            if ($result) {
153
+                $tags = $this->tagManager->getTagsByIds([$tagId]);
154
+                $tag = current($tags);
155
+                if (!$this->tagManager->canUserSeeTag($tag, $this->user)) {
156
+                    return false;
157
+                }
158
+            }
159
+
160
+            return $result;
161
+        } catch (\InvalidArgumentException $e) {
162
+            throw new BadRequest('Invalid tag id', 0, $e);
163
+        } catch (TagNotFoundException $e) {
164
+            return false;
165
+        }
166
+    }
167
+
168
+    function delete() {
169
+        throw new Forbidden('Permission denied to delete this collection');
170
+    }
171
+
172
+    function getName() {
173
+        return $this->objectId;
174
+    }
175
+
176
+    function setName($name) {
177
+        throw new Forbidden('Permission denied to rename this collection');
178
+    }
179
+
180
+    /**
181
+     * Returns the last modification time, as a unix timestamp
182
+     *
183
+     * @return int
184
+     */
185
+    function getLastModified() {
186
+        return null;
187
+    }
188
+
189
+    /**
190
+     * Create a sabre node for the mapping of the 
191
+     * given system tag to the collection's object
192
+     *
193
+     * @param ISystemTag $tag
194
+     *
195
+     * @return SystemTagMappingNode
196
+     */
197
+    private function makeNode(ISystemTag $tag) {
198
+        return new SystemTagMappingNode(
199
+            $tag,
200
+            $this->objectId,
201
+            $this->objectType,
202
+            $this->user,
203
+            $this->tagManager,
204
+            $this->tagMapper
205
+        );
206
+    }
207 207
 }
Please login to merge, or discard this patch.