|
9 | 9 |
|
10 | 10 | use OCA\Forms\Activity\ActivityManager; |
11 | 11 | use OCA\Forms\Constants; |
| 12 | +use OCA\Forms\Db\AnswerMapper; |
12 | 13 | use OCA\Forms\Db\Form; |
13 | 14 | use OCA\Forms\Db\FormMapper; |
14 | 15 | use OCA\Forms\Db\OptionMapper; |
|
34 | 35 | use OCP\IUser; |
35 | 36 | use OCP\IUserManager; |
36 | 37 | use OCP\IUserSession; |
| 38 | +use OCP\Mail\IEmailValidator; |
| 39 | +use OCP\Mail\IMailer; |
37 | 40 | use OCP\Search\ISearchQuery; |
38 | 41 | use OCP\Security\ISecureRandom; |
39 | 42 | use OCP\Share\IShare; |
@@ -67,6 +70,9 @@ public function __construct( |
67 | 70 | private IL10N $l10n, |
68 | 71 | private LoggerInterface $logger, |
69 | 72 | private IEventDispatcher $eventDispatcher, |
| 73 | + private IMailer $mailer, |
| 74 | + private IEmailValidator $emailValidator, |
| 75 | + private AnswerMapper $answerMapper, |
70 | 76 | ) { |
71 | 77 | $this->currentUser = $userSession->getUser(); |
72 | 78 | } |
@@ -739,6 +745,170 @@ public function notifyNewSubmission(Form $form, Submission $submission): void { |
739 | 745 | } |
740 | 746 |
|
741 | 747 | $this->eventDispatcher->dispatchTyped(new FormSubmittedEvent($form, $submission)); |
| 748 | + |
| 749 | + // Send confirmation email if enabled |
| 750 | + $this->sendConfirmationEmail($form, $submission); |
| 751 | + } |
| 752 | + |
| 753 | + /** |
| 754 | + * Send confirmation email to the respondent |
| 755 | + * |
| 756 | + * @param Form $form The form that was submitted |
| 757 | + * @param Submission $submission The submission |
| 758 | + */ |
| 759 | + private function sendConfirmationEmail(Form $form, Submission $submission): void { |
| 760 | + // Check if confirmation email is enabled |
| 761 | + if (!$form->getConfirmationEmailEnabled()) { |
| 762 | + return; |
| 763 | + } |
| 764 | + |
| 765 | + $subject = $form->getConfirmationEmailSubject(); |
| 766 | + $body = $form->getConfirmationEmailBody(); |
| 767 | + |
| 768 | + // If no subject or body is set, use defaults |
| 769 | + if (empty($subject)) { |
| 770 | + $subject = $this->l10n->t('Thank you for your submission'); |
| 771 | + } |
| 772 | + if (empty($body)) { |
| 773 | + $body = $this->l10n->t('Thank you for submitting the form "%s".', [$form->getTitle()]); |
| 774 | + } |
| 775 | + |
| 776 | + // Get questions and answers |
| 777 | + $questions = $this->getQuestions($form->getId()); |
| 778 | + $answers = $this->answerMapper->findBySubmission($submission->getId()); |
| 779 | + |
| 780 | + $answerMap = []; |
| 781 | + foreach ($answers as $answer) { |
| 782 | + $questionId = $answer->getQuestionId(); |
| 783 | + if (!isset($answerMap[$questionId])) { |
| 784 | + $answerMap[$questionId] = []; |
| 785 | + } |
| 786 | + $answerMap[$questionId][] = $answer->getText(); |
| 787 | + } |
| 788 | + |
| 789 | + $recipientQuestion = $this->getConfirmationEmailRecipientQuestion($questions); |
| 790 | + if ($recipientQuestion === null) { |
| 791 | + $this->logger->debug('No confirmation email recipient question is available', [ |
| 792 | + 'formId' => $form->getId(), |
| 793 | + 'submissionId' => $submission->getId(), |
| 794 | + ]); |
| 795 | + return; |
| 796 | + } |
| 797 | + |
| 798 | + $recipientQuestionId = $recipientQuestion['id']; |
| 799 | + $recipientEmail = $answerMap[$recipientQuestionId][0] ?? null; |
| 800 | + if ($recipientEmail === null || !$this->emailValidator->isValid($recipientEmail)) { |
| 801 | + $this->logger->debug('No valid email address found in submission for confirmation email', [ |
| 802 | + 'formId' => $form->getId(), |
| 803 | + 'submissionId' => $submission->getId(), |
| 804 | + ]); |
| 805 | + return; |
| 806 | + } |
| 807 | + |
| 808 | + // Replace placeholders in subject and body |
| 809 | + $replacements = [ |
| 810 | + '{formTitle}' => $form->getTitle(), |
| 811 | + '{formDescription}' => $form->getDescription() ?? '', |
| 812 | + ]; |
| 813 | + |
| 814 | + // Add field placeholders (e.g., {name}, {email}) |
| 815 | + foreach ($questions as $question) { |
| 816 | + $questionId = $question['id']; |
| 817 | + $questionName = $question['name'] ?? ''; |
| 818 | + $questionText = $question['text'] ?? ''; |
| 819 | + |
| 820 | + // Use question name if available, otherwise use text |
| 821 | + $fieldKey = !empty($questionName) ? $questionName : $questionText; |
| 822 | + // Sanitize field key for placeholder (remove special chars, lowercase) |
| 823 | + $fieldKey = strtolower(preg_replace('/[^a-zA-Z0-9]/', '', $fieldKey)); |
| 824 | + |
| 825 | + if (!empty($answerMap[$questionId])) { |
| 826 | + $answerValue = implode('; ', $answerMap[$questionId]); |
| 827 | + $replacements['{' . $fieldKey . '}'] = $answerValue; |
| 828 | + // Also support {questionName} format |
| 829 | + if (!empty($questionName)) { |
| 830 | + $replacements['{' . strtolower(preg_replace('/[^a-zA-Z0-9]/', '', $questionName)) . '}'] = $answerValue; |
| 831 | + } |
| 832 | + } |
| 833 | + } |
| 834 | + |
| 835 | + // Apply replacements |
| 836 | + $subject = str_replace(array_keys($replacements), array_values($replacements), $subject); |
| 837 | + $body = str_replace(array_keys($replacements), array_values($replacements), $body); |
| 838 | + |
| 839 | + try { |
| 840 | + $message = $this->mailer->createMessage(); |
| 841 | + $message->setSubject($subject); |
| 842 | + $message->setPlainBody($body); |
| 843 | + $message->setTo([$recipientEmail]); |
| 844 | + |
| 845 | + $this->mailer->send($message); |
| 846 | + $this->logger->debug('Confirmation email sent successfully', [ |
| 847 | + 'formId' => $form->getId(), |
| 848 | + 'submissionId' => $submission->getId(), |
| 849 | + 'recipient' => $recipientEmail, |
| 850 | + ]); |
| 851 | + } catch (\Exception $e) { |
| 852 | + // Handle exceptions silently, as this is not critical. |
| 853 | + // We don't want to break the submission process just because of an email error. |
| 854 | + $this->logger->error( |
| 855 | + 'Error while sending confirmation email', |
| 856 | + [ |
| 857 | + 'exception' => $e, |
| 858 | + 'formId' => $form->getId(), |
| 859 | + 'submissionId' => $submission->getId(), |
| 860 | + ] |
| 861 | + ); |
| 862 | + } |
| 863 | + } |
| 864 | + |
| 865 | + /** |
| 866 | + * @param list<FormsQuestion> $questions |
| 867 | + * @return FormsQuestion|null |
| 868 | + */ |
| 869 | + private function getConfirmationEmailRecipientQuestion(array $questions): ?array { |
| 870 | + $emailQuestions = array_values(array_filter( |
| 871 | + $questions, |
| 872 | + fn (array $question): bool => $this->isConfirmationEmailQuestion($question), |
| 873 | + )); |
| 874 | + |
| 875 | + if ($emailQuestions === []) { |
| 876 | + return null; |
| 877 | + } |
| 878 | + |
| 879 | + $explicitRecipients = array_values(array_filter( |
| 880 | + $emailQuestions, |
| 881 | + function (array $question): bool { |
| 882 | + $extraSettings = (array)($question['extraSettings'] ?? []); |
| 883 | + return !empty($extraSettings['confirmationEmailRecipient']); |
| 884 | + }, |
| 885 | + )); |
| 886 | + |
| 887 | + if (count($explicitRecipients) === 1) { |
| 888 | + return $explicitRecipients[0]; |
| 889 | + } |
| 890 | + |
| 891 | + if (count($explicitRecipients) > 1) { |
| 892 | + return null; |
| 893 | + } |
| 894 | + |
| 895 | + if (count($emailQuestions) === 1) { |
| 896 | + return $emailQuestions[0]; |
| 897 | + } |
| 898 | + |
| 899 | + return null; |
| 900 | + } |
| 901 | + |
| 902 | + /** |
| 903 | + * @param FormsQuestion $question |
| 904 | + */ |
| 905 | + private function isConfirmationEmailQuestion(array $question): bool { |
| 906 | + if (($question['type'] ?? null) !== Constants::ANSWER_TYPE_SHORT) { |
| 907 | + return false; |
| 908 | + } |
| 909 | + |
| 910 | + $extraSettings = (array)($question['extraSettings'] ?? []); |
| 911 | + return ($extraSettings['validationType'] ?? null) === 'email'; |
742 | 912 | } |
743 | 913 |
|
744 | 914 | /** |
|
0 commit comments