@@ -29,59 +29,59 @@ |
||
29 | 29 | |
30 | 30 | class Filter implements IFilter { |
31 | 31 | |
32 | - /** @var IL10N */ |
|
33 | - protected $l; |
|
32 | + /** @var IL10N */ |
|
33 | + protected $l; |
|
34 | 34 | |
35 | - /** @var IURLGenerator */ |
|
36 | - protected $url; |
|
35 | + /** @var IURLGenerator */ |
|
36 | + protected $url; |
|
37 | 37 | |
38 | - public function __construct(IL10N $l, IURLGenerator $url) { |
|
39 | - $this->l = $l; |
|
40 | - $this->url = $url; |
|
41 | - } |
|
38 | + public function __construct(IL10N $l, IURLGenerator $url) { |
|
39 | + $this->l = $l; |
|
40 | + $this->url = $url; |
|
41 | + } |
|
42 | 42 | |
43 | - /** |
|
44 | - * @return string Lowercase a-z and underscore only identifier |
|
45 | - */ |
|
46 | - public function getIdentifier(): string { |
|
47 | - return 'contacts'; |
|
48 | - } |
|
43 | + /** |
|
44 | + * @return string Lowercase a-z and underscore only identifier |
|
45 | + */ |
|
46 | + public function getIdentifier(): string { |
|
47 | + return 'contacts'; |
|
48 | + } |
|
49 | 49 | |
50 | - /** |
|
51 | - * @return string A translated string |
|
52 | - */ |
|
53 | - public function getName(): string { |
|
54 | - return $this->l->t('Contacts'); |
|
55 | - } |
|
50 | + /** |
|
51 | + * @return string A translated string |
|
52 | + */ |
|
53 | + public function getName(): string { |
|
54 | + return $this->l->t('Contacts'); |
|
55 | + } |
|
56 | 56 | |
57 | - /** |
|
58 | - * @return int whether the filter should be rather on the top or bottom of |
|
59 | - * the admin section. The filters are arranged in ascending order of the |
|
60 | - * priority values. It is required to return a value between 0 and 100. |
|
61 | - */ |
|
62 | - public function getPriority(): int { |
|
63 | - return 40; |
|
64 | - } |
|
57 | + /** |
|
58 | + * @return int whether the filter should be rather on the top or bottom of |
|
59 | + * the admin section. The filters are arranged in ascending order of the |
|
60 | + * priority values. It is required to return a value between 0 and 100. |
|
61 | + */ |
|
62 | + public function getPriority(): int { |
|
63 | + return 40; |
|
64 | + } |
|
65 | 65 | |
66 | - /** |
|
67 | - * @return string Full URL to an icon, empty string when none is given |
|
68 | - */ |
|
69 | - public function getIcon(): string { |
|
70 | - return $this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts.svg')); |
|
71 | - } |
|
66 | + /** |
|
67 | + * @return string Full URL to an icon, empty string when none is given |
|
68 | + */ |
|
69 | + public function getIcon(): string { |
|
70 | + return $this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts.svg')); |
|
71 | + } |
|
72 | 72 | |
73 | - /** |
|
74 | - * @param string[] $types |
|
75 | - * @return string[] An array of allowed apps from which activities should be displayed |
|
76 | - */ |
|
77 | - public function filterTypes(array $types): array { |
|
78 | - return array_intersect(['contacts'], $types); |
|
79 | - } |
|
73 | + /** |
|
74 | + * @param string[] $types |
|
75 | + * @return string[] An array of allowed apps from which activities should be displayed |
|
76 | + */ |
|
77 | + public function filterTypes(array $types): array { |
|
78 | + return array_intersect(['contacts'], $types); |
|
79 | + } |
|
80 | 80 | |
81 | - /** |
|
82 | - * @return string[] An array of allowed apps from which activities should be displayed |
|
83 | - */ |
|
84 | - public function allowedApps(): array { |
|
85 | - return []; |
|
86 | - } |
|
81 | + /** |
|
82 | + * @return string[] An array of allowed apps from which activities should be displayed |
|
83 | + */ |
|
84 | + public function allowedApps(): array { |
|
85 | + return []; |
|
86 | + } |
|
87 | 87 | } |
@@ -35,157 +35,157 @@ |
||
35 | 35 | use OCP\L10N\IFactory; |
36 | 36 | |
37 | 37 | class Addressbook extends Base { |
38 | - public const SUBJECT_ADD = 'addressbook_add'; |
|
39 | - public const SUBJECT_UPDATE = 'addressbook_update'; |
|
40 | - public const SUBJECT_DELETE = 'addressbook_delete'; |
|
41 | - public const SUBJECT_SHARE_USER = 'addressbook_user_share'; |
|
42 | - public const SUBJECT_SHARE_GROUP = 'addressbook_group_share'; |
|
43 | - public const SUBJECT_UNSHARE_USER = 'addressbook_user_unshare'; |
|
44 | - public const SUBJECT_UNSHARE_GROUP = 'addressbook_group_unshare'; |
|
45 | - |
|
46 | - /** @var IFactory */ |
|
47 | - protected $languageFactory; |
|
48 | - |
|
49 | - /** @var IManager */ |
|
50 | - protected $activityManager; |
|
51 | - |
|
52 | - /** @var IEventMerger */ |
|
53 | - protected $eventMerger; |
|
54 | - |
|
55 | - public function __construct(IFactory $languageFactory, |
|
56 | - IURLGenerator $url, |
|
57 | - IManager $activityManager, |
|
58 | - IUserManager $userManager, |
|
59 | - IGroupManager $groupManager, |
|
60 | - IEventMerger $eventMerger) { |
|
61 | - parent::__construct($userManager, $groupManager, $url); |
|
62 | - $this->languageFactory = $languageFactory; |
|
63 | - $this->activityManager = $activityManager; |
|
64 | - $this->eventMerger = $eventMerger; |
|
65 | - } |
|
66 | - |
|
67 | - /** |
|
68 | - * @param string $language |
|
69 | - * @param IEvent $event |
|
70 | - * @param IEvent|null $previousEvent |
|
71 | - * @return IEvent |
|
72 | - * @throws \InvalidArgumentException |
|
73 | - */ |
|
74 | - public function parse($language, IEvent $event, IEvent $previousEvent = null): IEvent { |
|
75 | - if ($event->getApp() !== 'dav' || $event->getType() !== 'addressbook') { |
|
76 | - throw new \InvalidArgumentException(); |
|
77 | - } |
|
78 | - |
|
79 | - $l = $this->languageFactory->get('dav', $language); |
|
80 | - |
|
81 | - if ($this->activityManager->getRequirePNG()) { |
|
82 | - $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts-dark.png'))); |
|
83 | - } else { |
|
84 | - $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts.svg'))); |
|
85 | - } |
|
86 | - |
|
87 | - if ($event->getSubject() === self::SUBJECT_ADD) { |
|
88 | - $subject = $l->t('{actor} created addressbook {addressbook}'); |
|
89 | - } elseif ($event->getSubject() === self::SUBJECT_ADD . '_self') { |
|
90 | - $subject = $l->t('You created addressbook {addressbook}'); |
|
91 | - } elseif ($event->getSubject() === self::SUBJECT_DELETE) { |
|
92 | - $subject = $l->t('{actor} deleted addressbook {addressbook}'); |
|
93 | - } elseif ($event->getSubject() === self::SUBJECT_DELETE . '_self') { |
|
94 | - $subject = $l->t('You deleted addressbook {addressbook}'); |
|
95 | - } elseif ($event->getSubject() === self::SUBJECT_UPDATE) { |
|
96 | - $subject = $l->t('{actor} updated addressbook {addressbook}'); |
|
97 | - } elseif ($event->getSubject() === self::SUBJECT_UPDATE . '_self') { |
|
98 | - $subject = $l->t('You updated addressbook {addressbook}'); |
|
99 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER) { |
|
100 | - $subject = $l->t('{actor} shared addressbook {addressbook} with you'); |
|
101 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER . '_you') { |
|
102 | - $subject = $l->t('You shared addressbook {addressbook} with {user}'); |
|
103 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER . '_by') { |
|
104 | - $subject = $l->t('{actor} shared addressbook {addressbook} with {user}'); |
|
105 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER) { |
|
106 | - $subject = $l->t('{actor} unshared addressbook {addressbook} from you'); |
|
107 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_you') { |
|
108 | - $subject = $l->t('You unshared addressbook {addressbook} from {user}'); |
|
109 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_by') { |
|
110 | - $subject = $l->t('{actor} unshared addressbook {addressbook} from {user}'); |
|
111 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_self') { |
|
112 | - $subject = $l->t('{actor} unshared addressbook {addressbook} from themselves'); |
|
113 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP . '_you') { |
|
114 | - $subject = $l->t('You shared addressbook {addressbook} with group {group}'); |
|
115 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP . '_by') { |
|
116 | - $subject = $l->t('{actor} shared addressbook {addressbook} with group {group}'); |
|
117 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP . '_you') { |
|
118 | - $subject = $l->t('You unshared addressbook {addressbook} from group {group}'); |
|
119 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP . '_by') { |
|
120 | - $subject = $l->t('{actor} unshared addressbook {addressbook} from group {group}'); |
|
121 | - } else { |
|
122 | - throw new \InvalidArgumentException(); |
|
123 | - } |
|
124 | - |
|
125 | - $parsedParameters = $this->getParameters($event, $l); |
|
126 | - $this->setSubjects($event, $subject, $parsedParameters); |
|
127 | - |
|
128 | - $event = $this->eventMerger->mergeEvents('addressbook', $event, $previousEvent); |
|
129 | - |
|
130 | - if ($event->getChildEvent() === null) { |
|
131 | - if (isset($parsedParameters['user'])) { |
|
132 | - // Couldn't group by calendar, maybe we can group by users |
|
133 | - $event = $this->eventMerger->mergeEvents('user', $event, $previousEvent); |
|
134 | - } elseif (isset($parsedParameters['group'])) { |
|
135 | - // Couldn't group by calendar, maybe we can group by groups |
|
136 | - $event = $this->eventMerger->mergeEvents('group', $event, $previousEvent); |
|
137 | - } |
|
138 | - } |
|
139 | - |
|
140 | - return $event; |
|
141 | - } |
|
142 | - |
|
143 | - protected function getParameters(IEvent $event, IL10N $l): array { |
|
144 | - $subject = $event->getSubject(); |
|
145 | - $parameters = $event->getSubjectParameters(); |
|
146 | - |
|
147 | - switch ($subject) { |
|
148 | - case self::SUBJECT_ADD: |
|
149 | - case self::SUBJECT_ADD . '_self': |
|
150 | - case self::SUBJECT_DELETE: |
|
151 | - case self::SUBJECT_DELETE . '_self': |
|
152 | - case self::SUBJECT_UPDATE: |
|
153 | - case self::SUBJECT_UPDATE . '_self': |
|
154 | - case self::SUBJECT_SHARE_USER: |
|
155 | - case self::SUBJECT_UNSHARE_USER: |
|
156 | - case self::SUBJECT_UNSHARE_USER . '_self': |
|
157 | - return [ |
|
158 | - 'actor' => $this->generateUserParameter($parameters['actor']), |
|
159 | - 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
160 | - ]; |
|
161 | - case self::SUBJECT_SHARE_USER . '_you': |
|
162 | - case self::SUBJECT_UNSHARE_USER . '_you': |
|
163 | - return [ |
|
164 | - 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
165 | - 'user' => $this->generateUserParameter($parameters['user']), |
|
166 | - ]; |
|
167 | - case self::SUBJECT_SHARE_USER . '_by': |
|
168 | - case self::SUBJECT_UNSHARE_USER . '_by': |
|
169 | - return [ |
|
170 | - 'actor' => $this->generateUserParameter($parameters['actor']), |
|
171 | - 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
172 | - 'user' => $this->generateUserParameter($parameters['user']), |
|
173 | - ]; |
|
174 | - case self::SUBJECT_SHARE_GROUP . '_you': |
|
175 | - case self::SUBJECT_UNSHARE_GROUP . '_you': |
|
176 | - return [ |
|
177 | - 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
178 | - 'group' => $this->generateGroupParameter($parameters['group']), |
|
179 | - ]; |
|
180 | - case self::SUBJECT_SHARE_GROUP . '_by': |
|
181 | - case self::SUBJECT_UNSHARE_GROUP . '_by': |
|
182 | - return [ |
|
183 | - 'actor' => $this->generateUserParameter($parameters['actor']), |
|
184 | - 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
185 | - 'group' => $this->generateGroupParameter($parameters['group']), |
|
186 | - ]; |
|
187 | - } |
|
188 | - |
|
189 | - throw new \InvalidArgumentException(); |
|
190 | - } |
|
38 | + public const SUBJECT_ADD = 'addressbook_add'; |
|
39 | + public const SUBJECT_UPDATE = 'addressbook_update'; |
|
40 | + public const SUBJECT_DELETE = 'addressbook_delete'; |
|
41 | + public const SUBJECT_SHARE_USER = 'addressbook_user_share'; |
|
42 | + public const SUBJECT_SHARE_GROUP = 'addressbook_group_share'; |
|
43 | + public const SUBJECT_UNSHARE_USER = 'addressbook_user_unshare'; |
|
44 | + public const SUBJECT_UNSHARE_GROUP = 'addressbook_group_unshare'; |
|
45 | + |
|
46 | + /** @var IFactory */ |
|
47 | + protected $languageFactory; |
|
48 | + |
|
49 | + /** @var IManager */ |
|
50 | + protected $activityManager; |
|
51 | + |
|
52 | + /** @var IEventMerger */ |
|
53 | + protected $eventMerger; |
|
54 | + |
|
55 | + public function __construct(IFactory $languageFactory, |
|
56 | + IURLGenerator $url, |
|
57 | + IManager $activityManager, |
|
58 | + IUserManager $userManager, |
|
59 | + IGroupManager $groupManager, |
|
60 | + IEventMerger $eventMerger) { |
|
61 | + parent::__construct($userManager, $groupManager, $url); |
|
62 | + $this->languageFactory = $languageFactory; |
|
63 | + $this->activityManager = $activityManager; |
|
64 | + $this->eventMerger = $eventMerger; |
|
65 | + } |
|
66 | + |
|
67 | + /** |
|
68 | + * @param string $language |
|
69 | + * @param IEvent $event |
|
70 | + * @param IEvent|null $previousEvent |
|
71 | + * @return IEvent |
|
72 | + * @throws \InvalidArgumentException |
|
73 | + */ |
|
74 | + public function parse($language, IEvent $event, IEvent $previousEvent = null): IEvent { |
|
75 | + if ($event->getApp() !== 'dav' || $event->getType() !== 'addressbook') { |
|
76 | + throw new \InvalidArgumentException(); |
|
77 | + } |
|
78 | + |
|
79 | + $l = $this->languageFactory->get('dav', $language); |
|
80 | + |
|
81 | + if ($this->activityManager->getRequirePNG()) { |
|
82 | + $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts-dark.png'))); |
|
83 | + } else { |
|
84 | + $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts.svg'))); |
|
85 | + } |
|
86 | + |
|
87 | + if ($event->getSubject() === self::SUBJECT_ADD) { |
|
88 | + $subject = $l->t('{actor} created addressbook {addressbook}'); |
|
89 | + } elseif ($event->getSubject() === self::SUBJECT_ADD . '_self') { |
|
90 | + $subject = $l->t('You created addressbook {addressbook}'); |
|
91 | + } elseif ($event->getSubject() === self::SUBJECT_DELETE) { |
|
92 | + $subject = $l->t('{actor} deleted addressbook {addressbook}'); |
|
93 | + } elseif ($event->getSubject() === self::SUBJECT_DELETE . '_self') { |
|
94 | + $subject = $l->t('You deleted addressbook {addressbook}'); |
|
95 | + } elseif ($event->getSubject() === self::SUBJECT_UPDATE) { |
|
96 | + $subject = $l->t('{actor} updated addressbook {addressbook}'); |
|
97 | + } elseif ($event->getSubject() === self::SUBJECT_UPDATE . '_self') { |
|
98 | + $subject = $l->t('You updated addressbook {addressbook}'); |
|
99 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER) { |
|
100 | + $subject = $l->t('{actor} shared addressbook {addressbook} with you'); |
|
101 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER . '_you') { |
|
102 | + $subject = $l->t('You shared addressbook {addressbook} with {user}'); |
|
103 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER . '_by') { |
|
104 | + $subject = $l->t('{actor} shared addressbook {addressbook} with {user}'); |
|
105 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER) { |
|
106 | + $subject = $l->t('{actor} unshared addressbook {addressbook} from you'); |
|
107 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_you') { |
|
108 | + $subject = $l->t('You unshared addressbook {addressbook} from {user}'); |
|
109 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_by') { |
|
110 | + $subject = $l->t('{actor} unshared addressbook {addressbook} from {user}'); |
|
111 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_self') { |
|
112 | + $subject = $l->t('{actor} unshared addressbook {addressbook} from themselves'); |
|
113 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP . '_you') { |
|
114 | + $subject = $l->t('You shared addressbook {addressbook} with group {group}'); |
|
115 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP . '_by') { |
|
116 | + $subject = $l->t('{actor} shared addressbook {addressbook} with group {group}'); |
|
117 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP . '_you') { |
|
118 | + $subject = $l->t('You unshared addressbook {addressbook} from group {group}'); |
|
119 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP . '_by') { |
|
120 | + $subject = $l->t('{actor} unshared addressbook {addressbook} from group {group}'); |
|
121 | + } else { |
|
122 | + throw new \InvalidArgumentException(); |
|
123 | + } |
|
124 | + |
|
125 | + $parsedParameters = $this->getParameters($event, $l); |
|
126 | + $this->setSubjects($event, $subject, $parsedParameters); |
|
127 | + |
|
128 | + $event = $this->eventMerger->mergeEvents('addressbook', $event, $previousEvent); |
|
129 | + |
|
130 | + if ($event->getChildEvent() === null) { |
|
131 | + if (isset($parsedParameters['user'])) { |
|
132 | + // Couldn't group by calendar, maybe we can group by users |
|
133 | + $event = $this->eventMerger->mergeEvents('user', $event, $previousEvent); |
|
134 | + } elseif (isset($parsedParameters['group'])) { |
|
135 | + // Couldn't group by calendar, maybe we can group by groups |
|
136 | + $event = $this->eventMerger->mergeEvents('group', $event, $previousEvent); |
|
137 | + } |
|
138 | + } |
|
139 | + |
|
140 | + return $event; |
|
141 | + } |
|
142 | + |
|
143 | + protected function getParameters(IEvent $event, IL10N $l): array { |
|
144 | + $subject = $event->getSubject(); |
|
145 | + $parameters = $event->getSubjectParameters(); |
|
146 | + |
|
147 | + switch ($subject) { |
|
148 | + case self::SUBJECT_ADD: |
|
149 | + case self::SUBJECT_ADD . '_self': |
|
150 | + case self::SUBJECT_DELETE: |
|
151 | + case self::SUBJECT_DELETE . '_self': |
|
152 | + case self::SUBJECT_UPDATE: |
|
153 | + case self::SUBJECT_UPDATE . '_self': |
|
154 | + case self::SUBJECT_SHARE_USER: |
|
155 | + case self::SUBJECT_UNSHARE_USER: |
|
156 | + case self::SUBJECT_UNSHARE_USER . '_self': |
|
157 | + return [ |
|
158 | + 'actor' => $this->generateUserParameter($parameters['actor']), |
|
159 | + 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
160 | + ]; |
|
161 | + case self::SUBJECT_SHARE_USER . '_you': |
|
162 | + case self::SUBJECT_UNSHARE_USER . '_you': |
|
163 | + return [ |
|
164 | + 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
165 | + 'user' => $this->generateUserParameter($parameters['user']), |
|
166 | + ]; |
|
167 | + case self::SUBJECT_SHARE_USER . '_by': |
|
168 | + case self::SUBJECT_UNSHARE_USER . '_by': |
|
169 | + return [ |
|
170 | + 'actor' => $this->generateUserParameter($parameters['actor']), |
|
171 | + 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
172 | + 'user' => $this->generateUserParameter($parameters['user']), |
|
173 | + ]; |
|
174 | + case self::SUBJECT_SHARE_GROUP . '_you': |
|
175 | + case self::SUBJECT_UNSHARE_GROUP . '_you': |
|
176 | + return [ |
|
177 | + 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
178 | + 'group' => $this->generateGroupParameter($parameters['group']), |
|
179 | + ]; |
|
180 | + case self::SUBJECT_SHARE_GROUP . '_by': |
|
181 | + case self::SUBJECT_UNSHARE_GROUP . '_by': |
|
182 | + return [ |
|
183 | + 'actor' => $this->generateUserParameter($parameters['actor']), |
|
184 | + 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
185 | + 'group' => $this->generateGroupParameter($parameters['group']), |
|
186 | + ]; |
|
187 | + } |
|
188 | + |
|
189 | + throw new \InvalidArgumentException(); |
|
190 | + } |
|
191 | 191 | } |
@@ -86,37 +86,37 @@ discard block |
||
86 | 86 | |
87 | 87 | if ($event->getSubject() === self::SUBJECT_ADD) { |
88 | 88 | $subject = $l->t('{actor} created addressbook {addressbook}'); |
89 | - } elseif ($event->getSubject() === self::SUBJECT_ADD . '_self') { |
|
89 | + } elseif ($event->getSubject() === self::SUBJECT_ADD.'_self') { |
|
90 | 90 | $subject = $l->t('You created addressbook {addressbook}'); |
91 | 91 | } elseif ($event->getSubject() === self::SUBJECT_DELETE) { |
92 | 92 | $subject = $l->t('{actor} deleted addressbook {addressbook}'); |
93 | - } elseif ($event->getSubject() === self::SUBJECT_DELETE . '_self') { |
|
93 | + } elseif ($event->getSubject() === self::SUBJECT_DELETE.'_self') { |
|
94 | 94 | $subject = $l->t('You deleted addressbook {addressbook}'); |
95 | 95 | } elseif ($event->getSubject() === self::SUBJECT_UPDATE) { |
96 | 96 | $subject = $l->t('{actor} updated addressbook {addressbook}'); |
97 | - } elseif ($event->getSubject() === self::SUBJECT_UPDATE . '_self') { |
|
97 | + } elseif ($event->getSubject() === self::SUBJECT_UPDATE.'_self') { |
|
98 | 98 | $subject = $l->t('You updated addressbook {addressbook}'); |
99 | 99 | } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER) { |
100 | 100 | $subject = $l->t('{actor} shared addressbook {addressbook} with you'); |
101 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER . '_you') { |
|
101 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER.'_you') { |
|
102 | 102 | $subject = $l->t('You shared addressbook {addressbook} with {user}'); |
103 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER . '_by') { |
|
103 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_USER.'_by') { |
|
104 | 104 | $subject = $l->t('{actor} shared addressbook {addressbook} with {user}'); |
105 | 105 | } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER) { |
106 | 106 | $subject = $l->t('{actor} unshared addressbook {addressbook} from you'); |
107 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_you') { |
|
107 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER.'_you') { |
|
108 | 108 | $subject = $l->t('You unshared addressbook {addressbook} from {user}'); |
109 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_by') { |
|
109 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER.'_by') { |
|
110 | 110 | $subject = $l->t('{actor} unshared addressbook {addressbook} from {user}'); |
111 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER . '_self') { |
|
111 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_USER.'_self') { |
|
112 | 112 | $subject = $l->t('{actor} unshared addressbook {addressbook} from themselves'); |
113 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP . '_you') { |
|
113 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP.'_you') { |
|
114 | 114 | $subject = $l->t('You shared addressbook {addressbook} with group {group}'); |
115 | - } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP . '_by') { |
|
115 | + } elseif ($event->getSubject() === self::SUBJECT_SHARE_GROUP.'_by') { |
|
116 | 116 | $subject = $l->t('{actor} shared addressbook {addressbook} with group {group}'); |
117 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP . '_you') { |
|
117 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP.'_you') { |
|
118 | 118 | $subject = $l->t('You unshared addressbook {addressbook} from group {group}'); |
119 | - } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP . '_by') { |
|
119 | + } elseif ($event->getSubject() === self::SUBJECT_UNSHARE_GROUP.'_by') { |
|
120 | 120 | $subject = $l->t('{actor} unshared addressbook {addressbook} from group {group}'); |
121 | 121 | } else { |
122 | 122 | throw new \InvalidArgumentException(); |
@@ -146,39 +146,39 @@ discard block |
||
146 | 146 | |
147 | 147 | switch ($subject) { |
148 | 148 | case self::SUBJECT_ADD: |
149 | - case self::SUBJECT_ADD . '_self': |
|
149 | + case self::SUBJECT_ADD.'_self': |
|
150 | 150 | case self::SUBJECT_DELETE: |
151 | - case self::SUBJECT_DELETE . '_self': |
|
151 | + case self::SUBJECT_DELETE.'_self': |
|
152 | 152 | case self::SUBJECT_UPDATE: |
153 | - case self::SUBJECT_UPDATE . '_self': |
|
153 | + case self::SUBJECT_UPDATE.'_self': |
|
154 | 154 | case self::SUBJECT_SHARE_USER: |
155 | 155 | case self::SUBJECT_UNSHARE_USER: |
156 | - case self::SUBJECT_UNSHARE_USER . '_self': |
|
156 | + case self::SUBJECT_UNSHARE_USER.'_self': |
|
157 | 157 | return [ |
158 | 158 | 'actor' => $this->generateUserParameter($parameters['actor']), |
159 | 159 | 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
160 | 160 | ]; |
161 | - case self::SUBJECT_SHARE_USER . '_you': |
|
162 | - case self::SUBJECT_UNSHARE_USER . '_you': |
|
161 | + case self::SUBJECT_SHARE_USER.'_you': |
|
162 | + case self::SUBJECT_UNSHARE_USER.'_you': |
|
163 | 163 | return [ |
164 | 164 | 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
165 | 165 | 'user' => $this->generateUserParameter($parameters['user']), |
166 | 166 | ]; |
167 | - case self::SUBJECT_SHARE_USER . '_by': |
|
168 | - case self::SUBJECT_UNSHARE_USER . '_by': |
|
167 | + case self::SUBJECT_SHARE_USER.'_by': |
|
168 | + case self::SUBJECT_UNSHARE_USER.'_by': |
|
169 | 169 | return [ |
170 | 170 | 'actor' => $this->generateUserParameter($parameters['actor']), |
171 | 171 | 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
172 | 172 | 'user' => $this->generateUserParameter($parameters['user']), |
173 | 173 | ]; |
174 | - case self::SUBJECT_SHARE_GROUP . '_you': |
|
175 | - case self::SUBJECT_UNSHARE_GROUP . '_you': |
|
174 | + case self::SUBJECT_SHARE_GROUP.'_you': |
|
175 | + case self::SUBJECT_UNSHARE_GROUP.'_you': |
|
176 | 176 | return [ |
177 | 177 | 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
178 | 178 | 'group' => $this->generateGroupParameter($parameters['group']), |
179 | 179 | ]; |
180 | - case self::SUBJECT_SHARE_GROUP . '_by': |
|
181 | - case self::SUBJECT_UNSHARE_GROUP . '_by': |
|
180 | + case self::SUBJECT_SHARE_GROUP.'_by': |
|
181 | + case self::SUBJECT_UNSHARE_GROUP.'_by': |
|
182 | 182 | return [ |
183 | 183 | 'actor' => $this->generateUserParameter($parameters['actor']), |
184 | 184 | 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
@@ -37,120 +37,120 @@ |
||
37 | 37 | |
38 | 38 | abstract class Base implements IProvider { |
39 | 39 | |
40 | - /** @var IUserManager */ |
|
41 | - protected $userManager; |
|
42 | - |
|
43 | - /** @var string[] */ |
|
44 | - protected $userDisplayNames = []; |
|
45 | - |
|
46 | - /** @var IGroupManager */ |
|
47 | - protected $groupManager; |
|
48 | - |
|
49 | - /** @var string[] */ |
|
50 | - protected $groupDisplayNames = []; |
|
51 | - |
|
52 | - /** @var IURLGenerator */ |
|
53 | - protected $url; |
|
54 | - |
|
55 | - public function __construct(IUserManager $userManager, |
|
56 | - IGroupManager $groupManager, |
|
57 | - IURLGenerator $urlGenerator) { |
|
58 | - $this->userManager = $userManager; |
|
59 | - $this->groupManager = $groupManager; |
|
60 | - $this->url = $urlGenerator; |
|
61 | - } |
|
62 | - |
|
63 | - /** |
|
64 | - * @param IEvent $event |
|
65 | - * @param string $subject |
|
66 | - * @param array $parameters |
|
67 | - */ |
|
68 | - protected function setSubjects(IEvent $event, string $subject, array $parameters): void { |
|
69 | - $placeholders = $replacements = []; |
|
70 | - foreach ($parameters as $placeholder => $parameter) { |
|
71 | - $placeholders[] = '{' . $placeholder . '}'; |
|
72 | - $replacements[] = $parameter['name']; |
|
73 | - } |
|
74 | - |
|
75 | - $event->setParsedSubject(str_replace($placeholders, $replacements, $subject)) |
|
76 | - ->setRichSubject($subject, $parameters); |
|
77 | - } |
|
78 | - |
|
79 | - /** |
|
80 | - * @param array $data |
|
81 | - * @param IL10N $l |
|
82 | - * @return array |
|
83 | - */ |
|
84 | - protected function generateAddressbookParameter(array $data, IL10N $l): array { |
|
85 | - if ($data['uri'] === CardDavBackend::PERSONAL_ADDRESSBOOK_URI && |
|
86 | - $data['name'] === CardDavBackend::PERSONAL_ADDRESSBOOK_NAME) { |
|
87 | - return [ |
|
88 | - 'type' => 'addressbook', |
|
89 | - 'id' => $data['id'], |
|
90 | - 'name' => $l->t('Personal'), |
|
91 | - ]; |
|
92 | - } |
|
93 | - |
|
94 | - return [ |
|
95 | - 'type' => 'addressbook', |
|
96 | - 'id' => $data['id'], |
|
97 | - 'name' => $data['name'], |
|
98 | - ]; |
|
99 | - } |
|
100 | - |
|
101 | - /** |
|
102 | - * @param string $uid |
|
103 | - * @return array |
|
104 | - */ |
|
105 | - protected function generateUserParameter(string $uid): array { |
|
106 | - if (!isset($this->userDisplayNames[$uid])) { |
|
107 | - $this->userDisplayNames[$uid] = $this->getUserDisplayName($uid); |
|
108 | - } |
|
109 | - |
|
110 | - return [ |
|
111 | - 'type' => 'user', |
|
112 | - 'id' => $uid, |
|
113 | - 'name' => $this->userDisplayNames[$uid], |
|
114 | - ]; |
|
115 | - } |
|
116 | - |
|
117 | - /** |
|
118 | - * @param string $uid |
|
119 | - * @return string |
|
120 | - */ |
|
121 | - protected function getUserDisplayName(string $uid): string { |
|
122 | - $user = $this->userManager->get($uid); |
|
123 | - if ($user instanceof IUser) { |
|
124 | - return $user->getDisplayName(); |
|
125 | - } |
|
126 | - return $uid; |
|
127 | - } |
|
128 | - |
|
129 | - /** |
|
130 | - * @param string $gid |
|
131 | - * @return array |
|
132 | - */ |
|
133 | - protected function generateGroupParameter(string $gid): array { |
|
134 | - if (!isset($this->groupDisplayNames[$gid])) { |
|
135 | - $this->groupDisplayNames[$gid] = $this->getGroupDisplayName($gid); |
|
136 | - } |
|
137 | - |
|
138 | - return [ |
|
139 | - 'type' => 'user-group', |
|
140 | - 'id' => $gid, |
|
141 | - 'name' => $this->groupDisplayNames[$gid], |
|
142 | - ]; |
|
143 | - } |
|
144 | - |
|
145 | - /** |
|
146 | - * @param string $gid |
|
147 | - * @return string |
|
148 | - */ |
|
149 | - protected function getGroupDisplayName(string $gid): string { |
|
150 | - $group = $this->groupManager->get($gid); |
|
151 | - if ($group instanceof IGroup) { |
|
152 | - return $group->getDisplayName(); |
|
153 | - } |
|
154 | - return $gid; |
|
155 | - } |
|
40 | + /** @var IUserManager */ |
|
41 | + protected $userManager; |
|
42 | + |
|
43 | + /** @var string[] */ |
|
44 | + protected $userDisplayNames = []; |
|
45 | + |
|
46 | + /** @var IGroupManager */ |
|
47 | + protected $groupManager; |
|
48 | + |
|
49 | + /** @var string[] */ |
|
50 | + protected $groupDisplayNames = []; |
|
51 | + |
|
52 | + /** @var IURLGenerator */ |
|
53 | + protected $url; |
|
54 | + |
|
55 | + public function __construct(IUserManager $userManager, |
|
56 | + IGroupManager $groupManager, |
|
57 | + IURLGenerator $urlGenerator) { |
|
58 | + $this->userManager = $userManager; |
|
59 | + $this->groupManager = $groupManager; |
|
60 | + $this->url = $urlGenerator; |
|
61 | + } |
|
62 | + |
|
63 | + /** |
|
64 | + * @param IEvent $event |
|
65 | + * @param string $subject |
|
66 | + * @param array $parameters |
|
67 | + */ |
|
68 | + protected function setSubjects(IEvent $event, string $subject, array $parameters): void { |
|
69 | + $placeholders = $replacements = []; |
|
70 | + foreach ($parameters as $placeholder => $parameter) { |
|
71 | + $placeholders[] = '{' . $placeholder . '}'; |
|
72 | + $replacements[] = $parameter['name']; |
|
73 | + } |
|
74 | + |
|
75 | + $event->setParsedSubject(str_replace($placeholders, $replacements, $subject)) |
|
76 | + ->setRichSubject($subject, $parameters); |
|
77 | + } |
|
78 | + |
|
79 | + /** |
|
80 | + * @param array $data |
|
81 | + * @param IL10N $l |
|
82 | + * @return array |
|
83 | + */ |
|
84 | + protected function generateAddressbookParameter(array $data, IL10N $l): array { |
|
85 | + if ($data['uri'] === CardDavBackend::PERSONAL_ADDRESSBOOK_URI && |
|
86 | + $data['name'] === CardDavBackend::PERSONAL_ADDRESSBOOK_NAME) { |
|
87 | + return [ |
|
88 | + 'type' => 'addressbook', |
|
89 | + 'id' => $data['id'], |
|
90 | + 'name' => $l->t('Personal'), |
|
91 | + ]; |
|
92 | + } |
|
93 | + |
|
94 | + return [ |
|
95 | + 'type' => 'addressbook', |
|
96 | + 'id' => $data['id'], |
|
97 | + 'name' => $data['name'], |
|
98 | + ]; |
|
99 | + } |
|
100 | + |
|
101 | + /** |
|
102 | + * @param string $uid |
|
103 | + * @return array |
|
104 | + */ |
|
105 | + protected function generateUserParameter(string $uid): array { |
|
106 | + if (!isset($this->userDisplayNames[$uid])) { |
|
107 | + $this->userDisplayNames[$uid] = $this->getUserDisplayName($uid); |
|
108 | + } |
|
109 | + |
|
110 | + return [ |
|
111 | + 'type' => 'user', |
|
112 | + 'id' => $uid, |
|
113 | + 'name' => $this->userDisplayNames[$uid], |
|
114 | + ]; |
|
115 | + } |
|
116 | + |
|
117 | + /** |
|
118 | + * @param string $uid |
|
119 | + * @return string |
|
120 | + */ |
|
121 | + protected function getUserDisplayName(string $uid): string { |
|
122 | + $user = $this->userManager->get($uid); |
|
123 | + if ($user instanceof IUser) { |
|
124 | + return $user->getDisplayName(); |
|
125 | + } |
|
126 | + return $uid; |
|
127 | + } |
|
128 | + |
|
129 | + /** |
|
130 | + * @param string $gid |
|
131 | + * @return array |
|
132 | + */ |
|
133 | + protected function generateGroupParameter(string $gid): array { |
|
134 | + if (!isset($this->groupDisplayNames[$gid])) { |
|
135 | + $this->groupDisplayNames[$gid] = $this->getGroupDisplayName($gid); |
|
136 | + } |
|
137 | + |
|
138 | + return [ |
|
139 | + 'type' => 'user-group', |
|
140 | + 'id' => $gid, |
|
141 | + 'name' => $this->groupDisplayNames[$gid], |
|
142 | + ]; |
|
143 | + } |
|
144 | + |
|
145 | + /** |
|
146 | + * @param string $gid |
|
147 | + * @return string |
|
148 | + */ |
|
149 | + protected function getGroupDisplayName(string $gid): string { |
|
150 | + $group = $this->groupManager->get($gid); |
|
151 | + if ($group instanceof IGroup) { |
|
152 | + return $group->getDisplayName(); |
|
153 | + } |
|
154 | + return $gid; |
|
155 | + } |
|
156 | 156 | } |
@@ -169,7 +169,7 @@ |
||
169 | 169 | protected function setSubjects(IEvent $event, string $subject, array $parameters): void { |
170 | 170 | $placeholders = $replacements = []; |
171 | 171 | foreach ($parameters as $placeholder => $parameter) { |
172 | - $placeholders[] = '{' . $placeholder . '}'; |
|
172 | + $placeholders[] = '{'.$placeholder.'}'; |
|
173 | 173 | $replacements[] = $parameter['name']; |
174 | 174 | } |
175 | 175 |
@@ -36,109 +36,109 @@ |
||
36 | 36 | use OCP\L10N\IFactory; |
37 | 37 | |
38 | 38 | class Card extends Base { |
39 | - public const SUBJECT_ADD = 'card_add'; |
|
40 | - public const SUBJECT_UPDATE = 'card_update'; |
|
41 | - public const SUBJECT_DELETE = 'card_delete'; |
|
42 | - |
|
43 | - /** @var IFactory */ |
|
44 | - protected $languageFactory; |
|
45 | - |
|
46 | - /** @var IManager */ |
|
47 | - protected $activityManager; |
|
48 | - |
|
49 | - /** @var IEventMerger */ |
|
50 | - protected $eventMerger; |
|
51 | - |
|
52 | - /** @var IAppManager */ |
|
53 | - protected $appManager; |
|
54 | - |
|
55 | - public function __construct(IFactory $languageFactory, |
|
56 | - IURLGenerator $url, |
|
57 | - IManager $activityManager, |
|
58 | - IUserManager $userManager, |
|
59 | - IGroupManager $groupManager, |
|
60 | - IEventMerger $eventMerger, |
|
61 | - IAppManager $appManager) { |
|
62 | - parent::__construct($userManager, $groupManager, $url); |
|
63 | - $this->languageFactory = $languageFactory; |
|
64 | - $this->activityManager = $activityManager; |
|
65 | - $this->eventMerger = $eventMerger; |
|
66 | - $this->appManager = $appManager; |
|
67 | - } |
|
68 | - |
|
69 | - /** |
|
70 | - * @param string $language |
|
71 | - * @param IEvent $event |
|
72 | - * @param IEvent|null $previousEvent |
|
73 | - * @return IEvent |
|
74 | - * @throws \InvalidArgumentException |
|
75 | - */ |
|
76 | - public function parse($language, IEvent $event, IEvent $previousEvent = null): IEvent { |
|
77 | - if ($event->getApp() !== 'dav' || $event->getType() !== 'card') { |
|
78 | - throw new \InvalidArgumentException(); |
|
79 | - } |
|
80 | - |
|
81 | - $l = $this->languageFactory->get('dav', $language); |
|
82 | - |
|
83 | - if ($this->activityManager->getRequirePNG()) { |
|
84 | - $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts-dark.png'))); |
|
85 | - } else { |
|
86 | - $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts.svg'))); |
|
87 | - } |
|
88 | - |
|
89 | - if ($event->getSubject() === self::SUBJECT_ADD) { |
|
90 | - $subject = $l->t('{actor} created contact {card} in addressbook {addressbook}'); |
|
91 | - } elseif ($event->getSubject() === self::SUBJECT_ADD . '_self') { |
|
92 | - $subject = $l->t('You created contact {card} in addressbook {addressbook}'); |
|
93 | - } elseif ($event->getSubject() === self::SUBJECT_DELETE) { |
|
94 | - $subject = $l->t('{actor} deleted contact {card} from addressbook {addressbook}'); |
|
95 | - } elseif ($event->getSubject() === self::SUBJECT_DELETE . '_self') { |
|
96 | - $subject = $l->t('You deleted contact {card} from addressbook {addressbook}'); |
|
97 | - } elseif ($event->getSubject() === self::SUBJECT_UPDATE) { |
|
98 | - $subject = $l->t('{actor} updated contact {card} in addressbook {addressbook}'); |
|
99 | - } elseif ($event->getSubject() === self::SUBJECT_UPDATE . '_self') { |
|
100 | - $subject = $l->t('You updated contact {card} in addressbook {addressbook}'); |
|
101 | - } else { |
|
102 | - throw new \InvalidArgumentException(); |
|
103 | - } |
|
104 | - |
|
105 | - $parsedParameters = $this->getParameters($event, $l); |
|
106 | - $this->setSubjects($event, $subject, $parsedParameters); |
|
107 | - |
|
108 | - $event = $this->eventMerger->mergeEvents('card', $event, $previousEvent); |
|
109 | - return $event; |
|
110 | - } |
|
111 | - |
|
112 | - protected function getParameters(IEvent $event, IL10N $l): array { |
|
113 | - $subject = $event->getSubject(); |
|
114 | - $parameters = $event->getSubjectParameters(); |
|
115 | - |
|
116 | - switch ($subject) { |
|
117 | - case self::SUBJECT_ADD: |
|
118 | - case self::SUBJECT_DELETE: |
|
119 | - case self::SUBJECT_UPDATE: |
|
120 | - return [ |
|
121 | - 'actor' => $this->generateUserParameter($parameters['actor']), |
|
122 | - 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
123 | - 'card' => $this->generateCardParameter($parameters['card']), |
|
124 | - ]; |
|
125 | - case self::SUBJECT_ADD . '_self': |
|
126 | - case self::SUBJECT_DELETE . '_self': |
|
127 | - case self::SUBJECT_UPDATE . '_self': |
|
128 | - return [ |
|
129 | - 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
130 | - 'card' => $this->generateCardParameter($parameters['card']), |
|
131 | - ]; |
|
132 | - } |
|
133 | - |
|
134 | - throw new \InvalidArgumentException(); |
|
135 | - } |
|
136 | - |
|
137 | - private function generateCardParameter(array $cardData): array { |
|
138 | - return [ |
|
139 | - 'type' => 'addressbook-contact', |
|
140 | - 'id' => $cardData['id'], |
|
141 | - 'name' => $cardData['name'], |
|
142 | - ]; |
|
143 | - } |
|
39 | + public const SUBJECT_ADD = 'card_add'; |
|
40 | + public const SUBJECT_UPDATE = 'card_update'; |
|
41 | + public const SUBJECT_DELETE = 'card_delete'; |
|
42 | + |
|
43 | + /** @var IFactory */ |
|
44 | + protected $languageFactory; |
|
45 | + |
|
46 | + /** @var IManager */ |
|
47 | + protected $activityManager; |
|
48 | + |
|
49 | + /** @var IEventMerger */ |
|
50 | + protected $eventMerger; |
|
51 | + |
|
52 | + /** @var IAppManager */ |
|
53 | + protected $appManager; |
|
54 | + |
|
55 | + public function __construct(IFactory $languageFactory, |
|
56 | + IURLGenerator $url, |
|
57 | + IManager $activityManager, |
|
58 | + IUserManager $userManager, |
|
59 | + IGroupManager $groupManager, |
|
60 | + IEventMerger $eventMerger, |
|
61 | + IAppManager $appManager) { |
|
62 | + parent::__construct($userManager, $groupManager, $url); |
|
63 | + $this->languageFactory = $languageFactory; |
|
64 | + $this->activityManager = $activityManager; |
|
65 | + $this->eventMerger = $eventMerger; |
|
66 | + $this->appManager = $appManager; |
|
67 | + } |
|
68 | + |
|
69 | + /** |
|
70 | + * @param string $language |
|
71 | + * @param IEvent $event |
|
72 | + * @param IEvent|null $previousEvent |
|
73 | + * @return IEvent |
|
74 | + * @throws \InvalidArgumentException |
|
75 | + */ |
|
76 | + public function parse($language, IEvent $event, IEvent $previousEvent = null): IEvent { |
|
77 | + if ($event->getApp() !== 'dav' || $event->getType() !== 'card') { |
|
78 | + throw new \InvalidArgumentException(); |
|
79 | + } |
|
80 | + |
|
81 | + $l = $this->languageFactory->get('dav', $language); |
|
82 | + |
|
83 | + if ($this->activityManager->getRequirePNG()) { |
|
84 | + $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts-dark.png'))); |
|
85 | + } else { |
|
86 | + $event->setIcon($this->url->getAbsoluteURL($this->url->imagePath('core', 'places/contacts.svg'))); |
|
87 | + } |
|
88 | + |
|
89 | + if ($event->getSubject() === self::SUBJECT_ADD) { |
|
90 | + $subject = $l->t('{actor} created contact {card} in addressbook {addressbook}'); |
|
91 | + } elseif ($event->getSubject() === self::SUBJECT_ADD . '_self') { |
|
92 | + $subject = $l->t('You created contact {card} in addressbook {addressbook}'); |
|
93 | + } elseif ($event->getSubject() === self::SUBJECT_DELETE) { |
|
94 | + $subject = $l->t('{actor} deleted contact {card} from addressbook {addressbook}'); |
|
95 | + } elseif ($event->getSubject() === self::SUBJECT_DELETE . '_self') { |
|
96 | + $subject = $l->t('You deleted contact {card} from addressbook {addressbook}'); |
|
97 | + } elseif ($event->getSubject() === self::SUBJECT_UPDATE) { |
|
98 | + $subject = $l->t('{actor} updated contact {card} in addressbook {addressbook}'); |
|
99 | + } elseif ($event->getSubject() === self::SUBJECT_UPDATE . '_self') { |
|
100 | + $subject = $l->t('You updated contact {card} in addressbook {addressbook}'); |
|
101 | + } else { |
|
102 | + throw new \InvalidArgumentException(); |
|
103 | + } |
|
104 | + |
|
105 | + $parsedParameters = $this->getParameters($event, $l); |
|
106 | + $this->setSubjects($event, $subject, $parsedParameters); |
|
107 | + |
|
108 | + $event = $this->eventMerger->mergeEvents('card', $event, $previousEvent); |
|
109 | + return $event; |
|
110 | + } |
|
111 | + |
|
112 | + protected function getParameters(IEvent $event, IL10N $l): array { |
|
113 | + $subject = $event->getSubject(); |
|
114 | + $parameters = $event->getSubjectParameters(); |
|
115 | + |
|
116 | + switch ($subject) { |
|
117 | + case self::SUBJECT_ADD: |
|
118 | + case self::SUBJECT_DELETE: |
|
119 | + case self::SUBJECT_UPDATE: |
|
120 | + return [ |
|
121 | + 'actor' => $this->generateUserParameter($parameters['actor']), |
|
122 | + 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
123 | + 'card' => $this->generateCardParameter($parameters['card']), |
|
124 | + ]; |
|
125 | + case self::SUBJECT_ADD . '_self': |
|
126 | + case self::SUBJECT_DELETE . '_self': |
|
127 | + case self::SUBJECT_UPDATE . '_self': |
|
128 | + return [ |
|
129 | + 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
|
130 | + 'card' => $this->generateCardParameter($parameters['card']), |
|
131 | + ]; |
|
132 | + } |
|
133 | + |
|
134 | + throw new \InvalidArgumentException(); |
|
135 | + } |
|
136 | + |
|
137 | + private function generateCardParameter(array $cardData): array { |
|
138 | + return [ |
|
139 | + 'type' => 'addressbook-contact', |
|
140 | + 'id' => $cardData['id'], |
|
141 | + 'name' => $cardData['name'], |
|
142 | + ]; |
|
143 | + } |
|
144 | 144 | } |
@@ -88,15 +88,15 @@ discard block |
||
88 | 88 | |
89 | 89 | if ($event->getSubject() === self::SUBJECT_ADD) { |
90 | 90 | $subject = $l->t('{actor} created contact {card} in addressbook {addressbook}'); |
91 | - } elseif ($event->getSubject() === self::SUBJECT_ADD . '_self') { |
|
91 | + } elseif ($event->getSubject() === self::SUBJECT_ADD.'_self') { |
|
92 | 92 | $subject = $l->t('You created contact {card} in addressbook {addressbook}'); |
93 | 93 | } elseif ($event->getSubject() === self::SUBJECT_DELETE) { |
94 | 94 | $subject = $l->t('{actor} deleted contact {card} from addressbook {addressbook}'); |
95 | - } elseif ($event->getSubject() === self::SUBJECT_DELETE . '_self') { |
|
95 | + } elseif ($event->getSubject() === self::SUBJECT_DELETE.'_self') { |
|
96 | 96 | $subject = $l->t('You deleted contact {card} from addressbook {addressbook}'); |
97 | 97 | } elseif ($event->getSubject() === self::SUBJECT_UPDATE) { |
98 | 98 | $subject = $l->t('{actor} updated contact {card} in addressbook {addressbook}'); |
99 | - } elseif ($event->getSubject() === self::SUBJECT_UPDATE . '_self') { |
|
99 | + } elseif ($event->getSubject() === self::SUBJECT_UPDATE.'_self') { |
|
100 | 100 | $subject = $l->t('You updated contact {card} in addressbook {addressbook}'); |
101 | 101 | } else { |
102 | 102 | throw new \InvalidArgumentException(); |
@@ -122,9 +122,9 @@ discard block |
||
122 | 122 | 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
123 | 123 | 'card' => $this->generateCardParameter($parameters['card']), |
124 | 124 | ]; |
125 | - case self::SUBJECT_ADD . '_self': |
|
126 | - case self::SUBJECT_DELETE . '_self': |
|
127 | - case self::SUBJECT_UPDATE . '_self': |
|
125 | + case self::SUBJECT_ADD.'_self': |
|
126 | + case self::SUBJECT_DELETE.'_self': |
|
127 | + case self::SUBJECT_UPDATE.'_self': |
|
128 | 128 | return [ |
129 | 129 | 'addressbook' => $this->generateAddressbookParameter($parameters['addressbook'], $l), |
130 | 130 | 'card' => $this->generateCardParameter($parameters['card']), |
@@ -28,54 +28,54 @@ |
||
28 | 28 | use OCA\DAV\CalDAV\Activity\Setting\CalDAVSetting; |
29 | 29 | |
30 | 30 | class Setting extends CalDAVSetting { |
31 | - /** |
|
32 | - * @return string Lowercase a-z and underscore only identifier |
|
33 | - */ |
|
34 | - public function getIdentifier(): string { |
|
35 | - return 'contacts'; |
|
36 | - } |
|
31 | + /** |
|
32 | + * @return string Lowercase a-z and underscore only identifier |
|
33 | + */ |
|
34 | + public function getIdentifier(): string { |
|
35 | + return 'contacts'; |
|
36 | + } |
|
37 | 37 | |
38 | - /** |
|
39 | - * @return string A translated string |
|
40 | - */ |
|
41 | - public function getName(): string { |
|
42 | - return $this->l->t('A <strong>contact</strong> or <strong>addressbook</strong> was modified'); |
|
43 | - } |
|
38 | + /** |
|
39 | + * @return string A translated string |
|
40 | + */ |
|
41 | + public function getName(): string { |
|
42 | + return $this->l->t('A <strong>contact</strong> or <strong>addressbook</strong> was modified'); |
|
43 | + } |
|
44 | 44 | |
45 | - /** |
|
46 | - * @return int whether the filter should be rather on the top or bottom of |
|
47 | - * the admin section. The filters are arranged in ascending order of the |
|
48 | - * priority values. It is required to return a value between 0 and 100. |
|
49 | - */ |
|
50 | - public function getPriority(): int { |
|
51 | - return 50; |
|
52 | - } |
|
45 | + /** |
|
46 | + * @return int whether the filter should be rather on the top or bottom of |
|
47 | + * the admin section. The filters are arranged in ascending order of the |
|
48 | + * priority values. It is required to return a value between 0 and 100. |
|
49 | + */ |
|
50 | + public function getPriority(): int { |
|
51 | + return 50; |
|
52 | + } |
|
53 | 53 | |
54 | - /** |
|
55 | - * @return bool True when the option can be changed for the stream |
|
56 | - */ |
|
57 | - public function canChangeStream(): bool { |
|
58 | - return true; |
|
59 | - } |
|
54 | + /** |
|
55 | + * @return bool True when the option can be changed for the stream |
|
56 | + */ |
|
57 | + public function canChangeStream(): bool { |
|
58 | + return true; |
|
59 | + } |
|
60 | 60 | |
61 | - /** |
|
62 | - * @return bool True when the option can be changed for the stream |
|
63 | - */ |
|
64 | - public function isDefaultEnabledStream(): bool { |
|
65 | - return true; |
|
66 | - } |
|
61 | + /** |
|
62 | + * @return bool True when the option can be changed for the stream |
|
63 | + */ |
|
64 | + public function isDefaultEnabledStream(): bool { |
|
65 | + return true; |
|
66 | + } |
|
67 | 67 | |
68 | - /** |
|
69 | - * @return bool True when the option can be changed for the mail |
|
70 | - */ |
|
71 | - public function canChangeMail(): bool { |
|
72 | - return true; |
|
73 | - } |
|
68 | + /** |
|
69 | + * @return bool True when the option can be changed for the mail |
|
70 | + */ |
|
71 | + public function canChangeMail(): bool { |
|
72 | + return true; |
|
73 | + } |
|
74 | 74 | |
75 | - /** |
|
76 | - * @return bool True when the option can be changed for the stream |
|
77 | - */ |
|
78 | - public function isDefaultEnabledMail(): bool { |
|
79 | - return false; |
|
80 | - } |
|
75 | + /** |
|
76 | + * @return bool True when the option can be changed for the stream |
|
77 | + */ |
|
78 | + public function isDefaultEnabledMail(): bool { |
|
79 | + return false; |
|
80 | + } |
|
81 | 81 | } |
@@ -41,445 +41,445 @@ |
||
41 | 41 | |
42 | 42 | class Backend { |
43 | 43 | |
44 | - /** @var IActivityManager */ |
|
45 | - protected $activityManager; |
|
46 | - |
|
47 | - /** @var IGroupManager */ |
|
48 | - protected $groupManager; |
|
49 | - |
|
50 | - /** @var IUserSession */ |
|
51 | - protected $userSession; |
|
52 | - |
|
53 | - /** @var IAppManager */ |
|
54 | - protected $appManager; |
|
55 | - |
|
56 | - public function __construct(IActivityManager $activityManager, |
|
57 | - IGroupManager $groupManager, |
|
58 | - IUserSession $userSession, |
|
59 | - IAppManager $appManager) { |
|
60 | - $this->activityManager = $activityManager; |
|
61 | - $this->groupManager = $groupManager; |
|
62 | - $this->userSession = $userSession; |
|
63 | - $this->appManager = $appManager; |
|
64 | - } |
|
65 | - |
|
66 | - /** |
|
67 | - * Creates activities when an addressbook was creates |
|
68 | - * |
|
69 | - * @param array $addressbookData |
|
70 | - */ |
|
71 | - public function onAddressbookCreate(array $addressbookData): void { |
|
72 | - $this->triggerAddressbookActivity(Addressbook::SUBJECT_ADD, $addressbookData); |
|
73 | - } |
|
74 | - |
|
75 | - /** |
|
76 | - * Creates activities when a calendar was updated |
|
77 | - * |
|
78 | - * @param array $addressbookData |
|
79 | - * @param array $shares |
|
80 | - * @param array $properties |
|
81 | - */ |
|
82 | - public function onAddressbookUpdate(array $addressbookData, array $shares, array $properties): void { |
|
83 | - $this->triggerAddressbookActivity(Addressbook::SUBJECT_UPDATE, $addressbookData, $shares, $properties); |
|
84 | - } |
|
85 | - |
|
86 | - /** |
|
87 | - * Creates activities when a calendar was deleted |
|
88 | - * |
|
89 | - * @param array $addressbookData |
|
90 | - * @param array $shares |
|
91 | - */ |
|
92 | - public function onAddressbookDelete(array $addressbookData, array $shares): void { |
|
93 | - $this->triggerAddressbookActivity(Addressbook::SUBJECT_DELETE, $addressbookData, $shares); |
|
94 | - } |
|
95 | - |
|
96 | - /** |
|
97 | - * Creates activities for all related users when a calendar was touched |
|
98 | - * |
|
99 | - * @param string $action |
|
100 | - * @param array $addressbookData |
|
101 | - * @param array $shares |
|
102 | - * @param array $changedProperties |
|
103 | - */ |
|
104 | - protected function triggerAddressbookActivity(string $action, array $addressbookData, array $shares = [], array $changedProperties = []): void { |
|
105 | - if (!isset($addressbookData['principaluri'])) { |
|
106 | - return; |
|
107 | - } |
|
108 | - |
|
109 | - $principal = explode('/', $addressbookData['principaluri']); |
|
110 | - $owner = array_pop($principal); |
|
111 | - |
|
112 | - $currentUser = $this->userSession->getUser(); |
|
113 | - if ($currentUser instanceof IUser) { |
|
114 | - $currentUser = $currentUser->getUID(); |
|
115 | - } else { |
|
116 | - $currentUser = $owner; |
|
117 | - } |
|
118 | - |
|
119 | - $event = $this->activityManager->generateEvent(); |
|
120 | - $event->setApp('dav') |
|
121 | - ->setObject('addressbook', (int) $addressbookData['id']) |
|
122 | - ->setType('addressbook') |
|
123 | - ->setAuthor($currentUser); |
|
124 | - |
|
125 | - $changedVisibleInformation = array_intersect([ |
|
126 | - '{DAV:}displayname', |
|
127 | - '{' . Plugin::NS_CARDDAV . '}addressbook-description', |
|
128 | - ], array_keys($changedProperties)); |
|
129 | - |
|
130 | - if (empty($shares) || ($action === Addressbook::SUBJECT_UPDATE && empty($changedVisibleInformation))) { |
|
131 | - $users = [$owner]; |
|
132 | - } else { |
|
133 | - $users = $this->getUsersForShares($shares); |
|
134 | - $users[] = $owner; |
|
135 | - } |
|
136 | - |
|
137 | - foreach ($users as $user) { |
|
138 | - $event->setAffectedUser($user) |
|
139 | - ->setSubject( |
|
140 | - $user === $currentUser ? $action . '_self' : $action, |
|
141 | - [ |
|
142 | - 'actor' => $currentUser, |
|
143 | - 'addressbook' => [ |
|
144 | - 'id' => (int) $addressbookData['id'], |
|
145 | - 'uri' => $addressbookData['uri'], |
|
146 | - 'name' => $addressbookData['{DAV:}displayname'], |
|
147 | - ], |
|
148 | - ] |
|
149 | - ); |
|
150 | - $this->activityManager->publish($event); |
|
151 | - } |
|
152 | - } |
|
153 | - |
|
154 | - /** |
|
155 | - * Creates activities for all related users when an addressbook was (un-)shared |
|
156 | - * |
|
157 | - * @param array $addressbookData |
|
158 | - * @param array $shares |
|
159 | - * @param array $add |
|
160 | - * @param array $remove |
|
161 | - */ |
|
162 | - public function onAddressbookUpdateShares(array $addressbookData, array $shares, array $add, array $remove): void { |
|
163 | - $principal = explode('/', $addressbookData['principaluri']); |
|
164 | - $owner = $principal[2]; |
|
165 | - |
|
166 | - $currentUser = $this->userSession->getUser(); |
|
167 | - if ($currentUser instanceof IUser) { |
|
168 | - $currentUser = $currentUser->getUID(); |
|
169 | - } else { |
|
170 | - $currentUser = $owner; |
|
171 | - } |
|
172 | - |
|
173 | - $event = $this->activityManager->generateEvent(); |
|
174 | - $event->setApp('dav') |
|
175 | - ->setObject('addressbook', (int) $addressbookData['id']) |
|
176 | - ->setType('addressbook') |
|
177 | - ->setAuthor($currentUser); |
|
178 | - |
|
179 | - foreach ($remove as $principal) { |
|
180 | - // principal:principals/users/test |
|
181 | - $parts = explode(':', $principal, 2); |
|
182 | - if ($parts[0] !== 'principal') { |
|
183 | - continue; |
|
184 | - } |
|
185 | - $principal = explode('/', $parts[1]); |
|
186 | - |
|
187 | - if ($principal[1] === 'users') { |
|
188 | - $this->triggerActivityUser( |
|
189 | - $principal[2], |
|
190 | - $event, |
|
191 | - $addressbookData, |
|
192 | - Addressbook::SUBJECT_UNSHARE_USER, |
|
193 | - Addressbook::SUBJECT_DELETE . '_self' |
|
194 | - ); |
|
195 | - |
|
196 | - if ($owner !== $principal[2]) { |
|
197 | - $parameters = [ |
|
198 | - 'actor' => $event->getAuthor(), |
|
199 | - 'addressbook' => [ |
|
200 | - 'id' => (int) $addressbookData['id'], |
|
201 | - 'uri' => $addressbookData['uri'], |
|
202 | - 'name' => $addressbookData['{DAV:}displayname'], |
|
203 | - ], |
|
204 | - 'user' => $principal[2], |
|
205 | - ]; |
|
206 | - |
|
207 | - if ($owner === $event->getAuthor()) { |
|
208 | - $subject = Addressbook::SUBJECT_UNSHARE_USER . '_you'; |
|
209 | - } elseif ($principal[2] === $event->getAuthor()) { |
|
210 | - $subject = Addressbook::SUBJECT_UNSHARE_USER . '_self'; |
|
211 | - } else { |
|
212 | - $event->setAffectedUser($event->getAuthor()) |
|
213 | - ->setSubject(Addressbook::SUBJECT_UNSHARE_USER . '_you', $parameters); |
|
214 | - $this->activityManager->publish($event); |
|
215 | - |
|
216 | - $subject = Addressbook::SUBJECT_UNSHARE_USER . '_by'; |
|
217 | - } |
|
218 | - |
|
219 | - $event->setAffectedUser($owner) |
|
220 | - ->setSubject($subject, $parameters); |
|
221 | - $this->activityManager->publish($event); |
|
222 | - } |
|
223 | - } elseif ($principal[1] === 'groups') { |
|
224 | - $this->triggerActivityGroup($principal[2], $event, $addressbookData, Addressbook::SUBJECT_UNSHARE_USER); |
|
225 | - |
|
226 | - $parameters = [ |
|
227 | - 'actor' => $event->getAuthor(), |
|
228 | - 'addressbook' => [ |
|
229 | - 'id' => (int) $addressbookData['id'], |
|
230 | - 'uri' => $addressbookData['uri'], |
|
231 | - 'name' => $addressbookData['{DAV:}displayname'], |
|
232 | - ], |
|
233 | - 'group' => $principal[2], |
|
234 | - ]; |
|
235 | - |
|
236 | - if ($owner === $event->getAuthor()) { |
|
237 | - $subject = Addressbook::SUBJECT_UNSHARE_GROUP . '_you'; |
|
238 | - } else { |
|
239 | - $event->setAffectedUser($event->getAuthor()) |
|
240 | - ->setSubject(Addressbook::SUBJECT_UNSHARE_GROUP . '_you', $parameters); |
|
241 | - $this->activityManager->publish($event); |
|
242 | - |
|
243 | - $subject = Addressbook::SUBJECT_UNSHARE_GROUP . '_by'; |
|
244 | - } |
|
245 | - |
|
246 | - $event->setAffectedUser($owner) |
|
247 | - ->setSubject($subject, $parameters); |
|
248 | - $this->activityManager->publish($event); |
|
249 | - } |
|
250 | - } |
|
251 | - |
|
252 | - foreach ($add as $share) { |
|
253 | - if ($this->isAlreadyShared($share['href'], $shares)) { |
|
254 | - continue; |
|
255 | - } |
|
256 | - |
|
257 | - // principal:principals/users/test |
|
258 | - $parts = explode(':', $share['href'], 2); |
|
259 | - if ($parts[0] !== 'principal') { |
|
260 | - continue; |
|
261 | - } |
|
262 | - $principal = explode('/', $parts[1]); |
|
263 | - |
|
264 | - if ($principal[1] === 'users') { |
|
265 | - $this->triggerActivityUser($principal[2], $event, $addressbookData, Addressbook::SUBJECT_SHARE_USER); |
|
266 | - |
|
267 | - if ($owner !== $principal[2]) { |
|
268 | - $parameters = [ |
|
269 | - 'actor' => $event->getAuthor(), |
|
270 | - 'addressbook' => [ |
|
271 | - 'id' => (int) $addressbookData['id'], |
|
272 | - 'uri' => $addressbookData['uri'], |
|
273 | - 'name' => $addressbookData['{DAV:}displayname'], |
|
274 | - ], |
|
275 | - 'user' => $principal[2], |
|
276 | - ]; |
|
277 | - |
|
278 | - if ($owner === $event->getAuthor()) { |
|
279 | - $subject = Addressbook::SUBJECT_SHARE_USER . '_you'; |
|
280 | - } else { |
|
281 | - $event->setAffectedUser($event->getAuthor()) |
|
282 | - ->setSubject(Addressbook::SUBJECT_SHARE_USER . '_you', $parameters); |
|
283 | - $this->activityManager->publish($event); |
|
284 | - |
|
285 | - $subject = Addressbook::SUBJECT_SHARE_USER . '_by'; |
|
286 | - } |
|
287 | - |
|
288 | - $event->setAffectedUser($owner) |
|
289 | - ->setSubject($subject, $parameters); |
|
290 | - $this->activityManager->publish($event); |
|
291 | - } |
|
292 | - } elseif ($principal[1] === 'groups') { |
|
293 | - $this->triggerActivityGroup($principal[2], $event, $addressbookData, Addressbook::SUBJECT_SHARE_USER); |
|
294 | - |
|
295 | - $parameters = [ |
|
296 | - 'actor' => $event->getAuthor(), |
|
297 | - 'addressbook' => [ |
|
298 | - 'id' => (int) $addressbookData['id'], |
|
299 | - 'uri' => $addressbookData['uri'], |
|
300 | - 'name' => $addressbookData['{DAV:}displayname'], |
|
301 | - ], |
|
302 | - 'group' => $principal[2], |
|
303 | - ]; |
|
304 | - |
|
305 | - if ($owner === $event->getAuthor()) { |
|
306 | - $subject = Addressbook::SUBJECT_SHARE_GROUP . '_you'; |
|
307 | - } else { |
|
308 | - $event->setAffectedUser($event->getAuthor()) |
|
309 | - ->setSubject(Addressbook::SUBJECT_SHARE_GROUP . '_you', $parameters); |
|
310 | - $this->activityManager->publish($event); |
|
311 | - |
|
312 | - $subject = Addressbook::SUBJECT_SHARE_GROUP . '_by'; |
|
313 | - } |
|
314 | - |
|
315 | - $event->setAffectedUser($owner) |
|
316 | - ->setSubject($subject, $parameters); |
|
317 | - $this->activityManager->publish($event); |
|
318 | - } |
|
319 | - } |
|
320 | - } |
|
321 | - |
|
322 | - /** |
|
323 | - * Checks if a calendar is already shared with a principal |
|
324 | - * |
|
325 | - * @param string $principal |
|
326 | - * @param array[] $shares |
|
327 | - * @return bool |
|
328 | - */ |
|
329 | - protected function isAlreadyShared(string $principal, array $shares): bool { |
|
330 | - foreach ($shares as $share) { |
|
331 | - if ($principal === $share['href']) { |
|
332 | - return true; |
|
333 | - } |
|
334 | - } |
|
335 | - |
|
336 | - return false; |
|
337 | - } |
|
338 | - |
|
339 | - /** |
|
340 | - * Creates the given activity for all members of the given group |
|
341 | - * |
|
342 | - * @param string $gid |
|
343 | - * @param IEvent $event |
|
344 | - * @param array $properties |
|
345 | - * @param string $subject |
|
346 | - */ |
|
347 | - protected function triggerActivityGroup(string $gid, IEvent $event, array $properties, string $subject): void { |
|
348 | - $group = $this->groupManager->get($gid); |
|
349 | - |
|
350 | - if ($group instanceof IGroup) { |
|
351 | - foreach ($group->getUsers() as $user) { |
|
352 | - // Exclude current user |
|
353 | - if ($user->getUID() !== $event->getAuthor()) { |
|
354 | - $this->triggerActivityUser($user->getUID(), $event, $properties, $subject); |
|
355 | - } |
|
356 | - } |
|
357 | - } |
|
358 | - } |
|
359 | - |
|
360 | - /** |
|
361 | - * Creates the given activity for the given user |
|
362 | - * |
|
363 | - * @param string $user |
|
364 | - * @param IEvent $event |
|
365 | - * @param array $properties |
|
366 | - * @param string $subject |
|
367 | - * @param string $subjectSelf |
|
368 | - */ |
|
369 | - protected function triggerActivityUser(string $user, IEvent $event, array $properties, string $subject, string $subjectSelf = ''): void { |
|
370 | - $event->setAffectedUser($user) |
|
371 | - ->setSubject( |
|
372 | - $user === $event->getAuthor() && $subjectSelf ? $subjectSelf : $subject, |
|
373 | - [ |
|
374 | - 'actor' => $event->getAuthor(), |
|
375 | - 'addressbook' => [ |
|
376 | - 'id' => (int) $properties['id'], |
|
377 | - 'uri' => $properties['uri'], |
|
378 | - 'name' => $properties['{DAV:}displayname'], |
|
379 | - ], |
|
380 | - ] |
|
381 | - ); |
|
382 | - |
|
383 | - $this->activityManager->publish($event); |
|
384 | - } |
|
385 | - |
|
386 | - /** |
|
387 | - * Creates activities when a card was created/updated/deleted |
|
388 | - * |
|
389 | - * @param string $action |
|
390 | - * @param array $addressbookData |
|
391 | - * @param array $shares |
|
392 | - * @param array $cardData |
|
393 | - */ |
|
394 | - public function triggerCardActivity(string $action, array $addressbookData, array $shares, array $cardData): void { |
|
395 | - if (!isset($addressbookData['principaluri'])) { |
|
396 | - return; |
|
397 | - } |
|
398 | - |
|
399 | - $principal = explode('/', $addressbookData['principaluri']); |
|
400 | - $owner = array_pop($principal); |
|
401 | - |
|
402 | - $currentUser = $this->userSession->getUser(); |
|
403 | - if ($currentUser instanceof IUser) { |
|
404 | - $currentUser = $currentUser->getUID(); |
|
405 | - } else { |
|
406 | - $currentUser = $owner; |
|
407 | - } |
|
408 | - |
|
409 | - $card = $this->getCardNameAndId($cardData); |
|
410 | - |
|
411 | - $event = $this->activityManager->generateEvent(); |
|
412 | - $event->setApp('dav') |
|
413 | - ->setObject('addressbook', (int) $addressbookData['id']) |
|
414 | - ->setType('card') |
|
415 | - ->setAuthor($currentUser); |
|
416 | - |
|
417 | - $users = $this->getUsersForShares($shares); |
|
418 | - $users[] = $owner; |
|
419 | - |
|
420 | - // Users for share can return the owner itself if the calendar is published |
|
421 | - foreach (array_unique($users) as $user) { |
|
422 | - $params = [ |
|
423 | - 'actor' => $event->getAuthor(), |
|
424 | - 'addressbook' => [ |
|
425 | - 'id' => (int) $addressbookData['id'], |
|
426 | - 'uri' => $addressbookData['uri'], |
|
427 | - 'name' => $addressbookData['{DAV:}displayname'], |
|
428 | - ], |
|
429 | - 'card' => [ |
|
430 | - 'id' => $card['id'], |
|
431 | - 'name' => $card['name'], |
|
432 | - ], |
|
433 | - ]; |
|
434 | - |
|
435 | - |
|
436 | - $event->setAffectedUser($user) |
|
437 | - ->setSubject( |
|
438 | - $user === $currentUser ? $action . '_self' : $action, |
|
439 | - $params |
|
440 | - ); |
|
441 | - |
|
442 | - $this->activityManager->publish($event); |
|
443 | - } |
|
444 | - } |
|
445 | - |
|
446 | - /** |
|
447 | - * @param array $cardData |
|
448 | - * @return string[] |
|
449 | - */ |
|
450 | - protected function getCardNameAndId(array $cardData): array { |
|
451 | - $vObject = Reader::read($cardData['carddata']); |
|
452 | - return ['id' => (string) $vObject->UID, 'name' => (string) ($vObject->FN ?? '')]; |
|
453 | - } |
|
454 | - |
|
455 | - /** |
|
456 | - * Get all users that have access to a given calendar |
|
457 | - * |
|
458 | - * @param array $shares |
|
459 | - * @return string[] |
|
460 | - */ |
|
461 | - protected function getUsersForShares(array $shares): array { |
|
462 | - $users = $groups = []; |
|
463 | - foreach ($shares as $share) { |
|
464 | - $principal = explode('/', $share['{http://owncloud.org/ns}principal']); |
|
465 | - if ($principal[1] === 'users') { |
|
466 | - $users[] = $principal[2]; |
|
467 | - } elseif ($principal[1] === 'groups') { |
|
468 | - $groups[] = $principal[2]; |
|
469 | - } |
|
470 | - } |
|
471 | - |
|
472 | - if (!empty($groups)) { |
|
473 | - foreach ($groups as $gid) { |
|
474 | - $group = $this->groupManager->get($gid); |
|
475 | - if ($group instanceof IGroup) { |
|
476 | - foreach ($group->getUsers() as $user) { |
|
477 | - $users[] = $user->getUID(); |
|
478 | - } |
|
479 | - } |
|
480 | - } |
|
481 | - } |
|
482 | - |
|
483 | - return array_unique($users); |
|
484 | - } |
|
44 | + /** @var IActivityManager */ |
|
45 | + protected $activityManager; |
|
46 | + |
|
47 | + /** @var IGroupManager */ |
|
48 | + protected $groupManager; |
|
49 | + |
|
50 | + /** @var IUserSession */ |
|
51 | + protected $userSession; |
|
52 | + |
|
53 | + /** @var IAppManager */ |
|
54 | + protected $appManager; |
|
55 | + |
|
56 | + public function __construct(IActivityManager $activityManager, |
|
57 | + IGroupManager $groupManager, |
|
58 | + IUserSession $userSession, |
|
59 | + IAppManager $appManager) { |
|
60 | + $this->activityManager = $activityManager; |
|
61 | + $this->groupManager = $groupManager; |
|
62 | + $this->userSession = $userSession; |
|
63 | + $this->appManager = $appManager; |
|
64 | + } |
|
65 | + |
|
66 | + /** |
|
67 | + * Creates activities when an addressbook was creates |
|
68 | + * |
|
69 | + * @param array $addressbookData |
|
70 | + */ |
|
71 | + public function onAddressbookCreate(array $addressbookData): void { |
|
72 | + $this->triggerAddressbookActivity(Addressbook::SUBJECT_ADD, $addressbookData); |
|
73 | + } |
|
74 | + |
|
75 | + /** |
|
76 | + * Creates activities when a calendar was updated |
|
77 | + * |
|
78 | + * @param array $addressbookData |
|
79 | + * @param array $shares |
|
80 | + * @param array $properties |
|
81 | + */ |
|
82 | + public function onAddressbookUpdate(array $addressbookData, array $shares, array $properties): void { |
|
83 | + $this->triggerAddressbookActivity(Addressbook::SUBJECT_UPDATE, $addressbookData, $shares, $properties); |
|
84 | + } |
|
85 | + |
|
86 | + /** |
|
87 | + * Creates activities when a calendar was deleted |
|
88 | + * |
|
89 | + * @param array $addressbookData |
|
90 | + * @param array $shares |
|
91 | + */ |
|
92 | + public function onAddressbookDelete(array $addressbookData, array $shares): void { |
|
93 | + $this->triggerAddressbookActivity(Addressbook::SUBJECT_DELETE, $addressbookData, $shares); |
|
94 | + } |
|
95 | + |
|
96 | + /** |
|
97 | + * Creates activities for all related users when a calendar was touched |
|
98 | + * |
|
99 | + * @param string $action |
|
100 | + * @param array $addressbookData |
|
101 | + * @param array $shares |
|
102 | + * @param array $changedProperties |
|
103 | + */ |
|
104 | + protected function triggerAddressbookActivity(string $action, array $addressbookData, array $shares = [], array $changedProperties = []): void { |
|
105 | + if (!isset($addressbookData['principaluri'])) { |
|
106 | + return; |
|
107 | + } |
|
108 | + |
|
109 | + $principal = explode('/', $addressbookData['principaluri']); |
|
110 | + $owner = array_pop($principal); |
|
111 | + |
|
112 | + $currentUser = $this->userSession->getUser(); |
|
113 | + if ($currentUser instanceof IUser) { |
|
114 | + $currentUser = $currentUser->getUID(); |
|
115 | + } else { |
|
116 | + $currentUser = $owner; |
|
117 | + } |
|
118 | + |
|
119 | + $event = $this->activityManager->generateEvent(); |
|
120 | + $event->setApp('dav') |
|
121 | + ->setObject('addressbook', (int) $addressbookData['id']) |
|
122 | + ->setType('addressbook') |
|
123 | + ->setAuthor($currentUser); |
|
124 | + |
|
125 | + $changedVisibleInformation = array_intersect([ |
|
126 | + '{DAV:}displayname', |
|
127 | + '{' . Plugin::NS_CARDDAV . '}addressbook-description', |
|
128 | + ], array_keys($changedProperties)); |
|
129 | + |
|
130 | + if (empty($shares) || ($action === Addressbook::SUBJECT_UPDATE && empty($changedVisibleInformation))) { |
|
131 | + $users = [$owner]; |
|
132 | + } else { |
|
133 | + $users = $this->getUsersForShares($shares); |
|
134 | + $users[] = $owner; |
|
135 | + } |
|
136 | + |
|
137 | + foreach ($users as $user) { |
|
138 | + $event->setAffectedUser($user) |
|
139 | + ->setSubject( |
|
140 | + $user === $currentUser ? $action . '_self' : $action, |
|
141 | + [ |
|
142 | + 'actor' => $currentUser, |
|
143 | + 'addressbook' => [ |
|
144 | + 'id' => (int) $addressbookData['id'], |
|
145 | + 'uri' => $addressbookData['uri'], |
|
146 | + 'name' => $addressbookData['{DAV:}displayname'], |
|
147 | + ], |
|
148 | + ] |
|
149 | + ); |
|
150 | + $this->activityManager->publish($event); |
|
151 | + } |
|
152 | + } |
|
153 | + |
|
154 | + /** |
|
155 | + * Creates activities for all related users when an addressbook was (un-)shared |
|
156 | + * |
|
157 | + * @param array $addressbookData |
|
158 | + * @param array $shares |
|
159 | + * @param array $add |
|
160 | + * @param array $remove |
|
161 | + */ |
|
162 | + public function onAddressbookUpdateShares(array $addressbookData, array $shares, array $add, array $remove): void { |
|
163 | + $principal = explode('/', $addressbookData['principaluri']); |
|
164 | + $owner = $principal[2]; |
|
165 | + |
|
166 | + $currentUser = $this->userSession->getUser(); |
|
167 | + if ($currentUser instanceof IUser) { |
|
168 | + $currentUser = $currentUser->getUID(); |
|
169 | + } else { |
|
170 | + $currentUser = $owner; |
|
171 | + } |
|
172 | + |
|
173 | + $event = $this->activityManager->generateEvent(); |
|
174 | + $event->setApp('dav') |
|
175 | + ->setObject('addressbook', (int) $addressbookData['id']) |
|
176 | + ->setType('addressbook') |
|
177 | + ->setAuthor($currentUser); |
|
178 | + |
|
179 | + foreach ($remove as $principal) { |
|
180 | + // principal:principals/users/test |
|
181 | + $parts = explode(':', $principal, 2); |
|
182 | + if ($parts[0] !== 'principal') { |
|
183 | + continue; |
|
184 | + } |
|
185 | + $principal = explode('/', $parts[1]); |
|
186 | + |
|
187 | + if ($principal[1] === 'users') { |
|
188 | + $this->triggerActivityUser( |
|
189 | + $principal[2], |
|
190 | + $event, |
|
191 | + $addressbookData, |
|
192 | + Addressbook::SUBJECT_UNSHARE_USER, |
|
193 | + Addressbook::SUBJECT_DELETE . '_self' |
|
194 | + ); |
|
195 | + |
|
196 | + if ($owner !== $principal[2]) { |
|
197 | + $parameters = [ |
|
198 | + 'actor' => $event->getAuthor(), |
|
199 | + 'addressbook' => [ |
|
200 | + 'id' => (int) $addressbookData['id'], |
|
201 | + 'uri' => $addressbookData['uri'], |
|
202 | + 'name' => $addressbookData['{DAV:}displayname'], |
|
203 | + ], |
|
204 | + 'user' => $principal[2], |
|
205 | + ]; |
|
206 | + |
|
207 | + if ($owner === $event->getAuthor()) { |
|
208 | + $subject = Addressbook::SUBJECT_UNSHARE_USER . '_you'; |
|
209 | + } elseif ($principal[2] === $event->getAuthor()) { |
|
210 | + $subject = Addressbook::SUBJECT_UNSHARE_USER . '_self'; |
|
211 | + } else { |
|
212 | + $event->setAffectedUser($event->getAuthor()) |
|
213 | + ->setSubject(Addressbook::SUBJECT_UNSHARE_USER . '_you', $parameters); |
|
214 | + $this->activityManager->publish($event); |
|
215 | + |
|
216 | + $subject = Addressbook::SUBJECT_UNSHARE_USER . '_by'; |
|
217 | + } |
|
218 | + |
|
219 | + $event->setAffectedUser($owner) |
|
220 | + ->setSubject($subject, $parameters); |
|
221 | + $this->activityManager->publish($event); |
|
222 | + } |
|
223 | + } elseif ($principal[1] === 'groups') { |
|
224 | + $this->triggerActivityGroup($principal[2], $event, $addressbookData, Addressbook::SUBJECT_UNSHARE_USER); |
|
225 | + |
|
226 | + $parameters = [ |
|
227 | + 'actor' => $event->getAuthor(), |
|
228 | + 'addressbook' => [ |
|
229 | + 'id' => (int) $addressbookData['id'], |
|
230 | + 'uri' => $addressbookData['uri'], |
|
231 | + 'name' => $addressbookData['{DAV:}displayname'], |
|
232 | + ], |
|
233 | + 'group' => $principal[2], |
|
234 | + ]; |
|
235 | + |
|
236 | + if ($owner === $event->getAuthor()) { |
|
237 | + $subject = Addressbook::SUBJECT_UNSHARE_GROUP . '_you'; |
|
238 | + } else { |
|
239 | + $event->setAffectedUser($event->getAuthor()) |
|
240 | + ->setSubject(Addressbook::SUBJECT_UNSHARE_GROUP . '_you', $parameters); |
|
241 | + $this->activityManager->publish($event); |
|
242 | + |
|
243 | + $subject = Addressbook::SUBJECT_UNSHARE_GROUP . '_by'; |
|
244 | + } |
|
245 | + |
|
246 | + $event->setAffectedUser($owner) |
|
247 | + ->setSubject($subject, $parameters); |
|
248 | + $this->activityManager->publish($event); |
|
249 | + } |
|
250 | + } |
|
251 | + |
|
252 | + foreach ($add as $share) { |
|
253 | + if ($this->isAlreadyShared($share['href'], $shares)) { |
|
254 | + continue; |
|
255 | + } |
|
256 | + |
|
257 | + // principal:principals/users/test |
|
258 | + $parts = explode(':', $share['href'], 2); |
|
259 | + if ($parts[0] !== 'principal') { |
|
260 | + continue; |
|
261 | + } |
|
262 | + $principal = explode('/', $parts[1]); |
|
263 | + |
|
264 | + if ($principal[1] === 'users') { |
|
265 | + $this->triggerActivityUser($principal[2], $event, $addressbookData, Addressbook::SUBJECT_SHARE_USER); |
|
266 | + |
|
267 | + if ($owner !== $principal[2]) { |
|
268 | + $parameters = [ |
|
269 | + 'actor' => $event->getAuthor(), |
|
270 | + 'addressbook' => [ |
|
271 | + 'id' => (int) $addressbookData['id'], |
|
272 | + 'uri' => $addressbookData['uri'], |
|
273 | + 'name' => $addressbookData['{DAV:}displayname'], |
|
274 | + ], |
|
275 | + 'user' => $principal[2], |
|
276 | + ]; |
|
277 | + |
|
278 | + if ($owner === $event->getAuthor()) { |
|
279 | + $subject = Addressbook::SUBJECT_SHARE_USER . '_you'; |
|
280 | + } else { |
|
281 | + $event->setAffectedUser($event->getAuthor()) |
|
282 | + ->setSubject(Addressbook::SUBJECT_SHARE_USER . '_you', $parameters); |
|
283 | + $this->activityManager->publish($event); |
|
284 | + |
|
285 | + $subject = Addressbook::SUBJECT_SHARE_USER . '_by'; |
|
286 | + } |
|
287 | + |
|
288 | + $event->setAffectedUser($owner) |
|
289 | + ->setSubject($subject, $parameters); |
|
290 | + $this->activityManager->publish($event); |
|
291 | + } |
|
292 | + } elseif ($principal[1] === 'groups') { |
|
293 | + $this->triggerActivityGroup($principal[2], $event, $addressbookData, Addressbook::SUBJECT_SHARE_USER); |
|
294 | + |
|
295 | + $parameters = [ |
|
296 | + 'actor' => $event->getAuthor(), |
|
297 | + 'addressbook' => [ |
|
298 | + 'id' => (int) $addressbookData['id'], |
|
299 | + 'uri' => $addressbookData['uri'], |
|
300 | + 'name' => $addressbookData['{DAV:}displayname'], |
|
301 | + ], |
|
302 | + 'group' => $principal[2], |
|
303 | + ]; |
|
304 | + |
|
305 | + if ($owner === $event->getAuthor()) { |
|
306 | + $subject = Addressbook::SUBJECT_SHARE_GROUP . '_you'; |
|
307 | + } else { |
|
308 | + $event->setAffectedUser($event->getAuthor()) |
|
309 | + ->setSubject(Addressbook::SUBJECT_SHARE_GROUP . '_you', $parameters); |
|
310 | + $this->activityManager->publish($event); |
|
311 | + |
|
312 | + $subject = Addressbook::SUBJECT_SHARE_GROUP . '_by'; |
|
313 | + } |
|
314 | + |
|
315 | + $event->setAffectedUser($owner) |
|
316 | + ->setSubject($subject, $parameters); |
|
317 | + $this->activityManager->publish($event); |
|
318 | + } |
|
319 | + } |
|
320 | + } |
|
321 | + |
|
322 | + /** |
|
323 | + * Checks if a calendar is already shared with a principal |
|
324 | + * |
|
325 | + * @param string $principal |
|
326 | + * @param array[] $shares |
|
327 | + * @return bool |
|
328 | + */ |
|
329 | + protected function isAlreadyShared(string $principal, array $shares): bool { |
|
330 | + foreach ($shares as $share) { |
|
331 | + if ($principal === $share['href']) { |
|
332 | + return true; |
|
333 | + } |
|
334 | + } |
|
335 | + |
|
336 | + return false; |
|
337 | + } |
|
338 | + |
|
339 | + /** |
|
340 | + * Creates the given activity for all members of the given group |
|
341 | + * |
|
342 | + * @param string $gid |
|
343 | + * @param IEvent $event |
|
344 | + * @param array $properties |
|
345 | + * @param string $subject |
|
346 | + */ |
|
347 | + protected function triggerActivityGroup(string $gid, IEvent $event, array $properties, string $subject): void { |
|
348 | + $group = $this->groupManager->get($gid); |
|
349 | + |
|
350 | + if ($group instanceof IGroup) { |
|
351 | + foreach ($group->getUsers() as $user) { |
|
352 | + // Exclude current user |
|
353 | + if ($user->getUID() !== $event->getAuthor()) { |
|
354 | + $this->triggerActivityUser($user->getUID(), $event, $properties, $subject); |
|
355 | + } |
|
356 | + } |
|
357 | + } |
|
358 | + } |
|
359 | + |
|
360 | + /** |
|
361 | + * Creates the given activity for the given user |
|
362 | + * |
|
363 | + * @param string $user |
|
364 | + * @param IEvent $event |
|
365 | + * @param array $properties |
|
366 | + * @param string $subject |
|
367 | + * @param string $subjectSelf |
|
368 | + */ |
|
369 | + protected function triggerActivityUser(string $user, IEvent $event, array $properties, string $subject, string $subjectSelf = ''): void { |
|
370 | + $event->setAffectedUser($user) |
|
371 | + ->setSubject( |
|
372 | + $user === $event->getAuthor() && $subjectSelf ? $subjectSelf : $subject, |
|
373 | + [ |
|
374 | + 'actor' => $event->getAuthor(), |
|
375 | + 'addressbook' => [ |
|
376 | + 'id' => (int) $properties['id'], |
|
377 | + 'uri' => $properties['uri'], |
|
378 | + 'name' => $properties['{DAV:}displayname'], |
|
379 | + ], |
|
380 | + ] |
|
381 | + ); |
|
382 | + |
|
383 | + $this->activityManager->publish($event); |
|
384 | + } |
|
385 | + |
|
386 | + /** |
|
387 | + * Creates activities when a card was created/updated/deleted |
|
388 | + * |
|
389 | + * @param string $action |
|
390 | + * @param array $addressbookData |
|
391 | + * @param array $shares |
|
392 | + * @param array $cardData |
|
393 | + */ |
|
394 | + public function triggerCardActivity(string $action, array $addressbookData, array $shares, array $cardData): void { |
|
395 | + if (!isset($addressbookData['principaluri'])) { |
|
396 | + return; |
|
397 | + } |
|
398 | + |
|
399 | + $principal = explode('/', $addressbookData['principaluri']); |
|
400 | + $owner = array_pop($principal); |
|
401 | + |
|
402 | + $currentUser = $this->userSession->getUser(); |
|
403 | + if ($currentUser instanceof IUser) { |
|
404 | + $currentUser = $currentUser->getUID(); |
|
405 | + } else { |
|
406 | + $currentUser = $owner; |
|
407 | + } |
|
408 | + |
|
409 | + $card = $this->getCardNameAndId($cardData); |
|
410 | + |
|
411 | + $event = $this->activityManager->generateEvent(); |
|
412 | + $event->setApp('dav') |
|
413 | + ->setObject('addressbook', (int) $addressbookData['id']) |
|
414 | + ->setType('card') |
|
415 | + ->setAuthor($currentUser); |
|
416 | + |
|
417 | + $users = $this->getUsersForShares($shares); |
|
418 | + $users[] = $owner; |
|
419 | + |
|
420 | + // Users for share can return the owner itself if the calendar is published |
|
421 | + foreach (array_unique($users) as $user) { |
|
422 | + $params = [ |
|
423 | + 'actor' => $event->getAuthor(), |
|
424 | + 'addressbook' => [ |
|
425 | + 'id' => (int) $addressbookData['id'], |
|
426 | + 'uri' => $addressbookData['uri'], |
|
427 | + 'name' => $addressbookData['{DAV:}displayname'], |
|
428 | + ], |
|
429 | + 'card' => [ |
|
430 | + 'id' => $card['id'], |
|
431 | + 'name' => $card['name'], |
|
432 | + ], |
|
433 | + ]; |
|
434 | + |
|
435 | + |
|
436 | + $event->setAffectedUser($user) |
|
437 | + ->setSubject( |
|
438 | + $user === $currentUser ? $action . '_self' : $action, |
|
439 | + $params |
|
440 | + ); |
|
441 | + |
|
442 | + $this->activityManager->publish($event); |
|
443 | + } |
|
444 | + } |
|
445 | + |
|
446 | + /** |
|
447 | + * @param array $cardData |
|
448 | + * @return string[] |
|
449 | + */ |
|
450 | + protected function getCardNameAndId(array $cardData): array { |
|
451 | + $vObject = Reader::read($cardData['carddata']); |
|
452 | + return ['id' => (string) $vObject->UID, 'name' => (string) ($vObject->FN ?? '')]; |
|
453 | + } |
|
454 | + |
|
455 | + /** |
|
456 | + * Get all users that have access to a given calendar |
|
457 | + * |
|
458 | + * @param array $shares |
|
459 | + * @return string[] |
|
460 | + */ |
|
461 | + protected function getUsersForShares(array $shares): array { |
|
462 | + $users = $groups = []; |
|
463 | + foreach ($shares as $share) { |
|
464 | + $principal = explode('/', $share['{http://owncloud.org/ns}principal']); |
|
465 | + if ($principal[1] === 'users') { |
|
466 | + $users[] = $principal[2]; |
|
467 | + } elseif ($principal[1] === 'groups') { |
|
468 | + $groups[] = $principal[2]; |
|
469 | + } |
|
470 | + } |
|
471 | + |
|
472 | + if (!empty($groups)) { |
|
473 | + foreach ($groups as $gid) { |
|
474 | + $group = $this->groupManager->get($gid); |
|
475 | + if ($group instanceof IGroup) { |
|
476 | + foreach ($group->getUsers() as $user) { |
|
477 | + $users[] = $user->getUID(); |
|
478 | + } |
|
479 | + } |
|
480 | + } |
|
481 | + } |
|
482 | + |
|
483 | + return array_unique($users); |
|
484 | + } |
|
485 | 485 | } |
@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | |
125 | 125 | $changedVisibleInformation = array_intersect([ |
126 | 126 | '{DAV:}displayname', |
127 | - '{' . Plugin::NS_CARDDAV . '}addressbook-description', |
|
127 | + '{'.Plugin::NS_CARDDAV.'}addressbook-description', |
|
128 | 128 | ], array_keys($changedProperties)); |
129 | 129 | |
130 | 130 | if (empty($shares) || ($action === Addressbook::SUBJECT_UPDATE && empty($changedVisibleInformation))) { |
@@ -137,7 +137,7 @@ discard block |
||
137 | 137 | foreach ($users as $user) { |
138 | 138 | $event->setAffectedUser($user) |
139 | 139 | ->setSubject( |
140 | - $user === $currentUser ? $action . '_self' : $action, |
|
140 | + $user === $currentUser ? $action.'_self' : $action, |
|
141 | 141 | [ |
142 | 142 | 'actor' => $currentUser, |
143 | 143 | 'addressbook' => [ |
@@ -190,7 +190,7 @@ discard block |
||
190 | 190 | $event, |
191 | 191 | $addressbookData, |
192 | 192 | Addressbook::SUBJECT_UNSHARE_USER, |
193 | - Addressbook::SUBJECT_DELETE . '_self' |
|
193 | + Addressbook::SUBJECT_DELETE.'_self' |
|
194 | 194 | ); |
195 | 195 | |
196 | 196 | if ($owner !== $principal[2]) { |
@@ -205,15 +205,15 @@ discard block |
||
205 | 205 | ]; |
206 | 206 | |
207 | 207 | if ($owner === $event->getAuthor()) { |
208 | - $subject = Addressbook::SUBJECT_UNSHARE_USER . '_you'; |
|
208 | + $subject = Addressbook::SUBJECT_UNSHARE_USER.'_you'; |
|
209 | 209 | } elseif ($principal[2] === $event->getAuthor()) { |
210 | - $subject = Addressbook::SUBJECT_UNSHARE_USER . '_self'; |
|
210 | + $subject = Addressbook::SUBJECT_UNSHARE_USER.'_self'; |
|
211 | 211 | } else { |
212 | 212 | $event->setAffectedUser($event->getAuthor()) |
213 | - ->setSubject(Addressbook::SUBJECT_UNSHARE_USER . '_you', $parameters); |
|
213 | + ->setSubject(Addressbook::SUBJECT_UNSHARE_USER.'_you', $parameters); |
|
214 | 214 | $this->activityManager->publish($event); |
215 | 215 | |
216 | - $subject = Addressbook::SUBJECT_UNSHARE_USER . '_by'; |
|
216 | + $subject = Addressbook::SUBJECT_UNSHARE_USER.'_by'; |
|
217 | 217 | } |
218 | 218 | |
219 | 219 | $event->setAffectedUser($owner) |
@@ -234,13 +234,13 @@ discard block |
||
234 | 234 | ]; |
235 | 235 | |
236 | 236 | if ($owner === $event->getAuthor()) { |
237 | - $subject = Addressbook::SUBJECT_UNSHARE_GROUP . '_you'; |
|
237 | + $subject = Addressbook::SUBJECT_UNSHARE_GROUP.'_you'; |
|
238 | 238 | } else { |
239 | 239 | $event->setAffectedUser($event->getAuthor()) |
240 | - ->setSubject(Addressbook::SUBJECT_UNSHARE_GROUP . '_you', $parameters); |
|
240 | + ->setSubject(Addressbook::SUBJECT_UNSHARE_GROUP.'_you', $parameters); |
|
241 | 241 | $this->activityManager->publish($event); |
242 | 242 | |
243 | - $subject = Addressbook::SUBJECT_UNSHARE_GROUP . '_by'; |
|
243 | + $subject = Addressbook::SUBJECT_UNSHARE_GROUP.'_by'; |
|
244 | 244 | } |
245 | 245 | |
246 | 246 | $event->setAffectedUser($owner) |
@@ -276,13 +276,13 @@ discard block |
||
276 | 276 | ]; |
277 | 277 | |
278 | 278 | if ($owner === $event->getAuthor()) { |
279 | - $subject = Addressbook::SUBJECT_SHARE_USER . '_you'; |
|
279 | + $subject = Addressbook::SUBJECT_SHARE_USER.'_you'; |
|
280 | 280 | } else { |
281 | 281 | $event->setAffectedUser($event->getAuthor()) |
282 | - ->setSubject(Addressbook::SUBJECT_SHARE_USER . '_you', $parameters); |
|
282 | + ->setSubject(Addressbook::SUBJECT_SHARE_USER.'_you', $parameters); |
|
283 | 283 | $this->activityManager->publish($event); |
284 | 284 | |
285 | - $subject = Addressbook::SUBJECT_SHARE_USER . '_by'; |
|
285 | + $subject = Addressbook::SUBJECT_SHARE_USER.'_by'; |
|
286 | 286 | } |
287 | 287 | |
288 | 288 | $event->setAffectedUser($owner) |
@@ -303,13 +303,13 @@ discard block |
||
303 | 303 | ]; |
304 | 304 | |
305 | 305 | if ($owner === $event->getAuthor()) { |
306 | - $subject = Addressbook::SUBJECT_SHARE_GROUP . '_you'; |
|
306 | + $subject = Addressbook::SUBJECT_SHARE_GROUP.'_you'; |
|
307 | 307 | } else { |
308 | 308 | $event->setAffectedUser($event->getAuthor()) |
309 | - ->setSubject(Addressbook::SUBJECT_SHARE_GROUP . '_you', $parameters); |
|
309 | + ->setSubject(Addressbook::SUBJECT_SHARE_GROUP.'_you', $parameters); |
|
310 | 310 | $this->activityManager->publish($event); |
311 | 311 | |
312 | - $subject = Addressbook::SUBJECT_SHARE_GROUP . '_by'; |
|
312 | + $subject = Addressbook::SUBJECT_SHARE_GROUP.'_by'; |
|
313 | 313 | } |
314 | 314 | |
315 | 315 | $event->setAffectedUser($owner) |
@@ -435,7 +435,7 @@ discard block |
||
435 | 435 | |
436 | 436 | $event->setAffectedUser($user) |
437 | 437 | ->setSubject( |
438 | - $user === $currentUser ? $action . '_self' : $action, |
|
438 | + $user === $currentUser ? $action.'_self' : $action, |
|
439 | 439 | $params |
440 | 440 | ); |
441 | 441 |
@@ -36,73 +36,73 @@ |
||
36 | 36 | use function sprintf; |
37 | 37 | |
38 | 38 | class CardListener implements IEventListener { |
39 | - /** @var ActivityBackend */ |
|
40 | - private $activityBackend; |
|
39 | + /** @var ActivityBackend */ |
|
40 | + private $activityBackend; |
|
41 | 41 | |
42 | - /** @var LoggerInterface */ |
|
43 | - private $logger; |
|
42 | + /** @var LoggerInterface */ |
|
43 | + private $logger; |
|
44 | 44 | |
45 | - public function __construct(ActivityBackend $activityBackend, |
|
46 | - LoggerInterface $logger) { |
|
47 | - $this->activityBackend = $activityBackend; |
|
48 | - $this->logger = $logger; |
|
49 | - } |
|
45 | + public function __construct(ActivityBackend $activityBackend, |
|
46 | + LoggerInterface $logger) { |
|
47 | + $this->activityBackend = $activityBackend; |
|
48 | + $this->logger = $logger; |
|
49 | + } |
|
50 | 50 | |
51 | - public function handle(Event $event): void { |
|
52 | - if ($event instanceof CardCreatedEvent) { |
|
53 | - try { |
|
54 | - $this->activityBackend->triggerCardActivity( |
|
55 | - Card::SUBJECT_ADD, |
|
56 | - $event->getAddressBookData(), |
|
57 | - $event->getShares(), |
|
58 | - $event->getCardData() |
|
59 | - ); |
|
51 | + public function handle(Event $event): void { |
|
52 | + if ($event instanceof CardCreatedEvent) { |
|
53 | + try { |
|
54 | + $this->activityBackend->triggerCardActivity( |
|
55 | + Card::SUBJECT_ADD, |
|
56 | + $event->getAddressBookData(), |
|
57 | + $event->getShares(), |
|
58 | + $event->getCardData() |
|
59 | + ); |
|
60 | 60 | |
61 | - $this->logger->debug( |
|
62 | - sprintf('Activity generated for a new card in addressbook %d', $event->getAddressBookId()) |
|
63 | - ); |
|
64 | - } catch (Throwable $e) { |
|
65 | - // Any error with activities shouldn't abort the addressbook creation, so we just log it |
|
66 | - $this->logger->error('Error generating activities for a new card in addressbook: ' . $e->getMessage(), [ |
|
67 | - 'exception' => $e, |
|
68 | - ]); |
|
69 | - } |
|
70 | - } elseif ($event instanceof CardUpdatedEvent) { |
|
71 | - try { |
|
72 | - $this->activityBackend->triggerCardActivity( |
|
73 | - Card::SUBJECT_UPDATE, |
|
74 | - $event->getAddressBookData(), |
|
75 | - $event->getShares(), |
|
76 | - $event->getCardData() |
|
77 | - ); |
|
61 | + $this->logger->debug( |
|
62 | + sprintf('Activity generated for a new card in addressbook %d', $event->getAddressBookId()) |
|
63 | + ); |
|
64 | + } catch (Throwable $e) { |
|
65 | + // Any error with activities shouldn't abort the addressbook creation, so we just log it |
|
66 | + $this->logger->error('Error generating activities for a new card in addressbook: ' . $e->getMessage(), [ |
|
67 | + 'exception' => $e, |
|
68 | + ]); |
|
69 | + } |
|
70 | + } elseif ($event instanceof CardUpdatedEvent) { |
|
71 | + try { |
|
72 | + $this->activityBackend->triggerCardActivity( |
|
73 | + Card::SUBJECT_UPDATE, |
|
74 | + $event->getAddressBookData(), |
|
75 | + $event->getShares(), |
|
76 | + $event->getCardData() |
|
77 | + ); |
|
78 | 78 | |
79 | - $this->logger->debug( |
|
80 | - sprintf('Activity generated for a changed card in addressbook %d', $event->getAddressBookId()) |
|
81 | - ); |
|
82 | - } catch (Throwable $e) { |
|
83 | - // Any error with activities shouldn't abort the addressbook update, so we just log it |
|
84 | - $this->logger->error('Error generating activities for a changed card in addressbook: ' . $e->getMessage(), [ |
|
85 | - 'exception' => $e, |
|
86 | - ]); |
|
87 | - } |
|
88 | - } elseif ($event instanceof CardDeletedEvent) { |
|
89 | - try { |
|
90 | - $this->activityBackend->triggerCardActivity( |
|
91 | - Card::SUBJECT_DELETE, |
|
92 | - $event->getAddressBookData(), |
|
93 | - $event->getShares(), |
|
94 | - $event->getCardData() |
|
95 | - ); |
|
79 | + $this->logger->debug( |
|
80 | + sprintf('Activity generated for a changed card in addressbook %d', $event->getAddressBookId()) |
|
81 | + ); |
|
82 | + } catch (Throwable $e) { |
|
83 | + // Any error with activities shouldn't abort the addressbook update, so we just log it |
|
84 | + $this->logger->error('Error generating activities for a changed card in addressbook: ' . $e->getMessage(), [ |
|
85 | + 'exception' => $e, |
|
86 | + ]); |
|
87 | + } |
|
88 | + } elseif ($event instanceof CardDeletedEvent) { |
|
89 | + try { |
|
90 | + $this->activityBackend->triggerCardActivity( |
|
91 | + Card::SUBJECT_DELETE, |
|
92 | + $event->getAddressBookData(), |
|
93 | + $event->getShares(), |
|
94 | + $event->getCardData() |
|
95 | + ); |
|
96 | 96 | |
97 | - $this->logger->debug( |
|
98 | - sprintf('Activity generated for a deleted card in addressbook %d', $event->getAddressBookId()) |
|
99 | - ); |
|
100 | - } catch (Throwable $e) { |
|
101 | - // Any error with activities shouldn't abort the addressbook deletion, so we just log it |
|
102 | - $this->logger->error('Error generating activities for a deleted card in addressbook: ' . $e->getMessage(), [ |
|
103 | - 'exception' => $e, |
|
104 | - ]); |
|
105 | - } |
|
106 | - } |
|
107 | - } |
|
97 | + $this->logger->debug( |
|
98 | + sprintf('Activity generated for a deleted card in addressbook %d', $event->getAddressBookId()) |
|
99 | + ); |
|
100 | + } catch (Throwable $e) { |
|
101 | + // Any error with activities shouldn't abort the addressbook deletion, so we just log it |
|
102 | + $this->logger->error('Error generating activities for a deleted card in addressbook: ' . $e->getMessage(), [ |
|
103 | + 'exception' => $e, |
|
104 | + ]); |
|
105 | + } |
|
106 | + } |
|
107 | + } |
|
108 | 108 | } |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | ); |
64 | 64 | } catch (Throwable $e) { |
65 | 65 | // Any error with activities shouldn't abort the addressbook creation, so we just log it |
66 | - $this->logger->error('Error generating activities for a new card in addressbook: ' . $e->getMessage(), [ |
|
66 | + $this->logger->error('Error generating activities for a new card in addressbook: '.$e->getMessage(), [ |
|
67 | 67 | 'exception' => $e, |
68 | 68 | ]); |
69 | 69 | } |
@@ -81,7 +81,7 @@ discard block |
||
81 | 81 | ); |
82 | 82 | } catch (Throwable $e) { |
83 | 83 | // Any error with activities shouldn't abort the addressbook update, so we just log it |
84 | - $this->logger->error('Error generating activities for a changed card in addressbook: ' . $e->getMessage(), [ |
|
84 | + $this->logger->error('Error generating activities for a changed card in addressbook: '.$e->getMessage(), [ |
|
85 | 85 | 'exception' => $e, |
86 | 86 | ]); |
87 | 87 | } |
@@ -99,7 +99,7 @@ discard block |
||
99 | 99 | ); |
100 | 100 | } catch (Throwable $e) { |
101 | 101 | // Any error with activities shouldn't abort the addressbook deletion, so we just log it |
102 | - $this->logger->error('Error generating activities for a deleted card in addressbook: ' . $e->getMessage(), [ |
|
102 | + $this->logger->error('Error generating activities for a deleted card in addressbook: '.$e->getMessage(), [ |
|
103 | 103 | 'exception' => $e, |
104 | 104 | ]); |
105 | 105 | } |
@@ -36,85 +36,85 @@ |
||
36 | 36 | use function sprintf; |
37 | 37 | |
38 | 38 | class AddressbookListener implements IEventListener { |
39 | - /** @var ActivityBackend */ |
|
40 | - private $activityBackend; |
|
39 | + /** @var ActivityBackend */ |
|
40 | + private $activityBackend; |
|
41 | 41 | |
42 | - /** @var LoggerInterface */ |
|
43 | - private $logger; |
|
42 | + /** @var LoggerInterface */ |
|
43 | + private $logger; |
|
44 | 44 | |
45 | - public function __construct(ActivityBackend $activityBackend, |
|
46 | - LoggerInterface $logger) { |
|
47 | - $this->activityBackend = $activityBackend; |
|
48 | - $this->logger = $logger; |
|
49 | - } |
|
45 | + public function __construct(ActivityBackend $activityBackend, |
|
46 | + LoggerInterface $logger) { |
|
47 | + $this->activityBackend = $activityBackend; |
|
48 | + $this->logger = $logger; |
|
49 | + } |
|
50 | 50 | |
51 | - public function handle(Event $event): void { |
|
52 | - if ($event instanceof AddressBookCreatedEvent) { |
|
53 | - try { |
|
54 | - $this->activityBackend->onAddressbookCreate( |
|
55 | - $event->getAddressBookData() |
|
56 | - ); |
|
51 | + public function handle(Event $event): void { |
|
52 | + if ($event instanceof AddressBookCreatedEvent) { |
|
53 | + try { |
|
54 | + $this->activityBackend->onAddressbookCreate( |
|
55 | + $event->getAddressBookData() |
|
56 | + ); |
|
57 | 57 | |
58 | - $this->logger->debug( |
|
59 | - sprintf('Activity generated for new addressbook %d', $event->getAddressBookId()) |
|
60 | - ); |
|
61 | - } catch (Throwable $e) { |
|
62 | - // Any error with activities shouldn't abort the addressbook creation, so we just log it |
|
63 | - $this->logger->error('Error generating activities for a new addressbook: ' . $e->getMessage(), [ |
|
64 | - 'exception' => $e, |
|
65 | - ]); |
|
66 | - } |
|
67 | - } elseif ($event instanceof AddressBookUpdatedEvent) { |
|
68 | - try { |
|
69 | - $this->activityBackend->onAddressbookUpdate( |
|
70 | - $event->getAddressBookData(), |
|
71 | - $event->getShares(), |
|
72 | - $event->getMutations() |
|
73 | - ); |
|
58 | + $this->logger->debug( |
|
59 | + sprintf('Activity generated for new addressbook %d', $event->getAddressBookId()) |
|
60 | + ); |
|
61 | + } catch (Throwable $e) { |
|
62 | + // Any error with activities shouldn't abort the addressbook creation, so we just log it |
|
63 | + $this->logger->error('Error generating activities for a new addressbook: ' . $e->getMessage(), [ |
|
64 | + 'exception' => $e, |
|
65 | + ]); |
|
66 | + } |
|
67 | + } elseif ($event instanceof AddressBookUpdatedEvent) { |
|
68 | + try { |
|
69 | + $this->activityBackend->onAddressbookUpdate( |
|
70 | + $event->getAddressBookData(), |
|
71 | + $event->getShares(), |
|
72 | + $event->getMutations() |
|
73 | + ); |
|
74 | 74 | |
75 | - $this->logger->debug( |
|
76 | - sprintf('Activity generated for changed addressbook %d', $event->getAddressBookId()) |
|
77 | - ); |
|
78 | - } catch (Throwable $e) { |
|
79 | - // Any error with activities shouldn't abort the addressbook update, so we just log it |
|
80 | - $this->logger->error('Error generating activities for a changed addressbook: ' . $e->getMessage(), [ |
|
81 | - 'exception' => $e, |
|
82 | - ]); |
|
83 | - } |
|
84 | - } elseif ($event instanceof AddressBookDeletedEvent) { |
|
85 | - try { |
|
86 | - $this->activityBackend->onAddressbookDelete( |
|
87 | - $event->getAddressBookData(), |
|
88 | - $event->getShares() |
|
89 | - ); |
|
75 | + $this->logger->debug( |
|
76 | + sprintf('Activity generated for changed addressbook %d', $event->getAddressBookId()) |
|
77 | + ); |
|
78 | + } catch (Throwable $e) { |
|
79 | + // Any error with activities shouldn't abort the addressbook update, so we just log it |
|
80 | + $this->logger->error('Error generating activities for a changed addressbook: ' . $e->getMessage(), [ |
|
81 | + 'exception' => $e, |
|
82 | + ]); |
|
83 | + } |
|
84 | + } elseif ($event instanceof AddressBookDeletedEvent) { |
|
85 | + try { |
|
86 | + $this->activityBackend->onAddressbookDelete( |
|
87 | + $event->getAddressBookData(), |
|
88 | + $event->getShares() |
|
89 | + ); |
|
90 | 90 | |
91 | - $this->logger->debug( |
|
92 | - sprintf('Activity generated for deleted addressbook %d', $event->getAddressBookId()) |
|
93 | - ); |
|
94 | - } catch (Throwable $e) { |
|
95 | - // Any error with activities shouldn't abort the addressbook deletion, so we just log it |
|
96 | - $this->logger->error('Error generating activities for a deleted addressbook: ' . $e->getMessage(), [ |
|
97 | - 'exception' => $e, |
|
98 | - ]); |
|
99 | - } |
|
100 | - } elseif ($event instanceof AddressBookShareUpdatedEvent) { |
|
101 | - try { |
|
102 | - $this->activityBackend->onAddressbookUpdateShares( |
|
103 | - $event->getAddressBookData(), |
|
104 | - $event->getOldShares(), |
|
105 | - $event->getAdded(), |
|
106 | - $event->getRemoved() |
|
107 | - ); |
|
91 | + $this->logger->debug( |
|
92 | + sprintf('Activity generated for deleted addressbook %d', $event->getAddressBookId()) |
|
93 | + ); |
|
94 | + } catch (Throwable $e) { |
|
95 | + // Any error with activities shouldn't abort the addressbook deletion, so we just log it |
|
96 | + $this->logger->error('Error generating activities for a deleted addressbook: ' . $e->getMessage(), [ |
|
97 | + 'exception' => $e, |
|
98 | + ]); |
|
99 | + } |
|
100 | + } elseif ($event instanceof AddressBookShareUpdatedEvent) { |
|
101 | + try { |
|
102 | + $this->activityBackend->onAddressbookUpdateShares( |
|
103 | + $event->getAddressBookData(), |
|
104 | + $event->getOldShares(), |
|
105 | + $event->getAdded(), |
|
106 | + $event->getRemoved() |
|
107 | + ); |
|
108 | 108 | |
109 | - $this->logger->debug( |
|
110 | - sprintf('Activity generated for (un)sharing addressbook %d', $event->getAddressBookId()) |
|
111 | - ); |
|
112 | - } catch (Throwable $e) { |
|
113 | - // Any error with activities shouldn't abort the addressbook creation, so we just log it |
|
114 | - $this->logger->error('Error generating activities for (un)sharing addressbook: ' . $e->getMessage(), [ |
|
115 | - 'exception' => $e, |
|
116 | - ]); |
|
117 | - } |
|
118 | - } |
|
119 | - } |
|
109 | + $this->logger->debug( |
|
110 | + sprintf('Activity generated for (un)sharing addressbook %d', $event->getAddressBookId()) |
|
111 | + ); |
|
112 | + } catch (Throwable $e) { |
|
113 | + // Any error with activities shouldn't abort the addressbook creation, so we just log it |
|
114 | + $this->logger->error('Error generating activities for (un)sharing addressbook: ' . $e->getMessage(), [ |
|
115 | + 'exception' => $e, |
|
116 | + ]); |
|
117 | + } |
|
118 | + } |
|
119 | + } |
|
120 | 120 | } |
@@ -60,7 +60,7 @@ discard block |
||
60 | 60 | ); |
61 | 61 | } catch (Throwable $e) { |
62 | 62 | // Any error with activities shouldn't abort the addressbook creation, so we just log it |
63 | - $this->logger->error('Error generating activities for a new addressbook: ' . $e->getMessage(), [ |
|
63 | + $this->logger->error('Error generating activities for a new addressbook: '.$e->getMessage(), [ |
|
64 | 64 | 'exception' => $e, |
65 | 65 | ]); |
66 | 66 | } |
@@ -77,7 +77,7 @@ discard block |
||
77 | 77 | ); |
78 | 78 | } catch (Throwable $e) { |
79 | 79 | // Any error with activities shouldn't abort the addressbook update, so we just log it |
80 | - $this->logger->error('Error generating activities for a changed addressbook: ' . $e->getMessage(), [ |
|
80 | + $this->logger->error('Error generating activities for a changed addressbook: '.$e->getMessage(), [ |
|
81 | 81 | 'exception' => $e, |
82 | 82 | ]); |
83 | 83 | } |
@@ -93,7 +93,7 @@ discard block |
||
93 | 93 | ); |
94 | 94 | } catch (Throwable $e) { |
95 | 95 | // Any error with activities shouldn't abort the addressbook deletion, so we just log it |
96 | - $this->logger->error('Error generating activities for a deleted addressbook: ' . $e->getMessage(), [ |
|
96 | + $this->logger->error('Error generating activities for a deleted addressbook: '.$e->getMessage(), [ |
|
97 | 97 | 'exception' => $e, |
98 | 98 | ]); |
99 | 99 | } |
@@ -111,7 +111,7 @@ discard block |
||
111 | 111 | ); |
112 | 112 | } catch (Throwable $e) { |
113 | 113 | // Any error with activities shouldn't abort the addressbook creation, so we just log it |
114 | - $this->logger->error('Error generating activities for (un)sharing addressbook: ' . $e->getMessage(), [ |
|
114 | + $this->logger->error('Error generating activities for (un)sharing addressbook: '.$e->getMessage(), [ |
|
115 | 115 | 'exception' => $e, |
116 | 116 | ]); |
117 | 117 | } |
@@ -92,276 +92,276 @@ |
||
92 | 92 | use function is_null; |
93 | 93 | |
94 | 94 | class Application extends App implements IBootstrap { |
95 | - public const APP_ID = 'dav'; |
|
95 | + public const APP_ID = 'dav'; |
|
96 | 96 | |
97 | - public function __construct() { |
|
98 | - parent::__construct(self::APP_ID); |
|
99 | - } |
|
97 | + public function __construct() { |
|
98 | + parent::__construct(self::APP_ID); |
|
99 | + } |
|
100 | 100 | |
101 | - public function register(IRegistrationContext $context): void { |
|
102 | - $context->registerServiceAlias('CardDAVSyncService', SyncService::class); |
|
103 | - $context->registerService(PhotoCache::class, function (ContainerInterface $c) { |
|
104 | - /** @var IServerContainer $server */ |
|
105 | - $server = $c->get(IServerContainer::class); |
|
101 | + public function register(IRegistrationContext $context): void { |
|
102 | + $context->registerServiceAlias('CardDAVSyncService', SyncService::class); |
|
103 | + $context->registerService(PhotoCache::class, function (ContainerInterface $c) { |
|
104 | + /** @var IServerContainer $server */ |
|
105 | + $server = $c->get(IServerContainer::class); |
|
106 | 106 | |
107 | - return new PhotoCache( |
|
108 | - $server->getAppDataDir('dav-photocache'), |
|
109 | - $c->get(ILogger::class) |
|
110 | - ); |
|
111 | - }); |
|
107 | + return new PhotoCache( |
|
108 | + $server->getAppDataDir('dav-photocache'), |
|
109 | + $c->get(ILogger::class) |
|
110 | + ); |
|
111 | + }); |
|
112 | 112 | |
113 | - /* |
|
113 | + /* |
|
114 | 114 | * Register capabilities |
115 | 115 | */ |
116 | - $context->registerCapability(Capabilities::class); |
|
116 | + $context->registerCapability(Capabilities::class); |
|
117 | 117 | |
118 | - /* |
|
118 | + /* |
|
119 | 119 | * Register Search Providers |
120 | 120 | */ |
121 | - $context->registerSearchProvider(ContactsSearchProvider::class); |
|
122 | - $context->registerSearchProvider(EventsSearchProvider::class); |
|
123 | - $context->registerSearchProvider(TasksSearchProvider::class); |
|
124 | - |
|
125 | - /** |
|
126 | - * Register event listeners |
|
127 | - */ |
|
128 | - $context->registerEventListener(CalendarCreatedEvent::class, ActivityUpdaterListener::class); |
|
129 | - $context->registerEventListener(CalendarDeletedEvent::class, ActivityUpdaterListener::class); |
|
130 | - $context->registerEventListener(CalendarDeletedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
131 | - $context->registerEventListener(CalendarDeletedEvent::class, CalendarDeletionDefaultUpdaterListener::class); |
|
132 | - $context->registerEventListener(CalendarUpdatedEvent::class, ActivityUpdaterListener::class); |
|
133 | - $context->registerEventListener(CalendarObjectCreatedEvent::class, ActivityUpdaterListener::class); |
|
134 | - $context->registerEventListener(CalendarObjectCreatedEvent::class, CalendarContactInteractionListener::class); |
|
135 | - $context->registerEventListener(CalendarObjectCreatedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
136 | - $context->registerEventListener(CalendarObjectUpdatedEvent::class, ActivityUpdaterListener::class); |
|
137 | - $context->registerEventListener(CalendarObjectUpdatedEvent::class, CalendarContactInteractionListener::class); |
|
138 | - $context->registerEventListener(CalendarObjectUpdatedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
139 | - $context->registerEventListener(CalendarObjectDeletedEvent::class, ActivityUpdaterListener::class); |
|
140 | - $context->registerEventListener(CalendarObjectDeletedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
141 | - $context->registerEventListener(CalendarShareUpdatedEvent::class, CalendarContactInteractionListener::class); |
|
142 | - |
|
143 | - |
|
144 | - $context->registerEventListener(AddressBookCreatedEvent::class, AddressbookListener::class); |
|
145 | - $context->registerEventListener(AddressBookDeletedEvent::class, AddressbookListener::class); |
|
146 | - $context->registerEventListener(AddressBookUpdatedEvent::class, AddressbookListener::class); |
|
147 | - $context->registerEventListener(AddressBookShareUpdatedEvent::class, AddressbookListener::class); |
|
148 | - $context->registerEventListener(CardCreatedEvent::class, CardListener::class); |
|
149 | - $context->registerEventListener(CardDeletedEvent::class, CardListener::class); |
|
150 | - $context->registerEventListener(CardUpdatedEvent::class, CardListener::class); |
|
151 | - |
|
152 | - $context->registerNotifierService(Notifier::class); |
|
153 | - } |
|
154 | - |
|
155 | - public function boot(IBootContext $context): void { |
|
156 | - // Load all dav apps |
|
157 | - \OC_App::loadApps(['dav']); |
|
158 | - |
|
159 | - $context->injectFn([$this, 'registerHooks']); |
|
160 | - $context->injectFn([$this, 'registerContactsManager']); |
|
161 | - $context->injectFn([$this, 'registerCalendarManager']); |
|
162 | - $context->injectFn([$this, 'registerCalendarReminders']); |
|
163 | - } |
|
164 | - |
|
165 | - public function registerHooks(HookManager $hm, |
|
166 | - EventDispatcherInterface $dispatcher, |
|
167 | - IAppContainer $container, |
|
168 | - IServerContainer $serverContainer) { |
|
169 | - $hm->setup(); |
|
170 | - |
|
171 | - // first time login event setup |
|
172 | - $dispatcher->addListener(IUser::class . '::firstLogin', function ($event) use ($hm) { |
|
173 | - if ($event instanceof GenericEvent) { |
|
174 | - $hm->firstLogin($event->getSubject()); |
|
175 | - } |
|
176 | - }); |
|
177 | - |
|
178 | - $birthdayListener = function ($event) use ($container): void { |
|
179 | - if ($event instanceof GenericEvent) { |
|
180 | - /** @var BirthdayService $b */ |
|
181 | - $b = $container->query(BirthdayService::class); |
|
182 | - $b->onCardChanged( |
|
183 | - (int) $event->getArgument('addressBookId'), |
|
184 | - (string) $event->getArgument('cardUri'), |
|
185 | - (string) $event->getArgument('cardData') |
|
186 | - ); |
|
187 | - } |
|
188 | - }; |
|
189 | - |
|
190 | - $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::createCard', $birthdayListener); |
|
191 | - $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::updateCard', $birthdayListener); |
|
192 | - $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::deleteCard', function ($event) use ($container) { |
|
193 | - if ($event instanceof GenericEvent) { |
|
194 | - /** @var BirthdayService $b */ |
|
195 | - $b = $container->query(BirthdayService::class); |
|
196 | - $b->onCardDeleted( |
|
197 | - (int) $event->getArgument('addressBookId'), |
|
198 | - (string) $event->getArgument('cardUri') |
|
199 | - ); |
|
200 | - } |
|
201 | - }); |
|
202 | - |
|
203 | - $clearPhotoCache = function ($event) use ($container): void { |
|
204 | - if ($event instanceof GenericEvent) { |
|
205 | - /** @var PhotoCache $p */ |
|
206 | - $p = $container->query(PhotoCache::class); |
|
207 | - $p->delete( |
|
208 | - $event->getArgument('addressBookId'), |
|
209 | - $event->getArgument('cardUri') |
|
210 | - ); |
|
211 | - } |
|
212 | - }; |
|
213 | - $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::updateCard', $clearPhotoCache); |
|
214 | - $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::deleteCard', $clearPhotoCache); |
|
215 | - |
|
216 | - $dispatcher->addListener('OC\AccountManager::userUpdated', function (GenericEvent $event) use ($container) { |
|
217 | - $user = $event->getSubject(); |
|
218 | - /** @var SyncService $syncService */ |
|
219 | - $syncService = $container->query(SyncService::class); |
|
220 | - $syncService->updateUser($user); |
|
221 | - }); |
|
222 | - |
|
223 | - $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::updateShares', function (GenericEvent $event) use ($container) { |
|
224 | - /** @var Backend $backend */ |
|
225 | - $backend = $container->query(Backend::class); |
|
226 | - $backend->onCalendarUpdateShares( |
|
227 | - $event->getArgument('calendarData'), |
|
228 | - $event->getArgument('shares'), |
|
229 | - $event->getArgument('add'), |
|
230 | - $event->getArgument('remove') |
|
231 | - ); |
|
232 | - |
|
233 | - // Here we should recalculate if reminders should be sent to new or old sharees |
|
234 | - }); |
|
235 | - |
|
236 | - $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::publishCalendar', function (GenericEvent $event) use ($container) { |
|
237 | - /** @var Backend $backend */ |
|
238 | - $backend = $container->query(Backend::class); |
|
239 | - $backend->onCalendarPublication( |
|
240 | - $event->getArgument('calendarData'), |
|
241 | - $event->getArgument('public') |
|
242 | - ); |
|
243 | - }); |
|
244 | - |
|
245 | - |
|
246 | - $dispatcher->addListener('OCP\Federation\TrustedServerEvent::remove', |
|
247 | - function (GenericEvent $event) { |
|
248 | - /** @var CardDavBackend $cardDavBackend */ |
|
249 | - $cardDavBackend = \OC::$server->query(CardDavBackend::class); |
|
250 | - $addressBookUri = $event->getSubject(); |
|
251 | - $addressBook = $cardDavBackend->getAddressBooksByUri('principals/system/system', $addressBookUri); |
|
252 | - if (!is_null($addressBook)) { |
|
253 | - $cardDavBackend->deleteAddressBook($addressBook['id']); |
|
254 | - } |
|
255 | - } |
|
256 | - ); |
|
257 | - |
|
258 | - $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::createSubscription', |
|
259 | - function (GenericEvent $event) use ($container, $serverContainer) { |
|
260 | - $jobList = $serverContainer->getJobList(); |
|
261 | - $subscriptionData = $event->getArgument('subscriptionData'); |
|
262 | - |
|
263 | - /** |
|
264 | - * Initial subscription refetch |
|
265 | - * |
|
266 | - * @var RefreshWebcalService $refreshWebcalService |
|
267 | - */ |
|
268 | - $refreshWebcalService = $container->query(RefreshWebcalService::class); |
|
269 | - $refreshWebcalService->refreshSubscription( |
|
270 | - (string) $subscriptionData['principaluri'], |
|
271 | - (string) $subscriptionData['uri'] |
|
272 | - ); |
|
273 | - |
|
274 | - $jobList->add(\OCA\DAV\BackgroundJob\RefreshWebcalJob::class, [ |
|
275 | - 'principaluri' => $subscriptionData['principaluri'], |
|
276 | - 'uri' => $subscriptionData['uri'] |
|
277 | - ]); |
|
278 | - } |
|
279 | - ); |
|
280 | - |
|
281 | - $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::deleteSubscription', |
|
282 | - function (GenericEvent $event) use ($container, $serverContainer) { |
|
283 | - $jobList = $serverContainer->getJobList(); |
|
284 | - $subscriptionData = $event->getArgument('subscriptionData'); |
|
285 | - |
|
286 | - $jobList->remove(\OCA\DAV\BackgroundJob\RefreshWebcalJob::class, [ |
|
287 | - 'principaluri' => $subscriptionData['principaluri'], |
|
288 | - 'uri' => $subscriptionData['uri'] |
|
289 | - ]); |
|
290 | - |
|
291 | - /** @var CalDavBackend $calDavBackend */ |
|
292 | - $calDavBackend = $container->query(CalDavBackend::class); |
|
293 | - $calDavBackend->purgeAllCachedEventsForSubscription($subscriptionData['id']); |
|
294 | - } |
|
295 | - ); |
|
296 | - |
|
297 | - $eventHandler = function () use ($container, $serverContainer): void { |
|
298 | - try { |
|
299 | - /** @var UpdateCalendarResourcesRoomsBackgroundJob $job */ |
|
300 | - $job = $container->query(UpdateCalendarResourcesRoomsBackgroundJob::class); |
|
301 | - $job->run([]); |
|
302 | - $serverContainer->getJobList()->setLastRun($job); |
|
303 | - } catch (Exception $ex) { |
|
304 | - $serverContainer->getLogger()->logException($ex); |
|
305 | - } |
|
306 | - }; |
|
307 | - |
|
308 | - $dispatcher->addListener('\OCP\Calendar\Resource\ForceRefreshEvent', $eventHandler); |
|
309 | - $dispatcher->addListener('\OCP\Calendar\Room\ForceRefreshEvent', $eventHandler); |
|
310 | - } |
|
311 | - |
|
312 | - public function registerContactsManager(IContactsManager $cm, IAppContainer $container): void { |
|
313 | - $cm->register(function () use ($container, $cm): void { |
|
314 | - $user = \OC::$server->getUserSession()->getUser(); |
|
315 | - if (!is_null($user)) { |
|
316 | - $this->setupContactsProvider($cm, $container, $user->getUID()); |
|
317 | - } else { |
|
318 | - $this->setupSystemContactsProvider($cm, $container); |
|
319 | - } |
|
320 | - }); |
|
321 | - } |
|
322 | - |
|
323 | - private function setupContactsProvider(IContactsManager $contactsManager, |
|
324 | - IAppContainer $container, |
|
325 | - string $userID): void { |
|
326 | - /** @var ContactsManager $cm */ |
|
327 | - $cm = $container->query(ContactsManager::class); |
|
328 | - $urlGenerator = $container->getServer()->getURLGenerator(); |
|
329 | - $cm->setupContactsProvider($contactsManager, $userID, $urlGenerator); |
|
330 | - } |
|
331 | - |
|
332 | - private function setupSystemContactsProvider(IContactsManager $contactsManager, |
|
333 | - IAppContainer $container): void { |
|
334 | - /** @var ContactsManager $cm */ |
|
335 | - $cm = $container->query(ContactsManager::class); |
|
336 | - $urlGenerator = $container->getServer()->getURLGenerator(); |
|
337 | - $cm->setupSystemContactsProvider($contactsManager, $urlGenerator); |
|
338 | - } |
|
339 | - |
|
340 | - public function registerCalendarManager(ICalendarManager $calendarManager, |
|
341 | - IAppContainer $container): void { |
|
342 | - $calendarManager->register(function () use ($container, $calendarManager) { |
|
343 | - $user = \OC::$server->getUserSession()->getUser(); |
|
344 | - if ($user !== null) { |
|
345 | - $this->setupCalendarProvider($calendarManager, $container, $user->getUID()); |
|
346 | - } |
|
347 | - }); |
|
348 | - } |
|
349 | - |
|
350 | - private function setupCalendarProvider(ICalendarManager $calendarManager, |
|
351 | - IAppContainer $container, |
|
352 | - $userId) { |
|
353 | - $cm = $container->query(CalendarManager::class); |
|
354 | - $cm->setupCalendarProvider($calendarManager, $userId); |
|
355 | - } |
|
356 | - |
|
357 | - public function registerCalendarReminders(NotificationProviderManager $manager, |
|
358 | - ILogger $logger): void { |
|
359 | - try { |
|
360 | - $manager->registerProvider(AudioProvider::class); |
|
361 | - $manager->registerProvider(EmailProvider::class); |
|
362 | - $manager->registerProvider(PushProvider::class); |
|
363 | - } catch (Throwable $ex) { |
|
364 | - $logger->logException($ex); |
|
365 | - } |
|
366 | - } |
|
121 | + $context->registerSearchProvider(ContactsSearchProvider::class); |
|
122 | + $context->registerSearchProvider(EventsSearchProvider::class); |
|
123 | + $context->registerSearchProvider(TasksSearchProvider::class); |
|
124 | + |
|
125 | + /** |
|
126 | + * Register event listeners |
|
127 | + */ |
|
128 | + $context->registerEventListener(CalendarCreatedEvent::class, ActivityUpdaterListener::class); |
|
129 | + $context->registerEventListener(CalendarDeletedEvent::class, ActivityUpdaterListener::class); |
|
130 | + $context->registerEventListener(CalendarDeletedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
131 | + $context->registerEventListener(CalendarDeletedEvent::class, CalendarDeletionDefaultUpdaterListener::class); |
|
132 | + $context->registerEventListener(CalendarUpdatedEvent::class, ActivityUpdaterListener::class); |
|
133 | + $context->registerEventListener(CalendarObjectCreatedEvent::class, ActivityUpdaterListener::class); |
|
134 | + $context->registerEventListener(CalendarObjectCreatedEvent::class, CalendarContactInteractionListener::class); |
|
135 | + $context->registerEventListener(CalendarObjectCreatedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
136 | + $context->registerEventListener(CalendarObjectUpdatedEvent::class, ActivityUpdaterListener::class); |
|
137 | + $context->registerEventListener(CalendarObjectUpdatedEvent::class, CalendarContactInteractionListener::class); |
|
138 | + $context->registerEventListener(CalendarObjectUpdatedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
139 | + $context->registerEventListener(CalendarObjectDeletedEvent::class, ActivityUpdaterListener::class); |
|
140 | + $context->registerEventListener(CalendarObjectDeletedEvent::class, CalendarObjectReminderUpdaterListener::class); |
|
141 | + $context->registerEventListener(CalendarShareUpdatedEvent::class, CalendarContactInteractionListener::class); |
|
142 | + |
|
143 | + |
|
144 | + $context->registerEventListener(AddressBookCreatedEvent::class, AddressbookListener::class); |
|
145 | + $context->registerEventListener(AddressBookDeletedEvent::class, AddressbookListener::class); |
|
146 | + $context->registerEventListener(AddressBookUpdatedEvent::class, AddressbookListener::class); |
|
147 | + $context->registerEventListener(AddressBookShareUpdatedEvent::class, AddressbookListener::class); |
|
148 | + $context->registerEventListener(CardCreatedEvent::class, CardListener::class); |
|
149 | + $context->registerEventListener(CardDeletedEvent::class, CardListener::class); |
|
150 | + $context->registerEventListener(CardUpdatedEvent::class, CardListener::class); |
|
151 | + |
|
152 | + $context->registerNotifierService(Notifier::class); |
|
153 | + } |
|
154 | + |
|
155 | + public function boot(IBootContext $context): void { |
|
156 | + // Load all dav apps |
|
157 | + \OC_App::loadApps(['dav']); |
|
158 | + |
|
159 | + $context->injectFn([$this, 'registerHooks']); |
|
160 | + $context->injectFn([$this, 'registerContactsManager']); |
|
161 | + $context->injectFn([$this, 'registerCalendarManager']); |
|
162 | + $context->injectFn([$this, 'registerCalendarReminders']); |
|
163 | + } |
|
164 | + |
|
165 | + public function registerHooks(HookManager $hm, |
|
166 | + EventDispatcherInterface $dispatcher, |
|
167 | + IAppContainer $container, |
|
168 | + IServerContainer $serverContainer) { |
|
169 | + $hm->setup(); |
|
170 | + |
|
171 | + // first time login event setup |
|
172 | + $dispatcher->addListener(IUser::class . '::firstLogin', function ($event) use ($hm) { |
|
173 | + if ($event instanceof GenericEvent) { |
|
174 | + $hm->firstLogin($event->getSubject()); |
|
175 | + } |
|
176 | + }); |
|
177 | + |
|
178 | + $birthdayListener = function ($event) use ($container): void { |
|
179 | + if ($event instanceof GenericEvent) { |
|
180 | + /** @var BirthdayService $b */ |
|
181 | + $b = $container->query(BirthdayService::class); |
|
182 | + $b->onCardChanged( |
|
183 | + (int) $event->getArgument('addressBookId'), |
|
184 | + (string) $event->getArgument('cardUri'), |
|
185 | + (string) $event->getArgument('cardData') |
|
186 | + ); |
|
187 | + } |
|
188 | + }; |
|
189 | + |
|
190 | + $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::createCard', $birthdayListener); |
|
191 | + $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::updateCard', $birthdayListener); |
|
192 | + $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::deleteCard', function ($event) use ($container) { |
|
193 | + if ($event instanceof GenericEvent) { |
|
194 | + /** @var BirthdayService $b */ |
|
195 | + $b = $container->query(BirthdayService::class); |
|
196 | + $b->onCardDeleted( |
|
197 | + (int) $event->getArgument('addressBookId'), |
|
198 | + (string) $event->getArgument('cardUri') |
|
199 | + ); |
|
200 | + } |
|
201 | + }); |
|
202 | + |
|
203 | + $clearPhotoCache = function ($event) use ($container): void { |
|
204 | + if ($event instanceof GenericEvent) { |
|
205 | + /** @var PhotoCache $p */ |
|
206 | + $p = $container->query(PhotoCache::class); |
|
207 | + $p->delete( |
|
208 | + $event->getArgument('addressBookId'), |
|
209 | + $event->getArgument('cardUri') |
|
210 | + ); |
|
211 | + } |
|
212 | + }; |
|
213 | + $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::updateCard', $clearPhotoCache); |
|
214 | + $dispatcher->addListener('\OCA\DAV\CardDAV\CardDavBackend::deleteCard', $clearPhotoCache); |
|
215 | + |
|
216 | + $dispatcher->addListener('OC\AccountManager::userUpdated', function (GenericEvent $event) use ($container) { |
|
217 | + $user = $event->getSubject(); |
|
218 | + /** @var SyncService $syncService */ |
|
219 | + $syncService = $container->query(SyncService::class); |
|
220 | + $syncService->updateUser($user); |
|
221 | + }); |
|
222 | + |
|
223 | + $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::updateShares', function (GenericEvent $event) use ($container) { |
|
224 | + /** @var Backend $backend */ |
|
225 | + $backend = $container->query(Backend::class); |
|
226 | + $backend->onCalendarUpdateShares( |
|
227 | + $event->getArgument('calendarData'), |
|
228 | + $event->getArgument('shares'), |
|
229 | + $event->getArgument('add'), |
|
230 | + $event->getArgument('remove') |
|
231 | + ); |
|
232 | + |
|
233 | + // Here we should recalculate if reminders should be sent to new or old sharees |
|
234 | + }); |
|
235 | + |
|
236 | + $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::publishCalendar', function (GenericEvent $event) use ($container) { |
|
237 | + /** @var Backend $backend */ |
|
238 | + $backend = $container->query(Backend::class); |
|
239 | + $backend->onCalendarPublication( |
|
240 | + $event->getArgument('calendarData'), |
|
241 | + $event->getArgument('public') |
|
242 | + ); |
|
243 | + }); |
|
244 | + |
|
245 | + |
|
246 | + $dispatcher->addListener('OCP\Federation\TrustedServerEvent::remove', |
|
247 | + function (GenericEvent $event) { |
|
248 | + /** @var CardDavBackend $cardDavBackend */ |
|
249 | + $cardDavBackend = \OC::$server->query(CardDavBackend::class); |
|
250 | + $addressBookUri = $event->getSubject(); |
|
251 | + $addressBook = $cardDavBackend->getAddressBooksByUri('principals/system/system', $addressBookUri); |
|
252 | + if (!is_null($addressBook)) { |
|
253 | + $cardDavBackend->deleteAddressBook($addressBook['id']); |
|
254 | + } |
|
255 | + } |
|
256 | + ); |
|
257 | + |
|
258 | + $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::createSubscription', |
|
259 | + function (GenericEvent $event) use ($container, $serverContainer) { |
|
260 | + $jobList = $serverContainer->getJobList(); |
|
261 | + $subscriptionData = $event->getArgument('subscriptionData'); |
|
262 | + |
|
263 | + /** |
|
264 | + * Initial subscription refetch |
|
265 | + * |
|
266 | + * @var RefreshWebcalService $refreshWebcalService |
|
267 | + */ |
|
268 | + $refreshWebcalService = $container->query(RefreshWebcalService::class); |
|
269 | + $refreshWebcalService->refreshSubscription( |
|
270 | + (string) $subscriptionData['principaluri'], |
|
271 | + (string) $subscriptionData['uri'] |
|
272 | + ); |
|
273 | + |
|
274 | + $jobList->add(\OCA\DAV\BackgroundJob\RefreshWebcalJob::class, [ |
|
275 | + 'principaluri' => $subscriptionData['principaluri'], |
|
276 | + 'uri' => $subscriptionData['uri'] |
|
277 | + ]); |
|
278 | + } |
|
279 | + ); |
|
280 | + |
|
281 | + $dispatcher->addListener('\OCA\DAV\CalDAV\CalDavBackend::deleteSubscription', |
|
282 | + function (GenericEvent $event) use ($container, $serverContainer) { |
|
283 | + $jobList = $serverContainer->getJobList(); |
|
284 | + $subscriptionData = $event->getArgument('subscriptionData'); |
|
285 | + |
|
286 | + $jobList->remove(\OCA\DAV\BackgroundJob\RefreshWebcalJob::class, [ |
|
287 | + 'principaluri' => $subscriptionData['principaluri'], |
|
288 | + 'uri' => $subscriptionData['uri'] |
|
289 | + ]); |
|
290 | + |
|
291 | + /** @var CalDavBackend $calDavBackend */ |
|
292 | + $calDavBackend = $container->query(CalDavBackend::class); |
|
293 | + $calDavBackend->purgeAllCachedEventsForSubscription($subscriptionData['id']); |
|
294 | + } |
|
295 | + ); |
|
296 | + |
|
297 | + $eventHandler = function () use ($container, $serverContainer): void { |
|
298 | + try { |
|
299 | + /** @var UpdateCalendarResourcesRoomsBackgroundJob $job */ |
|
300 | + $job = $container->query(UpdateCalendarResourcesRoomsBackgroundJob::class); |
|
301 | + $job->run([]); |
|
302 | + $serverContainer->getJobList()->setLastRun($job); |
|
303 | + } catch (Exception $ex) { |
|
304 | + $serverContainer->getLogger()->logException($ex); |
|
305 | + } |
|
306 | + }; |
|
307 | + |
|
308 | + $dispatcher->addListener('\OCP\Calendar\Resource\ForceRefreshEvent', $eventHandler); |
|
309 | + $dispatcher->addListener('\OCP\Calendar\Room\ForceRefreshEvent', $eventHandler); |
|
310 | + } |
|
311 | + |
|
312 | + public function registerContactsManager(IContactsManager $cm, IAppContainer $container): void { |
|
313 | + $cm->register(function () use ($container, $cm): void { |
|
314 | + $user = \OC::$server->getUserSession()->getUser(); |
|
315 | + if (!is_null($user)) { |
|
316 | + $this->setupContactsProvider($cm, $container, $user->getUID()); |
|
317 | + } else { |
|
318 | + $this->setupSystemContactsProvider($cm, $container); |
|
319 | + } |
|
320 | + }); |
|
321 | + } |
|
322 | + |
|
323 | + private function setupContactsProvider(IContactsManager $contactsManager, |
|
324 | + IAppContainer $container, |
|
325 | + string $userID): void { |
|
326 | + /** @var ContactsManager $cm */ |
|
327 | + $cm = $container->query(ContactsManager::class); |
|
328 | + $urlGenerator = $container->getServer()->getURLGenerator(); |
|
329 | + $cm->setupContactsProvider($contactsManager, $userID, $urlGenerator); |
|
330 | + } |
|
331 | + |
|
332 | + private function setupSystemContactsProvider(IContactsManager $contactsManager, |
|
333 | + IAppContainer $container): void { |
|
334 | + /** @var ContactsManager $cm */ |
|
335 | + $cm = $container->query(ContactsManager::class); |
|
336 | + $urlGenerator = $container->getServer()->getURLGenerator(); |
|
337 | + $cm->setupSystemContactsProvider($contactsManager, $urlGenerator); |
|
338 | + } |
|
339 | + |
|
340 | + public function registerCalendarManager(ICalendarManager $calendarManager, |
|
341 | + IAppContainer $container): void { |
|
342 | + $calendarManager->register(function () use ($container, $calendarManager) { |
|
343 | + $user = \OC::$server->getUserSession()->getUser(); |
|
344 | + if ($user !== null) { |
|
345 | + $this->setupCalendarProvider($calendarManager, $container, $user->getUID()); |
|
346 | + } |
|
347 | + }); |
|
348 | + } |
|
349 | + |
|
350 | + private function setupCalendarProvider(ICalendarManager $calendarManager, |
|
351 | + IAppContainer $container, |
|
352 | + $userId) { |
|
353 | + $cm = $container->query(CalendarManager::class); |
|
354 | + $cm->setupCalendarProvider($calendarManager, $userId); |
|
355 | + } |
|
356 | + |
|
357 | + public function registerCalendarReminders(NotificationProviderManager $manager, |
|
358 | + ILogger $logger): void { |
|
359 | + try { |
|
360 | + $manager->registerProvider(AudioProvider::class); |
|
361 | + $manager->registerProvider(EmailProvider::class); |
|
362 | + $manager->registerProvider(PushProvider::class); |
|
363 | + } catch (Throwable $ex) { |
|
364 | + $logger->logException($ex); |
|
365 | + } |
|
366 | + } |
|
367 | 367 | } |