@@ -25,192 +25,192 @@ |
||
| 25 | 25 | */ |
| 26 | 26 | |
| 27 | 27 | interface ITags { |
| 28 | - /** |
|
| 29 | - * @since 19.0.0 |
|
| 30 | - */ |
|
| 31 | - public const TAG_FAVORITE = '_$!<Favorite>!$_'; |
|
| 32 | - |
|
| 33 | - /** |
|
| 34 | - * Check if any tags are saved for this type and user. |
|
| 35 | - * @since 6.0.0 |
|
| 36 | - */ |
|
| 37 | - public function isEmpty(): bool; |
|
| 38 | - |
|
| 39 | - /** |
|
| 40 | - * Returns an array mapping a given tag's properties to its values: |
|
| 41 | - * ['id' => 0, 'name' = 'Tag', 'owner' = 'User', 'type' => 'tagtype'] |
|
| 42 | - * |
|
| 43 | - * @param string $id The ID of the tag that is going to be mapped |
|
| 44 | - * @return array|false |
|
| 45 | - * @since 8.0.0 |
|
| 46 | - */ |
|
| 47 | - public function getTag(string $id); |
|
| 48 | - |
|
| 49 | - /** |
|
| 50 | - * Get the tags for a specific user. |
|
| 51 | - * |
|
| 52 | - * This returns an array with id/name maps: |
|
| 53 | - * |
|
| 54 | - * ```php |
|
| 55 | - * [ |
|
| 56 | - * ['id' => 0, 'name' = 'First tag'], |
|
| 57 | - * ['id' => 1, 'name' = 'Second tag'], |
|
| 58 | - * ] |
|
| 59 | - * ``` |
|
| 60 | - * |
|
| 61 | - * @return array<array-key, array{id: int, name: string}> |
|
| 62 | - * @since 6.0.0 |
|
| 63 | - */ |
|
| 64 | - public function getTags(): array; |
|
| 65 | - |
|
| 66 | - /** |
|
| 67 | - * Get a list of tags for the given item ids. |
|
| 68 | - * |
|
| 69 | - * This returns an array with object id / tag names: |
|
| 70 | - * |
|
| 71 | - * ```php |
|
| 72 | - * [ |
|
| 73 | - * 1 => array('First tag', 'Second tag'), |
|
| 74 | - * 2 => array('Second tag'), |
|
| 75 | - * 3 => array('Second tag', 'Third tag'), |
|
| 76 | - * ] |
|
| 77 | - * ``` |
|
| 78 | - * |
|
| 79 | - * @param list<int> $objIds item ids |
|
| 80 | - * @return array<int, list<string>>|false with object id as key and an array |
|
| 81 | - * of tag names as value or false if an error occurred |
|
| 82 | - * @since 8.0.0 |
|
| 83 | - */ |
|
| 84 | - public function getTagsForObjects(array $objIds); |
|
| 85 | - |
|
| 86 | - /** |
|
| 87 | - * Get a list of items tagged with $tag. |
|
| 88 | - * |
|
| 89 | - * Throws an exception if the tag could not be found. |
|
| 90 | - * |
|
| 91 | - * @param string|integer $tag Tag id or name. |
|
| 92 | - * @return array|false An array of object ids or false on error. |
|
| 93 | - * @since 6.0.0 |
|
| 94 | - */ |
|
| 95 | - public function getIdsForTag($tag); |
|
| 96 | - |
|
| 97 | - /** |
|
| 98 | - * Checks whether a tag is already saved. |
|
| 99 | - * |
|
| 100 | - * @param string $name The name to check for. |
|
| 101 | - * @since 6.0.0 |
|
| 102 | - */ |
|
| 103 | - public function hasTag(string $name): bool; |
|
| 104 | - |
|
| 105 | - /** |
|
| 106 | - * Checks whether a tag is saved for the given user, |
|
| 107 | - * disregarding the ones shared with them. |
|
| 108 | - * |
|
| 109 | - * @param string $name The tag name to check for. |
|
| 110 | - * @param string $user The user whose tags are to be checked. |
|
| 111 | - * @return bool |
|
| 112 | - * @since 8.0.0 |
|
| 113 | - */ |
|
| 114 | - public function userHasTag(string $name, string $user): bool; |
|
| 115 | - |
|
| 116 | - /** |
|
| 117 | - * Add a new tag. |
|
| 118 | - * |
|
| 119 | - * @param string $name A string with a name of the tag |
|
| 120 | - * @return int|false the id of the added tag or false if it already exists. |
|
| 121 | - * @since 6.0.0 |
|
| 122 | - */ |
|
| 123 | - public function add(string $name); |
|
| 124 | - |
|
| 125 | - /** |
|
| 126 | - * Rename tag. |
|
| 127 | - * |
|
| 128 | - * @param string|integer $from The name or ID of the existing tag |
|
| 129 | - * @param string $to The new name of the tag. |
|
| 130 | - * @return bool |
|
| 131 | - * @since 6.0.0 |
|
| 132 | - */ |
|
| 133 | - public function rename($from, string $to): bool; |
|
| 134 | - |
|
| 135 | - /** |
|
| 136 | - * Add a list of new tags. |
|
| 137 | - * |
|
| 138 | - * @param string|string[] $names A string with a name or an array of strings containing |
|
| 139 | - * the name(s) of the to add. |
|
| 140 | - * @param bool $sync When true, save the tags |
|
| 141 | - * @param int|null $id int Optional object id to add to this|these tag(s) |
|
| 142 | - * @return bool Returns false on error. |
|
| 143 | - * @since 6.0.0 |
|
| 144 | - */ |
|
| 145 | - public function addMultiple($names, bool $sync = false, ?int $id = null): bool; |
|
| 146 | - |
|
| 147 | - /** |
|
| 148 | - * Delete tag/object relations from the db |
|
| 149 | - * |
|
| 150 | - * @param array $ids The ids of the objects |
|
| 151 | - * @return boolean Returns false on error. |
|
| 152 | - * @since 6.0.0 |
|
| 153 | - */ |
|
| 154 | - public function purgeObjects(array $ids); |
|
| 155 | - |
|
| 156 | - /** |
|
| 157 | - * Get favorites for an object type |
|
| 158 | - * |
|
| 159 | - * @return array|false An array of object ids. |
|
| 160 | - * @since 6.0.0 |
|
| 161 | - */ |
|
| 162 | - public function getFavorites(); |
|
| 163 | - |
|
| 164 | - /** |
|
| 165 | - * Add an object to favorites |
|
| 166 | - * |
|
| 167 | - * @param int $objid The id of the object |
|
| 168 | - * @return boolean |
|
| 169 | - * @since 6.0.0 |
|
| 170 | - */ |
|
| 171 | - public function addToFavorites($objid); |
|
| 172 | - |
|
| 173 | - /** |
|
| 174 | - * Remove an object from favorites |
|
| 175 | - * |
|
| 176 | - * @param int $objid The id of the object |
|
| 177 | - * @return boolean |
|
| 178 | - * @since 6.0.0 |
|
| 179 | - */ |
|
| 180 | - public function removeFromFavorites($objid); |
|
| 181 | - |
|
| 182 | - /** |
|
| 183 | - * Creates a tag/object relation. |
|
| 184 | - * |
|
| 185 | - * @param int $objid The id of the object |
|
| 186 | - * @param string $tag The id or name of the tag |
|
| 187 | - * @param string $path The optional path of the node. Used when dispatching the favorite change event. |
|
| 188 | - * @return boolean Returns false on database error. |
|
| 189 | - * @since 6.0.0 |
|
| 190 | - * @since 31.0.0 Added the $path argument. |
|
| 191 | - * @since 33.0.0 Change $path default value from '' to null. |
|
| 192 | - */ |
|
| 193 | - public function tagAs($objid, $tag, ?string $path = null); |
|
| 194 | - |
|
| 195 | - /** |
|
| 196 | - * Delete single tag/object relation from the db |
|
| 197 | - * |
|
| 198 | - * @param int $objid The id of the object |
|
| 199 | - * @param string $tag The id or name of the tag |
|
| 200 | - * @param string $path The optional path of the node. Used when dispatching the favorite change event. |
|
| 201 | - * @return boolean |
|
| 202 | - * @since 6.0.0 |
|
| 203 | - * @since 31.0.0 Added the $path argument. |
|
| 204 | - * @since 33.0.0 Change $path default value from '' to null. |
|
| 205 | - */ |
|
| 206 | - public function unTag($objid, $tag, ?string $path = null); |
|
| 207 | - |
|
| 208 | - /** |
|
| 209 | - * Delete tags from the database |
|
| 210 | - * |
|
| 211 | - * @param string[]|integer[] $names An array of tags (names or IDs) to delete |
|
| 212 | - * @return bool Returns false on error |
|
| 213 | - * @since 6.0.0 |
|
| 214 | - */ |
|
| 215 | - public function delete($names); |
|
| 28 | + /** |
|
| 29 | + * @since 19.0.0 |
|
| 30 | + */ |
|
| 31 | + public const TAG_FAVORITE = '_$!<Favorite>!$_'; |
|
| 32 | + |
|
| 33 | + /** |
|
| 34 | + * Check if any tags are saved for this type and user. |
|
| 35 | + * @since 6.0.0 |
|
| 36 | + */ |
|
| 37 | + public function isEmpty(): bool; |
|
| 38 | + |
|
| 39 | + /** |
|
| 40 | + * Returns an array mapping a given tag's properties to its values: |
|
| 41 | + * ['id' => 0, 'name' = 'Tag', 'owner' = 'User', 'type' => 'tagtype'] |
|
| 42 | + * |
|
| 43 | + * @param string $id The ID of the tag that is going to be mapped |
|
| 44 | + * @return array|false |
|
| 45 | + * @since 8.0.0 |
|
| 46 | + */ |
|
| 47 | + public function getTag(string $id); |
|
| 48 | + |
|
| 49 | + /** |
|
| 50 | + * Get the tags for a specific user. |
|
| 51 | + * |
|
| 52 | + * This returns an array with id/name maps: |
|
| 53 | + * |
|
| 54 | + * ```php |
|
| 55 | + * [ |
|
| 56 | + * ['id' => 0, 'name' = 'First tag'], |
|
| 57 | + * ['id' => 1, 'name' = 'Second tag'], |
|
| 58 | + * ] |
|
| 59 | + * ``` |
|
| 60 | + * |
|
| 61 | + * @return array<array-key, array{id: int, name: string}> |
|
| 62 | + * @since 6.0.0 |
|
| 63 | + */ |
|
| 64 | + public function getTags(): array; |
|
| 65 | + |
|
| 66 | + /** |
|
| 67 | + * Get a list of tags for the given item ids. |
|
| 68 | + * |
|
| 69 | + * This returns an array with object id / tag names: |
|
| 70 | + * |
|
| 71 | + * ```php |
|
| 72 | + * [ |
|
| 73 | + * 1 => array('First tag', 'Second tag'), |
|
| 74 | + * 2 => array('Second tag'), |
|
| 75 | + * 3 => array('Second tag', 'Third tag'), |
|
| 76 | + * ] |
|
| 77 | + * ``` |
|
| 78 | + * |
|
| 79 | + * @param list<int> $objIds item ids |
|
| 80 | + * @return array<int, list<string>>|false with object id as key and an array |
|
| 81 | + * of tag names as value or false if an error occurred |
|
| 82 | + * @since 8.0.0 |
|
| 83 | + */ |
|
| 84 | + public function getTagsForObjects(array $objIds); |
|
| 85 | + |
|
| 86 | + /** |
|
| 87 | + * Get a list of items tagged with $tag. |
|
| 88 | + * |
|
| 89 | + * Throws an exception if the tag could not be found. |
|
| 90 | + * |
|
| 91 | + * @param string|integer $tag Tag id or name. |
|
| 92 | + * @return array|false An array of object ids or false on error. |
|
| 93 | + * @since 6.0.0 |
|
| 94 | + */ |
|
| 95 | + public function getIdsForTag($tag); |
|
| 96 | + |
|
| 97 | + /** |
|
| 98 | + * Checks whether a tag is already saved. |
|
| 99 | + * |
|
| 100 | + * @param string $name The name to check for. |
|
| 101 | + * @since 6.0.0 |
|
| 102 | + */ |
|
| 103 | + public function hasTag(string $name): bool; |
|
| 104 | + |
|
| 105 | + /** |
|
| 106 | + * Checks whether a tag is saved for the given user, |
|
| 107 | + * disregarding the ones shared with them. |
|
| 108 | + * |
|
| 109 | + * @param string $name The tag name to check for. |
|
| 110 | + * @param string $user The user whose tags are to be checked. |
|
| 111 | + * @return bool |
|
| 112 | + * @since 8.0.0 |
|
| 113 | + */ |
|
| 114 | + public function userHasTag(string $name, string $user): bool; |
|
| 115 | + |
|
| 116 | + /** |
|
| 117 | + * Add a new tag. |
|
| 118 | + * |
|
| 119 | + * @param string $name A string with a name of the tag |
|
| 120 | + * @return int|false the id of the added tag or false if it already exists. |
|
| 121 | + * @since 6.0.0 |
|
| 122 | + */ |
|
| 123 | + public function add(string $name); |
|
| 124 | + |
|
| 125 | + /** |
|
| 126 | + * Rename tag. |
|
| 127 | + * |
|
| 128 | + * @param string|integer $from The name or ID of the existing tag |
|
| 129 | + * @param string $to The new name of the tag. |
|
| 130 | + * @return bool |
|
| 131 | + * @since 6.0.0 |
|
| 132 | + */ |
|
| 133 | + public function rename($from, string $to): bool; |
|
| 134 | + |
|
| 135 | + /** |
|
| 136 | + * Add a list of new tags. |
|
| 137 | + * |
|
| 138 | + * @param string|string[] $names A string with a name or an array of strings containing |
|
| 139 | + * the name(s) of the to add. |
|
| 140 | + * @param bool $sync When true, save the tags |
|
| 141 | + * @param int|null $id int Optional object id to add to this|these tag(s) |
|
| 142 | + * @return bool Returns false on error. |
|
| 143 | + * @since 6.0.0 |
|
| 144 | + */ |
|
| 145 | + public function addMultiple($names, bool $sync = false, ?int $id = null): bool; |
|
| 146 | + |
|
| 147 | + /** |
|
| 148 | + * Delete tag/object relations from the db |
|
| 149 | + * |
|
| 150 | + * @param array $ids The ids of the objects |
|
| 151 | + * @return boolean Returns false on error. |
|
| 152 | + * @since 6.0.0 |
|
| 153 | + */ |
|
| 154 | + public function purgeObjects(array $ids); |
|
| 155 | + |
|
| 156 | + /** |
|
| 157 | + * Get favorites for an object type |
|
| 158 | + * |
|
| 159 | + * @return array|false An array of object ids. |
|
| 160 | + * @since 6.0.0 |
|
| 161 | + */ |
|
| 162 | + public function getFavorites(); |
|
| 163 | + |
|
| 164 | + /** |
|
| 165 | + * Add an object to favorites |
|
| 166 | + * |
|
| 167 | + * @param int $objid The id of the object |
|
| 168 | + * @return boolean |
|
| 169 | + * @since 6.0.0 |
|
| 170 | + */ |
|
| 171 | + public function addToFavorites($objid); |
|
| 172 | + |
|
| 173 | + /** |
|
| 174 | + * Remove an object from favorites |
|
| 175 | + * |
|
| 176 | + * @param int $objid The id of the object |
|
| 177 | + * @return boolean |
|
| 178 | + * @since 6.0.0 |
|
| 179 | + */ |
|
| 180 | + public function removeFromFavorites($objid); |
|
| 181 | + |
|
| 182 | + /** |
|
| 183 | + * Creates a tag/object relation. |
|
| 184 | + * |
|
| 185 | + * @param int $objid The id of the object |
|
| 186 | + * @param string $tag The id or name of the tag |
|
| 187 | + * @param string $path The optional path of the node. Used when dispatching the favorite change event. |
|
| 188 | + * @return boolean Returns false on database error. |
|
| 189 | + * @since 6.0.0 |
|
| 190 | + * @since 31.0.0 Added the $path argument. |
|
| 191 | + * @since 33.0.0 Change $path default value from '' to null. |
|
| 192 | + */ |
|
| 193 | + public function tagAs($objid, $tag, ?string $path = null); |
|
| 194 | + |
|
| 195 | + /** |
|
| 196 | + * Delete single tag/object relation from the db |
|
| 197 | + * |
|
| 198 | + * @param int $objid The id of the object |
|
| 199 | + * @param string $tag The id or name of the tag |
|
| 200 | + * @param string $path The optional path of the node. Used when dispatching the favorite change event. |
|
| 201 | + * @return boolean |
|
| 202 | + * @since 6.0.0 |
|
| 203 | + * @since 31.0.0 Added the $path argument. |
|
| 204 | + * @since 33.0.0 Change $path default value from '' to null. |
|
| 205 | + */ |
|
| 206 | + public function unTag($objid, $tag, ?string $path = null); |
|
| 207 | + |
|
| 208 | + /** |
|
| 209 | + * Delete tags from the database |
|
| 210 | + * |
|
| 211 | + * @param string[]|integer[] $names An array of tags (names or IDs) to delete |
|
| 212 | + * @return bool Returns false on error |
|
| 213 | + * @since 6.0.0 |
|
| 214 | + */ |
|
| 215 | + public function delete($names); |
|
| 216 | 216 | } |
@@ -26,115 +26,115 @@ |
||
| 26 | 26 | */ |
| 27 | 27 | class TagManager implements ITagManager, IEventListener { |
| 28 | 28 | |
| 29 | - public function __construct( |
|
| 30 | - private TagMapper $mapper, |
|
| 31 | - private IUserSession $userSession, |
|
| 32 | - private IDBConnection $connection, |
|
| 33 | - private LoggerInterface $logger, |
|
| 34 | - private IEventDispatcher $dispatcher, |
|
| 35 | - private IRootFolder $rootFolder, |
|
| 36 | - ) { |
|
| 37 | - } |
|
| 29 | + public function __construct( |
|
| 30 | + private TagMapper $mapper, |
|
| 31 | + private IUserSession $userSession, |
|
| 32 | + private IDBConnection $connection, |
|
| 33 | + private LoggerInterface $logger, |
|
| 34 | + private IEventDispatcher $dispatcher, |
|
| 35 | + private IRootFolder $rootFolder, |
|
| 36 | + ) { |
|
| 37 | + } |
|
| 38 | 38 | |
| 39 | - /** |
|
| 40 | - * Create a new \OCP\ITags instance and load tags from db. |
|
| 41 | - * |
|
| 42 | - * @see \OCP\ITags |
|
| 43 | - * @param string $type The type identifier e.g. 'contact' or 'event'. |
|
| 44 | - * @param array $defaultTags An array of default tags to be used if none are stored. |
|
| 45 | - * @param boolean $includeShared Whether to include tags for items shared with this user by others. |
|
| 46 | - * @param string $userId user for which to retrieve the tags, defaults to the currently |
|
| 47 | - * logged in user |
|
| 48 | - * @return \OCP\ITags |
|
| 49 | - * |
|
| 50 | - * since 20.0.0 $includeShared isn't used anymore |
|
| 51 | - */ |
|
| 52 | - public function load($type, $defaultTags = [], $includeShared = false, $userId = null) { |
|
| 53 | - if (is_null($userId)) { |
|
| 54 | - $user = $this->userSession->getUser(); |
|
| 55 | - if ($user === null) { |
|
| 56 | - // nothing we can do without a user |
|
| 57 | - return null; |
|
| 58 | - } |
|
| 59 | - $userId = $this->userSession->getUser()->getUId(); |
|
| 60 | - } |
|
| 61 | - $userFolder = $this->rootFolder->getUserFolder($userId); |
|
| 62 | - return new Tags($this->mapper, $userId, $type, $this->logger, $this->connection, $this->dispatcher, $this->userSession, $userFolder, $defaultTags); |
|
| 63 | - } |
|
| 39 | + /** |
|
| 40 | + * Create a new \OCP\ITags instance and load tags from db. |
|
| 41 | + * |
|
| 42 | + * @see \OCP\ITags |
|
| 43 | + * @param string $type The type identifier e.g. 'contact' or 'event'. |
|
| 44 | + * @param array $defaultTags An array of default tags to be used if none are stored. |
|
| 45 | + * @param boolean $includeShared Whether to include tags for items shared with this user by others. |
|
| 46 | + * @param string $userId user for which to retrieve the tags, defaults to the currently |
|
| 47 | + * logged in user |
|
| 48 | + * @return \OCP\ITags |
|
| 49 | + * |
|
| 50 | + * since 20.0.0 $includeShared isn't used anymore |
|
| 51 | + */ |
|
| 52 | + public function load($type, $defaultTags = [], $includeShared = false, $userId = null) { |
|
| 53 | + if (is_null($userId)) { |
|
| 54 | + $user = $this->userSession->getUser(); |
|
| 55 | + if ($user === null) { |
|
| 56 | + // nothing we can do without a user |
|
| 57 | + return null; |
|
| 58 | + } |
|
| 59 | + $userId = $this->userSession->getUser()->getUId(); |
|
| 60 | + } |
|
| 61 | + $userFolder = $this->rootFolder->getUserFolder($userId); |
|
| 62 | + return new Tags($this->mapper, $userId, $type, $this->logger, $this->connection, $this->dispatcher, $this->userSession, $userFolder, $defaultTags); |
|
| 63 | + } |
|
| 64 | 64 | |
| 65 | - /** |
|
| 66 | - * Get all users who favorited an object |
|
| 67 | - * |
|
| 68 | - * @param string $objectType |
|
| 69 | - * @param int $objectId |
|
| 70 | - * @return array |
|
| 71 | - */ |
|
| 72 | - public function getUsersFavoritingObject(string $objectType, int $objectId): array { |
|
| 73 | - $query = $this->connection->getQueryBuilder(); |
|
| 74 | - $query->select('uid') |
|
| 75 | - ->from('vcategory_to_object', 'o') |
|
| 76 | - ->innerJoin('o', 'vcategory', 'c', $query->expr()->eq('o.categoryid', 'c.id')) |
|
| 77 | - ->where($query->expr()->eq('objid', $query->createNamedParameter($objectId, IQueryBuilder::PARAM_INT))) |
|
| 78 | - ->andWhere($query->expr()->eq('c.type', $query->createNamedParameter($objectType))) |
|
| 79 | - ->andWhere($query->expr()->eq('c.category', $query->createNamedParameter(ITags::TAG_FAVORITE))); |
|
| 65 | + /** |
|
| 66 | + * Get all users who favorited an object |
|
| 67 | + * |
|
| 68 | + * @param string $objectType |
|
| 69 | + * @param int $objectId |
|
| 70 | + * @return array |
|
| 71 | + */ |
|
| 72 | + public function getUsersFavoritingObject(string $objectType, int $objectId): array { |
|
| 73 | + $query = $this->connection->getQueryBuilder(); |
|
| 74 | + $query->select('uid') |
|
| 75 | + ->from('vcategory_to_object', 'o') |
|
| 76 | + ->innerJoin('o', 'vcategory', 'c', $query->expr()->eq('o.categoryid', 'c.id')) |
|
| 77 | + ->where($query->expr()->eq('objid', $query->createNamedParameter($objectId, IQueryBuilder::PARAM_INT))) |
|
| 78 | + ->andWhere($query->expr()->eq('c.type', $query->createNamedParameter($objectType))) |
|
| 79 | + ->andWhere($query->expr()->eq('c.category', $query->createNamedParameter(ITags::TAG_FAVORITE))); |
|
| 80 | 80 | |
| 81 | - $result = $query->executeQuery(); |
|
| 82 | - $users = $result->fetchAll(\PDO::FETCH_COLUMN); |
|
| 83 | - $result->closeCursor(); |
|
| 81 | + $result = $query->executeQuery(); |
|
| 82 | + $users = $result->fetchAll(\PDO::FETCH_COLUMN); |
|
| 83 | + $result->closeCursor(); |
|
| 84 | 84 | |
| 85 | - return $users; |
|
| 86 | - } |
|
| 85 | + return $users; |
|
| 86 | + } |
|
| 87 | 87 | |
| 88 | - public function handle(Event $event): void { |
|
| 89 | - if (!($event instanceof UserDeletedEvent)) { |
|
| 90 | - return; |
|
| 91 | - } |
|
| 88 | + public function handle(Event $event): void { |
|
| 89 | + if (!($event instanceof UserDeletedEvent)) { |
|
| 90 | + return; |
|
| 91 | + } |
|
| 92 | 92 | |
| 93 | - // Find all objectid/tagId pairs. |
|
| 94 | - $user = $event->getUser(); |
|
| 95 | - $qb = $this->connection->getQueryBuilder(); |
|
| 96 | - $qb->select('id') |
|
| 97 | - ->from('vcategory') |
|
| 98 | - ->where($qb->expr()->eq('uid', $qb->createNamedParameter($user->getUID()))); |
|
| 99 | - try { |
|
| 100 | - $result = $qb->executeQuery(); |
|
| 101 | - } catch (DBException $e) { |
|
| 102 | - $this->logger->error($e->getMessage(), [ |
|
| 103 | - 'app' => 'core', |
|
| 104 | - 'exception' => $e, |
|
| 105 | - ]); |
|
| 106 | - return; |
|
| 107 | - } |
|
| 93 | + // Find all objectid/tagId pairs. |
|
| 94 | + $user = $event->getUser(); |
|
| 95 | + $qb = $this->connection->getQueryBuilder(); |
|
| 96 | + $qb->select('id') |
|
| 97 | + ->from('vcategory') |
|
| 98 | + ->where($qb->expr()->eq('uid', $qb->createNamedParameter($user->getUID()))); |
|
| 99 | + try { |
|
| 100 | + $result = $qb->executeQuery(); |
|
| 101 | + } catch (DBException $e) { |
|
| 102 | + $this->logger->error($e->getMessage(), [ |
|
| 103 | + 'app' => 'core', |
|
| 104 | + 'exception' => $e, |
|
| 105 | + ]); |
|
| 106 | + return; |
|
| 107 | + } |
|
| 108 | 108 | |
| 109 | - $tagsIds = array_map(fn (array $row) => (int)$row['id'], $result->fetchAll()); |
|
| 110 | - $result->closeCursor(); |
|
| 109 | + $tagsIds = array_map(fn (array $row) => (int)$row['id'], $result->fetchAll()); |
|
| 110 | + $result->closeCursor(); |
|
| 111 | 111 | |
| 112 | - if (count($tagsIds) === 0) { |
|
| 113 | - return; |
|
| 114 | - } |
|
| 112 | + if (count($tagsIds) === 0) { |
|
| 113 | + return; |
|
| 114 | + } |
|
| 115 | 115 | |
| 116 | - // Clean vcategory_to_object table |
|
| 117 | - $qb = $this->connection->getQueryBuilder(); |
|
| 118 | - $qb = $qb->delete('vcategory_to_object') |
|
| 119 | - ->where($qb->expr()->in('categoryid', $qb->createParameter('chunk'))); |
|
| 116 | + // Clean vcategory_to_object table |
|
| 117 | + $qb = $this->connection->getQueryBuilder(); |
|
| 118 | + $qb = $qb->delete('vcategory_to_object') |
|
| 119 | + ->where($qb->expr()->in('categoryid', $qb->createParameter('chunk'))); |
|
| 120 | 120 | |
| 121 | - // Clean vcategory |
|
| 122 | - $qb1 = $this->connection->getQueryBuilder(); |
|
| 123 | - $qb1 = $qb1->delete('vcategory') |
|
| 124 | - ->where($qb1->expr()->in('uid', $qb1->createParameter('chunk'))); |
|
| 121 | + // Clean vcategory |
|
| 122 | + $qb1 = $this->connection->getQueryBuilder(); |
|
| 123 | + $qb1 = $qb1->delete('vcategory') |
|
| 124 | + ->where($qb1->expr()->in('uid', $qb1->createParameter('chunk'))); |
|
| 125 | 125 | |
| 126 | - foreach (array_chunk($tagsIds, 1000) as $tagChunk) { |
|
| 127 | - $qb->setParameter('chunk', $tagChunk, IQueryBuilder::PARAM_INT_ARRAY); |
|
| 128 | - $qb1->setParameter('chunk', $tagChunk, IQueryBuilder::PARAM_INT_ARRAY); |
|
| 129 | - try { |
|
| 130 | - $qb->executeStatement(); |
|
| 131 | - $qb1->executeStatement(); |
|
| 132 | - } catch (DBException $e) { |
|
| 133 | - $this->logger->error($e->getMessage(), [ |
|
| 134 | - 'app' => 'core', |
|
| 135 | - 'exception' => $e, |
|
| 136 | - ]); |
|
| 137 | - } |
|
| 138 | - } |
|
| 139 | - } |
|
| 126 | + foreach (array_chunk($tagsIds, 1000) as $tagChunk) { |
|
| 127 | + $qb->setParameter('chunk', $tagChunk, IQueryBuilder::PARAM_INT_ARRAY); |
|
| 128 | + $qb1->setParameter('chunk', $tagChunk, IQueryBuilder::PARAM_INT_ARRAY); |
|
| 129 | + try { |
|
| 130 | + $qb->executeStatement(); |
|
| 131 | + $qb1->executeStatement(); |
|
| 132 | + } catch (DBException $e) { |
|
| 133 | + $this->logger->error($e->getMessage(), [ |
|
| 134 | + 'app' => 'core', |
|
| 135 | + 'exception' => $e, |
|
| 136 | + ]); |
|
| 137 | + } |
|
| 138 | + } |
|
| 139 | + } |
|
| 140 | 140 | } |
@@ -22,682 +22,682 @@ |
||
| 22 | 22 | use Psr\Log\LoggerInterface; |
| 23 | 23 | |
| 24 | 24 | class Tags implements ITags { |
| 25 | - /** |
|
| 26 | - * Used for storing objectid/categoryname pairs while rescanning. |
|
| 27 | - */ |
|
| 28 | - private static array $relations = []; |
|
| 29 | - private array $tags = []; |
|
| 30 | - |
|
| 31 | - /** |
|
| 32 | - * Are we including tags for shared items? |
|
| 33 | - */ |
|
| 34 | - private bool $includeShared = false; |
|
| 35 | - |
|
| 36 | - /** |
|
| 37 | - * The current user, plus any owners of the items shared with the current |
|
| 38 | - * user, if $this->includeShared === true. |
|
| 39 | - */ |
|
| 40 | - private array $owners = []; |
|
| 41 | - |
|
| 42 | - /** |
|
| 43 | - * The sharing backend for objects of $this->type. Required if |
|
| 44 | - * $this->includeShared === true to determine ownership of items. |
|
| 45 | - */ |
|
| 46 | - private ?Share_Backend $backend = null; |
|
| 47 | - |
|
| 48 | - public const TAG_TABLE = 'vcategory'; |
|
| 49 | - public const RELATION_TABLE = 'vcategory_to_object'; |
|
| 50 | - |
|
| 51 | - /** |
|
| 52 | - * Constructor. |
|
| 53 | - * |
|
| 54 | - * @param TagMapper $mapper Instance of the TagMapper abstraction layer. |
|
| 55 | - * @param string $user The user whose data the object will operate on. |
|
| 56 | - * @param string $type The type of items for which tags will be loaded. |
|
| 57 | - * @param array $defaultTags Tags that should be created at construction. |
|
| 58 | - * |
|
| 59 | - * since 20.0.0 $includeShared isn't used anymore |
|
| 60 | - */ |
|
| 61 | - public function __construct( |
|
| 62 | - private TagMapper $mapper, |
|
| 63 | - private string $user, |
|
| 64 | - private string $type, |
|
| 65 | - private LoggerInterface $logger, |
|
| 66 | - private IDBConnection $db, |
|
| 67 | - private IEventDispatcher $dispatcher, |
|
| 68 | - private IUserSession $userSession, |
|
| 69 | - private Folder $userFolder, |
|
| 70 | - array $defaultTags = [], |
|
| 71 | - ) { |
|
| 72 | - $this->owners = [$this->user]; |
|
| 73 | - $this->tags = $this->mapper->loadTags($this->owners, $this->type); |
|
| 74 | - |
|
| 75 | - if (count($defaultTags) > 0 && count($this->tags) === 0) { |
|
| 76 | - $this->addMultiple($defaultTags, true); |
|
| 77 | - } |
|
| 78 | - } |
|
| 79 | - |
|
| 80 | - /** |
|
| 81 | - * Check if any tags are saved for this type and user. |
|
| 82 | - * |
|
| 83 | - * @return boolean |
|
| 84 | - */ |
|
| 85 | - public function isEmpty(): bool { |
|
| 86 | - return count($this->tags) === 0; |
|
| 87 | - } |
|
| 88 | - |
|
| 89 | - /** |
|
| 90 | - * Returns an array mapping a given tag's properties to its values: |
|
| 91 | - * ['id' => 0, 'name' = 'Tag', 'owner' = 'User', 'type' => 'tagtype'] |
|
| 92 | - * |
|
| 93 | - * @param string $id The ID of the tag that is going to be mapped |
|
| 94 | - * @return array|false |
|
| 95 | - */ |
|
| 96 | - public function getTag(string $id) { |
|
| 97 | - $key = $this->getTagById($id); |
|
| 98 | - if ($key !== false) { |
|
| 99 | - return $this->tagMap($this->tags[$key]); |
|
| 100 | - } |
|
| 101 | - return false; |
|
| 102 | - } |
|
| 103 | - |
|
| 104 | - /** |
|
| 105 | - * Get the tags for a specific user. |
|
| 106 | - * |
|
| 107 | - * This returns an array with maps containing each tag's properties: |
|
| 108 | - * [ |
|
| 109 | - * ['id' => 0, 'name' = 'First tag', 'owner' = 'User', 'type' => 'tagtype'], |
|
| 110 | - * ['id' => 1, 'name' = 'Shared tag', 'owner' = 'Other user', 'type' => 'tagtype'], |
|
| 111 | - * ] |
|
| 112 | - * |
|
| 113 | - * @return array<array-key, array{id: int, name: string}> |
|
| 114 | - */ |
|
| 115 | - public function getTags(): array { |
|
| 116 | - if (!count($this->tags)) { |
|
| 117 | - return []; |
|
| 118 | - } |
|
| 119 | - |
|
| 120 | - usort($this->tags, function ($a, $b) { |
|
| 121 | - return strnatcasecmp($a->getName(), $b->getName()); |
|
| 122 | - }); |
|
| 123 | - $tagMap = []; |
|
| 124 | - |
|
| 125 | - foreach ($this->tags as $tag) { |
|
| 126 | - if ($tag->getName() !== ITags::TAG_FAVORITE) { |
|
| 127 | - $tagMap[] = $this->tagMap($tag); |
|
| 128 | - } |
|
| 129 | - } |
|
| 130 | - return $tagMap; |
|
| 131 | - } |
|
| 132 | - |
|
| 133 | - /** |
|
| 134 | - * Return only the tags owned by the given user, omitting any tags shared |
|
| 135 | - * by other users. |
|
| 136 | - * |
|
| 137 | - * @param string $user The user whose tags are to be checked. |
|
| 138 | - * @return array An array of Tag objects. |
|
| 139 | - */ |
|
| 140 | - public function getTagsForUser(string $user): array { |
|
| 141 | - return array_filter($this->tags, |
|
| 142 | - function ($tag) use ($user) { |
|
| 143 | - return $tag->getOwner() === $user; |
|
| 144 | - } |
|
| 145 | - ); |
|
| 146 | - } |
|
| 147 | - |
|
| 148 | - /** |
|
| 149 | - * Get the list of tags for the given ids. |
|
| 150 | - * |
|
| 151 | - * @param list<int> $objIds array of object ids |
|
| 152 | - * @return array<int, list<string>>|false of tags id as key to array of tag names |
|
| 153 | - * or false if an error occurred |
|
| 154 | - */ |
|
| 155 | - public function getTagsForObjects(array $objIds) { |
|
| 156 | - $entries = []; |
|
| 157 | - |
|
| 158 | - try { |
|
| 159 | - $chunks = array_chunk($objIds, 900, false); |
|
| 160 | - $qb = $this->db->getQueryBuilder(); |
|
| 161 | - $qb->select('category', 'categoryid', 'objid') |
|
| 162 | - ->from(self::RELATION_TABLE, 'r') |
|
| 163 | - ->join('r', self::TAG_TABLE, 't', $qb->expr()->eq('r.categoryid', 't.id')) |
|
| 164 | - ->where($qb->expr()->eq('uid', $qb->createParameter('uid'))) |
|
| 165 | - ->andWhere($qb->expr()->eq('r.type', $qb->createParameter('type'))) |
|
| 166 | - ->andWhere($qb->expr()->in('objid', $qb->createParameter('chunk'))); |
|
| 167 | - foreach ($chunks as $chunk) { |
|
| 168 | - $qb->setParameter('uid', $this->user, IQueryBuilder::PARAM_STR); |
|
| 169 | - $qb->setParameter('type', $this->type, IQueryBuilder::PARAM_STR); |
|
| 170 | - $qb->setParameter('chunk', $chunk, IQueryBuilder::PARAM_INT_ARRAY); |
|
| 171 | - $result = $qb->executeQuery(); |
|
| 172 | - while ($row = $result->fetch()) { |
|
| 173 | - $objId = (int)$row['objid']; |
|
| 174 | - if (!isset($entries[$objId])) { |
|
| 175 | - $entries[$objId] = []; |
|
| 176 | - } |
|
| 177 | - $entries[$objId][] = $row['category']; |
|
| 178 | - } |
|
| 179 | - $result->closeCursor(); |
|
| 180 | - } |
|
| 181 | - } catch (\Exception $e) { |
|
| 182 | - $this->logger->error($e->getMessage(), [ |
|
| 183 | - 'exception' => $e, |
|
| 184 | - 'app' => 'core', |
|
| 185 | - ]); |
|
| 186 | - return false; |
|
| 187 | - } |
|
| 188 | - |
|
| 189 | - return $entries; |
|
| 190 | - } |
|
| 191 | - |
|
| 192 | - /** |
|
| 193 | - * Get the a list if items tagged with $tag. |
|
| 194 | - * |
|
| 195 | - * Throws an exception if the tag could not be found. |
|
| 196 | - * |
|
| 197 | - * @param string $tag Tag id or name. |
|
| 198 | - * @return int[]|false An array of object ids or false on error. |
|
| 199 | - * @throws \Exception |
|
| 200 | - */ |
|
| 201 | - public function getIdsForTag($tag) { |
|
| 202 | - $tagId = false; |
|
| 203 | - if (is_numeric($tag)) { |
|
| 204 | - $tagId = $tag; |
|
| 205 | - } elseif (is_string($tag)) { |
|
| 206 | - $tag = trim($tag); |
|
| 207 | - if ($tag === '') { |
|
| 208 | - $this->logger->debug(__METHOD__ . ' Cannot use empty tag names', ['app' => 'core']); |
|
| 209 | - return false; |
|
| 210 | - } |
|
| 211 | - $tagId = $this->getTagId($tag); |
|
| 212 | - } |
|
| 213 | - |
|
| 214 | - if ($tagId === false) { |
|
| 215 | - $l10n = \OCP\Util::getL10N('core'); |
|
| 216 | - throw new \Exception( |
|
| 217 | - $l10n->t('Could not find category "%s"', [$tag]) |
|
| 218 | - ); |
|
| 219 | - } |
|
| 220 | - |
|
| 221 | - $ids = []; |
|
| 222 | - try { |
|
| 223 | - $qb = $this->db->getQueryBuilder(); |
|
| 224 | - $qb->select('objid') |
|
| 225 | - ->from(self::RELATION_TABLE) |
|
| 226 | - ->where($qb->expr()->eq('categoryid', $qb->createNamedParameter($tagId, IQueryBuilder::PARAM_STR))); |
|
| 227 | - $result = $qb->executeQuery(); |
|
| 228 | - } catch (Exception $e) { |
|
| 229 | - $this->logger->error($e->getMessage(), [ |
|
| 230 | - 'app' => 'core', |
|
| 231 | - 'exception' => $e, |
|
| 232 | - ]); |
|
| 233 | - return false; |
|
| 234 | - } |
|
| 235 | - |
|
| 236 | - while ($row = $result->fetch()) { |
|
| 237 | - $ids[] = (int)$row['objid']; |
|
| 238 | - } |
|
| 239 | - $result->closeCursor(); |
|
| 240 | - |
|
| 241 | - return $ids; |
|
| 242 | - } |
|
| 243 | - |
|
| 244 | - /** |
|
| 245 | - * Checks whether a tag is saved for the given user, |
|
| 246 | - * disregarding the ones shared with them. |
|
| 247 | - * |
|
| 248 | - * @param string $name The tag name to check for. |
|
| 249 | - * @param string $user The user whose tags are to be checked. |
|
| 250 | - */ |
|
| 251 | - public function userHasTag(string $name, string $user): bool { |
|
| 252 | - return $this->array_searchi($name, $this->getTagsForUser($user)) !== false; |
|
| 253 | - } |
|
| 254 | - |
|
| 255 | - /** |
|
| 256 | - * Checks whether a tag is saved for or shared with the current user. |
|
| 257 | - * |
|
| 258 | - * @param string $name The tag name to check for. |
|
| 259 | - */ |
|
| 260 | - public function hasTag(string $name): bool { |
|
| 261 | - return $this->getTagId($name) !== false; |
|
| 262 | - } |
|
| 263 | - |
|
| 264 | - /** |
|
| 265 | - * Add a new tag. |
|
| 266 | - * |
|
| 267 | - * @param string $name A string with a name of the tag |
|
| 268 | - * @return false|int the id of the added tag or false on error. |
|
| 269 | - */ |
|
| 270 | - public function add(string $name) { |
|
| 271 | - $name = trim($name); |
|
| 272 | - |
|
| 273 | - if ($name === '') { |
|
| 274 | - $this->logger->debug(__METHOD__ . ' Cannot add an empty tag', ['app' => 'core']); |
|
| 275 | - return false; |
|
| 276 | - } |
|
| 277 | - if ($this->userHasTag($name, $this->user)) { |
|
| 278 | - $this->logger->debug(__METHOD__ . ' Tag with name already exists', ['app' => 'core']); |
|
| 279 | - return false; |
|
| 280 | - } |
|
| 281 | - try { |
|
| 282 | - $tag = new Tag($this->user, $this->type, $name); |
|
| 283 | - $tag = $this->mapper->insert($tag); |
|
| 284 | - $this->tags[] = $tag; |
|
| 285 | - } catch (\Exception $e) { |
|
| 286 | - $this->logger->error($e->getMessage(), [ |
|
| 287 | - 'exception' => $e, |
|
| 288 | - 'app' => 'core', |
|
| 289 | - ]); |
|
| 290 | - return false; |
|
| 291 | - } |
|
| 292 | - $this->logger->debug(__METHOD__ . ' Added an tag with ' . $tag->getId(), ['app' => 'core']); |
|
| 293 | - return $tag->getId(); |
|
| 294 | - } |
|
| 295 | - |
|
| 296 | - /** |
|
| 297 | - * Rename tag. |
|
| 298 | - * |
|
| 299 | - * @param string|integer $from The name or ID of the existing tag |
|
| 300 | - * @param string $to The new name of the tag. |
|
| 301 | - * @return bool |
|
| 302 | - */ |
|
| 303 | - public function rename($from, string $to): bool { |
|
| 304 | - $from = trim($from); |
|
| 305 | - $to = trim($to); |
|
| 306 | - |
|
| 307 | - if ($to === '' || $from === '') { |
|
| 308 | - $this->logger->debug(__METHOD__ . 'Cannot use an empty tag names', ['app' => 'core']); |
|
| 309 | - return false; |
|
| 310 | - } |
|
| 311 | - |
|
| 312 | - if (is_numeric($from)) { |
|
| 313 | - $key = $this->getTagById($from); |
|
| 314 | - } else { |
|
| 315 | - $key = $this->getTagByName($from); |
|
| 316 | - } |
|
| 317 | - if ($key === false) { |
|
| 318 | - $this->logger->debug(__METHOD__ . 'Tag ' . $from . 'does not exist', ['app' => 'core']); |
|
| 319 | - return false; |
|
| 320 | - } |
|
| 321 | - $tag = $this->tags[$key]; |
|
| 322 | - |
|
| 323 | - if ($this->userHasTag($to, $tag->getOwner())) { |
|
| 324 | - $this->logger->debug(__METHOD__ . 'A tag named' . $to . 'already exists for user' . $tag->getOwner(), ['app' => 'core']); |
|
| 325 | - return false; |
|
| 326 | - } |
|
| 327 | - |
|
| 328 | - try { |
|
| 329 | - $tag->setName($to); |
|
| 330 | - $this->tags[$key] = $this->mapper->update($tag); |
|
| 331 | - } catch (\Exception $e) { |
|
| 332 | - $this->logger->error($e->getMessage(), [ |
|
| 333 | - 'exception' => $e, |
|
| 334 | - 'app' => 'core', |
|
| 335 | - ]); |
|
| 336 | - return false; |
|
| 337 | - } |
|
| 338 | - return true; |
|
| 339 | - } |
|
| 340 | - |
|
| 341 | - /** |
|
| 342 | - * Add a list of new tags. |
|
| 343 | - * |
|
| 344 | - * @param string|string[] $names A string with a name or an array of strings containing |
|
| 345 | - * the name(s) of the tag(s) to add. |
|
| 346 | - * @param bool $sync When true, save the tags |
|
| 347 | - * @param int|null $id int Optional object id to add to this|these tag(s) |
|
| 348 | - * @return bool Returns false on error. |
|
| 349 | - */ |
|
| 350 | - public function addMultiple($names, bool $sync = false, ?int $id = null): bool { |
|
| 351 | - if (!is_array($names)) { |
|
| 352 | - $names = [$names]; |
|
| 353 | - } |
|
| 354 | - $names = array_map('trim', $names); |
|
| 355 | - array_filter($names); |
|
| 356 | - |
|
| 357 | - $newones = []; |
|
| 358 | - foreach ($names as $name) { |
|
| 359 | - if (!$this->hasTag($name) && $name !== '') { |
|
| 360 | - $newones[] = new Tag($this->user, $this->type, $name); |
|
| 361 | - } |
|
| 362 | - if (!is_null($id)) { |
|
| 363 | - // Insert $objectid, $categoryid pairs if not exist. |
|
| 364 | - self::$relations[] = ['objid' => $id, 'tag' => $name]; |
|
| 365 | - } |
|
| 366 | - } |
|
| 367 | - $this->tags = array_merge($this->tags, $newones); |
|
| 368 | - if ($sync === true) { |
|
| 369 | - $this->save(); |
|
| 370 | - } |
|
| 371 | - |
|
| 372 | - return true; |
|
| 373 | - } |
|
| 374 | - |
|
| 375 | - /** |
|
| 376 | - * Save the list of tags and their object relations |
|
| 377 | - */ |
|
| 378 | - protected function save(): void { |
|
| 379 | - foreach ($this->tags as $tag) { |
|
| 380 | - try { |
|
| 381 | - if (!$this->mapper->tagExists($tag)) { |
|
| 382 | - $this->mapper->insert($tag); |
|
| 383 | - } |
|
| 384 | - } catch (\Exception $e) { |
|
| 385 | - $this->logger->error($e->getMessage(), [ |
|
| 386 | - 'exception' => $e, |
|
| 387 | - 'app' => 'core', |
|
| 388 | - ]); |
|
| 389 | - } |
|
| 390 | - } |
|
| 391 | - |
|
| 392 | - // reload tags to get the proper ids. |
|
| 393 | - $this->tags = $this->mapper->loadTags($this->owners, $this->type); |
|
| 394 | - $this->logger->debug(__METHOD__ . 'tags' . print_r($this->tags, true), ['app' => 'core']); |
|
| 395 | - // Loop through temporarily cached objectid/tagname pairs |
|
| 396 | - // and save relations. |
|
| 397 | - $tags = $this->tags; |
|
| 398 | - // For some reason this is needed or array_search(i) will return 0..? |
|
| 399 | - ksort($tags); |
|
| 400 | - foreach (self::$relations as $relation) { |
|
| 401 | - $tagId = $this->getTagId($relation['tag']); |
|
| 402 | - $this->logger->debug(__METHOD__ . 'catid ' . $relation['tag'] . ' ' . $tagId, ['app' => 'core']); |
|
| 403 | - if ($tagId) { |
|
| 404 | - $qb = $this->db->getQueryBuilder(); |
|
| 405 | - $qb->insert(self::RELATION_TABLE) |
|
| 406 | - ->values([ |
|
| 407 | - 'objid' => $qb->createNamedParameter($relation['objid'], IQueryBuilder::PARAM_INT), |
|
| 408 | - 'categoryid' => $qb->createNamedParameter($tagId, IQueryBuilder::PARAM_INT), |
|
| 409 | - 'type' => $qb->createNamedParameter($this->type), |
|
| 410 | - ]); |
|
| 411 | - try { |
|
| 412 | - $qb->executeStatement(); |
|
| 413 | - } catch (Exception $e) { |
|
| 414 | - $this->logger->error($e->getMessage(), [ |
|
| 415 | - 'exception' => $e, |
|
| 416 | - 'app' => 'core', |
|
| 417 | - ]); |
|
| 418 | - } |
|
| 419 | - } |
|
| 420 | - } |
|
| 421 | - self::$relations = []; // reset |
|
| 422 | - } |
|
| 423 | - |
|
| 424 | - /** |
|
| 425 | - * Delete tag/object relations from the db |
|
| 426 | - * |
|
| 427 | - * @param array $ids The ids of the objects |
|
| 428 | - * @return boolean Returns false on error. |
|
| 429 | - */ |
|
| 430 | - public function purgeObjects(array $ids): bool { |
|
| 431 | - if (count($ids) === 0) { |
|
| 432 | - // job done ;) |
|
| 433 | - return true; |
|
| 434 | - } |
|
| 435 | - $updates = $ids; |
|
| 436 | - $qb = $this->db->getQueryBuilder(); |
|
| 437 | - $qb->delete(self::RELATION_TABLE) |
|
| 438 | - ->where($qb->expr()->in('objid', $qb->createNamedParameter($ids))); |
|
| 439 | - try { |
|
| 440 | - $qb->executeStatement(); |
|
| 441 | - } catch (Exception $e) { |
|
| 442 | - $this->logger->error($e->getMessage(), [ |
|
| 443 | - 'app' => 'core', |
|
| 444 | - 'exception' => $e, |
|
| 445 | - ]); |
|
| 446 | - return false; |
|
| 447 | - } |
|
| 448 | - return true; |
|
| 449 | - } |
|
| 450 | - |
|
| 451 | - /** |
|
| 452 | - * Get favorites for an object type |
|
| 453 | - * |
|
| 454 | - * @return array|false An array of object ids. |
|
| 455 | - */ |
|
| 456 | - public function getFavorites() { |
|
| 457 | - if (!$this->userHasTag(ITags::TAG_FAVORITE, $this->user)) { |
|
| 458 | - return []; |
|
| 459 | - } |
|
| 460 | - |
|
| 461 | - try { |
|
| 462 | - return $this->getIdsForTag(ITags::TAG_FAVORITE); |
|
| 463 | - } catch (\Exception $e) { |
|
| 464 | - \OCP\Server::get(LoggerInterface::class)->error( |
|
| 465 | - $e->getMessage(), |
|
| 466 | - [ |
|
| 467 | - 'app' => 'core', |
|
| 468 | - 'exception' => $e, |
|
| 469 | - ] |
|
| 470 | - ); |
|
| 471 | - return []; |
|
| 472 | - } |
|
| 473 | - } |
|
| 474 | - |
|
| 475 | - /** |
|
| 476 | - * Add an object to favorites |
|
| 477 | - * |
|
| 478 | - * @param int $objid The id of the object |
|
| 479 | - * @return boolean |
|
| 480 | - */ |
|
| 481 | - public function addToFavorites($objid) { |
|
| 482 | - if (!$this->userHasTag(ITags::TAG_FAVORITE, $this->user)) { |
|
| 483 | - $this->add(ITags::TAG_FAVORITE); |
|
| 484 | - } |
|
| 485 | - return $this->tagAs($objid, ITags::TAG_FAVORITE); |
|
| 486 | - } |
|
| 487 | - |
|
| 488 | - /** |
|
| 489 | - * Remove an object from favorites |
|
| 490 | - * |
|
| 491 | - * @param int $objid The id of the object |
|
| 492 | - * @return boolean |
|
| 493 | - */ |
|
| 494 | - public function removeFromFavorites($objid) { |
|
| 495 | - return $this->unTag($objid, ITags::TAG_FAVORITE); |
|
| 496 | - } |
|
| 497 | - |
|
| 498 | - /** |
|
| 499 | - * Creates a tag/object relation. |
|
| 500 | - */ |
|
| 501 | - public function tagAs($objid, $tag, ?string $path = null) { |
|
| 502 | - if (is_string($tag) && !is_numeric($tag)) { |
|
| 503 | - $tag = trim($tag); |
|
| 504 | - if ($tag === '') { |
|
| 505 | - $this->logger->debug(__METHOD__ . ', Cannot add an empty tag'); |
|
| 506 | - return false; |
|
| 507 | - } |
|
| 508 | - if (!$this->hasTag($tag)) { |
|
| 509 | - $this->add($tag); |
|
| 510 | - } |
|
| 511 | - $tagId = $this->getTagId($tag); |
|
| 512 | - } else { |
|
| 513 | - $tagId = $tag; |
|
| 514 | - } |
|
| 515 | - $qb = $this->db->getQueryBuilder(); |
|
| 516 | - $qb->insert(self::RELATION_TABLE) |
|
| 517 | - ->values([ |
|
| 518 | - 'objid' => $qb->createNamedParameter($objid, IQueryBuilder::PARAM_INT), |
|
| 519 | - 'categoryid' => $qb->createNamedParameter($tagId, IQueryBuilder::PARAM_INT), |
|
| 520 | - 'type' => $qb->createNamedParameter($this->type, IQueryBuilder::PARAM_STR), |
|
| 521 | - ]); |
|
| 522 | - try { |
|
| 523 | - $qb->executeStatement(); |
|
| 524 | - } catch (\Exception $e) { |
|
| 525 | - \OCP\Server::get(LoggerInterface::class)->error($e->getMessage(), [ |
|
| 526 | - 'app' => 'core', |
|
| 527 | - 'exception' => $e, |
|
| 528 | - ]); |
|
| 529 | - return false; |
|
| 530 | - } |
|
| 531 | - if ($tag === ITags::TAG_FAVORITE) { |
|
| 532 | - if ($path === null) { |
|
| 533 | - $node = $this->userFolder->getFirstNodeById($objid); |
|
| 534 | - if ($node !== null) { |
|
| 535 | - $path = $node->getPath(); |
|
| 536 | - } else { |
|
| 537 | - throw new Exception('Failed to favorite: node with id ' . $objid . ' not found'); |
|
| 538 | - } |
|
| 539 | - } |
|
| 540 | - |
|
| 541 | - $this->dispatcher->dispatchTyped(new NodeAddedToFavorite($this->userSession->getUser(), $objid, $path)); |
|
| 542 | - } |
|
| 543 | - return true; |
|
| 544 | - } |
|
| 545 | - |
|
| 546 | - /** |
|
| 547 | - * Delete single tag/object relation from the db |
|
| 548 | - */ |
|
| 549 | - public function unTag($objid, $tag, ?string $path = null) { |
|
| 550 | - if (is_string($tag) && !is_numeric($tag)) { |
|
| 551 | - $tag = trim($tag); |
|
| 552 | - if ($tag === '') { |
|
| 553 | - $this->logger->debug(__METHOD__ . ', Tag name is empty'); |
|
| 554 | - return false; |
|
| 555 | - } |
|
| 556 | - $tagId = $this->getTagId($tag); |
|
| 557 | - } else { |
|
| 558 | - $tagId = $tag; |
|
| 559 | - } |
|
| 560 | - |
|
| 561 | - try { |
|
| 562 | - $qb = $this->db->getQueryBuilder(); |
|
| 563 | - $qb->delete(self::RELATION_TABLE) |
|
| 564 | - ->where($qb->expr()->andX( |
|
| 565 | - $qb->expr()->eq('objid', $qb->createNamedParameter($objid)), |
|
| 566 | - $qb->expr()->eq('categoryid', $qb->createNamedParameter($tagId)), |
|
| 567 | - $qb->expr()->eq('type', $qb->createNamedParameter($this->type)), |
|
| 568 | - ))->executeStatement(); |
|
| 569 | - } catch (\Exception $e) { |
|
| 570 | - $this->logger->error($e->getMessage(), [ |
|
| 571 | - 'app' => 'core', |
|
| 572 | - 'exception' => $e, |
|
| 573 | - ]); |
|
| 574 | - return false; |
|
| 575 | - } |
|
| 576 | - if ($tag === ITags::TAG_FAVORITE) { |
|
| 577 | - if ($path === null) { |
|
| 578 | - $node = $this->userFolder->getFirstNodeById($objid); |
|
| 579 | - if ($node !== null) { |
|
| 580 | - $path = $node->getPath(); |
|
| 581 | - } else { |
|
| 582 | - throw new Exception('Failed to unfavorite: node with id ' . $objid . ' not found'); |
|
| 583 | - } |
|
| 584 | - } |
|
| 585 | - |
|
| 586 | - $this->dispatcher->dispatchTyped(new NodeRemovedFromFavorite($this->userSession->getUser(), $objid, $path)); |
|
| 587 | - } |
|
| 588 | - return true; |
|
| 589 | - } |
|
| 590 | - |
|
| 591 | - /** |
|
| 592 | - * Delete tags from the database. |
|
| 593 | - * |
|
| 594 | - * @param string[]|integer[] $names An array of tags (names or IDs) to delete |
|
| 595 | - * @return bool Returns false on error |
|
| 596 | - */ |
|
| 597 | - public function delete($names) { |
|
| 598 | - if (!is_array($names)) { |
|
| 599 | - $names = [$names]; |
|
| 600 | - } |
|
| 601 | - |
|
| 602 | - $names = array_map('trim', $names); |
|
| 603 | - array_filter($names); |
|
| 604 | - |
|
| 605 | - $this->logger->debug(__METHOD__ . ', before: ' . print_r($this->tags, true)); |
|
| 606 | - foreach ($names as $name) { |
|
| 607 | - $id = null; |
|
| 608 | - |
|
| 609 | - if (is_numeric($name)) { |
|
| 610 | - $key = $this->getTagById($name); |
|
| 611 | - } else { |
|
| 612 | - $key = $this->getTagByName($name); |
|
| 613 | - } |
|
| 614 | - if ($key !== false) { |
|
| 615 | - $tag = $this->tags[$key]; |
|
| 616 | - $id = $tag->getId(); |
|
| 617 | - unset($this->tags[$key]); |
|
| 618 | - $this->mapper->delete($tag); |
|
| 619 | - } else { |
|
| 620 | - $this->logger->error(__METHOD__ . 'Cannot delete tag ' . $name . ': not found.'); |
|
| 621 | - } |
|
| 622 | - if (!is_null($id) && $id !== false) { |
|
| 623 | - try { |
|
| 624 | - $qb = $this->db->getQueryBuilder(); |
|
| 625 | - $qb->delete(self::RELATION_TABLE) |
|
| 626 | - ->where($qb->expr()->eq('categoryid', $qb->createNamedParameter($id, IQueryBuilder::PARAM_INT))) |
|
| 627 | - ->executeStatement(); |
|
| 628 | - } catch (\Exception $e) { |
|
| 629 | - $this->logger->error($e->getMessage(), [ |
|
| 630 | - 'app' => 'core', |
|
| 631 | - 'exception' => $e, |
|
| 632 | - ]); |
|
| 633 | - return false; |
|
| 634 | - } |
|
| 635 | - } |
|
| 636 | - } |
|
| 637 | - return true; |
|
| 638 | - } |
|
| 639 | - |
|
| 640 | - // case-insensitive array_search |
|
| 641 | - protected function array_searchi($needle, $haystack, $mem = 'getName') { |
|
| 642 | - if (!is_array($haystack)) { |
|
| 643 | - return false; |
|
| 644 | - } |
|
| 645 | - return array_search(strtolower($needle), array_map( |
|
| 646 | - function ($tag) use ($mem) { |
|
| 647 | - return strtolower(call_user_func([$tag, $mem])); |
|
| 648 | - }, $haystack) |
|
| 649 | - ); |
|
| 650 | - } |
|
| 651 | - |
|
| 652 | - /** |
|
| 653 | - * Get a tag's ID. |
|
| 654 | - * |
|
| 655 | - * @param string $name The tag name to look for. |
|
| 656 | - * @return string|bool The tag's id or false if no matching tag is found. |
|
| 657 | - */ |
|
| 658 | - private function getTagId($name) { |
|
| 659 | - $key = $this->array_searchi($name, $this->tags); |
|
| 660 | - if ($key !== false) { |
|
| 661 | - return $this->tags[$key]->getId(); |
|
| 662 | - } |
|
| 663 | - return false; |
|
| 664 | - } |
|
| 665 | - |
|
| 666 | - /** |
|
| 667 | - * Get a tag by its name. |
|
| 668 | - * |
|
| 669 | - * @param string $name The tag name. |
|
| 670 | - * @return integer|bool The tag object's offset within the $this->tags |
|
| 671 | - * array or false if it doesn't exist. |
|
| 672 | - */ |
|
| 673 | - private function getTagByName($name) { |
|
| 674 | - return $this->array_searchi($name, $this->tags, 'getName'); |
|
| 675 | - } |
|
| 676 | - |
|
| 677 | - /** |
|
| 678 | - * Get a tag by its ID. |
|
| 679 | - * |
|
| 680 | - * @param string $id The tag ID to look for. |
|
| 681 | - * @return integer|bool The tag object's offset within the $this->tags |
|
| 682 | - * array or false if it doesn't exist. |
|
| 683 | - */ |
|
| 684 | - private function getTagById($id) { |
|
| 685 | - return $this->array_searchi($id, $this->tags, 'getId'); |
|
| 686 | - } |
|
| 687 | - |
|
| 688 | - /** |
|
| 689 | - * Returns an array mapping a given tag's properties to its values: |
|
| 690 | - * ['id' => 0, 'name' = 'Tag', 'owner' = 'User', 'type' => 'tagtype'] |
|
| 691 | - * |
|
| 692 | - * @param Tag $tag The tag that is going to be mapped |
|
| 693 | - * @return array |
|
| 694 | - */ |
|
| 695 | - private function tagMap(Tag $tag) { |
|
| 696 | - return [ |
|
| 697 | - 'id' => $tag->getId(), |
|
| 698 | - 'name' => $tag->getName(), |
|
| 699 | - 'owner' => $tag->getOwner(), |
|
| 700 | - 'type' => $tag->getType() |
|
| 701 | - ]; |
|
| 702 | - } |
|
| 25 | + /** |
|
| 26 | + * Used for storing objectid/categoryname pairs while rescanning. |
|
| 27 | + */ |
|
| 28 | + private static array $relations = []; |
|
| 29 | + private array $tags = []; |
|
| 30 | + |
|
| 31 | + /** |
|
| 32 | + * Are we including tags for shared items? |
|
| 33 | + */ |
|
| 34 | + private bool $includeShared = false; |
|
| 35 | + |
|
| 36 | + /** |
|
| 37 | + * The current user, plus any owners of the items shared with the current |
|
| 38 | + * user, if $this->includeShared === true. |
|
| 39 | + */ |
|
| 40 | + private array $owners = []; |
|
| 41 | + |
|
| 42 | + /** |
|
| 43 | + * The sharing backend for objects of $this->type. Required if |
|
| 44 | + * $this->includeShared === true to determine ownership of items. |
|
| 45 | + */ |
|
| 46 | + private ?Share_Backend $backend = null; |
|
| 47 | + |
|
| 48 | + public const TAG_TABLE = 'vcategory'; |
|
| 49 | + public const RELATION_TABLE = 'vcategory_to_object'; |
|
| 50 | + |
|
| 51 | + /** |
|
| 52 | + * Constructor. |
|
| 53 | + * |
|
| 54 | + * @param TagMapper $mapper Instance of the TagMapper abstraction layer. |
|
| 55 | + * @param string $user The user whose data the object will operate on. |
|
| 56 | + * @param string $type The type of items for which tags will be loaded. |
|
| 57 | + * @param array $defaultTags Tags that should be created at construction. |
|
| 58 | + * |
|
| 59 | + * since 20.0.0 $includeShared isn't used anymore |
|
| 60 | + */ |
|
| 61 | + public function __construct( |
|
| 62 | + private TagMapper $mapper, |
|
| 63 | + private string $user, |
|
| 64 | + private string $type, |
|
| 65 | + private LoggerInterface $logger, |
|
| 66 | + private IDBConnection $db, |
|
| 67 | + private IEventDispatcher $dispatcher, |
|
| 68 | + private IUserSession $userSession, |
|
| 69 | + private Folder $userFolder, |
|
| 70 | + array $defaultTags = [], |
|
| 71 | + ) { |
|
| 72 | + $this->owners = [$this->user]; |
|
| 73 | + $this->tags = $this->mapper->loadTags($this->owners, $this->type); |
|
| 74 | + |
|
| 75 | + if (count($defaultTags) > 0 && count($this->tags) === 0) { |
|
| 76 | + $this->addMultiple($defaultTags, true); |
|
| 77 | + } |
|
| 78 | + } |
|
| 79 | + |
|
| 80 | + /** |
|
| 81 | + * Check if any tags are saved for this type and user. |
|
| 82 | + * |
|
| 83 | + * @return boolean |
|
| 84 | + */ |
|
| 85 | + public function isEmpty(): bool { |
|
| 86 | + return count($this->tags) === 0; |
|
| 87 | + } |
|
| 88 | + |
|
| 89 | + /** |
|
| 90 | + * Returns an array mapping a given tag's properties to its values: |
|
| 91 | + * ['id' => 0, 'name' = 'Tag', 'owner' = 'User', 'type' => 'tagtype'] |
|
| 92 | + * |
|
| 93 | + * @param string $id The ID of the tag that is going to be mapped |
|
| 94 | + * @return array|false |
|
| 95 | + */ |
|
| 96 | + public function getTag(string $id) { |
|
| 97 | + $key = $this->getTagById($id); |
|
| 98 | + if ($key !== false) { |
|
| 99 | + return $this->tagMap($this->tags[$key]); |
|
| 100 | + } |
|
| 101 | + return false; |
|
| 102 | + } |
|
| 103 | + |
|
| 104 | + /** |
|
| 105 | + * Get the tags for a specific user. |
|
| 106 | + * |
|
| 107 | + * This returns an array with maps containing each tag's properties: |
|
| 108 | + * [ |
|
| 109 | + * ['id' => 0, 'name' = 'First tag', 'owner' = 'User', 'type' => 'tagtype'], |
|
| 110 | + * ['id' => 1, 'name' = 'Shared tag', 'owner' = 'Other user', 'type' => 'tagtype'], |
|
| 111 | + * ] |
|
| 112 | + * |
|
| 113 | + * @return array<array-key, array{id: int, name: string}> |
|
| 114 | + */ |
|
| 115 | + public function getTags(): array { |
|
| 116 | + if (!count($this->tags)) { |
|
| 117 | + return []; |
|
| 118 | + } |
|
| 119 | + |
|
| 120 | + usort($this->tags, function ($a, $b) { |
|
| 121 | + return strnatcasecmp($a->getName(), $b->getName()); |
|
| 122 | + }); |
|
| 123 | + $tagMap = []; |
|
| 124 | + |
|
| 125 | + foreach ($this->tags as $tag) { |
|
| 126 | + if ($tag->getName() !== ITags::TAG_FAVORITE) { |
|
| 127 | + $tagMap[] = $this->tagMap($tag); |
|
| 128 | + } |
|
| 129 | + } |
|
| 130 | + return $tagMap; |
|
| 131 | + } |
|
| 132 | + |
|
| 133 | + /** |
|
| 134 | + * Return only the tags owned by the given user, omitting any tags shared |
|
| 135 | + * by other users. |
|
| 136 | + * |
|
| 137 | + * @param string $user The user whose tags are to be checked. |
|
| 138 | + * @return array An array of Tag objects. |
|
| 139 | + */ |
|
| 140 | + public function getTagsForUser(string $user): array { |
|
| 141 | + return array_filter($this->tags, |
|
| 142 | + function ($tag) use ($user) { |
|
| 143 | + return $tag->getOwner() === $user; |
|
| 144 | + } |
|
| 145 | + ); |
|
| 146 | + } |
|
| 147 | + |
|
| 148 | + /** |
|
| 149 | + * Get the list of tags for the given ids. |
|
| 150 | + * |
|
| 151 | + * @param list<int> $objIds array of object ids |
|
| 152 | + * @return array<int, list<string>>|false of tags id as key to array of tag names |
|
| 153 | + * or false if an error occurred |
|
| 154 | + */ |
|
| 155 | + public function getTagsForObjects(array $objIds) { |
|
| 156 | + $entries = []; |
|
| 157 | + |
|
| 158 | + try { |
|
| 159 | + $chunks = array_chunk($objIds, 900, false); |
|
| 160 | + $qb = $this->db->getQueryBuilder(); |
|
| 161 | + $qb->select('category', 'categoryid', 'objid') |
|
| 162 | + ->from(self::RELATION_TABLE, 'r') |
|
| 163 | + ->join('r', self::TAG_TABLE, 't', $qb->expr()->eq('r.categoryid', 't.id')) |
|
| 164 | + ->where($qb->expr()->eq('uid', $qb->createParameter('uid'))) |
|
| 165 | + ->andWhere($qb->expr()->eq('r.type', $qb->createParameter('type'))) |
|
| 166 | + ->andWhere($qb->expr()->in('objid', $qb->createParameter('chunk'))); |
|
| 167 | + foreach ($chunks as $chunk) { |
|
| 168 | + $qb->setParameter('uid', $this->user, IQueryBuilder::PARAM_STR); |
|
| 169 | + $qb->setParameter('type', $this->type, IQueryBuilder::PARAM_STR); |
|
| 170 | + $qb->setParameter('chunk', $chunk, IQueryBuilder::PARAM_INT_ARRAY); |
|
| 171 | + $result = $qb->executeQuery(); |
|
| 172 | + while ($row = $result->fetch()) { |
|
| 173 | + $objId = (int)$row['objid']; |
|
| 174 | + if (!isset($entries[$objId])) { |
|
| 175 | + $entries[$objId] = []; |
|
| 176 | + } |
|
| 177 | + $entries[$objId][] = $row['category']; |
|
| 178 | + } |
|
| 179 | + $result->closeCursor(); |
|
| 180 | + } |
|
| 181 | + } catch (\Exception $e) { |
|
| 182 | + $this->logger->error($e->getMessage(), [ |
|
| 183 | + 'exception' => $e, |
|
| 184 | + 'app' => 'core', |
|
| 185 | + ]); |
|
| 186 | + return false; |
|
| 187 | + } |
|
| 188 | + |
|
| 189 | + return $entries; |
|
| 190 | + } |
|
| 191 | + |
|
| 192 | + /** |
|
| 193 | + * Get the a list if items tagged with $tag. |
|
| 194 | + * |
|
| 195 | + * Throws an exception if the tag could not be found. |
|
| 196 | + * |
|
| 197 | + * @param string $tag Tag id or name. |
|
| 198 | + * @return int[]|false An array of object ids or false on error. |
|
| 199 | + * @throws \Exception |
|
| 200 | + */ |
|
| 201 | + public function getIdsForTag($tag) { |
|
| 202 | + $tagId = false; |
|
| 203 | + if (is_numeric($tag)) { |
|
| 204 | + $tagId = $tag; |
|
| 205 | + } elseif (is_string($tag)) { |
|
| 206 | + $tag = trim($tag); |
|
| 207 | + if ($tag === '') { |
|
| 208 | + $this->logger->debug(__METHOD__ . ' Cannot use empty tag names', ['app' => 'core']); |
|
| 209 | + return false; |
|
| 210 | + } |
|
| 211 | + $tagId = $this->getTagId($tag); |
|
| 212 | + } |
|
| 213 | + |
|
| 214 | + if ($tagId === false) { |
|
| 215 | + $l10n = \OCP\Util::getL10N('core'); |
|
| 216 | + throw new \Exception( |
|
| 217 | + $l10n->t('Could not find category "%s"', [$tag]) |
|
| 218 | + ); |
|
| 219 | + } |
|
| 220 | + |
|
| 221 | + $ids = []; |
|
| 222 | + try { |
|
| 223 | + $qb = $this->db->getQueryBuilder(); |
|
| 224 | + $qb->select('objid') |
|
| 225 | + ->from(self::RELATION_TABLE) |
|
| 226 | + ->where($qb->expr()->eq('categoryid', $qb->createNamedParameter($tagId, IQueryBuilder::PARAM_STR))); |
|
| 227 | + $result = $qb->executeQuery(); |
|
| 228 | + } catch (Exception $e) { |
|
| 229 | + $this->logger->error($e->getMessage(), [ |
|
| 230 | + 'app' => 'core', |
|
| 231 | + 'exception' => $e, |
|
| 232 | + ]); |
|
| 233 | + return false; |
|
| 234 | + } |
|
| 235 | + |
|
| 236 | + while ($row = $result->fetch()) { |
|
| 237 | + $ids[] = (int)$row['objid']; |
|
| 238 | + } |
|
| 239 | + $result->closeCursor(); |
|
| 240 | + |
|
| 241 | + return $ids; |
|
| 242 | + } |
|
| 243 | + |
|
| 244 | + /** |
|
| 245 | + * Checks whether a tag is saved for the given user, |
|
| 246 | + * disregarding the ones shared with them. |
|
| 247 | + * |
|
| 248 | + * @param string $name The tag name to check for. |
|
| 249 | + * @param string $user The user whose tags are to be checked. |
|
| 250 | + */ |
|
| 251 | + public function userHasTag(string $name, string $user): bool { |
|
| 252 | + return $this->array_searchi($name, $this->getTagsForUser($user)) !== false; |
|
| 253 | + } |
|
| 254 | + |
|
| 255 | + /** |
|
| 256 | + * Checks whether a tag is saved for or shared with the current user. |
|
| 257 | + * |
|
| 258 | + * @param string $name The tag name to check for. |
|
| 259 | + */ |
|
| 260 | + public function hasTag(string $name): bool { |
|
| 261 | + return $this->getTagId($name) !== false; |
|
| 262 | + } |
|
| 263 | + |
|
| 264 | + /** |
|
| 265 | + * Add a new tag. |
|
| 266 | + * |
|
| 267 | + * @param string $name A string with a name of the tag |
|
| 268 | + * @return false|int the id of the added tag or false on error. |
|
| 269 | + */ |
|
| 270 | + public function add(string $name) { |
|
| 271 | + $name = trim($name); |
|
| 272 | + |
|
| 273 | + if ($name === '') { |
|
| 274 | + $this->logger->debug(__METHOD__ . ' Cannot add an empty tag', ['app' => 'core']); |
|
| 275 | + return false; |
|
| 276 | + } |
|
| 277 | + if ($this->userHasTag($name, $this->user)) { |
|
| 278 | + $this->logger->debug(__METHOD__ . ' Tag with name already exists', ['app' => 'core']); |
|
| 279 | + return false; |
|
| 280 | + } |
|
| 281 | + try { |
|
| 282 | + $tag = new Tag($this->user, $this->type, $name); |
|
| 283 | + $tag = $this->mapper->insert($tag); |
|
| 284 | + $this->tags[] = $tag; |
|
| 285 | + } catch (\Exception $e) { |
|
| 286 | + $this->logger->error($e->getMessage(), [ |
|
| 287 | + 'exception' => $e, |
|
| 288 | + 'app' => 'core', |
|
| 289 | + ]); |
|
| 290 | + return false; |
|
| 291 | + } |
|
| 292 | + $this->logger->debug(__METHOD__ . ' Added an tag with ' . $tag->getId(), ['app' => 'core']); |
|
| 293 | + return $tag->getId(); |
|
| 294 | + } |
|
| 295 | + |
|
| 296 | + /** |
|
| 297 | + * Rename tag. |
|
| 298 | + * |
|
| 299 | + * @param string|integer $from The name or ID of the existing tag |
|
| 300 | + * @param string $to The new name of the tag. |
|
| 301 | + * @return bool |
|
| 302 | + */ |
|
| 303 | + public function rename($from, string $to): bool { |
|
| 304 | + $from = trim($from); |
|
| 305 | + $to = trim($to); |
|
| 306 | + |
|
| 307 | + if ($to === '' || $from === '') { |
|
| 308 | + $this->logger->debug(__METHOD__ . 'Cannot use an empty tag names', ['app' => 'core']); |
|
| 309 | + return false; |
|
| 310 | + } |
|
| 311 | + |
|
| 312 | + if (is_numeric($from)) { |
|
| 313 | + $key = $this->getTagById($from); |
|
| 314 | + } else { |
|
| 315 | + $key = $this->getTagByName($from); |
|
| 316 | + } |
|
| 317 | + if ($key === false) { |
|
| 318 | + $this->logger->debug(__METHOD__ . 'Tag ' . $from . 'does not exist', ['app' => 'core']); |
|
| 319 | + return false; |
|
| 320 | + } |
|
| 321 | + $tag = $this->tags[$key]; |
|
| 322 | + |
|
| 323 | + if ($this->userHasTag($to, $tag->getOwner())) { |
|
| 324 | + $this->logger->debug(__METHOD__ . 'A tag named' . $to . 'already exists for user' . $tag->getOwner(), ['app' => 'core']); |
|
| 325 | + return false; |
|
| 326 | + } |
|
| 327 | + |
|
| 328 | + try { |
|
| 329 | + $tag->setName($to); |
|
| 330 | + $this->tags[$key] = $this->mapper->update($tag); |
|
| 331 | + } catch (\Exception $e) { |
|
| 332 | + $this->logger->error($e->getMessage(), [ |
|
| 333 | + 'exception' => $e, |
|
| 334 | + 'app' => 'core', |
|
| 335 | + ]); |
|
| 336 | + return false; |
|
| 337 | + } |
|
| 338 | + return true; |
|
| 339 | + } |
|
| 340 | + |
|
| 341 | + /** |
|
| 342 | + * Add a list of new tags. |
|
| 343 | + * |
|
| 344 | + * @param string|string[] $names A string with a name or an array of strings containing |
|
| 345 | + * the name(s) of the tag(s) to add. |
|
| 346 | + * @param bool $sync When true, save the tags |
|
| 347 | + * @param int|null $id int Optional object id to add to this|these tag(s) |
|
| 348 | + * @return bool Returns false on error. |
|
| 349 | + */ |
|
| 350 | + public function addMultiple($names, bool $sync = false, ?int $id = null): bool { |
|
| 351 | + if (!is_array($names)) { |
|
| 352 | + $names = [$names]; |
|
| 353 | + } |
|
| 354 | + $names = array_map('trim', $names); |
|
| 355 | + array_filter($names); |
|
| 356 | + |
|
| 357 | + $newones = []; |
|
| 358 | + foreach ($names as $name) { |
|
| 359 | + if (!$this->hasTag($name) && $name !== '') { |
|
| 360 | + $newones[] = new Tag($this->user, $this->type, $name); |
|
| 361 | + } |
|
| 362 | + if (!is_null($id)) { |
|
| 363 | + // Insert $objectid, $categoryid pairs if not exist. |
|
| 364 | + self::$relations[] = ['objid' => $id, 'tag' => $name]; |
|
| 365 | + } |
|
| 366 | + } |
|
| 367 | + $this->tags = array_merge($this->tags, $newones); |
|
| 368 | + if ($sync === true) { |
|
| 369 | + $this->save(); |
|
| 370 | + } |
|
| 371 | + |
|
| 372 | + return true; |
|
| 373 | + } |
|
| 374 | + |
|
| 375 | + /** |
|
| 376 | + * Save the list of tags and their object relations |
|
| 377 | + */ |
|
| 378 | + protected function save(): void { |
|
| 379 | + foreach ($this->tags as $tag) { |
|
| 380 | + try { |
|
| 381 | + if (!$this->mapper->tagExists($tag)) { |
|
| 382 | + $this->mapper->insert($tag); |
|
| 383 | + } |
|
| 384 | + } catch (\Exception $e) { |
|
| 385 | + $this->logger->error($e->getMessage(), [ |
|
| 386 | + 'exception' => $e, |
|
| 387 | + 'app' => 'core', |
|
| 388 | + ]); |
|
| 389 | + } |
|
| 390 | + } |
|
| 391 | + |
|
| 392 | + // reload tags to get the proper ids. |
|
| 393 | + $this->tags = $this->mapper->loadTags($this->owners, $this->type); |
|
| 394 | + $this->logger->debug(__METHOD__ . 'tags' . print_r($this->tags, true), ['app' => 'core']); |
|
| 395 | + // Loop through temporarily cached objectid/tagname pairs |
|
| 396 | + // and save relations. |
|
| 397 | + $tags = $this->tags; |
|
| 398 | + // For some reason this is needed or array_search(i) will return 0..? |
|
| 399 | + ksort($tags); |
|
| 400 | + foreach (self::$relations as $relation) { |
|
| 401 | + $tagId = $this->getTagId($relation['tag']); |
|
| 402 | + $this->logger->debug(__METHOD__ . 'catid ' . $relation['tag'] . ' ' . $tagId, ['app' => 'core']); |
|
| 403 | + if ($tagId) { |
|
| 404 | + $qb = $this->db->getQueryBuilder(); |
|
| 405 | + $qb->insert(self::RELATION_TABLE) |
|
| 406 | + ->values([ |
|
| 407 | + 'objid' => $qb->createNamedParameter($relation['objid'], IQueryBuilder::PARAM_INT), |
|
| 408 | + 'categoryid' => $qb->createNamedParameter($tagId, IQueryBuilder::PARAM_INT), |
|
| 409 | + 'type' => $qb->createNamedParameter($this->type), |
|
| 410 | + ]); |
|
| 411 | + try { |
|
| 412 | + $qb->executeStatement(); |
|
| 413 | + } catch (Exception $e) { |
|
| 414 | + $this->logger->error($e->getMessage(), [ |
|
| 415 | + 'exception' => $e, |
|
| 416 | + 'app' => 'core', |
|
| 417 | + ]); |
|
| 418 | + } |
|
| 419 | + } |
|
| 420 | + } |
|
| 421 | + self::$relations = []; // reset |
|
| 422 | + } |
|
| 423 | + |
|
| 424 | + /** |
|
| 425 | + * Delete tag/object relations from the db |
|
| 426 | + * |
|
| 427 | + * @param array $ids The ids of the objects |
|
| 428 | + * @return boolean Returns false on error. |
|
| 429 | + */ |
|
| 430 | + public function purgeObjects(array $ids): bool { |
|
| 431 | + if (count($ids) === 0) { |
|
| 432 | + // job done ;) |
|
| 433 | + return true; |
|
| 434 | + } |
|
| 435 | + $updates = $ids; |
|
| 436 | + $qb = $this->db->getQueryBuilder(); |
|
| 437 | + $qb->delete(self::RELATION_TABLE) |
|
| 438 | + ->where($qb->expr()->in('objid', $qb->createNamedParameter($ids))); |
|
| 439 | + try { |
|
| 440 | + $qb->executeStatement(); |
|
| 441 | + } catch (Exception $e) { |
|
| 442 | + $this->logger->error($e->getMessage(), [ |
|
| 443 | + 'app' => 'core', |
|
| 444 | + 'exception' => $e, |
|
| 445 | + ]); |
|
| 446 | + return false; |
|
| 447 | + } |
|
| 448 | + return true; |
|
| 449 | + } |
|
| 450 | + |
|
| 451 | + /** |
|
| 452 | + * Get favorites for an object type |
|
| 453 | + * |
|
| 454 | + * @return array|false An array of object ids. |
|
| 455 | + */ |
|
| 456 | + public function getFavorites() { |
|
| 457 | + if (!$this->userHasTag(ITags::TAG_FAVORITE, $this->user)) { |
|
| 458 | + return []; |
|
| 459 | + } |
|
| 460 | + |
|
| 461 | + try { |
|
| 462 | + return $this->getIdsForTag(ITags::TAG_FAVORITE); |
|
| 463 | + } catch (\Exception $e) { |
|
| 464 | + \OCP\Server::get(LoggerInterface::class)->error( |
|
| 465 | + $e->getMessage(), |
|
| 466 | + [ |
|
| 467 | + 'app' => 'core', |
|
| 468 | + 'exception' => $e, |
|
| 469 | + ] |
|
| 470 | + ); |
|
| 471 | + return []; |
|
| 472 | + } |
|
| 473 | + } |
|
| 474 | + |
|
| 475 | + /** |
|
| 476 | + * Add an object to favorites |
|
| 477 | + * |
|
| 478 | + * @param int $objid The id of the object |
|
| 479 | + * @return boolean |
|
| 480 | + */ |
|
| 481 | + public function addToFavorites($objid) { |
|
| 482 | + if (!$this->userHasTag(ITags::TAG_FAVORITE, $this->user)) { |
|
| 483 | + $this->add(ITags::TAG_FAVORITE); |
|
| 484 | + } |
|
| 485 | + return $this->tagAs($objid, ITags::TAG_FAVORITE); |
|
| 486 | + } |
|
| 487 | + |
|
| 488 | + /** |
|
| 489 | + * Remove an object from favorites |
|
| 490 | + * |
|
| 491 | + * @param int $objid The id of the object |
|
| 492 | + * @return boolean |
|
| 493 | + */ |
|
| 494 | + public function removeFromFavorites($objid) { |
|
| 495 | + return $this->unTag($objid, ITags::TAG_FAVORITE); |
|
| 496 | + } |
|
| 497 | + |
|
| 498 | + /** |
|
| 499 | + * Creates a tag/object relation. |
|
| 500 | + */ |
|
| 501 | + public function tagAs($objid, $tag, ?string $path = null) { |
|
| 502 | + if (is_string($tag) && !is_numeric($tag)) { |
|
| 503 | + $tag = trim($tag); |
|
| 504 | + if ($tag === '') { |
|
| 505 | + $this->logger->debug(__METHOD__ . ', Cannot add an empty tag'); |
|
| 506 | + return false; |
|
| 507 | + } |
|
| 508 | + if (!$this->hasTag($tag)) { |
|
| 509 | + $this->add($tag); |
|
| 510 | + } |
|
| 511 | + $tagId = $this->getTagId($tag); |
|
| 512 | + } else { |
|
| 513 | + $tagId = $tag; |
|
| 514 | + } |
|
| 515 | + $qb = $this->db->getQueryBuilder(); |
|
| 516 | + $qb->insert(self::RELATION_TABLE) |
|
| 517 | + ->values([ |
|
| 518 | + 'objid' => $qb->createNamedParameter($objid, IQueryBuilder::PARAM_INT), |
|
| 519 | + 'categoryid' => $qb->createNamedParameter($tagId, IQueryBuilder::PARAM_INT), |
|
| 520 | + 'type' => $qb->createNamedParameter($this->type, IQueryBuilder::PARAM_STR), |
|
| 521 | + ]); |
|
| 522 | + try { |
|
| 523 | + $qb->executeStatement(); |
|
| 524 | + } catch (\Exception $e) { |
|
| 525 | + \OCP\Server::get(LoggerInterface::class)->error($e->getMessage(), [ |
|
| 526 | + 'app' => 'core', |
|
| 527 | + 'exception' => $e, |
|
| 528 | + ]); |
|
| 529 | + return false; |
|
| 530 | + } |
|
| 531 | + if ($tag === ITags::TAG_FAVORITE) { |
|
| 532 | + if ($path === null) { |
|
| 533 | + $node = $this->userFolder->getFirstNodeById($objid); |
|
| 534 | + if ($node !== null) { |
|
| 535 | + $path = $node->getPath(); |
|
| 536 | + } else { |
|
| 537 | + throw new Exception('Failed to favorite: node with id ' . $objid . ' not found'); |
|
| 538 | + } |
|
| 539 | + } |
|
| 540 | + |
|
| 541 | + $this->dispatcher->dispatchTyped(new NodeAddedToFavorite($this->userSession->getUser(), $objid, $path)); |
|
| 542 | + } |
|
| 543 | + return true; |
|
| 544 | + } |
|
| 545 | + |
|
| 546 | + /** |
|
| 547 | + * Delete single tag/object relation from the db |
|
| 548 | + */ |
|
| 549 | + public function unTag($objid, $tag, ?string $path = null) { |
|
| 550 | + if (is_string($tag) && !is_numeric($tag)) { |
|
| 551 | + $tag = trim($tag); |
|
| 552 | + if ($tag === '') { |
|
| 553 | + $this->logger->debug(__METHOD__ . ', Tag name is empty'); |
|
| 554 | + return false; |
|
| 555 | + } |
|
| 556 | + $tagId = $this->getTagId($tag); |
|
| 557 | + } else { |
|
| 558 | + $tagId = $tag; |
|
| 559 | + } |
|
| 560 | + |
|
| 561 | + try { |
|
| 562 | + $qb = $this->db->getQueryBuilder(); |
|
| 563 | + $qb->delete(self::RELATION_TABLE) |
|
| 564 | + ->where($qb->expr()->andX( |
|
| 565 | + $qb->expr()->eq('objid', $qb->createNamedParameter($objid)), |
|
| 566 | + $qb->expr()->eq('categoryid', $qb->createNamedParameter($tagId)), |
|
| 567 | + $qb->expr()->eq('type', $qb->createNamedParameter($this->type)), |
|
| 568 | + ))->executeStatement(); |
|
| 569 | + } catch (\Exception $e) { |
|
| 570 | + $this->logger->error($e->getMessage(), [ |
|
| 571 | + 'app' => 'core', |
|
| 572 | + 'exception' => $e, |
|
| 573 | + ]); |
|
| 574 | + return false; |
|
| 575 | + } |
|
| 576 | + if ($tag === ITags::TAG_FAVORITE) { |
|
| 577 | + if ($path === null) { |
|
| 578 | + $node = $this->userFolder->getFirstNodeById($objid); |
|
| 579 | + if ($node !== null) { |
|
| 580 | + $path = $node->getPath(); |
|
| 581 | + } else { |
|
| 582 | + throw new Exception('Failed to unfavorite: node with id ' . $objid . ' not found'); |
|
| 583 | + } |
|
| 584 | + } |
|
| 585 | + |
|
| 586 | + $this->dispatcher->dispatchTyped(new NodeRemovedFromFavorite($this->userSession->getUser(), $objid, $path)); |
|
| 587 | + } |
|
| 588 | + return true; |
|
| 589 | + } |
|
| 590 | + |
|
| 591 | + /** |
|
| 592 | + * Delete tags from the database. |
|
| 593 | + * |
|
| 594 | + * @param string[]|integer[] $names An array of tags (names or IDs) to delete |
|
| 595 | + * @return bool Returns false on error |
|
| 596 | + */ |
|
| 597 | + public function delete($names) { |
|
| 598 | + if (!is_array($names)) { |
|
| 599 | + $names = [$names]; |
|
| 600 | + } |
|
| 601 | + |
|
| 602 | + $names = array_map('trim', $names); |
|
| 603 | + array_filter($names); |
|
| 604 | + |
|
| 605 | + $this->logger->debug(__METHOD__ . ', before: ' . print_r($this->tags, true)); |
|
| 606 | + foreach ($names as $name) { |
|
| 607 | + $id = null; |
|
| 608 | + |
|
| 609 | + if (is_numeric($name)) { |
|
| 610 | + $key = $this->getTagById($name); |
|
| 611 | + } else { |
|
| 612 | + $key = $this->getTagByName($name); |
|
| 613 | + } |
|
| 614 | + if ($key !== false) { |
|
| 615 | + $tag = $this->tags[$key]; |
|
| 616 | + $id = $tag->getId(); |
|
| 617 | + unset($this->tags[$key]); |
|
| 618 | + $this->mapper->delete($tag); |
|
| 619 | + } else { |
|
| 620 | + $this->logger->error(__METHOD__ . 'Cannot delete tag ' . $name . ': not found.'); |
|
| 621 | + } |
|
| 622 | + if (!is_null($id) && $id !== false) { |
|
| 623 | + try { |
|
| 624 | + $qb = $this->db->getQueryBuilder(); |
|
| 625 | + $qb->delete(self::RELATION_TABLE) |
|
| 626 | + ->where($qb->expr()->eq('categoryid', $qb->createNamedParameter($id, IQueryBuilder::PARAM_INT))) |
|
| 627 | + ->executeStatement(); |
|
| 628 | + } catch (\Exception $e) { |
|
| 629 | + $this->logger->error($e->getMessage(), [ |
|
| 630 | + 'app' => 'core', |
|
| 631 | + 'exception' => $e, |
|
| 632 | + ]); |
|
| 633 | + return false; |
|
| 634 | + } |
|
| 635 | + } |
|
| 636 | + } |
|
| 637 | + return true; |
|
| 638 | + } |
|
| 639 | + |
|
| 640 | + // case-insensitive array_search |
|
| 641 | + protected function array_searchi($needle, $haystack, $mem = 'getName') { |
|
| 642 | + if (!is_array($haystack)) { |
|
| 643 | + return false; |
|
| 644 | + } |
|
| 645 | + return array_search(strtolower($needle), array_map( |
|
| 646 | + function ($tag) use ($mem) { |
|
| 647 | + return strtolower(call_user_func([$tag, $mem])); |
|
| 648 | + }, $haystack) |
|
| 649 | + ); |
|
| 650 | + } |
|
| 651 | + |
|
| 652 | + /** |
|
| 653 | + * Get a tag's ID. |
|
| 654 | + * |
|
| 655 | + * @param string $name The tag name to look for. |
|
| 656 | + * @return string|bool The tag's id or false if no matching tag is found. |
|
| 657 | + */ |
|
| 658 | + private function getTagId($name) { |
|
| 659 | + $key = $this->array_searchi($name, $this->tags); |
|
| 660 | + if ($key !== false) { |
|
| 661 | + return $this->tags[$key]->getId(); |
|
| 662 | + } |
|
| 663 | + return false; |
|
| 664 | + } |
|
| 665 | + |
|
| 666 | + /** |
|
| 667 | + * Get a tag by its name. |
|
| 668 | + * |
|
| 669 | + * @param string $name The tag name. |
|
| 670 | + * @return integer|bool The tag object's offset within the $this->tags |
|
| 671 | + * array or false if it doesn't exist. |
|
| 672 | + */ |
|
| 673 | + private function getTagByName($name) { |
|
| 674 | + return $this->array_searchi($name, $this->tags, 'getName'); |
|
| 675 | + } |
|
| 676 | + |
|
| 677 | + /** |
|
| 678 | + * Get a tag by its ID. |
|
| 679 | + * |
|
| 680 | + * @param string $id The tag ID to look for. |
|
| 681 | + * @return integer|bool The tag object's offset within the $this->tags |
|
| 682 | + * array or false if it doesn't exist. |
|
| 683 | + */ |
|
| 684 | + private function getTagById($id) { |
|
| 685 | + return $this->array_searchi($id, $this->tags, 'getId'); |
|
| 686 | + } |
|
| 687 | + |
|
| 688 | + /** |
|
| 689 | + * Returns an array mapping a given tag's properties to its values: |
|
| 690 | + * ['id' => 0, 'name' = 'Tag', 'owner' = 'User', 'type' => 'tagtype'] |
|
| 691 | + * |
|
| 692 | + * @param Tag $tag The tag that is going to be mapped |
|
| 693 | + * @return array |
|
| 694 | + */ |
|
| 695 | + private function tagMap(Tag $tag) { |
|
| 696 | + return [ |
|
| 697 | + 'id' => $tag->getId(), |
|
| 698 | + 'name' => $tag->getName(), |
|
| 699 | + 'owner' => $tag->getOwner(), |
|
| 700 | + 'type' => $tag->getType() |
|
| 701 | + ]; |
|
| 702 | + } |
|
| 703 | 703 | } |
@@ -117,7 +117,7 @@ discard block |
||
| 117 | 117 | return []; |
| 118 | 118 | } |
| 119 | 119 | |
| 120 | - usort($this->tags, function ($a, $b) { |
|
| 120 | + usort($this->tags, function($a, $b) { |
|
| 121 | 121 | return strnatcasecmp($a->getName(), $b->getName()); |
| 122 | 122 | }); |
| 123 | 123 | $tagMap = []; |
@@ -139,7 +139,7 @@ discard block |
||
| 139 | 139 | */ |
| 140 | 140 | public function getTagsForUser(string $user): array { |
| 141 | 141 | return array_filter($this->tags, |
| 142 | - function ($tag) use ($user) { |
|
| 142 | + function($tag) use ($user) { |
|
| 143 | 143 | return $tag->getOwner() === $user; |
| 144 | 144 | } |
| 145 | 145 | ); |
@@ -170,7 +170,7 @@ discard block |
||
| 170 | 170 | $qb->setParameter('chunk', $chunk, IQueryBuilder::PARAM_INT_ARRAY); |
| 171 | 171 | $result = $qb->executeQuery(); |
| 172 | 172 | while ($row = $result->fetch()) { |
| 173 | - $objId = (int)$row['objid']; |
|
| 173 | + $objId = (int) $row['objid']; |
|
| 174 | 174 | if (!isset($entries[$objId])) { |
| 175 | 175 | $entries[$objId] = []; |
| 176 | 176 | } |
@@ -205,7 +205,7 @@ discard block |
||
| 205 | 205 | } elseif (is_string($tag)) { |
| 206 | 206 | $tag = trim($tag); |
| 207 | 207 | if ($tag === '') { |
| 208 | - $this->logger->debug(__METHOD__ . ' Cannot use empty tag names', ['app' => 'core']); |
|
| 208 | + $this->logger->debug(__METHOD__.' Cannot use empty tag names', ['app' => 'core']); |
|
| 209 | 209 | return false; |
| 210 | 210 | } |
| 211 | 211 | $tagId = $this->getTagId($tag); |
@@ -234,7 +234,7 @@ discard block |
||
| 234 | 234 | } |
| 235 | 235 | |
| 236 | 236 | while ($row = $result->fetch()) { |
| 237 | - $ids[] = (int)$row['objid']; |
|
| 237 | + $ids[] = (int) $row['objid']; |
|
| 238 | 238 | } |
| 239 | 239 | $result->closeCursor(); |
| 240 | 240 | |
@@ -271,11 +271,11 @@ discard block |
||
| 271 | 271 | $name = trim($name); |
| 272 | 272 | |
| 273 | 273 | if ($name === '') { |
| 274 | - $this->logger->debug(__METHOD__ . ' Cannot add an empty tag', ['app' => 'core']); |
|
| 274 | + $this->logger->debug(__METHOD__.' Cannot add an empty tag', ['app' => 'core']); |
|
| 275 | 275 | return false; |
| 276 | 276 | } |
| 277 | 277 | if ($this->userHasTag($name, $this->user)) { |
| 278 | - $this->logger->debug(__METHOD__ . ' Tag with name already exists', ['app' => 'core']); |
|
| 278 | + $this->logger->debug(__METHOD__.' Tag with name already exists', ['app' => 'core']); |
|
| 279 | 279 | return false; |
| 280 | 280 | } |
| 281 | 281 | try { |
@@ -289,7 +289,7 @@ discard block |
||
| 289 | 289 | ]); |
| 290 | 290 | return false; |
| 291 | 291 | } |
| 292 | - $this->logger->debug(__METHOD__ . ' Added an tag with ' . $tag->getId(), ['app' => 'core']); |
|
| 292 | + $this->logger->debug(__METHOD__.' Added an tag with '.$tag->getId(), ['app' => 'core']); |
|
| 293 | 293 | return $tag->getId(); |
| 294 | 294 | } |
| 295 | 295 | |
@@ -305,7 +305,7 @@ discard block |
||
| 305 | 305 | $to = trim($to); |
| 306 | 306 | |
| 307 | 307 | if ($to === '' || $from === '') { |
| 308 | - $this->logger->debug(__METHOD__ . 'Cannot use an empty tag names', ['app' => 'core']); |
|
| 308 | + $this->logger->debug(__METHOD__.'Cannot use an empty tag names', ['app' => 'core']); |
|
| 309 | 309 | return false; |
| 310 | 310 | } |
| 311 | 311 | |
@@ -315,13 +315,13 @@ discard block |
||
| 315 | 315 | $key = $this->getTagByName($from); |
| 316 | 316 | } |
| 317 | 317 | if ($key === false) { |
| 318 | - $this->logger->debug(__METHOD__ . 'Tag ' . $from . 'does not exist', ['app' => 'core']); |
|
| 318 | + $this->logger->debug(__METHOD__.'Tag '.$from.'does not exist', ['app' => 'core']); |
|
| 319 | 319 | return false; |
| 320 | 320 | } |
| 321 | 321 | $tag = $this->tags[$key]; |
| 322 | 322 | |
| 323 | 323 | if ($this->userHasTag($to, $tag->getOwner())) { |
| 324 | - $this->logger->debug(__METHOD__ . 'A tag named' . $to . 'already exists for user' . $tag->getOwner(), ['app' => 'core']); |
|
| 324 | + $this->logger->debug(__METHOD__.'A tag named'.$to.'already exists for user'.$tag->getOwner(), ['app' => 'core']); |
|
| 325 | 325 | return false; |
| 326 | 326 | } |
| 327 | 327 | |
@@ -391,7 +391,7 @@ discard block |
||
| 391 | 391 | |
| 392 | 392 | // reload tags to get the proper ids. |
| 393 | 393 | $this->tags = $this->mapper->loadTags($this->owners, $this->type); |
| 394 | - $this->logger->debug(__METHOD__ . 'tags' . print_r($this->tags, true), ['app' => 'core']); |
|
| 394 | + $this->logger->debug(__METHOD__.'tags'.print_r($this->tags, true), ['app' => 'core']); |
|
| 395 | 395 | // Loop through temporarily cached objectid/tagname pairs |
| 396 | 396 | // and save relations. |
| 397 | 397 | $tags = $this->tags; |
@@ -399,7 +399,7 @@ discard block |
||
| 399 | 399 | ksort($tags); |
| 400 | 400 | foreach (self::$relations as $relation) { |
| 401 | 401 | $tagId = $this->getTagId($relation['tag']); |
| 402 | - $this->logger->debug(__METHOD__ . 'catid ' . $relation['tag'] . ' ' . $tagId, ['app' => 'core']); |
|
| 402 | + $this->logger->debug(__METHOD__.'catid '.$relation['tag'].' '.$tagId, ['app' => 'core']); |
|
| 403 | 403 | if ($tagId) { |
| 404 | 404 | $qb = $this->db->getQueryBuilder(); |
| 405 | 405 | $qb->insert(self::RELATION_TABLE) |
@@ -502,7 +502,7 @@ discard block |
||
| 502 | 502 | if (is_string($tag) && !is_numeric($tag)) { |
| 503 | 503 | $tag = trim($tag); |
| 504 | 504 | if ($tag === '') { |
| 505 | - $this->logger->debug(__METHOD__ . ', Cannot add an empty tag'); |
|
| 505 | + $this->logger->debug(__METHOD__.', Cannot add an empty tag'); |
|
| 506 | 506 | return false; |
| 507 | 507 | } |
| 508 | 508 | if (!$this->hasTag($tag)) { |
@@ -534,7 +534,7 @@ discard block |
||
| 534 | 534 | if ($node !== null) { |
| 535 | 535 | $path = $node->getPath(); |
| 536 | 536 | } else { |
| 537 | - throw new Exception('Failed to favorite: node with id ' . $objid . ' not found'); |
|
| 537 | + throw new Exception('Failed to favorite: node with id '.$objid.' not found'); |
|
| 538 | 538 | } |
| 539 | 539 | } |
| 540 | 540 | |
@@ -550,7 +550,7 @@ discard block |
||
| 550 | 550 | if (is_string($tag) && !is_numeric($tag)) { |
| 551 | 551 | $tag = trim($tag); |
| 552 | 552 | if ($tag === '') { |
| 553 | - $this->logger->debug(__METHOD__ . ', Tag name is empty'); |
|
| 553 | + $this->logger->debug(__METHOD__.', Tag name is empty'); |
|
| 554 | 554 | return false; |
| 555 | 555 | } |
| 556 | 556 | $tagId = $this->getTagId($tag); |
@@ -579,7 +579,7 @@ discard block |
||
| 579 | 579 | if ($node !== null) { |
| 580 | 580 | $path = $node->getPath(); |
| 581 | 581 | } else { |
| 582 | - throw new Exception('Failed to unfavorite: node with id ' . $objid . ' not found'); |
|
| 582 | + throw new Exception('Failed to unfavorite: node with id '.$objid.' not found'); |
|
| 583 | 583 | } |
| 584 | 584 | } |
| 585 | 585 | |
@@ -602,7 +602,7 @@ discard block |
||
| 602 | 602 | $names = array_map('trim', $names); |
| 603 | 603 | array_filter($names); |
| 604 | 604 | |
| 605 | - $this->logger->debug(__METHOD__ . ', before: ' . print_r($this->tags, true)); |
|
| 605 | + $this->logger->debug(__METHOD__.', before: '.print_r($this->tags, true)); |
|
| 606 | 606 | foreach ($names as $name) { |
| 607 | 607 | $id = null; |
| 608 | 608 | |
@@ -617,7 +617,7 @@ discard block |
||
| 617 | 617 | unset($this->tags[$key]); |
| 618 | 618 | $this->mapper->delete($tag); |
| 619 | 619 | } else { |
| 620 | - $this->logger->error(__METHOD__ . 'Cannot delete tag ' . $name . ': not found.'); |
|
| 620 | + $this->logger->error(__METHOD__.'Cannot delete tag '.$name.': not found.'); |
|
| 621 | 621 | } |
| 622 | 622 | if (!is_null($id) && $id !== false) { |
| 623 | 623 | try { |
@@ -643,7 +643,7 @@ discard block |
||
| 643 | 643 | return false; |
| 644 | 644 | } |
| 645 | 645 | return array_search(strtolower($needle), array_map( |
| 646 | - function ($tag) use ($mem) { |
|
| 646 | + function($tag) use ($mem) { |
|
| 647 | 647 | return strtolower(call_user_func([$tag, $mem])); |
| 648 | 648 | }, $haystack) |
| 649 | 649 | ); |
@@ -18,51 +18,51 @@ |
||
| 18 | 18 | */ |
| 19 | 19 | class TagService { |
| 20 | 20 | |
| 21 | - public function __construct( |
|
| 22 | - private IUserSession $userSession, |
|
| 23 | - private IManager $activityManager, |
|
| 24 | - private ?ITags $tagger, |
|
| 25 | - private ?Folder $homeFolder, |
|
| 26 | - ) { |
|
| 27 | - } |
|
| 21 | + public function __construct( |
|
| 22 | + private IUserSession $userSession, |
|
| 23 | + private IManager $activityManager, |
|
| 24 | + private ?ITags $tagger, |
|
| 25 | + private ?Folder $homeFolder, |
|
| 26 | + ) { |
|
| 27 | + } |
|
| 28 | 28 | |
| 29 | - /** |
|
| 30 | - * Updates the tags of the specified file path. |
|
| 31 | - * The passed tags are absolute, which means they will |
|
| 32 | - * replace the actual tag selection. |
|
| 33 | - * |
|
| 34 | - * @param string $path path |
|
| 35 | - * @param array $tags array of tags |
|
| 36 | - * @return array list of tags |
|
| 37 | - * @throws NotFoundException if the file does not exist |
|
| 38 | - */ |
|
| 39 | - public function updateFileTags($path, $tags) { |
|
| 40 | - if ($this->tagger === null) { |
|
| 41 | - throw new \RuntimeException('No tagger set'); |
|
| 42 | - } |
|
| 43 | - if ($this->homeFolder === null) { |
|
| 44 | - throw new \RuntimeException('No homeFolder set'); |
|
| 45 | - } |
|
| 29 | + /** |
|
| 30 | + * Updates the tags of the specified file path. |
|
| 31 | + * The passed tags are absolute, which means they will |
|
| 32 | + * replace the actual tag selection. |
|
| 33 | + * |
|
| 34 | + * @param string $path path |
|
| 35 | + * @param array $tags array of tags |
|
| 36 | + * @return array list of tags |
|
| 37 | + * @throws NotFoundException if the file does not exist |
|
| 38 | + */ |
|
| 39 | + public function updateFileTags($path, $tags) { |
|
| 40 | + if ($this->tagger === null) { |
|
| 41 | + throw new \RuntimeException('No tagger set'); |
|
| 42 | + } |
|
| 43 | + if ($this->homeFolder === null) { |
|
| 44 | + throw new \RuntimeException('No homeFolder set'); |
|
| 45 | + } |
|
| 46 | 46 | |
| 47 | - $fileId = $this->homeFolder->get($path)->getId(); |
|
| 47 | + $fileId = $this->homeFolder->get($path)->getId(); |
|
| 48 | 48 | |
| 49 | - $currentTags = $this->tagger->getTagsForObjects([$fileId]); |
|
| 49 | + $currentTags = $this->tagger->getTagsForObjects([$fileId]); |
|
| 50 | 50 | |
| 51 | - if (!empty($currentTags)) { |
|
| 52 | - $currentTags = current($currentTags); |
|
| 53 | - } |
|
| 51 | + if (!empty($currentTags)) { |
|
| 52 | + $currentTags = current($currentTags); |
|
| 53 | + } |
|
| 54 | 54 | |
| 55 | - $newTags = array_diff($tags, $currentTags); |
|
| 56 | - foreach ($newTags as $tag) { |
|
| 57 | - $this->tagger->tagAs($fileId, $tag, $path); |
|
| 58 | - } |
|
| 59 | - $deletedTags = array_diff($currentTags, $tags); |
|
| 60 | - foreach ($deletedTags as $tag) { |
|
| 61 | - $this->tagger->unTag($fileId, $tag, $path); |
|
| 62 | - } |
|
| 55 | + $newTags = array_diff($tags, $currentTags); |
|
| 56 | + foreach ($newTags as $tag) { |
|
| 57 | + $this->tagger->tagAs($fileId, $tag, $path); |
|
| 58 | + } |
|
| 59 | + $deletedTags = array_diff($currentTags, $tags); |
|
| 60 | + foreach ($deletedTags as $tag) { |
|
| 61 | + $this->tagger->unTag($fileId, $tag, $path); |
|
| 62 | + } |
|
| 63 | 63 | |
| 64 | - // TODO: re-read from tagger to make sure the |
|
| 65 | - // list is up to date, in case of concurrent changes ? |
|
| 66 | - return $tags; |
|
| 67 | - } |
|
| 64 | + // TODO: re-read from tagger to make sure the |
|
| 65 | + // list is up to date, in case of concurrent changes ? |
|
| 66 | + return $tags; |
|
| 67 | + } |
|
| 68 | 68 | } |
@@ -37,267 +37,267 @@ |
||
| 37 | 37 | |
| 38 | 38 | class TagsPlugin extends \Sabre\DAV\ServerPlugin { |
| 39 | 39 | |
| 40 | - // namespace |
|
| 41 | - public const NS_OWNCLOUD = 'http://owncloud.org/ns'; |
|
| 42 | - public const TAGS_PROPERTYNAME = '{http://owncloud.org/ns}tags'; |
|
| 43 | - public const FAVORITE_PROPERTYNAME = '{http://owncloud.org/ns}favorite'; |
|
| 44 | - public const TAG_FAVORITE = '_$!<Favorite>!$_'; |
|
| 40 | + // namespace |
|
| 41 | + public const NS_OWNCLOUD = 'http://owncloud.org/ns'; |
|
| 42 | + public const TAGS_PROPERTYNAME = '{http://owncloud.org/ns}tags'; |
|
| 43 | + public const FAVORITE_PROPERTYNAME = '{http://owncloud.org/ns}favorite'; |
|
| 44 | + public const TAG_FAVORITE = '_$!<Favorite>!$_'; |
|
| 45 | 45 | |
| 46 | - /** |
|
| 47 | - * Reference to main server object |
|
| 48 | - * |
|
| 49 | - * @var \Sabre\DAV\Server |
|
| 50 | - */ |
|
| 51 | - private $server; |
|
| 46 | + /** |
|
| 47 | + * Reference to main server object |
|
| 48 | + * |
|
| 49 | + * @var \Sabre\DAV\Server |
|
| 50 | + */ |
|
| 51 | + private $server; |
|
| 52 | 52 | |
| 53 | - /** |
|
| 54 | - * @var ITags |
|
| 55 | - */ |
|
| 56 | - private $tagger; |
|
| 53 | + /** |
|
| 54 | + * @var ITags |
|
| 55 | + */ |
|
| 56 | + private $tagger; |
|
| 57 | 57 | |
| 58 | - /** |
|
| 59 | - * Array of file id to tags array |
|
| 60 | - * The null value means the cache wasn't initialized. |
|
| 61 | - * |
|
| 62 | - * @var array |
|
| 63 | - */ |
|
| 64 | - private $cachedTags; |
|
| 65 | - private array $cachedDirectories; |
|
| 58 | + /** |
|
| 59 | + * Array of file id to tags array |
|
| 60 | + * The null value means the cache wasn't initialized. |
|
| 61 | + * |
|
| 62 | + * @var array |
|
| 63 | + */ |
|
| 64 | + private $cachedTags; |
|
| 65 | + private array $cachedDirectories; |
|
| 66 | 66 | |
| 67 | - /** |
|
| 68 | - * @param \Sabre\DAV\Tree $tree tree |
|
| 69 | - * @param ITagManager $tagManager tag manager |
|
| 70 | - */ |
|
| 71 | - public function __construct( |
|
| 72 | - private \Sabre\DAV\Tree $tree, |
|
| 73 | - private ITagManager $tagManager, |
|
| 74 | - private IEventDispatcher $eventDispatcher, |
|
| 75 | - private IUserSession $userSession, |
|
| 76 | - ) { |
|
| 77 | - $this->tagger = null; |
|
| 78 | - $this->cachedTags = []; |
|
| 79 | - } |
|
| 67 | + /** |
|
| 68 | + * @param \Sabre\DAV\Tree $tree tree |
|
| 69 | + * @param ITagManager $tagManager tag manager |
|
| 70 | + */ |
|
| 71 | + public function __construct( |
|
| 72 | + private \Sabre\DAV\Tree $tree, |
|
| 73 | + private ITagManager $tagManager, |
|
| 74 | + private IEventDispatcher $eventDispatcher, |
|
| 75 | + private IUserSession $userSession, |
|
| 76 | + ) { |
|
| 77 | + $this->tagger = null; |
|
| 78 | + $this->cachedTags = []; |
|
| 79 | + } |
|
| 80 | 80 | |
| 81 | - /** |
|
| 82 | - * This initializes the plugin. |
|
| 83 | - * |
|
| 84 | - * This function is called by \Sabre\DAV\Server, after |
|
| 85 | - * addPlugin is called. |
|
| 86 | - * |
|
| 87 | - * This method should set up the required event subscriptions. |
|
| 88 | - * |
|
| 89 | - * @param \Sabre\DAV\Server $server |
|
| 90 | - * @return void |
|
| 91 | - */ |
|
| 92 | - public function initialize(\Sabre\DAV\Server $server) { |
|
| 93 | - $server->xml->namespaceMap[self::NS_OWNCLOUD] = 'oc'; |
|
| 94 | - $server->xml->elementMap[self::TAGS_PROPERTYNAME] = TagList::class; |
|
| 81 | + /** |
|
| 82 | + * This initializes the plugin. |
|
| 83 | + * |
|
| 84 | + * This function is called by \Sabre\DAV\Server, after |
|
| 85 | + * addPlugin is called. |
|
| 86 | + * |
|
| 87 | + * This method should set up the required event subscriptions. |
|
| 88 | + * |
|
| 89 | + * @param \Sabre\DAV\Server $server |
|
| 90 | + * @return void |
|
| 91 | + */ |
|
| 92 | + public function initialize(\Sabre\DAV\Server $server) { |
|
| 93 | + $server->xml->namespaceMap[self::NS_OWNCLOUD] = 'oc'; |
|
| 94 | + $server->xml->elementMap[self::TAGS_PROPERTYNAME] = TagList::class; |
|
| 95 | 95 | |
| 96 | - $this->server = $server; |
|
| 97 | - $this->server->on('preloadCollection', $this->preloadCollection(...)); |
|
| 98 | - $this->server->on('propFind', [$this, 'handleGetProperties']); |
|
| 99 | - $this->server->on('propPatch', [$this, 'handleUpdateProperties']); |
|
| 100 | - $this->server->on('preloadProperties', [$this, 'handlePreloadProperties']); |
|
| 101 | - } |
|
| 96 | + $this->server = $server; |
|
| 97 | + $this->server->on('preloadCollection', $this->preloadCollection(...)); |
|
| 98 | + $this->server->on('propFind', [$this, 'handleGetProperties']); |
|
| 99 | + $this->server->on('propPatch', [$this, 'handleUpdateProperties']); |
|
| 100 | + $this->server->on('preloadProperties', [$this, 'handlePreloadProperties']); |
|
| 101 | + } |
|
| 102 | 102 | |
| 103 | - /** |
|
| 104 | - * Returns the tagger |
|
| 105 | - * |
|
| 106 | - * @return ITags tagger |
|
| 107 | - */ |
|
| 108 | - private function getTagger() { |
|
| 109 | - if (!$this->tagger) { |
|
| 110 | - $this->tagger = $this->tagManager->load('files'); |
|
| 111 | - } |
|
| 112 | - return $this->tagger; |
|
| 113 | - } |
|
| 103 | + /** |
|
| 104 | + * Returns the tagger |
|
| 105 | + * |
|
| 106 | + * @return ITags tagger |
|
| 107 | + */ |
|
| 108 | + private function getTagger() { |
|
| 109 | + if (!$this->tagger) { |
|
| 110 | + $this->tagger = $this->tagManager->load('files'); |
|
| 111 | + } |
|
| 112 | + return $this->tagger; |
|
| 113 | + } |
|
| 114 | 114 | |
| 115 | - /** |
|
| 116 | - * Returns tags and favorites. |
|
| 117 | - * |
|
| 118 | - * @param integer $fileId file id |
|
| 119 | - * @return array list($tags, $favorite) with $tags as tag array |
|
| 120 | - * and $favorite is a boolean whether the file was favorited |
|
| 121 | - */ |
|
| 122 | - private function getTagsAndFav($fileId) { |
|
| 123 | - $isFav = false; |
|
| 124 | - $tags = $this->getTags($fileId); |
|
| 125 | - if ($tags) { |
|
| 126 | - $favPos = array_search(self::TAG_FAVORITE, $tags); |
|
| 127 | - if ($favPos !== false) { |
|
| 128 | - $isFav = true; |
|
| 129 | - unset($tags[$favPos]); |
|
| 130 | - } |
|
| 131 | - } |
|
| 132 | - return [$tags, $isFav]; |
|
| 133 | - } |
|
| 115 | + /** |
|
| 116 | + * Returns tags and favorites. |
|
| 117 | + * |
|
| 118 | + * @param integer $fileId file id |
|
| 119 | + * @return array list($tags, $favorite) with $tags as tag array |
|
| 120 | + * and $favorite is a boolean whether the file was favorited |
|
| 121 | + */ |
|
| 122 | + private function getTagsAndFav($fileId) { |
|
| 123 | + $isFav = false; |
|
| 124 | + $tags = $this->getTags($fileId); |
|
| 125 | + if ($tags) { |
|
| 126 | + $favPos = array_search(self::TAG_FAVORITE, $tags); |
|
| 127 | + if ($favPos !== false) { |
|
| 128 | + $isFav = true; |
|
| 129 | + unset($tags[$favPos]); |
|
| 130 | + } |
|
| 131 | + } |
|
| 132 | + return [$tags, $isFav]; |
|
| 133 | + } |
|
| 134 | 134 | |
| 135 | - /** |
|
| 136 | - * Returns tags for the given file id |
|
| 137 | - * |
|
| 138 | - * @param integer $fileId file id |
|
| 139 | - * @return array list of tags for that file |
|
| 140 | - */ |
|
| 141 | - private function getTags($fileId) { |
|
| 142 | - if (isset($this->cachedTags[$fileId])) { |
|
| 143 | - return $this->cachedTags[$fileId]; |
|
| 144 | - } else { |
|
| 145 | - $tags = $this->getTagger()->getTagsForObjects([$fileId]); |
|
| 146 | - if ($tags !== false) { |
|
| 147 | - if (empty($tags)) { |
|
| 148 | - return []; |
|
| 149 | - } |
|
| 150 | - return current($tags); |
|
| 151 | - } |
|
| 152 | - } |
|
| 153 | - return null; |
|
| 154 | - } |
|
| 135 | + /** |
|
| 136 | + * Returns tags for the given file id |
|
| 137 | + * |
|
| 138 | + * @param integer $fileId file id |
|
| 139 | + * @return array list of tags for that file |
|
| 140 | + */ |
|
| 141 | + private function getTags($fileId) { |
|
| 142 | + if (isset($this->cachedTags[$fileId])) { |
|
| 143 | + return $this->cachedTags[$fileId]; |
|
| 144 | + } else { |
|
| 145 | + $tags = $this->getTagger()->getTagsForObjects([$fileId]); |
|
| 146 | + if ($tags !== false) { |
|
| 147 | + if (empty($tags)) { |
|
| 148 | + return []; |
|
| 149 | + } |
|
| 150 | + return current($tags); |
|
| 151 | + } |
|
| 152 | + } |
|
| 153 | + return null; |
|
| 154 | + } |
|
| 155 | 155 | |
| 156 | - /** |
|
| 157 | - * Prefetches tags for a list of file IDs and caches the results |
|
| 158 | - * |
|
| 159 | - * @param array $fileIds List of file IDs to prefetch tags for |
|
| 160 | - * @return void |
|
| 161 | - */ |
|
| 162 | - private function prefetchTagsForFileIds(array $fileIds) { |
|
| 163 | - $tags = $this->getTagger()->getTagsForObjects($fileIds); |
|
| 164 | - if ($tags === false) { |
|
| 165 | - // the tags API returns false on error... |
|
| 166 | - $tags = []; |
|
| 167 | - } |
|
| 156 | + /** |
|
| 157 | + * Prefetches tags for a list of file IDs and caches the results |
|
| 158 | + * |
|
| 159 | + * @param array $fileIds List of file IDs to prefetch tags for |
|
| 160 | + * @return void |
|
| 161 | + */ |
|
| 162 | + private function prefetchTagsForFileIds(array $fileIds) { |
|
| 163 | + $tags = $this->getTagger()->getTagsForObjects($fileIds); |
|
| 164 | + if ($tags === false) { |
|
| 165 | + // the tags API returns false on error... |
|
| 166 | + $tags = []; |
|
| 167 | + } |
|
| 168 | 168 | |
| 169 | - foreach ($fileIds as $fileId) { |
|
| 170 | - $this->cachedTags[$fileId] = $tags[$fileId] ?? []; |
|
| 171 | - } |
|
| 172 | - } |
|
| 169 | + foreach ($fileIds as $fileId) { |
|
| 170 | + $this->cachedTags[$fileId] = $tags[$fileId] ?? []; |
|
| 171 | + } |
|
| 172 | + } |
|
| 173 | 173 | |
| 174 | - /** |
|
| 175 | - * Updates the tags of the given file id |
|
| 176 | - * |
|
| 177 | - * @param int $fileId |
|
| 178 | - * @param array $tags array of tag strings |
|
| 179 | - * @param string $path path of the file |
|
| 180 | - */ |
|
| 181 | - private function updateTags($fileId, $tags, string $path) { |
|
| 182 | - $tagger = $this->getTagger(); |
|
| 183 | - $currentTags = $this->getTags($fileId); |
|
| 174 | + /** |
|
| 175 | + * Updates the tags of the given file id |
|
| 176 | + * |
|
| 177 | + * @param int $fileId |
|
| 178 | + * @param array $tags array of tag strings |
|
| 179 | + * @param string $path path of the file |
|
| 180 | + */ |
|
| 181 | + private function updateTags($fileId, $tags, string $path) { |
|
| 182 | + $tagger = $this->getTagger(); |
|
| 183 | + $currentTags = $this->getTags($fileId); |
|
| 184 | 184 | |
| 185 | - $newTags = array_diff($tags, $currentTags); |
|
| 186 | - foreach ($newTags as $tag) { |
|
| 187 | - if ($tag === self::TAG_FAVORITE) { |
|
| 188 | - continue; |
|
| 189 | - } |
|
| 190 | - $tagger->tagAs($fileId, $tag, $path); |
|
| 191 | - } |
|
| 192 | - $deletedTags = array_diff($currentTags, $tags); |
|
| 193 | - foreach ($deletedTags as $tag) { |
|
| 194 | - if ($tag === self::TAG_FAVORITE) { |
|
| 195 | - continue; |
|
| 196 | - } |
|
| 197 | - $tagger->unTag($fileId, $tag, $path); |
|
| 198 | - } |
|
| 199 | - } |
|
| 185 | + $newTags = array_diff($tags, $currentTags); |
|
| 186 | + foreach ($newTags as $tag) { |
|
| 187 | + if ($tag === self::TAG_FAVORITE) { |
|
| 188 | + continue; |
|
| 189 | + } |
|
| 190 | + $tagger->tagAs($fileId, $tag, $path); |
|
| 191 | + } |
|
| 192 | + $deletedTags = array_diff($currentTags, $tags); |
|
| 193 | + foreach ($deletedTags as $tag) { |
|
| 194 | + if ($tag === self::TAG_FAVORITE) { |
|
| 195 | + continue; |
|
| 196 | + } |
|
| 197 | + $tagger->unTag($fileId, $tag, $path); |
|
| 198 | + } |
|
| 199 | + } |
|
| 200 | 200 | |
| 201 | - private function preloadCollection(PropFind $propFind, ICollection $collection): |
|
| 202 | - void { |
|
| 203 | - if (!($collection instanceof Node)) { |
|
| 204 | - return; |
|
| 205 | - } |
|
| 201 | + private function preloadCollection(PropFind $propFind, ICollection $collection): |
|
| 202 | + void { |
|
| 203 | + if (!($collection instanceof Node)) { |
|
| 204 | + return; |
|
| 205 | + } |
|
| 206 | 206 | |
| 207 | - // need prefetch ? |
|
| 208 | - if ($collection instanceof Directory |
|
| 209 | - && !isset($this->cachedDirectories[$collection->getPath()]) |
|
| 210 | - && (!is_null($propFind->getStatus(self::TAGS_PROPERTYNAME)) |
|
| 211 | - || !is_null($propFind->getStatus(self::FAVORITE_PROPERTYNAME)) |
|
| 212 | - )) { |
|
| 213 | - // note: pre-fetching only supported for depth <= 1 |
|
| 214 | - $folderContent = $collection->getChildren(); |
|
| 215 | - $fileIds = [(int)$collection->getId()]; |
|
| 216 | - foreach ($folderContent as $info) { |
|
| 217 | - $fileIds[] = (int)$info->getId(); |
|
| 218 | - } |
|
| 219 | - $this->prefetchTagsForFileIds($fileIds); |
|
| 220 | - $this->cachedDirectories[$collection->getPath()] = true; |
|
| 221 | - } |
|
| 222 | - } |
|
| 207 | + // need prefetch ? |
|
| 208 | + if ($collection instanceof Directory |
|
| 209 | + && !isset($this->cachedDirectories[$collection->getPath()]) |
|
| 210 | + && (!is_null($propFind->getStatus(self::TAGS_PROPERTYNAME)) |
|
| 211 | + || !is_null($propFind->getStatus(self::FAVORITE_PROPERTYNAME)) |
|
| 212 | + )) { |
|
| 213 | + // note: pre-fetching only supported for depth <= 1 |
|
| 214 | + $folderContent = $collection->getChildren(); |
|
| 215 | + $fileIds = [(int)$collection->getId()]; |
|
| 216 | + foreach ($folderContent as $info) { |
|
| 217 | + $fileIds[] = (int)$info->getId(); |
|
| 218 | + } |
|
| 219 | + $this->prefetchTagsForFileIds($fileIds); |
|
| 220 | + $this->cachedDirectories[$collection->getPath()] = true; |
|
| 221 | + } |
|
| 222 | + } |
|
| 223 | 223 | |
| 224 | - /** |
|
| 225 | - * Adds tags and favorites properties to the response, |
|
| 226 | - * if requested. |
|
| 227 | - * |
|
| 228 | - * @param PropFind $propFind |
|
| 229 | - * @param \Sabre\DAV\INode $node |
|
| 230 | - * @return void |
|
| 231 | - */ |
|
| 232 | - public function handleGetProperties( |
|
| 233 | - PropFind $propFind, |
|
| 234 | - \Sabre\DAV\INode $node, |
|
| 235 | - ) { |
|
| 236 | - if (!($node instanceof Node)) { |
|
| 237 | - return; |
|
| 238 | - } |
|
| 224 | + /** |
|
| 225 | + * Adds tags and favorites properties to the response, |
|
| 226 | + * if requested. |
|
| 227 | + * |
|
| 228 | + * @param PropFind $propFind |
|
| 229 | + * @param \Sabre\DAV\INode $node |
|
| 230 | + * @return void |
|
| 231 | + */ |
|
| 232 | + public function handleGetProperties( |
|
| 233 | + PropFind $propFind, |
|
| 234 | + \Sabre\DAV\INode $node, |
|
| 235 | + ) { |
|
| 236 | + if (!($node instanceof Node)) { |
|
| 237 | + return; |
|
| 238 | + } |
|
| 239 | 239 | |
| 240 | - $isFav = null; |
|
| 240 | + $isFav = null; |
|
| 241 | 241 | |
| 242 | - $propFind->handle(self::TAGS_PROPERTYNAME, function () use (&$isFav, $node) { |
|
| 243 | - [$tags, $isFav] = $this->getTagsAndFav($node->getId()); |
|
| 244 | - return new TagList($tags); |
|
| 245 | - }); |
|
| 242 | + $propFind->handle(self::TAGS_PROPERTYNAME, function () use (&$isFav, $node) { |
|
| 243 | + [$tags, $isFav] = $this->getTagsAndFav($node->getId()); |
|
| 244 | + return new TagList($tags); |
|
| 245 | + }); |
|
| 246 | 246 | |
| 247 | - $propFind->handle(self::FAVORITE_PROPERTYNAME, function () use ($isFav, $node) { |
|
| 248 | - if (is_null($isFav)) { |
|
| 249 | - [, $isFav] = $this->getTagsAndFav($node->getId()); |
|
| 250 | - } |
|
| 251 | - if ($isFav) { |
|
| 252 | - return 1; |
|
| 253 | - } else { |
|
| 254 | - return 0; |
|
| 255 | - } |
|
| 256 | - }); |
|
| 257 | - } |
|
| 247 | + $propFind->handle(self::FAVORITE_PROPERTYNAME, function () use ($isFav, $node) { |
|
| 248 | + if (is_null($isFav)) { |
|
| 249 | + [, $isFav] = $this->getTagsAndFav($node->getId()); |
|
| 250 | + } |
|
| 251 | + if ($isFav) { |
|
| 252 | + return 1; |
|
| 253 | + } else { |
|
| 254 | + return 0; |
|
| 255 | + } |
|
| 256 | + }); |
|
| 257 | + } |
|
| 258 | 258 | |
| 259 | - /** |
|
| 260 | - * Updates tags and favorites properties, if applicable. |
|
| 261 | - * |
|
| 262 | - * @param string $path |
|
| 263 | - * @param PropPatch $propPatch |
|
| 264 | - * |
|
| 265 | - * @return void |
|
| 266 | - */ |
|
| 267 | - public function handleUpdateProperties($path, PropPatch $propPatch) { |
|
| 268 | - $node = $this->tree->getNodeForPath($path); |
|
| 269 | - if (!($node instanceof Node)) { |
|
| 270 | - return; |
|
| 271 | - } |
|
| 259 | + /** |
|
| 260 | + * Updates tags and favorites properties, if applicable. |
|
| 261 | + * |
|
| 262 | + * @param string $path |
|
| 263 | + * @param PropPatch $propPatch |
|
| 264 | + * |
|
| 265 | + * @return void |
|
| 266 | + */ |
|
| 267 | + public function handleUpdateProperties($path, PropPatch $propPatch) { |
|
| 268 | + $node = $this->tree->getNodeForPath($path); |
|
| 269 | + if (!($node instanceof Node)) { |
|
| 270 | + return; |
|
| 271 | + } |
|
| 272 | 272 | |
| 273 | - $propPatch->handle(self::TAGS_PROPERTYNAME, function ($tagList) use ($node, $path) { |
|
| 274 | - $this->updateTags($node->getId(), $tagList->getTags(), $path); |
|
| 275 | - return true; |
|
| 276 | - }); |
|
| 273 | + $propPatch->handle(self::TAGS_PROPERTYNAME, function ($tagList) use ($node, $path) { |
|
| 274 | + $this->updateTags($node->getId(), $tagList->getTags(), $path); |
|
| 275 | + return true; |
|
| 276 | + }); |
|
| 277 | 277 | |
| 278 | - $propPatch->handle(self::FAVORITE_PROPERTYNAME, function ($favState) use ($node, $path) { |
|
| 279 | - if ((int)$favState === 1 || $favState === 'true') { |
|
| 280 | - $this->getTagger()->tagAs($node->getId(), self::TAG_FAVORITE, $path); |
|
| 281 | - } else { |
|
| 282 | - $this->getTagger()->unTag($node->getId(), self::TAG_FAVORITE, $path); |
|
| 283 | - } |
|
| 278 | + $propPatch->handle(self::FAVORITE_PROPERTYNAME, function ($favState) use ($node, $path) { |
|
| 279 | + if ((int)$favState === 1 || $favState === 'true') { |
|
| 280 | + $this->getTagger()->tagAs($node->getId(), self::TAG_FAVORITE, $path); |
|
| 281 | + } else { |
|
| 282 | + $this->getTagger()->unTag($node->getId(), self::TAG_FAVORITE, $path); |
|
| 283 | + } |
|
| 284 | 284 | |
| 285 | - if (is_null($favState)) { |
|
| 286 | - // confirm deletion |
|
| 287 | - return 204; |
|
| 288 | - } |
|
| 285 | + if (is_null($favState)) { |
|
| 286 | + // confirm deletion |
|
| 287 | + return 204; |
|
| 288 | + } |
|
| 289 | 289 | |
| 290 | - return 200; |
|
| 291 | - }); |
|
| 292 | - } |
|
| 290 | + return 200; |
|
| 291 | + }); |
|
| 292 | + } |
|
| 293 | 293 | |
| 294 | - public function handlePreloadProperties(array $nodes, array $requestProperties): void { |
|
| 295 | - if ( |
|
| 296 | - !in_array(self::FAVORITE_PROPERTYNAME, $requestProperties, true) |
|
| 297 | - && !in_array(self::TAGS_PROPERTYNAME, $requestProperties, true) |
|
| 298 | - ) { |
|
| 299 | - return; |
|
| 300 | - } |
|
| 301 | - $this->prefetchTagsForFileIds(array_map(fn ($node) => $node->getId(), $nodes)); |
|
| 302 | - } |
|
| 294 | + public function handlePreloadProperties(array $nodes, array $requestProperties): void { |
|
| 295 | + if ( |
|
| 296 | + !in_array(self::FAVORITE_PROPERTYNAME, $requestProperties, true) |
|
| 297 | + && !in_array(self::TAGS_PROPERTYNAME, $requestProperties, true) |
|
| 298 | + ) { |
|
| 299 | + return; |
|
| 300 | + } |
|
| 301 | + $this->prefetchTagsForFileIds(array_map(fn ($node) => $node->getId(), $nodes)); |
|
| 302 | + } |
|
| 303 | 303 | } |
@@ -212,9 +212,9 @@ discard block |
||
| 212 | 212 | )) { |
| 213 | 213 | // note: pre-fetching only supported for depth <= 1 |
| 214 | 214 | $folderContent = $collection->getChildren(); |
| 215 | - $fileIds = [(int)$collection->getId()]; |
|
| 215 | + $fileIds = [(int) $collection->getId()]; |
|
| 216 | 216 | foreach ($folderContent as $info) { |
| 217 | - $fileIds[] = (int)$info->getId(); |
|
| 217 | + $fileIds[] = (int) $info->getId(); |
|
| 218 | 218 | } |
| 219 | 219 | $this->prefetchTagsForFileIds($fileIds); |
| 220 | 220 | $this->cachedDirectories[$collection->getPath()] = true; |
@@ -239,12 +239,12 @@ discard block |
||
| 239 | 239 | |
| 240 | 240 | $isFav = null; |
| 241 | 241 | |
| 242 | - $propFind->handle(self::TAGS_PROPERTYNAME, function () use (&$isFav, $node) { |
|
| 242 | + $propFind->handle(self::TAGS_PROPERTYNAME, function() use (&$isFav, $node) { |
|
| 243 | 243 | [$tags, $isFav] = $this->getTagsAndFav($node->getId()); |
| 244 | 244 | return new TagList($tags); |
| 245 | 245 | }); |
| 246 | 246 | |
| 247 | - $propFind->handle(self::FAVORITE_PROPERTYNAME, function () use ($isFav, $node) { |
|
| 247 | + $propFind->handle(self::FAVORITE_PROPERTYNAME, function() use ($isFav, $node) { |
|
| 248 | 248 | if (is_null($isFav)) { |
| 249 | 249 | [, $isFav] = $this->getTagsAndFav($node->getId()); |
| 250 | 250 | } |
@@ -270,13 +270,13 @@ discard block |
||
| 270 | 270 | return; |
| 271 | 271 | } |
| 272 | 272 | |
| 273 | - $propPatch->handle(self::TAGS_PROPERTYNAME, function ($tagList) use ($node, $path) { |
|
| 273 | + $propPatch->handle(self::TAGS_PROPERTYNAME, function($tagList) use ($node, $path) { |
|
| 274 | 274 | $this->updateTags($node->getId(), $tagList->getTags(), $path); |
| 275 | 275 | return true; |
| 276 | 276 | }); |
| 277 | 277 | |
| 278 | - $propPatch->handle(self::FAVORITE_PROPERTYNAME, function ($favState) use ($node, $path) { |
|
| 279 | - if ((int)$favState === 1 || $favState === 'true') { |
|
| 278 | + $propPatch->handle(self::FAVORITE_PROPERTYNAME, function($favState) use ($node, $path) { |
|
| 279 | + if ((int) $favState === 1 || $favState === 'true') { |
|
| 280 | 280 | $this->getTagger()->tagAs($node->getId(), self::TAG_FAVORITE, $path); |
| 281 | 281 | } else { |
| 282 | 282 | $this->getTagger()->unTag($node->getId(), self::TAG_FAVORITE, $path); |
@@ -23,388 +23,388 @@ |
||
| 23 | 23 | use Sabre\DAV\Tree; |
| 24 | 24 | |
| 25 | 25 | class TagsPluginTest extends \Test\TestCase { |
| 26 | - public const TAGS_PROPERTYNAME = TagsPlugin::TAGS_PROPERTYNAME; |
|
| 27 | - public const FAVORITE_PROPERTYNAME = TagsPlugin::FAVORITE_PROPERTYNAME; |
|
| 28 | - public const TAG_FAVORITE = TagsPlugin::TAG_FAVORITE; |
|
| 29 | - |
|
| 30 | - private \Sabre\DAV\Server $server; |
|
| 31 | - private Tree&MockObject $tree; |
|
| 32 | - private ITagManager&MockObject $tagManager; |
|
| 33 | - private ITags&MockObject $tagger; |
|
| 34 | - private IEventDispatcher&MockObject $eventDispatcher; |
|
| 35 | - private IUserSession&MockObject $userSession; |
|
| 36 | - private TagsPlugin $plugin; |
|
| 37 | - |
|
| 38 | - protected function setUp(): void { |
|
| 39 | - parent::setUp(); |
|
| 40 | - |
|
| 41 | - $this->server = new \Sabre\DAV\Server(); |
|
| 42 | - $this->tree = $this->createMock(Tree::class); |
|
| 43 | - $this->tagger = $this->createMock(ITags::class); |
|
| 44 | - $this->tagManager = $this->createMock(ITagManager::class); |
|
| 45 | - $this->eventDispatcher = $this->createMock(IEventDispatcher::class); |
|
| 46 | - $user = $this->createMock(IUser::class); |
|
| 47 | - |
|
| 48 | - $this->userSession = $this->createMock(IUserSession::class); |
|
| 49 | - $this->userSession->expects($this->any()) |
|
| 50 | - ->method('getUser') |
|
| 51 | - ->withAnyParameters() |
|
| 52 | - ->willReturn($user); |
|
| 53 | - $this->tagManager->expects($this->any()) |
|
| 54 | - ->method('load') |
|
| 55 | - ->with('files') |
|
| 56 | - ->willReturn($this->tagger); |
|
| 57 | - $this->plugin = new TagsPlugin($this->tree, $this->tagManager, $this->eventDispatcher, $this->userSession); |
|
| 58 | - $this->plugin->initialize($this->server); |
|
| 59 | - } |
|
| 60 | - |
|
| 61 | - #[\PHPUnit\Framework\Attributes\DataProvider('tagsGetPropertiesDataProvider')] |
|
| 62 | - public function testGetProperties(array $tags, array $requestedProperties, array $expectedProperties): void { |
|
| 63 | - $node = $this->createMock(Node::class); |
|
| 64 | - $node->expects($this->any()) |
|
| 65 | - ->method('getId') |
|
| 66 | - ->willReturn(123); |
|
| 67 | - |
|
| 68 | - $expectedCallCount = 0; |
|
| 69 | - if (count($requestedProperties) > 0) { |
|
| 70 | - $expectedCallCount = 1; |
|
| 71 | - } |
|
| 72 | - |
|
| 73 | - $this->tagger->expects($this->exactly($expectedCallCount)) |
|
| 74 | - ->method('getTagsForObjects') |
|
| 75 | - ->with($this->equalTo([123])) |
|
| 76 | - ->willReturn([123 => $tags]); |
|
| 77 | - |
|
| 78 | - $propFind = new \Sabre\DAV\PropFind( |
|
| 79 | - '/dummyPath', |
|
| 80 | - $requestedProperties, |
|
| 81 | - 0 |
|
| 82 | - ); |
|
| 83 | - |
|
| 84 | - $this->plugin->handleGetProperties( |
|
| 85 | - $propFind, |
|
| 86 | - $node |
|
| 87 | - ); |
|
| 88 | - |
|
| 89 | - $result = $propFind->getResultForMultiStatus(); |
|
| 90 | - |
|
| 91 | - $this->assertEmpty($result[404]); |
|
| 92 | - unset($result[404]); |
|
| 93 | - $this->assertEquals($expectedProperties, $result); |
|
| 94 | - } |
|
| 95 | - |
|
| 96 | - #[\PHPUnit\Framework\Attributes\DataProvider('tagsGetPropertiesDataProvider')] |
|
| 97 | - public function testPreloadThenGetProperties(array $tags, array $requestedProperties, array $expectedProperties): void { |
|
| 98 | - $node1 = $this->createMock(File::class); |
|
| 99 | - $node1->expects($this->any()) |
|
| 100 | - ->method('getId') |
|
| 101 | - ->willReturn(111); |
|
| 102 | - $node2 = $this->createMock(File::class); |
|
| 103 | - $node2->expects($this->any()) |
|
| 104 | - ->method('getId') |
|
| 105 | - ->willReturn(222); |
|
| 106 | - |
|
| 107 | - $expectedCallCount = 0; |
|
| 108 | - if (count($requestedProperties) > 0) { |
|
| 109 | - // this guarantees that getTagsForObjects |
|
| 110 | - // is only called once and then the tags |
|
| 111 | - // are cached |
|
| 112 | - $expectedCallCount = 1; |
|
| 113 | - } |
|
| 114 | - |
|
| 115 | - $node = $this->createMock(Directory::class); |
|
| 116 | - $node->expects($this->any()) |
|
| 117 | - ->method('getId') |
|
| 118 | - ->willReturn(123); |
|
| 119 | - $node->expects($this->exactly($expectedCallCount)) |
|
| 120 | - ->method('getChildren') |
|
| 121 | - ->willReturn([$node1, $node2]); |
|
| 122 | - |
|
| 123 | - $this->tagger->expects($this->exactly($expectedCallCount)) |
|
| 124 | - ->method('getTagsForObjects') |
|
| 125 | - ->with($this->equalTo([123, 111, 222])) |
|
| 126 | - ->willReturn( |
|
| 127 | - [ |
|
| 128 | - 111 => $tags, |
|
| 129 | - 123 => $tags |
|
| 130 | - ] |
|
| 131 | - ); |
|
| 132 | - |
|
| 133 | - // simulate sabre recursive PROPFIND traversal |
|
| 134 | - $propFindRoot = new \Sabre\DAV\PropFind( |
|
| 135 | - '/subdir', |
|
| 136 | - $requestedProperties, |
|
| 137 | - 1 |
|
| 138 | - ); |
|
| 139 | - $propFind1 = new \Sabre\DAV\PropFind( |
|
| 140 | - '/subdir/test.txt', |
|
| 141 | - $requestedProperties, |
|
| 142 | - 0 |
|
| 143 | - ); |
|
| 144 | - $propFind2 = new \Sabre\DAV\PropFind( |
|
| 145 | - '/subdir/test2.txt', |
|
| 146 | - $requestedProperties, |
|
| 147 | - 0 |
|
| 148 | - ); |
|
| 149 | - |
|
| 150 | - $this->server->emit('preloadCollection', [$propFindRoot, $node]); |
|
| 151 | - |
|
| 152 | - $this->plugin->handleGetProperties( |
|
| 153 | - $propFindRoot, |
|
| 154 | - $node |
|
| 155 | - ); |
|
| 156 | - $this->plugin->handleGetProperties( |
|
| 157 | - $propFind1, |
|
| 158 | - $node1 |
|
| 159 | - ); |
|
| 160 | - $this->plugin->handleGetProperties( |
|
| 161 | - $propFind2, |
|
| 162 | - $node2 |
|
| 163 | - ); |
|
| 164 | - |
|
| 165 | - $result = $propFind1->getResultForMultiStatus(); |
|
| 166 | - |
|
| 167 | - $this->assertEmpty($result[404]); |
|
| 168 | - unset($result[404]); |
|
| 169 | - $this->assertEquals($expectedProperties, $result); |
|
| 170 | - } |
|
| 171 | - |
|
| 172 | - public static function tagsGetPropertiesDataProvider(): array { |
|
| 173 | - return [ |
|
| 174 | - // request both, receive both |
|
| 175 | - [ |
|
| 176 | - ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 177 | - [self::TAGS_PROPERTYNAME, self::FAVORITE_PROPERTYNAME], |
|
| 178 | - [ |
|
| 179 | - 200 => [ |
|
| 180 | - self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2']), |
|
| 181 | - self::FAVORITE_PROPERTYNAME => true, |
|
| 182 | - ] |
|
| 183 | - ] |
|
| 184 | - ], |
|
| 185 | - // request tags alone |
|
| 186 | - [ |
|
| 187 | - ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 188 | - [self::TAGS_PROPERTYNAME], |
|
| 189 | - [ |
|
| 190 | - 200 => [ |
|
| 191 | - self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2']), |
|
| 192 | - ] |
|
| 193 | - ] |
|
| 194 | - ], |
|
| 195 | - // request fav alone |
|
| 196 | - [ |
|
| 197 | - ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 198 | - [self::FAVORITE_PROPERTYNAME], |
|
| 199 | - [ |
|
| 200 | - 200 => [ |
|
| 201 | - self::FAVORITE_PROPERTYNAME => true, |
|
| 202 | - ] |
|
| 203 | - ] |
|
| 204 | - ], |
|
| 205 | - // request none |
|
| 206 | - [ |
|
| 207 | - ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 208 | - [], |
|
| 209 | - [ |
|
| 210 | - 200 => [] |
|
| 211 | - ], |
|
| 212 | - ], |
|
| 213 | - // request both with none set, receive both |
|
| 214 | - [ |
|
| 215 | - [], |
|
| 216 | - [self::TAGS_PROPERTYNAME, self::FAVORITE_PROPERTYNAME], |
|
| 217 | - [ |
|
| 218 | - 200 => [ |
|
| 219 | - self::TAGS_PROPERTYNAME => new TagList([]), |
|
| 220 | - self::FAVORITE_PROPERTYNAME => false, |
|
| 221 | - ] |
|
| 222 | - ] |
|
| 223 | - ], |
|
| 224 | - ]; |
|
| 225 | - } |
|
| 226 | - |
|
| 227 | - public function testGetPropertiesSkipChunks(): void { |
|
| 228 | - $sabreNode = $this->createMock(UploadFile::class); |
|
| 229 | - |
|
| 230 | - $propFind = new \Sabre\DAV\PropFind( |
|
| 231 | - '/dummyPath', |
|
| 232 | - [self::TAGS_PROPERTYNAME, self::TAG_FAVORITE], |
|
| 233 | - 0 |
|
| 234 | - ); |
|
| 235 | - |
|
| 236 | - $this->plugin->handleGetProperties( |
|
| 237 | - $propFind, |
|
| 238 | - $sabreNode |
|
| 239 | - ); |
|
| 240 | - |
|
| 241 | - $result = $propFind->getResultForMultiStatus(); |
|
| 242 | - $this->assertCount(2, $result[404]); |
|
| 243 | - } |
|
| 244 | - |
|
| 245 | - public function testUpdateTags(): void { |
|
| 246 | - // this test will replace the existing tags "tagremove" with "tag1" and "tag2" |
|
| 247 | - // and keep "tagkeep" |
|
| 248 | - $node = $this->createMock(Node::class); |
|
| 249 | - $node->expects($this->any()) |
|
| 250 | - ->method('getId') |
|
| 251 | - ->willReturn(123); |
|
| 252 | - |
|
| 253 | - $this->tree->expects($this->any()) |
|
| 254 | - ->method('getNodeForPath') |
|
| 255 | - ->with('/dummypath') |
|
| 256 | - ->willReturn($node); |
|
| 257 | - |
|
| 258 | - $this->tagger->expects($this->once()) |
|
| 259 | - ->method('getTagsForObjects') |
|
| 260 | - ->with($this->equalTo([123])) |
|
| 261 | - ->willReturn([123 => ['tagkeep', 'tagremove', self::TAG_FAVORITE]]); |
|
| 262 | - |
|
| 263 | - // then tag as tag1 and tag2 |
|
| 264 | - $calls = [ |
|
| 265 | - [123, 'tag1', '/dummypath'], |
|
| 266 | - [123, 'tag2', '/dummypath'], |
|
| 267 | - ]; |
|
| 268 | - $this->tagger->expects($this->exactly(count($calls))) |
|
| 269 | - ->method('tagAs') |
|
| 270 | - ->willReturnCallback(function () use (&$calls): void { |
|
| 271 | - $expected = array_shift($calls); |
|
| 272 | - $this->assertEquals($expected, func_get_args()); |
|
| 273 | - }); |
|
| 274 | - |
|
| 275 | - // it will untag tag3 |
|
| 276 | - $this->tagger->expects($this->once()) |
|
| 277 | - ->method('unTag') |
|
| 278 | - ->with(123, 'tagremove'); |
|
| 279 | - |
|
| 280 | - // properties to set |
|
| 281 | - $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 282 | - self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2', 'tagkeep']) |
|
| 283 | - ]); |
|
| 284 | - |
|
| 285 | - $this->plugin->handleUpdateProperties( |
|
| 286 | - '/dummypath', |
|
| 287 | - $propPatch |
|
| 288 | - ); |
|
| 289 | - |
|
| 290 | - $propPatch->commit(); |
|
| 291 | - |
|
| 292 | - // all requested properties removed, as they were processed already |
|
| 293 | - $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 294 | - |
|
| 295 | - $result = $propPatch->getResult(); |
|
| 296 | - $this->assertEquals(200, $result[self::TAGS_PROPERTYNAME]); |
|
| 297 | - $this->assertArrayNotHasKey(self::FAVORITE_PROPERTYNAME, $result); |
|
| 298 | - } |
|
| 299 | - |
|
| 300 | - public function testUpdateTagsFromScratch(): void { |
|
| 301 | - $node = $this->createMock(Node::class); |
|
| 302 | - $node->expects($this->any()) |
|
| 303 | - ->method('getId') |
|
| 304 | - ->willReturn(123); |
|
| 305 | - |
|
| 306 | - $this->tree->expects($this->any()) |
|
| 307 | - ->method('getNodeForPath') |
|
| 308 | - ->with('/dummypath') |
|
| 309 | - ->willReturn($node); |
|
| 310 | - |
|
| 311 | - $this->tagger->expects($this->once()) |
|
| 312 | - ->method('getTagsForObjects') |
|
| 313 | - ->with($this->equalTo([123])) |
|
| 314 | - ->willReturn([]); |
|
| 315 | - |
|
| 316 | - // then tag as tag1 and tag2 |
|
| 317 | - $calls = [ |
|
| 318 | - [123, 'tag1', '/dummypath'], |
|
| 319 | - [123, 'tag2', '/dummypath'], |
|
| 320 | - ]; |
|
| 321 | - $this->tagger->expects($this->exactly(count($calls))) |
|
| 322 | - ->method('tagAs') |
|
| 323 | - ->willReturnCallback(function () use (&$calls): void { |
|
| 324 | - $expected = array_shift($calls); |
|
| 325 | - $this->assertEquals($expected, func_get_args()); |
|
| 326 | - }); |
|
| 327 | - |
|
| 328 | - // properties to set |
|
| 329 | - $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 330 | - self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2']) |
|
| 331 | - ]); |
|
| 332 | - |
|
| 333 | - $this->plugin->handleUpdateProperties( |
|
| 334 | - '/dummypath', |
|
| 335 | - $propPatch |
|
| 336 | - ); |
|
| 337 | - |
|
| 338 | - $propPatch->commit(); |
|
| 339 | - |
|
| 340 | - // all requested properties removed, as they were processed already |
|
| 341 | - $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 342 | - |
|
| 343 | - $result = $propPatch->getResult(); |
|
| 344 | - $this->assertEquals(200, $result[self::TAGS_PROPERTYNAME]); |
|
| 345 | - $this->assertArrayNotHasKey(self::FAVORITE_PROPERTYNAME, $result); |
|
| 346 | - } |
|
| 347 | - |
|
| 348 | - public function testUpdateFav(): void { |
|
| 349 | - // this test will replace the existing tags "tagremove" with "tag1" and "tag2" |
|
| 350 | - // and keep "tagkeep" |
|
| 351 | - $node = $this->createMock(Node::class); |
|
| 352 | - $node->expects($this->any()) |
|
| 353 | - ->method('getId') |
|
| 354 | - ->willReturn(123); |
|
| 355 | - |
|
| 356 | - $this->tree->expects($this->any()) |
|
| 357 | - ->method('getNodeForPath') |
|
| 358 | - ->with('/dummypath') |
|
| 359 | - ->willReturn($node); |
|
| 360 | - |
|
| 361 | - // set favorite tag |
|
| 362 | - $this->tagger->expects($this->once()) |
|
| 363 | - ->method('tagAs') |
|
| 364 | - ->with(123, self::TAG_FAVORITE); |
|
| 365 | - |
|
| 366 | - // properties to set |
|
| 367 | - $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 368 | - self::FAVORITE_PROPERTYNAME => true |
|
| 369 | - ]); |
|
| 370 | - |
|
| 371 | - $this->plugin->handleUpdateProperties( |
|
| 372 | - '/dummypath', |
|
| 373 | - $propPatch |
|
| 374 | - ); |
|
| 375 | - |
|
| 376 | - $propPatch->commit(); |
|
| 377 | - |
|
| 378 | - // all requested properties removed, as they were processed already |
|
| 379 | - $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 380 | - |
|
| 381 | - $result = $propPatch->getResult(); |
|
| 382 | - $this->assertArrayNotHasKey(self::TAGS_PROPERTYNAME, $result); |
|
| 383 | - $this->assertEquals(200, $result[self::FAVORITE_PROPERTYNAME]); |
|
| 384 | - |
|
| 385 | - // unfavorite now |
|
| 386 | - // set favorite tag |
|
| 387 | - $this->tagger->expects($this->once()) |
|
| 388 | - ->method('unTag') |
|
| 389 | - ->with(123, self::TAG_FAVORITE); |
|
| 390 | - |
|
| 391 | - // properties to set |
|
| 392 | - $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 393 | - self::FAVORITE_PROPERTYNAME => false |
|
| 394 | - ]); |
|
| 395 | - |
|
| 396 | - $this->plugin->handleUpdateProperties( |
|
| 397 | - '/dummypath', |
|
| 398 | - $propPatch |
|
| 399 | - ); |
|
| 400 | - |
|
| 401 | - $propPatch->commit(); |
|
| 402 | - |
|
| 403 | - // all requested properties removed, as they were processed already |
|
| 404 | - $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 405 | - |
|
| 406 | - $result = $propPatch->getResult(); |
|
| 407 | - $this->assertArrayNotHasKey(self::TAGS_PROPERTYNAME, $result); |
|
| 408 | - $this->assertEquals(200, $result[self::FAVORITE_PROPERTYNAME]); |
|
| 409 | - } |
|
| 26 | + public const TAGS_PROPERTYNAME = TagsPlugin::TAGS_PROPERTYNAME; |
|
| 27 | + public const FAVORITE_PROPERTYNAME = TagsPlugin::FAVORITE_PROPERTYNAME; |
|
| 28 | + public const TAG_FAVORITE = TagsPlugin::TAG_FAVORITE; |
|
| 29 | + |
|
| 30 | + private \Sabre\DAV\Server $server; |
|
| 31 | + private Tree&MockObject $tree; |
|
| 32 | + private ITagManager&MockObject $tagManager; |
|
| 33 | + private ITags&MockObject $tagger; |
|
| 34 | + private IEventDispatcher&MockObject $eventDispatcher; |
|
| 35 | + private IUserSession&MockObject $userSession; |
|
| 36 | + private TagsPlugin $plugin; |
|
| 37 | + |
|
| 38 | + protected function setUp(): void { |
|
| 39 | + parent::setUp(); |
|
| 40 | + |
|
| 41 | + $this->server = new \Sabre\DAV\Server(); |
|
| 42 | + $this->tree = $this->createMock(Tree::class); |
|
| 43 | + $this->tagger = $this->createMock(ITags::class); |
|
| 44 | + $this->tagManager = $this->createMock(ITagManager::class); |
|
| 45 | + $this->eventDispatcher = $this->createMock(IEventDispatcher::class); |
|
| 46 | + $user = $this->createMock(IUser::class); |
|
| 47 | + |
|
| 48 | + $this->userSession = $this->createMock(IUserSession::class); |
|
| 49 | + $this->userSession->expects($this->any()) |
|
| 50 | + ->method('getUser') |
|
| 51 | + ->withAnyParameters() |
|
| 52 | + ->willReturn($user); |
|
| 53 | + $this->tagManager->expects($this->any()) |
|
| 54 | + ->method('load') |
|
| 55 | + ->with('files') |
|
| 56 | + ->willReturn($this->tagger); |
|
| 57 | + $this->plugin = new TagsPlugin($this->tree, $this->tagManager, $this->eventDispatcher, $this->userSession); |
|
| 58 | + $this->plugin->initialize($this->server); |
|
| 59 | + } |
|
| 60 | + |
|
| 61 | + #[\PHPUnit\Framework\Attributes\DataProvider('tagsGetPropertiesDataProvider')] |
|
| 62 | + public function testGetProperties(array $tags, array $requestedProperties, array $expectedProperties): void { |
|
| 63 | + $node = $this->createMock(Node::class); |
|
| 64 | + $node->expects($this->any()) |
|
| 65 | + ->method('getId') |
|
| 66 | + ->willReturn(123); |
|
| 67 | + |
|
| 68 | + $expectedCallCount = 0; |
|
| 69 | + if (count($requestedProperties) > 0) { |
|
| 70 | + $expectedCallCount = 1; |
|
| 71 | + } |
|
| 72 | + |
|
| 73 | + $this->tagger->expects($this->exactly($expectedCallCount)) |
|
| 74 | + ->method('getTagsForObjects') |
|
| 75 | + ->with($this->equalTo([123])) |
|
| 76 | + ->willReturn([123 => $tags]); |
|
| 77 | + |
|
| 78 | + $propFind = new \Sabre\DAV\PropFind( |
|
| 79 | + '/dummyPath', |
|
| 80 | + $requestedProperties, |
|
| 81 | + 0 |
|
| 82 | + ); |
|
| 83 | + |
|
| 84 | + $this->plugin->handleGetProperties( |
|
| 85 | + $propFind, |
|
| 86 | + $node |
|
| 87 | + ); |
|
| 88 | + |
|
| 89 | + $result = $propFind->getResultForMultiStatus(); |
|
| 90 | + |
|
| 91 | + $this->assertEmpty($result[404]); |
|
| 92 | + unset($result[404]); |
|
| 93 | + $this->assertEquals($expectedProperties, $result); |
|
| 94 | + } |
|
| 95 | + |
|
| 96 | + #[\PHPUnit\Framework\Attributes\DataProvider('tagsGetPropertiesDataProvider')] |
|
| 97 | + public function testPreloadThenGetProperties(array $tags, array $requestedProperties, array $expectedProperties): void { |
|
| 98 | + $node1 = $this->createMock(File::class); |
|
| 99 | + $node1->expects($this->any()) |
|
| 100 | + ->method('getId') |
|
| 101 | + ->willReturn(111); |
|
| 102 | + $node2 = $this->createMock(File::class); |
|
| 103 | + $node2->expects($this->any()) |
|
| 104 | + ->method('getId') |
|
| 105 | + ->willReturn(222); |
|
| 106 | + |
|
| 107 | + $expectedCallCount = 0; |
|
| 108 | + if (count($requestedProperties) > 0) { |
|
| 109 | + // this guarantees that getTagsForObjects |
|
| 110 | + // is only called once and then the tags |
|
| 111 | + // are cached |
|
| 112 | + $expectedCallCount = 1; |
|
| 113 | + } |
|
| 114 | + |
|
| 115 | + $node = $this->createMock(Directory::class); |
|
| 116 | + $node->expects($this->any()) |
|
| 117 | + ->method('getId') |
|
| 118 | + ->willReturn(123); |
|
| 119 | + $node->expects($this->exactly($expectedCallCount)) |
|
| 120 | + ->method('getChildren') |
|
| 121 | + ->willReturn([$node1, $node2]); |
|
| 122 | + |
|
| 123 | + $this->tagger->expects($this->exactly($expectedCallCount)) |
|
| 124 | + ->method('getTagsForObjects') |
|
| 125 | + ->with($this->equalTo([123, 111, 222])) |
|
| 126 | + ->willReturn( |
|
| 127 | + [ |
|
| 128 | + 111 => $tags, |
|
| 129 | + 123 => $tags |
|
| 130 | + ] |
|
| 131 | + ); |
|
| 132 | + |
|
| 133 | + // simulate sabre recursive PROPFIND traversal |
|
| 134 | + $propFindRoot = new \Sabre\DAV\PropFind( |
|
| 135 | + '/subdir', |
|
| 136 | + $requestedProperties, |
|
| 137 | + 1 |
|
| 138 | + ); |
|
| 139 | + $propFind1 = new \Sabre\DAV\PropFind( |
|
| 140 | + '/subdir/test.txt', |
|
| 141 | + $requestedProperties, |
|
| 142 | + 0 |
|
| 143 | + ); |
|
| 144 | + $propFind2 = new \Sabre\DAV\PropFind( |
|
| 145 | + '/subdir/test2.txt', |
|
| 146 | + $requestedProperties, |
|
| 147 | + 0 |
|
| 148 | + ); |
|
| 149 | + |
|
| 150 | + $this->server->emit('preloadCollection', [$propFindRoot, $node]); |
|
| 151 | + |
|
| 152 | + $this->plugin->handleGetProperties( |
|
| 153 | + $propFindRoot, |
|
| 154 | + $node |
|
| 155 | + ); |
|
| 156 | + $this->plugin->handleGetProperties( |
|
| 157 | + $propFind1, |
|
| 158 | + $node1 |
|
| 159 | + ); |
|
| 160 | + $this->plugin->handleGetProperties( |
|
| 161 | + $propFind2, |
|
| 162 | + $node2 |
|
| 163 | + ); |
|
| 164 | + |
|
| 165 | + $result = $propFind1->getResultForMultiStatus(); |
|
| 166 | + |
|
| 167 | + $this->assertEmpty($result[404]); |
|
| 168 | + unset($result[404]); |
|
| 169 | + $this->assertEquals($expectedProperties, $result); |
|
| 170 | + } |
|
| 171 | + |
|
| 172 | + public static function tagsGetPropertiesDataProvider(): array { |
|
| 173 | + return [ |
|
| 174 | + // request both, receive both |
|
| 175 | + [ |
|
| 176 | + ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 177 | + [self::TAGS_PROPERTYNAME, self::FAVORITE_PROPERTYNAME], |
|
| 178 | + [ |
|
| 179 | + 200 => [ |
|
| 180 | + self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2']), |
|
| 181 | + self::FAVORITE_PROPERTYNAME => true, |
|
| 182 | + ] |
|
| 183 | + ] |
|
| 184 | + ], |
|
| 185 | + // request tags alone |
|
| 186 | + [ |
|
| 187 | + ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 188 | + [self::TAGS_PROPERTYNAME], |
|
| 189 | + [ |
|
| 190 | + 200 => [ |
|
| 191 | + self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2']), |
|
| 192 | + ] |
|
| 193 | + ] |
|
| 194 | + ], |
|
| 195 | + // request fav alone |
|
| 196 | + [ |
|
| 197 | + ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 198 | + [self::FAVORITE_PROPERTYNAME], |
|
| 199 | + [ |
|
| 200 | + 200 => [ |
|
| 201 | + self::FAVORITE_PROPERTYNAME => true, |
|
| 202 | + ] |
|
| 203 | + ] |
|
| 204 | + ], |
|
| 205 | + // request none |
|
| 206 | + [ |
|
| 207 | + ['tag1', 'tag2', self::TAG_FAVORITE], |
|
| 208 | + [], |
|
| 209 | + [ |
|
| 210 | + 200 => [] |
|
| 211 | + ], |
|
| 212 | + ], |
|
| 213 | + // request both with none set, receive both |
|
| 214 | + [ |
|
| 215 | + [], |
|
| 216 | + [self::TAGS_PROPERTYNAME, self::FAVORITE_PROPERTYNAME], |
|
| 217 | + [ |
|
| 218 | + 200 => [ |
|
| 219 | + self::TAGS_PROPERTYNAME => new TagList([]), |
|
| 220 | + self::FAVORITE_PROPERTYNAME => false, |
|
| 221 | + ] |
|
| 222 | + ] |
|
| 223 | + ], |
|
| 224 | + ]; |
|
| 225 | + } |
|
| 226 | + |
|
| 227 | + public function testGetPropertiesSkipChunks(): void { |
|
| 228 | + $sabreNode = $this->createMock(UploadFile::class); |
|
| 229 | + |
|
| 230 | + $propFind = new \Sabre\DAV\PropFind( |
|
| 231 | + '/dummyPath', |
|
| 232 | + [self::TAGS_PROPERTYNAME, self::TAG_FAVORITE], |
|
| 233 | + 0 |
|
| 234 | + ); |
|
| 235 | + |
|
| 236 | + $this->plugin->handleGetProperties( |
|
| 237 | + $propFind, |
|
| 238 | + $sabreNode |
|
| 239 | + ); |
|
| 240 | + |
|
| 241 | + $result = $propFind->getResultForMultiStatus(); |
|
| 242 | + $this->assertCount(2, $result[404]); |
|
| 243 | + } |
|
| 244 | + |
|
| 245 | + public function testUpdateTags(): void { |
|
| 246 | + // this test will replace the existing tags "tagremove" with "tag1" and "tag2" |
|
| 247 | + // and keep "tagkeep" |
|
| 248 | + $node = $this->createMock(Node::class); |
|
| 249 | + $node->expects($this->any()) |
|
| 250 | + ->method('getId') |
|
| 251 | + ->willReturn(123); |
|
| 252 | + |
|
| 253 | + $this->tree->expects($this->any()) |
|
| 254 | + ->method('getNodeForPath') |
|
| 255 | + ->with('/dummypath') |
|
| 256 | + ->willReturn($node); |
|
| 257 | + |
|
| 258 | + $this->tagger->expects($this->once()) |
|
| 259 | + ->method('getTagsForObjects') |
|
| 260 | + ->with($this->equalTo([123])) |
|
| 261 | + ->willReturn([123 => ['tagkeep', 'tagremove', self::TAG_FAVORITE]]); |
|
| 262 | + |
|
| 263 | + // then tag as tag1 and tag2 |
|
| 264 | + $calls = [ |
|
| 265 | + [123, 'tag1', '/dummypath'], |
|
| 266 | + [123, 'tag2', '/dummypath'], |
|
| 267 | + ]; |
|
| 268 | + $this->tagger->expects($this->exactly(count($calls))) |
|
| 269 | + ->method('tagAs') |
|
| 270 | + ->willReturnCallback(function () use (&$calls): void { |
|
| 271 | + $expected = array_shift($calls); |
|
| 272 | + $this->assertEquals($expected, func_get_args()); |
|
| 273 | + }); |
|
| 274 | + |
|
| 275 | + // it will untag tag3 |
|
| 276 | + $this->tagger->expects($this->once()) |
|
| 277 | + ->method('unTag') |
|
| 278 | + ->with(123, 'tagremove'); |
|
| 279 | + |
|
| 280 | + // properties to set |
|
| 281 | + $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 282 | + self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2', 'tagkeep']) |
|
| 283 | + ]); |
|
| 284 | + |
|
| 285 | + $this->plugin->handleUpdateProperties( |
|
| 286 | + '/dummypath', |
|
| 287 | + $propPatch |
|
| 288 | + ); |
|
| 289 | + |
|
| 290 | + $propPatch->commit(); |
|
| 291 | + |
|
| 292 | + // all requested properties removed, as they were processed already |
|
| 293 | + $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 294 | + |
|
| 295 | + $result = $propPatch->getResult(); |
|
| 296 | + $this->assertEquals(200, $result[self::TAGS_PROPERTYNAME]); |
|
| 297 | + $this->assertArrayNotHasKey(self::FAVORITE_PROPERTYNAME, $result); |
|
| 298 | + } |
|
| 299 | + |
|
| 300 | + public function testUpdateTagsFromScratch(): void { |
|
| 301 | + $node = $this->createMock(Node::class); |
|
| 302 | + $node->expects($this->any()) |
|
| 303 | + ->method('getId') |
|
| 304 | + ->willReturn(123); |
|
| 305 | + |
|
| 306 | + $this->tree->expects($this->any()) |
|
| 307 | + ->method('getNodeForPath') |
|
| 308 | + ->with('/dummypath') |
|
| 309 | + ->willReturn($node); |
|
| 310 | + |
|
| 311 | + $this->tagger->expects($this->once()) |
|
| 312 | + ->method('getTagsForObjects') |
|
| 313 | + ->with($this->equalTo([123])) |
|
| 314 | + ->willReturn([]); |
|
| 315 | + |
|
| 316 | + // then tag as tag1 and tag2 |
|
| 317 | + $calls = [ |
|
| 318 | + [123, 'tag1', '/dummypath'], |
|
| 319 | + [123, 'tag2', '/dummypath'], |
|
| 320 | + ]; |
|
| 321 | + $this->tagger->expects($this->exactly(count($calls))) |
|
| 322 | + ->method('tagAs') |
|
| 323 | + ->willReturnCallback(function () use (&$calls): void { |
|
| 324 | + $expected = array_shift($calls); |
|
| 325 | + $this->assertEquals($expected, func_get_args()); |
|
| 326 | + }); |
|
| 327 | + |
|
| 328 | + // properties to set |
|
| 329 | + $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 330 | + self::TAGS_PROPERTYNAME => new TagList(['tag1', 'tag2']) |
|
| 331 | + ]); |
|
| 332 | + |
|
| 333 | + $this->plugin->handleUpdateProperties( |
|
| 334 | + '/dummypath', |
|
| 335 | + $propPatch |
|
| 336 | + ); |
|
| 337 | + |
|
| 338 | + $propPatch->commit(); |
|
| 339 | + |
|
| 340 | + // all requested properties removed, as they were processed already |
|
| 341 | + $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 342 | + |
|
| 343 | + $result = $propPatch->getResult(); |
|
| 344 | + $this->assertEquals(200, $result[self::TAGS_PROPERTYNAME]); |
|
| 345 | + $this->assertArrayNotHasKey(self::FAVORITE_PROPERTYNAME, $result); |
|
| 346 | + } |
|
| 347 | + |
|
| 348 | + public function testUpdateFav(): void { |
|
| 349 | + // this test will replace the existing tags "tagremove" with "tag1" and "tag2" |
|
| 350 | + // and keep "tagkeep" |
|
| 351 | + $node = $this->createMock(Node::class); |
|
| 352 | + $node->expects($this->any()) |
|
| 353 | + ->method('getId') |
|
| 354 | + ->willReturn(123); |
|
| 355 | + |
|
| 356 | + $this->tree->expects($this->any()) |
|
| 357 | + ->method('getNodeForPath') |
|
| 358 | + ->with('/dummypath') |
|
| 359 | + ->willReturn($node); |
|
| 360 | + |
|
| 361 | + // set favorite tag |
|
| 362 | + $this->tagger->expects($this->once()) |
|
| 363 | + ->method('tagAs') |
|
| 364 | + ->with(123, self::TAG_FAVORITE); |
|
| 365 | + |
|
| 366 | + // properties to set |
|
| 367 | + $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 368 | + self::FAVORITE_PROPERTYNAME => true |
|
| 369 | + ]); |
|
| 370 | + |
|
| 371 | + $this->plugin->handleUpdateProperties( |
|
| 372 | + '/dummypath', |
|
| 373 | + $propPatch |
|
| 374 | + ); |
|
| 375 | + |
|
| 376 | + $propPatch->commit(); |
|
| 377 | + |
|
| 378 | + // all requested properties removed, as they were processed already |
|
| 379 | + $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 380 | + |
|
| 381 | + $result = $propPatch->getResult(); |
|
| 382 | + $this->assertArrayNotHasKey(self::TAGS_PROPERTYNAME, $result); |
|
| 383 | + $this->assertEquals(200, $result[self::FAVORITE_PROPERTYNAME]); |
|
| 384 | + |
|
| 385 | + // unfavorite now |
|
| 386 | + // set favorite tag |
|
| 387 | + $this->tagger->expects($this->once()) |
|
| 388 | + ->method('unTag') |
|
| 389 | + ->with(123, self::TAG_FAVORITE); |
|
| 390 | + |
|
| 391 | + // properties to set |
|
| 392 | + $propPatch = new \Sabre\DAV\PropPatch([ |
|
| 393 | + self::FAVORITE_PROPERTYNAME => false |
|
| 394 | + ]); |
|
| 395 | + |
|
| 396 | + $this->plugin->handleUpdateProperties( |
|
| 397 | + '/dummypath', |
|
| 398 | + $propPatch |
|
| 399 | + ); |
|
| 400 | + |
|
| 401 | + $propPatch->commit(); |
|
| 402 | + |
|
| 403 | + // all requested properties removed, as they were processed already |
|
| 404 | + $this->assertEmpty($propPatch->getRemainingMutations()); |
|
| 405 | + |
|
| 406 | + $result = $propPatch->getResult(); |
|
| 407 | + $this->assertArrayNotHasKey(self::TAGS_PROPERTYNAME, $result); |
|
| 408 | + $this->assertEquals(200, $result[self::FAVORITE_PROPERTYNAME]); |
|
| 409 | + } |
|
| 410 | 410 | } |
@@ -28,271 +28,271 @@ |
||
| 28 | 28 | * @group DB |
| 29 | 29 | */ |
| 30 | 30 | class TagsTest extends \Test\TestCase { |
| 31 | - protected $objectType; |
|
| 32 | - /** @var IUser */ |
|
| 33 | - protected $user; |
|
| 34 | - /** @var IUserSession */ |
|
| 35 | - protected $userSession; |
|
| 36 | - protected $backupGlobals = false; |
|
| 37 | - /** @var \OC\Tagging\TagMapper */ |
|
| 38 | - protected $tagMapper; |
|
| 39 | - /** @var ITagManager */ |
|
| 40 | - protected $tagMgr; |
|
| 41 | - |
|
| 42 | - protected function setUp(): void { |
|
| 43 | - parent::setUp(); |
|
| 44 | - |
|
| 45 | - Server::get(IUserManager::class)->clearBackends(); |
|
| 46 | - Server::get(IUserManager::class)->registerBackend(new \Test\Util\User\Dummy()); |
|
| 47 | - $userId = $this->getUniqueID('user_'); |
|
| 48 | - Server::get(IUserManager::class)->createUser($userId, 'pass'); |
|
| 49 | - \OC_User::setUserId($userId); |
|
| 50 | - $this->user = $this->createMock(IUser::class); |
|
| 51 | - $this->user->method('getUID') |
|
| 52 | - ->willReturn($userId); |
|
| 53 | - $this->userSession = $this->createMock(IUserSession::class); |
|
| 54 | - $this->userSession |
|
| 55 | - ->expects($this->any()) |
|
| 56 | - ->method('getUser') |
|
| 57 | - ->willReturn($this->user); |
|
| 58 | - $userFolder = $this->createMock(Folder::class); |
|
| 59 | - $node = $this->createMock(Node::class); |
|
| 60 | - $this->rootFolder = $this->createMock(IRootFolder::class); |
|
| 61 | - $this->rootFolder |
|
| 62 | - ->method('getUserFolder') |
|
| 63 | - ->willReturnCallback(fn () => $userFolder); |
|
| 64 | - $userFolder |
|
| 65 | - ->method('getFirstNodeById') |
|
| 66 | - ->willReturnCallback(fn () => $node); |
|
| 67 | - $node |
|
| 68 | - ->method('getPath') |
|
| 69 | - ->willReturnCallback(fn () => 'file.txt'); |
|
| 70 | - |
|
| 71 | - $this->objectType = $this->getUniqueID('type_'); |
|
| 72 | - $this->tagMapper = new TagMapper(Server::get(IDBConnection::class)); |
|
| 73 | - $this->tagMgr = new TagManager($this->tagMapper, $this->userSession, Server::get(IDBConnection::class), Server::get(LoggerInterface::class), Server::get(IEventDispatcher::class), $this->rootFolder); |
|
| 74 | - } |
|
| 75 | - |
|
| 76 | - protected function tearDown(): void { |
|
| 77 | - $conn = Server::get(IDBConnection::class); |
|
| 78 | - $conn->executeQuery('DELETE FROM `*PREFIX*vcategory_to_object`'); |
|
| 79 | - $conn->executeQuery('DELETE FROM `*PREFIX*vcategory`'); |
|
| 80 | - |
|
| 81 | - parent::tearDown(); |
|
| 82 | - } |
|
| 83 | - |
|
| 84 | - public function testTagManagerWithoutUserReturnsNull(): void { |
|
| 85 | - $this->userSession = $this->createMock(IUserSession::class); |
|
| 86 | - $this->userSession |
|
| 87 | - ->expects($this->any()) |
|
| 88 | - ->method('getUser') |
|
| 89 | - ->willReturn(null); |
|
| 90 | - $this->tagMgr = new TagManager($this->tagMapper, $this->userSession, Server::get(IDBConnection::class), Server::get(LoggerInterface::class), Server::get(IEventDispatcher::class), $this->rootFolder); |
|
| 91 | - $this->assertNull($this->tagMgr->load($this->objectType)); |
|
| 92 | - } |
|
| 93 | - |
|
| 94 | - public function testInstantiateWithDefaults(): void { |
|
| 95 | - $defaultTags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 96 | - |
|
| 97 | - $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 98 | - |
|
| 99 | - $this->assertEquals(4, count($tagger->getTags())); |
|
| 100 | - } |
|
| 101 | - |
|
| 102 | - public function testAddTags(): void { |
|
| 103 | - $tags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 104 | - |
|
| 105 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 106 | - |
|
| 107 | - foreach ($tags as $tag) { |
|
| 108 | - $result = $tagger->add($tag); |
|
| 109 | - $this->assertGreaterThan(0, $result, 'add() returned an ID <= 0'); |
|
| 110 | - $this->assertTrue((bool)$result); |
|
| 111 | - } |
|
| 112 | - |
|
| 113 | - $this->assertFalse($tagger->add('Family')); |
|
| 114 | - $this->assertFalse($tagger->add('fAMILY')); |
|
| 115 | - |
|
| 116 | - $this->assertCount(4, $tagger->getTags(), 'Wrong number of added tags'); |
|
| 117 | - } |
|
| 118 | - |
|
| 119 | - public function testAddMultiple(): void { |
|
| 120 | - $tags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 121 | - |
|
| 122 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 123 | - |
|
| 124 | - foreach ($tags as $tag) { |
|
| 125 | - $this->assertFalse($tagger->hasTag($tag)); |
|
| 126 | - } |
|
| 127 | - |
|
| 128 | - $result = $tagger->addMultiple($tags); |
|
| 129 | - $this->assertTrue((bool)$result); |
|
| 130 | - |
|
| 131 | - foreach ($tags as $tag) { |
|
| 132 | - $this->assertTrue($tagger->hasTag($tag)); |
|
| 133 | - } |
|
| 134 | - |
|
| 135 | - $tagMaps = $tagger->getTags(); |
|
| 136 | - $this->assertCount(4, $tagMaps, 'Not all tags added'); |
|
| 137 | - foreach ($tagMaps as $tagMap) { |
|
| 138 | - $this->assertEquals(null, $tagMap['id']); |
|
| 139 | - } |
|
| 140 | - |
|
| 141 | - // As addMultiple has been called without $sync=true, the tags aren't |
|
| 142 | - // saved to the database, so they're gone when we reload $tagger: |
|
| 143 | - |
|
| 144 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 145 | - $this->assertEquals(0, count($tagger->getTags())); |
|
| 146 | - |
|
| 147 | - // Now, we call addMultiple() with $sync=true so the tags will be |
|
| 148 | - // be saved to the database. |
|
| 149 | - $result = $tagger->addMultiple($tags, true); |
|
| 150 | - $this->assertTrue((bool)$result); |
|
| 151 | - |
|
| 152 | - $tagMaps = $tagger->getTags(); |
|
| 153 | - foreach ($tagMaps as $tagMap) { |
|
| 154 | - $this->assertNotEquals(null, $tagMap['id']); |
|
| 155 | - } |
|
| 156 | - |
|
| 157 | - // Reload the tagger. |
|
| 158 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 159 | - |
|
| 160 | - foreach ($tags as $tag) { |
|
| 161 | - $this->assertTrue($tagger->hasTag($tag)); |
|
| 162 | - } |
|
| 163 | - |
|
| 164 | - $this->assertCount(4, $tagger->getTags(), 'Not all previously saved tags found'); |
|
| 165 | - } |
|
| 166 | - |
|
| 167 | - public function testIsEmpty(): void { |
|
| 168 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 169 | - |
|
| 170 | - $this->assertEquals(0, count($tagger->getTags())); |
|
| 171 | - $this->assertTrue($tagger->isEmpty()); |
|
| 172 | - |
|
| 173 | - $result = $tagger->add('Tag'); |
|
| 174 | - $this->assertGreaterThan(0, $result, 'add() returned an ID <= 0'); |
|
| 175 | - $this->assertNotEquals(false, $result, 'add() returned false'); |
|
| 176 | - $this->assertFalse($tagger->isEmpty()); |
|
| 177 | - } |
|
| 178 | - |
|
| 179 | - public function testGetTagsForObjects(): void { |
|
| 180 | - $defaultTags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 181 | - $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 182 | - |
|
| 183 | - $tagger->tagAs(1, 'Friends'); |
|
| 184 | - $tagger->tagAs(1, 'Other'); |
|
| 185 | - $tagger->tagAs(2, 'Family'); |
|
| 186 | - |
|
| 187 | - $tags = $tagger->getTagsForObjects([1]); |
|
| 188 | - $this->assertEquals(1, count($tags)); |
|
| 189 | - $tags = current($tags); |
|
| 190 | - sort($tags); |
|
| 191 | - $this->assertSame(['Friends', 'Other'], $tags); |
|
| 192 | - |
|
| 193 | - $tags = $tagger->getTagsForObjects([1, 2]); |
|
| 194 | - $this->assertEquals(2, count($tags)); |
|
| 195 | - $tags1 = $tags[1]; |
|
| 196 | - sort($tags1); |
|
| 197 | - $this->assertSame(['Friends', 'Other'], $tags1); |
|
| 198 | - $this->assertSame(['Family'], $tags[2]); |
|
| 199 | - $this->assertEquals( |
|
| 200 | - [], |
|
| 201 | - $tagger->getTagsForObjects([4]) |
|
| 202 | - ); |
|
| 203 | - $this->assertEquals( |
|
| 204 | - [], |
|
| 205 | - $tagger->getTagsForObjects([4, 5]) |
|
| 206 | - ); |
|
| 207 | - } |
|
| 208 | - |
|
| 209 | - public function testGetTagsForObjectsMassiveResults(): void { |
|
| 210 | - $defaultTags = ['tag1']; |
|
| 211 | - $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 212 | - $tagData = $tagger->getTags(); |
|
| 213 | - $tagId = $tagData[0]['id']; |
|
| 214 | - $tagType = $tagData[0]['type']; |
|
| 215 | - |
|
| 216 | - $conn = Server::get(IDBConnection::class); |
|
| 217 | - $statement = $conn->prepare( |
|
| 218 | - 'INSERT INTO `*PREFIX*vcategory_to_object` ' |
|
| 219 | - . '(`objid`, `categoryid`, `type`) VALUES ' |
|
| 220 | - . '(?, ?, ?)' |
|
| 221 | - ); |
|
| 222 | - |
|
| 223 | - // insert lots of entries |
|
| 224 | - $idsArray = []; |
|
| 225 | - for ($i = 1; $i <= 1500; $i++) { |
|
| 226 | - $statement->execute([$i, $tagId, $tagType]); |
|
| 227 | - $idsArray[] = $i; |
|
| 228 | - } |
|
| 229 | - |
|
| 230 | - $tags = $tagger->getTagsForObjects($idsArray); |
|
| 231 | - $this->assertEquals(1500, count($tags)); |
|
| 232 | - } |
|
| 233 | - |
|
| 234 | - public function testDeleteTags(): void { |
|
| 235 | - $defaultTags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 236 | - $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 237 | - |
|
| 238 | - $this->assertEquals(4, count($tagger->getTags())); |
|
| 239 | - |
|
| 240 | - $tagger->delete('family'); |
|
| 241 | - $this->assertEquals(3, count($tagger->getTags())); |
|
| 242 | - |
|
| 243 | - $tagger->delete(['Friends', 'Work', 'Other']); |
|
| 244 | - $this->assertEquals(0, count($tagger->getTags())); |
|
| 245 | - } |
|
| 246 | - |
|
| 247 | - public function testRenameTag(): void { |
|
| 248 | - $defaultTags = ['Friends', 'Family', 'Wrok', 'Other']; |
|
| 249 | - $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 250 | - |
|
| 251 | - $this->assertTrue($tagger->rename('Wrok', 'Work')); |
|
| 252 | - $this->assertTrue($tagger->hasTag('Work')); |
|
| 253 | - $this->assertFalse($tagger->hasTag('Wrok')); |
|
| 254 | - $this->assertFalse($tagger->rename('Wrok', 'Work')); // Rename non-existant tag. |
|
| 255 | - $this->assertFalse($tagger->rename('Work', 'Family')); // Collide with existing tag. |
|
| 256 | - } |
|
| 257 | - |
|
| 258 | - public function testTagAs(): void { |
|
| 259 | - $objids = [1, 2, 3, 4, 5, 6, 7, 8, 9]; |
|
| 260 | - |
|
| 261 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 262 | - |
|
| 263 | - foreach ($objids as $id) { |
|
| 264 | - $this->assertTrue($tagger->tagAs($id, 'Family')); |
|
| 265 | - } |
|
| 266 | - |
|
| 267 | - $this->assertEquals(1, count($tagger->getTags())); |
|
| 268 | - $this->assertEquals(9, count($tagger->getIdsForTag('Family'))); |
|
| 269 | - } |
|
| 270 | - |
|
| 271 | - /** |
|
| 272 | - * @depends testTagAs |
|
| 273 | - */ |
|
| 274 | - public function testUnTag(): void { |
|
| 275 | - $objIds = [1, 2, 3, 4, 5, 6, 7, 8, 9]; |
|
| 276 | - |
|
| 277 | - // Is this "legal"? |
|
| 278 | - $this->testTagAs(); |
|
| 279 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 280 | - |
|
| 281 | - foreach ($objIds as $id) { |
|
| 282 | - $this->assertTrue(in_array($id, $tagger->getIdsForTag('Family'))); |
|
| 283 | - $tagger->unTag($id, 'Family'); |
|
| 284 | - $this->assertFalse(in_array($id, $tagger->getIdsForTag('Family'))); |
|
| 285 | - } |
|
| 286 | - |
|
| 287 | - $this->assertEquals(1, count($tagger->getTags())); |
|
| 288 | - $this->assertEquals(0, count($tagger->getIdsForTag('Family'))); |
|
| 289 | - } |
|
| 290 | - |
|
| 291 | - public function testFavorite(): void { |
|
| 292 | - $tagger = $this->tagMgr->load($this->objectType); |
|
| 293 | - $this->assertTrue($tagger->addToFavorites(1)); |
|
| 294 | - $this->assertEquals([1], $tagger->getFavorites()); |
|
| 295 | - $this->assertTrue($tagger->removeFromFavorites(1)); |
|
| 296 | - $this->assertEquals([], $tagger->getFavorites()); |
|
| 297 | - } |
|
| 31 | + protected $objectType; |
|
| 32 | + /** @var IUser */ |
|
| 33 | + protected $user; |
|
| 34 | + /** @var IUserSession */ |
|
| 35 | + protected $userSession; |
|
| 36 | + protected $backupGlobals = false; |
|
| 37 | + /** @var \OC\Tagging\TagMapper */ |
|
| 38 | + protected $tagMapper; |
|
| 39 | + /** @var ITagManager */ |
|
| 40 | + protected $tagMgr; |
|
| 41 | + |
|
| 42 | + protected function setUp(): void { |
|
| 43 | + parent::setUp(); |
|
| 44 | + |
|
| 45 | + Server::get(IUserManager::class)->clearBackends(); |
|
| 46 | + Server::get(IUserManager::class)->registerBackend(new \Test\Util\User\Dummy()); |
|
| 47 | + $userId = $this->getUniqueID('user_'); |
|
| 48 | + Server::get(IUserManager::class)->createUser($userId, 'pass'); |
|
| 49 | + \OC_User::setUserId($userId); |
|
| 50 | + $this->user = $this->createMock(IUser::class); |
|
| 51 | + $this->user->method('getUID') |
|
| 52 | + ->willReturn($userId); |
|
| 53 | + $this->userSession = $this->createMock(IUserSession::class); |
|
| 54 | + $this->userSession |
|
| 55 | + ->expects($this->any()) |
|
| 56 | + ->method('getUser') |
|
| 57 | + ->willReturn($this->user); |
|
| 58 | + $userFolder = $this->createMock(Folder::class); |
|
| 59 | + $node = $this->createMock(Node::class); |
|
| 60 | + $this->rootFolder = $this->createMock(IRootFolder::class); |
|
| 61 | + $this->rootFolder |
|
| 62 | + ->method('getUserFolder') |
|
| 63 | + ->willReturnCallback(fn () => $userFolder); |
|
| 64 | + $userFolder |
|
| 65 | + ->method('getFirstNodeById') |
|
| 66 | + ->willReturnCallback(fn () => $node); |
|
| 67 | + $node |
|
| 68 | + ->method('getPath') |
|
| 69 | + ->willReturnCallback(fn () => 'file.txt'); |
|
| 70 | + |
|
| 71 | + $this->objectType = $this->getUniqueID('type_'); |
|
| 72 | + $this->tagMapper = new TagMapper(Server::get(IDBConnection::class)); |
|
| 73 | + $this->tagMgr = new TagManager($this->tagMapper, $this->userSession, Server::get(IDBConnection::class), Server::get(LoggerInterface::class), Server::get(IEventDispatcher::class), $this->rootFolder); |
|
| 74 | + } |
|
| 75 | + |
|
| 76 | + protected function tearDown(): void { |
|
| 77 | + $conn = Server::get(IDBConnection::class); |
|
| 78 | + $conn->executeQuery('DELETE FROM `*PREFIX*vcategory_to_object`'); |
|
| 79 | + $conn->executeQuery('DELETE FROM `*PREFIX*vcategory`'); |
|
| 80 | + |
|
| 81 | + parent::tearDown(); |
|
| 82 | + } |
|
| 83 | + |
|
| 84 | + public function testTagManagerWithoutUserReturnsNull(): void { |
|
| 85 | + $this->userSession = $this->createMock(IUserSession::class); |
|
| 86 | + $this->userSession |
|
| 87 | + ->expects($this->any()) |
|
| 88 | + ->method('getUser') |
|
| 89 | + ->willReturn(null); |
|
| 90 | + $this->tagMgr = new TagManager($this->tagMapper, $this->userSession, Server::get(IDBConnection::class), Server::get(LoggerInterface::class), Server::get(IEventDispatcher::class), $this->rootFolder); |
|
| 91 | + $this->assertNull($this->tagMgr->load($this->objectType)); |
|
| 92 | + } |
|
| 93 | + |
|
| 94 | + public function testInstantiateWithDefaults(): void { |
|
| 95 | + $defaultTags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 96 | + |
|
| 97 | + $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 98 | + |
|
| 99 | + $this->assertEquals(4, count($tagger->getTags())); |
|
| 100 | + } |
|
| 101 | + |
|
| 102 | + public function testAddTags(): void { |
|
| 103 | + $tags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 104 | + |
|
| 105 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 106 | + |
|
| 107 | + foreach ($tags as $tag) { |
|
| 108 | + $result = $tagger->add($tag); |
|
| 109 | + $this->assertGreaterThan(0, $result, 'add() returned an ID <= 0'); |
|
| 110 | + $this->assertTrue((bool)$result); |
|
| 111 | + } |
|
| 112 | + |
|
| 113 | + $this->assertFalse($tagger->add('Family')); |
|
| 114 | + $this->assertFalse($tagger->add('fAMILY')); |
|
| 115 | + |
|
| 116 | + $this->assertCount(4, $tagger->getTags(), 'Wrong number of added tags'); |
|
| 117 | + } |
|
| 118 | + |
|
| 119 | + public function testAddMultiple(): void { |
|
| 120 | + $tags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 121 | + |
|
| 122 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 123 | + |
|
| 124 | + foreach ($tags as $tag) { |
|
| 125 | + $this->assertFalse($tagger->hasTag($tag)); |
|
| 126 | + } |
|
| 127 | + |
|
| 128 | + $result = $tagger->addMultiple($tags); |
|
| 129 | + $this->assertTrue((bool)$result); |
|
| 130 | + |
|
| 131 | + foreach ($tags as $tag) { |
|
| 132 | + $this->assertTrue($tagger->hasTag($tag)); |
|
| 133 | + } |
|
| 134 | + |
|
| 135 | + $tagMaps = $tagger->getTags(); |
|
| 136 | + $this->assertCount(4, $tagMaps, 'Not all tags added'); |
|
| 137 | + foreach ($tagMaps as $tagMap) { |
|
| 138 | + $this->assertEquals(null, $tagMap['id']); |
|
| 139 | + } |
|
| 140 | + |
|
| 141 | + // As addMultiple has been called without $sync=true, the tags aren't |
|
| 142 | + // saved to the database, so they're gone when we reload $tagger: |
|
| 143 | + |
|
| 144 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 145 | + $this->assertEquals(0, count($tagger->getTags())); |
|
| 146 | + |
|
| 147 | + // Now, we call addMultiple() with $sync=true so the tags will be |
|
| 148 | + // be saved to the database. |
|
| 149 | + $result = $tagger->addMultiple($tags, true); |
|
| 150 | + $this->assertTrue((bool)$result); |
|
| 151 | + |
|
| 152 | + $tagMaps = $tagger->getTags(); |
|
| 153 | + foreach ($tagMaps as $tagMap) { |
|
| 154 | + $this->assertNotEquals(null, $tagMap['id']); |
|
| 155 | + } |
|
| 156 | + |
|
| 157 | + // Reload the tagger. |
|
| 158 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 159 | + |
|
| 160 | + foreach ($tags as $tag) { |
|
| 161 | + $this->assertTrue($tagger->hasTag($tag)); |
|
| 162 | + } |
|
| 163 | + |
|
| 164 | + $this->assertCount(4, $tagger->getTags(), 'Not all previously saved tags found'); |
|
| 165 | + } |
|
| 166 | + |
|
| 167 | + public function testIsEmpty(): void { |
|
| 168 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 169 | + |
|
| 170 | + $this->assertEquals(0, count($tagger->getTags())); |
|
| 171 | + $this->assertTrue($tagger->isEmpty()); |
|
| 172 | + |
|
| 173 | + $result = $tagger->add('Tag'); |
|
| 174 | + $this->assertGreaterThan(0, $result, 'add() returned an ID <= 0'); |
|
| 175 | + $this->assertNotEquals(false, $result, 'add() returned false'); |
|
| 176 | + $this->assertFalse($tagger->isEmpty()); |
|
| 177 | + } |
|
| 178 | + |
|
| 179 | + public function testGetTagsForObjects(): void { |
|
| 180 | + $defaultTags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 181 | + $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 182 | + |
|
| 183 | + $tagger->tagAs(1, 'Friends'); |
|
| 184 | + $tagger->tagAs(1, 'Other'); |
|
| 185 | + $tagger->tagAs(2, 'Family'); |
|
| 186 | + |
|
| 187 | + $tags = $tagger->getTagsForObjects([1]); |
|
| 188 | + $this->assertEquals(1, count($tags)); |
|
| 189 | + $tags = current($tags); |
|
| 190 | + sort($tags); |
|
| 191 | + $this->assertSame(['Friends', 'Other'], $tags); |
|
| 192 | + |
|
| 193 | + $tags = $tagger->getTagsForObjects([1, 2]); |
|
| 194 | + $this->assertEquals(2, count($tags)); |
|
| 195 | + $tags1 = $tags[1]; |
|
| 196 | + sort($tags1); |
|
| 197 | + $this->assertSame(['Friends', 'Other'], $tags1); |
|
| 198 | + $this->assertSame(['Family'], $tags[2]); |
|
| 199 | + $this->assertEquals( |
|
| 200 | + [], |
|
| 201 | + $tagger->getTagsForObjects([4]) |
|
| 202 | + ); |
|
| 203 | + $this->assertEquals( |
|
| 204 | + [], |
|
| 205 | + $tagger->getTagsForObjects([4, 5]) |
|
| 206 | + ); |
|
| 207 | + } |
|
| 208 | + |
|
| 209 | + public function testGetTagsForObjectsMassiveResults(): void { |
|
| 210 | + $defaultTags = ['tag1']; |
|
| 211 | + $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 212 | + $tagData = $tagger->getTags(); |
|
| 213 | + $tagId = $tagData[0]['id']; |
|
| 214 | + $tagType = $tagData[0]['type']; |
|
| 215 | + |
|
| 216 | + $conn = Server::get(IDBConnection::class); |
|
| 217 | + $statement = $conn->prepare( |
|
| 218 | + 'INSERT INTO `*PREFIX*vcategory_to_object` ' |
|
| 219 | + . '(`objid`, `categoryid`, `type`) VALUES ' |
|
| 220 | + . '(?, ?, ?)' |
|
| 221 | + ); |
|
| 222 | + |
|
| 223 | + // insert lots of entries |
|
| 224 | + $idsArray = []; |
|
| 225 | + for ($i = 1; $i <= 1500; $i++) { |
|
| 226 | + $statement->execute([$i, $tagId, $tagType]); |
|
| 227 | + $idsArray[] = $i; |
|
| 228 | + } |
|
| 229 | + |
|
| 230 | + $tags = $tagger->getTagsForObjects($idsArray); |
|
| 231 | + $this->assertEquals(1500, count($tags)); |
|
| 232 | + } |
|
| 233 | + |
|
| 234 | + public function testDeleteTags(): void { |
|
| 235 | + $defaultTags = ['Friends', 'Family', 'Work', 'Other']; |
|
| 236 | + $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 237 | + |
|
| 238 | + $this->assertEquals(4, count($tagger->getTags())); |
|
| 239 | + |
|
| 240 | + $tagger->delete('family'); |
|
| 241 | + $this->assertEquals(3, count($tagger->getTags())); |
|
| 242 | + |
|
| 243 | + $tagger->delete(['Friends', 'Work', 'Other']); |
|
| 244 | + $this->assertEquals(0, count($tagger->getTags())); |
|
| 245 | + } |
|
| 246 | + |
|
| 247 | + public function testRenameTag(): void { |
|
| 248 | + $defaultTags = ['Friends', 'Family', 'Wrok', 'Other']; |
|
| 249 | + $tagger = $this->tagMgr->load($this->objectType, $defaultTags); |
|
| 250 | + |
|
| 251 | + $this->assertTrue($tagger->rename('Wrok', 'Work')); |
|
| 252 | + $this->assertTrue($tagger->hasTag('Work')); |
|
| 253 | + $this->assertFalse($tagger->hasTag('Wrok')); |
|
| 254 | + $this->assertFalse($tagger->rename('Wrok', 'Work')); // Rename non-existant tag. |
|
| 255 | + $this->assertFalse($tagger->rename('Work', 'Family')); // Collide with existing tag. |
|
| 256 | + } |
|
| 257 | + |
|
| 258 | + public function testTagAs(): void { |
|
| 259 | + $objids = [1, 2, 3, 4, 5, 6, 7, 8, 9]; |
|
| 260 | + |
|
| 261 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 262 | + |
|
| 263 | + foreach ($objids as $id) { |
|
| 264 | + $this->assertTrue($tagger->tagAs($id, 'Family')); |
|
| 265 | + } |
|
| 266 | + |
|
| 267 | + $this->assertEquals(1, count($tagger->getTags())); |
|
| 268 | + $this->assertEquals(9, count($tagger->getIdsForTag('Family'))); |
|
| 269 | + } |
|
| 270 | + |
|
| 271 | + /** |
|
| 272 | + * @depends testTagAs |
|
| 273 | + */ |
|
| 274 | + public function testUnTag(): void { |
|
| 275 | + $objIds = [1, 2, 3, 4, 5, 6, 7, 8, 9]; |
|
| 276 | + |
|
| 277 | + // Is this "legal"? |
|
| 278 | + $this->testTagAs(); |
|
| 279 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 280 | + |
|
| 281 | + foreach ($objIds as $id) { |
|
| 282 | + $this->assertTrue(in_array($id, $tagger->getIdsForTag('Family'))); |
|
| 283 | + $tagger->unTag($id, 'Family'); |
|
| 284 | + $this->assertFalse(in_array($id, $tagger->getIdsForTag('Family'))); |
|
| 285 | + } |
|
| 286 | + |
|
| 287 | + $this->assertEquals(1, count($tagger->getTags())); |
|
| 288 | + $this->assertEquals(0, count($tagger->getIdsForTag('Family'))); |
|
| 289 | + } |
|
| 290 | + |
|
| 291 | + public function testFavorite(): void { |
|
| 292 | + $tagger = $this->tagMgr->load($this->objectType); |
|
| 293 | + $this->assertTrue($tagger->addToFavorites(1)); |
|
| 294 | + $this->assertEquals([1], $tagger->getFavorites()); |
|
| 295 | + $this->assertTrue($tagger->removeFromFavorites(1)); |
|
| 296 | + $this->assertEquals([], $tagger->getFavorites()); |
|
| 297 | + } |
|
| 298 | 298 | } |