@@ -27,72 +27,72 @@ |
||
27 | 27 | |
28 | 28 | class FileDeleted implements ISetting { |
29 | 29 | |
30 | - /** @var IL10N */ |
|
31 | - protected $l; |
|
30 | + /** @var IL10N */ |
|
31 | + protected $l; |
|
32 | 32 | |
33 | - /** |
|
34 | - * @param IL10N $l |
|
35 | - */ |
|
36 | - public function __construct(IL10N $l) { |
|
37 | - $this->l = $l; |
|
38 | - } |
|
33 | + /** |
|
34 | + * @param IL10N $l |
|
35 | + */ |
|
36 | + public function __construct(IL10N $l) { |
|
37 | + $this->l = $l; |
|
38 | + } |
|
39 | 39 | |
40 | - /** |
|
41 | - * @return string Lowercase a-z and underscore only identifier |
|
42 | - * @since 11.0.0 |
|
43 | - */ |
|
44 | - public function getIdentifier() { |
|
45 | - return 'file_deleted'; |
|
46 | - } |
|
40 | + /** |
|
41 | + * @return string Lowercase a-z and underscore only identifier |
|
42 | + * @since 11.0.0 |
|
43 | + */ |
|
44 | + public function getIdentifier() { |
|
45 | + return 'file_deleted'; |
|
46 | + } |
|
47 | 47 | |
48 | - /** |
|
49 | - * @return string A translated string |
|
50 | - * @since 11.0.0 |
|
51 | - */ |
|
52 | - public function getName() { |
|
53 | - return $this->l->t('A file or folder has been <strong>deleted</strong>'); |
|
54 | - } |
|
48 | + /** |
|
49 | + * @return string A translated string |
|
50 | + * @since 11.0.0 |
|
51 | + */ |
|
52 | + public function getName() { |
|
53 | + return $this->l->t('A file or folder has been <strong>deleted</strong>'); |
|
54 | + } |
|
55 | 55 | |
56 | - /** |
|
57 | - * @return int whether the filter should be rather on the top or bottom of |
|
58 | - * the admin section. The filters are arranged in ascending order of the |
|
59 | - * priority values. It is required to return a value between 0 and 100. |
|
60 | - * @since 11.0.0 |
|
61 | - */ |
|
62 | - public function getPriority() { |
|
63 | - return 3; |
|
64 | - } |
|
56 | + /** |
|
57 | + * @return int whether the filter should be rather on the top or bottom of |
|
58 | + * the admin section. The filters are arranged in ascending order of the |
|
59 | + * priority values. It is required to return a value between 0 and 100. |
|
60 | + * @since 11.0.0 |
|
61 | + */ |
|
62 | + public function getPriority() { |
|
63 | + return 3; |
|
64 | + } |
|
65 | 65 | |
66 | - /** |
|
67 | - * @return bool True when the option can be changed for the stream |
|
68 | - * @since 11.0.0 |
|
69 | - */ |
|
70 | - public function canChangeStream() { |
|
71 | - return true; |
|
72 | - } |
|
66 | + /** |
|
67 | + * @return bool True when the option can be changed for the stream |
|
68 | + * @since 11.0.0 |
|
69 | + */ |
|
70 | + public function canChangeStream() { |
|
71 | + return true; |
|
72 | + } |
|
73 | 73 | |
74 | - /** |
|
75 | - * @return bool True when the option can be changed for the stream |
|
76 | - * @since 11.0.0 |
|
77 | - */ |
|
78 | - public function isDefaultEnabledStream() { |
|
79 | - return true; |
|
80 | - } |
|
74 | + /** |
|
75 | + * @return bool True when the option can be changed for the stream |
|
76 | + * @since 11.0.0 |
|
77 | + */ |
|
78 | + public function isDefaultEnabledStream() { |
|
79 | + return true; |
|
80 | + } |
|
81 | 81 | |
82 | - /** |
|
83 | - * @return bool True when the option can be changed for the mail |
|
84 | - * @since 11.0.0 |
|
85 | - */ |
|
86 | - public function canChangeMail() { |
|
87 | - return true; |
|
88 | - } |
|
82 | + /** |
|
83 | + * @return bool True when the option can be changed for the mail |
|
84 | + * @since 11.0.0 |
|
85 | + */ |
|
86 | + public function canChangeMail() { |
|
87 | + return true; |
|
88 | + } |
|
89 | 89 | |
90 | - /** |
|
91 | - * @return bool True when the option can be changed for the stream |
|
92 | - * @since 11.0.0 |
|
93 | - */ |
|
94 | - public function isDefaultEnabledMail() { |
|
95 | - return false; |
|
96 | - } |
|
90 | + /** |
|
91 | + * @return bool True when the option can be changed for the stream |
|
92 | + * @since 11.0.0 |
|
93 | + */ |
|
94 | + public function isDefaultEnabledMail() { |
|
95 | + return false; |
|
96 | + } |
|
97 | 97 | } |
98 | 98 |
@@ -27,72 +27,72 @@ |
||
27 | 27 | |
28 | 28 | class FileRestored implements ISetting { |
29 | 29 | |
30 | - /** @var IL10N */ |
|
31 | - protected $l; |
|
30 | + /** @var IL10N */ |
|
31 | + protected $l; |
|
32 | 32 | |
33 | - /** |
|
34 | - * @param IL10N $l |
|
35 | - */ |
|
36 | - public function __construct(IL10N $l) { |
|
37 | - $this->l = $l; |
|
38 | - } |
|
33 | + /** |
|
34 | + * @param IL10N $l |
|
35 | + */ |
|
36 | + public function __construct(IL10N $l) { |
|
37 | + $this->l = $l; |
|
38 | + } |
|
39 | 39 | |
40 | - /** |
|
41 | - * @return string Lowercase a-z and underscore only identifier |
|
42 | - * @since 11.0.0 |
|
43 | - */ |
|
44 | - public function getIdentifier() { |
|
45 | - return 'file_restored'; |
|
46 | - } |
|
40 | + /** |
|
41 | + * @return string Lowercase a-z and underscore only identifier |
|
42 | + * @since 11.0.0 |
|
43 | + */ |
|
44 | + public function getIdentifier() { |
|
45 | + return 'file_restored'; |
|
46 | + } |
|
47 | 47 | |
48 | - /** |
|
49 | - * @return string A translated string |
|
50 | - * @since 11.0.0 |
|
51 | - */ |
|
52 | - public function getName() { |
|
53 | - return $this->l->t('A file or folder has been <strong>restored</strong>'); |
|
54 | - } |
|
48 | + /** |
|
49 | + * @return string A translated string |
|
50 | + * @since 11.0.0 |
|
51 | + */ |
|
52 | + public function getName() { |
|
53 | + return $this->l->t('A file or folder has been <strong>restored</strong>'); |
|
54 | + } |
|
55 | 55 | |
56 | - /** |
|
57 | - * @return int whether the filter should be rather on the top or bottom of |
|
58 | - * the admin section. The filters are arranged in ascending order of the |
|
59 | - * priority values. It is required to return a value between 0 and 100. |
|
60 | - * @since 11.0.0 |
|
61 | - */ |
|
62 | - public function getPriority() { |
|
63 | - return 4; |
|
64 | - } |
|
56 | + /** |
|
57 | + * @return int whether the filter should be rather on the top or bottom of |
|
58 | + * the admin section. The filters are arranged in ascending order of the |
|
59 | + * priority values. It is required to return a value between 0 and 100. |
|
60 | + * @since 11.0.0 |
|
61 | + */ |
|
62 | + public function getPriority() { |
|
63 | + return 4; |
|
64 | + } |
|
65 | 65 | |
66 | - /** |
|
67 | - * @return bool True when the option can be changed for the stream |
|
68 | - * @since 11.0.0 |
|
69 | - */ |
|
70 | - public function canChangeStream() { |
|
71 | - return true; |
|
72 | - } |
|
66 | + /** |
|
67 | + * @return bool True when the option can be changed for the stream |
|
68 | + * @since 11.0.0 |
|
69 | + */ |
|
70 | + public function canChangeStream() { |
|
71 | + return true; |
|
72 | + } |
|
73 | 73 | |
74 | - /** |
|
75 | - * @return bool True when the option can be changed for the stream |
|
76 | - * @since 11.0.0 |
|
77 | - */ |
|
78 | - public function isDefaultEnabledStream() { |
|
79 | - return true; |
|
80 | - } |
|
74 | + /** |
|
75 | + * @return bool True when the option can be changed for the stream |
|
76 | + * @since 11.0.0 |
|
77 | + */ |
|
78 | + public function isDefaultEnabledStream() { |
|
79 | + return true; |
|
80 | + } |
|
81 | 81 | |
82 | - /** |
|
83 | - * @return bool True when the option can be changed for the mail |
|
84 | - * @since 11.0.0 |
|
85 | - */ |
|
86 | - public function canChangeMail() { |
|
87 | - return true; |
|
88 | - } |
|
82 | + /** |
|
83 | + * @return bool True when the option can be changed for the mail |
|
84 | + * @since 11.0.0 |
|
85 | + */ |
|
86 | + public function canChangeMail() { |
|
87 | + return true; |
|
88 | + } |
|
89 | 89 | |
90 | - /** |
|
91 | - * @return bool True when the option can be changed for the stream |
|
92 | - * @since 11.0.0 |
|
93 | - */ |
|
94 | - public function isDefaultEnabledMail() { |
|
95 | - return false; |
|
96 | - } |
|
90 | + /** |
|
91 | + * @return bool True when the option can be changed for the stream |
|
92 | + * @since 11.0.0 |
|
93 | + */ |
|
94 | + public function isDefaultEnabledMail() { |
|
95 | + return false; |
|
96 | + } |
|
97 | 97 | } |
98 | 98 |
@@ -27,55 +27,55 @@ |
||
27 | 27 | use OCP\DB\QueryBuilder\IQueryFunction; |
28 | 28 | |
29 | 29 | class QuoteHelper { |
30 | - /** |
|
31 | - * @param array|string|ILiteral|IParameter|IQueryFunction $strings string, Literal or Parameter |
|
32 | - * @return array|string |
|
33 | - */ |
|
34 | - public function quoteColumnNames($strings) { |
|
35 | - if (!is_array($strings)) { |
|
36 | - return $this->quoteColumnName($strings); |
|
37 | - } |
|
30 | + /** |
|
31 | + * @param array|string|ILiteral|IParameter|IQueryFunction $strings string, Literal or Parameter |
|
32 | + * @return array|string |
|
33 | + */ |
|
34 | + public function quoteColumnNames($strings) { |
|
35 | + if (!is_array($strings)) { |
|
36 | + return $this->quoteColumnName($strings); |
|
37 | + } |
|
38 | 38 | |
39 | - $return = []; |
|
40 | - foreach ($strings as $string) { |
|
41 | - $return[] = $this->quoteColumnName($string); |
|
42 | - } |
|
39 | + $return = []; |
|
40 | + foreach ($strings as $string) { |
|
41 | + $return[] = $this->quoteColumnName($string); |
|
42 | + } |
|
43 | 43 | |
44 | - return $return; |
|
45 | - } |
|
44 | + return $return; |
|
45 | + } |
|
46 | 46 | |
47 | - /** |
|
48 | - * @param string|ILiteral|IParameter|IQueryFunction $string string, Literal or Parameter |
|
49 | - * @return string |
|
50 | - */ |
|
51 | - public function quoteColumnName($string) { |
|
52 | - if ($string instanceof IParameter || $string instanceof ILiteral || $string instanceof IQueryFunction) { |
|
53 | - return (string) $string; |
|
54 | - } |
|
47 | + /** |
|
48 | + * @param string|ILiteral|IParameter|IQueryFunction $string string, Literal or Parameter |
|
49 | + * @return string |
|
50 | + */ |
|
51 | + public function quoteColumnName($string) { |
|
52 | + if ($string instanceof IParameter || $string instanceof ILiteral || $string instanceof IQueryFunction) { |
|
53 | + return (string) $string; |
|
54 | + } |
|
55 | 55 | |
56 | - if ($string === null || $string === 'null' || $string === '*') { |
|
57 | - return $string; |
|
58 | - } |
|
56 | + if ($string === null || $string === 'null' || $string === '*') { |
|
57 | + return $string; |
|
58 | + } |
|
59 | 59 | |
60 | - if (!is_string($string)) { |
|
61 | - throw new \InvalidArgumentException('Only strings, Literals and Parameters are allowed'); |
|
62 | - } |
|
60 | + if (!is_string($string)) { |
|
61 | + throw new \InvalidArgumentException('Only strings, Literals and Parameters are allowed'); |
|
62 | + } |
|
63 | 63 | |
64 | - $string = str_replace(' AS ', ' as ', $string); |
|
65 | - if (substr_count($string, ' as ')) { |
|
66 | - return implode(' as ', array_map([$this, 'quoteColumnName'], explode(' as ', $string, 2))); |
|
67 | - } |
|
64 | + $string = str_replace(' AS ', ' as ', $string); |
|
65 | + if (substr_count($string, ' as ')) { |
|
66 | + return implode(' as ', array_map([$this, 'quoteColumnName'], explode(' as ', $string, 2))); |
|
67 | + } |
|
68 | 68 | |
69 | - if (substr_count($string, '.')) { |
|
70 | - list($alias, $columnName) = explode('.', $string, 2); |
|
69 | + if (substr_count($string, '.')) { |
|
70 | + list($alias, $columnName) = explode('.', $string, 2); |
|
71 | 71 | |
72 | - if ($columnName === '*') { |
|
73 | - return '`' . $alias . '`.*'; |
|
74 | - } |
|
72 | + if ($columnName === '*') { |
|
73 | + return '`' . $alias . '`.*'; |
|
74 | + } |
|
75 | 75 | |
76 | - return '`' . $alias . '`.`' . $columnName . '`'; |
|
77 | - } |
|
76 | + return '`' . $alias . '`.`' . $columnName . '`'; |
|
77 | + } |
|
78 | 78 | |
79 | - return '`' . $string . '`'; |
|
80 | - } |
|
79 | + return '`' . $string . '`'; |
|
80 | + } |
|
81 | 81 | } |
@@ -31,89 +31,89 @@ |
||
31 | 31 | |
32 | 32 | class OldGroupMembershipShares implements IRepairStep { |
33 | 33 | |
34 | - /** @var \OCP\IDBConnection */ |
|
35 | - protected $connection; |
|
36 | - |
|
37 | - /** @var \OCP\IGroupManager */ |
|
38 | - protected $groupManager; |
|
39 | - |
|
40 | - /** |
|
41 | - * @var array [gid => [uid => (bool)]] |
|
42 | - */ |
|
43 | - protected $memberships; |
|
44 | - |
|
45 | - /** |
|
46 | - * @param IDBConnection $connection |
|
47 | - * @param IGroupManager $groupManager |
|
48 | - */ |
|
49 | - public function __construct(IDBConnection $connection, IGroupManager $groupManager) { |
|
50 | - $this->connection = $connection; |
|
51 | - $this->groupManager = $groupManager; |
|
52 | - } |
|
53 | - |
|
54 | - /** |
|
55 | - * Returns the step's name |
|
56 | - * |
|
57 | - * @return string |
|
58 | - */ |
|
59 | - public function getName() { |
|
60 | - return 'Remove shares of old group memberships'; |
|
61 | - } |
|
62 | - |
|
63 | - /** |
|
64 | - * Run repair step. |
|
65 | - * Must throw exception on error. |
|
66 | - * |
|
67 | - * @throws \Exception in case of failure |
|
68 | - * @suppress SqlInjectionChecker |
|
69 | - */ |
|
70 | - public function run(IOutput $output) { |
|
71 | - $deletedEntries = 0; |
|
72 | - |
|
73 | - $query = $this->connection->getQueryBuilder(); |
|
74 | - $query->select('s1.id')->selectAlias('s1.share_with', 'user')->selectAlias('s2.share_with', 'group') |
|
75 | - ->from('share', 's1') |
|
76 | - ->where($query->expr()->isNotNull('s1.parent')) |
|
77 | - // \OC\Share\Constant::$shareTypeGroupUserUnique === 2 |
|
78 | - ->andWhere($query->expr()->eq('s1.share_type', $query->expr()->literal(2))) |
|
79 | - ->andWhere($query->expr()->isNotNull('s2.id')) |
|
80 | - ->andWhere($query->expr()->eq('s2.share_type', $query->expr()->literal(Share::SHARE_TYPE_GROUP))) |
|
81 | - ->leftJoin('s1', 'share', 's2', $query->expr()->eq('s1.parent', 's2.id')); |
|
82 | - |
|
83 | - $deleteQuery = $this->connection->getQueryBuilder(); |
|
84 | - $deleteQuery->delete('share') |
|
85 | - ->where($query->expr()->eq('id', $deleteQuery->createParameter('share'))); |
|
86 | - |
|
87 | - $result = $query->execute(); |
|
88 | - while ($row = $result->fetch()) { |
|
89 | - if (!$this->isMember($row['group'], $row['user'])) { |
|
90 | - $deletedEntries += $deleteQuery->setParameter('share', (int) $row['id']) |
|
91 | - ->execute(); |
|
92 | - } |
|
93 | - } |
|
94 | - $result->closeCursor(); |
|
95 | - |
|
96 | - if ($deletedEntries) { |
|
97 | - $output->info('Removed ' . $deletedEntries . ' shares where user is not a member of the group anymore'); |
|
98 | - } |
|
99 | - } |
|
100 | - |
|
101 | - /** |
|
102 | - * @param string $gid |
|
103 | - * @param string $uid |
|
104 | - * @return bool |
|
105 | - */ |
|
106 | - protected function isMember($gid, $uid) { |
|
107 | - if (isset($this->memberships[$gid][$uid])) { |
|
108 | - return $this->memberships[$gid][$uid]; |
|
109 | - } |
|
110 | - |
|
111 | - $isMember = $this->groupManager->isInGroup($uid, $gid); |
|
112 | - if (!isset($this->memberships[$gid])) { |
|
113 | - $this->memberships[$gid] = []; |
|
114 | - } |
|
115 | - $this->memberships[$gid][$uid] = $isMember; |
|
116 | - |
|
117 | - return $isMember; |
|
118 | - } |
|
34 | + /** @var \OCP\IDBConnection */ |
|
35 | + protected $connection; |
|
36 | + |
|
37 | + /** @var \OCP\IGroupManager */ |
|
38 | + protected $groupManager; |
|
39 | + |
|
40 | + /** |
|
41 | + * @var array [gid => [uid => (bool)]] |
|
42 | + */ |
|
43 | + protected $memberships; |
|
44 | + |
|
45 | + /** |
|
46 | + * @param IDBConnection $connection |
|
47 | + * @param IGroupManager $groupManager |
|
48 | + */ |
|
49 | + public function __construct(IDBConnection $connection, IGroupManager $groupManager) { |
|
50 | + $this->connection = $connection; |
|
51 | + $this->groupManager = $groupManager; |
|
52 | + } |
|
53 | + |
|
54 | + /** |
|
55 | + * Returns the step's name |
|
56 | + * |
|
57 | + * @return string |
|
58 | + */ |
|
59 | + public function getName() { |
|
60 | + return 'Remove shares of old group memberships'; |
|
61 | + } |
|
62 | + |
|
63 | + /** |
|
64 | + * Run repair step. |
|
65 | + * Must throw exception on error. |
|
66 | + * |
|
67 | + * @throws \Exception in case of failure |
|
68 | + * @suppress SqlInjectionChecker |
|
69 | + */ |
|
70 | + public function run(IOutput $output) { |
|
71 | + $deletedEntries = 0; |
|
72 | + |
|
73 | + $query = $this->connection->getQueryBuilder(); |
|
74 | + $query->select('s1.id')->selectAlias('s1.share_with', 'user')->selectAlias('s2.share_with', 'group') |
|
75 | + ->from('share', 's1') |
|
76 | + ->where($query->expr()->isNotNull('s1.parent')) |
|
77 | + // \OC\Share\Constant::$shareTypeGroupUserUnique === 2 |
|
78 | + ->andWhere($query->expr()->eq('s1.share_type', $query->expr()->literal(2))) |
|
79 | + ->andWhere($query->expr()->isNotNull('s2.id')) |
|
80 | + ->andWhere($query->expr()->eq('s2.share_type', $query->expr()->literal(Share::SHARE_TYPE_GROUP))) |
|
81 | + ->leftJoin('s1', 'share', 's2', $query->expr()->eq('s1.parent', 's2.id')); |
|
82 | + |
|
83 | + $deleteQuery = $this->connection->getQueryBuilder(); |
|
84 | + $deleteQuery->delete('share') |
|
85 | + ->where($query->expr()->eq('id', $deleteQuery->createParameter('share'))); |
|
86 | + |
|
87 | + $result = $query->execute(); |
|
88 | + while ($row = $result->fetch()) { |
|
89 | + if (!$this->isMember($row['group'], $row['user'])) { |
|
90 | + $deletedEntries += $deleteQuery->setParameter('share', (int) $row['id']) |
|
91 | + ->execute(); |
|
92 | + } |
|
93 | + } |
|
94 | + $result->closeCursor(); |
|
95 | + |
|
96 | + if ($deletedEntries) { |
|
97 | + $output->info('Removed ' . $deletedEntries . ' shares where user is not a member of the group anymore'); |
|
98 | + } |
|
99 | + } |
|
100 | + |
|
101 | + /** |
|
102 | + * @param string $gid |
|
103 | + * @param string $uid |
|
104 | + * @return bool |
|
105 | + */ |
|
106 | + protected function isMember($gid, $uid) { |
|
107 | + if (isset($this->memberships[$gid][$uid])) { |
|
108 | + return $this->memberships[$gid][$uid]; |
|
109 | + } |
|
110 | + |
|
111 | + $isMember = $this->groupManager->isInGroup($uid, $gid); |
|
112 | + if (!isset($this->memberships[$gid])) { |
|
113 | + $this->memberships[$gid] = []; |
|
114 | + } |
|
115 | + $this->memberships[$gid][$uid] = $isMember; |
|
116 | + |
|
117 | + return $isMember; |
|
118 | + } |
|
119 | 119 | } |
@@ -29,39 +29,39 @@ |
||
29 | 29 | |
30 | 30 | class ConfigController extends OCSController { |
31 | 31 | |
32 | - /** @var IConfig */ |
|
33 | - private $config; |
|
32 | + /** @var IConfig */ |
|
33 | + private $config; |
|
34 | 34 | |
35 | - /** |
|
36 | - * @param string $appName |
|
37 | - * @param IRequest $request |
|
38 | - * @param IConfig $config |
|
39 | - */ |
|
40 | - public function __construct($appName, |
|
41 | - IRequest $request, |
|
42 | - IConfig $config) { |
|
43 | - parent::__construct($appName, $request); |
|
44 | - $this->config = $config; |
|
45 | - } |
|
35 | + /** |
|
36 | + * @param string $appName |
|
37 | + * @param IRequest $request |
|
38 | + * @param IConfig $config |
|
39 | + */ |
|
40 | + public function __construct($appName, |
|
41 | + IRequest $request, |
|
42 | + IConfig $config) { |
|
43 | + parent::__construct($appName, $request); |
|
44 | + $this->config = $config; |
|
45 | + } |
|
46 | 46 | |
47 | - /** |
|
48 | - * @param string $appid |
|
49 | - * @param string $configkey |
|
50 | - * @param string $value |
|
51 | - * @return DataResponse |
|
52 | - */ |
|
53 | - public function setAppValue($appid, $configkey, $value) { |
|
54 | - $this->config->setAppValue($appid, $configkey, $value); |
|
55 | - return new DataResponse(); |
|
56 | - } |
|
47 | + /** |
|
48 | + * @param string $appid |
|
49 | + * @param string $configkey |
|
50 | + * @param string $value |
|
51 | + * @return DataResponse |
|
52 | + */ |
|
53 | + public function setAppValue($appid, $configkey, $value) { |
|
54 | + $this->config->setAppValue($appid, $configkey, $value); |
|
55 | + return new DataResponse(); |
|
56 | + } |
|
57 | 57 | |
58 | - /** |
|
59 | - * @param string $appid |
|
60 | - * @param string $configkey |
|
61 | - * @return DataResponse |
|
62 | - */ |
|
63 | - public function deleteAppValue($appid, $configkey) { |
|
64 | - $this->config->deleteAppValue($appid, $configkey); |
|
65 | - return new DataResponse(); |
|
66 | - } |
|
58 | + /** |
|
59 | + * @param string $appid |
|
60 | + * @param string $configkey |
|
61 | + * @return DataResponse |
|
62 | + */ |
|
63 | + public function deleteAppValue($appid, $configkey) { |
|
64 | + $this->config->deleteAppValue($appid, $configkey); |
|
65 | + return new DataResponse(); |
|
66 | + } |
|
67 | 67 | } |
@@ -33,12 +33,12 @@ |
||
33 | 33 | */ |
34 | 34 | interface ICallbackResponse { |
35 | 35 | |
36 | - /** |
|
37 | - * Outputs the content that should be printed |
|
38 | - * |
|
39 | - * @param IOutput $output a small wrapper that handles output |
|
40 | - * @since 8.1.0 |
|
41 | - */ |
|
42 | - public function callback(IOutput $output); |
|
36 | + /** |
|
37 | + * Outputs the content that should be printed |
|
38 | + * |
|
39 | + * @param IOutput $output a small wrapper that handles output |
|
40 | + * @since 8.1.0 |
|
41 | + */ |
|
42 | + public function callback(IOutput $output); |
|
43 | 43 | |
44 | 44 | } |
@@ -25,16 +25,16 @@ |
||
25 | 25 | |
26 | 26 | class Exception extends \Exception { |
27 | 27 | |
28 | - /** @var Result */ |
|
29 | - private $result; |
|
28 | + /** @var Result */ |
|
29 | + private $result; |
|
30 | 30 | |
31 | - public function __construct(Result $result) { |
|
32 | - parent::__construct(); |
|
33 | - $this->result = $result; |
|
34 | - } |
|
31 | + public function __construct(Result $result) { |
|
32 | + parent::__construct(); |
|
33 | + $this->result = $result; |
|
34 | + } |
|
35 | 35 | |
36 | - public function getResult() { |
|
37 | - return $this->result; |
|
38 | - } |
|
36 | + public function getResult() { |
|
37 | + return $this->result; |
|
38 | + } |
|
39 | 39 | |
40 | 40 | } |
@@ -32,26 +32,26 @@ |
||
32 | 32 | * @package OC\BackgroundJob |
33 | 33 | */ |
34 | 34 | abstract class TimedJob extends Job { |
35 | - protected $interval = 0; |
|
35 | + protected $interval = 0; |
|
36 | 36 | |
37 | - /** |
|
38 | - * set the interval for the job |
|
39 | - * |
|
40 | - * @param int $interval |
|
41 | - */ |
|
42 | - public function setInterval($interval) { |
|
43 | - $this->interval = $interval; |
|
44 | - } |
|
37 | + /** |
|
38 | + * set the interval for the job |
|
39 | + * |
|
40 | + * @param int $interval |
|
41 | + */ |
|
42 | + public function setInterval($interval) { |
|
43 | + $this->interval = $interval; |
|
44 | + } |
|
45 | 45 | |
46 | - /** |
|
47 | - * run the job if |
|
48 | - * |
|
49 | - * @param JobList $jobList |
|
50 | - * @param ILogger|null $logger |
|
51 | - */ |
|
52 | - public function execute($jobList, ILogger $logger = null) { |
|
53 | - if ((time() - $this->lastRun) > $this->interval) { |
|
54 | - parent::execute($jobList, $logger); |
|
55 | - } |
|
56 | - } |
|
46 | + /** |
|
47 | + * run the job if |
|
48 | + * |
|
49 | + * @param JobList $jobList |
|
50 | + * @param ILogger|null $logger |
|
51 | + */ |
|
52 | + public function execute($jobList, ILogger $logger = null) { |
|
53 | + if ((time() - $this->lastRun) > $this->interval) { |
|
54 | + parent::execute($jobList, $logger); |
|
55 | + } |
|
56 | + } |
|
57 | 57 | } |
@@ -32,14 +32,14 @@ |
||
32 | 32 | * @package OC\BackgroundJob |
33 | 33 | */ |
34 | 34 | abstract class QueuedJob extends Job { |
35 | - /** |
|
36 | - * run the job, then remove it from the joblist |
|
37 | - * |
|
38 | - * @param JobList $jobList |
|
39 | - * @param ILogger|null $logger |
|
40 | - */ |
|
41 | - public function execute($jobList, ILogger $logger = null) { |
|
42 | - $jobList->remove($this, $this->argument); |
|
43 | - parent::execute($jobList, $logger); |
|
44 | - } |
|
35 | + /** |
|
36 | + * run the job, then remove it from the joblist |
|
37 | + * |
|
38 | + * @param JobList $jobList |
|
39 | + * @param ILogger|null $logger |
|
40 | + */ |
|
41 | + public function execute($jobList, ILogger $logger = null) { |
|
42 | + $jobList->remove($this, $this->argument); |
|
43 | + parent::execute($jobList, $logger); |
|
44 | + } |
|
45 | 45 | } |