Passed
Push — master ( 41cace...9ea657 )
by John
26:43 queued 10s
created
apps/dav/lib/CardDAV/CardDavBackend.php 1 patch
Indentation   +1110 added lines, -1110 removed lines patch added patch discarded remove patch
@@ -53,1114 +53,1114 @@
 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->createFunction('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 calendars
171
-		$principals = $this->principalBackend->getGroupMembership($principalUriOriginal, true);
172
-		$principals = array_map(function($principal) {
173
-			return urldecode($principal);
174
-		}, $principals);
175
-		$principals[]= $principalUri;
176
-
177
-		$query = $this->db->getQueryBuilder();
178
-		$result = $query->select(['a.id', 'a.uri', 'a.displayname', 'a.principaluri', 'a.description', 'a.synctoken', 's.access'])
179
-			->from('dav_shares', 's')
180
-			->join('s', 'addressbooks', 'a', $query->expr()->eq('s.resourceid', 'a.id'))
181
-			->where($query->expr()->in('s.principaluri', $query->createParameter('principaluri')))
182
-			->andWhere($query->expr()->eq('s.type', $query->createParameter('type')))
183
-			->setParameter('type', 'addressbook')
184
-			->setParameter('principaluri', $principals, IQueryBuilder::PARAM_STR_ARRAY)
185
-			->execute();
186
-
187
-		$readOnlyPropertyName = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}read-only';
188
-		while($row = $result->fetch()) {
189
-			if ($row['principaluri'] === $principalUri) {
190
-				continue;
191
-			}
192
-
193
-			$readOnly = (int) $row['access'] === Backend::ACCESS_READ;
194
-			if (isset($addressBooks[$row['id']])) {
195
-				if ($readOnly) {
196
-					// New share can not have more permissions then the old one.
197
-					continue;
198
-				}
199
-				if (isset($addressBooks[$row['id']][$readOnlyPropertyName]) &&
200
-					$addressBooks[$row['id']][$readOnlyPropertyName] === 0) {
201
-					// Old share is already read-write, no more permissions can be gained
202
-					continue;
203
-				}
204
-			}
205
-
206
-			list(, $name) = \Sabre\Uri\split($row['principaluri']);
207
-			$uri = $row['uri'] . '_shared_by_' . $name;
208
-			$displayName = $row['displayname'] . ' (' . $this->getUserDisplayName($name) . ')';
209
-
210
-			$addressBooks[$row['id']] = [
211
-				'id'  => $row['id'],
212
-				'uri' => $uri,
213
-				'principaluri' => $principalUriOriginal,
214
-				'{DAV:}displayname' => $displayName,
215
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
216
-				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
217
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
218
-				'{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal' => $row['principaluri'],
219
-				$readOnlyPropertyName => $readOnly,
220
-			];
221
-
222
-			$this->addOwnerPrincipal($addressBooks[$row['id']]);
223
-		}
224
-		$result->closeCursor();
225
-
226
-		return array_values($addressBooks);
227
-	}
228
-
229
-	public function getUsersOwnAddressBooks($principalUri) {
230
-		$principalUri = $this->convertPrincipal($principalUri, true);
231
-		$query = $this->db->getQueryBuilder();
232
-		$query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
233
-			  ->from('addressbooks')
234
-			  ->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
235
-
236
-		$addressBooks = [];
237
-
238
-		$result = $query->execute();
239
-		while($row = $result->fetch()) {
240
-			$addressBooks[$row['id']] = [
241
-				'id'  => $row['id'],
242
-				'uri' => $row['uri'],
243
-				'principaluri' => $this->convertPrincipal($row['principaluri'], false),
244
-				'{DAV:}displayname' => $row['displayname'],
245
-				'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
246
-				'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
247
-				'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
248
-			];
249
-
250
-			$this->addOwnerPrincipal($addressBooks[$row['id']]);
251
-		}
252
-		$result->closeCursor();
253
-
254
-		return array_values($addressBooks);
255
-	}
256
-
257
-	private function getUserDisplayName($uid) {
258
-		if (!isset($this->userDisplayNames[$uid])) {
259
-			$user = $this->userManager->get($uid);
260
-
261
-			if ($user instanceof IUser) {
262
-				$this->userDisplayNames[$uid] = $user->getDisplayName();
263
-			} else {
264
-				$this->userDisplayNames[$uid] = $uid;
265
-			}
266
-		}
267
-
268
-		return $this->userDisplayNames[$uid];
269
-	}
270
-
271
-	/**
272
-	 * @param int $addressBookId
273
-	 */
274
-	public function getAddressBookById($addressBookId) {
275
-		$query = $this->db->getQueryBuilder();
276
-		$result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
277
-			->from('addressbooks')
278
-			->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
279
-			->execute();
280
-
281
-		$row = $result->fetch();
282
-		$result->closeCursor();
283
-		if ($row === false) {
284
-			return null;
285
-		}
286
-
287
-		$addressBook = [
288
-			'id'  => $row['id'],
289
-			'uri' => $row['uri'],
290
-			'principaluri' => $row['principaluri'],
291
-			'{DAV:}displayname' => $row['displayname'],
292
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
293
-			'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
294
-			'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
295
-		];
296
-
297
-		$this->addOwnerPrincipal($addressBook);
298
-
299
-		return $addressBook;
300
-	}
301
-
302
-	/**
303
-	 * @param $addressBookUri
304
-	 * @return array|null
305
-	 */
306
-	public function getAddressBooksByUri($principal, $addressBookUri) {
307
-		$query = $this->db->getQueryBuilder();
308
-		$result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
309
-			->from('addressbooks')
310
-			->where($query->expr()->eq('uri', $query->createNamedParameter($addressBookUri)))
311
-			->andWhere($query->expr()->eq('principaluri', $query->createNamedParameter($principal)))
312
-			->setMaxResults(1)
313
-			->execute();
314
-
315
-		$row = $result->fetch();
316
-		$result->closeCursor();
317
-		if ($row === false) {
318
-			return null;
319
-		}
320
-
321
-		$addressBook = [
322
-			'id'  => $row['id'],
323
-			'uri' => $row['uri'],
324
-			'principaluri' => $row['principaluri'],
325
-			'{DAV:}displayname' => $row['displayname'],
326
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
327
-			'{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
328
-			'{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
329
-		];
330
-
331
-		$this->addOwnerPrincipal($addressBook);
332
-
333
-		return $addressBook;
334
-	}
335
-
336
-	/**
337
-	 * Updates properties for an address book.
338
-	 *
339
-	 * The list of mutations is stored in a Sabre\DAV\PropPatch object.
340
-	 * To do the actual updates, you must tell this object which properties
341
-	 * you're going to process with the handle() method.
342
-	 *
343
-	 * Calling the handle method is like telling the PropPatch object "I
344
-	 * promise I can handle updating this property".
345
-	 *
346
-	 * Read the PropPatch documentation for more info and examples.
347
-	 *
348
-	 * @param string $addressBookId
349
-	 * @param \Sabre\DAV\PropPatch $propPatch
350
-	 * @return void
351
-	 */
352
-	function updateAddressBook($addressBookId, \Sabre\DAV\PropPatch $propPatch) {
353
-		$supportedProperties = [
354
-			'{DAV:}displayname',
355
-			'{' . Plugin::NS_CARDDAV . '}addressbook-description',
356
-		];
357
-
358
-		/**
359
-		 * @suppress SqlInjectionChecker
360
-		 */
361
-		$propPatch->handle($supportedProperties, function($mutations) use ($addressBookId) {
362
-
363
-			$updates = [];
364
-			foreach($mutations as $property=>$newValue) {
365
-
366
-				switch($property) {
367
-					case '{DAV:}displayname' :
368
-						$updates['displayname'] = $newValue;
369
-						break;
370
-					case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
371
-						$updates['description'] = $newValue;
372
-						break;
373
-				}
374
-			}
375
-			$query = $this->db->getQueryBuilder();
376
-			$query->update('addressbooks');
377
-
378
-			foreach($updates as $key=>$value) {
379
-				$query->set($key, $query->createNamedParameter($value));
380
-			}
381
-			$query->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
382
-			->execute();
383
-
384
-			$this->addChange($addressBookId, "", 2);
385
-
386
-			return true;
387
-
388
-		});
389
-	}
390
-
391
-	/**
392
-	 * Creates a new address book
393
-	 *
394
-	 * @param string $principalUri
395
-	 * @param string $url Just the 'basename' of the url.
396
-	 * @param array $properties
397
-	 * @return int
398
-	 * @throws BadRequest
399
-	 */
400
-	function createAddressBook($principalUri, $url, array $properties) {
401
-		$values = [
402
-			'displayname' => null,
403
-			'description' => null,
404
-			'principaluri' => $principalUri,
405
-			'uri' => $url,
406
-			'synctoken' => 1
407
-		];
408
-
409
-		foreach($properties as $property=>$newValue) {
410
-
411
-			switch($property) {
412
-				case '{DAV:}displayname' :
413
-					$values['displayname'] = $newValue;
414
-					break;
415
-				case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
416
-					$values['description'] = $newValue;
417
-					break;
418
-				default :
419
-					throw new BadRequest('Unknown property: ' . $property);
420
-			}
421
-
422
-		}
423
-
424
-		// Fallback to make sure the displayname is set. Some clients may refuse
425
-		// to work with addressbooks not having a displayname.
426
-		if(is_null($values['displayname'])) {
427
-			$values['displayname'] = $url;
428
-		}
429
-
430
-		$query = $this->db->getQueryBuilder();
431
-		$query->insert('addressbooks')
432
-			->values([
433
-				'uri' => $query->createParameter('uri'),
434
-				'displayname' => $query->createParameter('displayname'),
435
-				'description' => $query->createParameter('description'),
436
-				'principaluri' => $query->createParameter('principaluri'),
437
-				'synctoken' => $query->createParameter('synctoken'),
438
-			])
439
-			->setParameters($values)
440
-			->execute();
441
-
442
-		return $query->getLastInsertId();
443
-	}
444
-
445
-	/**
446
-	 * Deletes an entire addressbook and all its contents
447
-	 *
448
-	 * @param mixed $addressBookId
449
-	 * @return void
450
-	 */
451
-	function deleteAddressBook($addressBookId) {
452
-		$query = $this->db->getQueryBuilder();
453
-		$query->delete('cards')
454
-			->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
455
-			->setParameter('addressbookid', $addressBookId)
456
-			->execute();
457
-
458
-		$query->delete('addressbookchanges')
459
-			->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
460
-			->setParameter('addressbookid', $addressBookId)
461
-			->execute();
462
-
463
-		$query->delete('addressbooks')
464
-			->where($query->expr()->eq('id', $query->createParameter('id')))
465
-			->setParameter('id', $addressBookId)
466
-			->execute();
467
-
468
-		$this->sharingBackend->deleteAllShares($addressBookId);
469
-
470
-		$query->delete($this->dbCardsPropertiesTable)
471
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
472
-			->execute();
473
-
474
-	}
475
-
476
-	/**
477
-	 * Returns all cards for a specific addressbook id.
478
-	 *
479
-	 * This method should return the following properties for each card:
480
-	 *   * carddata - raw vcard data
481
-	 *   * uri - Some unique url
482
-	 *   * lastmodified - A unix timestamp
483
-	 *
484
-	 * It's recommended to also return the following properties:
485
-	 *   * etag - A unique etag. This must change every time the card changes.
486
-	 *   * size - The size of the card in bytes.
487
-	 *
488
-	 * If these last two properties are provided, less time will be spent
489
-	 * calculating them. If they are specified, you can also ommit carddata.
490
-	 * This may speed up certain requests, especially with large cards.
491
-	 *
492
-	 * @param mixed $addressBookId
493
-	 * @return array
494
-	 */
495
-	function getCards($addressBookId) {
496
-		$query = $this->db->getQueryBuilder();
497
-		$query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
498
-			->from('cards')
499
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
500
-
501
-		$cards = [];
502
-
503
-		$result = $query->execute();
504
-		while($row = $result->fetch()) {
505
-			$row['etag'] = '"' . $row['etag'] . '"';
506
-			$row['carddata'] = $this->readBlob($row['carddata']);
507
-			$cards[] = $row;
508
-		}
509
-		$result->closeCursor();
510
-
511
-		return $cards;
512
-	}
513
-
514
-	/**
515
-	 * Returns a specific card.
516
-	 *
517
-	 * The same set of properties must be returned as with getCards. The only
518
-	 * exception is that 'carddata' is absolutely required.
519
-	 *
520
-	 * If the card does not exist, you must return false.
521
-	 *
522
-	 * @param mixed $addressBookId
523
-	 * @param string $cardUri
524
-	 * @return array
525
-	 */
526
-	function getCard($addressBookId, $cardUri) {
527
-		$query = $this->db->getQueryBuilder();
528
-		$query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
529
-			->from('cards')
530
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
531
-			->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
532
-			->setMaxResults(1);
533
-
534
-		$result = $query->execute();
535
-		$row = $result->fetch();
536
-		if (!$row) {
537
-			return false;
538
-		}
539
-		$row['etag'] = '"' . $row['etag'] . '"';
540
-		$row['carddata'] = $this->readBlob($row['carddata']);
541
-
542
-		return $row;
543
-	}
544
-
545
-	/**
546
-	 * Returns a list of cards.
547
-	 *
548
-	 * This method should work identical to getCard, but instead return all the
549
-	 * cards in the list as an array.
550
-	 *
551
-	 * If the backend supports this, it may allow for some speed-ups.
552
-	 *
553
-	 * @param mixed $addressBookId
554
-	 * @param string[] $uris
555
-	 * @return array
556
-	 */
557
-	function getMultipleCards($addressBookId, array $uris) {
558
-		if (empty($uris)) {
559
-			return [];
560
-		}
561
-
562
-		$chunks = array_chunk($uris, 100);
563
-		$cards = [];
564
-
565
-		$query = $this->db->getQueryBuilder();
566
-		$query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
567
-			->from('cards')
568
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
569
-			->andWhere($query->expr()->in('uri', $query->createParameter('uri')));
570
-
571
-		foreach ($chunks as $uris) {
572
-			$query->setParameter('uri', $uris, IQueryBuilder::PARAM_STR_ARRAY);
573
-			$result = $query->execute();
574
-
575
-			while ($row = $result->fetch()) {
576
-				$row['etag'] = '"' . $row['etag'] . '"';
577
-				$row['carddata'] = $this->readBlob($row['carddata']);
578
-				$cards[] = $row;
579
-			}
580
-			$result->closeCursor();
581
-		}
582
-		return $cards;
583
-	}
584
-
585
-	/**
586
-	 * Creates a new card.
587
-	 *
588
-	 * The addressbook id will be passed as the first argument. This is the
589
-	 * same id as it is returned from the getAddressBooksForUser method.
590
-	 *
591
-	 * The cardUri is a base uri, and doesn't include the full path. The
592
-	 * cardData argument is the vcard body, and is passed as a string.
593
-	 *
594
-	 * It is possible to return an ETag from this method. This ETag is for the
595
-	 * newly created resource, and must be enclosed with double quotes (that
596
-	 * is, the string itself must contain the double quotes).
597
-	 *
598
-	 * You should only return the ETag if you store the carddata as-is. If a
599
-	 * subsequent GET request on the same card does not have the same body,
600
-	 * byte-by-byte and you did return an ETag here, clients tend to get
601
-	 * confused.
602
-	 *
603
-	 * If you don't return an ETag, you can just return null.
604
-	 *
605
-	 * @param mixed $addressBookId
606
-	 * @param string $cardUri
607
-	 * @param string $cardData
608
-	 * @return string
609
-	 */
610
-	function createCard($addressBookId, $cardUri, $cardData) {
611
-		$etag = md5($cardData);
612
-		$uid = $this->getUID($cardData);
613
-
614
-		$q = $this->db->getQueryBuilder();
615
-		$q->select('uid')
616
-			->from('cards')
617
-			->where($q->expr()->eq('addressbookid', $q->createNamedParameter($addressBookId)))
618
-			->andWhere($q->expr()->eq('uid', $q->createNamedParameter($uid)))
619
-			->setMaxResults(1);
620
-		$result = $q->execute();
621
-		$count = (bool) $result->fetchColumn();
622
-		$result->closeCursor();
623
-		if ($count) {
624
-			throw new \Sabre\DAV\Exception\BadRequest('VCard object with uid already exists in this addressbook collection.');
625
-		}
626
-
627
-		$query = $this->db->getQueryBuilder();
628
-		$query->insert('cards')
629
-			->values([
630
-				'carddata' => $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB),
631
-				'uri' => $query->createNamedParameter($cardUri),
632
-				'lastmodified' => $query->createNamedParameter(time()),
633
-				'addressbookid' => $query->createNamedParameter($addressBookId),
634
-				'size' => $query->createNamedParameter(strlen($cardData)),
635
-				'etag' => $query->createNamedParameter($etag),
636
-				'uid' => $query->createNamedParameter($uid),
637
-			])
638
-			->execute();
639
-
640
-		$this->addChange($addressBookId, $cardUri, 1);
641
-		$this->updateProperties($addressBookId, $cardUri, $cardData);
642
-
643
-		$this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::createCard',
644
-			new GenericEvent(null, [
645
-				'addressBookId' => $addressBookId,
646
-				'cardUri' => $cardUri,
647
-				'cardData' => $cardData]));
648
-
649
-		return '"' . $etag . '"';
650
-	}
651
-
652
-	/**
653
-	 * Updates a card.
654
-	 *
655
-	 * The addressbook id will be passed as the first argument. This is the
656
-	 * same id as it is returned from the getAddressBooksForUser method.
657
-	 *
658
-	 * The cardUri is a base uri, and doesn't include the full path. The
659
-	 * cardData argument is the vcard body, and is passed as a string.
660
-	 *
661
-	 * It is possible to return an ETag from this method. This ETag should
662
-	 * match that of the updated resource, and must be enclosed with double
663
-	 * quotes (that is: the string itself must contain the actual quotes).
664
-	 *
665
-	 * You should only return the ETag if you store the carddata as-is. If a
666
-	 * subsequent GET request on the same card does not have the same body,
667
-	 * byte-by-byte and you did return an ETag here, clients tend to get
668
-	 * confused.
669
-	 *
670
-	 * If you don't return an ETag, you can just return null.
671
-	 *
672
-	 * @param mixed $addressBookId
673
-	 * @param string $cardUri
674
-	 * @param string $cardData
675
-	 * @return string
676
-	 */
677
-	function updateCard($addressBookId, $cardUri, $cardData) {
678
-
679
-		$uid = $this->getUID($cardData);
680
-		$etag = md5($cardData);
681
-		$query = $this->db->getQueryBuilder();
682
-		$query->update('cards')
683
-			->set('carddata', $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB))
684
-			->set('lastmodified', $query->createNamedParameter(time()))
685
-			->set('size', $query->createNamedParameter(strlen($cardData)))
686
-			->set('etag', $query->createNamedParameter($etag))
687
-			->set('uid', $query->createNamedParameter($uid))
688
-			->where($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
689
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
690
-			->execute();
691
-
692
-		$this->addChange($addressBookId, $cardUri, 2);
693
-		$this->updateProperties($addressBookId, $cardUri, $cardData);
694
-
695
-		$this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::updateCard',
696
-			new GenericEvent(null, [
697
-				'addressBookId' => $addressBookId,
698
-				'cardUri' => $cardUri,
699
-				'cardData' => $cardData]));
700
-
701
-		return '"' . $etag . '"';
702
-	}
703
-
704
-	/**
705
-	 * Deletes a card
706
-	 *
707
-	 * @param mixed $addressBookId
708
-	 * @param string $cardUri
709
-	 * @return bool
710
-	 */
711
-	function deleteCard($addressBookId, $cardUri) {
712
-		try {
713
-			$cardId = $this->getCardId($addressBookId, $cardUri);
714
-		} catch (\InvalidArgumentException $e) {
715
-			$cardId = null;
716
-		}
717
-		$query = $this->db->getQueryBuilder();
718
-		$ret = $query->delete('cards')
719
-			->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
720
-			->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
721
-			->execute();
722
-
723
-		$this->addChange($addressBookId, $cardUri, 3);
724
-
725
-		$this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::deleteCard',
726
-			new GenericEvent(null, [
727
-				'addressBookId' => $addressBookId,
728
-				'cardUri' => $cardUri]));
729
-
730
-		if ($ret === 1) {
731
-			if ($cardId !== null) {
732
-				$this->purgeProperties($addressBookId, $cardId);
733
-			}
734
-			return true;
735
-		}
736
-
737
-		return false;
738
-	}
739
-
740
-	/**
741
-	 * The getChanges method returns all the changes that have happened, since
742
-	 * the specified syncToken in the specified address book.
743
-	 *
744
-	 * This function should return an array, such as the following:
745
-	 *
746
-	 * [
747
-	 *   'syncToken' => 'The current synctoken',
748
-	 *   'added'   => [
749
-	 *      'new.txt',
750
-	 *   ],
751
-	 *   'modified'   => [
752
-	 *      'modified.txt',
753
-	 *   ],
754
-	 *   'deleted' => [
755
-	 *      'foo.php.bak',
756
-	 *      'old.txt'
757
-	 *   ]
758
-	 * ];
759
-	 *
760
-	 * The returned syncToken property should reflect the *current* syncToken
761
-	 * of the calendar, as reported in the {http://sabredav.org/ns}sync-token
762
-	 * property. This is needed here too, to ensure the operation is atomic.
763
-	 *
764
-	 * If the $syncToken argument is specified as null, this is an initial
765
-	 * sync, and all members should be reported.
766
-	 *
767
-	 * The modified property is an array of nodenames that have changed since
768
-	 * the last token.
769
-	 *
770
-	 * The deleted property is an array with nodenames, that have been deleted
771
-	 * from collection.
772
-	 *
773
-	 * The $syncLevel argument is basically the 'depth' of the report. If it's
774
-	 * 1, you only have to report changes that happened only directly in
775
-	 * immediate descendants. If it's 2, it should also include changes from
776
-	 * the nodes below the child collections. (grandchildren)
777
-	 *
778
-	 * The $limit argument allows a client to specify how many results should
779
-	 * be returned at most. If the limit is not specified, it should be treated
780
-	 * as infinite.
781
-	 *
782
-	 * If the limit (infinite or not) is higher than you're willing to return,
783
-	 * you should throw a Sabre\DAV\Exception\TooMuchMatches() exception.
784
-	 *
785
-	 * If the syncToken is expired (due to data cleanup) or unknown, you must
786
-	 * return null.
787
-	 *
788
-	 * The limit is 'suggestive'. You are free to ignore it.
789
-	 *
790
-	 * @param string $addressBookId
791
-	 * @param string $syncToken
792
-	 * @param int $syncLevel
793
-	 * @param int $limit
794
-	 * @return array
795
-	 */
796
-	function getChangesForAddressBook($addressBookId, $syncToken, $syncLevel, $limit = null) {
797
-		// Current synctoken
798
-		$stmt = $this->db->prepare('SELECT `synctoken` FROM `*PREFIX*addressbooks` WHERE `id` = ?');
799
-		$stmt->execute([ $addressBookId ]);
800
-		$currentToken = $stmt->fetchColumn(0);
801
-
802
-		if (is_null($currentToken)) return null;
803
-
804
-		$result = [
805
-			'syncToken' => $currentToken,
806
-			'added'     => [],
807
-			'modified'  => [],
808
-			'deleted'   => [],
809
-		];
810
-
811
-		if ($syncToken) {
812
-
813
-			$query = "SELECT `uri`, `operation` FROM `*PREFIX*addressbookchanges` WHERE `synctoken` >= ? AND `synctoken` < ? AND `addressbookid` = ? ORDER BY `synctoken`";
814
-			if ($limit>0) {
815
-				$query .= " `LIMIT` " . (int)$limit;
816
-			}
817
-
818
-			// Fetching all changes
819
-			$stmt = $this->db->prepare($query);
820
-			$stmt->execute([$syncToken, $currentToken, $addressBookId]);
821
-
822
-			$changes = [];
823
-
824
-			// This loop ensures that any duplicates are overwritten, only the
825
-			// last change on a node is relevant.
826
-			while($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
827
-
828
-				$changes[$row['uri']] = $row['operation'];
829
-
830
-			}
831
-
832
-			foreach($changes as $uri => $operation) {
833
-
834
-				switch($operation) {
835
-					case 1:
836
-						$result['added'][] = $uri;
837
-						break;
838
-					case 2:
839
-						$result['modified'][] = $uri;
840
-						break;
841
-					case 3:
842
-						$result['deleted'][] = $uri;
843
-						break;
844
-				}
845
-
846
-			}
847
-		} else {
848
-			// No synctoken supplied, this is the initial sync.
849
-			$query = "SELECT `uri` FROM `*PREFIX*cards` WHERE `addressbookid` = ?";
850
-			$stmt = $this->db->prepare($query);
851
-			$stmt->execute([$addressBookId]);
852
-
853
-			$result['added'] = $stmt->fetchAll(\PDO::FETCH_COLUMN);
854
-		}
855
-		return $result;
856
-	}
857
-
858
-	/**
859
-	 * Adds a change record to the addressbookchanges table.
860
-	 *
861
-	 * @param mixed $addressBookId
862
-	 * @param string $objectUri
863
-	 * @param int $operation 1 = add, 2 = modify, 3 = delete
864
-	 * @return void
865
-	 */
866
-	protected function addChange($addressBookId, $objectUri, $operation) {
867
-		$sql = 'INSERT INTO `*PREFIX*addressbookchanges`(`uri`, `synctoken`, `addressbookid`, `operation`) SELECT ?, `synctoken`, ?, ? FROM `*PREFIX*addressbooks` WHERE `id` = ?';
868
-		$stmt = $this->db->prepare($sql);
869
-		$stmt->execute([
870
-			$objectUri,
871
-			$addressBookId,
872
-			$operation,
873
-			$addressBookId
874
-		]);
875
-		$stmt = $this->db->prepare('UPDATE `*PREFIX*addressbooks` SET `synctoken` = `synctoken` + 1 WHERE `id` = ?');
876
-		$stmt->execute([
877
-			$addressBookId
878
-		]);
879
-	}
880
-
881
-	private function readBlob($cardData) {
882
-		if (is_resource($cardData)) {
883
-			return stream_get_contents($cardData);
884
-		}
885
-
886
-		return $cardData;
887
-	}
888
-
889
-	/**
890
-	 * @param IShareable $shareable
891
-	 * @param string[] $add
892
-	 * @param string[] $remove
893
-	 */
894
-	public function updateShares(IShareable $shareable, $add, $remove) {
895
-		$this->sharingBackend->updateShares($shareable, $add, $remove);
896
-	}
897
-
898
-	/**
899
-	 * search contact
900
-	 *
901
-	 * @param int $addressBookId
902
-	 * @param string $pattern which should match within the $searchProperties
903
-	 * @param array $searchProperties defines the properties within the query pattern should match
904
-	 * @return array an array of contacts which are arrays of key-value-pairs
905
-	 */
906
-	public function search($addressBookId, $pattern, $searchProperties) {
907
-		$query = $this->db->getQueryBuilder();
908
-		$query2 = $this->db->getQueryBuilder();
909
-
910
-		$query2->selectDistinct('cp.cardid')->from($this->dbCardsPropertiesTable, 'cp');
911
-		$query2->andWhere($query2->expr()->eq('cp.addressbookid', $query->createNamedParameter($addressBookId)));
912
-		$or = $query2->expr()->orX();
913
-		foreach ($searchProperties as $property) {
914
-			$or->add($query2->expr()->eq('cp.name', $query->createNamedParameter($property)));
915
-		}
916
-		$query2->andWhere($or);
917
-
918
-		// No need for like when the pattern is empty
919
-		if ('' !== $pattern) {
920
-			$query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter('%' . $this->db->escapeLikeParameter($pattern) . '%')));
921
-		}
922
-
923
-		$query->select('c.carddata', 'c.uri')->from($this->dbCardsTable, 'c')
924
-			->where($query->expr()->in('c.id', $query->createFunction($query2->getSQL())));
925
-
926
-		$result = $query->execute();
927
-		$cards = $result->fetchAll();
928
-
929
-		$result->closeCursor();
930
-
931
-		return array_map(function($array) {
932
-			$array['carddata'] = $this->readBlob($array['carddata']);
933
-			return $array;
934
-		}, $cards);
935
-	}
936
-
937
-	/**
938
-	 * @param int $bookId
939
-	 * @param string $name
940
-	 * @return array
941
-	 */
942
-	public function collectCardProperties($bookId, $name) {
943
-		$query = $this->db->getQueryBuilder();
944
-		$result = $query->selectDistinct('value')
945
-			->from($this->dbCardsPropertiesTable)
946
-			->where($query->expr()->eq('name', $query->createNamedParameter($name)))
947
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($bookId)))
948
-			->execute();
949
-
950
-		$all = $result->fetchAll(PDO::FETCH_COLUMN);
951
-		$result->closeCursor();
952
-
953
-		return $all;
954
-	}
955
-
956
-	/**
957
-	 * get URI from a given contact
958
-	 *
959
-	 * @param int $id
960
-	 * @return string
961
-	 */
962
-	public function getCardUri($id) {
963
-		$query = $this->db->getQueryBuilder();
964
-		$query->select('uri')->from($this->dbCardsTable)
965
-				->where($query->expr()->eq('id', $query->createParameter('id')))
966
-				->setParameter('id', $id);
967
-
968
-		$result = $query->execute();
969
-		$uri = $result->fetch();
970
-		$result->closeCursor();
971
-
972
-		if (!isset($uri['uri'])) {
973
-			throw new \InvalidArgumentException('Card does not exists: ' . $id);
974
-		}
975
-
976
-		return $uri['uri'];
977
-	}
978
-
979
-	/**
980
-	 * return contact with the given URI
981
-	 *
982
-	 * @param int $addressBookId
983
-	 * @param string $uri
984
-	 * @returns array
985
-	 */
986
-	public function getContact($addressBookId, $uri) {
987
-		$result = [];
988
-		$query = $this->db->getQueryBuilder();
989
-		$query->select('*')->from($this->dbCardsTable)
990
-				->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
991
-				->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
992
-		$queryResult = $query->execute();
993
-		$contact = $queryResult->fetch();
994
-		$queryResult->closeCursor();
995
-
996
-		if (is_array($contact)) {
997
-			$result = $contact;
998
-		}
999
-
1000
-		return $result;
1001
-	}
1002
-
1003
-	/**
1004
-	 * Returns the list of people whom this address book is shared with.
1005
-	 *
1006
-	 * Every element in this array should have the following properties:
1007
-	 *   * href - Often a mailto: address
1008
-	 *   * commonName - Optional, for example a first + last name
1009
-	 *   * status - See the Sabre\CalDAV\SharingPlugin::STATUS_ constants.
1010
-	 *   * readOnly - boolean
1011
-	 *   * summary - Optional, a description for the share
1012
-	 *
1013
-	 * @return array
1014
-	 */
1015
-	public function getShares($addressBookId) {
1016
-		return $this->sharingBackend->getShares($addressBookId);
1017
-	}
1018
-
1019
-	/**
1020
-	 * update properties table
1021
-	 *
1022
-	 * @param int $addressBookId
1023
-	 * @param string $cardUri
1024
-	 * @param string $vCardSerialized
1025
-	 */
1026
-	protected function updateProperties($addressBookId, $cardUri, $vCardSerialized) {
1027
-		$cardId = $this->getCardId($addressBookId, $cardUri);
1028
-		$vCard = $this->readCard($vCardSerialized);
1029
-
1030
-		$this->purgeProperties($addressBookId, $cardId);
1031
-
1032
-		$query = $this->db->getQueryBuilder();
1033
-		$query->insert($this->dbCardsPropertiesTable)
1034
-			->values(
1035
-				[
1036
-					'addressbookid' => $query->createNamedParameter($addressBookId),
1037
-					'cardid' => $query->createNamedParameter($cardId),
1038
-					'name' => $query->createParameter('name'),
1039
-					'value' => $query->createParameter('value'),
1040
-					'preferred' => $query->createParameter('preferred')
1041
-				]
1042
-			);
1043
-
1044
-		foreach ($vCard->children() as $property) {
1045
-			if(!in_array($property->name, self::$indexProperties)) {
1046
-				continue;
1047
-			}
1048
-			$preferred = 0;
1049
-			foreach($property->parameters as $parameter) {
1050
-				if ($parameter->name === 'TYPE' && strtoupper($parameter->getValue()) === 'PREF') {
1051
-					$preferred = 1;
1052
-					break;
1053
-				}
1054
-			}
1055
-			$query->setParameter('name', $property->name);
1056
-			$query->setParameter('value', substr($property->getValue(), 0, 254));
1057
-			$query->setParameter('preferred', $preferred);
1058
-			$query->execute();
1059
-		}
1060
-	}
1061
-
1062
-	/**
1063
-	 * read vCard data into a vCard object
1064
-	 *
1065
-	 * @param string $cardData
1066
-	 * @return VCard
1067
-	 */
1068
-	protected function readCard($cardData) {
1069
-		return  Reader::read($cardData);
1070
-	}
1071
-
1072
-	/**
1073
-	 * delete all properties from a given card
1074
-	 *
1075
-	 * @param int $addressBookId
1076
-	 * @param int $cardId
1077
-	 */
1078
-	protected function purgeProperties($addressBookId, $cardId) {
1079
-		$query = $this->db->getQueryBuilder();
1080
-		$query->delete($this->dbCardsPropertiesTable)
1081
-			->where($query->expr()->eq('cardid', $query->createNamedParameter($cardId)))
1082
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1083
-		$query->execute();
1084
-	}
1085
-
1086
-	/**
1087
-	 * get ID from a given contact
1088
-	 *
1089
-	 * @param int $addressBookId
1090
-	 * @param string $uri
1091
-	 * @return int
1092
-	 */
1093
-	protected function getCardId($addressBookId, $uri) {
1094
-		$query = $this->db->getQueryBuilder();
1095
-		$query->select('id')->from($this->dbCardsTable)
1096
-			->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
1097
-			->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1098
-
1099
-		$result = $query->execute();
1100
-		$cardIds = $result->fetch();
1101
-		$result->closeCursor();
1102
-
1103
-		if (!isset($cardIds['id'])) {
1104
-			throw new \InvalidArgumentException('Card does not exists: ' . $uri);
1105
-		}
1106
-
1107
-		return (int)$cardIds['id'];
1108
-	}
1109
-
1110
-	/**
1111
-	 * For shared address books the sharee is set in the ACL of the address book
1112
-	 * @param $addressBookId
1113
-	 * @param $acl
1114
-	 * @return array
1115
-	 */
1116
-	public function applyShareAcl($addressBookId, $acl) {
1117
-		return $this->sharingBackend->applyShareAcl($addressBookId, $acl);
1118
-	}
1119
-
1120
-	private function convertPrincipal($principalUri, $toV2) {
1121
-		if ($this->principalBackend->getPrincipalPrefix() === 'principals') {
1122
-			list(, $name) = \Sabre\Uri\split($principalUri);
1123
-			if ($toV2 === true) {
1124
-				return "principals/users/$name";
1125
-			}
1126
-			return "principals/$name";
1127
-		}
1128
-		return $principalUri;
1129
-	}
1130
-
1131
-	private function addOwnerPrincipal(&$addressbookInfo) {
1132
-		$ownerPrincipalKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal';
1133
-		$displaynameKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_NEXTCLOUD . '}owner-displayname';
1134
-		if (isset($addressbookInfo[$ownerPrincipalKey])) {
1135
-			$uri = $addressbookInfo[$ownerPrincipalKey];
1136
-		} else {
1137
-			$uri = $addressbookInfo['principaluri'];
1138
-		}
1139
-
1140
-		$principalInformation = $this->principalBackend->getPrincipalByPath($uri);
1141
-		if (isset($principalInformation['{DAV:}displayname'])) {
1142
-			$addressbookInfo[$displaynameKey] = $principalInformation['{DAV:}displayname'];
1143
-		}
1144
-	}
1145
-
1146
-	/**
1147
-	 * Extract UID from vcard
1148
-	 *
1149
-	 * @param string $cardData the vcard raw data
1150
-	 * @return string the uid
1151
-	 * @throws BadRequest if no UID is available
1152
-	 */
1153
-	private function getUID($cardData) {
1154
-		if ($cardData != '') {
1155
-			$vCard = Reader::read($cardData);
1156
-			if ($vCard->UID) {
1157
-				$uid = $vCard->UID->getValue();
1158
-				return $uid;
1159
-			}
1160
-			// should already be handled, but just in case
1161
-			throw new BadRequest('vCards on CardDAV servers MUST have a UID property');
1162
-		}
1163
-		// should already be handled, but just in case
1164
-		throw new BadRequest('vCard can not be empty');
1165
-	}
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->createFunction('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 calendars
171
+        $principals = $this->principalBackend->getGroupMembership($principalUriOriginal, true);
172
+        $principals = array_map(function($principal) {
173
+            return urldecode($principal);
174
+        }, $principals);
175
+        $principals[]= $principalUri;
176
+
177
+        $query = $this->db->getQueryBuilder();
178
+        $result = $query->select(['a.id', 'a.uri', 'a.displayname', 'a.principaluri', 'a.description', 'a.synctoken', 's.access'])
179
+            ->from('dav_shares', 's')
180
+            ->join('s', 'addressbooks', 'a', $query->expr()->eq('s.resourceid', 'a.id'))
181
+            ->where($query->expr()->in('s.principaluri', $query->createParameter('principaluri')))
182
+            ->andWhere($query->expr()->eq('s.type', $query->createParameter('type')))
183
+            ->setParameter('type', 'addressbook')
184
+            ->setParameter('principaluri', $principals, IQueryBuilder::PARAM_STR_ARRAY)
185
+            ->execute();
186
+
187
+        $readOnlyPropertyName = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}read-only';
188
+        while($row = $result->fetch()) {
189
+            if ($row['principaluri'] === $principalUri) {
190
+                continue;
191
+            }
192
+
193
+            $readOnly = (int) $row['access'] === Backend::ACCESS_READ;
194
+            if (isset($addressBooks[$row['id']])) {
195
+                if ($readOnly) {
196
+                    // New share can not have more permissions then the old one.
197
+                    continue;
198
+                }
199
+                if (isset($addressBooks[$row['id']][$readOnlyPropertyName]) &&
200
+                    $addressBooks[$row['id']][$readOnlyPropertyName] === 0) {
201
+                    // Old share is already read-write, no more permissions can be gained
202
+                    continue;
203
+                }
204
+            }
205
+
206
+            list(, $name) = \Sabre\Uri\split($row['principaluri']);
207
+            $uri = $row['uri'] . '_shared_by_' . $name;
208
+            $displayName = $row['displayname'] . ' (' . $this->getUserDisplayName($name) . ')';
209
+
210
+            $addressBooks[$row['id']] = [
211
+                'id'  => $row['id'],
212
+                'uri' => $uri,
213
+                'principaluri' => $principalUriOriginal,
214
+                '{DAV:}displayname' => $displayName,
215
+                '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
216
+                '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
217
+                '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
218
+                '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal' => $row['principaluri'],
219
+                $readOnlyPropertyName => $readOnly,
220
+            ];
221
+
222
+            $this->addOwnerPrincipal($addressBooks[$row['id']]);
223
+        }
224
+        $result->closeCursor();
225
+
226
+        return array_values($addressBooks);
227
+    }
228
+
229
+    public function getUsersOwnAddressBooks($principalUri) {
230
+        $principalUri = $this->convertPrincipal($principalUri, true);
231
+        $query = $this->db->getQueryBuilder();
232
+        $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
233
+                ->from('addressbooks')
234
+                ->where($query->expr()->eq('principaluri', $query->createNamedParameter($principalUri)));
235
+
236
+        $addressBooks = [];
237
+
238
+        $result = $query->execute();
239
+        while($row = $result->fetch()) {
240
+            $addressBooks[$row['id']] = [
241
+                'id'  => $row['id'],
242
+                'uri' => $row['uri'],
243
+                'principaluri' => $this->convertPrincipal($row['principaluri'], false),
244
+                '{DAV:}displayname' => $row['displayname'],
245
+                '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
246
+                '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
247
+                '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
248
+            ];
249
+
250
+            $this->addOwnerPrincipal($addressBooks[$row['id']]);
251
+        }
252
+        $result->closeCursor();
253
+
254
+        return array_values($addressBooks);
255
+    }
256
+
257
+    private function getUserDisplayName($uid) {
258
+        if (!isset($this->userDisplayNames[$uid])) {
259
+            $user = $this->userManager->get($uid);
260
+
261
+            if ($user instanceof IUser) {
262
+                $this->userDisplayNames[$uid] = $user->getDisplayName();
263
+            } else {
264
+                $this->userDisplayNames[$uid] = $uid;
265
+            }
266
+        }
267
+
268
+        return $this->userDisplayNames[$uid];
269
+    }
270
+
271
+    /**
272
+     * @param int $addressBookId
273
+     */
274
+    public function getAddressBookById($addressBookId) {
275
+        $query = $this->db->getQueryBuilder();
276
+        $result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
277
+            ->from('addressbooks')
278
+            ->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
279
+            ->execute();
280
+
281
+        $row = $result->fetch();
282
+        $result->closeCursor();
283
+        if ($row === false) {
284
+            return null;
285
+        }
286
+
287
+        $addressBook = [
288
+            'id'  => $row['id'],
289
+            'uri' => $row['uri'],
290
+            'principaluri' => $row['principaluri'],
291
+            '{DAV:}displayname' => $row['displayname'],
292
+            '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
293
+            '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
294
+            '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
295
+        ];
296
+
297
+        $this->addOwnerPrincipal($addressBook);
298
+
299
+        return $addressBook;
300
+    }
301
+
302
+    /**
303
+     * @param $addressBookUri
304
+     * @return array|null
305
+     */
306
+    public function getAddressBooksByUri($principal, $addressBookUri) {
307
+        $query = $this->db->getQueryBuilder();
308
+        $result = $query->select(['id', 'uri', 'displayname', 'principaluri', 'description', 'synctoken'])
309
+            ->from('addressbooks')
310
+            ->where($query->expr()->eq('uri', $query->createNamedParameter($addressBookUri)))
311
+            ->andWhere($query->expr()->eq('principaluri', $query->createNamedParameter($principal)))
312
+            ->setMaxResults(1)
313
+            ->execute();
314
+
315
+        $row = $result->fetch();
316
+        $result->closeCursor();
317
+        if ($row === false) {
318
+            return null;
319
+        }
320
+
321
+        $addressBook = [
322
+            'id'  => $row['id'],
323
+            'uri' => $row['uri'],
324
+            'principaluri' => $row['principaluri'],
325
+            '{DAV:}displayname' => $row['displayname'],
326
+            '{' . Plugin::NS_CARDDAV . '}addressbook-description' => $row['description'],
327
+            '{http://calendarserver.org/ns/}getctag' => $row['synctoken'],
328
+            '{http://sabredav.org/ns}sync-token' => $row['synctoken']?$row['synctoken']:'0',
329
+        ];
330
+
331
+        $this->addOwnerPrincipal($addressBook);
332
+
333
+        return $addressBook;
334
+    }
335
+
336
+    /**
337
+     * Updates properties for an address book.
338
+     *
339
+     * The list of mutations is stored in a Sabre\DAV\PropPatch object.
340
+     * To do the actual updates, you must tell this object which properties
341
+     * you're going to process with the handle() method.
342
+     *
343
+     * Calling the handle method is like telling the PropPatch object "I
344
+     * promise I can handle updating this property".
345
+     *
346
+     * Read the PropPatch documentation for more info and examples.
347
+     *
348
+     * @param string $addressBookId
349
+     * @param \Sabre\DAV\PropPatch $propPatch
350
+     * @return void
351
+     */
352
+    function updateAddressBook($addressBookId, \Sabre\DAV\PropPatch $propPatch) {
353
+        $supportedProperties = [
354
+            '{DAV:}displayname',
355
+            '{' . Plugin::NS_CARDDAV . '}addressbook-description',
356
+        ];
357
+
358
+        /**
359
+         * @suppress SqlInjectionChecker
360
+         */
361
+        $propPatch->handle($supportedProperties, function($mutations) use ($addressBookId) {
362
+
363
+            $updates = [];
364
+            foreach($mutations as $property=>$newValue) {
365
+
366
+                switch($property) {
367
+                    case '{DAV:}displayname' :
368
+                        $updates['displayname'] = $newValue;
369
+                        break;
370
+                    case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
371
+                        $updates['description'] = $newValue;
372
+                        break;
373
+                }
374
+            }
375
+            $query = $this->db->getQueryBuilder();
376
+            $query->update('addressbooks');
377
+
378
+            foreach($updates as $key=>$value) {
379
+                $query->set($key, $query->createNamedParameter($value));
380
+            }
381
+            $query->where($query->expr()->eq('id', $query->createNamedParameter($addressBookId)))
382
+            ->execute();
383
+
384
+            $this->addChange($addressBookId, "", 2);
385
+
386
+            return true;
387
+
388
+        });
389
+    }
390
+
391
+    /**
392
+     * Creates a new address book
393
+     *
394
+     * @param string $principalUri
395
+     * @param string $url Just the 'basename' of the url.
396
+     * @param array $properties
397
+     * @return int
398
+     * @throws BadRequest
399
+     */
400
+    function createAddressBook($principalUri, $url, array $properties) {
401
+        $values = [
402
+            'displayname' => null,
403
+            'description' => null,
404
+            'principaluri' => $principalUri,
405
+            'uri' => $url,
406
+            'synctoken' => 1
407
+        ];
408
+
409
+        foreach($properties as $property=>$newValue) {
410
+
411
+            switch($property) {
412
+                case '{DAV:}displayname' :
413
+                    $values['displayname'] = $newValue;
414
+                    break;
415
+                case '{' . Plugin::NS_CARDDAV . '}addressbook-description' :
416
+                    $values['description'] = $newValue;
417
+                    break;
418
+                default :
419
+                    throw new BadRequest('Unknown property: ' . $property);
420
+            }
421
+
422
+        }
423
+
424
+        // Fallback to make sure the displayname is set. Some clients may refuse
425
+        // to work with addressbooks not having a displayname.
426
+        if(is_null($values['displayname'])) {
427
+            $values['displayname'] = $url;
428
+        }
429
+
430
+        $query = $this->db->getQueryBuilder();
431
+        $query->insert('addressbooks')
432
+            ->values([
433
+                'uri' => $query->createParameter('uri'),
434
+                'displayname' => $query->createParameter('displayname'),
435
+                'description' => $query->createParameter('description'),
436
+                'principaluri' => $query->createParameter('principaluri'),
437
+                'synctoken' => $query->createParameter('synctoken'),
438
+            ])
439
+            ->setParameters($values)
440
+            ->execute();
441
+
442
+        return $query->getLastInsertId();
443
+    }
444
+
445
+    /**
446
+     * Deletes an entire addressbook and all its contents
447
+     *
448
+     * @param mixed $addressBookId
449
+     * @return void
450
+     */
451
+    function deleteAddressBook($addressBookId) {
452
+        $query = $this->db->getQueryBuilder();
453
+        $query->delete('cards')
454
+            ->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
455
+            ->setParameter('addressbookid', $addressBookId)
456
+            ->execute();
457
+
458
+        $query->delete('addressbookchanges')
459
+            ->where($query->expr()->eq('addressbookid', $query->createParameter('addressbookid')))
460
+            ->setParameter('addressbookid', $addressBookId)
461
+            ->execute();
462
+
463
+        $query->delete('addressbooks')
464
+            ->where($query->expr()->eq('id', $query->createParameter('id')))
465
+            ->setParameter('id', $addressBookId)
466
+            ->execute();
467
+
468
+        $this->sharingBackend->deleteAllShares($addressBookId);
469
+
470
+        $query->delete($this->dbCardsPropertiesTable)
471
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
472
+            ->execute();
473
+
474
+    }
475
+
476
+    /**
477
+     * Returns all cards for a specific addressbook id.
478
+     *
479
+     * This method should return the following properties for each card:
480
+     *   * carddata - raw vcard data
481
+     *   * uri - Some unique url
482
+     *   * lastmodified - A unix timestamp
483
+     *
484
+     * It's recommended to also return the following properties:
485
+     *   * etag - A unique etag. This must change every time the card changes.
486
+     *   * size - The size of the card in bytes.
487
+     *
488
+     * If these last two properties are provided, less time will be spent
489
+     * calculating them. If they are specified, you can also ommit carddata.
490
+     * This may speed up certain requests, especially with large cards.
491
+     *
492
+     * @param mixed $addressBookId
493
+     * @return array
494
+     */
495
+    function getCards($addressBookId) {
496
+        $query = $this->db->getQueryBuilder();
497
+        $query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
498
+            ->from('cards')
499
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
500
+
501
+        $cards = [];
502
+
503
+        $result = $query->execute();
504
+        while($row = $result->fetch()) {
505
+            $row['etag'] = '"' . $row['etag'] . '"';
506
+            $row['carddata'] = $this->readBlob($row['carddata']);
507
+            $cards[] = $row;
508
+        }
509
+        $result->closeCursor();
510
+
511
+        return $cards;
512
+    }
513
+
514
+    /**
515
+     * Returns a specific card.
516
+     *
517
+     * The same set of properties must be returned as with getCards. The only
518
+     * exception is that 'carddata' is absolutely required.
519
+     *
520
+     * If the card does not exist, you must return false.
521
+     *
522
+     * @param mixed $addressBookId
523
+     * @param string $cardUri
524
+     * @return array
525
+     */
526
+    function getCard($addressBookId, $cardUri) {
527
+        $query = $this->db->getQueryBuilder();
528
+        $query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
529
+            ->from('cards')
530
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
531
+            ->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
532
+            ->setMaxResults(1);
533
+
534
+        $result = $query->execute();
535
+        $row = $result->fetch();
536
+        if (!$row) {
537
+            return false;
538
+        }
539
+        $row['etag'] = '"' . $row['etag'] . '"';
540
+        $row['carddata'] = $this->readBlob($row['carddata']);
541
+
542
+        return $row;
543
+    }
544
+
545
+    /**
546
+     * Returns a list of cards.
547
+     *
548
+     * This method should work identical to getCard, but instead return all the
549
+     * cards in the list as an array.
550
+     *
551
+     * If the backend supports this, it may allow for some speed-ups.
552
+     *
553
+     * @param mixed $addressBookId
554
+     * @param string[] $uris
555
+     * @return array
556
+     */
557
+    function getMultipleCards($addressBookId, array $uris) {
558
+        if (empty($uris)) {
559
+            return [];
560
+        }
561
+
562
+        $chunks = array_chunk($uris, 100);
563
+        $cards = [];
564
+
565
+        $query = $this->db->getQueryBuilder();
566
+        $query->select(['id', 'uri', 'lastmodified', 'etag', 'size', 'carddata', 'uid'])
567
+            ->from('cards')
568
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
569
+            ->andWhere($query->expr()->in('uri', $query->createParameter('uri')));
570
+
571
+        foreach ($chunks as $uris) {
572
+            $query->setParameter('uri', $uris, IQueryBuilder::PARAM_STR_ARRAY);
573
+            $result = $query->execute();
574
+
575
+            while ($row = $result->fetch()) {
576
+                $row['etag'] = '"' . $row['etag'] . '"';
577
+                $row['carddata'] = $this->readBlob($row['carddata']);
578
+                $cards[] = $row;
579
+            }
580
+            $result->closeCursor();
581
+        }
582
+        return $cards;
583
+    }
584
+
585
+    /**
586
+     * Creates a new card.
587
+     *
588
+     * The addressbook id will be passed as the first argument. This is the
589
+     * same id as it is returned from the getAddressBooksForUser method.
590
+     *
591
+     * The cardUri is a base uri, and doesn't include the full path. The
592
+     * cardData argument is the vcard body, and is passed as a string.
593
+     *
594
+     * It is possible to return an ETag from this method. This ETag is for the
595
+     * newly created resource, and must be enclosed with double quotes (that
596
+     * is, the string itself must contain the double quotes).
597
+     *
598
+     * You should only return the ETag if you store the carddata as-is. If a
599
+     * subsequent GET request on the same card does not have the same body,
600
+     * byte-by-byte and you did return an ETag here, clients tend to get
601
+     * confused.
602
+     *
603
+     * If you don't return an ETag, you can just return null.
604
+     *
605
+     * @param mixed $addressBookId
606
+     * @param string $cardUri
607
+     * @param string $cardData
608
+     * @return string
609
+     */
610
+    function createCard($addressBookId, $cardUri, $cardData) {
611
+        $etag = md5($cardData);
612
+        $uid = $this->getUID($cardData);
613
+
614
+        $q = $this->db->getQueryBuilder();
615
+        $q->select('uid')
616
+            ->from('cards')
617
+            ->where($q->expr()->eq('addressbookid', $q->createNamedParameter($addressBookId)))
618
+            ->andWhere($q->expr()->eq('uid', $q->createNamedParameter($uid)))
619
+            ->setMaxResults(1);
620
+        $result = $q->execute();
621
+        $count = (bool) $result->fetchColumn();
622
+        $result->closeCursor();
623
+        if ($count) {
624
+            throw new \Sabre\DAV\Exception\BadRequest('VCard object with uid already exists in this addressbook collection.');
625
+        }
626
+
627
+        $query = $this->db->getQueryBuilder();
628
+        $query->insert('cards')
629
+            ->values([
630
+                'carddata' => $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB),
631
+                'uri' => $query->createNamedParameter($cardUri),
632
+                'lastmodified' => $query->createNamedParameter(time()),
633
+                'addressbookid' => $query->createNamedParameter($addressBookId),
634
+                'size' => $query->createNamedParameter(strlen($cardData)),
635
+                'etag' => $query->createNamedParameter($etag),
636
+                'uid' => $query->createNamedParameter($uid),
637
+            ])
638
+            ->execute();
639
+
640
+        $this->addChange($addressBookId, $cardUri, 1);
641
+        $this->updateProperties($addressBookId, $cardUri, $cardData);
642
+
643
+        $this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::createCard',
644
+            new GenericEvent(null, [
645
+                'addressBookId' => $addressBookId,
646
+                'cardUri' => $cardUri,
647
+                'cardData' => $cardData]));
648
+
649
+        return '"' . $etag . '"';
650
+    }
651
+
652
+    /**
653
+     * Updates a card.
654
+     *
655
+     * The addressbook id will be passed as the first argument. This is the
656
+     * same id as it is returned from the getAddressBooksForUser method.
657
+     *
658
+     * The cardUri is a base uri, and doesn't include the full path. The
659
+     * cardData argument is the vcard body, and is passed as a string.
660
+     *
661
+     * It is possible to return an ETag from this method. This ETag should
662
+     * match that of the updated resource, and must be enclosed with double
663
+     * quotes (that is: the string itself must contain the actual quotes).
664
+     *
665
+     * You should only return the ETag if you store the carddata as-is. If a
666
+     * subsequent GET request on the same card does not have the same body,
667
+     * byte-by-byte and you did return an ETag here, clients tend to get
668
+     * confused.
669
+     *
670
+     * If you don't return an ETag, you can just return null.
671
+     *
672
+     * @param mixed $addressBookId
673
+     * @param string $cardUri
674
+     * @param string $cardData
675
+     * @return string
676
+     */
677
+    function updateCard($addressBookId, $cardUri, $cardData) {
678
+
679
+        $uid = $this->getUID($cardData);
680
+        $etag = md5($cardData);
681
+        $query = $this->db->getQueryBuilder();
682
+        $query->update('cards')
683
+            ->set('carddata', $query->createNamedParameter($cardData, IQueryBuilder::PARAM_LOB))
684
+            ->set('lastmodified', $query->createNamedParameter(time()))
685
+            ->set('size', $query->createNamedParameter(strlen($cardData)))
686
+            ->set('etag', $query->createNamedParameter($etag))
687
+            ->set('uid', $query->createNamedParameter($uid))
688
+            ->where($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
689
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
690
+            ->execute();
691
+
692
+        $this->addChange($addressBookId, $cardUri, 2);
693
+        $this->updateProperties($addressBookId, $cardUri, $cardData);
694
+
695
+        $this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::updateCard',
696
+            new GenericEvent(null, [
697
+                'addressBookId' => $addressBookId,
698
+                'cardUri' => $cardUri,
699
+                'cardData' => $cardData]));
700
+
701
+        return '"' . $etag . '"';
702
+    }
703
+
704
+    /**
705
+     * Deletes a card
706
+     *
707
+     * @param mixed $addressBookId
708
+     * @param string $cardUri
709
+     * @return bool
710
+     */
711
+    function deleteCard($addressBookId, $cardUri) {
712
+        try {
713
+            $cardId = $this->getCardId($addressBookId, $cardUri);
714
+        } catch (\InvalidArgumentException $e) {
715
+            $cardId = null;
716
+        }
717
+        $query = $this->db->getQueryBuilder();
718
+        $ret = $query->delete('cards')
719
+            ->where($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)))
720
+            ->andWhere($query->expr()->eq('uri', $query->createNamedParameter($cardUri)))
721
+            ->execute();
722
+
723
+        $this->addChange($addressBookId, $cardUri, 3);
724
+
725
+        $this->dispatcher->dispatch('\OCA\DAV\CardDAV\CardDavBackend::deleteCard',
726
+            new GenericEvent(null, [
727
+                'addressBookId' => $addressBookId,
728
+                'cardUri' => $cardUri]));
729
+
730
+        if ($ret === 1) {
731
+            if ($cardId !== null) {
732
+                $this->purgeProperties($addressBookId, $cardId);
733
+            }
734
+            return true;
735
+        }
736
+
737
+        return false;
738
+    }
739
+
740
+    /**
741
+     * The getChanges method returns all the changes that have happened, since
742
+     * the specified syncToken in the specified address book.
743
+     *
744
+     * This function should return an array, such as the following:
745
+     *
746
+     * [
747
+     *   'syncToken' => 'The current synctoken',
748
+     *   'added'   => [
749
+     *      'new.txt',
750
+     *   ],
751
+     *   'modified'   => [
752
+     *      'modified.txt',
753
+     *   ],
754
+     *   'deleted' => [
755
+     *      'foo.php.bak',
756
+     *      'old.txt'
757
+     *   ]
758
+     * ];
759
+     *
760
+     * The returned syncToken property should reflect the *current* syncToken
761
+     * of the calendar, as reported in the {http://sabredav.org/ns}sync-token
762
+     * property. This is needed here too, to ensure the operation is atomic.
763
+     *
764
+     * If the $syncToken argument is specified as null, this is an initial
765
+     * sync, and all members should be reported.
766
+     *
767
+     * The modified property is an array of nodenames that have changed since
768
+     * the last token.
769
+     *
770
+     * The deleted property is an array with nodenames, that have been deleted
771
+     * from collection.
772
+     *
773
+     * The $syncLevel argument is basically the 'depth' of the report. If it's
774
+     * 1, you only have to report changes that happened only directly in
775
+     * immediate descendants. If it's 2, it should also include changes from
776
+     * the nodes below the child collections. (grandchildren)
777
+     *
778
+     * The $limit argument allows a client to specify how many results should
779
+     * be returned at most. If the limit is not specified, it should be treated
780
+     * as infinite.
781
+     *
782
+     * If the limit (infinite or not) is higher than you're willing to return,
783
+     * you should throw a Sabre\DAV\Exception\TooMuchMatches() exception.
784
+     *
785
+     * If the syncToken is expired (due to data cleanup) or unknown, you must
786
+     * return null.
787
+     *
788
+     * The limit is 'suggestive'. You are free to ignore it.
789
+     *
790
+     * @param string $addressBookId
791
+     * @param string $syncToken
792
+     * @param int $syncLevel
793
+     * @param int $limit
794
+     * @return array
795
+     */
796
+    function getChangesForAddressBook($addressBookId, $syncToken, $syncLevel, $limit = null) {
797
+        // Current synctoken
798
+        $stmt = $this->db->prepare('SELECT `synctoken` FROM `*PREFIX*addressbooks` WHERE `id` = ?');
799
+        $stmt->execute([ $addressBookId ]);
800
+        $currentToken = $stmt->fetchColumn(0);
801
+
802
+        if (is_null($currentToken)) return null;
803
+
804
+        $result = [
805
+            'syncToken' => $currentToken,
806
+            'added'     => [],
807
+            'modified'  => [],
808
+            'deleted'   => [],
809
+        ];
810
+
811
+        if ($syncToken) {
812
+
813
+            $query = "SELECT `uri`, `operation` FROM `*PREFIX*addressbookchanges` WHERE `synctoken` >= ? AND `synctoken` < ? AND `addressbookid` = ? ORDER BY `synctoken`";
814
+            if ($limit>0) {
815
+                $query .= " `LIMIT` " . (int)$limit;
816
+            }
817
+
818
+            // Fetching all changes
819
+            $stmt = $this->db->prepare($query);
820
+            $stmt->execute([$syncToken, $currentToken, $addressBookId]);
821
+
822
+            $changes = [];
823
+
824
+            // This loop ensures that any duplicates are overwritten, only the
825
+            // last change on a node is relevant.
826
+            while($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
827
+
828
+                $changes[$row['uri']] = $row['operation'];
829
+
830
+            }
831
+
832
+            foreach($changes as $uri => $operation) {
833
+
834
+                switch($operation) {
835
+                    case 1:
836
+                        $result['added'][] = $uri;
837
+                        break;
838
+                    case 2:
839
+                        $result['modified'][] = $uri;
840
+                        break;
841
+                    case 3:
842
+                        $result['deleted'][] = $uri;
843
+                        break;
844
+                }
845
+
846
+            }
847
+        } else {
848
+            // No synctoken supplied, this is the initial sync.
849
+            $query = "SELECT `uri` FROM `*PREFIX*cards` WHERE `addressbookid` = ?";
850
+            $stmt = $this->db->prepare($query);
851
+            $stmt->execute([$addressBookId]);
852
+
853
+            $result['added'] = $stmt->fetchAll(\PDO::FETCH_COLUMN);
854
+        }
855
+        return $result;
856
+    }
857
+
858
+    /**
859
+     * Adds a change record to the addressbookchanges table.
860
+     *
861
+     * @param mixed $addressBookId
862
+     * @param string $objectUri
863
+     * @param int $operation 1 = add, 2 = modify, 3 = delete
864
+     * @return void
865
+     */
866
+    protected function addChange($addressBookId, $objectUri, $operation) {
867
+        $sql = 'INSERT INTO `*PREFIX*addressbookchanges`(`uri`, `synctoken`, `addressbookid`, `operation`) SELECT ?, `synctoken`, ?, ? FROM `*PREFIX*addressbooks` WHERE `id` = ?';
868
+        $stmt = $this->db->prepare($sql);
869
+        $stmt->execute([
870
+            $objectUri,
871
+            $addressBookId,
872
+            $operation,
873
+            $addressBookId
874
+        ]);
875
+        $stmt = $this->db->prepare('UPDATE `*PREFIX*addressbooks` SET `synctoken` = `synctoken` + 1 WHERE `id` = ?');
876
+        $stmt->execute([
877
+            $addressBookId
878
+        ]);
879
+    }
880
+
881
+    private function readBlob($cardData) {
882
+        if (is_resource($cardData)) {
883
+            return stream_get_contents($cardData);
884
+        }
885
+
886
+        return $cardData;
887
+    }
888
+
889
+    /**
890
+     * @param IShareable $shareable
891
+     * @param string[] $add
892
+     * @param string[] $remove
893
+     */
894
+    public function updateShares(IShareable $shareable, $add, $remove) {
895
+        $this->sharingBackend->updateShares($shareable, $add, $remove);
896
+    }
897
+
898
+    /**
899
+     * search contact
900
+     *
901
+     * @param int $addressBookId
902
+     * @param string $pattern which should match within the $searchProperties
903
+     * @param array $searchProperties defines the properties within the query pattern should match
904
+     * @return array an array of contacts which are arrays of key-value-pairs
905
+     */
906
+    public function search($addressBookId, $pattern, $searchProperties) {
907
+        $query = $this->db->getQueryBuilder();
908
+        $query2 = $this->db->getQueryBuilder();
909
+
910
+        $query2->selectDistinct('cp.cardid')->from($this->dbCardsPropertiesTable, 'cp');
911
+        $query2->andWhere($query2->expr()->eq('cp.addressbookid', $query->createNamedParameter($addressBookId)));
912
+        $or = $query2->expr()->orX();
913
+        foreach ($searchProperties as $property) {
914
+            $or->add($query2->expr()->eq('cp.name', $query->createNamedParameter($property)));
915
+        }
916
+        $query2->andWhere($or);
917
+
918
+        // No need for like when the pattern is empty
919
+        if ('' !== $pattern) {
920
+            $query2->andWhere($query2->expr()->ilike('cp.value', $query->createNamedParameter('%' . $this->db->escapeLikeParameter($pattern) . '%')));
921
+        }
922
+
923
+        $query->select('c.carddata', 'c.uri')->from($this->dbCardsTable, 'c')
924
+            ->where($query->expr()->in('c.id', $query->createFunction($query2->getSQL())));
925
+
926
+        $result = $query->execute();
927
+        $cards = $result->fetchAll();
928
+
929
+        $result->closeCursor();
930
+
931
+        return array_map(function($array) {
932
+            $array['carddata'] = $this->readBlob($array['carddata']);
933
+            return $array;
934
+        }, $cards);
935
+    }
936
+
937
+    /**
938
+     * @param int $bookId
939
+     * @param string $name
940
+     * @return array
941
+     */
942
+    public function collectCardProperties($bookId, $name) {
943
+        $query = $this->db->getQueryBuilder();
944
+        $result = $query->selectDistinct('value')
945
+            ->from($this->dbCardsPropertiesTable)
946
+            ->where($query->expr()->eq('name', $query->createNamedParameter($name)))
947
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($bookId)))
948
+            ->execute();
949
+
950
+        $all = $result->fetchAll(PDO::FETCH_COLUMN);
951
+        $result->closeCursor();
952
+
953
+        return $all;
954
+    }
955
+
956
+    /**
957
+     * get URI from a given contact
958
+     *
959
+     * @param int $id
960
+     * @return string
961
+     */
962
+    public function getCardUri($id) {
963
+        $query = $this->db->getQueryBuilder();
964
+        $query->select('uri')->from($this->dbCardsTable)
965
+                ->where($query->expr()->eq('id', $query->createParameter('id')))
966
+                ->setParameter('id', $id);
967
+
968
+        $result = $query->execute();
969
+        $uri = $result->fetch();
970
+        $result->closeCursor();
971
+
972
+        if (!isset($uri['uri'])) {
973
+            throw new \InvalidArgumentException('Card does not exists: ' . $id);
974
+        }
975
+
976
+        return $uri['uri'];
977
+    }
978
+
979
+    /**
980
+     * return contact with the given URI
981
+     *
982
+     * @param int $addressBookId
983
+     * @param string $uri
984
+     * @returns array
985
+     */
986
+    public function getContact($addressBookId, $uri) {
987
+        $result = [];
988
+        $query = $this->db->getQueryBuilder();
989
+        $query->select('*')->from($this->dbCardsTable)
990
+                ->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
991
+                ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
992
+        $queryResult = $query->execute();
993
+        $contact = $queryResult->fetch();
994
+        $queryResult->closeCursor();
995
+
996
+        if (is_array($contact)) {
997
+            $result = $contact;
998
+        }
999
+
1000
+        return $result;
1001
+    }
1002
+
1003
+    /**
1004
+     * Returns the list of people whom this address book is shared with.
1005
+     *
1006
+     * Every element in this array should have the following properties:
1007
+     *   * href - Often a mailto: address
1008
+     *   * commonName - Optional, for example a first + last name
1009
+     *   * status - See the Sabre\CalDAV\SharingPlugin::STATUS_ constants.
1010
+     *   * readOnly - boolean
1011
+     *   * summary - Optional, a description for the share
1012
+     *
1013
+     * @return array
1014
+     */
1015
+    public function getShares($addressBookId) {
1016
+        return $this->sharingBackend->getShares($addressBookId);
1017
+    }
1018
+
1019
+    /**
1020
+     * update properties table
1021
+     *
1022
+     * @param int $addressBookId
1023
+     * @param string $cardUri
1024
+     * @param string $vCardSerialized
1025
+     */
1026
+    protected function updateProperties($addressBookId, $cardUri, $vCardSerialized) {
1027
+        $cardId = $this->getCardId($addressBookId, $cardUri);
1028
+        $vCard = $this->readCard($vCardSerialized);
1029
+
1030
+        $this->purgeProperties($addressBookId, $cardId);
1031
+
1032
+        $query = $this->db->getQueryBuilder();
1033
+        $query->insert($this->dbCardsPropertiesTable)
1034
+            ->values(
1035
+                [
1036
+                    'addressbookid' => $query->createNamedParameter($addressBookId),
1037
+                    'cardid' => $query->createNamedParameter($cardId),
1038
+                    'name' => $query->createParameter('name'),
1039
+                    'value' => $query->createParameter('value'),
1040
+                    'preferred' => $query->createParameter('preferred')
1041
+                ]
1042
+            );
1043
+
1044
+        foreach ($vCard->children() as $property) {
1045
+            if(!in_array($property->name, self::$indexProperties)) {
1046
+                continue;
1047
+            }
1048
+            $preferred = 0;
1049
+            foreach($property->parameters as $parameter) {
1050
+                if ($parameter->name === 'TYPE' && strtoupper($parameter->getValue()) === 'PREF') {
1051
+                    $preferred = 1;
1052
+                    break;
1053
+                }
1054
+            }
1055
+            $query->setParameter('name', $property->name);
1056
+            $query->setParameter('value', substr($property->getValue(), 0, 254));
1057
+            $query->setParameter('preferred', $preferred);
1058
+            $query->execute();
1059
+        }
1060
+    }
1061
+
1062
+    /**
1063
+     * read vCard data into a vCard object
1064
+     *
1065
+     * @param string $cardData
1066
+     * @return VCard
1067
+     */
1068
+    protected function readCard($cardData) {
1069
+        return  Reader::read($cardData);
1070
+    }
1071
+
1072
+    /**
1073
+     * delete all properties from a given card
1074
+     *
1075
+     * @param int $addressBookId
1076
+     * @param int $cardId
1077
+     */
1078
+    protected function purgeProperties($addressBookId, $cardId) {
1079
+        $query = $this->db->getQueryBuilder();
1080
+        $query->delete($this->dbCardsPropertiesTable)
1081
+            ->where($query->expr()->eq('cardid', $query->createNamedParameter($cardId)))
1082
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1083
+        $query->execute();
1084
+    }
1085
+
1086
+    /**
1087
+     * get ID from a given contact
1088
+     *
1089
+     * @param int $addressBookId
1090
+     * @param string $uri
1091
+     * @return int
1092
+     */
1093
+    protected function getCardId($addressBookId, $uri) {
1094
+        $query = $this->db->getQueryBuilder();
1095
+        $query->select('id')->from($this->dbCardsTable)
1096
+            ->where($query->expr()->eq('uri', $query->createNamedParameter($uri)))
1097
+            ->andWhere($query->expr()->eq('addressbookid', $query->createNamedParameter($addressBookId)));
1098
+
1099
+        $result = $query->execute();
1100
+        $cardIds = $result->fetch();
1101
+        $result->closeCursor();
1102
+
1103
+        if (!isset($cardIds['id'])) {
1104
+            throw new \InvalidArgumentException('Card does not exists: ' . $uri);
1105
+        }
1106
+
1107
+        return (int)$cardIds['id'];
1108
+    }
1109
+
1110
+    /**
1111
+     * For shared address books the sharee is set in the ACL of the address book
1112
+     * @param $addressBookId
1113
+     * @param $acl
1114
+     * @return array
1115
+     */
1116
+    public function applyShareAcl($addressBookId, $acl) {
1117
+        return $this->sharingBackend->applyShareAcl($addressBookId, $acl);
1118
+    }
1119
+
1120
+    private function convertPrincipal($principalUri, $toV2) {
1121
+        if ($this->principalBackend->getPrincipalPrefix() === 'principals') {
1122
+            list(, $name) = \Sabre\Uri\split($principalUri);
1123
+            if ($toV2 === true) {
1124
+                return "principals/users/$name";
1125
+            }
1126
+            return "principals/$name";
1127
+        }
1128
+        return $principalUri;
1129
+    }
1130
+
1131
+    private function addOwnerPrincipal(&$addressbookInfo) {
1132
+        $ownerPrincipalKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_OWNCLOUD . '}owner-principal';
1133
+        $displaynameKey = '{' . \OCA\DAV\DAV\Sharing\Plugin::NS_NEXTCLOUD . '}owner-displayname';
1134
+        if (isset($addressbookInfo[$ownerPrincipalKey])) {
1135
+            $uri = $addressbookInfo[$ownerPrincipalKey];
1136
+        } else {
1137
+            $uri = $addressbookInfo['principaluri'];
1138
+        }
1139
+
1140
+        $principalInformation = $this->principalBackend->getPrincipalByPath($uri);
1141
+        if (isset($principalInformation['{DAV:}displayname'])) {
1142
+            $addressbookInfo[$displaynameKey] = $principalInformation['{DAV:}displayname'];
1143
+        }
1144
+    }
1145
+
1146
+    /**
1147
+     * Extract UID from vcard
1148
+     *
1149
+     * @param string $cardData the vcard raw data
1150
+     * @return string the uid
1151
+     * @throws BadRequest if no UID is available
1152
+     */
1153
+    private function getUID($cardData) {
1154
+        if ($cardData != '') {
1155
+            $vCard = Reader::read($cardData);
1156
+            if ($vCard->UID) {
1157
+                $uid = $vCard->UID->getValue();
1158
+                return $uid;
1159
+            }
1160
+            // should already be handled, but just in case
1161
+            throw new BadRequest('vCards on CardDAV servers MUST have a UID property');
1162
+        }
1163
+        // should already be handled, but just in case
1164
+        throw new BadRequest('vCard can not be empty');
1165
+    }
1166 1166
 }
Please login to merge, or discard this patch.