Spaces:
Sleeping
Sleeping
File size: 5,069 Bytes
07c3cdd | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 | <?php
/**
* Class PushMessageIOS
* Class to send push notifications for iOS
* Example usage
*
* $ios = new PushMessageIOS($passphrase);
* $ios->setDevices($devicesToken);
* $response = $an->send($message);
*
*/
namespace ProcessMaker\BusinessModel\Light;
use ProcessMaker\Core\System;
class PushMessageIOS
{
private $url = 'ssl://gateway.sandbox.push.apple.com:2195';
private $passphrase = "sample";
private $pemFile = 'mobileios.pem';
private $devices = array();
private $response = array();
private $numberDevices = 0;
/**
* Sete server notification Ios
* @param $url string the url server
*/
public function setUrl($url)
{
$this->url = $url;
}
/**
* Set key passphrase
* @param string $passphrase update your private key's
*/
public function setKey($passphrase)
{
$this->passphrase = $passphrase;
}
/**
* Set name file .pem
* @param string $file name file .pem
*/
public function setPemFile($file)
{
$file = file_exists(PATH_CONFIG . $file) ? $file : 'mobileios.pem';
$this->pemFile = $file;
}
/**
* Set the devices token to send to
* @param array $devicesToken of device tokens to send to
*/
public function setDevices($devicesToken)
{
if (is_array($devicesToken)) {
$this->devices = $devicesToken;
} else {
$this->devices = array($devicesToken);
}
}
/**
* Set the setting value config
*/
public function setSettingNotification()
{
$conf = System::getSystemConfiguration(PATH_CONFIG . 'mobile.ini');
$this->setUrl($conf['apple']['url']);
$this->setKey($conf['apple']['passphrase']);
$this->setPemFile($conf['apple']['pemFile']);
}
/**
* Send the message to the device
* @param $message string the message to send
* @param $data object for payload body
* @return array
* @throws \Exception
*/
public function send($message, $data)
{
$this->numberDevices = count($this->devices);
if (!is_array($this->devices) || $this->numberDevices == 0) {
$this->error("No devices set");
}
if (strlen($this->passphrase) < 8) {
$this->error("Server API Key not set");
}
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', PATH_CONFIG . $this->pemFile);
stream_context_set_option($ctx, 'ssl', 'passphrase', $this->passphrase);
// Open a connection to the APNS server
// $fp = stream_socket_client(
// $this->url, $err,
// $errstr, 60, STREAM_CLIENT_CONNECT|STREAM_CLIENT_PERSISTENT, $ctx);
// if (!$fp)
// exit("Failed to connect: $err $errstr" . PHP_EOL);
$alert = new \stdClass();
$alert->{'loc-key'} = $data['taskAssignType'];
$alert->{'loc-args'} = array($message);
// Create the payload body
if (!is_null($data)) {
$body['aps'] = array(
'alert' => $alert,
'sound' => 'default',
'data' => $data
);
} else {
$body['aps'] = array(
'alert' => $alert,
'sound' => 'default'
);
}
// Encode the payload as JSON
$payload = json_encode($body);
// // Build the binary notification
// $msg = chr(0) . pack('n', 32) . pack('H*', $this->devices) . pack('n', strlen($payload)) . $payload;
//
// // Send it to the server
// $result = fwrite($fp, $msg, strlen($msg));
// fclose($fp);
foreach ($this->devices as $item) {
// Open a connection to the APNS server
$fp = stream_socket_client($this->url, $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
throw (new \Exception(\G::LoadTranslation('ID_FAILED') . ': ' . "$err $errstr"));
} else {
//echo 'Apple service is online. ' . '<br />';
}
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $item) . pack('n', strlen($payload)) . $payload;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
if (!$result) {
$this->response['undelivered'][] = 'Undelivered message count: ' . $item;
} else {
$this->response['delivered'][] = 'Delivered message count: ' . $item;
}
if ($fp) {
fclose($fp);
//echo 'The connection has been closed by the client' . '<br />';
}
}
return $this->response;
}
public function getNumberDevices()
{
return $this->numberDevices;
}
public function error($msg)
{
echo "Android send notification failed with error:";
echo "\t" . $msg;
}
} |