123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081 |
- <?php
- declare(strict_types=1);
- namespace OCA\ContactsInteraction\Db;
- use OCP\DB\QueryBuilder\IQueryBuilder;
- use OCP\IDBConnection;
- use OCP\IUser;
- use function is_resource;
- use function stream_get_contents;
- class CardSearchDao {
- public function __construct(
- private IDBConnection $db,
- ) {
- }
- public function findExisting(IUser $user,
- ?string $uid,
- ?string $email,
- ?string $cloudId): ?string {
- $addressbooksQuery = $this->db->getQueryBuilder();
- $cardQuery = $this->db->getQueryBuilder();
- $propQuery = $this->db->getQueryBuilder();
- $additionalWheres = [];
- if ($uid !== null) {
- $additionalWheres[] = $propQuery->expr()->andX(
- $propQuery->expr()->eq('name', $cardQuery->createNamedParameter('UID')),
- $propQuery->expr()->eq('value', $cardQuery->createNamedParameter($uid))
- );
- }
- if ($email !== null) {
- $additionalWheres[] = $propQuery->expr()->andX(
- $propQuery->expr()->eq('name', $cardQuery->createNamedParameter('EMAIL')),
- $propQuery->expr()->eq('value', $cardQuery->createNamedParameter($email))
- );
- }
- if ($cloudId !== null) {
- $additionalWheres[] = $propQuery->expr()->andX(
- $propQuery->expr()->eq('name', $cardQuery->createNamedParameter('CLOUD')),
- $propQuery->expr()->eq('value', $cardQuery->createNamedParameter($cloudId))
- );
- }
- $addressbooksQuery->selectDistinct('id')
- ->from('addressbooks')
- ->where($addressbooksQuery->expr()->eq('principaluri', $cardQuery->createNamedParameter('principals/users/' . $user->getUID())));
- $propQuery->selectDistinct('cardid')
- ->from('cards_properties')
- ->where($propQuery->expr()->in('addressbookid', $propQuery->createFunction($addressbooksQuery->getSQL()), IQueryBuilder::PARAM_INT_ARRAY))
- ->groupBy('cardid');
- if (!empty($additionalWheres)) {
- $propQuery->andWhere($propQuery->expr()->orX(...$additionalWheres));
- }
- $cardQuery->select('carddata')
- ->from('cards')
- ->where($cardQuery->expr()->in('id', $cardQuery->createFunction($propQuery->getSQL()), IQueryBuilder::PARAM_INT_ARRAY))
- ->andWhere($cardQuery->expr()->in('addressbookid', $cardQuery->createFunction($addressbooksQuery->getSQL()), IQueryBuilder::PARAM_INT_ARRAY))
- ->setMaxResults(1);
- $result = $cardQuery->executeQuery();
-
- $card = $result->fetchOne();
- if ($card === false) {
- return null;
- }
- if (is_resource($card)) {
- return stream_get_contents($card);
- }
- return $card;
- }
- }
|