# ivyforms/1.5/backend/src/Repository/Notification/NotificationRepository.php

The Innovative Form Builder – IvyForms, version 1.5. 235 lines.

- Page: https://pluginprobe.com/plugins/ivyforms/1.5/code/backend/src/Repository/Notification/NotificationRepository.php
- Raw: https://pluginprobe.com/plugins/ivyforms/1.5/raw/backend/src/Repository/Notification/NotificationRepository.php
- Modified: 2026-10-05T14:37:20+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/ivyforms/1.5/code/backend/src/Repository/Notification/NotificationRepository.php#L10-L20`.

```php
<?php

/**
 * @copyright © Melograno Venture Studio. All rights reserved.
 * @licence   See LICENCE.md for license details.
 */

namespace IvyForms\Repository\Notification;

use IvyForms\Common\Exceptions\QueryExecutionException;
use IvyForms\Entity\Notification\Notification;
use IvyForms\Factory\Notification\NotificationFactory;
use IvyForms\Repository\AbstractRepository;
use IvyForms\Repository\Notification\NotificationRepositoryInterface;
use IvyForms\Services\Translations\BackendStrings;

class NotificationRepository extends AbstractRepository implements NotificationRepositoryInterface
{
    public const FACTORY = NotificationFactory::class;

    /**
     * Add notification to the database
     *
     * @param Notification $entity
     *
     * @return int
     *
     * @throws QueryExecutionException
     */
    public function add($entity): int
    {
        $data = $entity->toArray();
        $row = $this->buildPersistRow($data);

        $result = $this->wpdb->insert(
            $this->table,
            $row['values'],
            $row['formats']
        );

        if ($result === false) {
            throw new QueryExecutionException(
                BackendStrings::getExceptionStrings()['unable_to_add_data'] . __CLASS__
            );
        }

        return $this->wpdb->insert_id;
    }

    /**
     * Update form in the database
     *
     * @param int  $id
     * @param Notification $entity
     *
     * @return bool
     *
     * @throws QueryExecutionException
     */
    public function update(int $id, $entity): bool
    {
        $data = $entity->toArray();
        $row = $this->buildPersistRow($data);

        $result = $this->wpdb->update(
            $this->table,
            $row['values'],
            ['id' => $id],
            $row['formats'],
            ['%d']
        );

        if ($result === false) {
            throw new QueryExecutionException(BackendStrings::getAllFormsStrings()['unable_to_save_data'] . __CLASS__);
        }

        return true;
    }

    /**
     * Build insert/update row values and formats, allowing Pro to append columns.
     *
     * @param array<string, mixed> $data
     * @return array{values: array<string, mixed>, formats: string[]}
     */
    private function buildPersistRow(array $data): array
    {
        $values = [
            'formId'          => (int) $data['formId'],
            'name'            => $data['name'],
            'sender'          => $data['sender'],
            'replyTo'         => $data['replyTo'],
            'receiver'        => $data['receiver'],
            'cc'              => $data['cc'],
            'bcc'             => $data['bcc'],
            'enabled'         => (int) $data['enabled'],
            'subject'         => $data['subject'],
            'message'         => $data['message'],
            'showEmptyFields' => (int) $data['showEmptyFields'],
            'smartLogic'      => wp_json_encode($data['smartLogic']),
        ];
        $formats = ['%d', '%s', '%s', '%s', '%s', '%s', '%s', '%d', '%s', '%s', '%d', '%s'];

        /**
         * Extend notification DB persist row (values + formats) for Pro columns.
         *
         * @since 1.2.0
         *
         * @param array<string, mixed> $row
         * @param array<string, mixed> $data
         */
        $filtered = apply_filters(
            'ivyforms/notification/repository_row',
            [
                'values' => $values,
                'formats' => $formats,
            ],
            $data
        );

        if (
            !is_array($filtered)
            || !isset($filtered['values'], $filtered['formats'])
            || !is_array($filtered['values'])
            || !is_array($filtered['formats'])
        ) {
            return [
                'values' => $values,
                'formats' => $formats,
            ];
        }

        return [
            'values' => $filtered['values'],
            'formats' => $filtered['formats'],
        ];
    }

    /**
     * Get all notifications by form ID.
     *
     * @param int $id
     *
     * @return array<Notification>
     * @throws QueryExecutionException
     */
    public function getAllById(int $id): array
    {
        $rows = $this->wpdb->get_results(
            $this->wpdb->prepare(
                $this->selectQuery() . " WHERE $this->table.formId = %d",
                [$id]
            ),
            ARRAY_A
        );
        if ($rows === false) {
            throw new QueryExecutionException(
                BackendStrings::getExceptionStrings()['unable_find_by_id'] . __CLASS__
            );
        }
        if (empty($rows)) {
            return [];
        }
        return array_map(function ($row) {
            return call_user_func([static::FACTORY, 'create'], $row);
        }, $rows);
    }

    /**
     * Get all active notifications by form ID.
     *
     * @param int $id
     *
     * @return array<Notification>
     * @throws QueryExecutionException
     */
    public function getAllActiveById(int $id): array
    {
        $rows = $this->wpdb->get_results(
            $this->wpdb->prepare(
                $this->selectQuery() . " WHERE $this->table.formId = %d AND $this->table.enabled = 1",
                $id
            ),
            ARRAY_A
        );
        if ($rows === false) {
            throw new QueryExecutionException(
                BackendStrings::getExceptionStrings()['unable_find_by_id'] . __CLASS__
            );
        }
        if (empty($rows)) {
            return [];
        }
        return array_map(function ($row) {
            return call_user_func([static::FACTORY, 'create'], $row);
        }, $rows);
    }

    /**
     * Define searchable columns for notifications
     *
     * @return string[]
     */
    protected function getSearchableColumns(): array
    {
        return ['name', 'receiver', 'subject'];
    }

    /**
     * Define filterable columns for notifications
     *
     * @return string[]
     */
    protected function getFilterableColumns(): array
    {
        return ['formId'];
    }

    /**
     * Define sortable columns for notifications
     *
     * @return string[]
     */
    protected function getSortableColumns(): array
    {
        return [
            'id',
            'name',
            'receiver',
            'subject',
            'enabled'
        ];
    }
}

```