EmailNotificationMigration.php

<?php

namespace App\Console\Commands;

use App\Models\Forms\Form;
use App\Models\Integration\FormIntegration;
use Illuminate\Console\Command;

class EmailNotificationMigration extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'forms:email-notification-migration';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'One Time Only -- Migrate Email & Submission Notifications to new Email Integration';

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        FormIntegration::where(function ($query) {
            $query->where('integration_id', 'email')
                ->orWhere('integration_id', 'submission_confirmation');
        })->chunk(
            100,
            function ($integrations) {
                foreach ($integrations as $integration) {
                    $this->line('Process For Form: ' . $integration->form_id . ' - ' . $integration->integration_id . ' - ' . $integration->id);

                    $this->updateIntegration($integration);
                }
            }
        );

        $this->line('Migration Done');
    }

    public function updateIntegration(FormIntegration $integration)
    {
        $existingData = $integration->data;
        if ($integration->integration_id === 'email') {
            $integration->data = [
                'send_to' => $existingData->notification_emails ?? null,
                'sender_name' => 'OpnForm',
                'subject' => 'New form submission',
                'email_content' => 'Hello there 👋 <br>New form submission received.',
                'include_submission_data' => true,
                'include_hidden_fields_submission_data' => false,
                'reply_to' => $existingData->notification_reply_to ?? null
            ];
        } elseif ($integration->integration_id === 'submission_confirmation') {
            $integration->integration_id = 'email';
            $integration->data = [
                'send_to' => $this->getMentionHtml($integration->form_id),
                'sender_name' => $existingData->notification_sender,
                'subject' => $existingData->notification_subject,
                'email_content' => $existingData->notification_body,
                'include_submission_data' => $existingData->notifications_include_submission,
                'include_hidden_fields_submission_data' => false,
                'reply_to' => $existingData->confirmation_reply_to ?? null
            ];
        }
        return $integration->save();
    }

    private function getMentionHtml($formId)
    {
        $emailField = $this->getRespondentEmail($formId);
        return $emailField ? '<span mention-field-id="' . $emailField['id'] . '" mention-field-name="' . $emailField['name'] . '" mention-fallback="" contenteditable="false" mention="true">' . $emailField['name'] . '</span>' : '';
    }

    private function getRespondentEmail($formId)
    {
        $form = Form::find($formId);
        $emailFields = collect($form->properties)->filter(function ($field) {
            $hidden = $field['hidden'] ?? false;
            return !$hidden && $field['type'] == 'email';
        });

        return $emailFields->count() > 0 ? $emailFields->first() : null;
    }
}