*/ class RecentContactMapper extends QBMapper { public const TABLE_NAME = 'recent_contact'; public function __construct(IDBConnection $db) { parent::__construct($db, self::TABLE_NAME); } /** * @return RecentContact[] */ public function findAll(string $uid): array { $qb = $this->db->getQueryBuilder(); $select = $qb ->select('*') ->from($this->getTableName()) ->where($qb->expr()->eq('actor_uid', $qb->createNamedParameter($uid))); return $this->findEntities($select); } /** * @throws DoesNotExistException */ public function find(string $uid, int $id): RecentContact { $qb = $this->db->getQueryBuilder(); $select = $qb ->select('*') ->from($this->getTableName()) ->where($qb->expr()->eq('id', $qb->createNamedParameter($id, $qb::PARAM_INT))) ->andWhere($qb->expr()->eq('actor_uid', $qb->createNamedParameter($uid))); return $this->findEntity($select); } /** * @return RecentContact[] */ public function findMatch(IUser $user, ?string $uid, ?string $email, ?string $cloudId): array { $qb = $this->db->getQueryBuilder(); $or = $qb->expr()->orX(); if ($uid !== null) { $or->add($qb->expr()->eq('uid', $qb->createNamedParameter($uid))); } if ($email !== null) { $or->add($qb->expr()->eq('email', $qb->createNamedParameter($email))); } if ($cloudId !== null) { $or->add($qb->expr()->eq('federated_cloud_id', $qb->createNamedParameter($cloudId))); } $select = $qb ->select('*') ->from($this->getTableName()) ->where($or) ->andWhere($qb->expr()->eq('actor_uid', $qb->createNamedParameter($user->getUID()))); return $this->findEntities($select); } public function findLastUpdatedForUserId(string $uid): ?int { $qb = $this->db->getQueryBuilder(); $select = $qb ->select('last_contact') ->from($this->getTableName()) ->where($qb->expr()->eq('actor_uid', $qb->createNamedParameter($uid))) ->orderBy('last_contact', 'DESC') ->setMaxResults(1); $cursor = $select->executeQuery(); $row = $cursor->fetch(); if ($row === false) { return null; } return (int)$row['last_contact']; } public function cleanUp(int $olderThan): void { $qb = $this->db->getQueryBuilder(); $delete = $qb ->delete($this->getTableName()) ->where($qb->expr()->lt('last_contact', $qb->createNamedParameter($olderThan))); $delete->executeStatement(); } }