Sid Gifari File Manager Pro v10.0.3

✏️ Editing: onesignal-notification.php Writable

<?php

require_once plugin_dir_path(__FILE__) . 'onesignal-helpers.php';
defined('ABSPATH') or die('This page may not be accessed directly.');

// Register the notification function, called when a post status changes
add_action('transition_post_status', 'onesignal_schedule_notification', 10, 3);

// Register the quick-edit handler to handle publish date changes
add_action('save_post', 'onesignal_handle_quick_edit_date_change', 10, 3);

// Register handler to cancel scheduled notifications when posts are deleted
add_action('wp_trash_post', 'onesignal_cancel_and_clear_notification');

// Display admin notices after a notification send attempt (classic editor)
add_action('admin_notices', 'onesignal_display_send_notice');

// AJAX endpoint to serve pending notices to the block editor
add_action('wp_ajax_onesignal_get_send_notice', 'onesignal_ajax_get_send_notice');

// Enqueue block editor notice script
add_action('enqueue_block_editor_assets', 'onesignal_enqueue_block_editor_notice');

/**
 * Creates and sends (or schedules) a OneSignal notification for a post.
 */
function onesignal_create_notification($post, $notification_options = array())
{
    $onesignal_wp_settings = get_option("OneSignalWPSetting");

// Cancel any existing scheduled notification for this post
    $existing_notification_id = onesignal_get_notification_id($post->ID);
    if (!empty($existing_notification_id)) {
        onesignal_cancel_notification($existing_notification_id);
    }

// Store the current publish date for future quick-edit comparisons
    update_post_meta($post->ID, 'os_previous_publish_date', $post->post_date);

// set api params - use provided options or defaults
    $title = $notification_options['title'] ?? decode_entities(get_bloginfo('name'));
    $content = $notification_options['content'] ?? $post->post_title;
    $excerpt = sanitize_content_for_excerpt($content);
    $segment = $notification_options['segment'] ?? 'All';
    $mobile_url = $notification_options['mobile_url'] ?? '';
    $config_utm_additional_url_params = $onesignal_wp_settings['utm_additional_url_params'] ?? '';

$url = get_permalink($post->ID);
    if (!empty($config_utm_additional_url_params)) {
      $utm_params = onesignal_parse_utm_parameters($config_utm_additional_url_params);
      if (!empty($utm_params)) {
        $separator = (strpos($url, '?') === false) ? '?' : '&';
        $url = $url . $separator . $utm_params;
      }
    }

$apiKeyType = onesignal_get_api_key_type();
    $authorizationHeader = $apiKeyType === "Rich"
        ? 'Key ' . get_option('OneSignalWPSetting')['app_rest_api_key']
        : 'Basic ' . get_option('OneSignalWPSetting')['app_rest_api_key'];

$args = array(
        'headers' => array(
            'Authorization' => $authorizationHeader,
            'accept' => 'application/json',
            'content-type' => 'application/json',
            'SDK-Wrapper' => onesignal_get_sdk_wrapper_header(),
        ),
        'body' => json_encode(array(
            'app_id' => get_option('OneSignalWPSetting')['app_id'],
            'headings' => array('en' => $title),
            'contents' => array('en' => $excerpt),
            'included_segments' => array($segment),
            'web_push_topic' => str_replace(' ', '-', strtolower($segment)),
            'isAnyWeb' => true,
        )),
    );

$fields = json_decode($args['body'], true);

// Conditionally send or schedule
    $postDate = new DateTime('now', new DateTimeZone('UTC'));
    $sendDate = new DateTime($post->post_date_gmt, new DateTimeZone('UTC'));

if ($sendDate > $postDate) {
        // Schedule the notification to be sent in the future
        $fields['send_after'] = $sendDate->format('Y-m-d H:i:s e');
    }

// Conditionally include mobile parameters
    if (get_option('OneSignalWPSetting')['send_to_mobile_platforms'] && get_option('OneSignalWPSetting')['send_to_mobile_platforms'] == 1) {
        $fields['isIos'] = true;
        $fields['isAndroid'] = true;
        $fields['isHuawei'] = true;
        $fields['isWP_WNS'] = true;
        if (!empty($mobile_url)) {
            $fields['app_url'] = $mobile_url;
            $fields['web_url'] = get_permalink($post->ID);
        } else {
            $fields['url'] = $url;
        }
    } else {
        $fields['url'] = $url;
    }
    // Set notification images based on the post's featured image
    if (has_post_thumbnail($post->ID)) {
        // Get the post thumbnail ID
        $post_thumbnail_id = get_post_thumbnail_id($post->ID);

// Retrieve image URLs for different sizes
        $thumbnail_size_url = wp_get_attachment_image_src($post_thumbnail_id, array(192, 192), true)[0];
        $large_size_url = wp_get_attachment_image_src($post_thumbnail_id, 'large', true)[0];

// Assign image URLs to notification fields
        $fields['firefox_icon'] =  $thumbnail_size_url;
        $fields['chrome_web_icon'] =  $thumbnail_size_url;
        $fields['chrome_web_image'] = $large_size_url;
        $fields['big_picture'] = $large_size_url;
        $fields['ios_attachments'] = [
            'id' => $large_size_url
        ];
    }

// Include any fields from onesignal_send_notification filter
    if (has_filter('onesignal_send_notification')) {
        $fields = apply_filters('onesignal_send_notification', $fields, $post->ID);
    }

$args['body'] = json_encode($fields);

if (defined('REST_REQUEST') && REST_REQUEST) return;
    $response = wp_remote_post('https://onesignal.com/api/v1/notifications', $args);
    if (is_wp_error($response)) {
        error_log('API request failed: ' . $response->get_error_message());
        onesignal_store_send_notice('error', $response->get_error_message(), $post->ID);
    } else {
        // Save the notification ID for potential future cancellation
        $response_code = wp_remote_retrieve_response_code($response);
        if ($response_code === 200) {
            $response_body = wp_remote_retrieve_body($response);
            $response_data = json_decode($response_body, true);
            $notification_id = $response_data['id'] ?? '';
            if (!empty($notification_id)) {
                onesignal_save_notification_id($post->ID, $notification_id);
                if (isset($fields['send_after'])) {
                    onesignal_store_send_notice('scheduled', $notification_id, $post->ID);
                } else {
                    onesignal_store_send_notice('success', $notification_id, $post->ID);
                }
            } else {
                // API returned 200 but empty id — no eligible subscribers
                $errors = $response_data['errors'] ?? [];
                if (is_array($errors) && isset($errors[0]) && is_string($errors[0])) {
                    $detail = str_ireplace(['players', 'player'], ['subscriptions', 'subscription'], $errors[0]);
                } else {
                    $detail = 'No eligible subscriptions found in the selected segment.';
                }
                onesignal_store_send_notice('warning', $detail, $post->ID);
            }
        } else {
            $response_body = wp_remote_retrieve_body($response);
            $response_data = json_decode($response_body, true);
            $errors = $response_data['errors'] ?? [];
            $error_message = (is_array($errors) && isset($errors[0]) && is_string($errors[0]))
                ? $errors[0]
                : wp_remote_retrieve_response_message($response);
            error_log('API request failed with status ' . $response_code . ': ' . $error_message);
            onesignal_store_send_notice('error', $error_message, $post->ID);
        }
    }
}

/**
 * Stores a notification send result in a short-lived user-scoped transient
 * so it can be displayed as an admin notice after the page redirect.
 */
function onesignal_store_send_notice($status, $detail = '', $post_id = 0)
{
    $key = 'onesignal_send_notice_' . get_current_user_id() . '_' . $post_id;
    set_transient($key, array('status' => $status, 'detail' => $detail), 60);
}

/**
 * Builds a dashboard link anchor tag for use in admin notices.
 */
function onesignal_build_dashboard_link($url, $label)
{
    if (empty($url)) return '';
    return ' <a href="' . esc_url($url) . '" target="_blank" rel="noopener noreferrer">'
        . esc_html__($label, 'onesignal')
        . '</a>';
}

/**
 * Reads the stored transient and renders a WP admin notice, then deletes it.
 */
function onesignal_display_send_notice()
{
    if (!is_admin()) return;

global $post;

$screen = get_current_screen();
    // Only show on the single-post edit screen
    if (!$screen || $screen->base !== 'post') {
        return;
    }

// In the block editor, Gutenberg fetches the redirect page in the background
    // after saving, which causes admin_notices to fire and consume the transient
    // before the JS AJAX handler can read it. Let the JS handle it instead.
    if ($screen->is_block_editor()) {
        return;
    }

$post_id = $post ? $post->ID : 0;
    $key = 'onesignal_send_notice_' . get_current_user_id() . '_' . $post_id;
    $notice = get_transient($key);
    if (!$notice) {
        return;
    }
    delete_transient($key);

$app_id = get_option('OneSignalWPSetting')['app_id'] ?? '';
    $detail = $notice['detail'] ?? '';
    $dashboard_url = (!empty($app_id) && !empty($detail))
        ? 'https://dashboard.onesignal.com/apps/' . rawurlencode($app_id) . '/push/' . rawurlencode($detail)
        : '';

switch ($notice['status']) {
        case 'success':
            $link    = onesignal_build_dashboard_link($dashboard_url, 'View the notification in the OneSignal Dashboard.');
            $message = __('Push notification sent successfully.', 'onesignal') . $link;
            $type    = 'success';
            break;
        case 'scheduled':
            $link    = onesignal_build_dashboard_link($dashboard_url, 'View the scheduled notification in the OneSignal Dashboard.');
            $message = __('Push notification scheduled.', 'onesignal')
                . $link . ' '
                . __('If you change the scheduled post time in WordPress, the existing notification will be cancelled and a new one created.', 'onesignal');
            $type    = 'info';
            break;
        case 'warning':
            $message = sprintf(
                __('Push notification not sent: %s', 'onesignal'),
                esc_html($detail)
            );
            $type = 'warning';
            break;
        case 'error':
        default:
            $message = sprintf(
                __('Push notification failed to send: %s', 'onesignal'),
                esc_html($detail)
            );
            $type = 'error';
            break;
    }

printf(
        '<div class="notice notice-%s is-dismissible"><p><strong>OneSignal:</strong> %s</p></div>',
        esc_attr($type),
        $message
    );
}

/**
 * AJAX handler that returns and clears the pending notice for the current user.
 * Used by the block editor JS after a save completes.
 */
function onesignal_ajax_get_send_notice()
{
    check_ajax_referer('onesignal_notice_nonce', 'nonce');
    $post_id = absint($_POST['post_id'] ?? 0);
    if (!current_user_can('edit_post', $post_id)) {
        wp_send_json_success(null);
    }
    $key = 'onesignal_send_notice_' . get_current_user_id() . '_' . $post_id;
    $notice = get_transient($key);
    if ($notice) {
        delete_transient($key);
        wp_send_json_success($notice);
    } else {
        wp_send_json_success(null);
    }
}

/**
 * Enqueues the block editor JS that polls for a pending notice after each save.
 */
function onesignal_enqueue_block_editor_notice()
{
    $script_path = plugin_dir_path(__FILE__) . 'onesignal-block-editor-notice.js';
    if (!file_exists($script_path)) {
        return;
    }
    wp_enqueue_script(
        'onesignal-block-editor-notice',
        plugins_url('onesignal-block-editor-notice.js', __FILE__),
        array('wp-data', 'wp-notices', 'wp-i18n'),
        filemtime($script_path),
        true
    );
    wp_localize_script('onesignal-block-editor-notice', 'onesignalNotice', array(
        'nonce'  => wp_create_nonce('onesignal_notice_nonce'),
        'ajaxUrl' => admin_url('admin-ajax.php'),
        'appId'  => get_option('OneSignalWPSetting')['app_id'] ?? '',
    ));
}

/**
 * Fires on every post status transition; sends or cancels notifications as appropriate.
 */
function onesignal_schedule_notification($new_status, $old_status, $post)
{
    if (($new_status === 'publish') || ($new_status === 'future')) {
        // check if update is on.
        $update = !empty($_POST['os_update']) ? $_POST['os_update'] : $post->os_update;

// do not send notification if not enabled
        if (empty($update)) {
            return;
        }

// Prepare notification options from POST data
        $notification_options = array(
            'title' => !empty($_POST['os_title']) ? sanitize_text_field($_POST['os_title']) : null,
            'content' => !empty($_POST['os_content']) ? sanitize_text_field($_POST['os_content']) : null,
            'segment' => $_POST['os_segment'] ?? 'All',
            'mobile_url' => $_POST['os_mobile_url'] ?? ''
        );

// Call the core notification function
        onesignal_create_notification($post, $notification_options);
    } elseif ($old_status === 'future') {
        // A scheduled post was reverted to a non-scheduled status (e.g. draft, pending).
        // Cancel the pending OneSignal notification so it isn't delivered at the old scheduled time.
        if (!onesignal_is_post_type_allowed($post->post_type)) {
            return;
        }

onesignal_cancel_and_clear_notification($post->ID);
    }
}

/**
 * Cancels and re-schedules a notification when a scheduled post's publish date is changed via quick-edit.
 */
function onesignal_handle_quick_edit_date_change($post_id, $post, $update)
{
    // Check user capability to edit this post
    if (!current_user_can('edit_post', $post_id)) {
        return;
    }

// Check if this is an autosave, revision, or not an update
    if (wp_is_post_autosave($post_id) || wp_is_post_revision($post_id) || !$update) {
        return;
    }

// Check if the post type is allowed for notifications
    if (!onesignal_is_post_type_allowed($post->post_type)) {
        return;
    }

// Only handle posts with 'future' status (scheduled posts)
    if ($post->post_status !== 'future') {
        return;
    }

// Get the previous publish date stored in post meta
    $previous_publish_date = get_post_meta($post_id, 'os_previous_publish_date', true);
    $current_publish_date = $post->post_date;

// If this is the first time we're tracking the publish date, store it and return
    if (empty($previous_publish_date)) {
        update_post_meta($post_id, 'os_previous_publish_date', $current_publish_date);
        return;
    }

// Check if the publish date has actually changed
    if ($previous_publish_date !== $current_publish_date) {
        // Cancel any existing scheduled notification for this post
        $existing_notification_id = onesignal_get_notification_id($post_id);
        if (!empty($existing_notification_id)) {
            $cancelled = onesignal_cancel_notification($existing_notification_id);
            if ($cancelled) {
                // Clear the stored notification ID since we cancelled it
                delete_post_meta($post_id, 'os_notification_id');
            }
        }

// Update the stored publish date
        update_post_meta($post_id, 'os_previous_publish_date', $current_publish_date);

// Honor the "Send notification when post is published" preference.
        $should_send = false;

// Check POST data with nonce verification
        if (!empty($_POST) && isset($_POST['onesignal_v3_metabox_nonce'])) {
            if (wp_verify_nonce($_POST['onesignal_v3_metabox_nonce'], 'onesignal_v3_metabox_save')) {
                $should_send = !empty($_POST['os_update']);
            }
        }

// Fallback to saved metadata if no POST data or failed nonce
        if (!$should_send) {
            $os_meta = get_post_meta($post_id, 'os_meta', true);
            $should_send = !empty($os_meta['os_update']);
        }

if (!$should_send) {
            return;
        }

// Create a new notification with default options (no custom title/content from metabox)
        // This will use the post title and default settings
        onesignal_create_notification($post);
    }
}

/**
 * Cancels the stored OneSignal notification, and clears its meta, on post deletion or status change (e.g. scheduled -> draft).
 */
function onesignal_cancel_and_clear_notification($post_id)
{
    $existing_notification_id = onesignal_get_notification_id($post_id);
    if (empty($existing_notification_id)) {
        return false;
    }

$cancelled = onesignal_cancel_notification($existing_notification_id);
    if ($cancelled) {
        delete_post_meta($post_id, 'os_notification_id');
        delete_post_meta($post_id, 'os_previous_publish_date');
    }
    return $cancelled;
}