Passed
Pull Request — master (#1284)
by René
06:52 queued 03:10
created

Version0107Date20210101161105::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 3
Code Lines 2

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
eloc 2
c 1
b 0
f 0
dl 0
loc 3
rs 10
cc 1
nc 1
nop 2
1
<?php
2
/**
3
 * @copyright Copyright (c) 2017 René Gieling <[email protected]>
4
 *
5
 * @author René Gieling <[email protected]>
6
 *
7
 * @license GNU AGPL version 3 or any later version
8
 *
9
 *  This program is free software: you can redistribute it and/or modify
10
 *  it under the terms of the GNU Affero General Public License as
11
 *  published by the Free Software Foundation, either version 3 of the
12
 *  License, or (at your option) any later version.
13
 *
14
 *  This program is distributed in the hope that it will be useful,
15
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
16
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17
 *  GNU Affero General Public License for more details.
18
 *
19
 *  You should have received a copy of the GNU Affero General Public License
20
 *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
21
 *
22
 */
23
24
namespace OCA\Polls\Migration;
25
26
use OCP\DB\ISchemaWrapper;
27
use OCP\Migration\IOutput;
28
use OCP\IDBConnection;
29
use OCP\Migration\SimpleMigrationStep;
30
use Doctrine\DBAL\Schema\SchemaException;
31
use OCA\Polls\Db\SubscriptionMapper;
32
33
class Version0107Date20210101161105 extends SimpleMigrationStep {
34
35
	/** @var SubscriptionMapper */
36
	private $subscriptionMapper;
37
38
	/** @var IDBConnection */
39
	protected $connection;
40
41
	public function __construct(IDBConnection $connection, SubscriptionMapper $subscriptionMapper) {
42
		$this->connection = $connection;
43
		$this->subscriptionMapper = $subscriptionMapper;
44
	}
45
46
	public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) {
47
		$this->subscriptionMapper->removeDuplicates();
48
		/** @var ISchemaWrapper $schema */
49
		$schema = $schemaClosure();
50
51
		if ($schema->hasTable('polls_notif')) {
52
			$table = $schema->getTable('polls_notif');
53
54
			try {
55
				$table->addUniqueIndex(['poll_id', 'user_id'], 'UNIQ_subscription');
56
			} catch (SchemaException $e) {
57
				//catch silently, index is already present
58
			}
59
		}
60
		return $schema;
61
	}
62
}
63