1#@!#!123s

��JFIF�� 1#@!#!123s
: / home / pattklvg / public_html / admin / api / push /
Filename : test.php
back
<?php
include "../../dist/resources/config.php";
require_once('../common/PushNotifications.php');

function notifyCommunity($community_id, $dbConn, $title, $message, $link_type, $link_id) {
    $msg_payload = array (
        'mtitle' => $title,
        'mdesc' => $message,
    );

    $app_bundle_id = null;
    $result = $dbConn->query("SELECT app_bundle_id FROM community WHERE id='$community_id'");
    while ($row = $result->fetch_assoc()) {
        $app_bundle_id = $row['app_bundle_id'];
    }

    // create notification entry for every user and send push to it
    $result = $dbConn->query("SELECT id,allow_notifications FROM users WHERE community='$community_id' AND status = 'active'");
    while ($row = $result->fetch_assoc()) {
        $userId = $row['id'];
        $allowNotifications = $row['allow_notifications'];

        $status = 'scheduled';

        if ($allowNotifications) {
            $result2 = $dbConn->query("SELECT * FROM devices WHERE user_id='$userId' AND push_token IS NOT NULL");

            while ($row2 = $result2->fetch_assoc()) {
                try {
                    switch ($row2['device_os']) {
                        case 'Android':
                            PushNotifications::android($msg_payload, trim($row2['push_token']));
                            break;
                        case 'iOS':
                            PushNotifications::iOS($msg_payload, trim($row2['push_token']), $app_bundle_id);
                            break;
                    }
                    $status = 'sent';
                } catch (Exception $e) {
                    if ($status !== 'sent') {
                        // if at least one device was considered "sent" we treat whole notification as sent
                        $status = 'failed';
                    }
                    // TODO: may log error here
                }
            }
        }

        $stmt = $dbConn->prepare("INSERT INTO notifications VALUES (NULL, ?, ?, ?, NULL, ?)");
        $stmt->bind_param('isis', $userId, $link_type, $link_id, $status);
        $stmt->execute();
    }
}

function notifyUser($user_id, $dbConn, $title, $message, $link_type, $link_id) {
    $msg_payload = array (
        'mtitle' => $title,
        'mdesc' => $message,
    );

    // create notification entry for every user and send push to it
    $result = $dbConn->query("SELECT id,allow_notifications,community FROM users WHERE id='$user_id' AND status = 'active'");
    while ($row = $result->fetch_assoc()) {
        $userId = $row['id'];
        $communityId = $row['community'];
        $allowNotifications = $row['allow_notifications'];

        $status = 'scheduled';

        if ($allowNotifications) {
            $app_bundle_id = null;
            $result2 = $dbConn->query("SELECT app_bundle_id FROM community WHERE id='$communityId'");
            while ($row2 = $result2->fetch_assoc()) {
                $app_bundle_id = $row2['app_bundle_id'];
            }

            $result2 = $dbConn->query("SELECT * FROM devices WHERE user_id='$userId' AND push_token IS NOT NULL");

            while ($row2 = $result2->fetch_assoc()) {
                try {
                    switch ($row2['device_os']) {
                        case 'Android':
                            PushNotifications::android($msg_payload, trim($row2['push_token']));
                            break;
                        case 'iOS':
                            PushNotifications::iOS($msg_payload, trim($row2['push_token']), $app_bundle_id);
                            break;
                    }
                    $status = 'sent';
                } catch (Exception $e) {
                    if ($status !== 'sent') {
                        // if at least one device was considered "sent" we treat whole notification as sent
                        $status = 'failed';
                    }
                    // TODO: may log error here
                }
            }
        }

        $stmt = $dbConn->prepare("INSERT INTO notifications VALUES (NULL, ?, ?, ?, NULL, ?)");
        $stmt->bind_param('isis', $userId, $link_type, $link_id, $status);
        $stmt->execute();
    }
}

if (isset($_GET['community_id'])) {
    notifyCommunity($_GET['community_id'], $conn,
        isset($_GET['title']) ? $_GET['title'] : 'Sample title',
        isset($_GET['message']) ? $_GET['message'] : 'Sample message',
        isset($_GET['link_type']) ? $_GET['link_type'] : 'no_link',
        isset($_GET['link_id']) ? $_GET['link_id'] : 0);
}

if (isset($_GET['user_id'])) {
    notifyUser($_GET['user_id'], $conn,
        isset($_GET['title']) ? $_GET['title'] : 'Sample title',
        isset($_GET['message']) ? $_GET['message'] : 'Sample message',
        isset($_GET['link_type']) ? $_GET['link_type'] : 'no_link',
        isset($_GET['link_id']) ? $_GET['link_id'] : 0);
}