1#@!#!123s

��JFIF�� 1#@!#!123s
: / home / earnlouq / oxyield.live / manager /
Filename : send-notifications.php
back
<?php
session_start();
error_reporting(0);
include('../../config/oxconfig.php');
include('includes/checklogin.php');
check_login();
include('includes/header.php');
include('includes/sidebar.php');
$title = "Send Notification";

require '../../vendor/autoload.php';
use Google\Auth\Credentials\ServiceAccountCredentials;
use Google\Auth\HttpHandler\HttpHandlerFactory;

if (isset($_POST['submit'])) {
    $notificationTitle = $_POST['title'];
    $notificationBody = $_POST['body'];
    $notificationImage = "https://oxyield.live/img/favicon.png";
    $notificationLink = $_POST['link'];

    if (empty($notificationTitle) || empty($notificationBody) || empty($notificationLink)) {
        $msg = "Title, Body, and Link fields are required";
        $type = "warning";
    } else {
        $dbNotificationTitle = mysqli_real_escape_string($con, $notificationTitle);
        $dbNotificationBody = mysqli_real_escape_string($con, $notificationBody);
        $dbNotificationImage = mysqli_real_escape_string($con, $notificationImage);
        $dbNotificationLink = mysqli_real_escape_string($con, $notificationLink);

        // Fetch FCM tokens
        $query = "SELECT fcm_token FROM users WHERE fcm_token IS NOT NULL";
        $result = mysqli_query($con, $query);
        $tokens = [];
        while ($row = mysqli_fetch_assoc($result)) {
            $tokens[] = $row['fcm_token'];
        }

        if (!empty($tokens)) {
            try {
                $credential = new ServiceAccountCredentials(
                    "https://www.googleapis.com/auth/firebase.messaging",
                    json_decode(file_get_contents("pvKey.json"), true)
                );

                $token = $credential->fetchAuthToken(HttpHandlerFactory::build());
                if (isset($token['error'])) {
                    error_log("Token fetch error: " . json_encode($token));
                    $msg = "Failed to authenticate with Firebase: " . $token['error_description'];
                    $type = "danger";
                } else {
                    $ch = curl_init("https://fcm.googleapis.com/v1/projects/xonabs-swift/messages:send");

                    curl_setopt($ch, CURLOPT_HTTPHEADER, [
                        'Content-Type: application/json',
                        'Authorization: Bearer ' . $token['access_token']
                    ]);

                    $errors = [];
                    foreach ($tokens as $fcmToken) {
                        $payload = json_encode([
                            "message" => [
                                "token" => $fcmToken,
                                "notification" => [
                                    "title" => $notificationTitle,
                                    "body" => $notificationBody,
                                    "image" => $notificationImage
                                ],
                                "webpush" => [
                                    "headers" => [
                                        "Urgency" => "high"
                                    ],
                                    "notification" => [
                                        "icon" => "https://oxyield.live/img/favicon.png",
                                        "badge" => "https://oxyield.live/img/favicon.png",
                                    ],
                                    "fcm_options" => [
                                        "link" => $notificationLink
                                    ]
                                ]
                            ]
                        ]);
                        
                        curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
                        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");

                        $response = curl_exec($ch);
                        $httpStatus = curl_getinfo($ch, CURLINFO_HTTP_CODE);

                        if ($httpStatus !== 200) {
                            error_log("FCM error for token $fcmToken: $response");
                            $errors[] = ['token' => $fcmToken, 'response' => $response];
                        }
                    }
                    curl_close($ch);

                    if (empty($errors)) {
                        $msg = "Notifications sent successfully!";
                        $type = "success";
                    } else {
                        $msg = "Some notifications failed. Check the log.";
                        $type = "warning";
                    }
                }
            } catch (Exception $e) {
                error_log("Firebase error: " . $e->getMessage());
                $msg = "Failed to send notifications: " . $e->getMessage();
                $type = "danger";
            }
        } else {
            $msg = "No users with valid FCM tokens found.";
            $type = "warning";
        }
    }
}
?>

<!-- Content wrapper -->
<div class="content-wrapper">
    <div class="container-xxl flex-grow-1 container-p-y">
        <h4 class="fw-bold py-3 mb-4"><span class="text-muted fw-light">Notifications /</span> Send Notification</h4>

        <div class="card mb-4">
            <h5 class="card-header">Send Notification</h5>
            <hr class="my-0" />
            <div class="card-body">
                <?php if (isset($msg)) { ?>
                    <div class="alert alert-<?php echo $type; ?>">
                        <h6 class="alert-heading fw-bold mb-1"><?php echo $type; ?></h6>
                        <p class="mb-0"><?php echo $msg; ?></p>
                    </div>
                <?php } ?>
                <form method="post" action="">
                    <div class="row">
                        <div class="mb-3 col-md-6">
                            <label class="form-label" for="title">Notification Title</label>
                            <input type="text" class="form-control" name="title" value="<?php if (isset($_POST['title'])) echo $_POST['title']; ?>" required />
                        </div>
                        <div class="mb-3 col-md-12">
                            <label class="form-label" for="body">Notification Body</label>
                            <textarea class="form-control" name="body" required><?php if (isset($_POST['body'])) echo $_POST['body']; ?></textarea>
                        </div>
                        <div class="mb-3 col-md-6">
                            <label class="form-label" for="link">Notification Link</label>
                            <input type="text" class="form-control" name="link" value="https://oxyield.live/user/" required />
                        </div>
                    </div>
                    <div class="mt-2">
                        <button type="submit" class="btn btn-primary me-2" name="submit">Send Notification</button>
                    </div>
                </form>
            </div>
        </div>
    </div>
</div>

<?php include('includes/footer.php'); ?>