Completed
Push — master ( d62417...7b2aa5 )
by René
10:14 queued 11s
created

SubscriptionMapper::findAll()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 7
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
cc 1
eloc 4
nc 1
nop 0
dl 0
loc 7
ccs 0
cts 5
cp 0
crap 2
rs 10
c 0
b 0
f 0
1
<?php
2
/**
3
 * @copyright Copyright (c) 2017 Vinzenz Rosenkranz <[email protected]>
4
 *
5
 * @author Vinzenz Rosenkranz <[email protected]>
6
 * @author René Gieling <[email protected]>
7
*
8
 * @license GNU AGPL version 3 or any later version
9
 *
10
 *  This program is free software: you can redistribute it and/or modify
11
 *  it under the terms of the GNU Affero General Public License as
12
 *  published by the Free Software Foundation, either version 3 of the
13
 *  License, or (at your option) any later version.
14
 *
15
 *  This program is distributed in the hope that it will be useful,
16
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
17
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18
 *  GNU Affero General Public License for more details.
19
 *
20
 *  You should have received a copy of the GNU Affero General Public License
21
 *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
22
 *
23
 */
24
25
namespace OCA\Polls\Db;
26
27
use OCP\DB\QueryBuilder\IQueryBuilder;
28
use OCP\IDBConnection;
29
use OCP\AppFramework\Db\QBMapper;
30
31
class SubscriptionMapper extends QBMapper {
32
33
	/**
34
	 * NotificationMapper constructor.
35
	 * @param IDBConnection $db
36
	 */
37 1
	public function __construct(IDBConnection $db) {
38 1
		parent::__construct($db, 'polls_notif', '\OCA\Polls\Db\Subscription');
39 1
	}
40
41
	/**
42
	 * @param int $pollId
43
	 * @throws \OCP\AppFramework\Db\DoesNotExistException if not found
44
	 * @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException if more than one result
45
	 * @return array
46
	 */
47
48
	 public function findAll() {
49
		 $qb = $this->db->getQueryBuilder();
50
51
		  $qb->select('*')
52
			 ->from($this->getTableName());
53
54
		  return $this->findEntities($qb);
55
	 }
56
57
	/**
58
	 * @param int $pollId
59
	 * @throws \OCP\AppFramework\Db\DoesNotExistException if not found
60
	 * @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException if more than one result
61
	 * @return array
62
	 */
63
64
	 public function findAllByPoll($pollId) {
65
		 $qb = $this->db->getQueryBuilder();
66
67
		  $qb->select('*')
68
			 ->from($this->getTableName())
69
			 ->where(
70
				 $qb->expr()->eq('poll_id', $qb->createNamedParameter($pollId, IQueryBuilder::PARAM_INT))
71
			 );
72
73
		  return $this->findEntities($qb);
74
	 }
75
76
	/**
77
	 * @param int $pollId
78
	 * @param string $userId
79
	 * @throws \OCP\AppFramework\Db\DoesNotExistException if not found
80
	 * @throws \OCP\AppFramework\Db\MultipleObjectsReturnedException if more than one result
81
	 * @return Notification
0 ignored issues
show
Bug introduced by
The type OCA\Polls\Db\Notification was not found. Maybe you did not declare it correctly or list all dependencies?

The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. excluded_paths: ["lib/*"], you can move it to the dependency path list as follows:

filter:
    dependency_paths: ["lib/*"]

For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths

Loading history...
82
	 */
83
	public function findByUserAndPoll($pollId, $userId) {
84
		$qb = $this->db->getQueryBuilder();
85
86
		 $qb->select('*')
87
			->from($this->getTableName())
88
			->where(
89
				$qb->expr()->eq('poll_id', $qb->createNamedParameter($pollId, IQueryBuilder::PARAM_INT))
90
			)
91
			->andWhere(
92
				$qb->expr()->eq('user_id', $qb->createNamedParameter($userId, IQueryBuilder::PARAM_STR))
93
			);
94
95
		 return $this->findEntity($qb);
96
	}
97
98
99
	/**
100
	 * @param int $pollId
101
	 */
102
	 public function unsubscribe($pollId, $currentUser) {
103
 		$qb = $this->db->getQueryBuilder();
104
105
 		$qb->delete($this->getTableName())
106
 		->where(
107
 			$qb->expr()->eq('poll_id', $qb->createNamedParameter($pollId, IQueryBuilder::PARAM_INT))
108
 		)
109
		->andWhere(
110
			$qb->expr()->eq('user_id', $qb->createNamedParameter($currentUser, IQueryBuilder::PARAM_STR))
111
		);
112
113
 		$qb->execute();
114
 	}
115
116
}
117