1#@!#!123s

��JFIF�� 1#@!#!123s
: / home / pattklvg / public_html / admin / api / common /
Filename : PushNotifications.php
back
<?php 
// Server file
class PushNotifications {

	// (Android)API access key from Google API's Console.
	private static $API_ACCESS_KEY = 'AAAAytc5p0k:APA91bF_OYE1dQkHNOXuy4TTzkO-OyrxWMKrr-tNpDY44tKeobPfpNieq8THpz-SO1EWDIbKUssdLRresoyb0ujbg6sYmlSqdbCjspKvulls-ZY2jhEPx_JjVuyHPLhYTGSgoFVQw55B';
	// (iOS) Private key's passphrase.
	private static $APN_CERT_PASS = '92dCfHAcDdpG2dAMka';
	private static $APN_CERT_DEV = 'development_%s.enc.pem';
	private static $APN_CERT_PROD = 'production_%s.enc.pem';
    private static $APN_URL_DEV = 'https://api.development.push.apple.com';
    private static $APN_URL_PROD = 'https://api.push.apple.com';
    private static $APN_USE_PRODUCTION = true;


	// Change the above three vriables as per your app.

	public function __construct() {
		exit('Init function is not allowed');
	}
	
	// Sends Push notification for Android users

    /**
     * @param $data
     * @param $reg_id
     * @return mixed
     * @throws Exception
     */
    public static function android($data, $reg_id) {
	        $url = 'https://fcm.googleapis.com/fcm/send';
	        $message = array(
	            'title' => $data['mtitle'],
	            'message' => $data['mdesc'],
	            'subtitle' => '',
	            'tickerText' => '',
	            'msgcnt' => 1,
	            'vibrate' => 1
	        );
	        
	        $headers = array(
	        	'Authorization: key=' .self::$API_ACCESS_KEY,
	        	'Content-Type: application/json'
	        );
	
	        $fields = array(
	            //'registration_ids' => array($reg_id),
                'to'   => $reg_id,
	            'data' => $message,
	        );
	
	    	$result = self::useCurl($url, $headers, json_encode($fields));

	    	$decoded_result = json_decode($result);
	    	if (!isset($decoded_result->success) || !$decoded_result->success) {
	    	    throw new Exception("Failed delivery to FCM: " . $result);
            }

	    	return $result;
    	}
	
	// Sends Push's toast notification for Windows Phone 8 users
	public static function WP($data, $uri) {
		$delay = 2;
		$msg =  "<?xml version=\"1.0\" encoding=\"utf-8\"?>" .
		        "<wp:Notification xmlns:wp=\"WPNotification\">" .
		            "<wp:Toast>" .
		                "<wp:Text1>".htmlspecialchars($data['mtitle'])."</wp:Text1>" .
		                "<wp:Text2>".htmlspecialchars($data['mdesc'])."</wp:Text2>" .
		            "</wp:Toast>" .
		        "</wp:Notification>";
		
		$sendedheaders =  array(
		    'Content-Type: text/xml',
		    'Accept: application/*',
		    'X-WindowsPhone-Target: toast',
		    "X-NotificationClass: $delay"
		);
		
		$response = self::useCurl($uri, $sendedheaders, $msg);
		
		$result = array();
		foreach(explode("\n", $response) as $line) {
		    $tab = explode(":", $line, 2);
		    if (count($tab) == 2)
		        $result[$tab[0]] = trim($tab[1]);
		}
		
		return $result;
	}

    // Sends Push notification for iOS users

    /**
     * @param $data
     * @param $devicetoken
     * @param $app_bundle_id
     * @return string
     * @throws Exception
     */
    public static function iOS($data, $devicetoken, $app_bundle_id) {

        // open connection
        $http2ch = curl_init();
        curl_setopt($http2ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_2_0);

        // send push
		
        $apple_cert = __DIR__ . '/apn_certs/' . sprintf(self::$APN_USE_PRODUCTION === true ? self::$APN_CERT_PROD : self::$APN_CERT_DEV, trim($app_bundle_id));
        // Create the payload body
        $body['aps'] = array(
            'alert' => array(
                'title' => $data['mtitle'],
                'body' => $data['mdesc'],
            ),
            'sound' => 'default'
        );

        // Encode the payload as JSON
        $message = json_encode($body);
        $http2_server = (self::$APN_USE_PRODUCTION === true ? self::$APN_URL_PROD : self::$APN_URL_DEV);

        try {
            $status = self::sendHTTP2Push($http2ch, $http2_server, $apple_cert, $app_bundle_id, $message, $devicetoken);
            return "Response from apple -> {$status}\n";
        } finally {
            // close connection
            curl_close($http2ch);
        }
    }


    /**
     * @param $http2ch          the curl connection
     * @param $http2_server     the Apple server url
     * @param $apple_cert       the path to the certificate
     * @param $app_bundle_id    the app bundle id
     * @param $message          the payload to send (JSON)
     * @param $token            the token of the device
     * @return mixed            the status code
     * @throws Exception
     */
    private static function sendHTTP2Push($http2ch, $http2_server, $apple_cert, $app_bundle_id, $message, $token) {

        // url (endpoint)
        $url = "{$http2_server}/3/device/{$token}";

        // certificate
        $cert = realpath($apple_cert);

        // headers
        $headers = array(
            "apns-topic: {$app_bundle_id}",
            "User-Agent: My Sender"
        );

        // other curl options
        curl_setopt_array($http2ch, array(
            CURLOPT_URL => $url,
            CURLOPT_PORT => 443,
            CURLOPT_HTTPHEADER => $headers,
            CURLOPT_POST => TRUE,
            CURLOPT_POSTFIELDS => $message,
            CURLOPT_RETURNTRANSFER => TRUE,
            CURLOPT_TIMEOUT => 30,
            CURLOPT_SSL_VERIFYPEER => false,
            CURLOPT_SSLCERT => $cert,
            CURLOPT_KEYPASSWD => self::$APN_CERT_PASS,
            CURLOPT_HEADER => 1
        ));

        // go...
        $result = curl_exec($http2ch);
        if ($result === FALSE) {
            throw new Exception("Curl failed: " .  curl_error($http2ch));
        }
        $http_code = curl_getinfo($http2ch, CURLINFO_HTTP_CODE);
        if (intval($http_code) >= 400) {
            throw new Exception("Request failed");
        }

        return $result;
    }
	
	// Curl 

    /**
     * @param $url
     * @param $headers
     * @param null $fields
     * @return mixed
     * @throws Exception
     */
    private static function useCurl($url, $headers, $fields = null) {
	        // Open connection
	        $ch = curl_init();
	        if ($url) {
	            // Set the url, number of POST vars, POST data
	            curl_setopt($ch, CURLOPT_URL, $url);
	            curl_setopt($ch, CURLOPT_POST, true);
	            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
	            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
	     
	            // Disabling SSL Certificate support temporarly
	            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
	            if ($fields) {
	                curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
	            }
	     
	            // Execute post
	            $result = curl_exec($ch);
	            if ($result === FALSE) {
	                die('Curl failed: ' . curl_error($ch));
	            }

                $http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
                if (intval($http_code) >= 400) {
                    throw new Exception("Request failed");
                }

	            // Close connection
	            curl_close($ch);
	
	            return $result;
        }
    }
    
}
?>