diff options
author | Maxence Lange <maxence@artificial-owl.com> | 2019-10-01 13:53:26 +0200 |
---|---|---|
committer | Maxence Lange <maxence@artificial-owl.com> | 2019-10-03 10:54:03 -0100 |
commit | 1130d7ffbdd6d1a81051890586a8a8884321be03 (patch) | |
tree | dd0b270d812a4d70d7f0720f7e9dd947bbef2d25 /lib/Db/StreamTagsRequest.php | |
parent | 6ba6d86fa74f54b9264afe12dd26b54ecb355d38 (diff) |
migrate data to a specific table
Signed-off-by: Maxence Lange <maxence@artificial-owl.com>
Diffstat (limited to 'lib/Db/StreamTagsRequest.php')
-rw-r--r-- | lib/Db/StreamTagsRequest.php | 78 |
1 files changed, 78 insertions, 0 deletions
diff --git a/lib/Db/StreamTagsRequest.php b/lib/Db/StreamTagsRequest.php new file mode 100644 index 00000000..4b80d34a --- /dev/null +++ b/lib/Db/StreamTagsRequest.php @@ -0,0 +1,78 @@ +<?php +declare(strict_types=1); + + +/** + * Nextcloud - Social Support + * + * This file is licensed under the Affero General Public License version 3 or + * later. See the COPYING file. + * + * @author Maxence Lange <maxence@artificial-owl.com> + * @copyright 2018, Maxence Lange <maxence@artificial-owl.com> + * @license GNU AGPL version 3 or any later version + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License + * along with this program. If not, see <http://www.gnu.org/licenses/>. + * + */ + + +namespace OCA\Social\Db; + + +use daita\MySmallPhpTools\Traits\TStringTools; +use Doctrine\DBAL\Exception\UniqueConstraintViolationException; +use OCA\Social\Model\ActivityPub\Stream; + + +/** + * Class StreamTagsRequest + * + * @package OCA\Social\Db + */ +class StreamTagsRequest extends StreamTagsRequestBuilder { + + + use TStringTools; + + + /** + * @param Stream $stream + */ + public function generateStreamTags(Stream $stream) { + $hashtags = $stream->getTags(); + + $this->miscService->log('$$$$ ' . json_encode($hashtags)); + foreach ($hashtags as $hashtag) { + $tag = $this->get('name', $hashtag); + if ($this->get('type', $hashtag) !== 'Hashtag' || $tag === '') { + continue; + } + + $tag = substr($tag, 1); + $qb = $this->getStreamTagsInsertSql(); + $streamId = $qb->prim($stream->getId()); + $qb->setValue('stream_id', $qb->createNamedParameter($streamId)); + $qb->setValue('hashtag', $qb->createNamedParameter($tag)); + try { + $qb->execute(); + } catch (UniqueConstraintViolationException $e) { + \OC::$server->getLogger() + ->log(1, 'Social - Duplicate hashtag on Stream ' . json_encode($stream)); + } + } + } + +} + |