. // }}} namespace Component\Posting; use App\Core\DB\DB; use App\Core\Event; use App\Core\Form; use App\Core\GSFile; use function App\Core\I18n\_m; use App\Core\Modules\Component; use App\Core\Router\Router; use App\Core\VisibilityScope; use App\Entity\Activity; use App\Entity\Actor; use App\Entity\Note; use App\Util\Common; use App\Util\Exception\BugFoundException; use App\Util\Exception\ClientException; use App\Util\Exception\DuplicateFoundException; use App\Util\Exception\RedirectException; use App\Util\Exception\ServerException; use App\Util\Form\FormFields; use App\Util\Formatting; use App\Util\HTML; use Component\Attachment\Entity\ActorToAttachment; use Component\Attachment\Entity\AttachmentToNote; use Component\Conversation\Conversation; use Component\Language\Entity\Language; use Functional as F; use Symfony\Component\Form\Extension\Core\Type\ChoiceType; use Symfony\Component\Form\Extension\Core\Type\FileType; use Symfony\Component\Form\Extension\Core\Type\SubmitType; use Symfony\Component\Form\Extension\Core\Type\TextareaType; use Symfony\Component\HttpFoundation\File\Exception\FormSizeFileException; use Symfony\Component\HttpFoundation\File\UploadedFile; use Symfony\Component\HttpFoundation\Request; use Symfony\Component\Routing\Exception\ResourceNotFoundException; use Symfony\Component\Validator\Constraints\Length; class Posting extends Component { /** * HTML render event handler responsible for adding and handling * the result of adding the note submission form, only if a user is logged in * * @throws ClientException * @throws RedirectException * @throws ServerException */ public function onAppendRightPostingBlock(Request $request, array &$res): bool { if (\is_null($user = Common::user())) { return Event::next; } $actor = $user->getActor(); $placeholder_strings = ['How are you feeling?', 'Have something to share?', 'How was your day?']; Event::handle('PostingPlaceHolderString', [&$placeholder_strings]); $placeholder = $placeholder_strings[array_rand($placeholder_strings)]; $initial_content = ''; Event::handle('PostingInitialContent', [&$initial_content]); $available_content_types = [ _m('Plain Text') => 'text/plain', ]; Event::handle('PostingAvailableContentTypes', [&$available_content_types]); $in_targets = []; Event::handle('PostingFillTargetChoices', [$request, $actor, &$in_targets]); $context_actor = null; Event::handle('PostingGetContextActor', [$request, $actor, &$context_actor]); $form_params = []; if (!empty($in_targets)) { // @phpstan-ignore-line // Add "none" option to the top of choices $in_targets = array_merge([_m('Public') => 'public'], $in_targets); $form_params[] = ['in', ChoiceType::class, ['label' => _m('In:'), 'multiple' => false, 'expanded' => false, 'choices' => $in_targets]]; } // TODO: if in group page, add GROUP visibility to the choices. $form_params[] = ['visibility', ChoiceType::class, ['label' => _m('Visibility:'), 'multiple' => false, 'expanded' => false, 'data' => 'public', 'choices' => [ _m('Public') => VisibilityScope::EVERYWHERE->value, _m('Local') => VisibilityScope::LOCAL->value, _m('Addressee') => VisibilityScope::ADDRESSEE->value, ]]]; $form_params[] = ['content', TextareaType::class, ['label' => _m('Content:'), 'data' => $initial_content, 'attr' => ['placeholder' => _m($placeholder)], 'constraints' => [new Length(['max' => Common::config('site', 'text_limit')])]]]; $form_params[] = ['attachments', FileType::class, ['label' => _m('Attachments:'), 'multiple' => true, 'required' => false, 'invalid_message' => _m('Attachment not valid.')]]; $form_params[] = FormFields::language($actor, $context_actor, label: _m('Note language'), help: _m('The selected language will be federated and added as a lang attribute, preferred language can be set up in settings')); if (\count($available_content_types) > 1) { $form_params[] = ['content_type', ChoiceType::class, [ 'label' => _m('Text format:'), 'multiple' => false, 'expanded' => false, 'data' => $available_content_types[array_key_first($available_content_types)], 'choices' => $available_content_types, ], ]; } Event::handle('PostingAddFormEntries', [$request, $actor, &$form_params]); $form_params[] = ['post_note', SubmitType::class, ['label' => _m('Post')]]; $form = Form::create($form_params); $form->handleRequest($request); if ($form->isSubmitted()) { try { if ($form->isValid()) { $data = $form->getData(); Event::handle('PostingModifyData', [$request, $actor, &$data, $form_params, $form]); if (empty($data['content']) && empty($data['attachments'])) { // TODO Display error: At least one of `content` and `attachments` must be provided throw new ClientException(_m('You must enter content or provide at least one attachment to post a note.')); } if (\is_null(VisibilityScope::tryFrom($data['visibility']))) { throw new ClientException(_m('You have selected an impossible visibility.')); } $content_type = $data['content_type'] ?? $available_content_types[array_key_first($available_content_types)]; $extra_args = []; Event::handle('AddExtraArgsToNoteContent', [$request, $actor, $data, &$extra_args, $form_params, $form]); $target = !\array_key_exists('in', $data) || $data['in'] === 'public' ? $context_actor : null; self::storeLocalNote( actor: $user->getActor(), content: $data['content'], content_type: $content_type, locale: $data['language'], scope: VisibilityScope::from($data['visibility']), target: $target ?? null, // @phpstan-ignore-line reply_to_id: $data['reply_to_id'], attachments: $data['attachments'], process_note_content_extra_args: $extra_args, ); try { if ($request->query->has('from')) { $from = $request->query->get('from'); if (str_contains($from, '#')) { [$from, $fragment] = explode('#', $from); } Router::match($from); throw new RedirectException(url: $from . (isset($fragment) ? '#' . $fragment : '')); } } catch (ResourceNotFoundException $e) { // continue } throw new RedirectException(); } } catch (FormSizeFileException $e) { throw new ClientException(_m('Invalid file size given'), previous: $e); } } $res['post_form'] = $form->createView(); return Event::next; } /** * Store the given note with $content and $attachments, created by * $actor_id, possibly as a reply to note $reply_to and with flag * $is_local. Sanitizes $content and $attachments * * @param array $attachments Array of UploadedFile to be stored as GSFiles associated to this note * @param array $processed_attachments Array of [Attachment, Attachment's name] to be associated to this $actor and Note * @param array $process_note_content_extra_args Extra arguments for the event ProcessNoteContent * * @throws BugFoundException * @throws ClientException * @throws DuplicateFoundException * @throws ServerException */ public static function storeLocalNote( Actor $actor, ?string $content, string $content_type, ?string $locale = null, ?VisibilityScope $scope = null, null|Actor|int $target = null, ?int $reply_to_id = null, array $attachments = [], array $processed_attachments = [], array $process_note_content_extra_args = [], bool $notify = true, ): Note { $scope ??= VisibilityScope::EVERYWHERE; // TODO: If site is private, default to LOCAL $rendered = null; $mentions = []; if (!empty($content)) { Event::handle('RenderNoteContent', [$content, $content_type, &$rendered, $actor, $locale, &$mentions]); } $note = Note::create([ 'actor_id' => $actor->getId(), 'content' => $content, 'content_type' => $content_type, 'rendered' => $rendered, 'language_id' => !\is_null($locale) ? Language::getByLocale($locale)->getId() : null, 'is_local' => true, 'scope' => $scope, 'reply_to' => $reply_to_id, ]); /** @var UploadedFile[] $attachments */ foreach ($attachments as $f) { $filesize = $f->getSize(); $max_file_size = Common::getUploadLimit(); if ($max_file_size < $filesize) { throw new ClientException(_m('No file may be larger than {quota} bytes and the file you sent was {size} bytes. ' . 'Try to upload a smaller version.', ['quota' => $max_file_size, 'size' => $filesize], )); } Event::handle('EnforceUserFileQuota', [$filesize, $actor->getId()]); $processed_attachments[] = [GSFile::storeFileAsAttachment($f), $f->getClientOriginalName()]; } DB::persist($note); // Need file and note ids for the next step $note->setUrl(Router::url('note_view', ['id' => $note->getId()], Router::ABSOLUTE_URL)); if (!empty($content)) { Event::handle('ProcessNoteContent', [$note, $content, $content_type, $process_note_content_extra_args]); } if ($processed_attachments !== []) { foreach ($processed_attachments as [$a, $fname]) { if (DB::count('actor_to_attachment', $args = ['attachment_id' => $a->getId(), 'actor_id' => $actor->getId()]) === 0) { DB::persist(ActorToAttachment::create($args)); } DB::persist(AttachmentToNote::create(['attachment_id' => $a->getId(), 'note_id' => $note->getId(), 'title' => $fname])); } } Conversation::assignLocalConversation($note, $reply_to_id); $activity = Activity::create([ 'actor_id' => $actor->getId(), 'verb' => 'create', 'object_type' => 'note', 'object_id' => $note->getId(), 'source' => 'web', ]); DB::persist($activity); if (!\is_null($target)) { $target = \is_int($target) ? Actor::getById($target) : $target; $mentions[] = [ 'mentioned' => [$target], 'type' => match ($target->getType()) { Actor::PERSON => 'mention', Actor::GROUP => 'group', default => throw new ClientException(_m('Unknown target type give in \'In\' field: {target}', ['{target}' => $target?->getNickname() ?? ''])), }, 'text' => $target->getNickname(), ]; } $mention_ids = F\unique(F\flat_map($mentions, fn (array $m) => F\map($m['mentioned'] ?? [], fn (Actor $a) => $a->getId()))); // Flush before notification DB::flush(); if ($notify) { Event::handle('NewNotification', [$actor, $activity, ['object' => $mention_ids], _m('{nickname} created a note {note_id}.', ['{nickname}' => $actor->getNickname(), '{note_id}' => $activity->getObjectId()])]); } return $note; } public function onRenderNoteContent(string $content, string $content_type, ?string &$rendered, Actor $author, ?string $language = null, array &$mentions = []) { switch ($content_type) { case 'text/plain': $rendered = Formatting::renderPlainText($content, $language); [$rendered, $mentions] = Formatting::linkifyMentions($rendered, $author, $language); return Event::stop; case 'text/html': // TODO: It has to linkify and stuff as well $rendered = HTML::sanitize($content); return Event::stop; default: return Event::next; } } }