­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ 'No errors encountered', 1 => 'Processing error', 2 => 'Missing device token', 3 => 'Missing topic', 4 => 'Missing payload', 5 => 'Invalid token size', 6 => 'Invalid topic size', 7 => 'Invalid payload size', 8 => 'Invalid token', self::STATUS_CODE_INTERNAL_ERROR => 'Internal error' ); protected static $apnsErrors = array( 'BadCollapseId' => 'The collapse identifier exceeds the maximum allowed size', 'BadDeviceToken' => 'The specified device token was bad. Verify that the request contains a valid token and that the token matches the environment.', 'BadExpirationDate' => 'The apns-expiration value is bad.', 'BadMessageId' => 'The apns-id value is bad.', 'BadPriority' => 'The apns-priority value is bad.', 'BadTopic' => 'The APP ID is invalid. Please enter the correct APP ID in your application settings.', 'DeviceTokenNotForTopic' => 'The device token does not match the specified topic.', 'DuplicateHeaders' => 'One or more headers were repeated.', 'IdleTimeout' => 'Idle time out.', 'MissingDeviceToken' => 'The device token is not specified in the request :path. Verify that the :path header contains the device token.', 'MissingTopic' => 'The APP ID is invalid. Please enter the correct APP ID in your application settings.', 'PayloadEmpty' => 'The message payload was empty', 'TopicDisallowed' => 'Pushing to this topic is not allowed', 'BadCertificate' => 'The certificate or password phrase is wrong. Please resubmit the right info in the application settings.', 'BadCertificateEnvironment' => 'The client certificate is for the wrong environment. Enbale/Disable the sandbox option in the application settings.', 'ExpiredProviderToken' => 'The provider token is stale and a new token should be generated', 'Forbidden' => 'The specified action is not allowed', 'InvalidProviderToken' => 'The provider token is not valid or the token signature could not be verified', 'MissingProviderToken' => 'No provider certificate was used to connect to APNs and Authorization header was missing or no provider token was specified', 'BadPath' => 'The request contained a bad :path value', 'MethodNotAllowed' => 'The specified :method was not POST', 'Unregistered' => 'The device token is inactive for the specified topic.', 'PayloadTooLarge' => 'The message payload was too large. Please minify your message text or custom payloads.', 'TooManyProviderTokenUpdates' => 'The provider token is being updated too often', 'TooManyRequests' => 'Too many requests were made consecutively to the same device token', 'InternalServerError' => 'An internal server error occurred', 'ServiceUnavailable' => 'The service is unavailable', 'Shutdown' => 'The server is shutting down' ); protected static $sendoptions = array( 'msgid' => '', 'message' => '', 'iostestmode' => 0, 'feedback' => 0, 'expire' => 0, 'ios_slide' => '', 'ios_badge' => 0, 'ios_sound' => 'default', 'ios_cavailable' => 0, 'ios_launchimg' => '', 'wp10_img' => '', 'extra_type' => '', 'extravalue' => '', 'and_extra_type' => '', 'and_extravalue' => '', 'wp_extra_type' => '', 'wp_extravalue' => '', 'wp10_extra_type' => '', 'wp10_extravalue' => '', 'bb_extra_type' => '', 'bb_extravalue' => '' ); public function __construct() { parent::__construct(); global $_wp_using_ext_object_cache; $_wp_using_ext_object_cache = null; } private static function archiveMsgLog($message, $sendtime, $sendtype, $options, $desktop_notification = array('chrome','safari','firefox')) { global $wpdb; $sendtime = date('Y-m-d H:i:s', $sendtime); if(!empty($desktop_notification)){ $desktop_notification = implode(',', $desktop_notification); } else{ $desktop_notification = ''; } $wpdb->insert($wpdb->prefix.'push_archive', array('message' => $message, 'starttime' => $sendtime, 'send_type' => $sendtype, 'desktop' => $desktop_notification, 'options' => serialize($options))); return $wpdb->insert_id; } public static function gpsRealtime() { if(isset($_GET['smpushlive'])){ if(!empty($_GET['lastupdate'])){ $lasttime = $_GET['lastupdate']; } else{ $lasttime = time()-3600; } $devices = self::$pushdb->get_results(self::parse_query("SELECT {type_name} AS devicetype,{info_name} AS deviceinfo,{latidude_name} AS latidude,{longitude_name} AS longitude FROM {tbname} WHERE {gpstime_name}>'$lasttime' AND {active_name}='1'"), 'ARRAY_A'); if($devices){ $devices[0]['lastupdate'] = (string)time(); echo json_encode($devices); } else{ echo time(); } exit; } self::loadpage('realtime_gps', 1, array()); } public static function SendPushMessage($device_token, $device_type, $message, $sendsetting = array(), $sendtime = 0) { global $wpdb; $token = array(); $token[0]['token'] = $device_token; self::$sendoptions['message'] = $message; self::$sendoptions = array_merge(self::$sendoptions, $sendsetting); if ($sendtime == 0) { $sendtime = current_time('timestamp'); } $msgid = self::archiveMsgLog($message, $sendtime, 'cronsend', self::$sendoptions); $crondata = array( 'token' => $device_token, 'device_type' => $device_type, 'sendtime' => $sendtime, 'sendoptions' => $msgid ); $wpdb->insert($wpdb->prefix.'push_cron_queue', $crondata); } public static function SendCronPush($ids, $message, $extravalue, $gettype = 'userid', $sendsetting = array(), $sendtime = 0, $channel_filter_ids=false, $gps_loc_filter=false) { global $wpdb; $inner = $select = $where = ''; if(!empty($channel_filter_ids)){ $defconid = self::$apisetting['def_connection']; $tablename = $wpdb->prefix.'push_relation'; $inner = "INNER JOIN $tablename ON($tablename.channel_id IN($channel_filter_ids) AND $tablename.connection_id='$defconid' AND $tablename.token_id={tbname}.{id_name})"; } if(!empty($gps_loc_filter['latidude']) AND ! empty($gps_loc_filter['longitude']) AND ! empty($gps_loc_filter['radius'])) { $select = ",(3959*acos(cos(radians($gps_loc_filter[latidude]))*cos(radians({tbname}.{latidude_name}))*cos(radians({tbname}.{longitude_name})-radians($gps_loc_filter[longitude]))+sin(radians($gps_loc_filter[latidude]))*sin(radians({tbname}.{latidude_name})))) AS geodistance"; if(!empty($gps_loc_filter['gps_expire'])){ $where = " AND {tbname}.{gpstime_name}>".(time()-($gps_loc_filter['gps_expire']*3600)); } $order = 'HAVING geodistance<='.$gps_loc_filter['radius'].' ORDER BY {tbname}.{id_name} ASC'; } else{ $order = 'GROUP BY {tbname}.{id_name}'; } if ($ids == 'all') { $queue = self::$pushdb->get_results(self::parse_query("SELECT {tbname}.{token_name} AS device_token,{tbname}.{type_name} AS device_type $select FROM {tbname} $inner WHERE {tbname}.{active_name}='1' $where $order")); } elseif ($gettype == 'userid') { if(is_array($ids)){ $ids = implode(',', $ids); } $queue = self::$pushdb->get_results(self::parse_query("SELECT {tbname}.{token_name} AS device_token,{tbname}.{type_name} AS device_type $select FROM {tbname} $inner WHERE {tbname}.userid IN($ids) AND {tbname}.{active_name}='1' $where $order")); } elseif ($gettype == 'tokenid') { $ids = implode(',', $ids); $queue = self::$pushdb->get_results(self::parse_query("SELECT {tbname}.{token_name} AS device_token,{tbname}.{type_name} AS device_type $select FROM {tbname} $inner WHERE {tbname}.{id_name} IN($ids) AND {tbname}.{active_name}='1' $where $order")); } elseif ($gettype == 'channel') { $defconid = self::$apisetting['def_connection']; $tablename = $wpdb->prefix.'push_relation'; $queue = self::$pushdb->get_results(self::parse_query("SELECT {tbname}.{token_name} AS device_token,{tbname}.{type_name} AS device_type $select FROM $tablename INNER JOIN {tbname} ON({tbname}.{id_name}=$tablename.token_id AND {tbname}.{active_name}='1') WHERE $tablename.channel_id IN($ids) AND $tablename.connection_id='$defconid' $where $order")); } if (!$queue) return false; self::$sendoptions['message'] = $message; if (!empty($sendsetting)) { self::$sendoptions = array_merge(self::$sendoptions, $sendsetting); } if (!empty($extravalue)) { if (is_array($extravalue)) { self::$sendoptions['extra_type'] = 'json'; self::$sendoptions['extravalue'] = (phpversion() >= 5.4) ? json_encode($extravalue, JSON_UNESCAPED_UNICODE) : json_encode($extravalue); } else { self::$sendoptions['extra_type'] = 'normal'; self::$sendoptions['extravalue'] = $extravalue; } } if ($sendtime == 0) { $sendtime = current_time('timestamp'); } $msgid = self::archiveMsgLog($message, $sendtime, 'cronsend', self::$sendoptions); foreach ($queue AS $queueone) { $crondata = array( 'token' => $queueone->device_token, 'device_type' => $queueone->device_type, 'sendtime' => $sendtime, 'sendoptions' => $msgid ); $wpdb->insert($wpdb->prefix.'push_cron_queue', $crondata); } } public static function activateTokens() { self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='1'")); self::update_counters(); wp_redirect(admin_url().'admin.php?page=smpush_send_notification'); } public static function smpush_cancelqueue() { global $wpdb; $wpdb->query("TRUNCATE `".$wpdb->prefix."push_queue`"); $wpdb->query("TRUNCATE `".$wpdb->prefix."push_feedback`"); delete_transient('smpush_post'); delete_transient('smpush_resum'); update_option('smpush_instant_send', array()); self::updateStats(); wp_redirect(admin_url().'admin.php?page=smpush_send_notification'); } public static function send_process($resumsend, $allcount = 0, $increration = 0) { self::load_jsplugins(); wp_enqueue_style('smpush-progbarstyle'); wp_enqueue_script('smpush-progbarscript'); include (smpush_dir.'/pages/send_process.php'); } public static function send_notification() { global $wpdb; $resume_mode = false; if (!empty($_GET['calculate'])) { $stats = self::calculateDevices(); echo json_encode($stats); exit; } if (!empty($_GET['savehistory'])) { update_option('smpush_history', $_POST); echo 1; exit; } if (!empty($_GET['clearhistory'])) { update_option('smpush_history', ''); echo 1; exit; } if (get_transient('smpush_resum') !== false && !isset($_GET['lastid'], $_GET['increration'])) { $_POST = get_transient('smpush_post'); $resume_mode = true; } if ($_POST) { if (isset($_POST['message'])) { $wpdb->query("TRUNCATE `".$wpdb->prefix."push_queue`"); $wpdb->query("TRUNCATE `".$wpdb->prefix."push_feedback`"); self::$sendoptions['message'] = $_POST['message']; $desktop_notification = array(); $where = ''; if(!empty($_POST['type'])){ $_POST['type'] = array_flip($_POST['type']); } if(empty($_POST['type']) || (isset($_POST['type']['ios']) && isset($_POST['type']['android']) && isset($_POST['type']['wp']) && isset($_POST['type']['bb']) && isset($_POST['type']['chrome']) && isset($_POST['type']['safari']) && isset($_POST['type']['firefox']))){ $_POST['type'] = array('all'); $desktop_notification = array('chrome','safari','firefox'); $where = ''; } elseif(!empty($_POST['type'])){ $_POST['type'] = array_flip($_POST['type']); } if (in_array('ios', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{ios_name}'"; } if (in_array('android', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{android_name}'"; } if (in_array('wp', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{wp_name}'"; } if (in_array('wp10', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{wp10_name}'"; } if (in_array('bb', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{bb_name}'"; } if (in_array('chrome', $_POST['type'])) { array_push($desktop_notification, 'chrome'); $where .= " OR {tbname}.{type_name}='{chrome_name}'"; } if (in_array('safari', $_POST['type'])) { array_push($desktop_notification, 'safari'); $where .= " OR {tbname}.{type_name}='{safari_name}'"; } if (in_array('firefox', $_POST['type'])) { array_push($desktop_notification, 'firefox'); $where .= " OR {tbname}.{type_name}='{firefox_name}'"; } if(!empty($where)){ $where = ' AND ('.ltrim($where, ' OR ').') '; } if (!empty($_POST['latidude']) AND ! empty($_POST['longitude']) AND ! empty($_POST['radius'])) { $select = ",(3959*acos(cos(radians($_POST[latidude]))*cos(radians({tbname}.{latidude_name}))*cos(radians({tbname}.{longitude_name})-radians($_POST[longitude]))+sin(radians($_POST[latidude]))*sin(radians({tbname}.{latidude_name})))) AS geodistance"; if(!empty($_POST['gps_expire'])){ $where .= " AND {tbname}.{gpstime_name}>".(time()-($_POST['gps_expire']*3600)); } $order = 'HAVING geodistance<='.$_POST['radius'].' ORDER BY {tbname}.{id_name} ASC'; } else{ $select = ''; $order = 'ORDER BY {tbname}.{id_name} ASC'; } if (!empty($_POST['inchannels_and']) OR ! empty($_POST['inchannels_or']) OR ! empty($_POST['notchannels_and']) OR ! empty($_POST['notchannels_or'])) { $defconid = self::$apisetting['def_connection']; $tablename = $wpdb->prefix.'push_relation'; //do not forget to change in calculateDevices() if you will make any changes in this query $smpush_query = self::parse_query("SELECT {tbname}.{id_name} AS token_id,{tbname}.{token_name} AS device_token,{tbname}.{type_name} AS device_type,GROUP_CONCAT($tablename.`channel_id` SEPARATOR ',') AS channelids $select FROM {tbname} INNER JOIN $tablename ON($tablename.token_id={tbname}.{id_name} AND $tablename.connection_id='$defconid') WHERE {tbname}.{active_name}='1' $where AND {tbname}.{id_name}>[lastid] GROUP BY {tbname}.{id_name} $order LIMIT 0,[limit]"); $alltokens = $wpdb->get_var(self::parse_query("SELECT COUNT(DISTINCT({tbname}.{id_name})) FROM {tbname} INNER JOIN $tablename ON($tablename.token_id={tbname}.{id_name} AND $tablename.connection_id='$defconid') WHERE {tbname}.{active_name}='1' $where")); } else { //do not forget to change in calculateDevices() if you will make any changes in this query $smpush_query = self::parse_query("SELECT {id_name} AS token_id,{token_name} AS device_token,{type_name} AS device_type $select FROM {tbname} WHERE {active_name}='1' $where AND {id_name}>[lastid] $order LIMIT 0,[limit]"); $alltokens = self::$pushdb->get_var(self::parse_query("SELECT COUNT({id_name}) FROM {tbname} WHERE {active_name}='1' $where")); } if ($alltokens === null) { wp_die('Please reconfig the default push notification database connection here'); } $feedback = (isset($_POST['feedback'])) ? 1 : 0; $iostestmode = (isset($_POST['iostestmode'])) ? 1 : 0; if (isset($_POST['feedback']) && (in_array('ios', $_POST['type']) OR in_array('all', $_POST['type']))) { $wpdb->insert($wpdb->prefix.'push_feedback', array('device_type' => 'ios')); } $_POST['feedback'] = $feedback; $_POST['iostestmode'] = $iostestmode; if ($_POST['extra_type'] == 'multi') { $json = array(); foreach ($_POST['key'] as $loop => $key) { if (!empty($key) && !empty($_POST['value'][$loop])) { $json[$key] = $_POST['value'][$loop]; } } if (empty($json)) { $_POST['extra'] = ''; $_POST['extra_type'] = ''; } else { $_POST['extra'] = (phpversion() >= 5.4) ? json_encode($json, JSON_UNESCAPED_UNICODE) : json_encode($json); $_POST['extra_type'] = 'json'; } } if ($_POST['and_extra_type'] == 'multi') { $json = array(); foreach ($_POST['and_key'] as $loop => $key) { if (!empty($key) && !empty($_POST['and_value'][$loop])) { $json[$key] = $_POST['and_value'][$loop]; } } if (empty($json)) { $_POST['and_extra'] = ''; $_POST['and_extra_type'] = ''; } else { $_POST['and_extra'] = (phpversion() >= 5.4) ? json_encode($json, JSON_UNESCAPED_UNICODE) : json_encode($json); $_POST['and_extra_type'] = 'json'; } } $options = array( 'message' => $_POST['message'], 'iostestmode' => $_POST['iostestmode'], 'feedback' => $_POST['feedback'], 'expire' => $_POST['expire'], 'desktop_link' => $_POST['desktop_link'], 'desktop_title' => $_POST['desktop_title'], 'desktop_icon' => $_POST['desktop_icon'], 'ios_slide' => $_POST['ios_slide'], 'ios_badge' => $_POST['ios_badge'], 'ios_sound' => $_POST['ios_sound'], 'ios_cavailable' => $_POST['ios_cavailable'], 'ios_launchimg' => $_POST['ios_launchimg'], 'wp10_img' => $_POST['wp10_img'], 'extra_type' => $_POST['extra_type'], 'extravalue' => $_POST['extra'], 'and_extra_type' => $_POST['and_extra_type'], 'and_extravalue' => $_POST['and_extra'], 'wp_extra_type' => $_POST['wp_extra_type'], 'wp_extravalue' => $_POST['wp_extra'], 'wp10_extra_type' => $_POST['wp10_extra_type'], 'wp10_extravalue' => $_POST['wp10_extra'], //'bb_extra_type' => $_POST['bb_extra_type'], //'bb_extravalue' => $_POST['bb_extra'], 'inchannels_and' => (empty($_POST['inchannels_and']))?array():$_POST['inchannels_and'], 'inchannels_or' => (empty($_POST['inchannels_or']))?array():$_POST['inchannels_or'], 'notchannels_and' => (empty($_POST['notchannels_and']))?array():$_POST['notchannels_and'], 'notchannels_or' => (empty($_POST['notchannels_or']))?array():$_POST['notchannels_or'] ); $sendtimeformat = $_POST['mm'].'/'.$_POST['jj'].'/'.$_POST['aa'].' '.$_POST['hh'].':'.$_POST['mn'].':00'; $options['sendtime'] = strtotime($sendtimeformat, current_time('timestamp')); $options['sendtype'] = (isset($_POST['sendnow'])) ? 'sendnow' : 'cronsend'; $options['query'] = $smpush_query; if(! $resume_mode){ $msgid = self::archiveMsgLog($options['message'], $options['sendtime'], $options['sendtype'], $options, $desktop_notification); set_transient('smpush_post', $_POST, 43200); $handler_options = array( 'token_counter' => 0, 'lastid' => 0, 'msgid' => $msgid, ); update_option('smpush_instant_send', $handler_options); } if ($alltokens == 0) $increration = 0; else $increration = ceil($alltokens / 20); self::send_process(false, $alltokens, $increration, $feedback); } else { wp_redirect(admin_url().'admin.php?page=smpush_send_notification'); } } elseif (isset($_GET['lastid'], $_GET['increration'])) { $handler_options = get_option('smpush_instant_send'); if (empty($_GET['lastid']) && !empty($handler_options['lastid'])) { $_GET['lastid'] = $handler_options['lastid']; } $message_data = $wpdb->get_row("SELECT * FROM ".$wpdb->prefix."push_archive WHERE id='$handler_options[msgid]'", ARRAY_A); $message_data['options'] = unserialize($message_data['options']); $smpush_query = $message_data['options']['query']; $options = $message_data['options']; $tokencounter = $handler_options['token_counter']; $query = str_replace(array('[lastid]', '[limit]'), array($_GET['lastid'], $_GET['increration']), $smpush_query); $tokens = self::$pushdb->get_results($query); if (!empty(self::$pushdb->last_error)) { self::jsonPrint(0, '

'.__('Please reconfig the default push notification database connection', 'smpush-plugin-lang').'

'); } if ($tokens) { if (!empty($options['inchannels_and']) OR ! empty($options['inchannels_or']) OR ! empty($options['notchannels_and']) OR ! empty($options['notchannels_or'])) { foreach ($tokens AS $token) { $lastid = $token->token_id; $token->channelids = explode(',', $token->channelids); //do not forget to change in calculateDevices() if you will make any changes in this query if (!empty($options['inchannels_and'])) { $intersect = array_intersect($token->channelids, $options['inchannels_and']); if (count($intersect) != count($options['inchannels_and'])) { continue; } } if (!empty($options['inchannels_or'])) { $bool = array_intersect($token->channelids, $options['inchannels_or']); if(empty($bool)){ continue; } } if (!empty($options['notchannels_and'])) { $bool = array_intersect($token->channelids, $options['notchannels_and']); if(!empty($bool)){ continue; } } if (!empty($options['notchannels_or'])) { $bool = array_diff($options['notchannels_or'], $token->channelids); if(empty($bool)){ continue; } } if ($options['sendtype'] == 'sendnow') { $wpdb->insert($wpdb->prefix.'push_queue', array('token' => $token->device_token, 'device_type' => $token->device_type)); } else { $wpdb->insert($wpdb->prefix.'push_cron_queue', array('token' => $token->device_token, 'device_type' => $token->device_type, 'sendtime' => $options['sendtime'], 'sendoptions' => $handler_options['msgid'])); } $tokencounter++; } } else { if ($options['sendtype'] == 'sendnow') { foreach ($tokens AS $token) { $wpdb->insert($wpdb->prefix.'push_queue', array('token' => $token->device_token, 'device_type' => $token->device_type)); $lastid = $token->token_id; $tokencounter++; } } else { foreach ($tokens AS $token) { $wpdb->insert($wpdb->prefix.'push_cron_queue', array('token' => $token->device_token, 'device_type' => $token->device_type, 'sendtime' => $options['sendtime'], 'sendoptions' => $handler_options['msgid'])); $lastid = $token->token_id; $tokencounter++; } } } $handler_options['lastid'] = $lastid; $handler_options['token_counter'] = $tokencounter; update_option('smpush_instant_send', $handler_options); set_transient('smpush_resum', 1, 43200); self::jsonPrint(1, $lastid); } delete_transient('smpush_resum'); delete_transient('smpush_post'); if ($options['sendtype'] == 'sendnow') { self::$sendoptions['message'] = $options['message']; self::updateStats(); self::updateStats('totalsend', $tokencounter); self::jsonPrint(-1, $tokencounter); } else { self::jsonPrint(-2, $tokencounter); } } else { $queuecount = $wpdb->get_var("SELECT COUNT(*) FROM ".$wpdb->prefix."push_queue"); if ($queuecount > 0) { self::send_process(true, $queuecount); } else { $params = array(); $params['all'] = self::$defconnection['counter']; $params['channels'] = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_channels ORDER BY id ASC"); $params['dbtype'] = $wpdb->get_var("SELECT dbtype FROM ".$wpdb->prefix."push_connection WHERE id='".self::$apisetting['def_connection']."'"); wp_register_script('smpush-gmap-source', 'https://maps.googleapis.com/maps/api/js?v=3.exp&key='.self::$apisetting['gmaps_apikey'], array('jquery'), SMPUSHVERSION); wp_register_script('smpush-gmap-js', smpush_jspath.'/gmap.js', array('jquery', 'smpush-gmap-source'), SMPUSHVERSION); wp_enqueue_script('postbox'); wp_enqueue_script('smpush-gmap-js'); wp_enqueue_script('smpush-select2-js'); wp_enqueue_style('smpush-select2-style'); add_thickbox(); self::$history = get_option('smpush_history', $_POST); self::loadpage('send_notification', 0, $params); } } } private static function calculateDevices() { global $wpdb; $stats = array('ios' => 0, 'android' => 0,'wp' => 0,'wp10' => 0, 'bb' => 0, 'chrome' => 0, 'safari' => 0, 'firefox' => 0); $select = $order = $where = $gpswhere = ''; $types_name = $wpdb->get_row("SELECT ios_name,android_name,wp_name,bb_name,chrome_name,safari_name,firefox_name,wp10_name FROM ".$wpdb->prefix."push_connection WHERE id='".self::$apisetting['def_connection']."'"); if(!empty($_POST['type'])){ $_POST['type'] = array_flip($_POST['type']); } if(empty($_POST['type']) || (isset($_POST['type']['ios']) && isset($_POST['type']['android']) && isset($_POST['type']['wp']) && isset($_POST['type']['wp10']) && isset($_POST['type']['bb']) && isset($_POST['type']['chrome']) && isset($_POST['type']['safari']) && isset($_POST['type']['firefox']))){ $_POST['type'] = array('all'); $where = ''; } elseif(!empty($_POST['type'])){ $_POST['type'] = array_flip($_POST['type']); } if (in_array('ios', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{ios_name}'"; } if (in_array('android', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{android_name}'"; } if (in_array('wp10', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{wp10_name}'"; } if (in_array('bb', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{bb_name}'"; } if (in_array('chrome', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{chrome_name}'"; } if (in_array('safari', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{safari_name}'"; } if (in_array('firefox', $_POST['type'])) { $where .= " OR {tbname}.{type_name}='{firefox_name}'"; } if(!empty($where)){ $where = ' AND ('.ltrim($where, ' OR ').') '; } if (!empty($_POST['latidude']) AND ! empty($_POST['longitude']) AND ! empty($_POST['radius'])) { $select = ",(3959*acos(cos(radians($_POST[latidude]))*cos(radians({tbname}.{latidude_name}))*cos(radians({tbname}.{longitude_name})-radians($_POST[longitude]))+sin(radians($_POST[latidude]))*sin(radians({tbname}.{latidude_name})))) AS geodistance"; if(!empty($_POST['gps_expire'])){ $gpswhere = " AND {tbname}.{gpstime_name}>".(time()-($_POST['gps_expire']*3600)); } $order = 'HAVING geodistance<='.$_POST['radius']; } if (!empty($_POST['inchannels_and']) OR ! empty($_POST['inchannels_or']) OR ! empty($_POST['notchannels_and']) OR ! empty($_POST['notchannels_or'])) { $defconid = self::$apisetting['def_connection']; $tablename = $wpdb->prefix.'push_relation'; $tokens = $wpdb->get_results(self::parse_query("SELECT {tbname}.{type_name} AS device_type,GROUP_CONCAT($tablename.`channel_id` SEPARATOR ',') AS channelids $select FROM {tbname} INNER JOIN $tablename ON($tablename.token_id={tbname}.{id_name} AND $tablename.connection_id='$defconid') WHERE {tbname}.{active_name}='1' $gpswhere $where GROUP BY {tbname}.{id_name} $order")); if($tokens){ foreach ($tokens AS $token) { $token->channelids = explode(',', $token->channelids); if (!empty($_POST['inchannels_and'])) { $intersect = array_intersect($token->channelids, $_POST['inchannels_and']); if (count($intersect) != count($_POST['inchannels_and'])) { continue; } } if (!empty($_POST['inchannels_or'])) { $bool = array_intersect($token->channelids, $_POST['inchannels_or']); if(empty($bool)){ continue; } } if (!empty($_POST['notchannels_and'])) { $bool = array_intersect($token->channelids, $_POST['notchannels_and']); if(!empty($bool)){ continue; } } if (!empty($_POST['notchannels_or'])) { $bool = array_diff($_POST['notchannels_or'], $token->channelids); if(empty($bool)){ continue; } } if($token->device_type == $types_name->ios_name){ $stats['ios']++; } elseif($token->device_type == $types_name->android_name){ $stats['android']++; } elseif($token->device_type == $types_name->wp_name){ $stats['wp']++; } elseif($token->device_type == $types_name->wp10_name){ $stats['wp10']++; } elseif($token->device_type == $types_name->bb_name){ $stats['bb']++; } elseif($token->device_type == $types_name->chrome_name){ $stats['chrome']++; } elseif($token->device_type == $types_name->safari_name){ $stats['safari']++; } elseif($token->device_type == $types_name->firefox_name){ $stats['firefox']++; } } } } else { if (in_array('ios', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS ios $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{ios_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['ios'] > 0){ $stats['ios'] = $tokenstats['ios']; } } if (in_array('android', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS android $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{android_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['android'] > 0){ $stats['android'] = $tokenstats['android']; } } if (in_array('wp', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS wp $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{wp_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['wp'] > 0){ $stats['wp'] = $tokenstats['wp']; } } if (in_array('wp10', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS wp10 $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{wp10_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['wp10'] > 0){ $stats['wp10'] = $tokenstats['wp10']; } } if (in_array('bb', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS bb $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{bb_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['bb'] > 0){ $stats['bb'] = $tokenstats['bb']; } } if (in_array('chrome', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS chrome $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{chrome_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['chrome'] > 0){ $stats['chrome'] = $tokenstats['chrome']; } } if (in_array('safari', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS safari $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{safari_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['safari'] > 0){ $stats['safari'] = $tokenstats['safari']; } } if (in_array('firefox', $_POST['type']) OR in_array('all', $_POST['type'])) { $tokenstats = self::$pushdb->get_row(self::parse_query("SELECT COUNT(*) AS firefox $select FROM {tbname} WHERE {active_name}='1' AND {tbname}.{type_name}='{firefox_name}' $gpswhere $order"), 'ARRAY_A'); if($tokenstats['firefox'] > 0){ $stats['firefox'] = $tokenstats['firefox']; } } } return $stats; } public static function RunQueue() { global $wpdb; $iphone_devices = array(); $android_devices = array(); $wp_devices = array(); $wp10_devices = array(); $bb_devices = array(); $chrome_devices = array(); $safari_devices = array(); $firefox_devices = array(); $icounter = $acounter = $wcounter = $w10counter = $bcounter = $ccounter = $scounter = $fcounter = 0; $handler_options = get_option('smpush_instant_send'); $message_data = $wpdb->get_row("SELECT * FROM ".$wpdb->prefix."push_archive WHERE id='$handler_options[msgid]'", ARRAY_A); if($message_data['send_type'] == 'feedback'){ self::connectFeedback(0); self::updateStats('all'); } $options = unserialize($message_data['options']); $options['msgid'] = $handler_options['msgid']; $all_count = $wpdb->get_var("SELECT COUNT(*) FROM ".$wpdb->prefix."push_queue"); $os_name = $wpdb->get_row("SELECT android_name,ios_name,wp_name,bb_name,chrome_name,safari_name,firefox_name,wp10_name FROM ".$wpdb->prefix."push_connection WHERE id='".self::$apisetting['def_connection']."'"); if ($options['iostestmode'] == 1) { $limit = 1; } else { $limit = 1000; } $queue = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->ios_name' LIMIT 0,$limit"); $queue2 = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->android_name' LIMIT 0,$limit"); $queue3 = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->wp_name' LIMIT 0,$limit"); $queue4 = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->bb_name' LIMIT 0,$limit"); $queue5 = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->chrome_name' LIMIT 0,$limit"); $queue6 = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->safari_name' LIMIT 0,$limit"); $queue7 = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->firefox_name' LIMIT 0,$limit"); $queue8 = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_queue WHERE device_type='$os_name->wp10_name' LIMIT 0,$limit"); if (!$queue && !$queue2 && !$queue3 && !$queue4 && !$queue5 && !$queue6 && !$queue7 && !$queue8) { self::connectFeedback($all_count); self::updateStats('all'); } foreach ($queue AS $queueone) { $iphone_devices[$icounter]['token'] = $queueone->token; $iphone_devices[$icounter]['id'] = $queueone->id; $icounter++; } foreach ($queue2 AS $queueone) { $android_devices['token'][$acounter] = $queueone->token; $android_devices['id'][$acounter] = $queueone->id; $acounter++; } foreach ($queue3 AS $queueone) { $wp_devices['token'][$wcounter] = $queueone->token; $wp_devices['id'][$wcounter] = $queueone->id; $wcounter++; } foreach ($queue4 AS $queueone) { $bb_devices['token'][$bcounter] = $queueone->token; $bb_devices['id'][$bcounter] = $queueone->id; $bcounter++; } foreach ($queue5 AS $queueone) { $chrome_devices['token'][$ccounter] = $queueone->token; $chrome_devices['id'][$ccounter] = $queueone->id; $ccounter++; } foreach ($queue6 AS $queueone) { $safari_devices[$scounter]['token'] = $queueone->token; $safari_devices[$scounter]['id'] = $queueone->id; $scounter++; } foreach ($queue7 AS $queueone) { $firefox_devices['token'][$fcounter] = $queueone->token; $firefox_devices['id'][$fcounter] = $queueone->id; $fcounter++; } foreach ($queue8 AS $queueone) { $wp10_devices['token'][$w10counter] = $queueone->token; $wp10_devices['id'][$w10counter] = $queueone->id; $w10counter++; } $message = $options['message']; if (!session_id()) { session_start(); } if ($icounter > 0) self::connectPush($message, $iphone_devices, 'ios', $options, true, $all_count); if ($acounter > 0) self::connectPush($message, $android_devices, 'android', $options, true, $all_count); if ($wcounter > 0) self::connectPush($message, $wp_devices, 'wp', $options, true, $all_count); if ($bcounter > 0) self::connectPush($message, $bb_devices, 'bb', $options, true, $all_count); if ($ccounter > 0) self::connectPush($message, $chrome_devices, 'chrome', $options, true, $all_count); if ($scounter > 0) self::connectPush($message, $safari_devices, 'safari', $options, true, $all_count); if ($fcounter > 0) self::connectPush($message, $firefox_devices, 'firefox', $options, true, $all_count); if ($w10counter > 0) self::connectPush($message, $wp10_devices, 'wp10', $options, true, $all_count); self::jsonPrint(1, array('message' => '', 'all_count' => $all_count)); } public static function connectPush($message, $device_token, $device_type, $options, $showerror = true, $all_count = 0, $cronjob = false) { global $wpdb; self::$cronSendOperation = $cronjob; if ($cronjob === true) { smpush_helper::$returnValue = 'cronjob'; } $message = str_replace(array('"','\''), '`', self::cleanString($message)); $sendCounter = 0; self::$sendoptions = $options; if ($device_type == 'ios' && self::$apisetting['apple_api_ver'] == 'http2') { $payload = self::getPayload($message); if (self::$sendoptions['expire'] > 0) { $expiry = current_time('timestamp') + (self::$sendoptions['expire'] * 3600); } else { $expiry = 0; } foreach ($device_token AS $key => $sDevice) { $sDevice['token'] = str_replace(array(' ', '-'), '', $sDevice['token']); if (isset($sDevice['id']) && $cronjob === false) { $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id='".$sDevice['id']."'"); } unset($device_token[$key]); if (preg_match('~^[a-f0-9]{64}$~i', $sDevice['token'])) { if(smpush_env == 'debug'){ $response = true; self::log('sent to: '.$sDevice['token']); self::log($payload); } else{ $response = self::connectAPNS($sDevice['token'], $payload, 'ios'); } if($response === false){ if (self::$sendoptions['feedback'] == 1) { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => $sDevice['token'], 'device_type' => 'ios_invalid')); } } elseif($response === -1){ self::updateStats('iosfail', 1); } elseif($response === true){ //successfull message } else{ return self::jsonPrint(0, '

'.$response.'

'); } } else { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => $sDevice['token'], 'device_type' => 'ios_invalid')); } $sendCounter++; } self::updateStats('iossend', $sendCounter, $cronjob); if (!empty($_SESSION['smpush_firstrun'])) { $_SESSION['smpush_firstrun'] = 0; self::jsonPrint(2, array('message' => '

'.__('Connection With Apple server established successfully', 'smpush-plugin-lang').'

'.'

'.__('Apple server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'ios' && self::$apisetting['apple_api_ver'] == 'ssl') { $payload = self::getPayload($message); $ctx = stream_context_create(); stream_context_set_option($ctx, 'ssl', 'local_cert', self::$apisetting['apple_cert_path']); stream_context_set_option($ctx, 'ssl', 'passphrase', self::$apisetting['apple_passphrase']); if (self::$apisetting['apple_sandbox'] == 1) { $appleserver = 'tls://gateway.sandbox.push.apple.com:2195'; } else { $appleserver = 'tls://gateway.push.apple.com:2195'; } @$fpssl = stream_socket_client($appleserver, $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx); if (!$fpssl && $showerror) { if (empty($errstr)) $errstr = __('Apple Certification error or problem with Password phrase', 'smpush-plugin-lang'); if ($err == 111) $errstr .= __(' - Contact your host to enable outgoing ports', 'smpush-plugin-lang'); elseif ($errstr == 'Connection timed out') { @fclose($fpssl); sleep(10); return self::jsonPrint(2, array('message' => '

'.__('Connection timed out or your host blocked the outgoing port 2195...System trying reconnect now', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } self::jsonPrint(0, '

'.__('Could not establish connection with SSL server', 'smpush-plugin-lang').': '.$errstr.'

'); } elseif (!$fpssl) return; elseif (!empty($_GET['firstrun'])) { $_SESSION['smpush_firstrun'] = 1; @fclose($fpssl); self::jsonPrint(2, array('message' => '

'.__('Connection With Apple server established successfully', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } if (self::$sendoptions['expire'] > 0) { $expiry = time() + (self::$sendoptions['expire'] * 3600); } else { $expiry = 0; } foreach ($device_token AS $key => $sDevice) { $sDevice['token'] = str_replace(array(' ', '-'), '', $sDevice['token']); if (isset($sDevice['id']) && $cronjob === false) { $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id='".$sDevice['id']."'"); } unset($device_token[$key]); if (preg_match('~^[a-f0-9]{64}$~i', $sDevice['token'])) { if ($expiry > 0) { @$sslwrite = chr(1).pack("N", $sDevice['id']).pack("N", $expiry).pack("n", 32).pack('H*', $sDevice['token']).pack("n", strlen($payload)).$payload; } else { @$sslwrite = chr(0).pack('n', 32).pack('H*', $sDevice['token']).pack('n', strlen($payload)).$payload; } $sslwriteLen = strlen($sslwrite); if(smpush_env == 'debug'){ $response = true; self::log('sent to: '.$sDevice['token']); self::log($payload); } elseif ($sslwriteLen !== (int) @fwrite($fpssl, $sslwrite)) { @fclose($fpssl); sleep(3); return self::jsonPrint(2, array('message' => '', 'all_count' => $all_count)); } if (!empty($_SESSION['smpush_firstrun']) OR ( self::$sendoptions['iostestmode'] == 1 AND $cronjob === false)) { stream_set_blocking($fpssl, 0); stream_set_write_buffer($fpssl, 0); $read = array($fpssl); $null = NULL; $nChangedStreams = stream_select($read, $null, $null, 0, 1000000); if ($nChangedStreams !== false && $nChangedStreams > 0) { $status = @ord(fread($fpssl, 1)); if (in_array($status, array(3, 4, 6, 7))) { @fclose($fpssl); self::jsonPrint(0, '

'.__('Apple server error', 'smpush-plugin-lang').': '.self::$_aErrorResponseMessages[$status].'

'); } if ($status == 8) { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => $sDevice['token'], 'device_type' => 'ios_invalid')); @fclose($fpssl); if (self::$sendoptions['iostestmode'] == 1) { $_SESSION['smpush_firstrun'] = 0; self::jsonPrint(2, array('message' => '

'.__('Apple server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } else { self::connectPush($message, $device_token, $device_type, $options, true, $all_count, $cronjob); } } } } if (!empty($_SESSION['smpush_firstrun'])) { $_SESSION['smpush_firstrun'] = 0; @fclose($fpssl); self::jsonPrint(2, array('message' => '

'.__('Apple server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } else { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => $sDevice['token'], 'device_type' => 'ios_invalid')); } } @fclose($fpssl); } elseif ($device_type == 'safari' && self::$apisetting['apple_api_ver'] == 'http2') { $payload = array(); $payload['aps']['alert'] = array( 'title' => self::cleanString(self::$sendoptions['desktop_title']), 'body' => $message ); if(!empty(self::$sendoptions['ios_slide'])){ $payload['aps']['alert']['action'] = self::$sendoptions['ios_slide']; } $payload['aps']['url-args'] = array(str_replace(get_bloginfo('url') , '', self::cleanString(self::$sendoptions['desktop_link']))); $payload = json_encode($payload); foreach ($device_token AS $key => $sDevice) { $sDevice['token'] = str_replace(array(' ', '-'), '', $sDevice['token']); if (isset($sDevice['id']) && $cronjob === false) { $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id='".$sDevice['id']."'"); } if(!empty(self::$sendoptions['msgid'])){ $wpdb->insert($wpdb->prefix.'push_desktop_messages', array('msgid' => self::$sendoptions['msgid'], 'token' => md5($sDevice['token']), 'type' => 'safari')); } unset($device_token[$key]); if(smpush_env == 'debug'){ $response = true; self::log('sent to: '.$sDevice['token']); self::log($payload); } else{ $response = self::connectAPNS($sDevice['token'], $payload, 'safari'); } if($response === false){ if (self::$sendoptions['feedback'] == 1) { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => $sDevice['token'], 'device_type' => 'safari_invalid')); } } elseif($response === -1){ self::updateStats('safarifail', 1); } elseif($response === true){ //successfull message } else{ return self::jsonPrint(0, '

'.$response.'

'); } $sendCounter++; } self::updateStats('safarisend', $sendCounter, $cronjob); if (!empty($_GET['safari_notify'])) { self::jsonPrint('safari_server_reponse', array('message' => '

'.__('Connection With Safari server established successfully', 'smpush-plugin-lang').'

'.__('Safari server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'safari' && self::$apisetting['apple_api_ver'] == 'ssl') { $payload = array(); $payload['aps']['alert'] = array( 'title' => self::cleanString(self::$sendoptions['desktop_title']), 'body' => $message ); if(!empty(self::$sendoptions['ios_slide'])){ $payload['aps']['alert']['action'] = self::$sendoptions['ios_slide']; } $payload['aps']['url-args'] = array(str_replace(get_bloginfo('url') , '', self::cleanString(self::$sendoptions['desktop_link']))); $payload = json_encode($payload); $ctx = stream_context_create(); stream_context_set_option($ctx, 'ssl', 'local_cert', self::$apisetting['safari_cert_path']); stream_context_set_option($ctx, 'ssl', 'passphrase', self::$apisetting['safari_passphrase']); $appleserver = 'tls://gateway.push.apple.com:2195'; @$fpssl = stream_socket_client($appleserver, $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx); if (!$fpssl && $showerror) { if (empty($errstr)) $errstr = __('Safari Certification error or problem with Password phrase', 'smpush-plugin-lang'); if ($err == 111) $errstr .= __(' - Contact your host to enable outgoing ports', 'smpush-plugin-lang'); elseif ($errstr == 'Connection timed out') { @fclose($fpssl); sleep(10); return self::jsonPrint(2, array('message' => '

'.__('Connection timed out or your host blocked the outgoing port 2195...System trying reconnect now', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } self::jsonPrint(0, '

'.__('Could not establish connection with Safari SSL server', 'smpush-plugin-lang').': '.$errstr.'

'); } elseif (!$fpssl)return; foreach ($device_token AS $key => $sDevice) { $sDevice['token'] = str_replace(array(' ', '-'), '', $sDevice['token']); if (isset($sDevice['id']) && $cronjob === false) { $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id='".$sDevice['id']."'"); } if(!empty(self::$sendoptions['msgid'])){ $wpdb->insert($wpdb->prefix.'push_desktop_messages', array('msgid' => self::$sendoptions['msgid'], 'token' => md5($sDevice['token']), 'type' => 'safari')); } unset($device_token[$key]); @$sslwrite = chr(0).pack('n', 32).pack('H*', $sDevice['token']).pack('n', strlen($payload)).$payload; $sslwriteLen = strlen($sslwrite); if(smpush_env == 'debug'){ $response = true; self::log('sent to: '.$sDevice['token']); self::log($payload); } elseif ($sslwriteLen !== (int) @fwrite($fpssl, $sslwrite)) { @fclose($fpssl); sleep(3); return self::jsonPrint(2, array('message' => '', 'all_count' => $all_count)); } } fclose($fpssl); if (!empty($_GET['safari_notify'])) { self::jsonPrint('safari_server_reponse', array('message' => '

'.__('Connection With Safari server established successfully', 'smpush-plugin-lang').'

'.__('Safari server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'wp') { $payload = array(); if (!empty(self::$sendoptions['wp_extravalue'])) { if (self::$sendoptions['wp_extra_type'] == 'normal') { $payload['relatedvalue'] = stripslashes(self::$sendoptions['wp_extravalue']); } else { $extravalue = json_decode(stripslashes(self::$sendoptions['wp_extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { $payload[$key] = stripslashes($value); } } } } elseif (!empty(self::$sendoptions['extravalue'])) { if (self::$sendoptions['extra_type'] == 'normal') { $payload['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } else { $extravalue = json_decode(stripslashes(self::$sendoptions['extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { $payload[$key] = stripslashes($value); } } } } if (!function_exists('curl_init') && $showerror) self::jsonPrint(0, '

'.__('Windows Phone: '.__('CURL Library is not support in your host', 'smpush-plugin-lang').'', 'smpush-plugin-lang').'

'); elseif (!function_exists('curl_init')) return; foreach($device_token['token'] as $key => $token){ if(smpush_env == 'debug'){ self::log('sent to: '.$token); self::log($message); self::log($payload); $response = true; } else{ $response = WindowsPhonePushNotification::push_toast($token, $message, $payload); } if (!empty($response['X-DeviceConnectionStatus']) && $response['X-DeviceConnectionStatus'] == 'Expired' && self::$sendoptions['feedback'] == 1) { self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($token)."'")); self::updateStats('wpfail', 1); } elseif ($response === false && $showerror) { self::jsonPrint(0, '

'.__('Windows Phone push notification server not responding or unauthorized response', 'smpush-plugin-lang').'

'); } } if (isset($device_token['id'])) { self::updateStats('wpsend', count($device_token['id']), $cronjob); if ($cronjob === false) { $ids = implode(',', $device_token['id']); $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id IN($ids)"); } } if (!empty($_GET['wp_notify'])) { self::jsonPrint('wp_server_reponse', array('message' => '

'.__('Connection With Windows Phone server established successfully', 'smpush-plugin-lang').'

'.__('Windows Phone server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'wp10') { $payload = array(); if (!empty(self::$sendoptions['wp10_extravalue'])) { if (self::$sendoptions['wp10_extra_type'] == 'normal') { $payload['relatedvalue'] = stripslashes(self::$sendoptions['wp10_extravalue']); } else { $extravalue = json_decode(stripslashes(self::$sendoptions['wp10_extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { $payload[$key] = stripslashes($value); } } } } elseif (!empty(self::$sendoptions['extravalue'])) { if (self::$sendoptions['extra_type'] == 'normal') { $payload['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } else { $extravalue = json_decode(stripslashes(self::$sendoptions['extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { $payload[$key] = stripslashes($value); } } } } if (!function_exists('curl_init') && $showerror) self::jsonPrint(0, '

Windows 10: '.__('CURL Library is not support in your host', 'smpush-plugin-lang').'

'); elseif (!function_exists('curl_init')) return; foreach($device_token['token'] as $key => $token){ if(smpush_env == 'debug'){ self::log('sent to: '.$token); self::log($message); self::log($payload); $response = true; } else{ $response = UniversalWindows10::pushToastWP10($token, $message, $payload, self::$sendoptions['wp10_img']); } if ($response === false) { if(self::$sendoptions['feedback'] == 1){ self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($token)."'")); self::updateStats('wp10fail', 1); } } elseif ($response !== true && $showerror) { self::jsonPrint(0, '

'.__('Windows 10 push notification server returns error', 'smpush-plugin-lang').': '.$response.'

'); } } if (isset($device_token['id'])) { self::updateStats('wp10send', count($device_token['id']), $cronjob); if ($cronjob === false) { $ids = implode(',', $device_token['id']); $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id IN($ids)"); } } if (!empty($_GET['wp10_notify'])) { self::jsonPrint('wp10_server_reponse', array('message' => '

'.__('Connection With Windows 10 server established successfully', 'smpush-plugin-lang').'

'.__('Windows 10 server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'bb') { if (!function_exists('curl_init') && $showerror) self::jsonPrint(0, '

BlackBerry: '.__('CURL Library is not support in your host', 'smpush-plugin-lang').'

'); elseif (!function_exists('curl_init')) return; $payload = array(); $payload['message'] = $message; if (!empty(self::$sendoptions['bb_extravalue'])) { if (self::$sendoptions['bb_extra_type'] == 'normal') { $payload['relatedvalue'] = stripslashes(self::$sendoptions['bb_extravalue']); } else { $extravalue = json_decode(stripslashes(self::$sendoptions['bb_extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { $payload[$key] = stripslashes($value); } } } } elseif (!empty(self::$sendoptions['extravalue'])) { if (self::$sendoptions['extra_type'] == 'normal') { $payload['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } else { $extravalue = json_decode(stripslashes(self::$sendoptions['extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { $payload[$key] = stripslashes($value); } } } } if(smpush_env == 'debug'){ $response = true; self::log('sent to: '.$device_token['token']); self::log($payload); } else{ $response = blackBerryPushNotification::pushMessage($device_token['token'], $payload, $showerror); } if (isset($device_token['id'])) { self::updateStats('bbsend', count($device_token['id']), $cronjob); if ($cronjob === false) { $ids = implode(',', $device_token['id']); $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id IN($ids)"); } if (self::$sendoptions['feedback'] == 1) { //$wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => serialize($device_token['token']), 'feedback' => $response, 'device_type' => 'bb')); } } if (!empty($_GET['bb_notify'])) { self::jsonPrint('bb_server_reponse', array('message' => '

'.__('Connection With BlackBerry server established successfully', 'smpush-plugin-lang').'

'.__('BlackBerry server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'android') { $message = html_entity_decode(preg_replace("/U\+([0-9A-F]{4,5})/", "&#x\\1;", $message), ENT_NOQUOTES, 'UTF-8'); $baseurl = 'https://fcm.googleapis.com/fcm/send'; if (self::$apisetting['android_titanium_payload'] == 1) { $data = array(); $data['payload']['android']['alert'] = $message; } elseif (self::$apisetting['android_corona_payload'] == 1) { $data = array(); $data['alert'] = $message; } else { $data = array('message' => $message); } if (!empty(self::$sendoptions['and_extravalue'])) { if (self::$sendoptions['and_extra_type'] == 'normal') { if (self::$apisetting['android_titanium_payload'] == 1) { $data['payload']['android']['relatedvalue'] = stripslashes(self::$sendoptions['and_extravalue']); } else { $data['relatedvalue'] = stripslashes(self::$sendoptions['and_extravalue']); } } else { $extravalue = json_decode(stripslashes(self::$sendoptions['and_extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { if (self::$apisetting['android_titanium_payload'] == 1 && !in_array($key, array('title', 'icon', 'badge', 'sound', 'vibrate'))) { $data['payload']['android'][$key] = stripslashes($value); } elseif (self::$apisetting['android_titanium_payload'] == 1) { $data['payload'][$key] = stripslashes($value); } else { $data[$key] = stripslashes($value); } } } } } elseif (!empty(self::$sendoptions['extravalue'])) { if (self::$sendoptions['extra_type'] == 'normal') { if (self::$apisetting['android_titanium_payload'] == 1) { $data['payload']['android']['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } else { $data['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } } else { $extravalue = json_decode(stripslashes(self::$sendoptions['extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { if (self::$apisetting['android_titanium_payload'] == 1 && !in_array($key, array('title', 'icon', 'badge', 'sound', 'vibrate'))) { $data['payload']['android'][$key] = stripslashes($value); } elseif (self::$apisetting['android_titanium_payload'] == 1) { $data['payload'][$key] = stripslashes($value); } else { $data[$key] = stripslashes($value); } } } } } $fields = array('registration_ids' => $device_token['token'], 'data' => $data); if (self::$sendoptions['expire'] > 0) { $fields['time_to_live'] = self::$sendoptions['expire'] * 3600; } $headers = array('Authorization: key='.self::$apisetting['google_apikey'], 'Content-Type: application/json'); if (!function_exists('curl_init') && $showerror) self::jsonPrint(0, '

Google: '.__('CURL Library is not support in your host', 'smpush-plugin-lang').'

'); elseif (!function_exists('curl_init')) return; $chandle = curl_init(); curl_setopt($chandle, CURLOPT_URL, $baseurl); curl_setopt($chandle, CURLOPT_POST, true); curl_setopt($chandle, CURLOPT_HTTPHEADER, $headers); curl_setopt($chandle, CURLOPT_RETURNTRANSFER, true); curl_setopt($chandle, CURLOPT_SSL_VERIFYPEER, false); if(phpversion() >= 5.4){ curl_setopt($chandle, CURLOPT_POSTFIELDS, json_encode($fields, JSON_UNESCAPED_UNICODE)); } else{ curl_setopt($chandle, CURLOPT_POSTFIELDS, json_encode($fields)); } if(smpush_env == 'debug'){ $result = true; $httpcode = 200; self::log($device_token['token']); self::log($data); } else{ $result = curl_exec($chandle); $httpcode = curl_getinfo($chandle, CURLINFO_HTTP_CODE); } if ($result === FALSE && $showerror) { self::jsonPrint(0, '

'.__('Google push notification server not responding', 'smpush-plugin-lang').'

'); } elseif ($httpcode == 503 && $showerror) { self::jsonPrint(0, '

'.__('Google push notification server not responding', 'smpush-plugin-lang').'

'); } elseif ($httpcode == 401 && $showerror) { $result = json_decode($result); if (!empty($result->results[0]->error)) self::jsonPrint(0, '

'.$result->results[0]->error.'

'); else self::jsonPrint(0, '

'.__('Invalid Google API key', 'smpush-plugin-lang').'

'); } if (isset($device_token['id'])) { self::updateStats('androidsend', count($device_token['id']), $cronjob); if ($cronjob === false) { $ids = implode(',', $device_token['id']); $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id IN($ids)"); } if (self::$sendoptions['feedback'] == 1) { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => serialize($device_token['token']), 'feedback' => $result, 'device_type' => 'android')); } } curl_close($chandle); if (!empty($_GET['google_notify'])) { self::jsonPrint(3, array('message' => '

'.__('Connection With Google server established successfully', 'smpush-plugin-lang').'

'.__('Google server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'chrome') { $baseurl = 'https://fcm.googleapis.com/fcm/send'; $data = array('message' => $message); if (!empty(self::$sendoptions['extravalue'])) { if (self::$sendoptions['extra_type'] == 'normal') { $data['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } else { $extravalue = json_decode(stripslashes(self::$sendoptions['extravalue'])); if ($extravalue) { foreach ($extravalue AS $key => $value) { $data[$key] = stripslashes($value); } } } } $fields = array('registration_ids' => $device_token['token'], 'data' => $data); if (self::$sendoptions['expire'] > 0) { $fields['time_to_live'] = self::$sendoptions['expire'] * 3600; } $headers = array('Authorization: key='.self::$apisetting['chrome_apikey'], 'Content-Type: application/json'); if (!function_exists('curl_init') && $showerror) self::jsonPrint(0, '

Google: '.__('CURL Library is not support in your host', 'smpush-plugin-lang').'

'); elseif (!function_exists('curl_init')) return; $chandle = curl_init(); curl_setopt($chandle, CURLOPT_URL, $baseurl); curl_setopt($chandle, CURLOPT_POST, true); curl_setopt($chandle, CURLOPT_HTTPHEADER, $headers); curl_setopt($chandle, CURLOPT_RETURNTRANSFER, true); curl_setopt($chandle, CURLOPT_SSL_VERIFYPEER, false); if(phpversion() >= 5.4){ curl_setopt($chandle, CURLOPT_POSTFIELDS, json_encode($fields, JSON_UNESCAPED_UNICODE)); } else{ curl_setopt($chandle, CURLOPT_POSTFIELDS, json_encode($fields)); } if(smpush_env == 'debug'){ $result = true; $httpcode = 200; self::log($device_token['token']); self::log($data); } else{ $result = curl_exec($chandle); $httpcode = curl_getinfo($chandle, CURLINFO_HTTP_CODE); } if ($result === FALSE && $showerror) { self::jsonPrint(0, '

'.__('Chrome push notification server not responding', 'smpush-plugin-lang').'

'); } elseif ($httpcode == 503 && $showerror) { self::jsonPrint(0, '

'.__('Chrome push notification server not responding', 'smpush-plugin-lang').'

'); } elseif ($httpcode == 401 && $showerror) { $result = json_decode($result); if (!empty($result->results[0]->error)) self::jsonPrint(0, '

'.$result->results[0]->error.'

'); else self::jsonPrint(0, '

'.__('Invalid Chrome API key', 'smpush-plugin-lang').'

'); } if (isset($device_token['id'])) { self::updateStats('chromesend', count($device_token['id']), $cronjob); if ($cronjob === false) { $ids = implode(',', $device_token['id']); $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id IN($ids)"); } if (self::$sendoptions['feedback'] == 1) { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => serialize($device_token['token']), 'feedback' => $result, 'device_type' => 'chrome')); } } if(!empty(self::$sendoptions['msgid'])){ foreach($device_token['token'] as $token){ $wpdb->insert($wpdb->prefix.'push_desktop_messages', array('msgid' => self::$sendoptions['msgid'], 'token' => md5($token), 'type' => 'chrome')); } } curl_close($chandle); if (!empty($_GET['chrome_notify'])) { self::jsonPrint('chrome_server_reponse', array('message' => '

'.__('Connection With Chrome server established successfully', 'smpush-plugin-lang').'

'.__('Chrome server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } elseif ($device_type == 'firefox') { $baseurl = 'https://updates.push.services.mozilla.com/wpush/v1/'; if (!function_exists('curl_init') && $showerror) self::jsonPrint(0, '

Firefox: '.__('CURL Library is not support in your host', 'smpush-plugin-lang').'

'); elseif (!function_exists('curl_init')) return; foreach($device_token['token'] as $token){ $chandle = curl_init(); curl_setopt($chandle, CURLOPT_URL, $baseurl.$token); curl_setopt($chandle, CURLOPT_POST, TRUE); curl_setopt($chandle, CURLOPT_RETURNTRANSFER, true); curl_setopt($chandle, CURLOPT_SSL_VERIFYPEER, false); if(smpush_env == 'debug'){ $result = true; $httpcode = 200; self::log('sent to: '.$token); self::log($data); } else{ $result = curl_exec($chandle); $httpcode = curl_getinfo($chandle, CURLINFO_HTTP_CODE); } if (($httpcode == 404 || $httpcode == 410) && self::$sendoptions['feedback'] == 1) { $wpdb->insert($wpdb->prefix.'push_feedback', array('tokens' => $token, 'device_type' => 'firefox')); } if(!empty(self::$sendoptions['msgid']) && $httpcode != 404){ $wpdb->insert($wpdb->prefix.'push_desktop_messages', array('msgid' => self::$sendoptions['msgid'], 'token' => md5($token), 'type' => 'firefox')); } curl_close($chandle); } if (isset($device_token['id'])) { self::updateStats('firefoxsend', count($device_token['id']), $cronjob); if ($cronjob === false) { $ids = implode(',', $device_token['id']); $wpdb->query("DELETE FROM ".$wpdb->prefix."push_queue WHERE id IN($ids)"); } } if (!empty($_GET['firefox_notify'])) { self::jsonPrint('firefox_server_reponse', array('message' => '

'.__('Connection With Firefox server established successfully', 'smpush-plugin-lang').'

'.__('Firefox server accepts the payload and start working', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } } public static function connectFeedback($all_count, $cronjob = false) { global $wpdb; self::$cronSendOperation = $cronjob; if ($cronjob === true) { smpush_helper::$returnValue = 'cronjob'; } $fail = $androidfail = $chromefail = 0; $feedbacks = $wpdb->get_results("SELECT * FROM ".$wpdb->prefix."push_feedback"); foreach ($feedbacks AS $feedback) { if ($feedback->device_type == 'ios_invalid') { self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($feedback->tokens)."'")); self::updateStats('iosfail', 1); } elseif ($feedback->device_type == 'safari_invalid') { self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($feedback->tokens)."'")); self::updateStats('safarifail', 1); } elseif ($feedback->device_type == 'android') { if (!empty($_GET['feedback_google'])) { self::jsonPrint(5, '

'.__('Start processing Google feedback queries', 'smpush-plugin-lang').'

'); } $tokens = unserialize($feedback->tokens); $result = json_decode($feedback->feedback, true); foreach ($result['results'] AS $key => $status) { if (isset($status['error'])) { if ($status['error'] == 'InvalidRegistration' || $status['error'] == 'NotRegistered' || $status['error'] == 'MismatchSenderId') { self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($tokens[$key])."'")); $androidfail++; } } } self::updateStats('androidfail', $androidfail); } elseif ($feedback->device_type == 'chrome') { if (!empty($_GET['feedback_chrome'])) { self::jsonPrint(6, '

'.__('Start processing Chrome feedback queries', 'smpush-plugin-lang').'

'); } $tokens = unserialize($feedback->tokens); $result = json_decode($feedback->feedback, true); foreach ($result['results'] AS $key => $status) { if (isset($status['error'])) { if ($status['error'] == 'InvalidRegistration' || $status['error'] == 'NotRegistered' || $status['error'] == 'MismatchSenderId') { self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($tokens[$key])."'")); $chromefail++; } } } self::updateStats('chromefail', $chromefail); } elseif ($feedback->device_type == 'firefox') { self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($feedback->tokens)."'")); self::updateStats('firefoxfail', 1); } elseif ($feedback->device_type == 'ios' && self::$apisetting['apple_api_ver'] == 'ssl' && !empty(self::$apisetting['apple_cert_path']) && !empty(self::$apisetting['apple_passphrase'])) { if (!empty($_GET['feedback_open'])) { self::jsonPrint(4, '

'.__('Start connection and reading with Apple feedback server, Maybe takes some time', 'smpush-plugin-lang').'

'); } $ctx = stream_context_create(); stream_context_set_option($ctx, 'ssl', 'local_cert', self::$apisetting['apple_cert_path']); stream_context_set_option($ctx, 'ssl', 'passphrase', self::$apisetting['apple_passphrase']); if (self::$apisetting['apple_sandbox'] == 1) { $appleserver = 'tls://feedback.sandbox.push.apple.com:2196'; } else { $appleserver = 'tls://feedback.push.apple.com:2196'; } @$fpssl = stream_socket_client($appleserver, $err, $errstr, 60, STREAM_CLIENT_CONNECT, $ctx); if (!$fpssl) { if (empty($errstr)) $errstr = __('Apple certification error or problem with Password phrase', 'smpush-plugin-lang'); if ($err == 111) $errstr .= __(' - Contact your host to enable outgoing ports', 'smpush-plugin-lang'); self::jsonPrint(0, '

'.__('Could not establish connection with SSL server', 'smpush-plugin-lang').': '.$errstr.'

'); } $nFeedbackTupleLen = self::TIME_BINARY_SIZE + self::TOKEN_LENGTH_BINARY_SIZE + self::DEVICE_BINARY_SIZE; $sBuffer = ''; while (!feof($fpssl)) { $sBuffer .= $sCurrBuffer = fread($fpssl, 8192); $nCurrBufferLen = strlen($sCurrBuffer); unset($sCurrBuffer, $nCurrBufferLen); $nBufferLen = strlen($sBuffer); if ($nBufferLen >= $nFeedbackTupleLen) { $nFeedbackTuples = floor($nBufferLen / $nFeedbackTupleLen); for ($i = 0; $i < $nFeedbackTuples; $i++) { $sFeedbackTuple = substr($sBuffer, 0, $nFeedbackTupleLen); $sBuffer = substr($sBuffer, $nFeedbackTupleLen); $aFeedback = self::_parseBinaryTuple($sFeedbackTuple); self::$pushdb->query(self::parse_query("UPDATE {tbname} SET {active_name}='0' WHERE {md5token_name}='".md5($aFeedback[deviceToken])."'")); $fail++; unset($aFeedback); } } $read = array($fpssl); $null = NULL; $nChangedStreams = stream_select($read, $null, $null, 0, 1000000); if ($nChangedStreams === false) { break; } } self::updateStats('iosfail', $fail); if ($fail > 0) { self::jsonPrint(2, array('message' => '

'.__('Reading from Apple feedback is finised, try to read again for more', 'smpush-plugin-lang').'

', 'all_count' => $all_count)); } } $wpdb->query("DELETE FROM ".$wpdb->prefix."push_feedback WHERE id='".$feedback->id."'"); } } protected static function _getPayload($message) { if (self::$apisetting['ios_titanium_payload'] == 1) { $aPayload['aps'] = array(); $aPayload['aps']['alert'] = $message; if (!empty(self::$sendoptions['ios_sound'])) { $aPayload['aps']['sound'] = stripslashes(self::$sendoptions['ios_sound']); } if (!empty(self::$sendoptions['ios_badge'])) { $aPayload['aps']['badge'] = (int)self::$sendoptions['ios_badge']; } if (!empty(self::$sendoptions['extravalue'])) { if (self::$sendoptions['extra_type'] == 'normal') { $aPayload['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } else { $extravalue = json_decode(self::$sendoptions['extravalue']); if ($extravalue) { foreach ($extravalue AS $key => $value) { $aPayload[$key] = stripslashes($value); } } } } } else { $aPayload['aps'] = array(); if (!empty(self::$sendoptions['ios_slide']) OR ! empty(self::$sendoptions['ios_launchimg'])) { $aPayload['aps']['alert']['body'] = $message; if (!empty(self::$sendoptions['ios_slide'])) { $aPayload['aps']['alert']['action-loc-key'] = stripslashes(self::$sendoptions['ios_slide']); } if (!empty(self::$sendoptions['ios_launchimg'])) { $aPayload['aps']['alert']['launch-image'] = stripslashes(self::$sendoptions['ios_launchimg']); } } else { $aPayload['aps']['alert'] = $message; } if (!empty(self::$sendoptions['ios_sound'])) { $aPayload['aps']['sound'] = stripslashes(self::$sendoptions['ios_sound']); } if (!empty(self::$sendoptions['ios_cavailable'])) { $aPayload['aps']['content-available'] = self::$sendoptions['ios_cavailable']; } if (!empty(self::$sendoptions['ios_badge'])) { $aPayload['aps']['badge'] = (int)self::$sendoptions['ios_badge']; } if (!empty(self::$sendoptions['extravalue'])) { if (self::$sendoptions['extra_type'] == 'normal') { if (self::$apisetting['android_corona_payload'] == 1) { $aPayload['aps']['custom'] = json_encode(array('relatedvalue' => stripslashes(self::$sendoptions['extravalue']))); } else{ $aPayload['aps']['relatedvalue'] = stripslashes(self::$sendoptions['extravalue']); } } elseif (self::$apisetting['android_corona_payload'] == 1) { $aPayload['aps']['custom'] = self::$sendoptions['extravalue']; } else { $extravalue = json_decode(self::$sendoptions['extravalue']); if ($extravalue) { foreach ($extravalue AS $key => $value) { $aPayload['aps'][$key] = stripslashes($value); } } } } } return $aPayload; } protected static function getPayload($message) { $message = html_entity_decode(preg_replace("/U\+([0-9A-F]{4,5})/", "&#x\\1;", $message), ENT_NOQUOTES, 'UTF-8'); if (phpversion() < 5.3 OR self::$apisetting['stop_summarize'] == 1) { return json_encode(self::_getPayload($message)); } @$sJSON = json_encode(self::_getPayload($message), defined('JSON_UNESCAPED_UNICODE') ? JSON_UNESCAPED_UNICODE : 0); if (!defined('JSON_UNESCAPED_UNICODE') && function_exists('mb_convert_encoding')) { $sJSON = preg_replace_callback('~\\\\u([0-9a-f]{4})~i', create_function('$aMatches', 'return mb_convert_encoding(pack("H*", $aMatches[1]), "UTF-8", "UTF-16");'), $sJSON); } $sJSONPayload = str_replace('"aps":[]', '"aps":{}', $sJSON); $nJSONPayloadLen = strlen($sJSONPayload); if ($nJSONPayloadLen > 256) { $nMaxTextLen = $nTextLen = strlen($message) - ($nJSONPayloadLen - 256); if ($nMaxTextLen > 0) { while (strlen($message = mb_substr($message, 0, --$nTextLen, 'UTF-8')) > $nMaxTextLen); return self::getPayload($message); } else { self::jsonPrint(0, '

Apple notification message is too long: '.$nJSONPayloadLen.' bytes. Maximum size is 256 bytes

'); } } return $sJSONPayload; } protected static function connectAPNS($deviceToken, $payload, $platform) { if (!defined('CURL_HTTP_VERSION_2_0')) { define('CURL_HTTP_VERSION_2_0', 3); } if($platform == 'safari'){ $cert = self::$apisetting['safari_cert_path']; $passphrase = self::$apisetting['safari_passphrase']; $appid = self::$apisetting['safari_web_id']; $serverAPNS = 'https://api.push.apple.com/3/device/'; } else{ $cert = self::$apisetting['apple_cert_path']; $passphrase = self::$apisetting['apple_passphrase']; $appid = self::$apisetting['apple_appid']; if (self::$apisetting['apple_sandbox'] == 1) { $serverAPNS = 'https://api.development.push.apple.com/3/device/'; } else { $serverAPNS = 'https://api.push.apple.com/3/device/'; } } $chandle = curl_init(); curl_setopt($chandle, CURLOPT_URL, $serverAPNS.$deviceToken); curl_setopt($chandle, CURLOPT_PORT, 443); curl_setopt($chandle, CURLOPT_POST, true); curl_setopt($chandle, CURLOPT_HTTPHEADER, array('apns-topic: '.$appid)); curl_setopt($chandle, CURLOPT_RETURNTRANSFER, true); curl_setopt($chandle, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($chandle, CURLOPT_SSLCERT, $cert); curl_setopt($chandle, CURLOPT_SSLCERTPASSWD, $passphrase); curl_setopt($chandle, CURLOPT_POSTFIELDS, $payload); curl_setopt($chandle, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_2_0); $response = curl_exec($chandle); $httpcode = curl_getinfo($chandle, CURLINFO_HTTP_CODE); curl_close($chandle); if (!empty($response)) { $response = json_decode($response, true); if(isset(self::$apnsErrors[$response['reason']])){ $failMSG = self::$apnsErrors[$response['reason']]; } else{ $failMSG = ''; } } switch ($httpcode) { case 200: return true; case 400: if ($response['reason'] == 'BadDeviceToken' || $response['reason'] == 'DeviceTokenNotForTopic') { //invalid device token return false; } else { return($failMSG); } break; case 403: return($failMSG); case 404: return($failMSG); case 405: return($failMSG); case 410: //invalid device token return false; case 413: return($failMSG); case 429: //not received return -1; case 500: return($failMSG); case 503: return($failMSG); case 0: return('Server must be installed CURL version >= 7.46 and OpenSSL version >= 1.0.2e with HTTP/2 enabled'); } } public static function updateStats($index = '', $value = 0, $cronjob = false) { if (self::$cronSendOperation === true OR $cronjob === true) { $transient = 'smpush_cron_stats'; } else { $transient = 'smpush_stats'; } if (empty($index)) { if (self::$cronSendOperation === false AND $cronjob === false AND ! empty(self::$sendoptions['message'])) { $handler_options = get_option('smpush_instant_send'); $archiveid = $handler_options['msgid']; } else { $archiveid = 0; } $stats = array('totalsend' => 0, 'iossend' => 0, 'iosfail' => 0, 'androidsend' => 0, 'androidfail' => 0, 'wpsend' => 0, 'wpfail' => 0, 'wp10send' => 0, 'wp10fail' => 0, 'bbsend' => 0, 'bbfail' => 0, 'chromesend' => 0, 'chromefail' => 0, 'safarisend' => 0, 'safarifail' => 0, 'firefoxsend' => 0, 'firefoxfail' => 0, 'archiveid' => $archiveid); update_option($transient, $stats); return; } $stats = get_option($transient); if ($index == 'all') { $stats['totalfail'] = $stats['iosfail'] + $stats['androidfail'] + $stats['wpfail'] + $stats['wp10fail'] + $stats['bbfail'] + $stats['chromefail'] + $stats['safarifail'] + $stats['firefoxfail']; $archid = $stats['archiveid']; unset($stats['archiveid']); $result = self::printReport($stats); if (self::$cronSendOperation === true) { return $stats; } global $wpdb; $wpdb->update($wpdb->prefix.'push_archive', array('endtime' => date('Y-m-d H:i:s')), array('id' => $archid)); $wpdb->insert($wpdb->prefix.'push_archive_reports', array('msgid' => $archid, 'report_time' => current_time('timestamp'), 'report' => serialize($stats))); return self::jsonPrint(-1, $result); } if ($index == 'totalsend') { if ($stats[$index] > 0) return; } $stats[$index] = $stats[$index] + $value; update_option($transient, $stats); } public static function printReport($stats) { if (isset($stats['error'])) { return '

'.$stats['error'].'

'; } $result = '

IOS '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['iossend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver or invalid tokens', 'smpush-plugin-lang').': '.$stats['iosfail'].' '.__('device token', 'smpush-plugin-lang').'

'; $result .= '

Android '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['androidsend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Successful delivered', 'smpush-plugin-lang').': '.($stats['androidsend'] - $stats['androidfail']).' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver and invalid tokens', 'smpush-plugin-lang').': '.$stats['androidfail'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

Windows Phone '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['wpsend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Successful delivered', 'smpush-plugin-lang').': '.($stats['wpsend'] - $stats['wpfail']).' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver and invalid tokens', 'smpush-plugin-lang').': '.$stats['wpfail'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

Blackberry '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['bbsend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Successful delivered', 'smpush-plugin-lang').': '.($stats['bbsend'] - $stats['bbfail']).' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver and invalid tokens', 'smpush-plugin-lang').': '.$stats['bbfail'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

Windows 10 '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['wp10send'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Successful delivered', 'smpush-plugin-lang').': '.($stats['wp10send'] - $stats['wp10fail']).' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver and invalid tokens', 'smpush-plugin-lang').': '.$stats['wp10fail'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

Chrome '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['chromesend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Successful delivered', 'smpush-plugin-lang').': '.($stats['chromesend'] - $stats['chromefail']).' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver and invalid tokens', 'smpush-plugin-lang').': '.$stats['chromefail'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

Safari '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['safarisend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Successful delivered', 'smpush-plugin-lang').': '.($stats['safarisend'] - $stats['safarifail']).' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver and invalid tokens', 'smpush-plugin-lang').': '.$stats['safarifail'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

Firefox '.__('Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent messages', 'smpush-plugin-lang').': '.$stats['firefoxsend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Successful delivered', 'smpush-plugin-lang').': '.($stats['firefoxsend'] - $stats['firefoxfail']).' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver and invalid tokens', 'smpush-plugin-lang').': '.$stats['firefoxfail'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Total Report', 'smpush-plugin-lang').':

'; $result .= '

'.__('Total sent', 'smpush-plugin-lang').': '.$stats['totalsend'].' '.__('message', 'smpush-plugin-lang').'

'; $result .= '

'.__('Failure to deliver or invalid tokens', 'smpush-plugin-lang').': '.$stats['totalfail'].' '.__('device token', 'smpush-plugin-lang').'

'; return $result; } public static function SendPush($ids, $message, $extravalue) {return;} protected static function _parseBinaryTuple($sBinaryTuple) { return unpack('Ntimestamp/ntokenLength/H*deviceToken', $sBinaryTuple); } }